add to local

core/framework/libraries/model.php

@@ -152,6 +152,8 @@ class Model
             $result = $this->db->select($options);
             if(!empty($result)) {
                 return reset($result[0]);
+            } else {
+                return 0;
             }
         }
         elseif(strtolower(substr($method,0,6))=='getby_')

helper/search/processor.php

@@ -20,10 +20,8 @@ class processor implements IProcessor
 {
     const GetRelatedWord = 1;
     const SearchReasult  = 2;
-
     const ValidateArea   = 20;
 
-
     public function handle_input($body)
     {
         if(StatesHelper::fetch_state('init')) {

helper/search/server.php

@@ -16,7 +16,8 @@ interface IProcessor
 class CentraHelper
 {
     const body_header_len = 10;
-    const time_out = 3600;
+    const read_time_out  = 600;
+    const write_time_out = 5;
 
 
     private $socket;
@@ -52,7 +53,6 @@ class CentraHelper
     public function run_loop($sockfd)
     {
         $this->socket = $sockfd;
-        //$this->socket = stream_socket_server ($this->remote_addr(), $errno, $errstr);
         echo "stream_set_blocking \n";
         if(stream_set_blocking($this->socket, 0) == false) {
             echo "stream_set_blocking error \n";
@@ -93,12 +93,11 @@ class CentraHelper
         }
 
         event_buffer_base_set($buffer, $base);
-        event_buffer_timeout_set($buffer, self::time_out, self::time_out);
+        event_buffer_timeout_set($buffer, self::read_time_out, self::write_time_out);
         event_buffer_watermark_set($buffer, EV_READ, 0, 0xffffff);
         event_buffer_priority_set($buffer, 10);
         event_buffer_enable($buffer, EV_READ | EV_PERSIST);
 
-        // we need to save both buffer and connection outside
         $this->connections[$this->connect_id] = $connection;
         $this->buffers[$this->connect_id] = $buffer;
         $this->contents[$this->connect_id] = "";

helper/search/tcp_client.php

@@ -127,8 +127,7 @@ class tcp_client
             Log::record("connect search server err --- code:{$errno} : {$err}");
             return false;
         } else {
-            //socket_set_option($this->mSocket, SOL_SOCKET, SO_KEEPALIVE, 1);
-            socket_set_timeout($this->mSocket,self::time_out);
+            //socket_set_timeout($this->mSocket,self::time_out);
             return true;
         }
     }