Changeset 185
- Timestamp:
- 06/03/06 14:01:54 (2 years ago)
- Files:
-
- experiments/NewMachine/lib/machine/reactor.rb (modified) (4 diffs)
Legend:
- Unmodified
- Added
- Removed
- Modified
- Copied
- Moved
experiments/NewMachine/lib/machine/reactor.rb
r183 r185 30 30 def initialize 31 31 @dispatchers = [] 32 33 32 @running = false 34 33 end … … 37 36 # TODO: exception handling 38 37 def run 38 #initialize_event_signal 39 39 log.debug "Reactor running..." 40 40 @running = true … … 52 52 log.debug "iterating..." 53 53 @dispatchers.each {|d| d.iterate } 54 #@signalled = false 54 55 end 55 56 … … 81 82 @running 82 83 end 84 85 86 =begin 87 def initialize_event_signal 88 @event_signal,b = Socket::socketpair( Socket::AF_UNIX, Socket::SOCK_STREAM, 0) 89 EventableStream.new b 90 end 91 92 def signal_event 93 unless @signalled 94 @event_signal.write '.' 95 @signalled = true 96 end 97 end 98 =end 99 83 100 end 84 101 end
