lldb::ConnectionStatus Disconnect(Error *error_ptr) override;
- size_t Read(void *dst, size_t dst_len, uint32_t timeout_usec,
+ size_t Read(void *dst, size_t dst_len, const Timeout<std::micro> &timeout,
lldb::ConnectionStatus &status, Error *error_ptr) override;
size_t Write(const void *src, size_t src_len, lldb::ConnectionStatus &status,
char pid_str[256];
::memset(pid_str, 0, sizeof(pid_str));
ConnectionStatus status;
- const size_t pid_str_len =
- file_conn.Read(pid_str, sizeof(pid_str), 0, status, NULL);
+ const size_t pid_str_len = file_conn.Read(
+ pid_str, sizeof(pid_str), std::chrono::seconds(0), status, NULL);
if (pid_str_len > 0) {
int pid = atoi(pid_str);
return (void *)(intptr_t)pid;
}
size_t ConnectionGenericFile::Read(void *dst, size_t dst_len,
- uint32_t timeout_usec,
+ const Timeout<std::micro> &timeout,
lldb::ConnectionStatus &status,
Error *error_ptr) {
ReturnInfo return_info;
// The expected return path. The operation is pending. Wait for the
// operation to complete
// or be interrupted.
- DWORD milliseconds = timeout_usec/1000;
+ DWORD milliseconds =
+ timeout
+ ? std::chrono::duration_cast<std::chrono::milliseconds>(*timeout)
+ .count()
+ : INFINITE;
DWORD wait_result =
::WaitForMultipleObjects(llvm::array_lengthof(m_event_handles),
m_event_handles, FALSE, milliseconds);
bool timed_out = false;
while (IsConnected() && !timed_out) {
lldb::ConnectionStatus status = eConnectionStatusNoConnection;
- size_t bytes_read =
- Read(buffer, sizeof(buffer), timeout_usec, status, &error);
+ size_t bytes_read = Read(buffer, sizeof(buffer),
+ timeout_usec == UINT32_MAX
+ ? Timeout<std::micro>(llvm::None)
+ : std::chrono::microseconds(timeout_usec),
+ status, &error);
if (log)
log->Printf("%s: Read (buffer, (sizeof(buffer), timeout_usec = 0x%x, "