Changeset 17

Timestamp:

10/06/08 16:24:06 (6 weeks ago)

Author:

richard

Message:

Basic socket server

Location:

flashunity

Files:

• libraries/Flashunity/Base.php (modified) (1 diff)
• libraries/Flashunity/Cli/Daemon.php (modified) (4 diffs)
• libraries/Flashunity/Cli/Daemon/Info/options.php (modified) (1 diff)
• libraries/Flashunity/Cli/Help.php (modified) (1 diff)
• libraries/Flashunity/Comm/Socket.php (modified) (4 diffs)
• libraries/Flashunity/Transport/Xml.php (modified) (2 diffs)
• script/flashunity.php (modified) (1 diff)

flashunity/libraries/Flashunity/Base.php

@@ -1 +1 @@
 <?php
+/**
+ *
+ * Extention to the Solar Cli library
+ *
+ * @category Main
+ * @package Flashunity
+ * @author Richard Thomas <richard@phpjack.com>
+ * @version $Id$
+ * @copyright Copyright (c) 2008, Richard Thomas.  All rights reserved.
+ * @license http://www.phpjack.com
+ * @link http://www.phpjack.com
+ */
+
 class Flashunity_Base extends Solar_Cli_Base {
     protected $_Flashunity_Base = array(

flashunity/libraries/Flashunity/Cli/Daemon.php

@@ -1 +1 @@
 <?php
+/**
+ *
+ * Main daemon used to run the server
+ *
+ * @category Main      
+ * @package Flashunity
+ * @author Richard Thomas <richard@phpjack.com>
+ * @version $Id$
+ * @copyright Copyright (c) 2008, Richard Thomas.  All rights reserved.      
+ * @license http://www.phpjack.com
+ * @link http://www.phpjack.com
+ */
 
 
 class Flashunity_Cli_Daemon extends Flashunity_Base {
     private $_tbalance_time = null;
-
     public function __construct($config = null) {
       parent::__construct($config);
@@ -16 +27 @@
         $config['transport'] = 'tcp';        
         $config['port'] = '9997';
-        $config['address'] = 'localhost';
+        $config['address'] = '10.0.1.203';
         $config['buffer'] = 1024;
         $this->_tbalance_time = microtime(1);
@@ -24 +35 @@
             $this->server->build_pool();
             $this->server->check_pool();
-            $this->server->check_new_conn();
-            $this->server->check_new_data();
+            if($new = $this->server->check_new_conn()) {
+                foreach($new as $value) {
+                    // $value = key we can use to reference for writes and such
+                    // We should record this and reference it
+                }
+            }
+            $data = $this->server->check_new_data();
+            foreach($data as $key => $value) {
+                $test = array();
+                $test[1] = 'Testing';
+                $test[2] = 'Whats up';
+                $test[3][1] = 'Go Go';
+                $test[3][2] = 'On On';
+                $this->server->write_all(json_encode($test));
+                echo "Writing\n";
+            }
             $this->_tbalance();
         }
@@ -37 +62 @@
             usleep($this->_config['Performance']['Min_Time'] - $dtime);
         } else {
-            $this->log('Flashunity_Deamon',Flashunity_Base::NORMAL,'Ran past min performance time');
+            $this->log('Flashunity_Deamon',Flashunity_Base::NORMAL,'Ran past min performance time by '.$dtime.' microseconds');
         }
+        $this->_tbalance_time = microtime(1);
     }
 

flashunity/libraries/Flashunity/Cli/Daemon/Info/options.php

@@ -1 +1 @@
 <?php
+
 return array(
 );

flashunity/libraries/Flashunity/Cli/Help.php

@@ -1 +1 @@
 <?php
+/**
+ *
+ * Simple Help Files
+ *
+ * @category Main      
+ * @package Flashunity
+ * @author Richard Thomas <richard@phpjack.com>
+ * @version $Id$
+ * @copyright Copyright (c) 2008, Richard Thomas.  All rights reserved.      
+ * @license http://www.phpjack.com
+ * @link http://www.phpjack.com
+ */
 
 class Flashunity_Cli_Help extends Flashunity_Base {

flashunity/libraries/Flashunity/Comm/Socket.php

@@ -1 +1 @@
 <?php
 /**
- * 
- * @category Comm
- * @package Main
- * @author Richard Thomas <cyberlot[AT]cyberlot.net>
- * @license http://www.cyberlot.net
- * 
+ *
+ * Extention to the Solar Cli library
+ *
+ * @category Main      
+ * @package Flashunity
+ * @author Richard Thomas <richard@phpjack.com>
+ * @version $Id$
+ * @copyright Copyright (c) 2008, Richard Thomas.  All rights reserved.      
+ * @license http://www.phpjack.com
+ * @link http://www.phpjack.com
  */
+
 class Flashunity_Comm_Socket extends FlashUnity_Base {
     private $resource = NULL;
@@ -28 +33 @@
     
     public function check_new_data() {
+        $data = array();
         while(list($key, $client) = each($this->cpool)) {
             if(!is_object($client) OR !$client->resource) {
@@ -39 +45 @@
                 $rtval = $this->_read($client);
                 if($rtval) {
-                    $this->_write_all($rtval);
+                    $data[$key] = $rtval;
+//                    $this->_write_all($rtval);
                 }
             }
         }
+        return $data;
+    }
+    
+    public function write($ckey, $string) {
+        $this->_write($this->cpool[$ckey], $string);
+    }
+    
+    public function write_all($string) {
+        $this->_write_all($string);
     }
     
@@ -78 +94 @@
             $this->cpool[$key]->key = $key;
         }
+        return $key;
     }
     
     public function check_new_conn() {
+        $new = NULL;
         if(in_array($this->resource, $this->current)) {
-            $this->_accept_conn();
+            $new[] = $this->_accept_conn();
         }
+        return $new;
     }
 

flashunity/libraries/Flashunity/Transport/Xml.php

@@ -1 +1 @@
 <?php
 /**
- * 
- * @category Transport
- * @package Main
- * @author Richard Thomas <cyberlot[AT]cyberlot.net>
- * @license http://www.cyberlot.net
- * 
+ *
+ * Extention to the Solar Cli library
+ *
+ * @category Main      
+ * @package Flashunity
+ * @author Richard Thomas <richard@phpjack.com>
+ * @version $Id$
+ * @copyright Copyright (c) 2008, Richard Thomas.  All rights reserved.      
+ * @license http://www.phpjack.com
+ * @link http://www.phpjack.com
  */
+
 class Flashunity_Transport_XML extends Solar_Cli_Base {
 
@@ -19 +24 @@
 
   public function read($client, $string) {
-    return $string;
+    return trim($string);
   }
 }

flashunity/script/flashunity.php

@@ -1 +1 @@
 #!/usr/bin/php
 <?php
+/**
+ *
+ * @category Main      
+ * @package Flashunity
+ * @author Richard Thomas <richard@phpjack.com>
+ * @version $Id$
+ * @copyright Copyright (c) 2008, Richard Thomas.  All rights reserved.      
+ * @license http://www.phpjack.com
+ * @link http://www.phpjack.com
+ */
+
 error_reporting(E_ALL);
 // system trunk directory