Searched refs:numRead (Results 1 - 4 of 4) sorted by relevance
| /base/msdp/device_status/intention/ipc/socket/src/ |
| H A D | socket_connection.cpp | 60 ssize_t numRead; in OnReadable() local
63 numRead = ::recv(fd, buf, sizeof(buf), MSG_DONTWAIT); in OnReadable()
64 if (numRead > 0) { in OnReadable()
65 buffer_.Write(buf, numRead); in OnReadable()
67 } else if (numRead < 0) { in OnReadable()
83 } while (numRead == sizeof(buf)); in OnReadable()
|
| H A D | socket_session_manager.cpp | 179 ssize_t numRead {};
in OnEpollIn()
182 numRead = ::recv(source.GetFd(), buf, sizeof(buf), MSG_DONTWAIT);
in OnEpollIn()
183 if (numRead > 0) {
in OnEpollIn()
184 FI_HILOGI("%{public}zd bytes received", numRead);
in OnEpollIn()
185 } else if (numRead < 0) {
in OnEpollIn()
201 } while (numRead == sizeof(buf));
in OnEpollIn()
|
| /base/msdp/device_status/intention/services/device_manager/src/ |
| H A D | monitor.cpp | 116 ssize_t numRead { 0 }; in ReceiveDevice()
120 numRead = ::read(inotifyFd_, buf, bufSize); in ReceiveDevice()
121 } while ((numRead < 0) && (errno == EINVAL) && in ReceiveDevice()
124 if (numRead < 0) { in ReceiveDevice()
128 if (numRead == 0) { in ReceiveDevice()
132 FI_HILOGD("Read %{public}zd bytes from inotify events", numRead); in ReceiveDevice()
133 for (char *p = buf; p < buf + numRead;) { in ReceiveDevice()
|
| /base/startup/init/interfaces/innerkits/fs_manager/libfs_hvb/ |
| H A D | hvb_ops.c | 119 ssize_t numRead = read(fd, buf, numBytes); in HvbReadFromPartition() local
120 if (numRead < 0 || (size_t)numRead != numBytes) { in HvbReadFromPartition()
127 *outNumRead = numRead; in HvbReadFromPartition()
|
Completed in 2 milliseconds