Home
last modified time | relevance | path

Searched refs:timeout_ms (Results 1 – 25 of 38) sorted by relevance

12

/system/core/fs_mgr/
Dfs_mgr_dm_linear.cpp112 bool force_writable, const std::chrono::milliseconds& timeout_ms, in CreateLogicalPartition() argument
130 if (timeout_ms > std::chrono::milliseconds::zero()) { in CreateLogicalPartition()
131 if (!fs_mgr_wait_for_file(*path, timeout_ms, FileWaitMode::Exists)) { in CreateLogicalPartition()
173 const std::chrono::milliseconds& timeout_ms, std::string* path) { in CreateLogicalPartition() argument
176 return CreateLogicalPartition(metadata, partition, force_writable, timeout_ms, in CreateLogicalPartition()
186 const std::chrono::milliseconds& timeout_ms, std::string* path) { in CreateLogicalPartition() argument
193 timeout_ms, path); in CreateLogicalPartition()
196 bool UnmapDevice(const std::string& name, const std::chrono::milliseconds& timeout_ms) { in UnmapDevice() argument
199 if (timeout_ms > std::chrono::milliseconds::zero()) { in UnmapDevice()
205 if (!path.empty() && !fs_mgr_wait_for_file(path, timeout_ms, FileWaitMode::DoesNotExist)) { in UnmapDevice()
[all …]
/system/extras/libperfmgr/
DNodeLooperThread.cc48 if (a.timeout_ms != std::chrono::milliseconds::zero()) { in Request()
53 ReqTime::max() - now) > a.timeout_ms) { in Request()
54 end_time = now + a.timeout_ms; in Request()
100 std::chrono::milliseconds timeout_ms = kMaxUpdatePeriod; in threadLoop() local
109 timeout_ms = std::min(n->Update(true), timeout_ms); in threadLoop()
113 if (timeout_ms.count() < sleep_timeout_ns / 1000 / 1000) { in threadLoop()
114 sleep_timeout_ns = timeout_ms.count() * 1000 * 1000; in threadLoop()
/system/core/fastboot/
Dsocket.cpp51 ssize_t Socket::ReceiveAll(void* data, size_t length, int timeout_ms) { in ReceiveAll() argument
55 ssize_t bytes = Receive(reinterpret_cast<char*>(data) + total, length - total, timeout_ms); in ReceiveAll()
77 bool Socket::WaitForRecv(int timeout_ms) { in WaitForRecv() argument
82 if (timeout_ms <= 0) { in WaitForRecv()
96 timeout.tv_sec = timeout_ms / 1000; in WaitForRecv()
97 timeout.tv_usec = (timeout_ms % 1000) * 1000; in WaitForRecv()
116 ssize_t Receive(void* data, size_t length, int timeout_ms) override;
151 ssize_t UdpSocket::Receive(void* data, size_t length, int timeout_ms) { in Receive() argument
152 if (!WaitForRecv(timeout_ms)) { in Receive()
174 ssize_t Receive(void* data, size_t length, int timeout_ms) override;
[all …]
Dsocket.h85 virtual ssize_t Receive(void* data, size_t length, int timeout_ms) = 0;
88 virtual ssize_t ReceiveAll(void* data, size_t length, int timeout_ms);
111 bool WaitForRecv(int timeout_ms);
Dusb.h65 UsbTransport* usb_open(ifc_match_func callback, uint32_t timeout_ms = 0);
Dsocket_mock.h60 ssize_t Receive(void* data, size_t length, int timeout_ms) override;
/system/extras/libperfmgr/include/perfmgr/
DNodeLooperThread.h37 std::chrono::milliseconds timeout_ms) in NodeAction()
40 timeout_ms(timeout_ms) {} in NodeAction()
43 std::chrono::milliseconds timeout_ms; // 0ms for forever member
/system/core/libcutils/
Dsockets_windows.cpp57 int socket_set_receive_timeout(cutils_socket_t sock, int timeout_ms) { in socket_set_receive_timeout() argument
59 reinterpret_cast<char*>(&timeout_ms), sizeof(timeout_ms)); in socket_set_receive_timeout()
Dsockets_unix.cpp34 int socket_set_receive_timeout(cutils_socket_t sock, int timeout_ms) { in socket_set_receive_timeout() argument
36 tv.tv_sec = timeout_ms / 1000; in socket_set_receive_timeout()
37 tv.tv_usec = (timeout_ms % 1000) * 1000; in socket_set_receive_timeout()
/system/core/fs_mgr/include/
Dfs_mgr_dm_linear.h61 const std::chrono::milliseconds& timeout_ms, std::string* path);
67 const std::chrono::milliseconds& timeout_ms, std::string* path);
71 bool DestroyLogicalPartition(const std::string& name, const std::chrono::milliseconds& timeout_ms);
/system/core/init/
Dproperty_service.cpp292 bool RecvUint32(uint32_t* value, uint32_t* timeout_ms) { in RecvUint32() argument
293 return RecvFully(value, sizeof(*value), timeout_ms); in RecvUint32()
296 bool RecvChars(char* chars, size_t size, uint32_t* timeout_ms) { in RecvChars() argument
297 return RecvFully(chars, size, timeout_ms); in RecvChars()
300 bool RecvString(std::string* value, uint32_t* timeout_ms) { in RecvString() argument
302 if (!RecvUint32(&len, timeout_ms)) { in RecvString()
319 if (!RecvChars(&chars[0], len, timeout_ms)) { in RecvString()
345 bool PollIn(uint32_t* timeout_ms) { in PollIn() argument
350 while (*timeout_ms > 0) { in PollIn()
352 int nr = poll(ufds, 1, *timeout_ms); in PollIn()
[all …]
Depoll.cpp73 int timeout_ms = -1; in Wait() local
75 timeout_ms = timeout->count(); in Wait()
78 auto nr = TEMP_FAILURE_RETRY(epoll_wait(epoll_fd_, &ev, 1, timeout_ms)); in Wait()
Duevent_listener.cpp195 int timeout_ms = -1; in Poll() local
202 timeout_ms = remaining_timeout.count(); in Poll()
205 int nr = poll(&ufd, 1, timeout_ms); in Poll()
/system/core/debuggerd/client/
Ddebuggerd_client.cpp68 bool debuggerd_trigger_dump(pid_t tid, DebuggerdDumpType dump_type, unsigned int timeout_ms, in debuggerd_trigger_dump() argument
84 const auto end = std::chrono::steady_clock::now() + std::chrono::milliseconds(timeout_ms); in debuggerd_trigger_dump()
86 auto set_timeout = [timeout_ms, &time_left](int sockfd) { in debuggerd_trigger_dump()
87 if (timeout_ms <= 0) { in debuggerd_trigger_dump()
209 if (timeout_ms <= 0) { in debuggerd_trigger_dump()
264 int timeout_ms = timeout_secs > 0 ? timeout_secs * 1000 : 0; in dump_backtrace_to_file_timeout() local
265 return debuggerd_trigger_dump(tid, dump_type, timeout_ms, std::move(copy)) ? 0 : -1; in dump_backtrace_to_file_timeout()
/system/core/libsuspend/
Dautosuspend.c91 int autosuspend_force_suspend(int timeout_ms) { in autosuspend_force_suspend() argument
101 return autosuspend_ops->force_suspend(timeout_ms); in autosuspend_force_suspend()
Dautosuspend_ops.h23 int (*force_suspend)(int timeout_ms);
Dautosuspend_wakeup_count.cpp208 static int force_suspend(int timeout_ms) { in force_suspend() argument
209 LOG(VERBOSE) << "force_suspend called with timeout: " << timeout_ms; in force_suspend()
/system/core/llkd/
DREADME.md30 ro.llk.timeout_ms, or ro.llk.[D|Z].timeout_ms, kill the process or parent
41 longer than ro.llk.timeout_ms, or ro.llk.stack.timeout_ms, then issue a kill
51 period of ro.llk.stack.timeout_ms, samples occur every ro.llk.check_ms. This
125 #### ro.llk.timeout_ms
129 #### ro.llk.D.timeout_ms
130 default ro.llk.timeout_ms, D maximum timelimit.
132 #### ro.llk.Z.timeout_ms
133 default ro.llk.timeout_ms, Z maximum timelimit.
135 #### ro.llk.stack.timeout_ms
136 default ro.llk.timeout_ms,
[all …]
/system/core/libsuspend/include/suspend/
Dautosuspend.h56 int autosuspend_force_suspend(int timeout_ms);
/system/bt/audio_hal_interface/
Dclient_interface.cc443 int timeout_ms = kDefaultDataReadTimeoutMs; in ReadAudioData() local
458 } else if (timeout_ms >= kDefaultDataReadPollIntervalMs) { in ReadAudioData()
461 timeout_ms -= kDefaultDataReadPollIntervalMs; in ReadAudioData()
465 << " no data " << (kDefaultDataReadTimeoutMs - timeout_ms) in ReadAudioData()
471 if (timeout_ms < in ReadAudioData()
473 timeout_ms >= kDefaultDataReadPollIntervalMs) { in ReadAudioData()
475 << " read " << (kDefaultDataReadTimeoutMs - timeout_ms) << " ms"; in ReadAudioData()
/system/core/debuggerd/include/debuggerd/
Dclient.h29 bool debuggerd_trigger_dump(pid_t pid, enum DebuggerdDumpType dump_type, unsigned int timeout_ms,
/system/bt/bta/dm/
Dbta_dm_pm.cc276 uint64_t timeout_ms, uint8_t srvc_id, in bta_dm_pm_start_timer() argument
290 alarm_set_on_mloop(p_timer->timer[timer_idx], timeout_ms, in bta_dm_pm_start_timer()
511 uint64_t timeout_ms = 0; in bta_dm_pm_set_mode() local
566 timeout_ms = p_act0->timeout; in bta_dm_pm_set_mode()
576 timeout_ms = p_act1->timeout; in bta_dm_pm_set_mode()
592 timeout_ms = 0; in bta_dm_pm_set_mode()
597 if ((pm_req != BTA_DM_PM_EXECUTE) && (timeout_ms > 0)) { in bta_dm_pm_set_mode()
605 if (remaining_ms < timeout_ms) { in bta_dm_pm_set_mode()
615 bta_dm_pm_start_timer(&bta_dm_cb.pm_timer[i], timer_idx, timeout_ms, in bta_dm_pm_set_mode()
622 APPL_TRACE_DEBUG("%s dm_pm_timer:%d, %d ms", __func__, i, timeout_ms); in bta_dm_pm_set_mode()
[all …]
/system/core/libcutils/include/cutils/
Dsockets.h111 int socket_set_receive_timeout(cutils_socket_t sock, int timeout_ms);
/system/core/libcutils/include_vndk/cutils/
Dsockets.h111 int socket_set_receive_timeout(cutils_socket_t sock, int timeout_ms);
/system/hardware/interfaces/suspend/1.0/default/
DSystemSuspendUnitTest.cpp68 static bool isReadBlocked(int fd, int timeout_ms = 20) { in isReadBlocked() argument
72 return poll(&pfd, 1, timeout_ms) == 0; in isReadBlocked()
170 bool isSystemSuspendBlocked(int timeout_ms = 20) { return isReadBlocked(stateFd, timeout_ms); } in isSystemSuspendBlocked() argument

12