Home
last modified time | relevance | path

Searched refs:read_slices (Results 1 – 4 of 4) sorted by relevance

/external/grpc-grpc/src/core/lib/iomgr/
Dtcp_custom.cc64 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 …]
Dendpoint_cfstream.cc52 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 …]
Dtcp_windows.cc117 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/
DCFStreamEndpointTests.mm155 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 …]