| /base/hiviewdfx/hiview_lite/ |
| D | hiview_cache.c | 109 int32 ReadFromCache(HiviewCache *cache, uint8 *data, uint16 rLen) in ReadFromCache() argument
119 if (cache->usedSize < rLen) { in ReadFromCache()
124 if ((uint32)rCursor + (uint32)rLen > (uint32)cache->size) { in ReadFromCache()
131 secondLen = rLen - firstLen; in ReadFromCache()
138 if (memcpy_s(data, rLen, cache->buffer + rCursor, rLen) != EOK) { in ReadFromCache()
143 cache->usedSize -= rLen; in ReadFromCache()
146 return rLen; in ReadFromCache()
149 int32 PrereadFromCache(HiviewCache *cache, uint8 *data, uint16 rLen) in PrereadFromCache() argument
154 if (cache->usedSize < rLen) { in PrereadFromCache()
162 if ((uint32)rCursor + (uint32)rLen > (uint32)cache->size) { in PrereadFromCache()
[all …]
|
| D | hiview_cache.h | 83 int32 ReadFromCache(HiviewCache *cache, uint8 *data, uint16 rLen);
94 int32 PrereadFromCache(HiviewCache *cache, uint8 *data, uint16 rLen);
|
| D | hiview_file.c | 187 int32 rLen = (readLen <= (wCursor - rCursor)) ? readLen : (wCursor - rCursor); in ReadFromFile() local
191 if ((int32)rLen == HIVIEW_FileRead(fp->fhandle, data, rLen)) { in ReadFromFile()
192 h->rCursor += rLen; in ReadFromFile()
194 rLen = 0; in ReadFromFile()
196 return rLen; in ReadFromFile()
|
| /base/startup/appspawn/interfaces/innerkits/client/ |
| D | appspawn_socket.cpp | 110 ssize_t rLen = TEMP_FAILURE_RETRY(read(socketFd, buf, len)); in ReadSocketMessage() local
111 while ((rLen < 0) && (errno == EAGAIN)) { in ReadSocketMessage()
112 rLen = TEMP_FAILURE_RETRY(read(socketFd, buf, len)); in ReadSocketMessage()
114 APPSPAWN_CHECK(rLen >= 0, return -EFAULT, in ReadSocketMessage()
115 "Read message from fd %{public}d error %{public}zd: %{public}d", socketFd, rLen, errno); in ReadSocketMessage()
117 return rLen; in ReadSocketMessage()
|
| /base/startup/init/services/modules/init_context/ |
| D | init_context.c | 138 ssize_t rLen = TEMP_FAILURE_RETRY(read(subInfo->recvFd, buffer, sizeof(buffer))); in SubInitExecuteCmd() local
139 while ((rLen < 0) && (errno == EAGAIN)) { in SubInitExecuteCmd()
140 rLen = TEMP_FAILURE_RETRY(read(subInfo->recvFd, buffer, sizeof(buffer))); in SubInitExecuteCmd()
142 PLUGIN_CHECK(rLen >= 0 && rLen < sizeof(buffer), return errno, in SubInitExecuteCmd()
145 buffer[rLen] = '\0'; in SubInitExecuteCmd()
190 ssize_t rLen = TEMP_FAILURE_RETRY(read(subInfo->recvFd, buffer, size)); in HandleRecvMessage_() local
191 while ((rLen < 0) && (errno == EAGAIN)) { in HandleRecvMessage_()
192 rLen = TEMP_FAILURE_RETRY(read(subInfo->recvFd, buffer, size)); in HandleRecvMessage_()
194 … PLUGIN_CHECK(rLen >= 0, return errno, "Read message for %d fail errno %d", subInfo->type, errno); in HandleRecvMessage_()
195 buffer[rLen] = '\0'; in HandleRecvMessage_()
|
| /base/startup/appspawn/interfaces/innerkits_new/client/ |
| D | appspawn_client.c | 131 ssize_t rLen = TEMP_FAILURE_RETRY(read(socketFd, buf, len)); in ReadMessage() local
132 APPSPAWN_CHECK(rLen >= 0, return APPSPAWN_TIMEOUT, in ReadMessage()
133 … "Read message from fd %{public}d rLen %{public}zd errno: %{public}d", socketFd, rLen, errno); in ReadMessage()
134 if ((size_t)rLen >= sizeof(AppSpawnResponseMsg)) { in ReadMessage()
|
| /base/startup/appspawn/test/unittest/app_spawn_standard_test/ |
| D | nweb_spawn_service_test.cpp | 237 ssize_t rLen = TEMP_FAILURE_RETRY(read(socketId, buffer, buffSize)); in RecvMsg() local
238 return static_cast<int>(rLen); in RecvMsg()
|
| D | app_spawn_service_test.cpp | 282 ssize_t rLen = TEMP_FAILURE_RETRY(read(socketId, buffer, buffSize)); in RecvMsg() local
283 return static_cast<int>(rLen); in RecvMsg()
|