| /developtools/hdc/src/test/jdwp/ |
| D | HdcJdwpSimulator.cpp | 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()
[all …]
|
| D | HdcJdwpSimulator.h | 48 static void ReceiveNewFd(uv_stream_t *q, ssize_t nread, const uv_buf_t *buf);
49 static void ProcessIncoming(uv_stream_t *client, ssize_t nread, const uv_buf_t *buf);
|
| /developtools/hdc/src/common/ |
| D | tcp.cpp | 35 void HdcTCPBase::RecvUDP(uv_udp_t *handle, ssize_t nread, const uv_buf_t *rcvbuf, const struct sock… in RecvUDP() argument
40 if (nread <= 0) { in RecvUDP()
70 void HdcTCPBase::ReadStream(uv_stream_t *tcp, ssize_t nread, const uv_buf_t *buf) in ReadStream() argument
77 if (nread == UV_ENOBUFS) { in ReadStream()
80 } else if (nread < 0) { in ReadStream()
85 uv_strerror_r(static_cast<int>(nread), buffer, bufSize); in ReadStream()
89 if (hSessionBase->FetchIOBuf(hSession, hSession->ioBuf, nread) < 0) { in ReadStream()
|
| D | tcp.h | 24 static void ReadStream(uv_stream_t *tcp, ssize_t nread, const uv_buf_t *buf);
31 …uv_udp_t *handle, ssize_t nread, const uv_buf_t *rcvbuf, const struct sockaddr *addr, unsigned fla…
|
| D | channel.cpp | 110 void HdcChannelBase::ReadStream(uv_stream_t *tcp, ssize_t nread, const uv_buf_t *buf) in ReadStream() argument
119 if (nread == UV_ENOBUFS) { in ReadStream()
122 } else if (nread == 0) { in ReadStream()
126 } else if (nread < 0) { in ReadStream()
130 uv_err_name_r(nread, buffer, bufSize); in ReadStream()
135 hChannel->availTailIndex += nread; in ReadStream()
|
| D | uart.cpp | 939 void HdcUARTBase::ReadDataFromUARTStream(uv_stream_t *stream, ssize_t nread, const uv_buf_t *buf) in ReadDataFromUARTStream() argument
947 if (nread < 0) { in ReadDataFromUARTStream()
948 uv_err_name_r(nread, buffer, bufSize); in ReadDataFromUARTStream()
951 hSession->sessionId, nread, buffer, in ReadDataFromUARTStream()
954 if (nread <= 0 or nread > signed(hSession->hUART->streamSize)) { in ReadDataFromUARTStream()
958 if (hSessionBase->FetchIOBuf(hSession, hSession->ioBuf, nread) < 0) { in ReadDataFromUARTStream()
968 hSession->hUART->streamSize -= nread; in ReadDataFromUARTStream()
969 WRITE_LOG(LOG_DEBUG, "%s sessionId:%u, nread:%d", __FUNCTION__, hSession->sessionId, nread); in ReadDataFromUARTStream()
|
| D | usb.h | 47 static void ReadUSB(uv_stream_t *stream, ssize_t nread, const uv_buf_t *buf);
|
| D | usb.cpp | 29 void HdcUSBBase::ReadUSB(uv_stream_t *stream, ssize_t nread, const uv_buf_t *buf) in ReadUSB() argument
33 if (hSessionBase->FetchIOBuf(hSession, hSession->ioBuf, nread) < 0) { in ReadUSB()
|
| D | session.cpp | 986 void HdcSessionBase::ReadCtrlFromSession(uv_stream_t *uvpipe, ssize_t nread, const uv_buf_t *buf) in ReadCtrlFromSession() argument
991 if (nread < 0) { in ReadCtrlFromSession()
994 uv_strerror_r(static_cast<int>(nread), buffer, bufSize); in ReadCtrlFromSession()
999 if (nread > 64) { // 64 : max length in ReadCtrlFromSession()
1005 hSessionBase->DispatchSessionThreadCommand(uvpipe, hSession, (uint8_t *)buf->base, nread); in ReadCtrlFromSession()
1142 void HdcSessionBase::ReadCtrlFromMain(uv_stream_t *uvpipe, ssize_t nread, const uv_buf_t *buf) in ReadCtrlFromMain() argument
1149 if (nread < 0) { in ReadCtrlFromMain()
1152 uv_strerror_r(static_cast<int>(nread), buffer, bufSize); in ReadCtrlFromMain()
1156 if (nread % formatCommandSize != 0) { in ReadCtrlFromMain()
1157 WRITE_LOG(LOG_FATAL, "ReadCtrlFromMain size failed, nread == %d", nread); in ReadCtrlFromMain()
[all …]
|
| D | channel.h | 26 static void ReadStream(uv_stream_t *tcp, ssize_t nread, const uv_buf_t *buf);
|
| D | session.h | 85 static void ReadCtrlFromMain(uv_stream_t *uvpipe, ssize_t nread, const uv_buf_t *buf);
86 static void ReadCtrlFromSession(uv_stream_t *uvpipe, ssize_t nread, const uv_buf_t *buf);
|
| D | forward.h | 71 static void ReadForwardBuf(uv_stream_t *stream, ssize_t nread, const uv_buf_t *buf);
|
| D | forward.cpp | 239 void HdcForwardBase::ReadForwardBuf(uv_stream_t *stream, ssize_t nread, const uv_buf_t *buf) in ReadForwardBuf() argument
242 if (nread < 0) { in ReadForwardBuf()
247 if (nread == 0) { in ReadForwardBuf()
251 ctx->thisClass->SendToTask(ctx->id, CMD_FORWARD_DATA, (uint8_t *)buf->base, nread); in ReadForwardBuf()
|
| D | uart.h | 195 static void ReadDataFromUARTStream(uv_stream_t *stream, ssize_t nread, const uv_buf_t *buf);
|
| /developtools/hdc/src/daemon/ |
| D | jdwp.cpp | 105 void HdcJdwp::ReadStream(uv_stream_t *pipe, ssize_t nread, const uv_buf_t *buf) in ReadStream() argument
108 if (nread == UV_ENOBUFS) { // It is definite enough, usually only 4 bytes in ReadStream()
111 } else if (nread == 0) { in ReadStream()
114 } else if (nread < JS_PKG_MIN_SIZE || nread > JS_PKG_MX_SIZE) { // valid Js package size in ReadStream()
116 } else if (nread < 0 || nread != 4) { // 4 : 4 bytes in ReadStream()
119 WRITE_LOG(LOG_DEBUG, "HdcJdwp::ReadStream invalid package nread:%d.", nread); in ReadStream()
127 if (nread == sizeof(uint32_t)) { // Java: pid in ReadStream()
132 if (jsMsg->msgLen == nread) { in ReadStream()
138 … WRITE_LOG(LOG_DEBUG, "HdcJdwp::ReadStream invalid js package size %d:%d.", jsMsg->msgLen, nread); in ReadStream()
|
| D | jdwp.h | 80 static void ReadStream(uv_stream_t *pipe, ssize_t nread, const uv_buf_t *buf);
|
| /developtools/hdc/src/host/ |
| D | client.h | 39 static void ReadStd(uv_stream_t *stream, ssize_t nread, const uv_buf_t *buf);
|
| D | client.cpp | 288 void HdcClient::ReadStd(uv_stream_t *stream, ssize_t nread, const uv_buf_t *buf) in ReadStd() argument
293 if (nread <= 0) { in ReadStd()
|
| /developtools/hdc/src/test/ |
| D | ut_mod.cpp | 172 auto funcOnRead = [](uv_stream_t *client, ssize_t nread, const uv_buf_t *buf) -> void { in UtForwardWaiter() argument
173 if (nread > 0 && !strcmp(buf->base, MESSAGE_SUCCESS.c_str())) { in UtForwardWaiter()
|