X-Git-Url: https://git.mxchange.org/?p=core.git;a=blobdiff_plain;f=inc%2Fclasses%2Fmain%2Fclass_BaseFrameworkSystem.php;h=214f2a9f68be77cbdb664148c6109567daa9f68e;hp=d7fc5dd7c1bc739e0de3d5acec6a29905ae950ee;hb=f40bcdcb63cb7aa74f5d75c50a5316810944b8eb;hpb=56f54f7f6f84c157db9a8c5b35193304e752f235

diff --git a/inc/classes/main/class_BaseFrameworkSystem.php b/inc/classes/main/class_BaseFrameworkSystem.php
index d7fc5dd7..214f2a9f 100644
--- a/inc/classes/main/class_BaseFrameworkSystem.php
+++ b/inc/classes/main/class_BaseFrameworkSystem.php
@@ -23,6 +23,41 @@
  * along with this program. If not, see <http://www.gnu.org/licenses/>.
  */
 class BaseFrameworkSystem extends stdClass implements FrameworkInterface {
+	/**
+	 * Separator for header data
+	 */
+	const SEPARATOR_HEADER_DATA = 0x01;
+
+	/**
+	 * Separator header->entries
+	 */
+	const SEPARATOR_HEADER_ENTRIES = 0x02;
+
+	/**
+	 * Separator hash->name
+	 */
+	const SEPARATOR_HASH_NAME = 0x03;
+
+	/**
+	 * Separator entry->entry
+	 */
+	const SEPARATOR_ENTRIES = 0x04;
+
+	/**
+	 * Length of count
+	 */
+	const LENGTH_COUNT = 20;
+
+	/**
+	 * Length of position
+	 */
+	const LENGTH_POSITION = 20;
+
+	/**
+	 * Length of name
+	 */
+	const LENGTH_NAME = 10;
+
 	/**
 	 * The real class name
 	 */
@@ -179,10 +214,15 @@ class BaseFrameworkSystem extends stdClass implements FrameworkInterface {
 	private $pointerInstance = NULL;
 
 	/**
-	 * An instance of an index
+	 * An instance of an Indexable class
 	 */
 	private $indexInstance = NULL;
 
+	/**
+	 * An instance of a CalculatableBlock class
+	 */
+	private $blockInstance = NULL;
+
 	/**
 	 * Thousands separator
 	 */
@@ -213,6 +253,36 @@ class BaseFrameworkSystem extends stdClass implements FrameworkInterface {
 	 */
 	private static $hashLength = NULL;
 
+	/**
+	 * Counter for total entries
+	 */
+	private $totalEntries = 0;
+
+	/**
+	 * Current seek position
+	 */
+	private $seekPosition = 0;
+
+	/**
+	 * Size of header
+	 */
+	private $headerSize = 0;
+
+	/**
+	 * File header
+	 */
+	private $header = array();
+
+	/**
+	 * Seek positions for gaps ("fragmentation")
+	 */
+	private $gaps = array();
+
+	/**
+	 * Seek positions for damaged entries (e.g. mismatching hash sum, ...)
+	 */
+	private $damagedEntries = array();
+
 	/***********************
 	 * Exception codes.... *
 	 ***********************/
@@ -472,7 +542,7 @@ class BaseFrameworkSystem extends stdClass implements FrameworkInterface {
 		$this->debugBackTrace(sprintf('Tried to set a missing field. name=%s, value[%s]=%s',
 			$name,
 			gettype($value),
-			$value
+			print_r($value, TRUE)
 		));
 	}
 
@@ -1271,6 +1341,25 @@ class BaseFrameworkSystem extends stdClass implements FrameworkInterface {
 		return $this->indexInstance;
 	}
 
+	/**
+	 * Setter for CalculatableBlock instance
+	 *
+	 * @param	$blockInstance	An instance of an CalculatableBlock class
+	 * @return	void
+	 */
+	protected final function setBlockInstance (CalculatableBlock $blockInstance) {
+		$this->blockInstance = $blockInstance;
+	}
+
+	/**
+	 * Getter for CalculatableBlock instance
+	 *
+	 * @return	$blockInstance	An instance of an CalculatableBlock class
+	 */
+	public final function getBlockInstance () {
+		return $this->blockInstance;
+	}
+
 	/**
 	 * Checks whether an object equals this object. You should overwrite this
 	 * method to implement own equality checks
@@ -2802,6 +2891,354 @@ class BaseFrameworkSystem extends stdClass implements FrameworkInterface {
 		// ... and return it
 		return $translated;
 	}
+
+	/**
+	 * Initializes counter for valid entries, arrays for damaged entries and
+	 * an array for gap seek positions. If you call this method on your own,
+	 * please re-analyze the file structure. So you are better to call
+	 * analyzeFile() instead of this method.
+	 *
+	 * @return	void
+	 */
+	protected function initCountersGapsArray () {
+		// Init counter and seek position
+		$this->setCounter(0);
+		$this->setSeekPosition(0);
+
+		// Init arrays
+		$this->gaps = array();
+		$this->damagedEntries = array();
+	}
+
+	/**
+	 * Getter for total entries
+	 *
+	 * @return	$totalEntries	Total entries in this file
+	 */
+	protected final function getCounter () {
+		// Get it
+		return $this->totalEntries;
+	}
+
+	/**
+	 * Setter for total entries
+	 *
+	 * @param	$totalEntries	Total entries in this file
+	 * @return	void
+	 */
+	protected final function setCounter ($counter) {
+		// Set it
+		$this->totalEntries = $counter;
+	}
+
+	/**
+	 * Increment counter
+	 *
+	 * @return	void
+	 */
+	protected final function incrementCounter () {
+		// Get it
+		$this->totalEntries++;
+	}
+
+	/**
+	 * Getter for header size
+	 *
+	 * @return	$totalEntries	Size of file header
+	 */
+	public final function getHeaderSize () {
+		// Get it
+		return $this->headerSize;
+	}
+
+	/**
+	 * Setter for header size
+	 *
+	 * @param	$headerSize		Size of file header
+	 * @return	void
+	 */
+	protected final function setHeaderSize ($headerSize) {
+		// Set it
+		$this->headerSize = $headerSize;
+	}
+
+	/**
+	 * Getter for header array
+	 *
+	 * @return	$totalEntries	Size of file header
+	 */
+	protected final function getHeade () {
+		// Get it
+		return $this->header;
+	}
+
+	/**
+	 * Setter for header
+	 *
+	 * @param	$header		Array for a file header
+	 * @return	void
+	 */
+	protected final function setHeader (array $header) {
+		// Set it
+		$this->header = $header;
+	}
+
+	/**
+	 * Getter for seek position
+	 *
+	 * @return	$seekPosition	Current seek position (stored here in object)
+	 */
+	protected final function getSeekPosition () {
+		// Get it
+		return $this->seekPosition;
+	}
+
+	/**
+	 * Setter for seek position
+	 *
+	 * @param	$seekPosition	Current seek position (stored here in object)
+	 * @return	void
+	 */
+	protected final function setSeekPosition ($seekPosition) {
+		// And set it
+		$this->seekPosition = $seekPosition;
+	}
+
+	/**
+	 * Updates seekPosition attribute from file to avoid to much access on file.
+	 *
+	 * @return	void
+	 */
+	protected function updateSeekPosition () {
+		//* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__)->debugOutput(sprintf('[%s:%d:] CALLED!', __METHOD__, __LINE__));
+
+		// Get key (= seek position)
+		$seekPosition = $this->getIteratorInstance()->key();
+		//* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__)->debugOutput(sprintf('[%s:%d:] Setting seekPosition=%s', __METHOD__, __LINE__, $seekPosition));
+
+		// And set it here
+		$this->setSeekPosition($seekPosition);
+
+		//* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__)->debugOutput(sprintf('[%s:%d:] EXIT!', __METHOD__, __LINE__));
+	}
+
+	/**
+	 * Checks whether the file header is initialized
+	 *
+	 * @return	$isInitialized	Whether the file header is initialized
+	 */
+	protected function isFileHeaderInitialized () {
+		//* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__)->debugOutput(sprintf('[%s:%d:] CALLED!', __METHOD__, __LINE__));
+
+		// Is the method there?
+		assert(is_callable(array($this, 'readFileHeader')));
+
+		// Default is not initialized
+		$isInitialized = FALSE;
+
+		// Is the file initialized?
+		if ($this->isFileInitialized()) {
+			// Some bytes has been written, so rewind to start of it.
+			$rewindStatus = $this->getIteratorInstance()->rewind();
+			//* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__)->debugOutput(sprintf('[%s:%d:] rewindStatus=%s', __METHOD__, __LINE__, $rewindStatus));
+
+			// Is the rewind() call successfull?
+			if ($rewindStatus != 1) {
+				// Something bad happened
+				self::createDebugInstance(__CLASS__)->debugOutput(sprintf('[%s:%d:] Could not rewind().', __METHOD__, __LINE__));
+			} // END - if
+
+			// Read file header
+			$this->readFileHeader();
+
+			// The above method does already check the header
+			$isInitialized = TRUE;
+		} // END - if
+
+		// Return result
+		//* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__)->debugOutput(sprintf('[%s:%d:] isInitialized=%d - EXIT!', __METHOD__, __LINE__, intval($isInitialized)));
+		return $isInitialized;
+	}
+
+	/**
+	 * Checks whether the assigned file has been initialized
+	 *
+	 * @return	$isInitialized		Whether the file's size is zero
+	 */
+	protected function isFileInitialized () {
+		//* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__)->debugOutput(sprintf('[%s:%d:] CALLED!', __METHOD__, __LINE__));
+
+		// size() must be callable
+		assert(is_callable(array($this, 'size')));
+
+		// Get it from iterator which holds the pointer instance. If FALSE is returned
+		$fileSize = $this->size();
+		//* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__)->debugOutput(sprintf('[%s:%d:] fileSize=%s', __METHOD__, __LINE__, $fileSize));
+
+		/*
+		 * The returned file size should not be FALSE or NULL as this means
+		 * that the pointer class does not work correctly.
+		 */
+		assert(is_int($fileSize));
+
+		// Is more than 0 returned?
+		$isInitialized = ($fileSize > 0);
+
+		// Return result
+		//* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__)->debugOutput(sprintf('[%s:%d:] isInitialized=%d - EXIT!', __METHOD__, __LINE__, intval($isInitialized)));
+		return $isInitialized;
+	}
+
+	/**
+	 * Creates the assigned file
+	 *
+	 * @return	void
+	 */
+	protected function createFileHeader () {
+		//* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__)->debugOutput(sprintf('[%s:%d:] CALLED!', __METHOD__, __LINE__));
+
+		// The method flushFileHeader() must be callable
+		assert(is_callable(array($this, 'flushFileHeader')));
+
+		// The file's header should not be initialized here
+		assert(!$this->isFileHeaderInitialized());
+
+		// Simple flush file header which will create it.
+		$this->flushFileHeader();
+
+		// Rewind seek position (to beginning of file) and update/flush file header
+		$this->rewineUpdateSeekPosition();
+
+		//* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__)->debugOutput(sprintf('[%s:%d:] EXIT!!', __METHOD__, __LINE__));
+	}
+
+	/**
+	 * Seeks to beginning of file, updates seek position in this object and
+	 * flushes the header.
+	 *
+	 * @return	void
+	 */
+	protected function rewineUpdateSeekPosition () {
+		//* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__)->debugOutput(sprintf('[%s:%d:] CALLED!', __METHOD__, __LINE__));
+
+		// Seek to beginning of file
+		$this->getIteratorInstance()->rewind();
+
+		// And update seek position ...
+		$this->updateSeekPosition();
+
+		// ... to write it back into the file
+		$this->flushFileHeader();
+
+		//* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__)->debugOutput(sprintf('[%s:%d:] EXIT!!', __METHOD__, __LINE__));
+	}
+
+	/**
+	 * Seeks to old position
+	 *
+	 * @return	void
+	 */
+	protected function seekToOldPosition () {
+		//* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__)->debugOutput(sprintf('[%s:%d:] CALLED!', __METHOD__, __LINE__));
+
+		// Seek to currently ("old") saved position
+		$this->getIteratorInstance()->seek($this->getSeekPosition());
+
+		//* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__)->debugOutput(sprintf('[%s:%d:] EXIT!!', __METHOD__, __LINE__));
+	}
+
+	/**
+	 * Writes data at given position
+	 *
+	 * @param	$seekPosition	Seek position
+	 * @param	$data			Data to be written
+	 * @param	$flushHeader	Whether to flush the header (default: flush)
+	 * @return	void
+	 */
+	protected function writeData ($seekPosition, $data, $flushHeader = TRUE) {
+		//* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__)->debugOutput(sprintf('[%s:%d:] seekPosition=%s,data()=%s - CALLED!', __METHOD__, __LINE__, $seekPosition, strlen($data)));
+
+		// Write data at given position
+		$this->getIteratorInstance()->writeAtPosition($seekPosition, $data);
+
+		// Update seek position
+		$this->updateSeekPosition();
+
+		// Flush the header?
+		if ($flushHeader === TRUE) {
+			// Flush header
+			$this->flushFileHeader();
+
+			// Seek to old position
+			$this->seekToOldPosition();
+		} // END - if
+
+		//* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__)->debugOutput(sprintf('[%s:%d:] EXIT!', __METHOD__, __LINE__));
+	}
+
+	/**
+	 * Pre-allocates file (if enabled) with some space for later faster write access.
+	 *
+	 * @param	$type	Type of the file
+	 * @return	void
+	 */
+	protected function preAllocateFile ($type) {
+		//* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__)->debugOutput(sprintf('[%s:%d:] CALLED!', __METHOD__, __LINE__));
+
+		// caluclateMinimumBlockLength() must be callable
+		assert(is_callable(array($this, 'caluclateMinimumBlockLength')));
+
+		// Is it enabled?
+		if ($this->getConfigInstance()->getConfigEntry($type . '_pre_allocate_enabled') != 'Y') {
+			// Not enabled
+			self::createDebugInstance(__CLASS__)->debugOutput(sprintf('[%s:%d:] Not pre-allocating file.', __METHOD__, __LINE__));
+
+			// Don't continue here.
+			return;
+		} // END - if
+
+		// Message to user
+		self::createDebugInstance(__CLASS__)->debugOutput(sprintf('[%s:%d:] Pre-allocating file ...', __METHOD__, __LINE__));
+
+		// Calculate minimum length for one entry
+		$minLengthEntry = $this->caluclateMinimumBlockLength();
+		//* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__)->debugOutput(sprintf('[%s:%d:] minLengthEntry=%s', __METHOD__, __LINE__, $minLengthEntry));
+
+		// Calulcate seek position
+		$seekPosition = $minLengthEntry * $this->getConfigInstance()->getConfigEntry($type . '_pre_allocate_count');
+		//* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__)->debugOutput(sprintf('[%s:%d:] seekPosition=%s', __METHOD__, __LINE__, $seekPosition));
+
+		// Now simply write a NUL there. This will pre-allocate the file.
+		$this->writeData($seekPosition, chr(0));
+
+		// Rewind seek position (to beginning of file) and update/flush file header
+		$this->rewineUpdateSeekPosition();
+
+		//* NOISY-DEBUG: */ self::createDebugInstance(__CLASS__)->debugOutput(sprintf('[%s:%d:] EXIT!', __METHOD__, __LINE__));
+	}
+
+	/**
+	 * Checks whether the block separator has been found
+	 *
+	 * @param	$str		String to look in
+	 * @return	$isFound	Whether the block separator has been found
+	 */
+	public function isBlockSeparatorFound ($str) {
+		// Determine it
+		$isFound = (strpos($str, self::getBlockSeparator()) !== FALSE);
+
+		// Return result
+		return $isFound;
+	}
+
+	/**
+	 * Getter for block separator character(s)
+	 *
+	 * @return	$blockSeparator		A separator for blocks
+	 */
+	protected static final function getBlockSeparator () {
+		return chr(self::SEPARATOR_ENTRIES);
+	}
 }
 
 // [EOF]