96 void HdcJdwpSimulator::ProcessIncoming(uv_stream_t *client, ssize_t nread, const uv_buf_t *buf)  in ProcessIncoming()  argument
98     HiLog::Debug(LABEL, "ProcessIncoming :%{public}d", nread);  in ProcessIncoming()
100         if (nread > 0) {  in ProcessIncoming()
101             std::unique_ptr<char[]> recv = std::make_unique<char[]>(nread + 1);  in ProcessIncoming()
102             if (memset_s(recv.get(), nread, 0, nread) != EOK) {  in ProcessIncoming()
106             if (memcpy_s(recv.get(), nread, buf->base, nread) != EOK) {  in ProcessIncoming()
110             for (int i = 0; i < (nread + 1); i++) {  in ProcessIncoming()
118             reply.insert(reply.end(), buf->base, buf->base + nread);  in ProcessIncoming()
122             for (int i = 0; i < (HANDSHAKE_MESSAGE.size() + nread + 1); i++) {  in ProcessIncoming()
125             SendToStream(client, buf, HANDSHAKE_MESSAGE.size() + nread + 1,  in ProcessIncoming()
128             if (nread != UV_EOF) {  in ProcessIncoming()
131                 uv_err_name_r(nread, buffer, bufSize);  in ProcessIncoming()
141 void HdcJdwpSimulator::ReceiveNewFd(uv_stream_t *q, ssize_t nread, const uv_buf_t *buf)  in ReceiveNewFd()  argument
147                  pidCurr, nread);  in ReceiveNewFd()
148     if (nread < 0) {  in ReceiveNewFd()
149         if (nread != UV_EOF) {  in ReceiveNewFd()
152             uv_err_name_r(nread, buffer, bufSize);  in ReceiveNewFd()