X-Git-Url: http://mop.ddnsfree.com/gitweb/?a=blobdiff_plain;f=web%2FObj%2Fcurl-de-sac.phh;h=f7911871fd485e47847c42ef59be60256658603e;hb=3d134990bee924e6e833c5c22ef2cb65524769d7;hp=0a1b18dd6093d25b678a3670fd938f7ff920205f;hpb=db714d824435fb021bc4d4158a7e628221fbdcd9;p=curl-de-sac.git

diff --git a/web/Obj/curl-de-sac.phh b/web/Obj/curl-de-sac.phh
index 0a1b18d..f791187 100644
--- a/web/Obj/curl-de-sac.phh
+++ b/web/Obj/curl-de-sac.phh
@@ -24,18 +24,64 @@
 
 $G_curl_de_sac_version = "0.1";
 
+class CDS_cmd {
+    var $cmd_cls;
+    var $ch;
+
+    function CDS_cmd($cmd_cls, $ch)
+    {
+        $this->cmd_cls = $cmd_cls;
+        $this->ch = $ch;
+    }
+}
+
 class CDS_cmd_cls {
+    var $cds;
     var $name;
     var $tout;
 
     function CDS_cmd_cls($name, $tout)
     {
+        $this->cds = NULL;
         $this->name = $name;
         $this->tout = $tout;
     }
 
-    function cb()
+    function cds_set($cds)
+    {
+        $this->cds = $cds;
+    }
+
+    static function pre_create($url)
+    {
+        if (($ch = curl_init()) == FALSE)
+            return FALSE;
+        curl_setopt($ch, CURLOPT_URL, $url);
+        curl_setopt($ch, CURLOPT_HEADER, 0);
+        curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
+        
+        return ($ch);
+    }
+
+    function create($cds, $ch)
+    {
+        if ($cds->dbg > 2) {
+            printf("CDS_cmd_cls::create - begin\n");
+            print_r($ch);
+        }
+        if (($ret = curl_multi_add_handle($cds->mh, $ch)) != 0) {
+            // INFO: $ret is a CURLM_XXX errors code
+            return (FALSE);
+        }
+        if ($cds->dbg > 2) {
+            printf("CDS_cmd_cls::create - end\n");
+        }
+        return (TRUE);
+    }
+
+    function cb($cmd, $ret)
     {
+        
         print "THIS MUST BE IMPLEMENTED";
         exit(123);
     }
@@ -44,10 +90,19 @@ class CDS_cmd_cls {
 class Curl_de_sac {
     var $mh;
     var $cmd_cls;
+    var $cmd;
+    var $dbg;
 
-    function Curl_de_sac() {
+    function Curl_de_sac($dbg=0) {
         $this->mh = curl_multi_init();
         $this->cmd_cls = array();
+        $this->cmd = array();
+        $this->dbg = $dbg;
+    }
+
+    function dbg_set($dbg)
+    {
+        $this->dbg = $dbg;
     }
 
     function cmd_register($cmd_cls)
@@ -59,7 +114,95 @@ class Curl_de_sac {
             return FALSE;
 
         $this->cmd_cls[$cmd_cls->name] = $cmd_cls;
+        $cmd_cls->cds_set($this);
+
+        return TRUE;
+    }
 
+    function cmd_deregister($cmd_cls)
+    {
+        if (get_class($cmd_cls) != 'CDS_cmd_cls' && is_subclass_of($cmd_cls, 'CDS_cmd_cls') == FALSE)
+            return FALSE;
+        if (!isset($this->cmd_cls[$cmd_cls->name]))
+            return FALSE;
+
+        $this->cmd_cls[$cmd_cls->name]->cds_set(NULL);
+
+        unset($this->cmd_cls[$cmd_cls->name]);
         return TRUE;
     }
+
+    function cmd_deregister_all()
+    {
+        foreach($this->cmd_cls as $cmd_cls) {
+            $cmd_cls->cds_set(NULL);
+        }
+
+        $this->cmd_cls = array();
+    }
+
+    function execute()
+    {
+        $args = func_get_args();
+
+        if ($this->dbg > 1) {
+             printf("CDS_cmd_cls::execute  ARGS:\n");
+             print_r($args);
+        }
+        do {
+            if (($name = array_shift($args)) === NULL)
+                break;
+            array_unshift($args, $this);
+            
+            if (!isset($this->cmd_cls[$name]))
+                break;
+            
+            $cmd_cls = $this->cmd_cls[$name];
+            
+            if (($inst = call_user_func_array(array($cmd_cls, "create"), $args)) == FALSE)
+                break;
+
+            array_push($this->cmd, $inst);
+            if ($this->dbg > 1) {
+                printf("CDS_cmd_cls::process - execute  push cmd\n");
+                print_r($this->cmd);
+            }
+            return TRUE;
+        } while (FALSE);
+
+        return FALSE;
+    }
+
+    function process()
+    {
+        if ($this->dbg > 1) {
+             printf("CDS_cmd_cls::process - begin\n");
+        }
+        $running = NULL;
+        $ret = curl_multi_exec($this->mh, $running);
+        $msgs_in_queue = NULL;
+
+        do {
+            if ($ret = curl_multi_info_read ($this->mh, $msgs_in_queue)) {
+                if ($this->dbg > 1)
+                    printf("Info_read miq: %d\n", $msgs_in_queue);
+                
+                foreach($this->cmd as $cmd) {
+                    if ($cmd->ch == $ret['handle']) {
+                        $cmd->cmd_cls->cb($cmd, $ret);
+                        break;
+                    }
+                }
+                $info = curl_getinfo($ret['handle']);
+                if ($this->dbg > 1) {
+                    printf("Getinfo:\n");
+                    print_r($info);
+                }
+            }
+        } while ($msgs_in_queue > 0);
+        if ($this->dbg > 1) {
+            printf("CDS_cmd_cls::process - end (queue: %d)\n", $msgs_in_queue);
+        }
+    }
+
 }
\ No newline at end of file