| /dports/devel/aws-c-io/aws-c-io-0.10.12/source/posix/ |
| H A D | socket.c | 1244 struct write_request { struct
1367 … struct write_request *write_request = AWS_CONTAINER_OF(node, struct write_request, node); in aws_socket_close() local
1368 … size_t bytes_written = write_request->original_buffer_len - write_request->cursor_cpy.len; in aws_socket_close()
1369 …write_request->written_fn(socket, write_request->error_code, bytes_written, write_request->write_u… in aws_socket_close()
1375 … struct write_request *write_request = AWS_CONTAINER_OF(node, struct write_request, node); in aws_socket_close() local
1431 … struct write_request *write_request = AWS_CONTAINER_OF(node, struct write_request, node); in s_written_task() local
1433 …write_request->written_fn(socket, write_request->error_code, bytes_written, write_request->write_u… in s_written_task()
1473 struct write_request *write_request = AWS_CONTAINER_OF(node, struct write_request, node); in s_process_write_requests() local
1549 … struct write_request *write_request = AWS_CONTAINER_OF(node, struct write_request, node); in s_process_write_requests() local
1798 …struct write_request *write_request = aws_mem_calloc(socket->allocator, 1, sizeof(struct write_req… local
[all …]
|
| H A D | pipe.c | 49 struct write_request { struct
68 struct write_request *currently_invoking_write_callback; argument
413 struct write_request *request = AWS_CONTAINER_OF(node, struct write_request, list_node); in s_write_end_complete_front_write_request()
420 struct write_request *prev_invoking_request = write_impl->currently_invoking_write_callback; in s_write_end_complete_front_write_request()
444 struct write_request *request = AWS_CONTAINER_OF(node, struct write_request, list_node); in s_write_end_process_requests()
525 …struct write_request *request = aws_mem_calloc(write_impl->alloc, 1, sizeof(struct write_request)); in aws_pipe_write()
574 struct write_request *request = AWS_CONTAINER_OF(node, struct write_request, list_node); in aws_pipe_clean_up_write_end()
|
| /dports/devel/aws-c-io/aws-c-io-0.10.12/source/windows/iocp/ |
| H A D | pipe.c | 91 struct write_request { struct
710 struct write_request *write_req = AWS_CONTAINER_OF(node, struct write_request, list_node); in aws_pipe_clean_up_write_end()
740 struct write_request *write = aws_mem_acquire(write_impl->alloc, sizeof(struct write_request)); in aws_pipe_write()
779 …struct write_request *write_request = AWS_CONTAINER_OF(overlapped, struct write_request, overlappe… in s_write_end_on_write_completion() local
782 AWS_ASSERT((num_bytes_transferred == write_request->original_cursor.len) || status_code); in s_write_end_on_write_completion()
784 struct aws_byte_cursor original_cursor = write_request->original_cursor; in s_write_end_on_write_completion()
785 aws_pipe_on_write_completed_fn *user_callback = write_request->user_callback; in s_write_end_on_write_completion()
786 void *user_data = write_request->user_data; in s_write_end_on_write_completion()
790 if (!write_request->is_write_end_cleaned_up) { in s_write_end_on_write_completion()
791 aws_linked_list_remove(&write_request->list_node); in s_write_end_on_write_completion()
[all …]
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/lib/cmetrics/src/ |
| H A D | cmt_encode_prometheus_remote_write.c | 84 context->write_request.n_metadata = mk_list_size(&context->metadata_entries); in render_remote_write_context_to_sds()
86 context->write_request.timeseries = calloc(context->write_request.n_timeseries, in render_remote_write_context_to_sds()
89 if (context->write_request.timeseries == NULL) { in render_remote_write_context_to_sds()
95 context->write_request.metadata = calloc(context->write_request.n_metadata, in render_remote_write_context_to_sds()
98 if (context->write_request.metadata == NULL) { in render_remote_write_context_to_sds()
101 free(context->write_request.timeseries); in render_remote_write_context_to_sds()
111 context->write_request.timeseries[entry_index++] = &time_series_entry->data; in render_remote_write_context_to_sds()
119 context->write_request.metadata[entry_index++] = &metadata_entry->data; in render_remote_write_context_to_sds()
132 free(context->write_request.timeseries); in render_remote_write_context_to_sds()
134 free(context->write_request.metadata); in render_remote_write_context_to_sds()
[all …]
|
| /dports/net/libdmapsharing/libdmapsharing-2.9.41/libdmapsharing/ |
| H A D | dmap-gst-input-stream.c | 58 gsize write_request; /* Number of bytes that must be read member
219 stream->priv->write_request = info.size; in dmap_gst_input_stream_new_buffer_cb()
230 stream->priv->write_request = 0; in dmap_gst_input_stream_new_buffer_cb()
333 if (gst_stream->priv->write_request > count) in dmap_gst_input_stream_read()
334 gst_stream->priv->write_request -= count; in dmap_gst_input_stream_read()
336 gst_stream->priv->write_request = 0; in dmap_gst_input_stream_read()
338 if (gst_stream->priv->write_request <= 0) { in dmap_gst_input_stream_read()
461 stream->priv->write_request = 0; in dmap_gst_input_stream_init()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/native_client/src/trusted/desc/ |
| H A D | nacl_desc_io_alloc_ctor_test.c | 67 size_t write_request; in WriteTestData() local
77 write_request = sizeof test_data; in WriteTestData()
78 if (write_request > to_write) { in WriteTestData()
79 write_request = to_write; in WriteTestData()
83 CHECK(WriteFile(hFile, test_data, (DWORD) write_request, &written, NULL)); in WriteTestData()
85 written = write(hFile, test_data, write_request); in WriteTestData()
90 CHECK((size_t) written <= write_request); in WriteTestData()
|
| /dports/news/inn-current/inn-2.7-20211226/storage/ovsqlite/ |
| H A D | ovsqlite.c | 164 write_request(void) in write_request() function
261 if (!write_request()) in server_handshake()
317 if (!write_request()) in ovsqlite_groupstats()
374 if (!write_request()) in ovsqlite_groupadd()
402 if (!write_request()) in ovsqlite_groupdel()
445 if (!write_request()) in ovsqlite_add()
483 if (!write_request()) in ovsqlite_cancel()
562 if (!write_request()) in fill_search_buffer()
713 if (!write_request()) in ovsqlite_getartinfo()
745 if (!write_request()) in expire_one()
[all …]
|
| /dports/archivers/maxcso/maxcso-1.10.0/libuv/test/ |
| H A D | test-tcp-write-after-connect.c | 30 uv_write_t write_request; variable
57 ASSERT(0 == uv_write(&write_request, in TEST_IMPL()
|
| /dports/devel/py-uvloop/uvloop-0.16.0/vendor/libuv/test/ |
| H A D | test-tcp-write-after-connect.c | 30 uv_write_t write_request; variable
62 ASSERT(0 == uv_write(&write_request, in TEST_IMPL()
|
| /dports/devel/libuv/libuv-v1.42.0/test/ |
| H A D | test-tcp-write-after-connect.c | 30 uv_write_t write_request; variable
62 ASSERT(0 == uv_write(&write_request, in TEST_IMPL()
|
| /dports/www/R-cran-httpuv/httpuv/src/libuv/test/ |
| H A D | test-tcp-write-after-connect.c | 30 uv_write_t write_request; variable
57 ASSERT(0 == uv_write(&write_request, in TEST_IMPL()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/native_client/src/shared/platform/win/ |
| H A D | nacl_host_desc_mmap_win_test.c | 66 size_t write_request; in WriteTestData() local
71 write_request = sizeof buffer; in WriteTestData()
72 if (write_request > to_write) { in WriteTestData()
73 write_request = to_write; in WriteTestData()
76 CHECK(WriteFile(hFile, buffer, (DWORD) write_request, &written, NULL)); in WriteTestData()
|
| /dports/www/p5-ApacheBench/ApacheBench-0.73/doc/ |
| H A D | C_Functions_Tree | 17 -> send a new request; write_request()
52 -> write_request();
56 write_request()
|
| /dports/misc/adios2/ADIOS2-2.7.1/thirdparty/EVPath/EVPath/ |
| H A D | cmib.c | 620 rinfo *write_request; in handle_response() local
627 if (write_request == NULL) { in handle_response()
636 if(write_request->wr == NULL) in handle_response()
663 for(i = 0; i < write_request->mrlen && write_request->mrlist; i ++) in handle_response()
668 if(write_request->wr) in handle_response()
670 free_sg_list(write_request->wr->sg_list, write_request->mrlen, free_data_elements); in handle_response()
671 free(write_request->wr); in handle_response()
735 free_sg_list(write_request->wr->sg_list, write_request->mrlen, free_data_elements); in handle_response()
737 free(write_request->wr); in handle_response()
738 write_request->wr = NULL; in handle_response()
[all …]
|
| /dports/irc/bitlbee/bitlbee-3.6/protocols/purple/ |
| H A D | ft-direct.c | 117 px->ft->write_request = prpl_xfer_write_request; in prplcb_xfer_new_send_cb()
185 px->ft->write_request(px->ft); in prplcb_xfer_read()
233 px->ft->write_request(px->ft); in prplcb_xfer_send_cb()
|
| /dports/net/p5-IO-Socket-Socks-Wrapper/IO-Socket-Socks-Wrapper-0.17/t/ |
| H A D | 02_in_pkg_no_global.t | 43 $http->write_request(GET => '/stuff');
82 $http->write_request(GET => '/');
|
| H A D | 01_in_pkg.t | 62 $http->write_request(GET => '/index');
73 $http->write_request(GET => '/index');
|
| /dports/net/py-h11/h11-0.12.0/h11/ |
| H A D | _writers.py | 31 def write_request(request, write): function
115 (CLIENT, IDLE): write_request,
|
| /dports/games/freecell-solver/freecell-solver-6.2.0/ |
| H A D | forking_range_solver.c | 60 static inline void write_request(const fc_solve_ms_deal_idx_type end_board, in write_request() function
99 write_request(end_board, board_num_step, next_board_num_ptr, worker); in transaction()
242 write_request( in range_solvers_main()
|
| /dports/emulators/simh/simh-3.9.0_5/ |
| H A D | sim_ether.h | 251 struct write_request { struct
252 struct write_request *next; argument
256 struct write_request *write_buffers;
|
| /dports/www/p5-HTTP-Tiny-UA/HTTP-Tiny-UA-0.006/t/lib/ |
| H A D | TestUtils.pm | 160 my $original_write_request = \&HTTP::Tiny::Handle::write_request;
161 *HTTP::Tiny::Handle::write_request = sub {
|
| /dports/lang/perl5.30/perl-5.30.3/cpan/HTTP-Tiny/t/ |
| H A D | Util.pm | 164 my $original_write_request = \&HTTP::Tiny::Handle::write_request;
165 *HTTP::Tiny::Handle::write_request = sub {
|
| /dports/lang/perl5.32/perl-5.32.1/cpan/HTTP-Tiny/t/ |
| H A D | Util.pm | 164 my $original_write_request = \&HTTP::Tiny::Handle::write_request;
165 *HTTP::Tiny::Handle::write_request = sub {
|
| /dports/lang/perl5.34/perl-5.34.0/cpan/HTTP-Tiny/t/ |
| H A D | Util.pm | 164 my $original_write_request = \&HTTP::Tiny::Handle::write_request;
165 *HTTP::Tiny::Handle::write_request = sub {
|
| /dports/www/p5-HTTP-Tiny-SPDY/HTTP-Tiny-SPDY-0.020/t/http_tiny/ |
| H A D | Util.pm | 161 my $original_write_request = \&HTTP::Tiny::Handle::SPDY::write_request;
162 *HTTP::Tiny::Handle::SPDY::write_request = sub {
|