Module: Ethon::Multies::Operations
- Included in:
- Ethon::Multi
- Defined in:
- lib/ethon/multies/operations.rb
Overview
This module contains logic to run a multi.
Instance Method Summary collapse
-
#check ⇒ Object
Check.
-
#get_timeout ⇒ Object
Get timeout.
-
#init_vars ⇒ Object
Initialize variables.
-
#ongoing? ⇒ Boolean
Return wether the multi still requests or not.
-
#perform ⇒ Object
Perform multi.
-
#reset_fds ⇒ Object
Reset file describtors.
-
#run ⇒ Object
Run.
-
#running_count ⇒ Integer
Return number of running requests.
-
#set_fds(timeout) ⇒ Object
Set fds.
-
#trigger ⇒ Object
Trigger.
Instance Method Details
#check ⇒ Object
Check.
96 97 98 99 100 101 102 103 104 105 106 107 108 |
# File 'lib/ethon/multies/operations.rb', line 96 def check msgs_left = ::FFI::MemoryPointer.new(:int) while true msg = Curl.multi_info_read(handle, msgs_left) break if msg.null? next if msg[:code] != :done easy = easy_handles.find{ |e| e.handle == msg[:easy_handle] } easy.return_code = msg[:data][:code] delete(easy) easy.complete Ethon.logger.debug("ETHON: performed #{easy.log_inspect}") if Ethon.logger end end |
#get_timeout ⇒ Object
Get timeout.
53 54 55 56 57 58 59 |
# File 'lib/ethon/multies/operations.rb', line 53 def get_timeout code = Curl.multi_timeout(handle, @timeout) raise Errors::MultiTimeout.new(code) unless code == :ok timeout = @timeout.read_long timeout = 1 if timeout < 0 timeout end |
#init_vars ⇒ Object
Initialize variables.
11 12 13 14 15 16 17 18 |
# File 'lib/ethon/multies/operations.rb', line 11 def init_vars @timeout = ::FFI::MemoryPointer.new(:long) @timeval = Curl::Timeval.new @fd_read = Curl::FDSet.new @fd_write = Curl::FDSet.new @fd_excep = Curl::FDSet.new @max_fd = ::FFI::MemoryPointer.new(:int) end |
#ongoing? ⇒ Boolean
Return wether the multi still requests or not.
26 27 28 |
# File 'lib/ethon/multies/operations.rb', line 26 def ongoing? easy_handles.size > 0 || (!defined?(@running_count) || running_count > 0) end |
#perform ⇒ Object
Perform multi.
34 35 36 37 38 39 40 41 42 43 44 45 |
# File 'lib/ethon/multies/operations.rb', line 34 def perform Ethon.logger.debug("ETHON: started MULTI") if Ethon.logger while ongoing? run timeout = get_timeout next if timeout == 0 reset_fds set_fds(timeout) end Ethon.logger.debug("ETHON: performed MULTI") if Ethon.logger nil end |
#reset_fds ⇒ Object
Reset file describtors.
65 66 67 68 69 |
# File 'lib/ethon/multies/operations.rb', line 65 def reset_fds @fd_read.clear @fd_write.clear @fd_excep.clear end |
#run ⇒ Object
Run.
114 115 116 117 |
# File 'lib/ethon/multies/operations.rb', line 114 def run begin code = trigger end while code == :call_multi_perform check end |
#running_count ⇒ Integer
Return number of running requests.
136 137 138 |
# File 'lib/ethon/multies/operations.rb', line 136 def running_count @running_count ||= nil end |
#set_fds(timeout) ⇒ Object
Set fds.
78 79 80 81 82 83 84 85 86 87 88 89 90 |
# File 'lib/ethon/multies/operations.rb', line 78 def set_fds(timeout) code = Curl.multi_fdset(handle, @fd_read, @fd_write, @fd_excep, @max_fd) raise Errors::MultiFdset.new(code) unless code == :ok max_fd = @max_fd.read_int if max_fd == -1 sleep(0.001) else @timeval[:sec] = timeout / 1000 @timeval[:usec] = (timeout * 1000) % 1000000 code = Curl.select(max_fd + 1, @fd_read, @fd_write, @fd_excep, @timeval) raise Errors::Select.new(::FFI.errno) if code < 0 end end |
#trigger ⇒ Object
Trigger.
123 124 125 126 127 128 |
# File 'lib/ethon/multies/operations.rb', line 123 def trigger running_count = FFI::MemoryPointer.new(:int) code = Curl.multi_perform(handle, running_count) @running_count = running_count.read_int code end |