diff --git a/src/stream_interface.c b/src/stream_interface.c index 75e60ff60..d30806609 100644 --- a/src/stream_interface.c +++ b/src/stream_interface.c @@ -618,8 +618,7 @@ static int si_cs_process(struct conn_stream *cs) * stream-int status. */ stream_int_notify(si); - channel_release_buffer(ic, &(si_strm(si)->buffer_wait)); - + stream_release_buffers(si_strm(si)); return 0; } @@ -788,6 +787,7 @@ struct task *si_cs_io_cb(struct task *t, void *ctx, unsigned short state) if (ret != 0) si_cs_process(cs); + stream_release_buffers(si_strm(si)); return (NULL); } @@ -1572,6 +1572,7 @@ void si_applet_wake_cb(struct stream_interface *si) /* update the stream-int, channels, and possibly wake the stream up */ stream_int_notify(si); + stream_release_buffers(si_strm(si)); /* stream_int_notify may have passed through chk_snd and released some * RXBLK flags. Process_stream will consider those flags to wake up the