dev

rdispatcher/coall.php

@@ -94,19 +94,20 @@ function subscribe_message(&$quit, &$redis, $channels,$looper)
                 }
                 elseif($type == 'ratio')
                 {
-                    if($fLoading == false)
-                    {
-                        $ins = Cache::getInstance('cacheredis');
-                        $val = $ins->get_org('channel_ratios');
-
-                        if(empty($val)) return;
-                        $val = json_decode($val,true);
-                        if(empty($val)) return;
-                        $ratios = $val['ratios'];
-                        if(empty($ratios)) return;
-
-                        refill\RefillFactory::instance()->UpdateRatio($ratios);
-                    }
+//                    if($fLoading == false)
+//                    {
+//                        $ins = Cache::getInstance('cacheredis');
+//                        $val = $ins->get_org('channel_ratios');
+//
+//                        if(empty($val)) return;
+//                        $val = json_decode($val,true);
+//                        if(empty($val)) return;
+//                        $ratios = $val['ratios'];
+//                        if(empty($ratios)) return;
+//
+////                        refill\RefillFactory::instance()->UpdateRatio($ratios);
+//
+//                    }
                 }
                 else {
                     Log::record("subscribe_message dont not handle mgs:{$channel}-{$type}",Log::DEBUG);
@@ -131,7 +132,7 @@ for ($i = 0; $i < $process_count;$i++)
     {
         Log::record("Swoole::Process init",Log::DEBUG);
         Base::run_util();
-        refill\RefillFactory::instance()->load();
+        refill\RefillFactory::instance();
         set_error_handler('handle_error');
         Log::record("Swoole::Process init success",Log::DEBUG);