function sendWaitingPackage ();
/**
- * Clears all stacker
+ * Clears all stacks
*
* @return void
*/
- function clearAllStacker ();
+ function clearAllStacks ();
}
// [EOF]
$this->bufferInstance = ObjectFactory::createObjectByConfiguredName('cruncher_buffer_stacker_class');
// Initialize common stackers, like in/out
- $this->bufferInstance->initStackers(array(
+ $this->bufferInstance->initStacks(array(
self::STACKER_NAME_IN_QUEUE,
self::STACKER_NAME_OUT_QUEUE
));
$decoderInstance = new PackageDecoder();
// Init stacker for received packages
- $stackerInstance->initStacker(self::STACKER_NAME_DECODED_PACKAGE);
+ $stackerInstance->initStack(self::STACKER_NAME_DECODED_PACKAGE);
// Set the stacker instance here
$decoderInstance->setStackerInstance($stackerInstance);
$this->setStackerInstance($stackerInstance);
// Init all stackers
- $this->initStackers();
+ $this->initStacks();
/*
* Get the state factory and create the initial state, we don't need
*
* @return void
*/
- private function initStackers () {
+ private function initStacks () {
// Initialize all stacker
- $this->getStackerInstance()->initStackers(array(
+ $this->getStackerInstance()->initStacks(array(
self::STACKER_NAME_INSERT_NODE,
));
}
$stackerInstance = ObjectFactory::createObjectByConfiguredName('chunk_handler_stacker_class');
// Init all stacker
- $stackerInstance->initStackers(array(
+ $stackerInstance->initStacks(array(
self::STACKER_NAME_CHUNKS_WITH_FINAL_EOP,
self::STACKER_NAME_CHUNKS_WITHOUT_FINAL,
self::STACKER_NAME_ASSEMBLED_RAW_DATA
$this->setStackerInstance($stackerInstance);
// Init stacker
- $this->initStacker();
+ $this->initStack();
}
/**
*
* @return void
*/
- protected function initStacker () {
- $this->getStackerInstance()->initStacker(self::STACKER_NAME_RAW_DATA);
+ protected function initStack () {
+ $this->getStackerInstance()->initStack(self::STACKER_NAME_RAW_DATA);
}
/**
$packageInstance->setStackerInstance($stackerInstance);
// Init all stacker
- $packageInstance->initStackers();
+ $packageInstance->initStacks();
// Get a visitor instance for speeding up things and set it
$visitorInstance = ObjectFactory::createObjectByConfiguredName('node_raw_data_monitor_visitor_class', array($packageInstance));
* @param $forceReInit Whether to force reinitialization of all stacks
* @return void
*/
- protected function initStackers ($forceReInit = FALSE) {
+ protected function initStacks ($forceReInit = FALSE) {
// Initialize all
- $this->getStackerInstance()->initStackers(array(
+ $this->getStackerInstance()->initStacks(array(
self::STACKER_NAME_UNDECLARED,
self::STACKER_NAME_DECLARED,
self::STACKER_NAME_OUTGOING,
self::STACKER_NAME_NEW_MESSAGE,
self::STACKER_NAME_PROCESSED_MESSAGE,
self::STACKER_NAME_BACK_BUFFER
- ));
+ ), $forceReInit);
}
/**
}
/**
- * Clears all stacker
+ * Clears all stacks
*
* @return void
*/
- public function clearAllStacker () {
+ public function clearAllStacks () {
// Call the init method to force re-initialization
- $this->initStackers(TRUE);
+ $this->initStacks(TRUE);
// Debug message
//* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__)->debugOutput('NETWORK-PACKAGE[' . __LINE__ . ']: All stacker have been re-initialized.');
* @return void
*/
protected function initOutgoingQueue () {
- $this->getOutgoingQueueInstance()->initStacker(self::STACKER_NAME_OUT_QUEUE, TRUE);
+ $this->getOutgoingQueueInstance()->initStack(self::STACKER_NAME_OUT_QUEUE, TRUE);
}
/**
* @return void
*/
protected function initIncomingQueue () {
- $this->getIncomingQueueInstance()->initStacker(self::STACKER_NAME_IN_QUEUE, TRUE);
+ $this->getIncomingQueueInstance()->initStack(self::STACKER_NAME_IN_QUEUE, TRUE);
}
/**
$this->stackerName = $typePrefix . '_' . $xmlTemplateType;
// Init stacker
- $stackerInstance->initStacker($this->stackerName);
+ $stackerInstance->initStack($this->stackerName);
// Set it
$this->setStackerInstance($stackerInstance);
*/
public function visitNetworkPackage (Deliverable $packageInstance) {
// Just call it back
- $packageInstance->clearAllStacker();
+ $packageInstance->clearAllStacks();
}
}