The server going away may cause it to send an error packet

amphp · Oct 15, 2017 · 9306cbe · 9306cbe
1 parent 0204d14
commit 9306cbe
Showing 1 changed file with 6 additions and 4 deletions.
diff --git a/lib/Processor.php b/lib/Processor.php
@@ -390,10 +390,12 @@ private function handleError($packet) {
         $this->parseCallback = null;
         if ($this->connectionState == self::READY) {
             // normal error
-            if ($this->config->exceptions) {
-                $this->getDeferred()->fail(new QueryException("MySQL error ({$this->connInfo->errorCode}): {$this->connInfo->errorState} {$this->connInfo->errorMsg}", $this->query));
-            } else {
-                $this->getDeferred()->resolve(false);
+            if ($deferred = $this->getDeferred()) {
+                if ($this->config->exceptions) {
+                    $deferred->fail(new QueryException("MySQL error ({$this->connInfo->errorCode}): {$this->connInfo->errorState} {$this->connInfo->errorMsg}", $this->query));
+                } else {
+                    $deferred->resolve(false);
+                }
             }
             $this->query = null;
             $this->ready();