Skip to content

Commit f7f7459

Browse files
committed
Fixes.
1 parent f69cac3 commit f7f7459

File tree

2 files changed

+6
-6
lines changed

2 files changed

+6
-6
lines changed

src/Controller/Admin/QueueProcessesController.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -112,7 +112,7 @@ public function delete(?int $id = null, ?int $sig = null) {
112112
$queueProcess = $this->QueueProcesses->get($id);
113113

114114
if (!Configure::read('Queue.multiserver')) {
115-
$this->QueueProcesses->terminateProcess($queueProcess->pid, $sig ?: SIGTERM);
115+
$this->QueueProcesses->terminateProcess($queueProcess->pid, $sig ?: \SIGTERM);
116116
}
117117

118118
if ($this->QueueProcesses->delete($queueProcess)) {

src/Queue/Processor.php

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -123,16 +123,16 @@ public function run(array $args): int {
123123
gc_enable();
124124
}
125125
if (function_exists('pcntl_signal')) {
126-
pcntl_signal(SIGTERM, [&$this, 'exit']);
127-
pcntl_signal(SIGINT, [&$this, 'abort']);
128-
pcntl_signal(SIGTSTP, [&$this, 'abort']);
129-
pcntl_signal(SIGQUIT, [&$this, 'abort']);
126+
pcntl_signal(\SIGTERM, [&$this, 'exit']);
127+
pcntl_signal(\SIGINT, [&$this, 'abort']);
128+
pcntl_signal(\SIGTSTP, [&$this, 'abort']);
129+
pcntl_signal(\SIGQUIT, [&$this, 'abort']);
130130
if (Configure::read('Queue.canInterruptSleep')) {
131131
// Defining a signal handler here will make the worker wake up
132132
// from its sleep() when SIGUSR1 is received. Since waking it
133133
// up is all we need, there is no further code to execute,
134134
// hence the empty function.
135-
pcntl_signal(SIGUSR1, function (): void {
135+
pcntl_signal(\SIGUSR1, function (): void {
136136
});
137137
}
138138
}

0 commit comments

Comments
 (0)