<?php
/**
* * * * * * * *<4297088@qq.com>
* */
namespace cn\gz53\framework\dao\process;
use cn\gz53\framework\dao\Dao;
use cn\gz53\framework\sdk\process\ProcessPoolWorkerSdk;
use cn\gz53\framework\model\po\process\ProcessPoolWorkerRunCallbackSetPo;
use cn\gz53\framework\model\po\process\ProcessPoolWorkerCallbackGetPo;
use cn\gz53\framework\model\po\process\ProcessPoolWorkerConfigSetPo;
class ProcessPoolWorkerDao extends Dao
{
public function setConfig(ProcessPoolWorkerConfigSetDaoI $bo){
$po = ProcessPoolWorkerConfigSetPo::getInstance($this->_context);
$processPoolWorkerSdk = ProcessPoolWorkerSdk::getInstance($this->_context);
$po->setConfig($bo->getConfig());
if(!$processPoolWorkerSdk->setConfig($po)){
return false;
}
return true;
}
public function setInitCallback(ProcessPoolWorkerRunCallbackSetDaoI $bo){
$po = ProcessPoolWorkerRunCallbackSetPo::getInstance($this->_context);
$processPoolWorkerSdk = ProcessPoolWorkerSdk::getInstance($this->_context);
$po->setRunnerInitCallback($bo->getRunnerInitCallback());
$po->setRouterCallback($bo->getRunnerRunCallback());
if(!$processPoolWorkerSdk->setRunnerCallback($po)){
return false;
}
return true;
}
public function getWorkerCallback(ProcessPoolWorkerCallbackGetDaoI $bo){
$po = ProcessPoolWorkerCallbackGetPo::getInstance($this->_context);
$processPoolWorkerSdk = ProcessPoolWorkerSdk::getInstance($this->_context);
if(!$processPoolWorkerSdk->getWorkerCallback($po)){
return false;
}
$bo->setWorkerStartCallback($po->getWorkerStartCallback());
$bo->setWorkerStopCallback($po->getWorkerStopCallback());
return true;
}
}