| /ohos5.0/foundation/ability/ability_base/interfaces/kits/native/extractortool/src/ |
| H A D | zip_file_reader_io.cpp | 53 ssize_t nread = 0; in ReadBuffer() local
55 nread = pread(fd_, dst, remainSize, startPos); in ReadBuffer()
56 if (nread <= 0) { in ReadBuffer()
60 startPos += (size_t)nread; in ReadBuffer()
61 dst += nread; in ReadBuffer()
62 remainSize -= (size_t)nread; in ReadBuffer()
|
| /ohos5.0/foundation/arkui/napi/sample/native_module_netserver/ |
| H A D | net_server.cpp | 153 void NetServer::TakeDiffactionsByStatus(uv_stream_t* handle, ssize_t nread, const uv_buf_t* buf, Ne… in TakeDiffactionsByStatus() argument
157 if (nread < 0) { in TakeDiffactionsByStatus()
170 for (int i = 0; i < nread; i++) { in TakeDiffactionsByStatus()
174 if (i + 1 < nread && buf->base[i + 1] == 'S') { in TakeDiffactionsByStatus()
194 wr->buf = uv_buf_init(buf->base, nread); in TakeDiffactionsByStatus()
201 void NetServer::AfterRead(uv_stream_t* handle, ssize_t nread, const uv_buf_t* buf) in AfterRead() argument
214 if (nread == 0) { in AfterRead()
219 TakeDiffactionsByStatus(handle, nread, buf, that); in AfterRead()
|
| H A D | netserver.cpp | 152 void NetServer::TakeDiffactionsByStatus(uv_stream_t* handle, ssize_t nread, const uv_buf_t* buf, Ne… in TakeDiffactionsByStatus() argument
156 if (nread < 0) { in TakeDiffactionsByStatus()
169 for (int i = 0; i < nread; i++) { in TakeDiffactionsByStatus()
173 if (i + 1 < nread && buf->base[i + 1] == 'S') { in TakeDiffactionsByStatus()
193 wr->buf = uv_buf_init(buf->base, nread); in TakeDiffactionsByStatus()
200 void NetServer::AfterRead(uv_stream_t* handle, ssize_t nread, const uv_buf_t* buf) in AfterRead() argument
213 if (nread == 0) { in AfterRead()
218 TakeDiffactionsByStatus(handle, nread, buf, that); in AfterRead()
|
| H A D | net_server.h | 63 static void AfterRead(uv_stream_t*, ssize_t nread, const uv_buf_t* buf);
64 static void TakeDiffactionsByStatus(uv_stream_t* handle, ssize_t nread,
|
| H A D | netserver.h | 104 static void AfterRead(uv_stream_t*, ssize_t nread, const uv_buf_t* buf);
105 static void TakeDiffactionsByStatus(uv_stream_t* handle, ssize_t nread,
|
| /ohos5.0/base/startup/init/services/param/linux/ |
| H A D | param_msgadp.c | 29 static void OnReceiveRequest(const TaskHandle task, const uint8_t *buffer, uint32_t nread) in OnReceiveRequest() argument
31 if (nread == 0 || buffer == NULL || g_recvMessage == NULL) { in OnReceiveRequest()
35 while (curr < nread) { in OnReceiveRequest()
37 if ((nread - curr < msg->msgSize) || in OnReceiveRequest()
38 (nread - curr < sizeof(ParamMessage)) || in OnReceiveRequest()
|
| /ohos5.0/base/hiviewdfx/faultloggerd/interfaces/innerkits/signal_handler/ |
| H A D | dfx_signalhandler_exception.c | 92 ssize_t nread = OHOS_TEMP_FAILURE_RETRY(read(fd, controlBuffer, sizeof(controlBuffer) - 1)); in CheckReadResp() local
93 if (nread != (ssize_t)(strlen(FAULTLOGGER_DAEMON_RESP))) { in CheckReadResp()
94 DFXLOG_ERROR("Failed to read expected length, nread: %zd, errno(%d).", nread, errno); in CheckReadResp()
|
| /ohos5.0/base/hiviewdfx/faultloggerd/services/ |
| H A D | fault_logger_daemon.cpp | 204 static bool CheckReadRequest(ssize_t nread, ssize_t size) in CheckReadRequest() argument
206 if (nread < 0) { in CheckReadRequest()
209 } else if (nread == 0) { in CheckReadRequest()
212 } else if (nread != static_cast<long>(size)) { in CheckReadRequest()
257 ssize_t nread = OHOS_TEMP_FAILURE_RETRY(read(connectionFd, buf.data(), REQUEST_BUF_SIZE)); in HandleRequest() local
258 if (CheckReadRequest(nread, sizeof(FaultLoggerdStatsRequest))) { in HandleRequest()
262 if (!CheckReadRequest(nread, sizeof(FaultLoggerdRequest))) { in HandleRequest()
334 if (!CheckReadRequest(nread, sizeof(CrashDumpException))) { in HandleExceptionRequest()
495 int nread = OHOS_TEMP_FAILURE_RETRY(read(connectionFd, buf, sizeof(buf) - 1)); in HandlePrintTHilogClientRequest() local
496 if (nread < 0) { in HandlePrintTHilogClientRequest()
[all …]
|
| /ohos5.0/base/startup/appspawn/standard/ |
| H A D | appspawn_main.c | 72 ssize_t nread = readlink("/proc/self/exe", buf, sizeof(buf) - 1); in CheckPreload() local
73 APPSPAWN_CHECK(nread != -1, return, "readlink fail: /proc/self/exe: %{public}d", errno); in CheckPreload()
74 buf[nread] = 0; in CheckPreload()
|
| /ohos5.0/base/startup/init/test/unittest/loopevent/ |
| H A D | loopserver_unittest.cpp | 51 static void DecodeMessage(const char *buffer, size_t nread, uint32_t &cmd) in DecodeMessage() argument
53 cJSON *root = cJSON_ParseWithLength(buffer, nread); in DecodeMessage()
94 static void TestOnReceiveRequest(const TaskHandle task, const uint8_t *buffer, uint32_t nread) in TestOnReceiveRequest() argument
102 DecodeMessage(reinterpret_cast<const char *>(buffer), nread, cmd); in TestOnReceiveRequest()
106 static void TestClientOnReceiveRequest(const TaskHandle task, const uint8_t *buffer, uint32_t nread) in TestClientOnReceiveRequest() argument
114 DecodeMessage(reinterpret_cast<const char *>(buffer), nread, cmd); in TestClientOnReceiveRequest()
|
| H A D | loopevent_unittest.cpp | 53 static void OnReceiveRequest(const TaskHandle task, const uint8_t *buffer, uint32_t nread) in OnReceiveRequest() argument
57 UNUSED(nread); in OnReceiveRequest()
|
| /ohos5.0/base/hiviewdfx/hiview/framework/native/unified_collection/collector/ |
| H A D | hilog_collector_impl.cpp | 52 ssize_t nread = read(readFd, buffer, sizeof(buffer) - 1); in ReadHilog() local
53 if (nread <= 0) { in ReadHilog()
|
| /ohos5.0/base/hiviewdfx/faultloggerd/interfaces/innerkits/dump_catcher/ |
| H A D | dfx_dump_catcher.cpp | 562 ssize_t nread = OHOS_TEMP_FAILURE_RETRY(read(fd, buffer, MAX_PIPE_SIZE)); in DoReadBuf() local
563 if (nread <= 0) { in DoReadBuf()
567 DFXLOG_DEBUG("%s :: %s :: nread: %zu", DFXDUMPCATCHER_TAG.c_str(), __func__, nread); in DoReadBuf()
578 ssize_t nread = OHOS_TEMP_FAILURE_RETRY(read(fd, &res, sizeof(res))); in DoReadRes() local
579 if (nread <= 0 || nread != sizeof(res)) { in DoReadRes()
|
| /ohos5.0/foundation/communication/netmanager_base/services/netmanagernative/src/manager/ |
| H A D | traffic_manager.cpp | 87 int nread = read(fd, buf, sizeof(long)); in GetInterfaceTrafficByType() local
88 if (nread == -1) { in GetInterfaceTrafficByType()
|
| H A D | interface_manager.cpp | 102 int nread = read(fd, originMtuValue, (sizeof(char) * (MAX_MTU_LEN - 1))); in GetMtu() local
103 if (nread == -1 || nread == 0) { in GetMtu()
|
| /ohos5.0/base/hiviewdfx/faultloggerd/interfaces/innerkits/faultloggerd_client/ |
| H A D | faultloggerd_client.cpp | 93 ssize_t nread = OHOS_TEMP_FAILURE_RETRY(read(sockfd, ControlBuffer, sizeof(ControlBuffer) - 1)); in CheckReadResp() local
94 if (nread != static_cast<ssize_t>(strlen(FAULTLOGGER_DAEMON_RESP))) { in CheckReadResp()
95 DFXLOG_ERROR("nread: %zd.", nread); in CheckReadResp()
|
| /ohos5.0/base/hiviewdfx/hiview/plugins/faultlogger/interfaces/js/napi/ |
| H A D | napi_faultlogger.cpp | 60 int nread = TEMP_FAILURE_RETRY(read((fd), buf, BUF_SIZE_512 - 1)); in ConversionInform() local
61 if (nread == -1) { in ConversionInform()
67 } else if (nread == 0) { in ConversionInform()
|
| /ohos5.0/base/hiviewdfx/hiview/plugins/faultlogger/service/ |
| H A D | faultlogger.cpp | 865 ssize_t nread = -1; in GetStackInfo() local
867 nread = TEMP_FAILURE_RETRY(read(*info.pipeFd, buffer, MAX_PIPE_SIZE)); in GetStackInfo()
868 if (nread <= 0) { in GetStackInfo()
873 std::string stackInfoOriginal(buffer, nread); in GetStackInfo()
942 ssize_t nread = TEMP_FAILURE_RETRY(read(fds[0], buffer, sizeof(buffer) - 1)); in GetHilog() local
943 if (nread <= 0) { in GetHilog()
|
| /ohos5.0/base/hiviewdfx/faultloggerd/test/fuzztest/faultloggerdserver_fuzzer/ |
| H A D | faultloggerdserver_fuzzer.cpp | 198 ssize_t nread = OHOS_TEMP_FAILURE_RETRY(read(sockfd, controlBuffer, sizeof(controlBuffer) - 1)); in CheckReadResp() local
199 if (nread != static_cast<ssize_t>(strlen(FAULTLOGGER_DAEMON_RESP))) { in CheckReadResp()
|
| /ohos5.0/foundation/communication/dsoftbus/tests/adapter/unittest/ |
| H A D | softbus_socket_test.cpp | 1395 int32_t nread = 0; variable
1398 int32_t ret = SoftBusSocketIoctl(socketFd, cmd, &nread);
1410 int32_t nread; variable
1416 ret = SoftBusSocketIoctl(socketFd, cmd, &nread);
|