#!/usr/bin/php
<?php
-define('WEBURL', 'http://localhost/curl-de-sac');
+define('WEB_URL', 'http://localhost/curl-de-sac');
+define('DBG_LEVEL', 0);
require_once('Obj/curl-de-sac.phh');
function create($cds, $url)
{
- printf("short::create url:[%s]\n", $url);
-
+ if ($cds->dbg_get() > 0) {
+ printf("'short'::create url:[%s]\n", $url);
+ }
+
do {
- if (($ch = parent::pre_create($url)) == FALSE)
+ if (($ch = parent::pre_create($cds, $url)) == FALSE)
break;
if (parent::create($cds, $ch) == FALSE)
break;
- $cmd = new short_cmd($ch, $this, "none currently");
+ $cmd = new short_cmd($this, $ch, "none currently");
return $cmd;
} while (FALSE);
return FALSE;
}
- function cb()
+ function process($cmd, $ret)
{
- printf("short_cb:\n");
+ if ($this->dbg_get() > 2) { printf("CURL: 'short' process: curl_multi_getcontent\n"); }
+
+ $content = curl_multi_getcontent($cmd->ch_get());
+ if ($this->dbg_get() > 0) { printf("'short' process: [%s]\n", $content); }
+
+ return TRUE;
+ }
+
+ function timeout($cmd)
+ {
+ printf("'Short' timeout function reached\n");
}
}
class long_cmd_cls extends CDS_cmd_cls {
function long_cmd_cls()
{
- parent::__construct("long", 10);
+ parent::__construct("long", 5);
}
function create($cds, $url)
{
- printf("long::create url:[%s]\n", $url);
-
+ if ($cds->dbg_get() > 0) {
+ printf("'long'::create url:[%s]\n", $url);
+ }
+
do {
- if (($ch = parent::pre_create($url)) == FALSE)
+ if (($ch = parent::pre_create($cds, $url)) == FALSE)
break;
if (parent::create($cds, $ch) == FALSE)
break;
- $cmd = new long_cmd($ch, $this, "none currently");
+ $cmd = new long_cmd($this, $ch, "none currently");
return $cmd;
} while (FALSE);
return FALSE;
}
- function cb()
+ function process($cmd, $ret)
{
- printf("long_cb:\n");
+ if ($this->dbg_get() > 2) { printf("CURL: 'long' process: curl_multi_getcontent\n"); }
+
+ $content = curl_multi_getcontent($cmd->ch_get());
+ if ($this->dbg_get() > 0) { printf("'long' process: [%s]\n", $content); }
+
+ return TRUE;
+ }
+
+ function timeout($cmd)
+ {
+ printf("'Long' timeout function reached\n");
}
}
function main()
{
+ $debug = DBG_LEVEL;
// create cds
- $cds = new Curl_de_sac(999);
+ $cds = new Curl_de_sac($debug);
- // create cds_cmd 1
- $cmd_cls1 = new short_cmd_cls();
+ // create short_cls
+ $short_cls = new short_cmd_cls();
- // registrer cds_cmd 1
- printf("Register CLS1\n");
- if (($cds->cmd_cls_register($cmd_cls1)) == FALSE) {
- fprintf(STDERR, "cmd_cls1 registration failed\n");
+ // registrer short_cls
+ printf("MAIN: Register 'short_cls'\n");
+ if (($cds->cmd_cls_register($short_cls)) == FALSE) {
+ fprintf(STDERR, "MAIN: 'short_cls' registration failed\n");
exit(1);
}
- // create cds_cmd 2
- $cmd_cls2 = new long_cmd_cls();
+ // create long_cls
+ $long_cls = new long_cmd_cls();
- // register cds_cmd 2
- printf("Register CLS2\n");
- if (($cds->cmd_cls_register($cmd_cls2)) == FALSE) {
- fprintf(STDERR, "cmd_cls2 registration failed\n");
+ // register long_cls
+ printf("MAIN: Register 'long_cls'\n");
+ if (($cds->cmd_cls_register($long_cls)) == FALSE) {
+ fprintf(STDERR, "MAIN: 'long_cls' registration failed\n");
exit(2);
}
- // register cds_cmd 2 (retry)
- printf("Re-register CLS2 (must go wrong)\n");
- if (($cds->cmd_cls_register($cmd_cls2)) != FALSE) {
- fprintf(STDERR, "cmd_cls2 re-registration success\n");
+ // register long_cls (retry)
+ printf("MAIN: Re-register 'long_cls' (must go wrong)\n");
+ if (($cds->cmd_cls_register($long_cls)) != FALSE) {
+ fprintf(STDERR, "MAIN: 'long_cls' re-registration success\n");
exit(3);
}
- print_r($cds);
- printf("Deregister CLS2\n");
- if (($cds->cmd_cls_deregister($cmd_cls2)) == FALSE) {
- fprintf(STDERR, "cmd_cls2 deregistration failed\n");
+ printf("MAIN: CDS:\n");
+ if (($debug & 1) == 1)
+ print_r($cds);
+ printf("MAIN: Deregister 'long_cls'\n");
+ if (($cds->cmd_cls_deregister($long_cls)) == FALSE) {
+ fprintf(STDERR, "MAIN: 'long_cls' deregistration failed\n");
exit(4);
}
- print_r($cds);
-
- // re-re-register cds_cmd 2
- printf("Re-re-register CLS2\n");
- if (($cds->cmd_cls_register($cmd_cls2)) == FALSE) {
- fprintf(STDERR, "cmd_cls2 re-re-registration failed\n");
+ printf("MAIN:");
+ if (($debug & 1) == 1) {
+ printf(" CDS:\n");
+ print_r($cds);
+ }
+ printf("\n");
+ // re-re-register long_cls
+ printf("MAIN: Re-re-register 'long_cls'\n");
+ if (($cds->cmd_cls_register($long_cls)) == FALSE) {
+ fprintf(STDERR, "MAIN: 'long_cls' re-re-registration failed\n");
exit(5);
}
- printf("Deregister all\n");
+ printf("MAIN: Deregister all\n");
$cds->cmd_cls_deregister_all();
- // registrer cds_cmd 1
- printf("Register CLS1\n");
- if (($cds->cmd_cls_register($cmd_cls1)) == FALSE) {
- fprintf(STDERR, "cmd_cls1 registration failed\n");
+ // registrer short_cls
+ printf("MAIN: register 'short_cls'\n");
+ if (($cds->cmd_cls_register($short_cls, 10)) == FALSE) {
+ fprintf(STDERR, "MAIN: 'short_cls' registration failed\n");
exit(1);
}
- // register cds_cmd 2
- printf("Register CLS2\n");
- if (($cds->cmd_cls_register($cmd_cls2)) == FALSE) {
- fprintf(STDERR, "cmd_cls2 registration failed\n");
+ // register long_cls
+ printf("MAIN: register 'long_cls'\n");
+ if (($cds->cmd_cls_register($long_cls, 4)) == FALSE) {
+ fprintf(STDERR, "MAIN: 'long_cls' registration failed\n");
exit(2);
}
- print_r($cds);
- printf("SUCCESS\n");
+ printf("MAIN:");
+ if (($debug & 1) == 1) {
+ printf(" CDS:\n");
+ print_r($cds);
+ }
+ printf("\n");
+
+ // for ($i = -15 ; $i < 30 ; $i++) {
+ for ($i = 0 ; $i < 20 ; $i++) {
+ printf("MAIN: START ITERATION %d\n", $i);
+
+ if ($i == 2) {
+ printf("MAIN: load 'short'\n");
+ if ($cds->execute("short", WEB_URL.'/short.php') == FALSE) {
+ printf("MAIN: push 'short' command failed\n");
+ exit(123);
+ }
+ }
- for ($i = 0 ; $i < 10 ; $i++) {
- if ($i == 2) {
- print("load short\n");
- if ($cds->execute("short", WEBURL.'/short.php') == FALSE) {
- printf("push command failed\n");
+ if ($i == 3) {
+ printf("MAIN: load 'short'\n");
+ if ($cds->execute("short", WEB_URL.'/short.php') == FALSE) {
+ printf("MAIN: push 'short' command failed\n");
exit(123);
}
}
- printf("Call process\n");
+
+ if ($i == 4) {
+ printf("MAIN: load 'long'\n");
+ if ($cds->execute("long", WEB_URL.'/long.php') == FALSE) {
+ printf("MAIN: push 'long' command failed\n");
+ exit(123);
+ }
+ }
+
+ printf("MAIN:");
+ if (($debug & 1) == 1) {
+ printf(" CDS:\n");
+ print_r($cds);
+ }
+ printf("\n");
+
+ printf("MAIN: Call process\n");
$cds->process();
sleep(1);
}
+ printf("MAIN: finished, dump cds:\n");
+ print_r($cds);
// start loop
// print status
// if input data execute some command
projects / curl-de-sac.git / blobdiff