fic/server
Archived
1
0
Fork 0
Code Issues Pull requests 10 Releases Wiki Activity

Rework pipe function

Browse source
This commit is contained in:
Némunaire 2015-01-18 06:50:18 +01:00 • committed by Nemunaire
parent 471b80c572
commit 8b3d771fd1
1 changed files with 5 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

11
onyx/include/functions.php
View file

@ -15,14 +15,13 @@ function pipe_backend_scheduler($instruct)
$socket = socket_create(AF_UNIX, SOCK_STREAM, 0); $socket = socket_create(AF_UNIX, SOCK_STREAM, 0);
if (is_writable($VAR["scheduler_socket"]) && socket_connect($socket, $VAR["scheduler_socket"])) if (is_writable($VAR["scheduler_socket"]) && socket_connect($socket, $VAR["scheduler_socket"]))
{ {
socket_write($socket, $instruct."\r\n") or die(socket_strerror(socket_last_error())); socket_write($socket, $instruct."\n") or die(socket_strerror(socket_last_error()));
sleep(1); usleep(300000);
$ret = socket_read($socket, 32768);
socket_shutdown($socket); socket_shutdown($socket);
socket_close($socket); socket_close($socket);
return $ret;
} }
else if(defined("DEBUG") && DEBUG) else if(defined("DEBUG") && DEBUG)
{ throw new Exception("Socket '".$VAR["scheduler_socket"]."' is not writable by ".$_SERVER["USER"]." user!");
print("Socket '".$VAR["scheduler_socket"]."' is not writable by ".$_SERVER["USER"]." user!");
exit(1);
}
} }