Searched refs:read_slices (Results 1 – 4 of 4) sorted by relevance
/external/grpc-grpc/src/core/lib/iomgr/ |
D | tcp_custom.cc | 64 grpc_slice_buffer* read_slices; member 134 for (i = 0; i < tcp->read_slices->count; i++) { in call_read_cb() 135 char* dump = grpc_dump_slice(tcp->read_slices->slices[i], in call_read_cb() 142 tcp->read_slices = nullptr; in call_read_cb() 157 if ((size_t)nread < tcp->read_slices->length) { in custom_read_callback() 162 tcp->read_slices, tcp->read_slices->length - (size_t)nread, &garbage); in custom_read_callback() 166 grpc_slice_buffer_reset_and_unref_internal(tcp->read_slices); in custom_read_callback() 181 char* buffer = (char*)GRPC_SLICE_START_PTR(tcp->read_slices->slices[0]); in tcp_read_allocation_done() 182 size_t len = GRPC_SLICE_LENGTH(tcp->read_slices->slices[0]); in tcp_read_allocation_done() 186 grpc_slice_buffer_reset_and_unref_internal(tcp->read_slices); in tcp_read_allocation_done() [all …]
|
D | endpoint_cfstream.cc | 52 grpc_slice_buffer* read_slices; member 125 for (i = 0; i < ep->read_slices->count; i++) { in CallReadCb() 126 char* dump = grpc_dump_slice(ep->read_slices->slices[i], in CallReadCb() 134 ep->read_slices = nullptr; in CallReadCb() 155 grpc_slice_buffer_reset_and_unref_internal(ep->read_slices); in ReadAction() 161 GPR_ASSERT(ep->read_slices->count == 1); in ReadAction() 162 grpc_slice slice = ep->read_slices->slices[0]; in ReadAction() 167 grpc_slice_buffer_reset_and_unref_internal(ep->read_slices); in ReadAction() 179 grpc_slice_buffer_reset_and_unref_internal(ep->read_slices); in ReadAction() 186 grpc_slice_buffer_trim_end(ep->read_slices, len - read_size, nullptr); in ReadAction() [all …]
|
D | tcp_windows.cc | 117 grpc_slice_buffer* read_slices; member 196 grpc_slice_buffer_add(tcp->read_slices, sub); in on_read() 212 static void win_read(grpc_endpoint* ep, grpc_slice_buffer* read_slices, in win_read() argument 230 tcp->read_slices = read_slices; in win_read() 231 grpc_slice_buffer_reset_and_unref_internal(read_slices); in win_read()
|
/external/grpc-grpc/test/core/iomgr/ios/CFStreamTests/ |
D | CFStreamEndpointTests.mm | 155 grpc_slice_buffer read_slices; 186 grpc_slice_buffer_init(&read_slices); 188 while (read_slices.length < kBufferSize) { 193 grpc_slice_buffer_move_into(&read_one_slice, &read_slices); 194 XCTAssertLessThanOrEqual(read_slices.length, kBufferSize); 196 XCTAssertTrue(compare_slice_buffer_with_buffer(&read_slices, read_buffer, kBufferSize)); 199 grpc_slice_buffer_reset_and_unref(&read_slices); 209 grpc_slice_buffer read_slices; 219 grpc_slice_buffer_init(&read_slices); 221 grpc_endpoint_read(ep_, &read_slices, &read_done); [all …]
|