src/Comodojo/Extender/Socket/QueueCommands.php 1 location
|
@@ 37-46 (lines=10) @@
|
| 34 |
|
|
| 35 |
|
} |
| 36 |
|
|
| 37 |
|
public function queueInfo(Process $daemon, $data = null) { |
| 38 |
|
|
| 39 |
|
$configuration = $daemon->getConfiguration(); |
| 40 |
|
$base_path = $configuration->get('base-path'); |
| 41 |
|
$lock_path = $configuration->get('run-path'); |
| 42 |
|
$lock_file = "$base_path/$lock_path/queue.worker.lock"; |
| 43 |
|
|
| 44 |
|
return unserialize(file_get_contents($lock_file)); |
| 45 |
|
|
| 46 |
|
} |
| 47 |
|
|
| 48 |
|
protected static function getManager(Process $daemon) { |
| 49 |
|
|
src/Comodojo/Extender/Socket/ScheduleCommands.php 1 location
|
@@ 123-132 (lines=10) @@
|
| 120 |
|
|
| 121 |
|
} |
| 122 |
|
|
| 123 |
|
public function schedulerInfo(Process $daemon, $data = null) { |
| 124 |
|
|
| 125 |
|
$configuration = $daemon->getConfiguration(); |
| 126 |
|
$base_path = $configuration->get('base-path'); |
| 127 |
|
$lock_path = $configuration->get('run-path'); |
| 128 |
|
$lock_file = "$base_path/$lock_path/schedule.worker.lock"; |
| 129 |
|
|
| 130 |
|
return unserialize(file_get_contents($lock_file)); |
| 131 |
|
|
| 132 |
|
} |
| 133 |
|
|
| 134 |
|
protected static function getManager(Process $daemon) { |
| 135 |
|
|