154 if(autoextend) { |
154 if(autoextend) { |
155 flags = UCX_BUFFER_AUTOEXTEND; |
155 flags = UCX_BUFFER_AUTOEXTEND; |
156 } |
156 } |
157 stream->buf = ucx_buffer_new(NULL, size, flags); |
157 stream->buf = ucx_buffer_new(NULL, size, flags); |
158 |
158 |
159 stream->io.write = test_io_write; |
159 stream->io.st.write = test_io_write; |
160 stream->io.writev = test_io_writev; |
160 stream->io.st.writev = test_io_writev; |
161 stream->io.close = test_io_close; |
161 stream->io.st.close = test_io_close; |
162 stream->io.finish = test_io_finish; |
162 stream->io.st.finish = test_io_finish; |
163 |
163 |
164 return stream; |
164 return stream; |
165 } |
165 } |
166 |
166 |
167 void testutil_iostream_destroy(TestIOStream *stream) { |
167 void testutil_iostream_destroy(TestIOStream *stream) { |