X-Git-Url: http://git.pjr.cc/?p=CBFWR.git;a=blobdiff_plain;f=libcbfwr%2Fcomms.php;h=db0215e7d6999220cfb16c41412a0573c3285232;hp=b1195c959def395cc0aaf7e0e7336d3482ce113e;hb=90e37664d8296ebb5f3aae443b44b09f95826e90;hpb=a52a53bbe7ad884562d7fb39c87442a38e331dd2 diff --git a/libcbfwr/comms.php b/libcbfwr/comms.php index b1195c9..db0215e 100644 --- a/libcbfwr/comms.php +++ b/libcbfwr/comms.php @@ -37,11 +37,18 @@ class Comms { function waitForMessage() { + global $MESSAGE_KEY, $LOCKING_KEY, $STORE_KEY; + $queue = msg_get_queue($MESSAGE_KEY); + msg_receive($queue, 0, $msgtype, 1024, $msg); + return $msg; } - function sendMessage() + function sendMessage($msg) { + global $MESSAGE_KEY, $LOCKING_KEY, $STORE_KEY; + $queue = msg_get_queue($MESSAGE_KEY); + msg_send($queue, 1, $msg); }