From 2df5f509a62f14aadeb473929c8fa40f0800ffb3 Mon Sep 17 00:00:00 2001 From: =?utf8?q?Roland=20H=C3=A4der?= Date: Fri, 23 Mar 2012 22:19:18 +0000 Subject: [PATCH] Switched around sub-tasks, commented out noisy debug line --- .../package/fragmenter/class_PackageFragmenter.php | 2 +- .../tasks/network/class_NetworkPackageReaderTask.php | 12 ++++++------ .../tasks/network/class_NetworkPackageWriterTask.php | 12 ++++++------ 3 files changed, 13 insertions(+), 13 deletions(-) diff --git a/application/hub/main/package/fragmenter/class_PackageFragmenter.php b/application/hub/main/package/fragmenter/class_PackageFragmenter.php index 622e56f34..9b1b8d52d 100644 --- a/application/hub/main/package/fragmenter/class_PackageFragmenter.php +++ b/application/hub/main/package/fragmenter/class_PackageFragmenter.php @@ -382,7 +382,7 @@ class PackageFragmenter extends BaseFrameworkSystem implements Fragmentable, Reg assert(strlen($rawData) <= NetworkPackage::TCP_PACKAGE_SIZE); // Add it to the array - /* NOISY-DEBUG: */ $this->debugOutput('FRAGMENTER: Adding ' . strlen($rawData) . ' bytes of a chunk ...'); + //* NOISY-DEBUG: */ $this->debugOutput('FRAGMENTER: Adding ' . strlen($rawData) . ' bytes of a chunk ...'); $this->chunks[$finalHash][] = $rawData; $this->chunkHashes[$finalHash][] = $rawDataHash; } diff --git a/application/hub/main/tasks/network/class_NetworkPackageReaderTask.php b/application/hub/main/tasks/network/class_NetworkPackageReaderTask.php index 7e10c0e84..da672097a 100644 --- a/application/hub/main/tasks/network/class_NetworkPackageReaderTask.php +++ b/application/hub/main/tasks/network/class_NetworkPackageReaderTask.php @@ -74,9 +74,9 @@ class NetworkPackageReaderTask extends BaseTask implements Taskable, Visitable { */ public function executeTask () { // Do we have something to handle? - if ($this->getPackageInstance()->isNewRawDataPending($this->getListenerPoolInstance())) { - // We have to handle raw data from the socket - $this->getPackageInstance()->handleIncomingDecodedData(); + if ($this->getPackageInstance()->isNewPackageArrived()) { + // Okay, then handle newly arrived package + $this->getPackageInstance()->handleNewlyArrivedPackage(); } elseif ($this->getPackageInstance()->isIncomingDecodedDataHandled()) { /* * We have handled decoded data so we should validate it, if we have @@ -84,9 +84,9 @@ class NetworkPackageReaderTask extends BaseTask implements Taskable, Visitable { * network package. */ $this->getPackageInstance()->assembleDecodedDataToPackage(); - } elseif ($this->getPackageInstance()->isNewPackageArrived()) { - // Okay, then handle newly arrived package - $this->getPackageInstance()->handleNewlyArrivedPackage(); + } elseif ($this->getPackageInstance()->isNewRawDataPending($this->getListenerPoolInstance())) { + // We have to handle raw data from the socket + $this->getPackageInstance()->handleIncomingDecodedData(); } // END - if } } diff --git a/application/hub/main/tasks/network/class_NetworkPackageWriterTask.php b/application/hub/main/tasks/network/class_NetworkPackageWriterTask.php index 12cbd092d..e410f660b 100644 --- a/application/hub/main/tasks/network/class_NetworkPackageWriterTask.php +++ b/application/hub/main/tasks/network/class_NetworkPackageWriterTask.php @@ -70,15 +70,15 @@ class NetworkPackageWriterTask extends BaseTask implements Taskable, Visitable { */ public function executeTask () { // Do we have something to deliver? - if ($this->getPackageInstance()->isPackageEnqueued()) { - // Okay, then deliver (better discover its recipients) this package - $this->getPackageInstance()->declareEnqueuedPackage(); + if ($this->getPackageInstance()->isPackageWaitingForDelivery()) { + // Sent it finally out + $this->getPackageInstance()->sendWaitingPackage(); } elseif ($this->getPackageInstance()->isPackageDeclared()) { // Prepare package for delivery $this->getPackageInstance()->deliverDeclaredPackage(); - } elseif ($this->getPackageInstance()->isPackageWaitingForDelivery()) { - // Sent it finally out - $this->getPackageInstance()->sendWaitingPackage(); + } elseif ($this->getPackageInstance()->isPackageEnqueued()) { + // Okay, then deliver (better discover its recipients) this package + $this->getPackageInstance()->declareEnqueuedPackage(); } } } -- 2.39.5