Home
last modified time | relevance | path

Searched refs:nread (Results 1 - 21 of 21) sorted by relevance

/developtools/hdc/src/test/jdwp/
H A DHdcJdwpSimulator.cpp96 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()
141 ReceiveNewFd(uv_stream_t *q, ssize_t nread, const uv_buf_t *buf) ReceiveNewFd() argument
[all...]
H A DHdcJdwpSimulator.h48 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/
H A Dtcp.cpp35 void HdcTCPBase::RecvUDP(uv_udp_t *handle, ssize_t nread, const uv_buf_t *rcvbuf, const struct sockaddr *addr, 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()
90 WRITE_LOG(LOG_FATAL, "ReadStream FetchIOBuf error nread:%zd", nread); in ReadStream()
H A Dtcp.h24 static void ReadStream(uv_stream_t *tcp, ssize_t nread, const uv_buf_t *buf);
32 uv_udp_t *handle, ssize_t nread, const uv_buf_t *rcvbuf, const struct sockaddr *addr, unsigned flags);
H A Dchannel.cpp110 void HdcChannelBase::ReadStream(uv_stream_t *tcp, ssize_t nread, const uv_buf_t *buf) in ReadStream() argument
121 if (nread == UV_ENOBUFS) { in ReadStream()
124 } else if (nread == 0) { in ReadStream()
128 } else if (nread < 0) { in ReadStream()
132 uv_err_name_r(nread, buffer, bufSize); in ReadStream()
137 hChannel->availTailIndex += nread; in ReadStream()
H A Dusb.h48 static void ReadUSB(uv_stream_t *stream, ssize_t nread, const uv_buf_t *buf);
H A Dusb.cpp29 void HdcUSBBase::ReadUSB(uv_stream_t *stream, ssize_t nread, const uv_buf_t *buf) in ReadUSB() argument
34 if (hSessionBase->FetchIOBuf(hSession, hSession->ioBuf, nread) < 0) { in ReadUSB()
H A Duart.cpp946 void HdcUARTBase::ReadDataFromUARTStream(uv_stream_t *stream, ssize_t nread, const uv_buf_t *buf) in ReadDataFromUARTStream() argument
954 if (nread < 0) { in ReadDataFromUARTStream()
955 uv_err_name_r(nread, buffer, bufSize); in ReadDataFromUARTStream()
957 WRITE_LOG(LOG_DEBUG, "%s sessionId:%u, nread:%zd %s streamSize %zu", __FUNCTION__, in ReadDataFromUARTStream()
958 hSession->sessionId, nread, buffer, in ReadDataFromUARTStream()
961 if (nread <= 0 or nread > signed(hSession->hUART->streamSize)) { in ReadDataFromUARTStream()
965 if (hSessionBase->FetchIOBuf(hSession, hSession->ioBuf, nread) < 0) { in ReadDataFromUARTStream()
975 hSession->hUART->streamSize -= nread; in ReadDataFromUARTStream()
976 WRITE_LOG(LOG_DEBUG, "%s sessionId:%u, nread in ReadDataFromUARTStream()
[all...]
H A Dsession.cpp1041 ssize_t nread = Base::ReadFromFd(hSession->ctrlFd[STREAM_MAIN], buf, size); in ReadCtrlFromSession() local
1043 if (nread < 0) { in ReadCtrlFromSession()
1046 uv_strerror_r(static_cast<int>(nread), buffer, bufSize); in ReadCtrlFromSession()
1051 if (nread == 0) { in ReadCtrlFromSession()
1057 hSessionBase->DispatchSessionThreadCommand(hSession, reinterpret_cast<uint8_t *>(buf), nread); in ReadCtrlFromSession()
1214 ssize_t nread = Base::ReadFromFd(hSession->ctrlFd[STREAM_WORK], buf, size); in ReadCtrlFromMain() local
1216 if (nread < 0) { in ReadCtrlFromMain()
1219 uv_strerror_r(static_cast<int>(nread), buffer, bufSize); in ReadCtrlFromMain()
1223 if (nread % formatCommandSize != 0) { in ReadCtrlFromMain()
1224 WRITE_LOG(LOG_FATAL, "ReadCtrlFromMain size failed, nread in ReadCtrlFromMain()
[all...]
H A Dforward.cpp255 void HdcForwardBase::ReadForwardBuf(uv_stream_t *stream, ssize_t nread, const uv_buf_t *buf) in ReadForwardBuf() argument
258 if (nread < 0) { in ReadForwardBuf()
259 WRITE_LOG(LOG_INFO, "ReadForwardBuf nread:%zd id:%u", nread, ctx->id); in ReadForwardBuf()
264 if (nread == 0) { in ReadForwardBuf()
265 WRITE_LOG(LOG_INFO, "ReadForwardBuf nread:0 id:%u", ctx->id); in ReadForwardBuf()
269 ctx->thisClass->SendToTask(ctx->id, CMD_FORWARD_DATA, (uint8_t *)buf->base, nread); in ReadForwardBuf()
H A Dchannel.h26 static void ReadStream(uv_stream_t *tcp, ssize_t nread, const uv_buf_t *buf);
H A Dforward.h77 static void ReadForwardBuf(uv_stream_t *stream, ssize_t nread, const uv_buf_t *buf);
H A Duart.h196 static void ReadDataFromUARTStream(uv_stream_t *stream, ssize_t nread, const uv_buf_t *buf);
/developtools/hdc/src/daemon/
H A Ddaemon_bridge.cpp60 void HdcDaemonBridge::AcceptClient(uv_stream_t *uvpipe, ssize_t nread, const uv_buf_t *buf) in AcceptClient() argument
71 if (nread != SOCKET_FD_LEN) { in AcceptClient()
72 WRITE_LOG(LOG_FATAL, "AcceptClient err nread %d", nread); in AcceptClient()
H A Djdwp.cpp115 void HdcJdwp::ReadStream(uv_stream_t *pipe, ssize_t nread, const uv_buf_t *buf) in ReadStream() argument
121 if (nread == UV_ENOBUFS) { // It is definite enough, usually only 4 bytes in ReadStream()
124 } else if (nread == 0) { in ReadStream()
127 } else if (nread < signed(JS_PKG_MIN_SIZE + sizeof(JsMsgHeader)) || in ReadStream()
128 nread > signed(JS_PKG_MAX_SIZE + sizeof(JsMsgHeader))) { in ReadStream()
130 } else if (nread < 0 || nread != 4) { // 4 : 4 bytes in ReadStream()
133 WRITE_LOG(LOG_DEBUG, "HdcJdwp::ReadStream invalid package nread:%d.", nread); in ReadStream()
141 if (nread in ReadStream()
[all...]
H A Ddaemon_bridge.h42 static void AcceptClient(uv_stream_t *uvpipe, ssize_t nread, const uv_buf_t *buf);
H A Djdwp.h88 static void ReadStream(uv_stream_t *pipe, ssize_t nread, const uv_buf_t *buf);
/developtools/profiler/host/smartperf/client/client_command/
H A Dstartup_delay.cpp208 ssize_t nread; in ExecuteCommand() local
209 while ((nread = read(pipefd[0], buf, sizeof(buf) - 1)) > 0) { in ExecuteCommand()
210 if (nread == sizeof(buf) - 1) { in ExecuteCommand()
214 buf[nread] = '\0'; in ExecuteCommand()
217 if (nread == -1) { in ExecuteCommand()
/developtools/hdc/src/test/
H A Dut_mod.cpp172 auto funcOnRead = [](uv_stream_t *client, ssize_t nread, const uv_buf_t *buf) -> void { in UtForwardWaiter()
173 if (nread > 0 && !strcmp(buf->base, MESSAGE_SUCCESS.c_str())) { in UtForwardWaiter()
/developtools/hdc/src/host/
H A Dclient.h39 static void ReadStd(uv_stream_t *stream, ssize_t nread, const uv_buf_t *buf);
H A Dclient.cpp472 void HdcClient::ReadStd(uv_stream_t *stream, ssize_t nread, const uv_buf_t *buf) in ReadStd() argument
477 if (nread <= 0) { in ReadStd()
478 WRITE_LOG(LOG_FATAL, "ReadStd error nread:%zd", nread); in ReadStd()

Completed in 16 milliseconds