Skip to content

Commit

Permalink
Docs
Browse files Browse the repository at this point in the history
  • Loading branch information
kakserpom committed Mar 19, 2013
1 parent d930c25 commit 2d15d27
Show file tree
Hide file tree
Showing 2 changed files with 135 additions and 10 deletions.
43 changes: 38 additions & 5 deletions lib/Daemon_IPCThread.php
Original file line number Diff line number Diff line change
Expand Up @@ -9,15 +9,48 @@
*/
// @TODO: respawning IPCThread on unexpected failures
class Daemon_IPCThread extends Thread {
/**
* Event base
* @var EventBase
*/
public $eventBase;
public $timeoutEvent;
public $breakMainLoop = FALSE;
public $reloadReady = FALSE;
public $delayedSigReg = TRUE;

/**
* Break main loop?
* @var boolean
*/
protected $breakMainLoop = false;

/**
* Reload ready?
* @var boolean
*/
protected $reloadReady = false;

/**
* If true, we do not register signals automatically at start
* @var boolean
*/
protected $delayedSigReg = true;

/**
* Instances count
* @var hash
*/
public $instancesCount = [];
public $connection;

/**
* File watcher
* @var FileWatcher
*/
public $fileWatcher;

/**
* If true, we do not register signals automatically at start
* @var boolean
*/
public $reload = false;

/**
* Runtime of Worker process.
* @return void
Expand Down
102 changes: 97 additions & 5 deletions lib/Daemon_WorkerThread.php
Original file line number Diff line number Diff line change
Expand Up @@ -9,30 +9,114 @@
*/
class Daemon_WorkerThread extends Thread {

/**
* Update?
* @var boolean
*/
public $update = false;

/**
* Reload?
* @var boolean
*/
public $reload = false;
public $reloadTime = 0;

/**
* Reload time
* @var integer
*/
protected $reloadTime = 0;

/**
* Reload delay
* @var integer
*/
protected $reloadDelay = 2;

/**
* Reloaded?
* @var boolean
*/
public $reloaded = false;

/**
* Map connnection id to application which created this connection
* @var string
* Time of last activity
* @var integer
*/
public $timeLastActivity = 0;

/**
* Last time of auto reload
* @var integer
*/
protected $autoReloadLast = 0;

/**
* Current status
* @var integer
*/
protected $currentStatus = 0;

/**
* Event base
* @var EventBase
*/
public $eventBase;

/**
* DNS base
* @var EventDnsBase
*/
public $dnsBase;
public $timeoutEvent;

/**
* State
* @var integer
*/
public $state = 0;

/**
* Break main loop?
* @var boolean
*/
public $breakMainLoop = false;

/**
* Reload ready?
* @var boolean
*/
public $reloadReady = false;
public $delayedSigReg = false;

/**
* If true, we do not register signals automatically at start
* @var boolean
*/
protected $delayedSigReg = false;

/**
* Instances count
* @var hash
*/
public $instancesCount = [];

/**
* Connection
* @var Connection
*/
public $connection;

/**
* Counter GC
* @var integer
*/
public $counterGC = 0;

/**
* Stack of callbacks to execute
* @var StackCallbacks
*/
public $callbacks;

/**
* Runtime of Worker process.
* @return void
Expand Down Expand Up @@ -360,6 +444,10 @@ protected function update() {
}
}

/**
* Check if we should break main loop
* @return void
*/
protected function breakMainLoopCheck() {
$time = microtime(true);

Expand Down Expand Up @@ -404,6 +492,10 @@ protected function breakMainLoopCheck() {
}
}

/**
* Start reloading procedure
* @var Connection
*/
protected function initReload() {
$this->reload = true;
$this->reloadTime = microtime(true) + $this->reloadDelay;
Expand Down

0 comments on commit 2d15d27

Please sign in to comment.