Lines Matching refs:chanpart
2126 chanpart_T *chanpart = &channel->ch_part[part]; in channel_parse_json() local
2127 jsonq_T *head = &chanpart->ch_json_head; in channel_parse_json()
2146 chanpart->ch_mode == MODE_JS ? JSON_JS : 0); in channel_parse_json()
2191 chanpart->ch_wait_len = 0; in channel_parse_json()
2196 if (chanpart->ch_wait_len < buflen) in channel_parse_json()
2204 chanpart->ch_wait_len = buflen; in channel_parse_json()
2206 chanpart->ch_deadline = GetTickCount() + 100L; in channel_parse_json()
2208 gettimeofday(&chanpart->ch_deadline, NULL); in channel_parse_json()
2209 chanpart->ch_deadline.tv_usec += 100 * 1000; in channel_parse_json()
2210 if (chanpart->ch_deadline.tv_usec > 1000 * 1000) in channel_parse_json()
2212 chanpart->ch_deadline.tv_usec -= 1000 * 1000; in channel_parse_json()
2213 ++chanpart->ch_deadline.tv_sec; in channel_parse_json()
2221 timeout = GetTickCount() > chanpart->ch_deadline; in channel_parse_json()
2227 timeout = now_tv.tv_sec > chanpart->ch_deadline.tv_sec in channel_parse_json()
2228 || (now_tv.tv_sec == chanpart->ch_deadline.tv_sec in channel_parse_json()
2229 && now_tv.tv_usec > chanpart->ch_deadline.tv_usec); in channel_parse_json()
2235 chanpart->ch_wait_len = 0; in channel_parse_json()
2250 chanpart->ch_wait_len = 0; in channel_parse_json()
2305 channel_add_block_id(chanpart_T *chanpart, int id) in channel_add_block_id() argument
2307 garray_T *gap = &chanpart->ch_block_ids; in channel_add_block_id()
2322 channel_remove_block_id(chanpart_T *chanpart, int id) in channel_remove_block_id() argument
2324 garray_T *gap = &chanpart->ch_block_ids; in channel_remove_block_id()
2346 channel_has_block_id(chanpart_T *chanpart, int id) in channel_has_block_id() argument
2348 garray_T *gap = &chanpart->ch_block_ids; in channel_has_block_id()
3070 chanpart_T *chanpart = &channel->ch_part[part]; in channel_part_info() local
3081 if (chanpart->ch_fd != INVALID_FD) in channel_part_info()
3090 switch (chanpart->ch_mode) in channel_part_info()
3102 else switch (chanpart->ch_io) in channel_part_info()
3113 dict_add_number(dict, namebuf, chanpart->ch_timeout); in channel_part_info()
3727 chanpart_T *chanpart = &channel->ch_part[part]; in channel_read_json_block() local
3734 channel_add_block_id(chanpart, id); in channel_read_json_block()
3758 if (chanpart->ch_wait_len > 0) in channel_read_json_block()
3761 timeout = chanpart->ch_deadline - GetTickCount() + 1; in channel_read_json_block()
3767 timeout = (chanpart->ch_deadline.tv_sec in channel_read_json_block()
3769 + (chanpart->ch_deadline.tv_usec in channel_read_json_block()
3778 chanpart->ch_wait_len = 0; in channel_read_json_block()
3784 fd = chanpart->ch_fd; in channel_read_json_block()
3800 channel_remove_block_id(chanpart, id); in channel_read_json_block()