3 * curl-de-sac - curl-de-sac.phh
5 * Copyright (C) 2014 Matteo Nastasi
6 * mailto: nastasi@alternativeoutput.it
7 * matteo.nastasi@gmail.com
8 * web: http://www.alternativeoutput.it
10 * This program is free software; you can redistribute it and/or modify
11 * it under the terms of the GNU General Public License as published by
12 * the Free Software Foundation; either version 2 of the License, or
13 * (at your option) any later version.
15 * This program is distributed in the hope that it will be useful, but
16 * WITHOUT ANY WARRANTY; without even the implied warranty of
17 * MERCHANTABLILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
18 * General Public License for more details. You should have received a
19 * copy of the GNU General Public License along with this program; if
20 * not, write to the Free Software Foundation, Inc, 59 Temple Place -
21 * Suite 330, Boston, MA 02111-1307, USA.
25 $G_curl_de_sac_version = "0.1";
31 function CDS_cmd($cmd_cls, $ch)
33 $this->cmd_cls = $cmd_cls;
43 function CDS_cmd_cls($name, $tout)
50 function cds_set($cds)
55 static function pre_create($url)
57 if (($ch = curl_init()) == FALSE)
59 curl_setopt($ch, CURLOPT_URL, $url);
60 curl_setopt($ch, CURLOPT_HEADER, 0);
61 curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
66 function create($cds, $ch)
69 printf("CDS_cmd_cls::create - begin\n");
72 if (($ret = curl_multi_add_handle($cds->mh, $ch)) != 0) {
73 // INFO: $ret is a CURLM_XXX errors code
77 printf("CDS_cmd_cls::create - end\n");
82 function cb($cmd, $ret)
85 print "THIS MUST BE IMPLEMENTED";
96 function Curl_de_sac($dbg=0) {
97 $this->mh = curl_multi_init();
98 $this->cmd_cls = array();
103 function dbg_set($dbg)
108 function cmd_register($cmd_cls)
110 if (get_class($cmd_cls) != 'CDS_cmd_cls' && is_subclass_of($cmd_cls, 'CDS_cmd_cls') == FALSE)
113 if (isset($this->cmd_cls[$cmd_cls->name]))
116 $this->cmd_cls[$cmd_cls->name] = $cmd_cls;
117 $cmd_cls->cds_set($this);
122 function cmd_deregister($cmd_cls)
124 if (get_class($cmd_cls) != 'CDS_cmd_cls' && is_subclass_of($cmd_cls, 'CDS_cmd_cls') == FALSE)
126 if (!isset($this->cmd_cls[$cmd_cls->name]))
129 $this->cmd_cls[$cmd_cls->name]->cds_set(NULL);
131 unset($this->cmd_cls[$cmd_cls->name]);
135 function cmd_deregister_all()
137 foreach($this->cmd_cls as $cmd_cls) {
138 $cmd_cls->cds_set(NULL);
141 $this->cmd_cls = array();
146 $args = func_get_args();
148 if ($this->dbg > 1) {
149 printf("CDS_cmd_cls::execute ARGS:\n");
153 if (($name = array_shift($args)) === NULL)
155 array_unshift($args, $this);
157 if (!isset($this->cmd_cls[$name]))
160 $cmd_cls = $this->cmd_cls[$name];
162 if (($inst = call_user_func_array(array($cmd_cls, "create"), $args)) == FALSE)
165 array_push($this->cmd, $inst);
166 if ($this->dbg > 1) {
167 printf("CDS_cmd_cls::process - execute push cmd\n");
178 if ($this->dbg > 1) {
179 printf("CDS_cmd_cls::process - begin\n");
182 $ret = curl_multi_exec($this->mh, $running);
183 $msgs_in_queue = NULL;
186 if ($ret = curl_multi_info_read ($this->mh, $msgs_in_queue)) {
188 printf("Info_read miq: %d\n", $msgs_in_queue);
190 foreach($this->cmd as $cmd) {
191 if ($cmd->ch == $ret['handle']) {
192 $cmd->cmd_cls->cb($cmd, $ret);
196 $info = curl_getinfo($ret['handle']);
197 if ($this->dbg > 1) {
198 printf("Getinfo:\n");
202 } while ($msgs_in_queue > 0);
203 if ($this->dbg > 1) {
204 printf("CDS_cmd_cls::process - end (queue: %d)\n", $msgs_in_queue);