changed how configs work

[CBFWR.git] / libcbfwr / comms.php

diff --git a/libcbfwr/comms.php b/libcbfwr/comms.php
index 808d1f8..b0c4f04 100644 (file)
--- a/libcbfwr/comms.php
+++ b/libcbfwr/comms.php
@@ -1,10 +1,75 @@
 <?php
 // C = msg key
 // L = locking key
-$MESSAGE_KEY = ftok(realpath(dirname(__FILE__)), "c");
+$MESSAGE_KEY = ftok(realpath(dirname(__FILE__)), "c"); // to daemon
 $LOCKING_KEY = ftok(realpath(dirname(__FILE__)), "l");
 $STORE_KEY = ftok(realpath(dirname(__FILE__)), "s");
+$CONF_STORE_SIZE = 16777216; // 16M by default
 
-global $MESSAGE_KEY, $LOCKING_KEY, $STORE_KEY;
+global $MESSAGE_KEY, $LOCKING_KEY, $STORE_KEY, $CONF_STORE_SIZE;
+
+class Comms {
+       function __construct()
+       {
+               global $MESSAGE_KEY, $LOCKING_KEY, $STORE_KEY;
+               $this->semres = sem_get($LOCKING_KEY, 0666);
+               $this->msgres = msg_get_queue($MESSAGE_KEY, 0666);
+       }
+       
+       function getConfig($type=0)
+       {
+               global $MESSAGE_KEY, $LOCKING_KEY, $STORE_KEY, $CONF_STORE_SIZE;
+               sem_acquire($this->semres);
+               $shm_space = shm_attach($STORE_KEY, $CONF_STORE_SIZE);
+               $config = shm_get_var($shm_space, $type);
+               sem_release($this->semres);
+               
+               return $config;
+       }
+       
+       function lockConfigs()
+       {
+               sem_acquire($this->semres);
+       }
+       
+       function unlockConfigs()
+       {
+               sem_release($this->semres);
+       }
+       
+       
+       // type = 0 for the fs config
+       // type = 1 for the boot hardware config
+       // type = 2 for running config
+       // type = 3 for web config
+       function putConfig($config, $type=0)
+       {
+               global $MESSAGE_KEY, $LOCKING_KEY, $STORE_KEY, $CONF_STORE_SIZE;
+               sem_acquire($this->semres);
+               $shm_space = shm_attach($STORE_KEY, $CONF_STORE_SIZE);
+               shm_put_var($shm_space, $type, $config);
+               sem_release($this->semres);             
+       }
+       
+       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($msg)
+       {
+               global $MESSAGE_KEY, $LOCKING_KEY, $STORE_KEY;
+               $queue = msg_get_queue($MESSAGE_KEY);
+               msg_send($queue, 1, $msg);
+               
+       }
+       
+       private $semres, $msgres;
+       
+}
 
 ?>
\ No newline at end of file