Searched refs:write_slices (Results 1 – 5 of 5) sorted by relevance
| /external/grpc-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);
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);
250 grpc_slice_buffer_reset_and_unref(&write_slices);
[all …]
|
| /external/grpc-grpc/src/core/lib/iomgr/ |
| D | tcp_windows.cc | 116 grpc_slice_buffer* write_slices; member
289 GPR_ASSERT(info->bytes_transfered == tcp->write_slices->length); in on_write()
319 tcp->write_slices = slices; in win_write()
320 GPR_ASSERT(tcp->write_slices->count <= UINT_MAX); in win_write()
321 if (tcp->write_slices->count > GPR_ARRAY_SIZE(local_buffers)) { in win_write()
322 buffers = (WSABUF*)gpr_malloc(sizeof(WSABUF) * tcp->write_slices->count); in win_write()
326 for (i = 0; i < tcp->write_slices->count; i++) { in win_write()
327 len = GRPC_SLICE_LENGTH(tcp->write_slices->slices[i]); in win_write()
330 buffers[i].buf = (char*)GRPC_SLICE_START_PTR(tcp->write_slices->slices[i]); in win_write()
334 status = WSASend(socket->socket, buffers, (DWORD)tcp->write_slices->count, in win_write()
[all …]
|
| D | tcp_custom.cc | 65 grpc_slice_buffer* write_slices; member
223 static void endpoint_write(grpc_endpoint* ep, grpc_slice_buffer* write_slices, in endpoint_write() argument
231 for (j = 0; j < write_slices->count; j++) { in endpoint_write()
232 char* data = grpc_dump_slice(write_slices->slices[j], in endpoint_write()
247 tcp->write_slices = write_slices; in endpoint_write()
248 GPR_ASSERT(tcp->write_slices->count <= UINT_MAX); in endpoint_write()
249 if (tcp->write_slices->count == 0) { in endpoint_write()
257 grpc_custom_socket_vtable->write(tcp->socket, tcp->write_slices, in endpoint_write()
|
| D | endpoint_cfstream.cc | 53 grpc_slice_buffer* write_slices; member
147 ep->write_slices = nullptr; in CallWriteCb()
197 grpc_slice_buffer_reset_and_unref_internal(ep->write_slices); in WriteAction()
203 grpc_slice slice = grpc_slice_buffer_take_first(ep->write_slices); in WriteAction()
208 grpc_slice_buffer_reset_and_unref_internal(ep->write_slices); in WriteAction()
222 ep->write_slices, grpc_slice_sub(slice, write_size, slice_len)); in WriteAction()
224 if (ep->write_slices->length > 0) { in WriteAction()
279 ep_impl->write_slices = slices; in CFStreamWrite()
358 ep_impl->write_slices = nil; in grpc_cfstream_endpoint_create()
|
| D | tcp_uv.cc | 152 grpc_slice_buffer* write_slices, in uv_socket_write() argument
159 uv_buffers = (uv_buf_t*)gpr_malloc(sizeof(uv_buf_t) * write_slices->count); in uv_socket_write()
160 for (size_t i = 0; i < write_slices->count; i++) { in uv_socket_write()
161 uv_buffers[i].base = (char*)GRPC_SLICE_START_PTR(write_slices->slices[i]); in uv_socket_write()
162 uv_buffers[i].len = GRPC_SLICE_LENGTH(write_slices->slices[i]); in uv_socket_write()
170 write_slices->count, uv_write_callback); in uv_socket_write()
|