Lines Matching refs:socket_
15 SocketStream::SocketStream(AsyncSocket* socket) : socket_(NULL) {
20 delete socket_;
24 if (socket_)
25 delete socket_;
26 socket_ = socket;
27 if (socket_) {
28 socket_->SignalConnectEvent.connect(this, &SocketStream::OnConnectEvent);
29 socket_->SignalReadEvent.connect(this, &SocketStream::OnReadEvent);
30 socket_->SignalWriteEvent.connect(this, &SocketStream::OnWriteEvent);
31 socket_->SignalCloseEvent.connect(this, &SocketStream::OnCloseEvent);
36 AsyncSocket* socket = socket_;
37 if (socket_) {
38 socket_->SignalConnectEvent.disconnect(this);
39 socket_->SignalReadEvent.disconnect(this);
40 socket_->SignalWriteEvent.disconnect(this);
41 socket_->SignalCloseEvent.disconnect(this);
42 socket_ = NULL;
48 ASSERT(socket_ != NULL);
49 switch (socket_->GetState()) {
62 ASSERT(socket_ != NULL);
63 int result = socket_->Recv(buffer, buffer_len);
65 if (socket_->IsBlocking())
68 *error = socket_->GetError();
81 ASSERT(socket_ != NULL);
82 int result = socket_->Send(data, data_len);
84 if (socket_->IsBlocking())
87 *error = socket_->GetError();
96 ASSERT(socket_ != NULL);
97 socket_->Close();
101 ASSERT(socket == socket_);
106 ASSERT(socket == socket_);
111 ASSERT(socket == socket_);
116 ASSERT(socket == socket_);