$decoderInstance = new PackageDecoder();
// Init stacker for received packages
- $handlerInstance->getStackerInstance()->initStack(self::STACKER_NAME_DECODED_PACKAGE);
+ $handlerInstance->getStackInstance()->initStack(self::STACKER_NAME_DECODED_PACKAGE);
// Set the handler instance here
$decoderInstance->setHandlerInstance($handlerInstance);
*/
public function ifUnhandledRawPackageDataLeft () {
// Check it
- $unhandledDataLeft = (!$this->getHandlerInstance()->getStackerInstance()->isStackEmpty(ChunkHandler::STACKER_NAME_ASSEMBLED_RAW_DATA));
+ $unhandledDataLeft = (!$this->getHandlerInstance()->getStackInstance()->isStackEmpty(ChunkHandler::STACKER_NAME_ASSEMBLED_RAW_DATA));
// Return it
//* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__)->debugOutput('PACKAGE-DECODER[' . __METHOD__ . ':' . __LINE__ . ']: unhandledDataLeft=' . intval($unhandledDataLeft));
assert($this->ifUnhandledRawPackageDataLeft());
// "Pop" the next raw package content
- $rawPackageContent = $this->getHandlerInstance()->getStackerInstance()->popNamed(ChunkHandler::STACKER_NAME_ASSEMBLED_RAW_DATA);
+ $rawPackageContent = $this->getHandlerInstance()->getStackInstance()->popNamed(ChunkHandler::STACKER_NAME_ASSEMBLED_RAW_DATA);
// Debug message
//* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__)->debugOutput('PACKAGE-DECODER[' . __METHOD__ . ':' . __LINE__ . ']: Got ' . strlen($rawPackageContent) . ' bytes from stack ' . ChunkHandler::STACKER_NAME_ASSEMBLED_RAW_DATA . ', decoding it ...');
if ($discoveryInstance->isRecipientListEmpty()) {
// The recipient is this node so next stack it on 'decoded_package'
//* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__)->debugOutput('PACKAGE-DECODER[' . __METHOD__ . ':' . __LINE__ . ']: Pushing ' . strlen($decodedData) . ' bytes to stack ' . self::STACKER_NAME_DECODED_PACKAGE . ' ...');
- $this->getHandlerInstance()->getStackerInstance()->pushNamed(self::STACKER_NAME_DECODED_PACKAGE, $decodedData);
+ $this->getHandlerInstance()->getStackInstance()->pushNamed(self::STACKER_NAME_DECODED_PACKAGE, $decodedData);
} else {
// Forward the package to the next node
$this->getPackageInstance()->forwardRawPackage($decodedData);
*/
public function ifDeocedPackagesLeft () {
// Check it ...
- $ifRawPackagesLeft = (!$this->getHandlerInstance()->getStackerInstance()->isStackEmpty(self::STACKER_NAME_DECODED_PACKAGE));
+ $ifRawPackagesLeft = (!$this->getHandlerInstance()->getStackInstance()->isStackEmpty(self::STACKER_NAME_DECODED_PACKAGE));
// ... return it
return $ifRawPackagesLeft;
assert($this->ifDeocedPackagesLeft());
// Get the next entry (assoziative array)
- $decodedData = $this->getHandlerInstance()->getStackerInstance()->popNamed(self::STACKER_NAME_DECODED_PACKAGE);
+ $decodedData = $this->getHandlerInstance()->getStackInstance()->popNamed(self::STACKER_NAME_DECODED_PACKAGE);
// Handle it
//* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__)->debugOutput('PACKAGE-DECODER[' . __METHOD__ . ':' . __LINE__ . ']: decodedData(' . count($decodedData) . ')=' . print_r($decodedData, TRUE));
parent::__construct($className);
// Get a stacker instance for this DHT
- $stackerInstance = ObjectFactory::createObjectByConfiguredName('dht_stacker_class');
+ $stackInstance = ObjectFactory::createObjectByConfiguredName('dht_stacker_class');
// Set it in this class
- $this->setStackerInstance($stackerInstance);
+ $this->setStackInstance($stackInstance);
// Init all stackers
$this->initStacks();
*/
private function initStacks () {
// Initialize all stacker
- $this->getStackerInstance()->initStacks(array(
+ $this->getStackInstance()->initStacks(array(
self::STACKER_NAME_INSERT_NODE,
self::STACKER_NAME_PENDING_PUBLISHING,
));
*/
public function ifInsertNodeDataPending () {
// Determine it if it is not empty
- $isPending = ($this->getStackerInstance()->isStackEmpty(self::STACKER_NAME_INSERT_NODE) === FALSE);
+ $isPending = ($this->getStackInstance()->isStackEmpty(self::STACKER_NAME_INSERT_NODE) === FALSE);
// Return status
return $isPending;
*/
public function insertSingleNodeData () {
// Get next node data from stack
- $nodeData = $this->getStackerInstance()->popNamed(self::STACKER_NAME_INSERT_NODE);
+ $nodeData = $this->getStackInstance()->popNamed(self::STACKER_NAME_INSERT_NODE);
// Make sure $nodeData is really an array and has at least one entry
assert((is_array($nodeData)) && (count($nodeData) > 0));
// ... and push it to the next stack
//* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__)->debugOutput('BASE-DHT[' . __METHOD__ . ':' . __LINE__ . '] Pushing entry with ' . count($current) . ' elements to stack ' . self::STACKER_NAME_PENDING_PUBLISHING . ' ...');
- $this->getStackerInstance()->pushNamed(self::STACKER_NAME_PENDING_PUBLISHING, $current);
+ $this->getStackInstance()->pushNamed(self::STACKER_NAME_PENDING_PUBLISHING, $current);
} // END - while
}
*/
public function hasEntriesPendingPublication () {
// Determine it if it is not empty
- $isPending = ($this->getStackerInstance()->isStackEmpty(self::STACKER_NAME_PENDING_PUBLISHING) === FALSE);
+ $isPending = ($this->getStackInstance()->isStackEmpty(self::STACKER_NAME_PENDING_PUBLISHING) === FALSE);
// Return status
/* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__)->debugOutput('BASE-DHT[' . __METHOD__ . ':' . __LINE__ . '] isPending=' . intval($isPending));
$this->publishHelperInstance->loadDescriptorXml($this);
// "Pop" next entry
- $entry = $this->getStackerInstance()->popNamed(self::STACKER_NAME_PENDING_PUBLISHING);
+ $entry = $this->getStackInstance()->popNamed(self::STACKER_NAME_PENDING_PUBLISHING);
// Some sanity-checks
assert(is_array($entry));
// Put them all into a stack
foreach ($nodeList as $nodeData) {
// Insert all entries
- $this->getStackerInstance()->pushNamed(self::STACKER_NAME_INSERT_NODE, $nodeData);
+ $this->getStackInstance()->pushNamed(self::STACKER_NAME_INSERT_NODE, $nodeData);
} // END - foreach
}
);
// Push the processed message back on stack
- $packageInstance->getStackerInstance()->pushNamed(NetworkPackage::STACKER_NAME_PROCESSED_MESSAGE, $messageArray);
+ $packageInstance->getStackInstance()->pushNamed(NetworkPackage::STACKER_NAME_PROCESSED_MESSAGE, $messageArray);
}
}
$handlerInstance = new ChunkHandler();
// Get a FIFO stacker
- $stackerInstance = ObjectFactory::createObjectByConfiguredName('chunk_handler_stacker_class');
+ $stackInstance = ObjectFactory::createObjectByConfiguredName('chunk_handler_stacker_class');
// Init all stacker
- $stackerInstance->initStacks(array(
+ $stackInstance->initStacks(array(
self::STACKER_NAME_CHUNKS_WITH_FINAL_EOP,
self::STACKER_NAME_CHUNKS_WITHOUT_FINAL,
self::STACKER_NAME_ASSEMBLED_RAW_DATA
));
// Set the stacker in this handler
- $handlerInstance->setStackerInstance($stackerInstance);
+ $handlerInstance->setStackInstance($stackInstance);
// Get a crypto instance ...
$cryptoInstance = ObjectFactory::createObjectByConfiguredName('crypto_class');
}
// Do we have some pending chunks (no final)?
- while (!$this->getStackerInstance()->isStackEmpty(self::STACKER_NAME_CHUNKS_WITHOUT_FINAL)) {
+ while (!$this->getStackInstance()->isStackEmpty(self::STACKER_NAME_CHUNKS_WITHOUT_FINAL)) {
// Then get it first and add it before the EOP chunks
- array_unshift($chunks, $this->getStackerInstance()->popNamed(self::STACKER_NAME_CHUNKS_WITHOUT_FINAL));
+ array_unshift($chunks, $this->getStackInstance()->popNamed(self::STACKER_NAME_CHUNKS_WITHOUT_FINAL));
} // END - while
// Add all chunks to the FIFO stacker
foreach ($chunks as $chunk) {
// Add the chunk
- $this->getStackerInstance()->pushNamed(self::STACKER_NAME_CHUNKS_WITH_FINAL_EOP, $chunk);
+ $this->getStackInstance()->pushNamed(self::STACKER_NAME_CHUNKS_WITH_FINAL_EOP, $chunk);
} // END - foreach
}
// Add all chunks to the FIFO stacker
foreach ($chunks as $chunk) {
// Add the chunk
- $this->getStackerInstance()->pushNamed(self::STACKER_NAME_CHUNKS_WITHOUT_FINAL, $chunk);
+ $this->getStackInstance()->pushNamed(self::STACKER_NAME_CHUNKS_WITHOUT_FINAL, $chunk);
} // END - foreach
}
*/
public function ifUnhandledChunksWithFinalAvailable () {
// Simply check if the stacker is not empty
- $unhandledChunks = $this->getStackerInstance()->isStackEmpty(self::STACKER_NAME_CHUNKS_WITH_FINAL_EOP) === FALSE;
+ $unhandledChunks = $this->getStackInstance()->isStackEmpty(self::STACKER_NAME_CHUNKS_WITH_FINAL_EOP) === FALSE;
// Return result
return $unhandledChunks;
assert($this->ifUnhandledChunksWithFinalAvailable());
// Get an entry from the stacker
- $chunk = $this->getStackerInstance()->popNamed(self::STACKER_NAME_CHUNKS_WITH_FINAL_EOP);
+ $chunk = $this->getStackInstance()->popNamed(self::STACKER_NAME_CHUNKS_WITH_FINAL_EOP);
// Split the string with proper separator character
$chunkSplits = explode(PackageFragmenter::CHUNK_DATA_HASH_SEPARATOR, $chunk);
$this->addChunkToFinalArray($chunkSplits);
// Is the stack now empty?
- if ($this->getStackerInstance()->isStackEmpty(self::STACKER_NAME_CHUNKS_WITH_FINAL_EOP)) {
+ if ($this->getStackInstance()->isStackEmpty(self::STACKER_NAME_CHUNKS_WITH_FINAL_EOP)) {
// Then mark the final array as complete
$this->markFinalArrayAsCompleted();
} // END - if
// Then feed it into the next stacker
//* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__)->debugOutput('CHUNK-HANDLER[' . __METHOD__ . ':' . __LINE__ . ']: Pushing ' . strlen($this->rawPackageData) . ' bytes to stack ' . self::STACKER_NAME_ASSEMBLED_RAW_DATA . ' ...');
- $this->getStackerInstance()->pushNamed(self::STACKER_NAME_ASSEMBLED_RAW_DATA, $this->rawPackageData);
+ $this->getStackInstance()->pushNamed(self::STACKER_NAME_ASSEMBLED_RAW_DATA, $this->rawPackageData);
// ... and reset it
$this->rawPackageData = '';
$this->setErrorCode(self::SOCKET_ERROR_UNKNOWN);
// Init stacker instance for processed raw data
- $stackerInstance = ObjectFactory::createObjectByConfiguredName('node_raw_data_stacker_class');
+ $stackInstance = ObjectFactory::createObjectByConfiguredName('node_raw_data_stacker_class');
// Remember this in this package handler
- $this->setStackerInstance($stackerInstance);
+ $this->setStackInstance($stackInstance);
// Init stacker
$this->initStack();
* @return void
*/
protected function initStack () {
- $this->getStackerInstance()->initStack(self::STACKER_NAME_RAW_DATA);
+ $this->getStackInstance()->initStack(self::STACKER_NAME_RAW_DATA);
}
/**
* Add the deocoded data and error code to the stacker so other classes
* (e.g. NetworkPackage) can "pop" it from the stacker.
*/
- $this->getStackerInstance()->pushNamed(self::STACKER_NAME_RAW_DATA, array(
+ $this->getStackInstance()->pushNamed(self::STACKER_NAME_RAW_DATA, array(
self::PACKAGE_RAW_DATA => $rawData,
self::PACKAGE_ERROR_CODE => $this->getErrorCode()
));
*/
public function isRawDataPending () {
// Does the stacker have some entries (not empty)?
- $isPending = (!$this->getStackerInstance()->isStackEmpty(self::STACKER_NAME_RAW_DATA));
+ $isPending = (!$this->getStackInstance()->isStackEmpty(self::STACKER_NAME_RAW_DATA));
// Return it
return $isPending;
*/
public function getNextRawData () {
// "Pop" the raw data from the stacker
- $rawData = $this->getStackerInstance()->popNamed(self::STACKER_NAME_RAW_DATA);
+ $rawData = $this->getStackInstance()->popNamed(self::STACKER_NAME_RAW_DATA);
// And return it
return $rawData;
$diff = $encodedDataArray[NetworkPackage::RAW_BUFFER_SIZE_INDEX] - strlen($encodedDataArray[NetworkPackage::RAW_ENCODED_DATA_INDEX]);
// Push raw data to the package's outgoing stack
- $this->getPackageInstance()->getStackerInstance()->pushNamed(NetworkPackage::STACKER_NAME_OUTGOING_STREAM, $encodedDataArray);
+ $this->getPackageInstance()->getStackInstance()->pushNamed(NetworkPackage::STACKER_NAME_OUTGOING_STREAM, $encodedDataArray);
}
/**
$assemblerInstance->setHandlerInstance($handlerInstance);
// Get stacker instance
- $stackerInstance = ObjectFactory::createObjectByConfiguredName('multiple_message_stacker_class');
+ $stackInstance = ObjectFactory::createObjectByConfiguredName('multiple_message_stacker_class');
// Initialize the only one stack
- $stackerInstance->initStack(self::STACKER_NAME_MULTIPLE_MESSAGE);
+ $stackInstance->initStack(self::STACKER_NAME_MULTIPLE_MESSAGE);
// And add it
- $assemblerInstance->setStackerInstance($stackerInstance);
+ $assemblerInstance->setStackInstance($stackInstance);
// Return the prepared instance
return $assemblerInstance;
*/
private function ifInputBufferIsEmpty () {
// Check it
- $isInputBufferEmpty = $this->getPackageInstance()->getStackerInstance()->isStackEmpty(NetworkPackage::STACKER_NAME_DECODED_HANDLED);
+ $isInputBufferEmpty = $this->getPackageInstance()->getStackInstance()->isStackEmpty(NetworkPackage::STACKER_NAME_DECODED_HANDLED);
// Debug message
//* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__)->debugOutput('PACKAGE-ASSEMBLER[' . __METHOD__ . ':' . __LINE__ . ']: isInputBufferEmpty=' . intval($isInputBufferEmpty));
*/
public function ifMultipleMessagesPending () {
// Determine it
- $isPending = (!$this->getStackerInstance()->isStackEmpty(self::STACKER_NAME_MULTIPLE_MESSAGE));
+ $isPending = (!$this->getStackInstance()->isStackEmpty(self::STACKER_NAME_MULTIPLE_MESSAGE));
// Return it
//* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__)->debugOutput('PACKAGE-ASSEMBLER[' . __METHOD__ . ':' . __LINE__ . ': isPending=' . intval($isPending));
$message = BaseRawDataHandler::STREAM_START_MARKER . $message;
// Push it on stack
- $this->getStackerInstance()->pushNamed(self::STACKER_NAME_MULTIPLE_MESSAGE, $message);
+ $this->getStackInstance()->pushNamed(self::STACKER_NAME_MULTIPLE_MESSAGE, $message);
} // END - foreach
// Clear pending data
assert($this->isPendingDataEmpty());
// "Pop" next entry from stack and set it as new pending data
- $this->pendingData = $this->getStackerInstance()->popNamed(self::STACKER_NAME_MULTIPLE_MESSAGE);
+ $this->pendingData = $this->getStackInstance()->popNamed(self::STACKER_NAME_MULTIPLE_MESSAGE);
// And handle it
$this->handlePendingData();
* which have no recipient address and stamp... ;-) This stacker will
* also be used for incoming raw data to handle it.
*/
- $stackerInstance = ObjectFactory::createObjectByConfiguredName('network_package_stacker_class');
+ $stackInstance = ObjectFactory::createObjectByConfiguredName('network_package_stacker_class');
// At last, set it in this class
- $packageInstance->setStackerInstance($stackerInstance);
+ $packageInstance->setStackInstance($stackInstance);
// Init all stacker
$packageInstance->initStacks();
*/
protected function initStacks ($forceReInit = FALSE) {
// Initialize all
- $this->getStackerInstance()->initStacks(array(
+ $this->getStackInstance()->initStacks(array(
self::STACKER_NAME_UNDECLARED,
self::STACKER_NAME_DECLARED,
self::STACKER_NAME_OUTGOING,
*/
private function changePackageStatus (array $packageData, $stackerName, $newStatus) {
// Skip this for empty stacks
- if ($this->getStackerInstance()->isStackEmpty($stackerName)) {
+ if ($this->getStackInstance()->isStackEmpty($stackerName)) {
// This avoids an exception after all packages has failed
return;
} // END - if
// Pop the entry (it should be it)
- $nextData = $this->getStackerInstance()->popNamed($stackerName);
+ $nextData = $this->getStackInstance()->popNamed($stackerName);
// Compare both signatures
assert($nextData[self::PACKAGE_DATA_SIGNATURE] == $packageData[self::PACKAGE_DATA_SIGNATURE]);
$packageData[self::PACKAGE_DATA_STATUS] = $newStatus;
// And push it again
- $this->getStackerInstance()->pushNamed($stackerName, $packageData);
+ $this->getStackInstance()->pushNamed($stackerName, $packageData);
}
/**
$packageData[self::PACKAGE_DATA_RECIPIENT] = $currentRecipient;
// Push the declared package to the next stack.
- $this->getStackerInstance()->pushNamed(self::STACKER_NAME_DECLARED, $packageData);
+ $this->getStackInstance()->pushNamed(self::STACKER_NAME_DECLARED, $packageData);
// Debug message
//* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__)->debugOutput('NETWORK-PACKAGE[' . __METHOD__ . ':' . __LINE__ . ']: Package declared for recipient ' . $currentRecipient);
//* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__)->debugOutput('NETWORK-PACKAGE[' . __METHOD__ . ':' . __LINE__ . ']: Reached line ' . __LINE__ . ' after validatePeerStateConnected() has been called.');
// Enqueue it again on the out-going queue, the connection is up and working at this point
- $this->getStackerInstance()->pushNamed(self::STACKER_NAME_OUTGOING, $packageData);
+ $this->getStackInstance()->pushNamed(self::STACKER_NAME_OUTGOING, $packageData);
// Debug message
//* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__)->debugOutput('NETWORK-PACKAGE[' . __METHOD__ . ':' . __LINE__ . ']: Reached line ' . __LINE__ . ' after pushNamed() has been called.');
);
// Now prepare the temporary array and push it on the 'undeclared' stack
- $this->getStackerInstance()->pushNamed(self::STACKER_NAME_UNDECLARED, array(
+ $this->getStackInstance()->pushNamed(self::STACKER_NAME_UNDECLARED, array(
self::PACKAGE_DATA_SENDER => $this->getSessionId(),
self::PACKAGE_DATA_RECIPIENT => $helperInstance->getRecipientType(),
self::PACKAGE_DATA_PROTOCOL => $protocolName,
*/
public function isPackageEnqueued () {
// Check whether the stacker is not empty
- $isEnqueued = (($this->getStackerInstance()->isStackInitialized(self::STACKER_NAME_UNDECLARED)) && (!$this->getStackerInstance()->isStackEmpty(self::STACKER_NAME_UNDECLARED)));
+ $isEnqueued = (($this->getStackInstance()->isStackInitialized(self::STACKER_NAME_UNDECLARED)) && (!$this->getStackInstance()->isStackEmpty(self::STACKER_NAME_UNDECLARED)));
// Return the result
return $isEnqueued;
*/
public function isPackageDeclared () {
// Check whether the stacker is not empty
- $isDeclared = (($this->getStackerInstance()->isStackInitialized(self::STACKER_NAME_DECLARED)) && (!$this->getStackerInstance()->isStackEmpty(self::STACKER_NAME_DECLARED)));
+ $isDeclared = (($this->getStackInstance()->isStackInitialized(self::STACKER_NAME_DECLARED)) && (!$this->getStackInstance()->isStackEmpty(self::STACKER_NAME_DECLARED)));
// Return the result
return $isDeclared;
*/
public function isPackageWaitingForDelivery () {
// Check whether the stacker is not empty
- $isWaitingDelivery = (($this->getStackerInstance()->isStackInitialized(self::STACKER_NAME_OUTGOING)) && (!$this->getStackerInstance()->isStackEmpty(self::STACKER_NAME_OUTGOING)));
+ $isWaitingDelivery = (($this->getStackInstance()->isStackInitialized(self::STACKER_NAME_OUTGOING)) && (!$this->getStackInstance()->isStackEmpty(self::STACKER_NAME_OUTGOING)));
// Return the result
return $isWaitingDelivery;
*/
public function isEncodedDataPending () {
// Check whether the stacker is not empty
- $isPending = (($this->getStackerInstance()->isStackInitialized(self::STACKER_NAME_OUTGOING_STREAM)) && (!$this->getStackerInstance()->isStackEmpty(self::STACKER_NAME_OUTGOING_STREAM)));
+ $isPending = (($this->getStackInstance()->isStackInitialized(self::STACKER_NAME_OUTGOING_STREAM)) && (!$this->getStackInstance()->isStackEmpty(self::STACKER_NAME_OUTGOING_STREAM)));
// Return the result
return $isPending;
* Now there are for sure packages to deliver, so start with the first
* one.
*/
- $packageData = $this->getStackerInstance()->popNamed(self::STACKER_NAME_UNDECLARED);
+ $packageData = $this->getStackInstance()->popNamed(self::STACKER_NAME_UNDECLARED);
// Declare the raw package data for delivery
$this->declareRawPackageData($packageData);
} // END - if
// Get the package
- $packageData = $this->getStackerInstance()->getNamed(self::STACKER_NAME_DECLARED);
+ $packageData = $this->getStackInstance()->getNamed(self::STACKER_NAME_DECLARED);
// Assert on it
assert(isset($packageData[self::PACKAGE_DATA_RECIPIENT]));
$this->deliverRawPackageData($packageData);
// And remove it finally
- $this->getStackerInstance()->popNamed(self::STACKER_NAME_DECLARED);
+ $this->getStackInstance()->popNamed(self::STACKER_NAME_DECLARED);
} catch (InvalidStateException $e) {
// The state is not excepected (shall be 'connected')
self::createDebugInstance(__CLASS__)->debugOutput('NETWORK-PACKAGE[' . __METHOD__ . ':' . __LINE__ . ']: Caught ' . $e->__toString() . ',message=' . $e->getMessage());
} // END - if
// Get the package
- $packageData = $this->getStackerInstance()->getNamed(self::STACKER_NAME_OUTGOING);
+ $packageData = $this->getStackInstance()->getNamed(self::STACKER_NAME_OUTGOING);
try {
// Now try to send it
$this->sendOutgoingRawPackageData($packageData);
// And remove it finally
- $this->getStackerInstance()->popNamed(self::STACKER_NAME_OUTGOING);
+ $this->getStackInstance()->popNamed(self::STACKER_NAME_OUTGOING);
} catch (InvalidSocketException $e) {
// Output exception message
self::createDebugInstance(__CLASS__)->debugOutput('NETWORK-PACKAGE[' . __METHOD__ . ':' . __LINE__ . ']: Package was not delivered: ' . $e->getMessage());
assert($this->isEncodedDataPending());
// Pop current data from stack
- $encodedDataArray = $this->getStackerInstance()->popNamed(self::STACKER_NAME_OUTGOING_STREAM);
+ $encodedDataArray = $this->getStackInstance()->popNamed(self::STACKER_NAME_OUTGOING_STREAM);
// Init in this round sent bytes
$sentBytes = 0;
}
// Push array back in stack
- $this->getStackerInstance()->pushNamed(self::STACKER_NAME_OUTGOING_STREAM, $encodedDataArray);
+ $this->getStackInstance()->pushNamed(self::STACKER_NAME_OUTGOING_STREAM, $encodedDataArray);
}
///////////////////////////////////////////////////////////////////////////
*/
private function isRawDataPending () {
// Just return whether the stack is not empty
- $isPending = (!$this->getStackerInstance()->isStackEmpty(self::STACKER_NAME_DECODED_INCOMING));
+ $isPending = (!$this->getStackInstance()->isStackEmpty(self::STACKER_NAME_DECODED_INCOMING));
// Return the status
return $isPending;
} // END - if
// Very noisy debug message:
- //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__)->debugOutput('NETWORK-PACKAGE[' . __METHOD__ . ':' . __LINE__ . ']: Stacker size is ' . $this->getStackerInstance()->getStackCount(self::STACKER_NAME_DECODED_INCOMING) . ' entries.');
+ //* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__)->debugOutput('NETWORK-PACKAGE[' . __METHOD__ . ':' . __LINE__ . ']: Stacker size is ' . $this->getStackInstance()->getStackCount(self::STACKER_NAME_DECODED_INCOMING) . ' entries.');
// "Pop" the next entry (the same array again) from the stack
- $decodedData = $this->getStackerInstance()->popNamed(self::STACKER_NAME_DECODED_INCOMING);
+ $decodedData = $this->getStackInstance()->popNamed(self::STACKER_NAME_DECODED_INCOMING);
// Make sure both array elements are there
assert(
// This package is "handled" and can be pushed on the next stack
//* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__)->debugOutput('NETWORK-PACKAGE[' . __METHOD__ . ':' . __LINE__ . ']: Pushing ' . strlen($decodedData[BaseRawDataHandler::PACKAGE_RAW_DATA]) . ' bytes to stack ' . self::STACKER_NAME_DECODED_HANDLED . ' ...');
- $this->getStackerInstance()->pushNamed(self::STACKER_NAME_DECODED_HANDLED, $decodedData);
+ $this->getStackInstance()->pushNamed(self::STACKER_NAME_DECODED_HANDLED, $decodedData);
}
/**
//* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__)->debugOutput('NETWORK-PACKAGE[' . __METHOD__ . ':' . __LINE__ . ']: decodedData[' . gettype($decodedData) . ']=' . print_r($decodedData, TRUE));
// And push it on our stack
- $this->getStackerInstance()->pushNamed(self::STACKER_NAME_DECODED_INCOMING, $decodedData);
+ $this->getStackInstance()->pushNamed(self::STACKER_NAME_DECODED_INCOMING, $decodedData);
}
/**
*/
public function isIncomingRawDataHandled () {
// Determine if the stack is not empty
- $isHandled = (!$this->getStackerInstance()->isStackEmpty(self::STACKER_NAME_DECODED_HANDLED));
+ $isHandled = (!$this->getStackInstance()->isStackEmpty(self::STACKER_NAME_DECODED_HANDLED));
// Return it
return $isHandled;
assert($this->isIncomingRawDataHandled());
// Get current package content (an array with two elements; see handleIncomingDecodedData() for details)
- $packageContent = $this->getStackerInstance()->getNamed(self::STACKER_NAME_DECODED_HANDLED);
+ $packageContent = $this->getStackInstance()->getNamed(self::STACKER_NAME_DECODED_HANDLED);
// Assert on some elements
assert(
$this->getAssemblerInstance()->chunkPackageContent($packageContent);
// Remove the package from 'handled_decoded' stack ...
- $this->getStackerInstance()->popNamed(self::STACKER_NAME_DECODED_HANDLED);
+ $this->getStackInstance()->popNamed(self::STACKER_NAME_DECODED_HANDLED);
// ... and push it on the 'chunked' stacker
//* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__)->debugOutput('NETWORK-PACKAGE[' . __METHOD__ . ':' . __LINE__ . ']: Pushing ' . strlen($packageContent[BaseRawDataHandler::PACKAGE_RAW_DATA]) . ' bytes on stack ' . self::STACKER_NAME_DECODED_CHUNKED . ',packageContent=' . print_r($packageContent, TRUE));
- $this->getStackerInstance()->pushNamed(self::STACKER_NAME_DECODED_CHUNKED, $packageContent);
+ $this->getStackInstance()->pushNamed(self::STACKER_NAME_DECODED_CHUNKED, $packageContent);
}
/**
*/
public function removeFirstFailedPackage () {
// Get the package again
- $packageData = $this->getStackerInstance()->getNamed(self::STACKER_NAME_DECLARED);
+ $packageData = $this->getStackInstance()->getNamed(self::STACKER_NAME_DECLARED);
// Is the package status 'failed'?
if ($packageData[self::PACKAGE_DATA_STATUS] != self::PACKAGE_STATUS_FAILED) {
} // END - if
// Remove this entry
- $this->getStackerInstance()->popNamed(self::STACKER_NAME_DECLARED);
+ $this->getStackInstance()->popNamed(self::STACKER_NAME_DECLARED);
}
/**
$decodedContent[self::PACKAGE_CONTENT_MESSAGE] = $this->getCompressorInstance()->decompressStream($decodedContent[self::PACKAGE_CONTENT_MESSAGE]);
// And push it on the next stack
- $this->getStackerInstance()->pushNamed(self::STACKER_NAME_NEW_MESSAGE, $decodedContent);
+ $this->getStackInstance()->pushNamed(self::STACKER_NAME_NEW_MESSAGE, $decodedContent);
}
/**
*/
public function isNewMessageArrived () {
// Determine if the stack is not empty
- $hasArrived = (!$this->getStackerInstance()->isStackEmpty(self::STACKER_NAME_NEW_MESSAGE));
+ $hasArrived = (!$this->getStackInstance()->isStackEmpty(self::STACKER_NAME_NEW_MESSAGE));
// Return it
return $hasArrived;
*/
public function handleNewlyArrivedMessage () {
// Get it from the stacker, it is the full array with the decoded message
- $decodedContent = $this->getStackerInstance()->popNamed(self::STACKER_NAME_NEW_MESSAGE);
+ $decodedContent = $this->getStackInstance()->popNamed(self::STACKER_NAME_NEW_MESSAGE);
// Now get a filter chain back from factory with given tags array
$chainInstance = PackageFilterChainFactory::createChainByTagsArray($decodedContent[self::PACKAGE_CONTENT_TAGS]);
*/
public function isProcessedMessagePending () {
// Check it
- $isPending = (!$this->getStackerInstance()->isStackEmpty(self::STACKER_NAME_PROCESSED_MESSAGE));
+ $isPending = (!$this->getStackInstance()->isStackEmpty(self::STACKER_NAME_PROCESSED_MESSAGE));
// Return it
return $isPending;
*/
public function handleProcessedMessage () {
// Get it from the stacker, it is the full array with the processed message
- $messageArray = $this->getStackerInstance()->popNamed(self::STACKER_NAME_PROCESSED_MESSAGE);
+ $messageArray = $this->getStackInstance()->popNamed(self::STACKER_NAME_PROCESSED_MESSAGE);
// Add type for later easier handling
$messageArray[self::MESSAGE_ARRAY_DATA][self::MESSAGE_ARRAY_TYPE] = $messageArray[self::MESSAGE_ARRAY_TYPE];
// Get new instance
$producerInstance = new MinerTestGenesisBlockProducer();
+ // Init the queue for this test block producer
+ $stackInstance = FileStackFactory::createFileStackInstance('test_block_miner');
+
+ // Set it here
+ $producerInstance->setStackInstance($stackInstance);
+
// Return the prepared instance
return $producerInstance;
}
$stackInstance = FileStackFactory::createFileStackInstance($prefix . '_url', $sourceName);
// Set the stack here
- $this->setStackerInstance($stackInstance);
+ $this->setStackInstance($stackInstance);
}
/**
*/
protected function isUrlStackEmpty () {
// Determine it
- $isEmpty = $this->getStackerInstance()->isStackEmpty('urls');
+ $isEmpty = $this->getStackInstance()->isStackEmpty('urls');
// Return result
return $isEmpty;
// Init source
$sourceInstance->initSource('crawler', 'uploaded_list');
+ // Get a
// Return the prepared instance
return $sourceInstance;
}
*/
public function processStack () {
// Does the stack have some entries left?
- if ($this->isUrlStackEmpty()) {
+ if (!$this->isUrlStackEmpty()) {
// Nothing to handle here
- return;
- } // END - if
+ $this->processNextEntry();
+ } elseif ($this->
$this->partialStub('Please implement this method.');
}
* Assign the found characters to variable and use the last entry from
* stack as the name.
*/
- parent::assignVariable($this->getStackerInstance()->getNamed('node_announcement'), $characters);
+ parent::assignVariable($this->getStackInstance()->getNamed('node_announcement'), $characters);
}
/**
*/
protected function startAnnouncement () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('node_announcement', 'announcement');
+ $this->getStackInstance()->pushNamed('node_announcement', 'announcement');
}
/**
*/
protected function startAnnouncementData () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('node_announcement', 'announcement-data');
+ $this->getStackInstance()->pushNamed('node_announcement', 'announcement-data');
}
/**
*/
protected function startNodeStatus () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('node_announcement', self::ANNOUNCEMENT_DATA_NODE_STATUS);
+ $this->getStackInstance()->pushNamed('node_announcement', self::ANNOUNCEMENT_DATA_NODE_STATUS);
}
/**
*/
protected function startNodeMode () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('node_announcement', self::ANNOUNCEMENT_DATA_NODE_MODE);
+ $this->getStackInstance()->pushNamed('node_announcement', self::ANNOUNCEMENT_DATA_NODE_MODE);
}
/**
*/
protected function startListener () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('node_announcement', 'listener');
+ $this->getStackInstance()->pushNamed('node_announcement', 'listener');
}
/**
*/
protected function startListenPort () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('node_announcement', self::ANNOUNCEMENT_DATA_LISTEN_PORT);
+ $this->getStackInstance()->pushNamed('node_announcement', self::ANNOUNCEMENT_DATA_LISTEN_PORT);
}
/**
*/
protected function startSessionId () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('node_announcement', self::ANNOUNCEMENT_DATA_SESSION_ID);
+ $this->getStackInstance()->pushNamed('node_announcement', self::ANNOUNCEMENT_DATA_SESSION_ID);
}
/**
*/
protected function startExternalIp () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('node_announcement', self::ANNOUNCEMENT_DATA_EXTERNAL_IP);
+ $this->getStackInstance()->pushNamed('node_announcement', self::ANNOUNCEMENT_DATA_EXTERNAL_IP);
}
/**
*/
protected function startInternalIp () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('node_announcement', self::ANNOUNCEMENT_DATA_INTERNAL_IP);
+ $this->getStackInstance()->pushNamed('node_announcement', self::ANNOUNCEMENT_DATA_INTERNAL_IP);
}
/**
*/
protected function startObjectTypeList () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('node_announcement', 'object-type-list');
+ $this->getStackInstance()->pushNamed('node_announcement', 'object-type-list');
}
/**
*/
protected function startObjectType () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('node_announcement', 'object-type');
+ $this->getStackInstance()->pushNamed('node_announcement', 'object-type');
}
/**
*/
protected function finishObjectType () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('node_announcement');
+ $this->getStackInstance()->popNamed('node_announcement');
}
/**
*/
protected function finishObjectTypeList () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('node_announcement');
+ $this->getStackInstance()->popNamed('node_announcement');
}
/**
*/
protected function finishSessionId () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('node_announcement');
+ $this->getStackInstance()->popNamed('node_announcement');
}
/**
*/
protected function finishInternalIp () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('node_announcement');
+ $this->getStackInstance()->popNamed('node_announcement');
}
/**
*/
protected function finishExternalIp () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('node_announcement');
+ $this->getStackInstance()->popNamed('node_announcement');
}
/**
*/
protected function finishListenPort () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('node_announcement');
+ $this->getStackInstance()->popNamed('node_announcement');
}
/**
*/
protected function finishListener () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('node_announcement');
+ $this->getStackInstance()->popNamed('node_announcement');
}
/**
*/
protected function finishNodeMode () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('node_announcement');
+ $this->getStackInstance()->popNamed('node_announcement');
}
/**
*/
protected function finishNodeStatus () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('node_announcement');
+ $this->getStackInstance()->popNamed('node_announcement');
}
/**
*/
protected function finishAnnouncementData () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('node_announcement');
+ $this->getStackInstance()->popNamed('node_announcement');
}
/**
*/
protected function finishAnnouncement () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('node_announcement');
+ $this->getStackInstance()->popNamed('node_announcement');
}
}
* Assign the found characters to variable and use the last entry from
* stack as the name.
*/
- parent::assignVariable($this->getStackerInstance()->getNamed('node_announcement_answer'), $characters);
+ parent::assignVariable($this->getStackInstance()->getNamed('node_announcement_answer'), $characters);
}
/**
*/
protected function startAnnouncementAnswer () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('node_announcement_answer', 'announcement-answer');
+ $this->getStackInstance()->pushNamed('node_announcement_answer', 'announcement-answer');
}
/**
*/
protected function startMyData () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('node_announcement_answer', 'my-data');
+ $this->getStackInstance()->pushNamed('node_announcement_answer', 'my-data');
}
/**
*/
protected function startMyExternalIp () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('node_announcement_answer', self::ANNOUNCEMENT_DATA_EXTERNAL_IP);
+ $this->getStackInstance()->pushNamed('node_announcement_answer', self::ANNOUNCEMENT_DATA_EXTERNAL_IP);
}
/**
*/
protected function startMyInternalIp () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('node_announcement_answer', self::ANNOUNCEMENT_DATA_INTERNAL_IP);
+ $this->getStackInstance()->pushNamed('node_announcement_answer', self::ANNOUNCEMENT_DATA_INTERNAL_IP);
}
/**
*/
protected function startMyListenPort () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('node_announcement_answer', self::ANNOUNCEMENT_DATA_LISTEN_PORT);
+ $this->getStackInstance()->pushNamed('node_announcement_answer', self::ANNOUNCEMENT_DATA_LISTEN_PORT);
}
/**
*/
protected function startMySessionId () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('node_announcement_answer', self::ANNOUNCEMENT_DATA_SESSION_ID);
+ $this->getStackInstance()->pushNamed('node_announcement_answer', self::ANNOUNCEMENT_DATA_SESSION_ID);
}
/**
*/
protected function startMyStatus () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('node_announcement_answer', self::ANNOUNCEMENT_DATA_NODE_STATUS);
+ $this->getStackInstance()->pushNamed('node_announcement_answer', self::ANNOUNCEMENT_DATA_NODE_STATUS);
}
/**
*/
protected function finishMyStatus () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('node_announcement_answer');
+ $this->getStackInstance()->popNamed('node_announcement_answer');
}
/**
*/
protected function finishMySessionId () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('node_announcement_answer');
+ $this->getStackInstance()->popNamed('node_announcement_answer');
}
/**
*/
protected function finishMyListenPort () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('node_announcement_answer');
+ $this->getStackInstance()->popNamed('node_announcement_answer');
}
/**
*/
protected function finishMyInternalIp () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('node_announcement_answer');
+ $this->getStackInstance()->popNamed('node_announcement_answer');
}
/**
*/
protected function finishMyExternalIp () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('node_announcement_answer');
+ $this->getStackInstance()->popNamed('node_announcement_answer');
}
/**
*/
protected function finishMyData () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('node_announcement_answer');
+ $this->getStackInstance()->popNamed('node_announcement_answer');
}
/**
*/
protected function startYourData () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('node_announcement_answer', 'your-data');
+ $this->getStackInstance()->pushNamed('node_announcement_answer', 'your-data');
}
/**
*/
protected function startYourExternalIp () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('node_announcement_answer', 'your-external-ip');
+ $this->getStackInstance()->pushNamed('node_announcement_answer', 'your-external-ip');
}
/**
*/
protected function startYourInternalIp () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('node_announcement_answer', 'your-internal-ip');
+ $this->getStackInstance()->pushNamed('node_announcement_answer', 'your-internal-ip');
}
/**
*/
protected function startYourSessionId () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('node_announcement_answer', 'your-session-id');
+ $this->getStackInstance()->pushNamed('node_announcement_answer', 'your-session-id');
}
/**
*/
protected function finishYourSessionId () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('node_announcement_answer');
+ $this->getStackInstance()->popNamed('node_announcement_answer');
}
/**
*/
protected function finishYourInternalIp () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('node_announcement_answer');
+ $this->getStackInstance()->popNamed('node_announcement_answer');
}
/**
*/
protected function finishYourExternalIp () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('node_announcement_answer');
+ $this->getStackInstance()->popNamed('node_announcement_answer');
}
/**
*/
protected function finishYourData () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('node_announcement_answer');
+ $this->getStackInstance()->popNamed('node_announcement_answer');
}
/**
*/
protected function finishAnnouncementAnswer () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('node_announcement_answer');
+ $this->getStackInstance()->popNamed('node_announcement_answer');
}
}
} // END - if
// Assign data with matching variable here
- parent::assignVariable($this->getStackerInstance()->getNamed('!!!'), $characters);
+ parent::assignVariable($this->getStackInstance()->getNamed('!!!'), $characters);
}
/**
*/
protected function start??? () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('!!!', '|||');
+ $this->getStackInstance()->pushNamed('!!!', '|||');
}
/**
*/
protected function finish??? () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('!!!');
+ $this->getStackInstance()->popNamed('!!!');
}
}
*/
protected function startAnswerStatus () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed($this->getStackerName(), self::ANSWER_STATUS);
+ $this->getStackInstance()->pushNamed($this->getStackerName(), self::ANSWER_STATUS);
}
/**
*/
protected function finishAnswerStatus () {
// Pop the last entry
- $this->getStackerInstance()->popNamed($this->getStackerName());
+ $this->getStackInstance()->popNamed($this->getStackerName());
}
}
* Assign the found characters to variable and use the last entry from
* stack as the name.
*/
- parent::assignVariable($this->getStackerInstance()->getNamed('node_dht_bootstrap_answer'), $characters);
+ parent::assignVariable($this->getStackInstance()->getNamed('node_dht_bootstrap_answer'), $characters);
}
/**
*/
protected function startDhtBootstrapAnswer () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('node_dht_bootstrap_answer', 'dht_bootstrap-answer');
+ $this->getStackInstance()->pushNamed('node_dht_bootstrap_answer', 'dht_bootstrap-answer');
}
/**
*/
protected function startMyData () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('node_dht_bootstrap_answer', 'my-data');
+ $this->getStackInstance()->pushNamed('node_dht_bootstrap_answer', 'my-data');
}
/**
*/
protected function startMyExternalIp () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('node_dht_bootstrap_answer', self::DHT_BOOTSTRAP_DATA_EXTERNAL_IP);
+ $this->getStackInstance()->pushNamed('node_dht_bootstrap_answer', self::DHT_BOOTSTRAP_DATA_EXTERNAL_IP);
}
/**
*/
protected function startMyInternalIp () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('node_dht_bootstrap_answer', self::DHT_BOOTSTRAP_DATA_INTERNAL_IP);
+ $this->getStackInstance()->pushNamed('node_dht_bootstrap_answer', self::DHT_BOOTSTRAP_DATA_INTERNAL_IP);
}
/**
*/
protected function startMyListenPort () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('node_dht_bootstrap_answer', self::DHT_BOOTSTRAP_DATA_LISTEN_PORT);
+ $this->getStackInstance()->pushNamed('node_dht_bootstrap_answer', self::DHT_BOOTSTRAP_DATA_LISTEN_PORT);
}
/**
*/
protected function startMySessionId () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('node_dht_bootstrap_answer', self::DHT_BOOTSTRAP_DATA_SESSION_ID);
+ $this->getStackInstance()->pushNamed('node_dht_bootstrap_answer', self::DHT_BOOTSTRAP_DATA_SESSION_ID);
}
/**
*/
protected function startMyStatus () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('node_dht_bootstrap_answer', self::DHT_BOOTSTRAP_DATA_NODE_STATUS);
+ $this->getStackInstance()->pushNamed('node_dht_bootstrap_answer', self::DHT_BOOTSTRAP_DATA_NODE_STATUS);
}
/**
*/
protected function startDhtNodesList () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('node_dht_bootstrap_answer', self::DHT_BOOTSTRAP_DATA_NODE_LIST);
+ $this->getStackInstance()->pushNamed('node_dht_bootstrap_answer', self::DHT_BOOTSTRAP_DATA_NODE_LIST);
}
/**
*/
protected function finishDhtNodesList () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('node_dht_bootstrap_answer');
+ $this->getStackInstance()->popNamed('node_dht_bootstrap_answer');
}
/**
*/
protected function finishMyStatus () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('node_dht_bootstrap_answer');
+ $this->getStackInstance()->popNamed('node_dht_bootstrap_answer');
}
/**
*/
protected function finishMySessionId () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('node_dht_bootstrap_answer');
+ $this->getStackInstance()->popNamed('node_dht_bootstrap_answer');
}
/**
*/
protected function finishMyListenPort () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('node_dht_bootstrap_answer');
+ $this->getStackInstance()->popNamed('node_dht_bootstrap_answer');
}
/**
*/
protected function finishMyInternalIp () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('node_dht_bootstrap_answer');
+ $this->getStackInstance()->popNamed('node_dht_bootstrap_answer');
}
/**
*/
protected function finishMyExternalIp () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('node_dht_bootstrap_answer');
+ $this->getStackInstance()->popNamed('node_dht_bootstrap_answer');
}
/**
*/
protected function finishMyData () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('node_dht_bootstrap_answer');
+ $this->getStackInstance()->popNamed('node_dht_bootstrap_answer');
}
/**
*/
protected function startYourData () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('node_dht_bootstrap_answer', 'your-data');
+ $this->getStackInstance()->pushNamed('node_dht_bootstrap_answer', 'your-data');
}
/**
*/
protected function startYourExternalIp () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('node_dht_bootstrap_answer', 'your-external-ip');
+ $this->getStackInstance()->pushNamed('node_dht_bootstrap_answer', 'your-external-ip');
}
/**
*/
protected function startYourInternalIp () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('node_dht_bootstrap_answer', 'your-internal-ip');
+ $this->getStackInstance()->pushNamed('node_dht_bootstrap_answer', 'your-internal-ip');
}
/**
*/
protected function startYourSessionId () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('node_dht_bootstrap_answer', 'your-session-id');
+ $this->getStackInstance()->pushNamed('node_dht_bootstrap_answer', 'your-session-id');
}
/**
*/
protected function finishYourSessionId () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('node_dht_bootstrap_answer');
+ $this->getStackInstance()->popNamed('node_dht_bootstrap_answer');
}
/**
*/
protected function finishYourInternalIp () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('node_dht_bootstrap_answer');
+ $this->getStackInstance()->popNamed('node_dht_bootstrap_answer');
}
/**
*/
protected function finishYourExternalIp () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('node_dht_bootstrap_answer');
+ $this->getStackInstance()->popNamed('node_dht_bootstrap_answer');
}
/**
*/
protected function finishYourData () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('node_dht_bootstrap_answer');
+ $this->getStackInstance()->popNamed('node_dht_bootstrap_answer');
}
/**
*/
protected function finishDhtBootstrapAnswer () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('node_dht_bootstrap_answer');
+ $this->getStackInstance()->popNamed('node_dht_bootstrap_answer');
}
}
* Assign the found characters to variable and use the last entry from
* stack as the name.
*/
- parent::assignVariable($this->getStackerInstance()->getNamed('node_request_node_list_answer'), $characters);
+ parent::assignVariable($this->getStackInstance()->getNamed('node_request_node_list_answer'), $characters);
}
/**
*/
protected function startRequestNodeListAnswer () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('node_request_node_list_answer', 'request-node-list-answer');
+ $this->getStackInstance()->pushNamed('node_request_node_list_answer', 'request-node-list-answer');
}
/**
*/
protected function startSessionId () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('node_request_node_list_answer', self::REQUEST_DATA_SESSION_ID);
+ $this->getStackInstance()->pushNamed('node_request_node_list_answer', self::REQUEST_DATA_SESSION_ID);
}
/**
*/
protected function startNodeList () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('node_request_node_list_answer', self::REQUEST_DATA_NODE_LIST);
+ $this->getStackInstance()->pushNamed('node_request_node_list_answer', self::REQUEST_DATA_NODE_LIST);
}
/**
*/
protected function finishNodeList () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('node_request_node_list_answer');
+ $this->getStackInstance()->popNamed('node_request_node_list_answer');
}
/**
*/
protected function finishSessionId () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('node_request_node_list_answer');
+ $this->getStackInstance()->popNamed('node_request_node_list_answer');
}
/**
*/
protected function finishRequestNodeListAnswer () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('node_request_node_list_answer');
+ $this->getStackInstance()->popNamed('node_request_node_list_answer');
}
}
} // END - if
// Assign data with matching variable here
- parent::assignVariable($this->getStackerInstance()->getNamed('!!!'), $characters);
+ parent::assignVariable($this->getStackInstance()->getNamed('!!!'), $characters);
}
/**
*/
protected function start??? () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('!!!', '|||');
+ $this->getStackInstance()->pushNamed('!!!', '|||');
}
/**
*/
protected function finish??? () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('!!!');
+ $this->getStackInstance()->popNamed('!!!');
}
}
$this->setCompileOutputPath($this->getConfigInstance()->getConfigEntry('base_path') . $this->getConfigInstance()->getConfigEntry('compile_output_path'));
// Init a variable stacker
- $stackerInstance = ObjectFactory::createObjectByConfiguredName($typePrefix . '_' . $xmlTemplateType . '_stacker_class');
+ $stackInstance = ObjectFactory::createObjectByConfiguredName($typePrefix . '_' . $xmlTemplateType . '_stacker_class');
// Set name
$this->stackerName = $typePrefix . '_' . $xmlTemplateType;
// Init stacker
- $stackerInstance->initStack($this->stackerName);
+ $stackInstance->initStack($this->stackerName);
// Set it
- $this->setStackerInstance($stackerInstance);
+ $this->setStackInstance($stackInstance);
// Set XML template type and prefix
$this->xmlTemplateType = $xmlTemplateType;
* Assign the found characters to variable and use the last entry from
* stack as the name
*/
- parent::assignVariable($this->getStackerInstance()->getNamed('node_self_connect'), $characters);
+ parent::assignVariable($this->getStackInstance()->getNamed('node_self_connect'), $characters);
}
/**
*/
protected function startSelfConnect () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('node_self_connect', 'self-connect');
+ $this->getStackInstance()->pushNamed('node_self_connect', 'self-connect');
}
/**
*/
protected function startSelfConnectData () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('node_self_connect', 'self-connect-data');
+ $this->getStackInstance()->pushNamed('node_self_connect', 'self-connect-data');
}
/**
*/
protected function startNodeId () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('node_self_connect', self::SELF_CONNECT_DATA_NODE_ID);
+ $this->getStackInstance()->pushNamed('node_self_connect', self::SELF_CONNECT_DATA_NODE_ID);
}
/**
*/
protected function startSessionId () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('node_self_connect', self::SELF_CONNECT_DATA_SESSION_ID);
+ $this->getStackInstance()->pushNamed('node_self_connect', self::SELF_CONNECT_DATA_SESSION_ID);
}
/**
*/
protected function finishSessionId () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('node_self_connect');
+ $this->getStackInstance()->popNamed('node_self_connect');
}
/**
*/
protected function finishNodeId () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('node_self_connect');
+ $this->getStackInstance()->popNamed('node_self_connect');
}
/**
*/
protected function finishSelfConnectData () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('node_self_connect');
+ $this->getStackInstance()->popNamed('node_self_connect');
}
/**
*/
protected function finishSelfConnect () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('node_self_connect');
+ $this->getStackInstance()->popNamed('node_self_connect');
}
}
* Assign the found characters to variable and use the last entry from
* stack as the name.
*/
- parent::assignVariable($this->getStackerInstance()->getNamed('dht_bootstrap'), $characters);
+ parent::assignVariable($this->getStackInstance()->getNamed('dht_bootstrap'), $characters);
}
/**
*/
protected function startDhtBootstrap () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('dht_bootstrap', 'dht-bootstrap');
+ $this->getStackInstance()->pushNamed('dht_bootstrap', 'dht-bootstrap');
}
/**
*/
protected function startDhtBootstrapData () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('dht_bootstrap', self::DHT_BOOTSTRAP_DATA_BOOTSTRAP_DATA);
+ $this->getStackInstance()->pushNamed('dht_bootstrap', self::DHT_BOOTSTRAP_DATA_BOOTSTRAP_DATA);
}
/**
*/
protected function startNodeStatus () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('dht_bootstrap', self::DHT_BOOTSTRAP_DATA_NODE_STATUS);
+ $this->getStackInstance()->pushNamed('dht_bootstrap', self::DHT_BOOTSTRAP_DATA_NODE_STATUS);
}
/**
*/
protected function startNodeMode () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('dht_bootstrap', self::DHT_BOOTSTRAP_DATA_NODE_MODE);
+ $this->getStackInstance()->pushNamed('dht_bootstrap', self::DHT_BOOTSTRAP_DATA_NODE_MODE);
}
/**
*/
protected function startListener () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('dht_bootstrap', 'listener');
+ $this->getStackInstance()->pushNamed('dht_bootstrap', 'listener');
}
/**
*/
protected function startListenPort () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('dht_bootstrap', self::DHT_BOOTSTRAP_DATA_LISTEN_PORT);
+ $this->getStackInstance()->pushNamed('dht_bootstrap', self::DHT_BOOTSTRAP_DATA_LISTEN_PORT);
}
/**
*/
protected function startExternalIp () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('dht_bootstrap', self::DHT_BOOTSTRAP_DATA_EXTERNAL_IP);
+ $this->getStackInstance()->pushNamed('dht_bootstrap', self::DHT_BOOTSTRAP_DATA_EXTERNAL_IP);
}
/**
*/
protected function startInternalIp () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('dht_bootstrap', self::DHT_BOOTSTRAP_DATA_INTERNAL_IP);
+ $this->getStackInstance()->pushNamed('dht_bootstrap', self::DHT_BOOTSTRAP_DATA_INTERNAL_IP);
}
/**
*/
protected function startSessionId () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('dht_bootstrap', self::DHT_BOOTSTRAP_DATA_SESSION_ID);
+ $this->getStackInstance()->pushNamed('dht_bootstrap', self::DHT_BOOTSTRAP_DATA_SESSION_ID);
}
/**
*/
protected function finishSessionId () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('dht_bootstrap');
+ $this->getStackInstance()->popNamed('dht_bootstrap');
}
/**
*/
protected function finishInternalIp () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('dht_bootstrap');
+ $this->getStackInstance()->popNamed('dht_bootstrap');
}
/**
*/
protected function finishExternalIp () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('dht_bootstrap');
+ $this->getStackInstance()->popNamed('dht_bootstrap');
}
/**
*/
protected function finishListenPort () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('dht_bootstrap');
+ $this->getStackInstance()->popNamed('dht_bootstrap');
}
/**
*/
protected function finishListener () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('dht_bootstrap');
+ $this->getStackInstance()->popNamed('dht_bootstrap');
}
/**
*/
protected function finishNodeMode () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('dht_bootstrap');
+ $this->getStackInstance()->popNamed('dht_bootstrap');
}
/**
*/
protected function finishNodeStatus () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('dht_bootstrap');
+ $this->getStackInstance()->popNamed('dht_bootstrap');
}
/**
*/
protected function finishDhtBootstrapData () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('dht_bootstrap');
+ $this->getStackInstance()->popNamed('dht_bootstrap');
}
/**
*/
protected function finishDhtBootstrap () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('dht_bootstrap');
+ $this->getStackInstance()->popNamed('dht_bootstrap');
}
}
} // END - if
// Assign data with matching variable here
- parent::assignVariable($this->getStackerInstance()->getNamed('node_request_node_list_entry'), $characters);
+ parent::assignVariable($this->getStackInstance()->getNamed('node_request_node_list_entry'), $characters);
}
/**
*/
protected function startRequestNodeListEntry () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('node_request_node_list_entry', 'request-node-list-entry');
+ $this->getStackInstance()->pushNamed('node_request_node_list_entry', 'request-node-list-entry');
}
/**
*/
protected function finishRequestNodeListEntry () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('node_request_node_list_entry');
+ $this->getStackInstance()->popNamed('node_request_node_list_entry');
}
}
} // END - if
// Get current XML node name as an array index
- $nodeName = $this->getStackerInstance()->getNamed('node_object_registry');
+ $nodeName = $this->getStackInstance()->getNamed('node_object_registry');
// Is the node name self::OBJECT_TYPE_DATA_NAME?
if ($nodeName == self::OBJECT_TYPE_DATA_NAME) {
*/
protected function startObjectRegistry () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('node_object_registry', 'object-registry');
+ $this->getStackInstance()->pushNamed('node_object_registry', 'object-registry');
}
/**
*/
protected function startObjectList ($objectCount) {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('node_object_registry', 'object-list');
+ $this->getStackInstance()->pushNamed('node_object_registry', 'object-list');
}
/**
*/
protected function startObjectListEntry () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('node_object_registry', 'object-list-entry');
+ $this->getStackInstance()->pushNamed('node_object_registry', 'object-list-entry');
}
/**
*/
protected function startObjectName () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('node_object_registry', self::OBJECT_TYPE_DATA_NAME);
+ $this->getStackInstance()->pushNamed('node_object_registry', self::OBJECT_TYPE_DATA_NAME);
}
/**
*/
protected function startObjectRecipientLimitation () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('node_object_registry', self::OBJECT_TYPE_DATA_RECIPIENT_LIMITATION);
+ $this->getStackInstance()->pushNamed('node_object_registry', self::OBJECT_TYPE_DATA_RECIPIENT_LIMITATION);
}
/**
*/
protected function startObjectMaxSpread () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('node_object_registry', self::OBJECT_TYPE_DATA_MAX_SPREAD);
+ $this->getStackInstance()->pushNamed('node_object_registry', self::OBJECT_TYPE_DATA_MAX_SPREAD);
}
/**
*/
protected function startObjectProtocol () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('node_object_registry', self::OBJECT_TYPE_DATA_PROTOCOL);
+ $this->getStackInstance()->pushNamed('node_object_registry', self::OBJECT_TYPE_DATA_PROTOCOL);
}
/**
*/
protected function startObjectRecipientType () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('node_object_registry', self::OBJECT_TYPE_DATA_RECIPIENT_TYPE);
+ $this->getStackInstance()->pushNamed('node_object_registry', self::OBJECT_TYPE_DATA_RECIPIENT_TYPE);
}
/**
*/
protected function finishObjectRecipientType () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('node_object_registry');
+ $this->getStackInstance()->popNamed('node_object_registry');
}
/**
*/
protected function finishObjectProtocol () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('node_object_registry');
+ $this->getStackInstance()->popNamed('node_object_registry');
}
/**
*/
protected function finishObjectMaxSpread () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('node_object_registry');
+ $this->getStackInstance()->popNamed('node_object_registry');
}
/**
*/
protected function finishObjectRecipientLimitation () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('node_object_registry');
+ $this->getStackInstance()->popNamed('node_object_registry');
}
/**
*/
protected function finishObjectName () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('node_object_registry');
+ $this->getStackInstance()->popNamed('node_object_registry');
}
/**
*/
protected function finishObjectListEntry () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('node_object_registry');
+ $this->getStackInstance()->popNamed('node_object_registry');
}
/**
*/
protected function finishObjectList () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('node_object_registry');
+ $this->getStackInstance()->popNamed('node_object_registry');
}
/**
*/
protected function finishObjectRegistry () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('node_object_registry');
+ $this->getStackInstance()->popNamed('node_object_registry');
}
}
// Assign the found characters to variable and use the last entry from
// stack as the name
- parent::assignVariable($this->getStackerInstance()->getNamed('cruncher_test_unit'), $characters);
+ parent::assignVariable($this->getStackInstance()->getNamed('cruncher_test_unit'), $characters);
}
/**
*/
protected function startTestUnit () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('cruncher_test_unit', 'cruncher-test-unit');
+ $this->getStackInstance()->pushNamed('cruncher_test_unit', 'cruncher-test-unit');
}
/**
*/
protected function startMetaData () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('cruncher_test_unit', 'meta-data');
+ $this->getStackInstance()->pushNamed('cruncher_test_unit', 'meta-data');
}
/**
*/
protected function startGlobalProjectIdentifier () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('cruncher_test_unit', 'global-project-identifier');
+ $this->getStackInstance()->pushNamed('cruncher_test_unit', 'global-project-identifier');
}
/**
*/
protected function finishGlobalProjectIdentifier () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('cruncher_test_unit');
+ $this->getStackInstance()->popNamed('cruncher_test_unit');
}
/**
*/
protected function startTestUnitCreated () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('cruncher_test_unit', 'test-unit-created');
+ $this->getStackInstance()->pushNamed('cruncher_test_unit', 'test-unit-created');
}
/**
*/
protected function finishTestUnitCreated () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('cruncher_test_unit');
+ $this->getStackInstance()->popNamed('cruncher_test_unit');
}
/**
*/
protected function startCipher () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('cruncher_test_unit', 'cipher');
+ $this->getStackInstance()->pushNamed('cruncher_test_unit', 'cipher');
}
/**
*/
protected function startCipherFunction () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('cruncher_test_unit', 'cipher-function');
+ $this->getStackInstance()->pushNamed('cruncher_test_unit', 'cipher-function');
}
/**
*/
protected function finishCipherFunction () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('cruncher_test_unit');
+ $this->getStackInstance()->popNamed('cruncher_test_unit');
}
/**
*/
protected function startCipherName () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('cruncher_test_unit', 'cipher-name');
+ $this->getStackInstance()->pushNamed('cruncher_test_unit', 'cipher-name');
}
/**
*/
protected function finishCipherName () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('cruncher_test_unit');
+ $this->getStackInstance()->popNamed('cruncher_test_unit');
}
/**
*/
protected function finishCipher () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('cruncher_test_unit');
+ $this->getStackInstance()->popNamed('cruncher_test_unit');
}
/**
*/
protected function finishMetaData () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('cruncher_test_unit');
+ $this->getStackInstance()->popNamed('cruncher_test_unit');
}
/**
*/
protected function startUnprocessedData () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('cruncher_test_unit', 'unprocessed-data');
+ $this->getStackInstance()->pushNamed('cruncher_test_unit', 'unprocessed-data');
}
/**
*/
protected function startEncryptedMessage () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('cruncher_test_unit', 'encrypted-message');
+ $this->getStackInstance()->pushNamed('cruncher_test_unit', 'encrypted-message');
}
/**
*/
protected function finishEncryptedMessage () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('cruncher_test_unit');
+ $this->getStackInstance()->popNamed('cruncher_test_unit');
}
/**
*/
protected function startCruncherKeyList ($keyCount) {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('cruncher_test_unit', 'cruncher-key-list');
+ $this->getStackInstance()->pushNamed('cruncher_test_unit', 'cruncher-key-list');
}
/**
*/
protected function startCruncherKey () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('cruncher_test_unit', 'cruncher-key');
+ $this->getStackInstance()->pushNamed('cruncher_test_unit', 'cruncher-key');
}
/**
*/
protected function startKeyId () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('cruncher_test_unit', 'key-id');
+ $this->getStackInstance()->pushNamed('cruncher_test_unit', 'key-id');
}
/**
*/
protected function finishKeyId () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('cruncher_test_unit');
+ $this->getStackInstance()->popNamed('cruncher_test_unit');
}
/**
*/
protected function startKeyValue () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('cruncher_test_unit', 'key-value');
+ $this->getStackInstance()->pushNamed('cruncher_test_unit', 'key-value');
}
/**
*/
protected function finishKeyValue () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('cruncher_test_unit');
+ $this->getStackInstance()->popNamed('cruncher_test_unit');
}
/**
*/
protected function finishCruncherKey () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('cruncher_test_unit');
+ $this->getStackInstance()->popNamed('cruncher_test_unit');
}
/**
*/
protected function finishCruncherKeyList () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('cruncher_test_unit');
+ $this->getStackInstance()->popNamed('cruncher_test_unit');
}
/**
*/
protected function finishUnprocessedData () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('cruncher_test_unit');
+ $this->getStackInstance()->popNamed('cruncher_test_unit');
}
/**
*/
protected function finishTestUnit () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('cruncher_test_unit');
+ $this->getStackInstance()->popNamed('cruncher_test_unit');
}
}
* Assign the found characters to variable and use the last entry from
* stack as the name.
*/
- parent::assignVariable($this->getStackerInstance()->getNamed('dht_publish'), $characters);
+ parent::assignVariable($this->getStackInstance()->getNamed('dht_publish'), $characters);
}
/**
*/
protected function startPublish () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('dht_publish', 'publish');
+ $this->getStackInstance()->pushNamed('dht_publish', 'publish');
}
/**
*/
protected function startPublishData () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('dht_publish', 'publish-data');
+ $this->getStackInstance()->pushNamed('dht_publish', 'publish-data');
}
/**
*/
protected function startNodeStatus () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('dht_publish', self::PUBLISH_DATA_NODE_STATUS);
+ $this->getStackInstance()->pushNamed('dht_publish', self::PUBLISH_DATA_NODE_STATUS);
}
/**
*/
protected function startNodeMode () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('dht_publish', self::PUBLISH_DATA_NODE_MODE);
+ $this->getStackInstance()->pushNamed('dht_publish', self::PUBLISH_DATA_NODE_MODE);
}
/**
*/
protected function startListener () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('dht_publish', 'listener');
+ $this->getStackInstance()->pushNamed('dht_publish', 'listener');
}
/**
*/
protected function startListenPort () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('dht_publish', self::PUBLISH_DATA_LISTEN_PORT);
+ $this->getStackInstance()->pushNamed('dht_publish', self::PUBLISH_DATA_LISTEN_PORT);
}
/**
*/
protected function startAcceptedObjectTypes () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('dht_publish', self::PUBLISH_DATA_ACCEPTED_OBJECT_TYPES);
+ $this->getStackInstance()->pushNamed('dht_publish', self::PUBLISH_DATA_ACCEPTED_OBJECT_TYPES);
}
/**
*/
protected function startPrivateKeyHash () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('dht_publish', self::PUBLISH_DATA_PRIVATE_KEY_HASH);
+ $this->getStackInstance()->pushNamed('dht_publish', self::PUBLISH_DATA_PRIVATE_KEY_HASH);
}
/**
*/
protected function startNodeId () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('dht_publish', self::PUBLISH_DATA_NODE_ID);
+ $this->getStackInstance()->pushNamed('dht_publish', self::PUBLISH_DATA_NODE_ID);
}
/**
*/
protected function startSessionId () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('dht_publish', self::PUBLISH_DATA_SESSION_ID);
+ $this->getStackInstance()->pushNamed('dht_publish', self::PUBLISH_DATA_SESSION_ID);
}
/**
*/
protected function startExternalIp () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('dht_publish', self::PUBLISH_DATA_EXTERNAL_IP);
+ $this->getStackInstance()->pushNamed('dht_publish', self::PUBLISH_DATA_EXTERNAL_IP);
}
/**
*/
protected function startObjectTypeList () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('dht_publish', 'object-type-list');
+ $this->getStackInstance()->pushNamed('dht_publish', 'object-type-list');
}
/**
*/
protected function startObjectType () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('dht_publish', 'object-type');
+ $this->getStackInstance()->pushNamed('dht_publish', 'object-type');
}
/**
*/
protected function finishObjectType () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('dht_publish');
+ $this->getStackInstance()->popNamed('dht_publish');
}
/**
*/
protected function finishObjectTypeList () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('dht_publish');
+ $this->getStackInstance()->popNamed('dht_publish');
}
/**
*/
protected function finishSessionId () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('dht_publish');
+ $this->getStackInstance()->popNamed('dht_publish');
}
/**
*/
protected function finishNodeId () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('dht_publish');
+ $this->getStackInstance()->popNamed('dht_publish');
}
/**
*/
protected function finishExternalIp () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('dht_publish');
+ $this->getStackInstance()->popNamed('dht_publish');
}
/**
*/
protected function finishListenPort () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('dht_publish');
+ $this->getStackInstance()->popNamed('dht_publish');
}
/**
*/
protected function finishPrivateKeyHash () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('dht_publish');
+ $this->getStackInstance()->popNamed('dht_publish');
}
/**
*/
protected function finishAcceptedObjectTypes () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('dht_publish');
+ $this->getStackInstance()->popNamed('dht_publish');
}
/**
*/
protected function finishListener () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('dht_publish');
+ $this->getStackInstance()->popNamed('dht_publish');
}
/**
*/
protected function finishNodeMode () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('dht_publish');
+ $this->getStackInstance()->popNamed('dht_publish');
}
/**
*/
protected function finishNodeStatus () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('dht_publish');
+ $this->getStackInstance()->popNamed('dht_publish');
}
/**
*/
protected function finishPublishData () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('dht_publish');
+ $this->getStackInstance()->popNamed('dht_publish');
}
/**
*/
protected function finishPublish () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('dht_publish');
+ $this->getStackInstance()->popNamed('dht_publish');
}
}
} // END - if
// Assign data with matching variable here
- parent::assignVariable($this->getStackerInstance()->getNamed('node_request_node_list'), $characters);
+ parent::assignVariable($this->getStackInstance()->getNamed('node_request_node_list'), $characters);
}
/**
*/
protected function startRequestNodeList () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('node_request_node_list', 'node-request-node-list');
+ $this->getStackInstance()->pushNamed('node_request_node_list', 'node-request-node-list');
}
/**
*/
protected function startAcceptedObjectTypes () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('node_request_node_list', self::REQUEST_DATA_ACCEPTED_OBJECT_TYPES);
+ $this->getStackInstance()->pushNamed('node_request_node_list', self::REQUEST_DATA_ACCEPTED_OBJECT_TYPES);
}
/**
*/
protected function startSessionId () {
// Push the node name on the stacker
- $this->getStackerInstance()->pushNamed('node_request_node_list', self::REQUEST_DATA_SESSION_ID);
+ $this->getStackInstance()->pushNamed('node_request_node_list', self::REQUEST_DATA_SESSION_ID);
}
/**
*/
protected function finishSessionId () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('node_request_node_list');
+ $this->getStackInstance()->popNamed('node_request_node_list');
}
/**
*/
protected function finishAcceptedObjectTypes () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('node_request_node_list');
+ $this->getStackInstance()->popNamed('node_request_node_list');
}
/**
*/
protected function finishRequestNodeList () {
// Pop the last entry
- $this->getStackerInstance()->popNamed('node_request_node_list');
+ $this->getStackInstance()->popNamed('node_request_node_list');
}
}
-Subproject commit 695f33514481689f765e61ee0653522c55c394d8
+Subproject commit 4b3bc49a694dcfe6ba3e0e5ee5e495a9c14d1a20
projects / hub.git / commitdiff