Searched refs:channel (Results 1 - 5 of 5) sorted by relevance

/dovecot/src/lib/
H A Dtest-multiplex.c35 static void test_multiplex_channel_write(struct test_channel *channel) argument
40 o_stream_nsend(channel->out, buf, len);
41 o_stream_nsend(channel->out_alt, buf, len);
44 static void test_multiplex_stream_write(struct ostream *channel ATTR_UNUSED)
53 static void test_istream_multiplex_stream_read(struct test_channel *channel) argument
58 if (i_stream_read(channel->in) > 0) {
59 data = i_stream_get_data(channel->in, &siz);
60 buffer_append(channel->received, data, siz);
61 i_stream_skip(channel->in, siz);
65 static void test_istream_read_alt(struct test_channel *channel) argument
77 setup_channel(struct test_channel *channel, struct istream *is, struct ostream *os) argument
96 teardown_channel(struct test_channel *channel) argument
[all...]
H A Dostream-multiplex.c25 /* channel 0 is main channel */
58 struct multiplex_ochannel *channel = NULL; local
63 channel = *channelp;
64 return channel;
70 struct multiplex_ochannel *channel; local
75 while((channel = get_next_channel(mstream)) != NULL) {
78 size_t amt = I_MIN(UINT_MAX, I_MIN(tmp, channel->buf->used));
82 buffer_append(mstream->wbuf, &channel->cid, 1);
84 buffer_append(mstream->wbuf, channel
105 struct multiplex_ochannel *channel = (struct multiplex_ochannel*)stream; local
133 struct multiplex_ochannel *channel = (struct multiplex_ochannel*)stream; local
160 struct multiplex_ochannel *channel = (struct multiplex_ochannel*)stream; local
177 struct multiplex_ochannel *channel = i_new(struct multiplex_ochannel, 1); local
216 struct multiplex_ochannel *channel = local
[all...]
H A Distream-multiplex.c24 /* channel 0 is main channel */
113 struct multiplex_ichannel *channel = local
117 if (channel != NULL && !channel->closed) {
118 struct istream_private *stream = &channel->istream;
119 stream->pos += channel->pending_pos;
121 stream->pos -= channel->pending_pos;
124 if (channel->cid != req_channel->cid)
134 if (channel
179 struct multiplex_ichannel *channel = (struct multiplex_ichannel*)stream; local
195 struct multiplex_ichannel *channel = (struct multiplex_ichannel*)stream; local
204 struct multiplex_ichannel *channel = (struct multiplex_ichannel*)stream; local
229 struct multiplex_ichannel *channel = (struct multiplex_ichannel*)stream; local
244 struct multiplex_ichannel *channel = i_new(struct multiplex_ichannel, 1); local
287 struct multiplex_ichannel *channel = local
[all...]
H A Dtest-istream-multiplex.c98 /* we get data for channel 0 and congest */
100 /* we read data for channel 0 */
108 /* we read data for channel 1 */
116 /* now we get byte for channel 1 */
118 /* now we read byte for channel 1 */
151 unsigned int channel = i_rand_limit(max_channel); local
154 input_crc[channel] =
155 crc32_data_more(input_crc[channel], packet_data, len);
157 buffer_append_c(buf, channel);
234 static void test_istream_multiplex_stream_read(struct istream *channel) argument
270 test_istream_multiplex_stream_write(struct ostream *channel) argument
[all...]
H A Dtest-ostream-multiplex.c90 static void test_ostream_multiplex_stream_write(struct ostream *channel ATTR_UNUSED)

Completed in 10 milliseconds