| /third_party/libsoup/libsoup/ |
| D | soup-body-output-stream.c | 110 gssize nwrote, my_count; in soup_body_output_stream_write_raw() local
125 nwrote = g_pollable_stream_write (bostream->priv->base_stream, in soup_body_output_stream_write_raw()
129 if (nwrote > 0 && bostream->priv->write_length) in soup_body_output_stream_write_raw()
130 bostream->priv->written += nwrote; in soup_body_output_stream_write_raw()
132 if (nwrote == my_count && my_count != count) in soup_body_output_stream_write_raw()
133 nwrote = count; in soup_body_output_stream_write_raw()
135 return nwrote; in soup_body_output_stream_write_raw()
147 gssize nwrote, len; in soup_body_output_stream_write_chunked() local
152 nwrote = g_pollable_stream_write (bostream->priv->base_stream, in soup_body_output_stream_write_chunked()
155 if (nwrote < 0) in soup_body_output_stream_write_chunked()
[all …]
|
| D | soup-message-io.c | 384 gssize nwrote; in io_write() local
415 nwrote = g_pollable_stream_write (io->ostream, in io_write()
420 if (nwrote == -1) in io_write()
422 io->written += nwrote; in io_write()
514 nwrote = g_pollable_stream_write (io->body_ostream, in io_write()
519 if (nwrote == -1) in io_write()
523 io->written, nwrote); in io_write()
524 io->written += nwrote; in io_write()
526 io->write_length -= nwrote; in io_write()
|
| D | soup-socket.h | 130 gsize *nwrote,
|
| D | soup-socket.c | 1998 gsize len, gsize *nwrote, in soup_socket_write() argument
2006 g_return_val_if_fail (nwrote != NULL, SOUP_SOCKET_ERROR); in soup_socket_write()
2034 *nwrote = my_nwrote; in soup_socket_write()
|
| /third_party/libsoup/tests/ |
| D | chunk-io-test.c | 354 gssize nread, nwrote, total; in do_io_tests() local
471 nwrote = g_output_stream_write (out, raw_contents->data + total, in do_io_tests()
475 if (nwrote > 0) { in do_io_tests()
476 total += nwrote; in do_io_tests()
477 chunk_total += nwrote; in do_io_tests()
516 nwrote = g_pollable_output_stream_write_nonblocking (G_POLLABLE_OUTPUT_STREAM (out), in do_io_tests()
520 if (nwrote == -1 && g_error_matches (error, G_IO_ERROR, G_IO_ERROR_WOULD_BLOCK)) { in do_io_tests()
532 } else if (nwrote == -1) { in do_io_tests()
537 total += nwrote; in do_io_tests()
538 chunk_total += nwrote; in do_io_tests()
[all …]
|
| D | chunk-test.c | 14 int next, nwrote, nfreed; member
69 ptd->nwrote += chunk->length; in wrote_body_data()
105 ptd->next = ptd->nwrote = ptd->nfreed = 0; in setup_request_body()
202 g_assert_cmpint (length, ==, ptd.nwrote); in do_request_test()
|
| D | server-test.c | 1129 gssize nread, nwrote; member
1182 gssize nwrote; in tunnel_wrote_cb() local
1184 nwrote = g_output_stream_write_finish (G_OUTPUT_STREAM (object), result, &error); in tunnel_wrote_cb()
1185 if (nwrote <= 0) { in tunnel_wrote_cb()
1205 write_end->nwrote += nwrote; in tunnel_wrote_cb()
1206 if (write_end->nwrote < read_end->nread) { in tunnel_wrote_cb()
1208 read_end->buffer + write_end->nwrote, in tunnel_wrote_cb()
1209 read_end->nread - write_end->nwrote, in tunnel_wrote_cb()
1252 write_end->nwrote = 0; in tunnel_read_cb()
|
| /third_party/libsoup/examples/ |
| D | simple-proxy.c | 23 gssize nread, nwrote; member
76 gssize nwrote; in tunnel_wrote_cb() local
78 nwrote = g_output_stream_write_finish (G_OUTPUT_STREAM (object), result, &error); in tunnel_wrote_cb()
79 if (nwrote <= 0) { in tunnel_wrote_cb()
99 write_end->nwrote += nwrote; in tunnel_wrote_cb()
100 if (write_end->nwrote < read_end->nread) { in tunnel_wrote_cb()
102 read_end->buffer + write_end->nwrote, in tunnel_wrote_cb()
103 read_end->nread - write_end->nwrote, in tunnel_wrote_cb()
146 write_end->nwrote = 0; in tunnel_read_cb()
|
| /third_party/glib/gio/tests/ |
| D | win32-streams.c | 43 gssize nwrote, offset; in writer_thread() local
63 nwrote = g_output_stream_write (out, DATA + offset, in writer_thread()
66 if (nwrote <= 0 || err != NULL) in writer_thread()
68 offset += nwrote; in writer_thread()
71 g_assert (nwrote > 0 || err != NULL); in writer_thread()
179 gssize nwrote; in writable() local
181 nwrote = g_output_stream_write_finish (out, res, &err); in writable()
190 g_assert_cmpint (nwrote, <=, main_len - main_offset); in writable()
192 main_offset += nwrote; in writable()
|
| D | unix-streams.c | 45 gssize nwrote, offset; in writer_thread() local
57 nwrote = g_output_stream_write (out, DATA + offset, in writer_thread()
60 if (nwrote <= 0 || err != NULL) in writer_thread()
62 offset += nwrote; in writer_thread()
65 g_assert (nwrote > 0 || err != NULL); in writer_thread()
214 gssize nwrote; in main_thread_wrote() local
216 nwrote = g_output_stream_write_finish (out, res, &err); in main_thread_wrote()
226 g_assert_cmpint (nwrote, <=, main_len - main_offset); in main_thread_wrote()
228 main_offset += nwrote; in main_thread_wrote()
|
| D | proxy-test.c | 459 gssize nread, nwrote, total; in proxy_bytes() local
485 for (total = 0; total < nread; total += nwrote) in proxy_bytes()
487 nwrote = g_socket_send_with_blocking (out_socket, in proxy_bytes()
501 gssize nread, nwrote; in proxy_thread() local
534 nwrote = g_socket_send (proxy->client_sock, command, 1, NULL, &error); in proxy_thread()
536 g_assert_cmpint (nwrote, ==, 1); in proxy_thread()
636 gssize nread, nwrote; in echo_server_thread() local
660 nwrote = g_socket_send (sock, buf, nread, NULL, &error); in echo_server_thread()
662 g_assert_cmpint (nwrote, ==, nread); in echo_server_thread()
846 gsize nwrote; in do_echo_test() local
[all …]
|
| D | pollable.c | 71 gssize nwrote; in write_callback() local
76 nwrote = g_output_stream_write (out, buf, 2, NULL, &error); in write_callback()
78 g_assert_cmpint (nwrote, ==, 2); in write_callback()
|
| D | socket.c | 52 gssize nread, nwrote; in echo_server_dgram_thread() local
65 nwrote = g_socket_send_to (sock, sa, buf, nread, cancellable, &error); in echo_server_dgram_thread()
69 g_assert_cmpint (nwrote, ==, nread); in echo_server_dgram_thread()
85 gssize nread, nwrote; in echo_server_thread() local
100 nwrote = g_socket_send (sock, buf, nread, NULL, &error); in echo_server_thread()
102 g_assert_cmpint (nwrote, ==, nread); in echo_server_thread()
|
| D | file.c | 705 gsize nwrote, length; in test_replace_cancel() local
729 &nwrote, NULL, &error); in test_replace_cancel()
731 g_assert_cmpint (nwrote, ==, strlen (replace_data)); in test_replace_cancel()
|
| /third_party/flutter/skia/third_party/externals/sdl/src/file/ |
| D | SDL_rwops.c | 350 size_t nwrote; in stdio_write() local
352 nwrote = fwrite(ptr, size, num, context->hidden.stdio.fp); in stdio_write()
353 if (nwrote == 0 && ferror(context->hidden.stdio.fp)) { in stdio_write()
356 return nwrote; in stdio_write()
|
| /third_party/glib/gio/ |
| D | goutputstream.c | 953 gssize nwrote; in async_ready_write_callback_wrapper() local
959 nwrote = -1; in async_ready_write_callback_wrapper()
963 nwrote = class->write_finish (stream, res, &error); in async_ready_write_callback_wrapper()
966 if (nwrote >= 0) in async_ready_write_callback_wrapper()
967 g_task_return_int (task, nwrote); in async_ready_write_callback_wrapper()
1607 gssize nwrote; in write_bytes_callback() local
1609 nwrote = g_output_stream_write_finish (G_OUTPUT_STREAM (stream), in write_bytes_callback()
1611 if (nwrote == -1) in write_bytes_callback()
1614 g_task_return_int (task, nwrote); in write_bytes_callback()
|
| /third_party/curl/lib/ |
| D | c-hyper.c | 96 ssize_t nwrote; in Curl_hyper_send() local
98 result = Curl_write(data, conn->sockfd, (void *)buf, buflen, &nwrote); in Curl_hyper_send()
114 return (size_t)nwrote; in Curl_hyper_send()
|
| /third_party/glib/glib/ |
| D | gtestutils.c | 3311 gsize nread, nwrote, total; in child_read() local
3345 for (total = 0; total < nread; total += nwrote) in child_read()
3349 nwrote = fwrite (buf + total, 1, nread - total, echo_file); in child_read()
3351 if (nwrote == 0) in child_read()
|
| /third_party/libsoup/ |
| D | NEWS | 3361 * The SoupSocket I/O methods now set nread/nwrote even on
|
| D | ChangeLog.pre-git | 1617 ensure that nread/nwrote parameters aren't NULL. They are also
|