Lines Matching refs:ch_part
321 channel->ch_part[part].ch_fd = INVALID_FD; in add_channel()
323 channel->ch_part[part].ch_inputHandler = (XtInputId)NULL; in add_channel()
326 channel->ch_part[part].ch_inputHandler = 0; in add_channel()
328 channel->ch_part[part].ch_timeout = 2000; in add_channel()
369 if (channel->ch_part[PART_IN].ch_bufref.br_buf != NULL) in channel_still_useful()
374 has_sock_msg = channel->ch_part[PART_SOCK].ch_fd != INVALID_FD in channel_still_useful()
375 || channel->ch_part[PART_SOCK].ch_head.rq_next != NULL in channel_still_useful()
376 || channel->ch_part[PART_SOCK].ch_json_head.jq_next != NULL; in channel_still_useful()
377 has_out_msg = channel->ch_part[PART_OUT].ch_fd != INVALID_FD in channel_still_useful()
378 || channel->ch_part[PART_OUT].ch_head.rq_next != NULL in channel_still_useful()
379 || channel->ch_part[PART_OUT].ch_json_head.jq_next != NULL; in channel_still_useful()
380 has_err_msg = channel->ch_part[PART_ERR].ch_fd != INVALID_FD in channel_still_useful()
381 || channel->ch_part[PART_ERR].ch_head.rq_next != NULL in channel_still_useful()
382 || channel->ch_part[PART_ERR].ch_json_head.jq_next != NULL; in channel_still_useful()
385 || ((channel->ch_part[PART_OUT].ch_callback.cb_name != NULL in channel_still_useful()
386 || channel->ch_part[PART_OUT].ch_bufref.br_buf != NULL) in channel_still_useful()
388 || ((channel->ch_part[PART_ERR].ch_callback.cb_name != NULL in channel_still_useful()
389 || channel->ch_part[PART_ERR].ch_bufref.br_buf != NULL) in channel_still_useful()
531 if (channel->ch_part[part].ch_fd == fd) in channel_fd2channel()
602 if (channel->ch_part[part].ch_inputHandler == (XtInputId)NULL) in channel_gui_register_one()
605 part_names[part], channel->ch_part[part].ch_fd); in channel_gui_register_one()
607 channel->ch_part[part].ch_inputHandler = XtAppAddInput( in channel_gui_register_one()
609 channel->ch_part[part].ch_fd, in channel_gui_register_one()
612 (XtPointer)(long)channel->ch_part[part].ch_fd); in channel_gui_register_one()
618 if (channel->ch_part[part].ch_inputHandler == 0) in channel_gui_register_one()
621 part_names[part], channel->ch_part[part].ch_fd); in channel_gui_register_one()
624 (gint)channel->ch_part[part].ch_fd); in channel_gui_register_one()
626 channel->ch_part[part].ch_inputHandler = g_io_add_watch( in channel_gui_register_one()
630 GINT_TO_POINTER(channel->ch_part[part].ch_fd)); in channel_gui_register_one()
634 channel->ch_part[part].ch_inputHandler = gdk_input_add( in channel_gui_register_one()
635 (gint)channel->ch_part[part].ch_fd, in channel_gui_register_one()
639 (gpointer)(long)channel->ch_part[part].ch_fd); in channel_gui_register_one()
677 if (channel->ch_part[part].ch_inputHandler != (XtInputId)NULL) in channel_gui_unregister_one()
680 XtRemoveInput(channel->ch_part[part].ch_inputHandler); in channel_gui_unregister_one()
681 channel->ch_part[part].ch_inputHandler = (XtInputId)NULL; in channel_gui_unregister_one()
685 if (channel->ch_part[part].ch_inputHandler != 0) in channel_gui_unregister_one()
689 g_source_remove(channel->ch_part[part].ch_inputHandler); in channel_gui_unregister_one()
691 gdk_input_remove(channel->ch_part[part].ch_inputHandler); in channel_gui_unregister_one()
693 channel->ch_part[part].ch_inputHandler = 0; in channel_gui_unregister_one()
1171 channel->ch_part[part].ch_mode = opt->jo_mode; in channel_set_options()
1173 channel->ch_part[PART_IN].ch_mode = opt->jo_in_mode; in channel_set_options()
1175 channel->ch_part[PART_OUT].ch_mode = opt->jo_out_mode; in channel_set_options()
1177 channel->ch_part[PART_ERR].ch_mode = opt->jo_err_mode; in channel_set_options()
1182 channel->ch_part[part].ch_timeout = opt->jo_timeout; in channel_set_options()
1184 channel->ch_part[PART_OUT].ch_timeout = opt->jo_out_timeout; in channel_set_options()
1186 channel->ch_part[PART_ERR].ch_timeout = opt->jo_err_timeout; in channel_set_options()
1188 channel->ch_part[PART_IN].ch_block_write = 1; in channel_set_options()
1193 free_set_callback(&channel->ch_part[PART_OUT].ch_callback, in channel_set_options()
1196 free_set_callback(&channel->ch_part[PART_ERR].ch_callback, in channel_set_options()
1208 channel->ch_part[PART_OUT].ch_mode = MODE_NL; in channel_set_options()
1226 channel->ch_part[PART_OUT].ch_nomodifiable = in channel_set_options()
1229 if (!buf->b_p_ma && !channel->ch_part[PART_OUT].ch_nomodifiable) in channel_set_options()
1237 set_bufref(&channel->ch_part[PART_OUT].ch_bufref, buf); in channel_set_options()
1253 channel->ch_part[PART_ERR].ch_mode = MODE_NL; in channel_set_options()
1255 buf = channel->ch_part[PART_OUT].ch_bufref.br_buf; in channel_set_options()
1273 channel->ch_part[PART_ERR].ch_nomodifiable = in channel_set_options()
1275 if (!buf->b_p_ma && !channel->ch_part[PART_ERR].ch_nomodifiable) in channel_set_options()
1283 set_bufref(&channel->ch_part[PART_ERR].ch_bufref, buf); in channel_set_options()
1291 channel->ch_part[PART_OUT].ch_io = opt->jo_io[PART_OUT]; in channel_set_options()
1292 channel->ch_part[PART_ERR].ch_io = opt->jo_io[PART_ERR]; in channel_set_options()
1293 channel->ch_part[PART_IN].ch_io = opt->jo_io[PART_IN]; in channel_set_options()
1386 sock_T *fd = &channel->ch_part[part].ch_fd; in ch_close_part()
1467 chanpart_T *in_part = &channel->ch_part[PART_IN]; in channel_set_job()
1505 cbq_T *head = &channel->ch_part[part].ch_cb_head; in channel_set_req_callback()
1557 chanpart_T *in_part = &channel->ch_part[PART_IN]; in can_write_buf_line()
1625 chanpart_T *in_part = &channel->ch_part[PART_IN]; in channel_write_in()
1687 chanpart_T *ch_part = &channel->ch_part[part]; in channel_buffer_free() local
1689 if (ch_part->ch_bufref.br_buf == buf) in channel_buffer_free()
1693 ch_part->ch_bufref.br_buf = NULL; in channel_buffer_free()
1704 chanpart_T *in_part = &channel->ch_part[PART_IN]; in channel_write_input()
1742 chanpart_T *in_part = &channel->ch_part[PART_IN]; in channel_write_new_lines()
1802 readq_T *head = &channel->ch_part[part].ch_head; in channel_peek()
1832 readq_T *head = &channel->ch_part[part].ch_head; in channel_get()
1858 readq_T *head = &channel->ch_part[part].ch_head; in channel_get_all()
1930 readq_T *head = &channel->ch_part[part].ch_head; in channel_consume()
1947 readq_T *head = &channel->ch_part[part].ch_head; in channel_collapse()
2010 readq_T *head = &channel->ch_part[part].ch_head; in channel_save()
2026 if (channel->ch_part[part].ch_mode == MODE_NL) in channel_save()
2126 chanpart_T *chanpart = &channel->ch_part[part]; in channel_parse_json()
2374 jsonq_T *head = &channel->ch_part[part].ch_json_head; in channel_get_json()
2390 &channel->ch_part[part], tv->vval.v_number))))) in channel_get_json()
2411 jsonq_T *head = &channel->ch_part[part].ch_json_head; in channel_push_json()
2475 int options = channel->ch_part[part].ch_mode == MODE_JS ? JSON_JS : 0; in channel_exe_cmd()
2632 chanpart_T *ch_part = &channel->ch_part[part]; in append_to_buffer() local
2636 if (!buffer->b_p_ma && !ch_part->ch_nomodifiable) in append_to_buffer()
2638 if (!ch_part->ch_nomod_error) in append_to_buffer()
2641 ch_part->ch_nomod_error = TRUE; in append_to_buffer()
2680 if (ch_part->ch_nomodifiable) in append_to_buffer()
2727 chanpart_T *in_part = &ch->ch_part[PART_IN]; in append_to_buffer()
2759 chanpart_T *ch_part = &channel->ch_part[part]; in may_invoke_callback() local
2760 ch_mode_T ch_mode = ch_part->ch_mode; in may_invoke_callback()
2761 cbq_T *cbhead = &ch_part->ch_cb_head; in may_invoke_callback()
2777 else if (ch_part->ch_callback.cb_name != NULL) in may_invoke_callback()
2778 callback = &ch_part->ch_callback; in may_invoke_callback()
2782 buffer = ch_part->ch_bufref.br_buf; in may_invoke_callback()
2783 if (buffer != NULL && (!bufref_valid(&ch_part->ch_bufref) in may_invoke_callback()
2788 ch_part->ch_bufref.br_buf = NULL; in may_invoke_callback()
2863 if (ch_part->ch_fd == INVALID_FD && node->rq_buflen > 0) in may_invoke_callback()
3008 ch_mode_T ch_mode = channel->ch_part[part].ch_mode; in channel_has_readahead()
3012 jsonq_T *head = &channel->ch_part[part].ch_json_head; in channel_has_readahead()
3070 chanpart_T *chanpart = &channel->ch_part[part]; in channel_part_info()
3166 || channel->ch_part[part].ch_bufref.br_buf != NULL) in channel_close()
3248 chanpart_T *ch_part = &channel->ch_part[part]; in channel_clear_one() local
3249 jsonq_T *json_head = &ch_part->ch_json_head; in channel_clear_one()
3250 cbq_T *cb_head = &ch_part->ch_cb_head; in channel_clear_one()
3270 free_callback(&ch_part->ch_callback); in channel_clear_one()
3271 ga_clear(&ch_part->ch_block_ids); in channel_clear_one()
3273 while (ch_part->ch_writeque.wq_next != NULL) in channel_clear_one()
3274 remove_from_writeque(&ch_part->ch_writeque, in channel_clear_one()
3275 ch_part->ch_writeque.wq_next); in channel_clear_one()
3325 chanpart_T *in_part = &ch->ch_part[PART_IN]; in channel_fill_wfds()
3350 chanpart_T *in_part = &ch->ch_part[PART_IN]; in channel_fill_poll_write()
3521 if (channel->ch_part[part].ch_fd == channel->ch_part[other].ch_fd) in ch_close_part_on_error()
3555 fd = channel->ch_part[part].ch_fd; in channel_read()
3620 ch_mode_T mode = channel->ch_part[part].ch_mode; in channel_read_block()
3621 sock_T fd = channel->ch_part[part].ch_fd; in channel_read_block()
3727 chanpart_T *chanpart = &channel->ch_part[part]; in channel_read_json_block()
3955 fd = channel->ch_part[part].ch_fd; in channel_handle_events()
4008 chanpart_T *ch_part = &channel->ch_part[part]; in channel_set_nonblock() local
4009 int fd = ch_part->ch_fd; in channel_set_nonblock()
4020 ch_part->ch_nonblocking = TRUE; in channel_set_nonblock()
4039 chanpart_T *ch_part = &channel->ch_part[part]; in channel_send() local
4042 fd = ch_part->ch_fd; in channel_send()
4054 if (channel->ch_nonblock && !ch_part->ch_nonblocking) in channel_send()
4069 writeq_T *wq = &ch_part->ch_writeque; in channel_send()
4109 if (res >= 0 && ch_part->ch_nonblocking) in channel_send()
4389 chanpart_T *ch_part = &channel->ch_part[part]; in channel_poll_setup() local
4391 if (ch_part->ch_fd != INVALID_FD) in channel_poll_setup()
4403 ch_part->ch_poll_idx = nfd; in channel_poll_setup()
4404 fds[nfd].fd = ch_part->ch_fd; in channel_poll_setup()
4410 channel->ch_part[part].ch_poll_idx = -1; in channel_poll_setup()
4436 idx = channel->ch_part[part].ch_poll_idx; in channel_poll_check()
4443 else if (channel->ch_part[part].ch_fd != INVALID_FD in channel_poll_check()
4451 in_part = &channel->ch_part[PART_IN]; in channel_poll_check()
4487 sock_T fd = channel->ch_part[part].ch_fd; in channel_select_setup()
4536 sock_T fd = channel->ch_part[part].ch_fd; in channel_select_check()
4551 in_part = &channel->ch_part[PART_IN]; in channel_select_check()
4648 if (channel->ch_part[part].ch_fd != INVALID_FD in channel_parse_messages()
4770 return channel->ch_part[part].ch_mode; in channel_get_mode()
4779 return channel->ch_part[part].ch_timeout; in channel_get_timeout()
4865 if (channel->ch_part[part].ch_bufref.br_buf != NULL) in f_ch_getbufnr()
4867 channel->ch_part[part].ch_bufref.br_buf->b_fnum; in f_ch_getbufnr()