1813 channel_first_nl(readq_T *node)  in channel_first_nl()  argument
1815     char_u  *buffer = node->rq_buffer;  in channel_first_nl()
1818     for (i = 0; i < node->rq_buflen; ++i)  in channel_first_nl()
1833     readq_T *node = head->rq_next;  in channel_get()  local
1836     if (node == NULL)  in channel_get()
1839 	*outlen += node->rq_buflen;  in channel_get()
1841     p = node->rq_buffer;  in channel_get()
1842     head->rq_next = node->rq_next;  in channel_get()
1843     if (node->rq_next == NULL)  in channel_get()
1846 	node->rq_next->rq_prev = NULL;  in channel_get()
1847     vim_free(node);  in channel_get()
1859     readq_T *node;  in channel_get_all()  local
1865     for (node = head->rq_next; node != NULL; node = node->rq_next)  in channel_get_all()
1866 	len += node->rq_buflen;  in channel_get_all()
1871     for (node = head->rq_next; node != NULL; node = node->rq_next)  in channel_get_all()
1873 	mch_memmove(p, node->rq_buffer, node->rq_buflen);  in channel_get_all()
1874 	p += node->rq_buflen;  in channel_get_all()
1931     readq_T *node = head->rq_next;  in channel_consume()  local
1932     char_u *buf = node->rq_buffer;  in channel_consume()
1934     mch_memmove(buf, buf + len, node->rq_buflen - len);  in channel_consume()
1935     node->rq_buflen -= len;  in channel_consume()
1936     node->rq_buffer[node->rq_buflen] = NUL;  in channel_consume()
1948     readq_T *node = head->rq_next;  in channel_collapse()  local
1955     if (node == NULL || node->rq_next == NULL)  in channel_collapse()
1958     last_node = node->rq_next;  in channel_collapse()
1959     len = node->rq_buflen + last_node->rq_buflen;  in channel_collapse()
1971     mch_memmove(p, node->rq_buffer, node->rq_buflen);  in channel_collapse()
1972     p += node->rq_buflen;  in channel_collapse()
1973     vim_free(node->rq_buffer);  in channel_collapse()
1974     node->rq_buffer = newbuf;  in channel_collapse()
1975     for (n = node; n != last_node; )  in channel_collapse()
1983     node->rq_buflen = (long_u)(p - newbuf);  in channel_collapse()
1986     for (n = node->rq_next; n != last_node; )  in channel_collapse()
1991     node->rq_next = last_node->rq_next;  in channel_collapse()
1993 	head->rq_prev = node;  in channel_collapse()
1995 	last_node->rq_next->rq_prev = node;  in channel_collapse()
2009     readq_T *node;  in channel_save()  local
2014     node = ALLOC_ONE(readq_T);  in channel_save()
2015     if (node == NULL)  in channel_save()
2019     node->rq_buffer = alloc(len + 1);  in channel_save()
2020     if (node->rq_buffer == NULL)  in channel_save()
2022 	vim_free(node);  in channel_save()
2029 	p = node->rq_buffer;  in channel_save()
2034 	node->rq_buflen = (long_u)(p - node->rq_buffer);  in channel_save()
2038 	mch_memmove(node->rq_buffer, buf, len);  in channel_save()
2039 	node->rq_buffer[len] = NUL;  in channel_save()
2040 	node->rq_buflen = (long_u)len;  in channel_save()
2046 	node->rq_next = head->rq_next;  in channel_save()
2047 	node->rq_prev = NULL;  in channel_save()
2049 	    head->rq_prev = node;  in channel_save()
2051 	    head->rq_next->rq_prev = node;  in channel_save()
2052 	head->rq_next = node;  in channel_save()
2057 	node->rq_next = NULL;  in channel_save()
2058 	node->rq_prev = head->rq_prev;  in channel_save()
2060 	    head->rq_next = node;  in channel_save()
2062 	    head->rq_prev->rq_next = node;  in channel_save()
2063 	head->rq_prev = node;  in channel_save()
2271 remove_cb_node(cbq_T *head, cbq_T *node)  in remove_cb_node()  argument
2273     if (node->cq_prev == NULL)  in remove_cb_node()
2274 	head->cq_next = node->cq_next;  in remove_cb_node()
2276 	node->cq_prev->cq_next = node->cq_next;  in remove_cb_node()
2277     if (node->cq_next == NULL)  in remove_cb_node()
2278 	head->cq_prev = node->cq_prev;  in remove_cb_node()
2280 	node->cq_next->cq_prev = node->cq_prev;  in remove_cb_node()
2288 remove_json_node(jsonq_T *head, jsonq_T *node)  in remove_json_node()  argument
2290     if (node->jq_prev == NULL)  in remove_json_node()
2291 	head->jq_next = node->jq_next;  in remove_json_node()
2293 	node->jq_prev->jq_next = node->jq_next;  in remove_json_node()
2294     if (node->jq_next == NULL)  in remove_json_node()
2295 	head->jq_prev = node->jq_prev;  in remove_json_node()
2297 	node->jq_next->jq_prev = node->jq_prev;  in remove_json_node()
2298     vim_free(node);  in remove_json_node()
2851 	    readq_T *node;  in may_invoke_callback()  local
2857 		node = channel_peek(channel, part);  in may_invoke_callback()
2858 		nl = channel_first_nl(node);  in may_invoke_callback()
2863 		    if (ch_part->ch_fd == INVALID_FD && node->rq_buflen > 0)  in may_invoke_callback()
2868 	    buf = node->rq_buffer;  in may_invoke_callback()
2872 					    && p < buf + node->rq_buflen; ++p)  in may_invoke_callback()
2881 	    else if (nl + 1 == buf + node->rq_buflen)  in may_invoke_callback()
3257 	cbq_T *node = cb_head->cq_next;  in channel_clear_one()  local
3259 	remove_cb_node(cb_head, node);  in channel_clear_one()
3260 	free_callback(&node->cq_callback);  in channel_clear_one()
3261 	vim_free(node);  in channel_clear_one()
3623     readq_T	*node;  in channel_read_block()  local
3630 	node = channel_peek(channel, part);  in channel_read_block()
3631 	if (node != NULL)  in channel_read_block()
3634 					   && channel_first_nl(node) != NULL))  in channel_read_block()
3665 	buf = node->rq_buffer;  in channel_read_block()
3666 	nl = channel_first_nl(node);  in channel_read_block()
3669 	for (p = buf; (nl == NULL || p < nl) && p < buf + node->rq_buflen; ++p)  in channel_read_block()
3678 	else if (nl + 1 == buf + node->rq_buflen)  in channel_read_block()