# pecl list
Installed packages, channel pecl.php.net:
=========================================
Package Version State
gearman 1.0.3 stable
# php -i | grep -i gearman
gearman
gearman support => enabled
libgearman version => 0.33
core 'core' of 23192: /opt/local/bin/php /opt/local/share/gearmand/gearman_worker.php
----------------- lwp# 1 / thread# 1 --------------------
fffffd7fff20036a _lwp_kill () + a
fffffd7fff18a7b1 raise () + 19
fffffd7fff15fee1 abort () + d9
fffffd7feff4c6f5 sigsegv_handler () + 125
fffffd7fff1f73b6 __sighndlr () + 6
fffffd7fff1ea09c call_user_handler () + 2a4
fffffd7fff1ea2c3 sigacthandler (6, 0, fffffd7fffdf9c70) + db
--- called from signal handler with signal 6 (SIGABRT) ---
fffffd7fff20036a _lwp_kill () + a
fffffd7fff18a7b1 raise () + 19
fffffd7fff15fe65 abort () + 5d
fffffd7fefea54ea ???????? ()
fffffd7fefea8acf _Z22gearman_request_optionR20gearman_universal_stR16gearman_string_t () + 13f
fffffd7fefeaad8d gearman_worker_set_server_option () + 1d
fffffd7fefece3d3 zif_gearman_worker_work () + 63
000000000074c66a zend_do_fcall_common_helper_SPEC () + a5a
000000000070e043 execute () + 1c3
fffffd7feff4114b nr__execute () + 52b
00000000006ec969 zend_execute_scripts () + 109
000000000069a41b php_execute_script () + 15b
000000000077f0d6 main () + 1566
00000000004c6f7c _start () + 6c
----------------- lwp# 2 / thread# 2 --------------------
fffffd7fff1ff4da __nanosleep () + a
fffffd7feff5017a nr__harvest_thread () + 4a
fffffd7fff1f7024 _thrp_setup () + bc
fffffd7fff1f72f0 _lwp_start ()
Here is a sanitized version of the code involved:
#!/opt/local/bin/php
<?php
$CONFIG=array();
$pid=getmypid();
echo "Starting\n";
$gmworker= new GearmanWorker();
$gmworker->addServer("gm-local");
$gmworker->addServer("gm-lb");
$gmworker->addFunction("jobFunction","jobFunction");
$gmclient=new GearmanClient();
$gmclient->addServer("gm-lb");
$mysqli=new mysqli('p:db-server', 'user', 'password', 'schema');
if ($mysqli->connect_error) {
die("MySQL Connection Error: ".$mysqli->connect_error."\n");
}
print "Waiting for job...\n";
while($gmworker->work())
{
if ($gmworker->returnCode() != GEARMAN_SUCCESS)
{
echo "return_code: " . $gmworker->returnCode() . "\n";
break;
}
}
function jobFunction($job)
{
global $gmclient;
global $pid;
global $CONFIG;
global $mysqli;
$sqlh=$mysqli->prepare('insert into table values(?,?) on duplicate key update field1=values(field1);');
$workload=json_decode($job->workload(),true);
$appname=$workload[0];
$currentJobs=$workload[1];
$nextJobs=array();
$object = new ObjectClass();
echo $pid.": Received job: " . $job->handle() . "\n";
try{
$param = array(
'field' => 'VALUE',
'field2' => $currentJobs );
$results = $object->api('/', 'POST', $param);
if(isset($results) && !empty($results)){
foreach($results as $result){
switch($result['code']){
case 200:
$resultArr=json_decode($result['body'],true);
$sqlh->bind_param('is',$resultArr['field'],$resultArr['field1']);
if($sqlh->execute()){
print "Upserted ".$sqlh->affected_rows." for ".$resultArr['field']."\n";
}
print "Storing Details ".print_r($resultArr,true)." for: ".$resultArr['field']."\n";
$nextJobs[]=array(
'field1' =>'value1',
'field2' => 'value2'
);
$jobIndex[]=array($resultArr['field'],'');
break;
default:
echo "Error: ".$result['body']."\n";
break;
}
}
}
else{
error_log("Bad Results: ".print_r($results,true));
}
}
catch(ObjectClassException $e){
error_log( "ERROR on ".$e);
echo $pid.": Failed job: ". $job->handle() . "ERROR on ".$e."\n";
return(-1);
}
$job_handle = $gmclient->doBackground("nextJobFunction", json_encode(array($appname,$jobIndex, $nextJobs)));
if ($gmclient->returnCode() != GEARMAN_SUCCESS){
error_log("Bad return code");
}
else {
echo "Dispatched Chunk of ".count($nextJobs)." jobs\n";
}
echo $pid.": Finished job: " . $job->handle() . "\n";
}
?>
Caused by this code in pecl/gearman:
php_gearman.c:
if (! gearman_
}