Lines Matching refs:server_
101 : server_(server), in VirtualSocket()
149 int result = server_->Bind(this, &local_addr_); in Bind()
158 server_->msg_queue_->Post(this, MSG_ID_ADDRESS_BOUND); in Bind()
170 server_->Unbind(local_addr_, this); in Close()
181 server_->Disconnect(server_->LookupBinding(addr)); in Close()
191 server_->LookupConnection(local_addr_, remote_addr_); in Close()
197 socket = server_->LookupBinding(remote_addr_); in Close()
199 server_->Disconnect(socket); in Close()
202 server_->RemoveConnection(remote_addr_, local_addr_); in Close()
203 server_->RemoveConnection(local_addr_, remote_addr_); in Close()
207 if (server_->msg_queue_) { in Close()
208 server_->msg_queue_->Clear(this, MSG_ID_CONNECT, &msgs); in Close()
216 server_->LookupConnection(local_addr_, data->addr); in Close()
221 server_->Disconnect(socket); in Close()
222 server_->RemoveConnection(local_addr_, data->addr); in Close()
224 server_->Disconnect(server_->LookupBinding(data->addr)); in Close()
229 if (server_->msg_queue_) { in Close()
230 server_->msg_queue_->Clear(this); in Close()
280 server_->msg_queue_->Get(&msg); in RecvFrom()
281 server_->msg_queue_->Dispatch(&msg); in RecvFrom()
299 bool was_full = (recv_buffer_size_ == server_->recv_buffer_capacity_); in RecvFrom()
302 VirtualSocket* sender = server_->LookupBinding(remote_addr_); in RecvFrom()
304 server_->SendTcp(sender); in RecvFrom()
330 VirtualSocket* socket = new VirtualSocket(server_, AF_INET, type_, async_); in Accept()
409 server_->Disconnect(server_->LookupBinding(data->addr)); in OnMessage()
450 int result = server_->Connect(this, addr, use_delay); in InitiateConnect()
464 server_->AddConnection(remote_addr_, local_addr_, this); in CompleteConnect()
476 int result = server_->Bind(this, &local_addr_); in SendUdp()
485 return server_->SendUdp(this, static_cast<const char*>(pv), cb, addr); in SendUdp()
489 size_t capacity = server_->send_buffer_capacity_ - send_buffer_.size(); in SendTcp()
498 server_->SendTcp(this); in SendTcp()
503 : server_(ss), server_owned_(false), msg_queue_(NULL), stop_on_idle_(false), in VirtualSocketServer()
512 if (!server_) { in VirtualSocketServer()
513 server_ = new PhysicalSocketServer(); in VirtualSocketServer()
524 delete server_; in ~VirtualSocketServer()