Searched refs:write_slices (Results 1 – 5 of 5) sorted by relevance
| /third_party/grpc/test/core/iomgr/ios/CFStreamTests/ |
| D | CFStreamEndpointTests.mm | 159 grpc_slice_buffer write_slices;
166 grpc_slice_buffer_init(&write_slices);
168 grpc_slice_buffer_add(&write_slices, slice);
170 grpc_endpoint_write(ep_, &write_slices, &write_done, nullptr);
200 grpc_slice_buffer_reset_and_unref(&write_slices);
212 grpc_slice_buffer write_slices;
223 grpc_slice_buffer_init(&write_slices);
225 grpc_slice_buffer_add(&write_slices, slice);
227 grpc_endpoint_write(ep_, &write_slices, &write_done, nullptr);
250 grpc_slice_buffer_reset_and_unref(&write_slices);
[all …]
|
| /third_party/grpc/src/core/lib/iomgr/ |
| D | tcp_custom.cc | 65 grpc_slice_buffer* write_slices = nullptr; member
231 static void endpoint_write(grpc_endpoint* ep, grpc_slice_buffer* write_slices, in endpoint_write() argument
239 for (j = 0; j < write_slices->count; j++) { in endpoint_write()
240 char* data = grpc_dump_slice(write_slices->slices[j], in endpoint_write()
256 tcp->write_slices = write_slices; in endpoint_write()
257 GPR_ASSERT(tcp->write_slices->count <= UINT_MAX); in endpoint_write()
258 if (tcp->write_slices->count == 0) { in endpoint_write()
266 grpc_custom_socket_vtable->write(tcp->socket, tcp->write_slices, in endpoint_write()
|
| D | endpoint_cfstream.cc | 55 grpc_slice_buffer* write_slices; member
149 ep->write_slices = nullptr; in CallWriteCb()
199 grpc_slice_buffer_reset_and_unref_internal(ep->write_slices); in WriteAction()
205 grpc_slice slice = grpc_slice_buffer_take_first(ep->write_slices); in WriteAction()
210 grpc_slice_buffer_reset_and_unref_internal(ep->write_slices); in WriteAction()
224 ep->write_slices, grpc_slice_sub(slice, write_size, slice_len)); in WriteAction()
226 if (ep->write_slices->length > 0) { in WriteAction()
284 ep_impl->write_slices = slices; in CFStreamWrite()
387 ep_impl->write_slices = nil; in grpc_cfstream_endpoint_create()
|
| D | tcp_windows.cc | 117 grpc_slice_buffer* write_slices; member
337 GPR_ASSERT(info->bytes_transferred == tcp->write_slices->length); in on_write()
379 tcp->write_slices = slices; in win_write()
380 GPR_ASSERT(tcp->write_slices->count <= UINT_MAX); in win_write()
381 if (tcp->write_slices->count > GPR_ARRAY_SIZE(local_buffers)) { in win_write()
382 buffers = (WSABUF*)gpr_malloc(sizeof(WSABUF) * tcp->write_slices->count); in win_write()
386 for (i = 0; i < tcp->write_slices->count; i++) { in win_write()
387 len = GRPC_SLICE_LENGTH(tcp->write_slices->slices[i]); in win_write()
390 buffers[i].buf = (char*)GRPC_SLICE_START_PTR(tcp->write_slices->slices[i]); in win_write()
394 status = WSASend(socket->socket, buffers, (DWORD)tcp->write_slices->count, in win_write()
[all …]
|
| D | tcp_uv.cc | 151 grpc_slice_buffer* write_slices, in uv_socket_write() argument
158 uv_buffers = (uv_buf_t*)gpr_malloc(sizeof(uv_buf_t) * write_slices->count); in uv_socket_write()
159 for (size_t i = 0; i < write_slices->count; i++) { in uv_socket_write()
160 uv_buffers[i].base = (char*)GRPC_SLICE_START_PTR(write_slices->slices[i]); in uv_socket_write()
161 uv_buffers[i].len = GRPC_SLICE_LENGTH(write_slices->slices[i]); in uv_socket_write()
169 write_slices->count, uv_write_callback); in uv_socket_write()
|