Lines Matching defs:that
79 NetServer* that = (NetServer*)peer->data;
80 that->Emit("disconnect", nullptr);
91 NetServer* that = (NetServer*)server->data;
94 that->Emit("error", nullptr);
97 if (that->clients_ == nullptr) {
98 that->clients_ = new NetClient();
101 tmp->next = that->clients_;
102 that->clients_ = tmp;
105 uv_tcp_init(that->loop_, (uv_tcp_t*)&that->clients_->tcp);
106 that->clients_->tcp.data = server->data;
107 uv_accept(server, (uv_stream_t*)&that->clients_->tcp);
108 uv_read_start((uv_stream_t*)&that->clients_->tcp, EchoAlloc, AfterRead);
110 that->Emit("connect", nullptr);
120 NetServer* that = (NetServer*)handle->data;
122 for (NetClient* i = that->clients_; i != nullptr; i = i->next) {
127 napi_reference_unref(that->env_, that->thisVarRef_, &thisRefCount);
137 NetServer* that = (NetServer*)req->data;
145 that->Emit("write", nullptr);
149 that->Emit("error", nullptr);
152 void NetServer::TakeDiffactionsByStatus(uv_stream_t* handle, ssize_t nread, const uv_buf_t* buf, NetServer* that)
163 sreq->data = that;
168 if (!that->serverClosed_) {
178 uv_close((uv_handle_t*)&that->tcpServer_, OnServerClose);
179 that->serverClosed_ = 1;
185 that->Emit("read", nullptr);
194 wr->req.data = that;
196 that->Emit("error", nullptr);
212 NetServer* that = (NetServer*)handle->data;
218 TakeDiffactionsByStatus(handle, nread, buf, that);