Home
last modified time | relevance | path

Searched refs:SEND_RETRY_LIMIT (Results 1 - 8 of 8) sorted by relevance

/base/msdp/device_status/utils/ipc/src/
H A Dstream_client.cpp64 while (remSize > 0 && retryCount < SEND_RETRY_LIMIT) { in SendMsg()
81 if (retryCount >= SEND_RETRY_LIMIT || remSize != 0) { in SendMsg()
83 retryCount, SEND_RETRY_LIMIT, idx, bufSize, fd_); in SendMsg()
H A Dstream_session.cpp59 while (remSize > 0 && retryCount < SEND_RETRY_LIMIT) { in SendMsg()
77 if (retryCount >= SEND_RETRY_LIMIT || remSize != 0) { in SendMsg()
79 retryCount, SEND_RETRY_LIMIT, idx, bufSize, fd_); in SendMsg()
/base/sensors/sensor/rust/utils/socket_ipc_rust_ffi/src/
H A Dstream_session.rs27 const SEND_RETRY_LIMIT: i32 = 32; consts
129 while rem_size > 0 && retry_count < SEND_RETRY_LIMIT { in session_send_msg()
155 if retry_count >= SEND_RETRY_LIMIT || rem_size != 0 { in session_send_msg()
157 retry_count, SEND_RETRY_LIMIT, idx, buf_size, self.fd); in session_send_msg()
H A Depoll_manager.rs24 const SEND_RETRY_LIMIT: i32 = 32; consts
/base/msdp/device_status/intention/ipc/socket/src/
H A Dsocket_session.cpp75 while (remSize > 0 && retryCount < SEND_RETRY_LIMIT) { in SendMsg()
94 if (retryCount >= SEND_RETRY_LIMIT || remSize != 0) { in SendMsg()
96 "pid:%{public}d", retryCount, SEND_RETRY_LIMIT, idx, bufSize, fd_, pid_); in SendMsg()
/base/sensors/sensor/utils/ipc/include/
H A Dproto.h23 static constexpr size_t SEND_RETRY_LIMIT = 32; member
/base/sensors/sensor/utils/ipc/src/
H A Dstream_session.cpp68 while (remSize > 0 && retryCount < SEND_RETRY_LIMIT) { in SendMsg()
94 if (retryCount >= SEND_RETRY_LIMIT || remSize != 0) { in SendMsg()
96 retryCount, SEND_RETRY_LIMIT, idx, size, fd_); in SendMsg()
/base/msdp/device_status/utils/common/include/
H A Dproto.h41 inline constexpr int32_t SEND_RETRY_LIMIT { 32 };

Completed in 3 milliseconds