0
@@ -102,6 +102,7 @@ class BackgrounDRb::WorkerProxy
0
 
0
   def close_connection
0
     @connection.close
0
+    @connection = nil
0
   end
0
 
0
   def ask_work p_data
0
@@ -144,14 +145,27 @@ class BackgrounDRb::WorkerProxy
0
   end
0
 
0
   def read_object
0
-    sock_data = ""
0
     begin
0
-      while(sock_data << @connection.read_nonblock(1023)); end
0
-    rescue Errno::EAGAIN
0
-      @tokenizer.extract(sock_data) { |b_data| return b_data }
0
+      message_length_str = @connection.read(9)
0
+      message_length = message_length_str.to_i
0
+      message_data = @connection.read(message_length)
0
+      return message_data
0
     rescue
0
       raise BackgrounDRb::BdrbConnError.new("Not able to connect")
0
     end
0
+
0
+   # begin
0
+   #   while(t_data = @connection.read_nonblock((16*1024)-1))
0
+   #     sock_data << t_data
0
+   #   end
0
+   #   return sock_data.join
0
+   # rescue Errno::EAGAIN
0
+   #   return sock_data.join
0
+   # rescue Errno::EWOULDBLOCK
0
+   #   return sock_data.join
0
+   # rescue
0
+   #   raise BackgrounDRb::BdrbConnError.new("Not able to connect",sock_data.join)
0
+   # end
0
   end
0
 
0
   def query_all_workers
0
@@ -174,7 +188,7 @@ class BackgrounDRb::WorkerProxy
0
   end
0
 
0
   def read_from_bdrb(timeout = 3)
0
-    @tokenizer = Packet::BinParser.new
0
+    #@tokenizer = Packet::BinParser.new
0
     begin
0
       ret_val = select([@connection],nil,nil,timeout)
0
       return nil unless ret_val