Lines Matching refs:server_
99 : server_(server), family_(family), type_(type), async_(async),
135 int result = server_->Bind(this, &local_addr_);
153 server_->Unbind(local_addr_, this);
164 server_->Disconnect(server_->LookupBinding(addr));
174 server_->LookupConnection(local_addr_, remote_addr_);
180 socket = server_->LookupBinding(remote_addr_);
182 server_->Disconnect(socket);
185 server_->RemoveConnection(remote_addr_, local_addr_);
186 server_->RemoveConnection(local_addr_, remote_addr_);
190 if (server_->msg_queue_) {
191 server_->msg_queue_->Clear(this, MSG_ID_CONNECT, &msgs);
198 VirtualSocket* socket = server_->LookupConnection(local_addr_,
204 server_->Disconnect(socket);
205 server_->RemoveConnection(local_addr_, data->addr);
207 server_->Disconnect(server_->LookupBinding(data->addr));
212 if (server_->msg_queue_) {
213 server_->msg_queue_->Clear(this);
261 server_->msg_queue_->Get(&msg);
262 server_->msg_queue_->Dispatch(&msg);
280 bool was_full = (recv_buffer_size_ == server_->recv_buffer_capacity_);
283 VirtualSocket* sender = server_->LookupBinding(remote_addr_);
285 server_->SendTcp(sender);
311 VirtualSocket* socket = new VirtualSocket(server_, AF_INET, type_,
391 server_->Disconnect(server_->LookupBinding(data->addr));
445 int result = server_->Connect(this, addr, use_delay);
459 server_->AddConnection(remote_addr_, local_addr_, this);
469 int result = server_->Bind(this, &local_addr_);
478 return server_->SendUdp(this, static_cast<const char*>(pv), cb, addr);
482 size_t capacity = server_->send_buffer_capacity_ - send_buffer_.size();
491 server_->SendTcp(this);
495 VirtualSocketServer* server_;
539 : server_(ss), server_owned_(false), msg_queue_(NULL), stop_on_idle_(false),
548 if (!server_) {
549 server_ = new PhysicalSocketServer();
560 delete server_;