Home
last modified time | relevance | path

Searched refs:write_req (Results 1 – 25 of 33) sorted by relevance

12

/third_party/libuv/test/
Dtest-fs-open-flags.c46 static uv_fs_t write_req; variable
111 r = uv_fs_write(NULL, &write_req, open_req.result, &iov, 1, -1, NULL); in refresh()
113 ASSERT(write_req.result == 1); in refresh()
114 uv_fs_req_cleanup(&write_req); in refresh()
164 r = uv_fs_write(NULL, &write_req, open_req.result, &iov, 1, -1, NULL); in writeExpect()
166 ASSERT(write_req.result == 1); in writeExpect()
167 uv_fs_req_cleanup(&write_req); in writeExpect()
170 r = uv_fs_write(NULL, &write_req, open_req.result, &iov, 1, -1, NULL); in writeExpect()
172 ASSERT(write_req.result == 1); in writeExpect()
173 uv_fs_req_cleanup(&write_req); in writeExpect()
[all …]
Dtest-pipe-set-non-blocking.c77 uv_write_t write_req; in TEST_IMPL() local
103 ASSERT(0 == uv_write(&write_req, (uv_stream_t*) &pipe_handle, &buf, 1, write_cb)); in TEST_IMPL()
104 ASSERT_NOT_NULL(write_req.handle); in TEST_IMPL()
107 ASSERT_NULL(write_req.handle); /* check for signaled completion of write_cb */ in TEST_IMPL()
Dtest-ipc-send-recv.c46 uv_write_t write_req; member
58 uv_write_t write_req; member
146 r = uv_write2(&ctx.write_req, in connect_cb()
305 uv_write_t* write_req; in read_cb() local
319 write_req = &ctx2.write_req; in read_cb()
322 write_req = &ctx2.write_req2; in read_cb()
340 r = uv_write2(write_req, in read_cb()
Dtest-tcp-connect-error-after-write.c60 uv_write_t write_req; in TEST_IMPL() local
77 r = uv_write(&write_req, (uv_stream_t*)&conn, &buf, 1, write_cb); in TEST_IMPL()
86 r = uv_write(&write_req, (uv_stream_t*)&conn, &buf, 1, write_cb); in TEST_IMPL()
Dbenchmark-pound.c46 uv_write_t write_req; member
54 uv_write_t write_req; member
62 uv_write_t write_req; member
133 r = uv_write(&conn->write_req, &conn->stream, &buf, 1, after_write); in connect_cb()
221 p->write_req.data = p; in tcp_make_connect()
242 p->write_req.data = p; in pipe_make_connect()
Dtest-fs.c99 static uv_fs_t write_req; variable
426 ASSERT(req == &write_req); in write_cb()
444 r = uv_fs_write(loop, &write_req, req->result, &iov, 1, -1, write_cb); in create_cb()
936 r = uv_fs_write(NULL, &write_req, open_req1.result, &iov, 1, -1, NULL); in fs_file_sync()
938 ASSERT(write_req.result >= 0); in fs_file_sync()
939 uv_fs_req_cleanup(&write_req); in fs_file_sync()
1025 r = uv_fs_write(NULL, &write_req, open_req1.result, &iov, 1, -1, NULL); in fs_file_write_null_buffer()
1027 ASSERT(write_req.result == 0); in fs_file_write_null_buffer()
1028 uv_fs_req_cleanup(&write_req); in fs_file_write_null_buffer()
2825 r = uv_fs_write(NULL, &write_req, open_req1.result, &iov, 1, -1, NULL); in fs_file_open_append()
[all …]
Dbenchmark-tcp-write-batch.c34 } write_req; typedef
37 static write_req* write_reqs;
54 write_req* w; in connect_cb()
Dtest-ipc-heavy-traffic-deadlock-bug.c40 uv_write_t write_req; member
51 container_of(req, struct write_info, write_req); in write_cb()
77 &write_info->write_req, handle, bufs, BUFFERS_PER_WRITE, write_cb); in do_write()
Dtest-tcp-open.c40 static uv_write_t write_req; variable
168 r = uv_write(&write_req, req->handle, &buf, 1, write1_cb); in write1_cb()
196 r = uv_write(&write_req, stream, &buf, 1, write_cb); in connect_cb()
227 r = uv_write(&write_req, stream, &buf, 1, write1_cb); in connect1_cb()
352 ASSERT(0 == uv_write(&write_req, (uv_stream_t*) &client, &buf, 1, write_cb)); in TEST_IMPL()
Dtest-tcp-read-stop.c27 static uv_write_t write_req; variable
43 ASSERT(0 == uv_write(&write_req, in timer_cb()
Dtest-tcp-write-fail.c36 static uv_write_t write_req; variable
86 r = uv_write(&write_req, stream, &buf, 1, write_cb); in connect_cb()
Dtest-not-readable-nor-writable-on-read-error.c28 static uv_write_t write_req; variable
75 r = uv_write(&write_req, in connect_cb()
Dtest-readable-on-eof.c28 static uv_write_t write_req; variable
81 r = uv_write(&write_req, in connect_cb()
Dtest-signal-pending-on-close.c32 static uv_write_t write_req; variable
83 r = uv_write(&write_req, (uv_stream_t *) &pipe_hdl, &buffer, 1, write_cb); in TEST_IMPL()
Dtest-tcp-alloc-cb-fail.c35 static uv_write_t write_req; variable
72 r = uv_write(&write_req, req->handle, &buf, 1, write_cb); in connect_cb()
Dtest-tcp-shutdown-after-write.c31 static uv_write_t write_req; variable
68 r = uv_write(&write_req, (uv_stream_t*)&conn, &buf, 1, write_cb); in timer_cb()
Dtest-tcp-unexpected-read.c30 static uv_write_t write_req; variable
82 ASSERT(0 == uv_write(&write_req, (uv_stream_t*) &peer_handle, in connection_cb()
Dtest-tcp-write-to-half-open-connection.c39 static uv_write_t write_req; variable
63 r = uv_write(&write_req, (uv_stream_t*)&tcp_peer, &buf, 1, write_cb); in connection_cb()
Dtest-callback-stack.c36 static uv_write_t write_req; variable
161 if (uv_write(&write_req, (uv_stream_t*)req->handle, &buf, 1, write_cb)) { in connect_cb()
Dtest-tcp-writealot.c126 uv_write_t* write_req = write_reqs + i; in connect_cb() local
133 r = uv_write(write_req, stream, send_bufs, CHUNKS_PER_WRITE, write_cb); in connect_cb()
/third_party/libuv/docs/code/uvcat/
Dmain.c11 uv_fs_t write_req; variable
37 uv_fs_write(uv_default_loop(), &write_req, 1, &iov, 1, -1, on_write); in on_read()
61 uv_fs_req_cleanup(&write_req); in main()
/third_party/libuv/docs/code/tty-gravity/
Dmain.c9 uv_write_t write_req; variable
23 uv_write(&write_req, (uv_stream_t*) &tty, &buf, 1, NULL); in update()
/third_party/ltp/testcases/kernel/fs/doio/
Ddoio.h145 struct write_req { struct
194 struct write_req write;
/third_party/grpc/src/core/lib/iomgr/
Dtcp_uv.cc48 uv_write_t write_req; member
156 uv_write_t* write_req; in uv_socket_write() local
165 write_req = &uv_socket->write_req; in uv_socket_write()
166 write_req->data = socket; in uv_socket_write()
168 uv_write(write_req, (uv_stream_t*)uv_socket->handle, uv_buffers, in uv_socket_write()
/third_party/libuv/docs/code/multi-echo-server/
Dmain.c40 uv_write_t *write_req = (uv_write_t*) malloc(sizeof(uv_write_t)); in on_new_connection() local
43 … uv_write2(write_req, (uv_stream_t*) &worker->pipe, &dummy_buf, 1, (uv_stream_t*) client, NULL); in on_new_connection()

12