Fix channel state handling

Shouldn't try and recv data when the channel is closed.
wtsnz · Feb 15, 2021 · 1465c82 · 1465c82
1 parent a2acd32
commit 1465c82
Showing 1 changed file with 10 additions and 5 deletions.
diff --git a/deps/portal/src/Channel.cpp b/deps/portal/src/Channel.cpp
@@ -119,13 +119,18 @@ void Channel::InternalThreadEntry()
  while (running) {
  std::unique_lock<std::mutex> lock(worker_mutex);
 
+ if (getState() == State::Errored) {
+ return;
+ }
+
+ // Receive some data
  const uint32_t numberOfBytesToAskFor = 1 << 18; // 262,144
- uint32_t numberOfBytesReceived = 0;
- auto vector = std::vector<char>(numberOfBytesToAskFor);
+ uint32_t numberOfBytesReceived = 0;
+ auto vector = std::vector<char>(numberOfBytesToAskFor);
 
- int ret = usbmuxd_recv_timeout(conn, vector.data(),
-  numberOfBytesToAskFor,
-  &numberOfBytesReceived, 1000);
+ int ret = usbmuxd_recv_timeout(conn, vector.data(),
+  numberOfBytesToAskFor,
+  &numberOfBytesReceived, 1000);
 
  if (ret == 0) {
  if (getState() == State::Connecting) {