/aosp12/system/core/fs_mgr/libdm/ |
H A D | loop_control.cpp | 42 bool LoopControl::Attach(int file_fd, const std::chrono::milliseconds& timeout_ms, in Attach() argument 53 if (!WaitForFile(*loopdev, timeout_ms - time_elapsed)) { in Attach() 74 if (!WaitForCondition(condition, timeout_ms)) { in Attach() 136 LoopDevice::LoopDevice(android::base::borrowed_fd fd, const std::chrono::milliseconds& timeout_ms, in LoopDevice() argument 142 Init(timeout_ms); in LoopDevice() 145 LoopDevice::LoopDevice(const std::string& path, const std::chrono::milliseconds& timeout_ms) in LoopDevice() argument 153 Init(timeout_ms); in LoopDevice() 162 void LoopDevice::Init(const std::chrono::milliseconds& timeout_ms) { in Init() argument 163 valid_ = control_.Attach(fd_.get(), timeout_ms, &device_); in Init()
|
H A D | utility.cpp | 30 const std::chrono::milliseconds& timeout_ms) { in WaitForCondition() argument 41 if (time_elapsed > timeout_ms) return false; in WaitForCondition() 45 bool WaitForFile(const std::string& path, const std::chrono::milliseconds& timeout_ms) { in WaitForFile() argument 58 return WaitForCondition(condition, timeout_ms); in WaitForFile() 61 bool WaitForFileDeleted(const std::string& path, const std::chrono::milliseconds& timeout_ms) { in WaitForFileDeleted() argument 72 return WaitForCondition(condition, timeout_ms); in WaitForFileDeleted()
|
H A D | utility.h | 25 bool WaitForFile(const std::string& path, const std::chrono::milliseconds& timeout_ms); 26 bool WaitForFileDeleted(const std::string& path, const std::chrono::milliseconds& timeout_ms); 28 const std::chrono::milliseconds& timeout_ms);
|
H A D | dm.cpp | 91 const std::chrono::milliseconds& timeout_ms) { in DeleteDeviceIfExists() argument 95 return DeleteDevice(name, timeout_ms); in DeleteDeviceIfExists() 103 const std::chrono::milliseconds& timeout_ms) { in DeleteDevice() argument 123 if (timeout_ms <= std::chrono::milliseconds::zero()) { in DeleteDevice() 129 if (!WaitForFileDeleted(unique_path, timeout_ms)) { in DeleteDevice() 179 const std::chrono::milliseconds& timeout_ms, std::string* path) { in WaitForDevice() argument 189 if (timeout_ms <= std::chrono::milliseconds::zero()) { in WaitForDevice() 202 if (!WaitForFile(unique_path, timeout_ms)) { in WaitForDevice() 211 const std::chrono::milliseconds& timeout_ms) { in CreateDevice() argument 221 if (!WaitForDevice(name, timeout_ms, path)) { in CreateDevice()
|
/aosp12/system/core/fastboot/ |
H A D | socket.cpp | 51 ssize_t Socket::ReceiveAll(void* data, size_t length, int timeout_ms) { in ReceiveAll() argument 79 bool Socket::WaitForRecv(int timeout_ms) { in WaitForRecv() argument 84 if (timeout_ms <= 0) { in WaitForRecv() 98 timeout.tv_sec = timeout_ms / 1000; in WaitForRecv() 99 timeout.tv_usec = (timeout_ms % 1000) * 1000; in WaitForRecv() 118 ssize_t Receive(void* data, size_t length, int timeout_ms) override; 153 ssize_t UdpSocket::Receive(void* data, size_t length, int timeout_ms) { in Receive() argument 154 if (!WaitForRecv(timeout_ms)) { in Receive() 176 ssize_t Receive(void* data, size_t length, int timeout_ms) override; 232 ssize_t TcpSocket::Receive(void* data, size_t length, int timeout_ms) { in Receive() argument [all …]
|
H A D | socket.h | 85 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);
|
/aosp12/hardware/google/pixel/power-libperfmgr/libperfmgr/ |
H A D | NodeLooperThread.cc | 50 if (a.timeout_ms != std::chrono::milliseconds::zero()) { in Request() 55 ReqTime::max() - now) > a.timeout_ms) { in Request() 56 end_time = now + a.timeout_ms; in Request() 102 std::chrono::milliseconds timeout_ms = kMaxUpdatePeriod; in threadLoop() local 112 timeout_ms = std::min(n->Update(true), timeout_ms); in threadLoop() 117 if (timeout_ms.count() < sleep_timeout_ns / 1000 / 1000) { in threadLoop() 118 sleep_timeout_ns = timeout_ms.count() * 1000 * 1000; in threadLoop()
|
/aosp12/hardware/libhardware/modules/vibrator/ |
H A D | vibrator.c | 80 static int sendit(unsigned int timeout_ms) in sendit() argument 84 snprintf(value, sizeof(value), "%u", timeout_ms); in sendit() 88 static int vibra_on(vibrator_device_t* vibradev __unused, unsigned int timeout_ms) in vibra_on() argument 91 return sendit(timeout_ms); in vibra_on() 117 static int vibra_led_on(vibrator_device_t* vibradev __unused, unsigned int timeout_ms) in vibra_led_on() argument 126 snprintf(value, sizeof(value), "%u\n", timeout_ms); in vibra_led_on()
|
/aosp12/system/core/fs_mgr/libfiemap/ |
H A D | image_manager.cpp | 314 .timeout_ms = timeout_ms, in MapWithDmLinear() 341 if (!control.Attach(file_fd, timeout_ms, path)) { in CreateLoopDevice() 373 const std::chrono::milliseconds& timeout_ms, in MapWithLoopDeviceList() argument 422 if (!dm.CreateDevice(name, table, path, timeout_ms)) { in MapWithLoopDeviceList() 459 const std::chrono::milliseconds& timeout_ms, in MapWithLoopDevice() argument 480 if (!CreateLoopDevice(control, file, timeout_ms - elapsed, &loop_device)) { in MapWithLoopDevice() 500 if (!MapWithLoopDeviceList(loop_devices, name, timeout_ms, path)) { in MapWithLoopDevice() 547 if (!MapWithDmLinear(*partition_opener_.get(), name, timeout_ms, path)) { in MapImageDevice() 550 } else if (!MapWithLoopDevice(name, timeout_ms, path)) { in MapImageDevice() 556 if (!MapWithDmLinear(*partition_opener_.get(), name, timeout_ms, path)) { in MapImageDevice() [all …]
|
/aosp12/hardware/google/pixel/power-libperfmgr/libperfmgr/include/perfmgr/ |
H A D | NodeLooperThread.h | 37 std::chrono::milliseconds timeout_ms) in NodeAction() 40 timeout_ms(timeout_ms) {} in NodeAction() 43 std::chrono::milliseconds timeout_ms; // 0ms for forever member
|
/aosp12/system/core/fs_mgr/libdm/include/libdm/ |
H A D | loop_control.h | 40 bool Attach(int file_fd, const std::chrono::milliseconds& timeout_ms, 67 LoopDevice(android::base::borrowed_fd fd, const std::chrono::milliseconds& timeout_ms, 71 LoopDevice(const std::string& path, const std::chrono::milliseconds& timeout_ms); 83 void Init(const std::chrono::milliseconds& timeout_ms);
|
/aosp12/frameworks/native/cmds/dumpstate/ |
H A D | DumpstateUtil.cpp | 46 static bool waitpid_with_timeout(pid_t pid, int timeout_ms, int* status) { in waitpid_with_timeout() argument 57 ts.tv_sec = MSEC_TO_SEC(timeout_ms); in waitpid_with_timeout() 58 ts.tv_nsec = (timeout_ms % 1000) * 1000000; in waitpid_with_timeout() 95 …andOptions::CommandOptionsBuilder::CommandOptionsBuilder(int64_t timeout_ms) : values(timeout_ms) { in CommandOptionsBuilder() argument 143 CommandOptions::CommandOptionsValues::CommandOptionsValues(int64_t timeout_ms) in CommandOptionsValues() argument 144 : timeout_ms_(timeout_ms), in CommandOptionsValues() 187 CommandOptions::CommandOptionsBuilder CommandOptions::WithTimeoutInMs(int64_t timeout_ms) { in WithTimeoutInMs() argument 188 return CommandOptions::CommandOptionsBuilder(timeout_ms); in WithTimeoutInMs()
|
H A D | DumpstateUtil.h | 79 explicit CommandOptionsValues(int64_t timeout_ms); 130 explicit CommandOptionsBuilder(int64_t timeout_ms); 154 static CommandOptionsBuilder WithTimeoutInMs(int64_t timeout_ms);
|
/aosp12/system/core/fs_mgr/libfiemap/include/libfiemap/ |
H A D | image_manager.h | 50 const std::chrono::milliseconds& timeout_ms, 81 const std::chrono::milliseconds& timeout_ms, std::string* path) = 0; 153 bool MapImageDevice(const std::string& name, const std::chrono::milliseconds& timeout_ms, 182 bool MapWithLoopDevice(const std::string& name, const std::chrono::milliseconds& timeout_ms, 185 const std::chrono::milliseconds& timeout_ms, std::string* path); 187 const std::chrono::milliseconds& timeout_ms, std::string* path); 207 const std::chrono::milliseconds& timeout_ms,
|
/aosp12/system/core/init/ |
H A D | property_service.cpp | 264 return RecvFully(chars, size, timeout_ms); in RecvChars() 269 if (!RecvUint32(&len, timeout_ms)) { in RecvString() 317 bool PollIn(uint32_t* timeout_ms) { in PollIn() argument 322 while (*timeout_ms > 0) { in PollIn() 324 int nr = poll(ufds, 1, *timeout_ms); in PollIn() 329 *timeout_ms = (millis > *timeout_ms) ? 0 : *timeout_ms - millis; in PollIn() 347 if (*timeout_ms > 0) { in PollIn() 348 --(*timeout_ms); in PollIn() 362 if (!PollIn(timeout_ms)) { in RecvFully() 543 uint32_t timeout_ms = kDefaultSocketTimeout; in handle_property_set_fd() local [all …]
|
H A D | epoll.cpp | 75 int timeout_ms = -1; in Wait() local 77 timeout_ms = timeout->count(); in Wait() 81 auto num_events = TEMP_FAILURE_RETRY(epoll_wait(epoll_fd_, ev, max_events, timeout_ms)); in Wait()
|
/aosp12/packages/apps/TV/jni/ |
H A D | DvbManager.h | 80 const int frequency, const char *modulationStr, int timeout_ms); 83 const char *modulationStr, int timeout_ms); 86 uint8_t *tsBuffer, int tsBufferSize, int timeout_ms); 97 const char *modulationStr, int timeout_ms);
|
H A D | DvbManager.cpp | 118 const int frequency, const char *modulationStr, int timeout_ms) { in tune() argument 120 modulationStr, timeout_ms); in tune() 125 const char *modulationStr, int timeout_ms) { in tune() argument 127 modulationStr, timeout_ms); in tune() 132 const char *modulationStr, int timeout_ms) { in tuneInternal() argument 281 while (currentTimeMillis() - tuneClock < timeout_ms) { in tuneInternal() 478 uint8_t *tsBuffer, int tsBufferSize, int timeout_ms) { in readTsStream() argument 492 int poll_result = poll(&pollFd, NUM_POLLFDS, timeout_ms); in readTsStream()
|
/aosp12/art/runtime/ |
H A D | barrier.cc | 73 bool Barrier::Increment(Thread* self, int delta, uint32_t timeout_ms) { in Increment() argument 79 uint64_t abs_timeout = NanoTime() + MsToNs(timeout_ms); in Increment() 81 timed_out = condition_->TimedWait(self, timeout_ms, timeout_ns); in Increment() 88 timeout_ms = time_left / (1000*1000); in Increment()
|
/aosp12/system/core/debuggerd/client/ |
H A D | debuggerd_client.cpp | 114 bool debuggerd_trigger_dump(pid_t tid, DebuggerdDumpType dump_type, unsigned int timeout_ms, in debuggerd_trigger_dump() argument 130 const auto end = std::chrono::steady_clock::now() + std::chrono::milliseconds(timeout_ms); in debuggerd_trigger_dump() 132 auto set_timeout = [timeout_ms, &time_left](int sockfd) { in debuggerd_trigger_dump() 133 if (timeout_ms <= 0) { in debuggerd_trigger_dump() 258 if (timeout_ms <= 0) { in debuggerd_trigger_dump() 318 int timeout_ms = timeout_secs > 0 ? timeout_secs * 1000 : 0; in dump_backtrace_to_file_timeout() local 319 int ret = debuggerd_trigger_dump(tid, dump_type, timeout_ms, std::move(copy)) ? 0 : -1; in dump_backtrace_to_file_timeout()
|
/aosp12/packages/apps/TV/tuner/src/com/android/tv/tuner/ |
H A D | TunerHal.java | 153 int timeout_ms = in tuneInternal() local 162 tuneStatus = nativeTune(getDeviceId(), frequency, modulation, timeout_ms); in tuneInternal() 167 timeout_ms); in tuneInternal() 191 @ModulationType String modulation, int timeout_ms); in nativeTune() argument 195 @ModulationType String modulation, int timeout_ms); in nativeTune() argument
|
/aosp12/system/bt/audio_hal_interface/ |
H A D | client_interface.cc | 766 int timeout_ms = kDefaultDataReadTimeoutMs; in ReadAudioData() local 781 } else if (timeout_ms >= kDefaultDataReadPollIntervalMs) { in ReadAudioData() 784 timeout_ms -= kDefaultDataReadPollIntervalMs; in ReadAudioData() 788 << " no data " << (kDefaultDataReadTimeoutMs - timeout_ms) in ReadAudioData() 794 if (timeout_ms < in ReadAudioData() 796 timeout_ms >= kDefaultDataReadPollIntervalMs) { in ReadAudioData() 843 int timeout_ms = kDefaultDataWriteTimeoutMs; in WriteAudioData() local 858 } else if (timeout_ms >= kDefaultDataWritePollIntervalMs) { in WriteAudioData() 861 timeout_ms -= kDefaultDataWritePollIntervalMs; in WriteAudioData() 871 if (timeout_ms < in WriteAudioData() [all …]
|
/aosp12/frameworks/base/cmds/incidentd/src/ |
H A D | incidentd_util.cpp | 182 static bool waitpid_with_timeout(pid_t pid, int timeout_ms, int* status) { in waitpid_with_timeout() argument 193 ts.tv_sec = timeout_ms / 1000; in waitpid_with_timeout() 194 ts.tv_nsec = (timeout_ms % 1000) * 1000000; in waitpid_with_timeout() 234 status_t wait_child(pid_t pid, int timeout_ms) { in wait_child() argument 236 if (waitpid_with_timeout(pid, timeout_ms, &status)) { in wait_child()
|
/aosp12/system/core/fs_mgr/libsnapshot/include/libsnapshot/ |
H A D | snapshot.h | 233 const std::string& super_device, const std::chrono::milliseconds& timeout_ms = {}) = 0; 238 virtual bool MapAllSnapshots(const std::chrono::milliseconds& timeout_ms = {}) = 0; 364 const std::chrono::milliseconds& timeout_ms = {}) override; 373 bool MapAllSnapshots(const std::chrono::milliseconds& timeout_ms = {}) override; 499 const std::string& cow_device, const std::chrono::milliseconds& timeout_ms, 504 const std::string& base_device, const std::chrono::milliseconds& timeout_ms, 509 const std::chrono::milliseconds& timeout_ms, std::string* path); 513 const std::chrono::milliseconds& timeout_ms); 639 const std::chrono::milliseconds& timeout_ms); 764 bool WaitForDevice(const std::string& device, std::chrono::milliseconds timeout_ms); [all …]
|
/aosp12/packages/modules/adb/fdevent/ |
H A D | fdevent_poll.cpp | 139 int timeout_ms; in Loop() local 141 timeout_ms = -1; in Loop() 143 timeout_ms = timeout->count(); in Loop() 146 int ret = adb_poll(pollfds.data(), pollfds.size(), timeout_ms); in Loop()
|