Changeset 204

Show
Ignore:
Timestamp:
11/14/07 23:26:06 (1 year ago)
Author:
gethema..@gmail.com
Message:

fixed bug with reading data back

Files:

Legend:

Unmodified
Added
Removed
Modified
Copied
Moved
  • branches/version10/framework/nbio.rb

    r187 r204  
    44    # when method returns nil it probably means that client diconnected 
    55    def read_data(t_sock) 
    6       sock_data = nil 
    76      begin 
    8         while(sock_data = t_sock.read_nonblock(1023)); end 
     7        while(sock_data << t_sock.read_nonblock(1023)); end 
     8        p sock_data 
    99      rescue Errno::EAGAIN 
    1010        return sock_data 
     
    5757      length_str = dump_length.rjust(9,'0') 
    5858      final_data = length_str + object_dump 
     59 
     60#       total_length = final_data.length 
     61#       loop do 
     62#         begin 
     63#           written_length = p_sock.write_nonblock(final_data) 
     64#         rescue Errno::EAGAIN 
     65#           break 
     66#         end 
     67#         break if written_length >= total_length 
     68#         final_data = final_data[written_length..-1] 
     69#         break if final_data.empty? 
     70#         total_length = final_data.length 
     71#       end 
     72 
    5973      begin 
    6074        p_sock.write_nonblock(final_data) 
  • branches/version10/lib/backgroundrb.rb

    r196 r204  
    5252  end 
    5353 
    54   def read_data 
    55     sock_data = nil 
     54  def read_object 
     55    sock_data = "" 
    5656    begin 
    57       while(sock_data = @connection.read_nonblock(1023)); end 
     57      while(sock_data << @connection.read_nonblock(1023)); end 
    5858    rescue Errno::EAGAIN 
    5959      @tokenizer.extract(sock_data) { |b_data| return b_data } 
     
    7272      ret_val = select([@connection],nil,nil,3) 
    7373      return nil unless ret_val 
    74       raw_response = read_data() 
     74      raw_response = read_object() 
    7575      master_response = Marshal.load(raw_response) 
    7676      return master_response 
     
    8989    dump_object(p_data,@connection) 
    9090    begin 
    91       ret_val = select([@connection],nil,nil,3
     91      ret_val = select([@connection],nil,nil,10
    9292      return nil unless ret_val 
    93       raw_response = read_data() 
     93 
     94      raw_response = read_object() 
    9495      master_response = Marshal.load(raw_response) 
    9596      return master_response[:data] 
  • branches/version10/server/cron_trigger.rb

    r201 r204  
    1111      @cron_expr = expr 
    1212      self.sec, self.min, self.hour, self.day, self.month, self.wday, self.year = @cron_expr.split(' ') 
    13       puts inspect 
     13      # puts inspect 
    1414    end 
    1515