summaryrefslogtreecommitdiff
path: root/buildscripts/phing/classes/phing/contrib/DocBlox/Parallel/WorkerPipe.php
diff options
context:
space:
mode:
Diffstat (limited to 'buildscripts/phing/classes/phing/contrib/DocBlox/Parallel/WorkerPipe.php')
-rw-r--r--buildscripts/phing/classes/phing/contrib/DocBlox/Parallel/WorkerPipe.php127
1 files changed, 0 insertions, 127 deletions
diff --git a/buildscripts/phing/classes/phing/contrib/DocBlox/Parallel/WorkerPipe.php b/buildscripts/phing/classes/phing/contrib/DocBlox/Parallel/WorkerPipe.php
deleted file mode 100644
index 3b7eb7fe..00000000
--- a/buildscripts/phing/classes/phing/contrib/DocBlox/Parallel/WorkerPipe.php
+++ /dev/null
@@ -1,127 +0,0 @@
-<?php
-/**
- * DocBlox
- *
- * PHP Version 5
- *
- * @category DocBlox
- * @package Parallel
- * @author Mike van Riel <mike.vanriel@naenius.com>
- * @copyright 2010-2011 Mike van Riel / Naenius (http://www.naenius.com)
- * @license http://www.opensource.org/licenses/mit-license.php MIT
- * @link http://docblox-project.org
- */
-
-/**
- * Class that represents a named pipe for a Worker.
- *
- * This class manages the named pipe for a worker and is able to push and pull
- * specific data to facilitate IPC (interprocess communication).
- *
- * @category DocBlox
- * @package Parallel
- * @author Mike van Riel <mike.vanriel@naenius.com>
- * @license http://www.opensource.org/licenses/mit-license.php MIT
- * @link http://docblox-project.org
- */
-class DocBlox_Parallel_WorkerPipe
-{
- /** @var DocBlox_Parallel_Worker worker class that is associated */
- protected $worker;
-
- /** @var string Path to the pipe */
- protected $path;
-
- /**
- * Initializes the named pipe.
- *
- * @param DocBlox_Parallel_Worker $worker Associated worker.
- */
- public function __construct(DocBlox_Parallel_Worker $worker)
- {
- $this->worker = $worker;
-
- $this->path = tempnam(sys_get_temp_dir(), 'dpm_');
- posix_mkfifo($this->path, 0750);
- }
-
- /**
- * If the named pipe was not cleaned up, do so now.
- */
- public function __destruct()
- {
- if (file_exists($this->path)) {
- $this->release();
- }
- }
-
- /**
- * Pull the worker data into the named pipe.
- *
- * @return void
- */
- public function pull()
- {
- $this->writePipeContents();
- }
-
- /**
- * Push the worker data back onto the worker and release the pipe.
- *
- * @return void
- */
- public function push()
- {
- list($result, $error, $return_code) = $this->readPipeContents();
- $this->release();
-
- $this->worker->setResult($result);
- $this->worker->setError($error);
- $this->worker->setReturnCode($return_code);
- }
-
- /**
- * Convenience method to show relation to readPipeContents.
- *
- * @return void
- */
- protected function writePipeContents()
- {
- // push the gathered data onto a name pipe
- $pipe = fopen($this->path, 'w');
- fwrite(
- $pipe, serialize(
- array(
- $this->worker->getResult(),
- $this->worker->getError(),
- $this->worker->getReturnCode()
- )
- )
- );
- fclose($pipe);
- }
-
- /**
- * Returns the unserialized contents of the pipe.
- *
- * @return array
- */
- protected function readPipeContents()
- {
- $pipe = fopen($this->path, 'r+');
- $result = unserialize(fread($pipe, filesize($this->path)));
- fclose($pipe);
-
- return $result;
- }
-
- /**
- * Releases the pipe.
- *
- * @return void
- */
- protected function release()
- {
- unlink($this->path);
- }
-} \ No newline at end of file