Lines Matching defs:connection_id
60 void SocketForwardRegionView::Recv(int connection_id, Packet* packet) {
63 (data()->queues_[connection_id].*ReadDirection)
71 bool SocketForwardRegionView::Send(int connection_id, const Packet& packet) {
77 auto& queue_pair = data()->queues_[connection_id];
87 (data()->queues_[connection_id].*WriteDirection)
92 void SocketForwardRegionView::IgnoreUntilBegin(int connection_id,
96 (data()->queues_[connection_id].*ReadDirection)
101 bool SocketForwardRegionView::IsOtherSideRecvClosed(int connection_id) {
102 auto& queue_pair = data()->queues_[connection_id];
139 int connection_id = 0;
165 Send(connection_id, begin_packet);
166 Send(connection_id, end_packet);
169 ++connection_id;
175 int connection_id, Queue QueuePair::*direction) {
176 auto& queue_pair = data()->queues_[connection_id];
199 void SocketForwardRegionView::MarkSendQueueDisconnected(int connection_id) {
200 MarkQueueDisconnected(connection_id, WriteDirection);
203 void SocketForwardRegionView::MarkRecvQueueDisconnected(int connection_id) {
204 MarkQueueDisconnected(connection_id, ReadDirection);
207 int SocketForwardRegionView::port(int connection_id) {
208 return data()->queues_[connection_id].port_;
242 int connection_id = AcquireConnectionID(port);
243 LOG(INFO) << "Acquired connection with id " << connection_id;
245 return {Sender{this, connection_id, current_generation},
246 Receiver{this, connection_id, current_generation}};
273 int connection_id = -1;
274 while (connection_id < 0) {
275 connection_id = GetWaitingConnectionID();
277 LOG(INFO) << "Accepted connection with id " << connection_id;
280 return {Sender{this, connection_id, current_generation},
281 Receiver{this, connection_id, current_generation}};
