Changeset 258
- Timestamp:
- 12/10/07 01:11:31 (9 months ago)
- Files:
-
- trunk/framework/core.rb (modified) (1 diff)
- trunk/framework/nbio.rb (modified) (1 diff)
Legend:
- Unmodified
- Added
- Removed
- Modified
- Copied
- Moved
trunk/framework/core.rb
r257 r258 131 131 # method opens a socket for listening 132 132 def start_server(ip,port,t_module,&block) 133 # t_socket = Socket.new(Socket::AF_INET,Socket::SOCK_STREAM,0) 134 # t_socket.setsockopt(Socket::SOL_SOCKET,Socket::SO_REUSEADDR,true) 135 # sockaddr = Socket.sockaddr_in(port.to_i,ip) 136 # t_socket.bind(sockaddr) 137 # t_socket.listen(50) 138 # t_socket.setsockopt(Socket::IPPROTO_TCP,Socket::TCP_NODELAY,1) 139 140 # BasicSocket.do_not_reverse_lookup = true 141 # configure_socket_options 133 BasicSocket.do_not_reverse_lookup = true 134 configure_socket_options 142 135 t_socket = TCPServer.new(ip,port.to_i) 143 # t_socket.setsockopt(*$tcp_defer_accept_opts) rescue nil 144 t_socket.setsockopt(Socket::IPPROTO_TCP,Socket::TCP_NODELAY,1) 136 t_socket.setsockopt(*$tcp_defer_accept_opts) rescue nil 145 137 listen_sockets[t_socket.fileno] = { :socket => t_socket,:block => block,:module => t_module } 146 138 @read_ios << t_socket trunk/framework/nbio.rb
r256 r258 14 14 sock_data = "" 15 15 begin 16 while(sock_data << t_sock.read_nonblock(1023)); end 16 while(t_data = t_sock.recv_nonblock(1023)) 17 raise DisconnectError.new(t_sock) if t_data.empty? 18 sock_data << t_data 19 end 17 20 rescue Errno::EAGAIN 18 p sock_data19 21 return sock_data 20 22 rescue 21 p "***************** : disconnecterror"23 puts "Some read error" 22 24 raise DisconnectError.new(t_sock) 23 25 end
