| /libuv/test/ |
| H A D | test-fs-open-flags.c | 46 static uv_fs_t write_req; variable
113 ASSERT_EQ(1, write_req.result); in refresh()
114 uv_fs_req_cleanup(&write_req); in refresh()
166 ASSERT_EQ(1, write_req.result); in writeExpect()
167 uv_fs_req_cleanup(&write_req); in writeExpect()
172 ASSERT_EQ(1, write_req.result); in writeExpect()
173 uv_fs_req_cleanup(&write_req); in writeExpect()
209 ASSERT_EQ(write_req.result, error); in writeFail()
210 uv_fs_req_cleanup(&write_req); in writeFail()
215 ASSERT_EQ(write_req.result, error); in writeFail()
[all …]
|
| H A D | test-pipe-set-non-blocking.c | 77 uv_write_t write_req; in TEST_IMPL() local
103 ASSERT_OK(uv_write(&write_req, in TEST_IMPL()
108 ASSERT_NOT_NULL(write_req.handle); in TEST_IMPL()
110 ASSERT_NULL(write_req.handle); /* check for signaled completion of write_cb */ in TEST_IMPL()
|
| H A D | test-tcp-connect-error-after-write.c | 65 uv_write_t write_req; in TEST_IMPL()
76 r = uv_write(&write_req, (uv_stream_t*)&conn, &buf, 1, write_cb); in TEST_IMPL()
85 r = uv_write(&write_req, (uv_stream_t*)&conn, &buf, 1, write_cb); in TEST_IMPL()
|
| H A D | test-ipc-send-recv.c | 46 uv_write_t write_req; member
58 uv_write_t write_req; member
150 r = uv_write2(&ctx.write_req, in connect_cb()
309 uv_write_t* write_req; in read_cb() local
325 write_req = &ctx2.write_req; in read_cb()
328 write_req = &ctx2.write_req2; in read_cb()
346 r = uv_write2(write_req, in read_cb()
|
| H A D | benchmark-pound.c | 46 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()
|
| H A D | benchmark-tcp-write-batch.c | 34 } write_req; typedef
37 static write_req* write_reqs;
54 write_req* w; in connect_cb()
|
| H A D | test-fs.c | 109 static uv_fs_t write_req; variable
477 ASSERT_PTR_EQ(req, &write_req); in write_cb()
1000 uv_fs_req_cleanup(&write_req); in fs_file_sync()
1129 ASSERT_OK(write_req.result); in fs_file_write_null_buffer()
1130 uv_fs_req_cleanup(&write_req); in fs_file_write_null_buffer()
3477 &write_req, in fs_write_alotof_bufs()
3521 write_req.result); in fs_write_alotof_bufs()
3597 &write_req, in fs_write_alotof_bufs_with_offset()
3903 ASSERT_NULL(write_req.path); in TEST_IMPL()
3904 ASSERT_NULL(write_req.ptr); in TEST_IMPL()
[all …]
|
| H A D | test-tcp-read-stop.c | 27 static uv_write_t write_req; variable
43 ASSERT_OK(uv_write(&write_req, in timer_cb()
|
| H A D | test-ipc-heavy-traffic-deadlock-bug.c | 40 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()
|
| H A D | test-tcp-open.c | 40 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_OK(uv_write(&write_req, in TEST_IMPL()
|
| H A D | test-not-readable-nor-writable-on-read-error.c | 28 static uv_write_t write_req; variable
75 r = uv_write(&write_req, in connect_cb()
|
| H A D | test-tcp-write-fail.c | 36 static uv_write_t write_req; variable
86 r = uv_write(&write_req, stream, &buf, 1, write_cb); in connect_cb()
|
| H A D | test-readable-on-eof.c | 28 static uv_write_t write_req; variable
81 r = uv_write(&write_req, in connect_cb()
|
| H A D | test-signal-pending-on-close.c | 32 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()
|
| H A D | test-tcp-alloc-cb-fail.c | 35 static uv_write_t write_req; variable
72 r = uv_write(&write_req, req->handle, &buf, 1, write_cb); in connect_cb()
|
| H A D | test-metrics.c | 30 uv_fs_t write_req; member
199 &fs_reqs.write_req, in create_cb()
314 uv_fs_t write_req; in TEST_IMPL() local
340 &write_req, in TEST_IMPL()
|
| H A D | test-tcp-shutdown-after-write.c | 31 static uv_write_t write_req; variable
68 r = uv_write(&write_req, (uv_stream_t*)&conn, &buf, 1, write_cb); in timer_cb()
|
| H A D | test-tcp-unexpected-read.c | 30 static uv_write_t write_req; variable
82 ASSERT_OK(uv_write(&write_req, (uv_stream_t*) &peer_handle, in connection_cb()
|
| H A D | test-tcp-write-to-half-open-connection.c | 39 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()
|
| H A D | test-callback-stack.c | 36 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()
|
| H A D | test-tcp-writealot.c | 126 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()
|
| H A D | test-shutdown-eof.c | 30 static uv_write_t write_req; variable
104 uv_write(&write_req, (uv_stream_t*) &tcp, &qbuf, 1, NULL); in connect_cb()
|
| /libuv/docs/code/uvcat/ |
| H A D | main.c | 10 uv_fs_t write_req; variable
36 uv_fs_write(uv_default_loop(), &write_req, 1, &iov, 1, -1, on_write); in on_read()
60 uv_fs_req_cleanup(&write_req); in main()
|
| /libuv/docs/code/tty-gravity/ |
| H A D | main.c | 9 uv_write_t write_req; variable
23 uv_write(&write_req, (uv_stream_t*) &tty, &buf, 1, NULL); in update()
|
| /libuv/docs/code/multi-echo-server/ |
| H A D | main.c | 40 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()
|
