Searched refs:TracedBuffer (Results 1 – 4 of 4) sorted by relevance
| /external/grpc-grpc/src/core/lib/iomgr/ |
| D | buffer_list.cc | 32 void TracedBuffer::AddNewEntry(TracedBuffer** head, uint32_t seq_no, in AddNewEntry()
35 TracedBuffer* new_elem = New<TracedBuffer>(seq_no, arg); in AddNewEntry()
43 TracedBuffer* ptr = *head; in AddNewEntry()
64 void TracedBuffer::ProcessTimestamp(TracedBuffer** head, in ProcessTimestamp()
68 TracedBuffer* elem = *head; in ProcessTimestamp()
69 TracedBuffer* next = nullptr; in ProcessTimestamp()
90 Delete<TracedBuffer>(elem); in ProcessTimestamp()
102 void TracedBuffer::Shutdown(TracedBuffer** head, grpc_error* shutdown_err) { in Shutdown()
104 TracedBuffer* elem = *head; in Shutdown()
110 Delete<TracedBuffer>(elem); in Shutdown()
|
| D | buffer_list.h | 54 class TracedBuffer {
58 static void AddNewEntry(grpc_core::TracedBuffer** head, uint32_t seq_no,
64 static void ProcessTimestamp(grpc_core::TracedBuffer** head,
70 static void Shutdown(grpc_core::TracedBuffer** head,
76 TracedBuffer(int seq_no, void* arg) in TracedBuffer() function
82 grpc_core::TracedBuffer* next_; /* The next TracedBuffer in the list */
85 class TracedBuffer {};
|
| D | tcp_posix.cc | 110 grpc_core::TracedBuffer* tb_head; /* List of traced buffers */
614 grpc_core::TracedBuffer::AddNewEntry( in tcp_write_with_timestamps()
661 grpc_core::TracedBuffer::ProcessTimestamp(&tcp->tb_head, serr, tss); in process_timestamp()
743 grpc_core::TracedBuffer::Shutdown(&tcp->tb_head, GRPC_ERROR_REF(error)); in tcp_handle_error()
|
| /external/grpc-grpc/test/core/iomgr/ |
| D | buffer_list_test.cc | 45 grpc_core::TracedBuffer* list = nullptr; in TestShutdownFlushesList()
50 grpc_core::TracedBuffer::AddNewEntry( in TestShutdownFlushesList()
53 grpc_core::TracedBuffer::Shutdown(&list, GRPC_ERROR_NONE); in TestShutdownFlushesList()
84 grpc_core::TracedBuffer* list = nullptr; in TestVerifierCalledOnAck()
87 grpc_core::TracedBuffer::AddNewEntry(&list, 213, &verifier_called); in TestVerifierCalledOnAck()
88 grpc_core::TracedBuffer::ProcessTimestamp(&list, &serr, &tss); in TestVerifierCalledOnAck()
91 grpc_core::TracedBuffer::Shutdown(&list, GRPC_ERROR_NONE); in TestVerifierCalledOnAck()
|