Class: Ebb::Connection

Inherits:
Object
  • Object
show all
Defined in:
lib/ebb.rb,
ext/ebb_ffi.c

Class Method Summary collapse

Instance Method Summary collapse

Class Method Details

.reset_responses ⇒ Object 



88
89
90
 
# File 'lib/ebb.rb', line 88

def self.reset_responses
  @@responses = {} # used for memory management :|
end

.responses ⇒ Object 



92
93
94
 
# File 'lib/ebb.rb', line 92

def self.responses
  @@responses
end

Instance Method Details

#append_request(req) ⇒ Object

called from c



101
102
103
 
# File 'lib/ebb.rb', line 101

def append_request(req)
  @requests.push req
end

#on_close ⇒ Object 



111
112
113
114
115
116
 
# File 'lib/ebb.rb', line 111

def on_close
  # garbage collection ! 
  @requests.each { |req| req.connection = nil }
  responses.each { |res| res.connection = nil }
  @@responses.delete(self)
end

#on_open ⇒ Object 



105
106
107
108
109
 
# File 'lib/ebb.rb', line 105

def on_open
  @being_written = nil
  @requests = []
  @@responses[self] = []
end

#on_writable ⇒ Object

called after FFI::connection_write if complete



133
134
135
136
137
138
139
140
141
142
143
144
 
# File 'lib/ebb.rb', line 133

def on_writable
  @being_written = nil
  return unless res = responses.first
  if res.finished?
    responses.shift
    if res.last 
      FFI::connection_schedule_close(self) 
      return
    end
  end 
  write
end

#responses ⇒ Object 



96
97
98
 
# File 'lib/ebb.rb', line 96

def responses
  @@responses[self]
end

#write ⇒ Object 



122
123
124
125
126
127
128
129
130
 
# File 'lib/ebb.rb', line 122

def write
  return if writing?
  return unless res = responses.first
  return if res.output.empty?
  # NOTE: connection_write does not buffer!
  chunk = res.output.shift
  @being_written = chunk # need to store this so ruby doesn't gc it
  FFI::connection_write(self, chunk) 
end

#writing? ⇒ Boolean

Returns:

  • (Boolean) 


118
119
120
 
# File 'lib/ebb.rb', line 118

def writing?
  ! @being_written.nil?
end