modify
This commit is contained in:
@@ -221,8 +221,6 @@ class Crontab extends BaseObject
|
|||||||
|
|
||||||
$name_md5 = md5($this->getName());
|
$name_md5 = md5($this->getName());
|
||||||
|
|
||||||
var_dump($name_md5);
|
|
||||||
|
|
||||||
$redis->hSet(self::WAIT_END, $name_md5, serialize($this));
|
$redis->hSet(self::WAIT_END, $name_md5, serialize($this));
|
||||||
$params = call_user_func($this->handler, $this->params, $this->name);
|
$params = call_user_func($this->handler, $this->params, $this->name);
|
||||||
$redis->hDel(self::WAIT_END, $name_md5);
|
$redis->hDel(self::WAIT_END, $name_md5);
|
||||||
|
|||||||
@@ -62,7 +62,6 @@ class Zookeeper extends Process
|
|||||||
*/
|
*/
|
||||||
private function dispatch($server, $redis, $setting, $value)
|
private function dispatch($server, $redis, $setting, $value)
|
||||||
{
|
{
|
||||||
var_dump($value);
|
|
||||||
$server->sendMessage(swoole_serialize([
|
$server->sendMessage(swoole_serialize([
|
||||||
'action' => 'crontab', 'handler' => swoole_unserialize($redis->get('crontab:' . $value))
|
'action' => 'crontab', 'handler' => swoole_unserialize($redis->get('crontab:' . $value))
|
||||||
]), random_int(0, $setting - 1));
|
]), random_int(0, $setting - 1));
|
||||||
|
|||||||
Reference in New Issue
Block a user