www.hjp.at/zettel/m/memcached_flags.rxml Looks like most clients use bit 0 to indicate native language serialization and bit 1 to indicate gzip compression.
# File lib/dalli/server.rb, line 34 def initialize(attribs, options = {}) (@hostname, @port, @weight) = attribs.split(':') @port ||= 11211 @port = Integer(@port) @weight ||= 1 @weight = Integer(@weight) @fail_count = 0 @down_at = nil @last_down_at = nil @options = DEFAULTS.merge(options) @sock = nil @msg = nil @error = nil @pid = nil @inprogress = nil end
# File lib/dalli/server.rb, line 78 def alive? return true if @sock if @last_down_at && @last_down_at + options[:down_retry_delay] >= Time.now time = @last_down_at + options[:down_retry_delay] - Time.now Dalli.logger.debug { "down_retry_delay not reached for #{hostname}:#{port} (%.3f seconds left)" % time } return false end connect !!@sock rescue Dalli::NetworkError false end
# File lib/dalli/server.rb, line 93 def close return unless @sock @sock.close rescue nil @sock = nil @pid = nil @inprogress = false end
# File lib/dalli/server.rb, line 111 def compressor @options[:compressor] end
# File lib/dalli/server.rb, line 101 def lock! end
Abort an earlier multi_response_start. Used to signal an external timeout. The underlying socket is disconnected, and the exception is swallowed.
Returns nothing.
# File lib/dalli/server.rb, line 187 def multi_response_abort @multi_buffer = nil @position = nil @inprogress = false failure! rescue NetworkError true end
Did the last call to multi_response_start complete successfully?
# File lib/dalli/server.rb, line 129 def multi_response_completed? @multi_buffer.nil? end
Attempt to receive and parse as many key/value pairs as possible from this server. After multi_response_start, this should be invoked repeatedly whenever this server's socket is readable until multi_response_completed?.
Returns a Hash of kv pairs received.
# File lib/dalli/server.rb, line 139 def multi_response_nonblock raise 'multi_response has completed' if @multi_buffer.nil? @multi_buffer << @sock.read_available buf = @multi_buffer pos = @position values = {} while buf.bytesize - pos >= 24 header = buf.slice(pos, 24) (key_length, _, body_length) = header.unpack(KV_HEADER) if key_length == 0 # all done! @multi_buffer = nil @position = nil @inprogress = false break elsif buf.bytesize - pos >= 24 + body_length flags = buf.slice(pos + 24, 4).unpack('N')[0] key = buf.slice(pos + 24 + 4, key_length) value = buf.slice(pos + 24 + 4 + key_length, body_length - key_length - 4) if body_length - key_length - 4 > 0 pos = pos + 24 + body_length begin values[key] = deserialize(value, flags) rescue DalliError end else # not enough data yet, wait for more break end end @position = pos values rescue SystemCallError, Timeout::Error, EOFError failure! end
Start reading key/value pairs from this connection. This is usually called after a series of GETKQ commands. A NOOP is sent, and the server begins flushing responses for kv pairs that were found.
Returns nothing.
# File lib/dalli/server.rb, line 120 def multi_response_start verify_state write_noop @multi_buffer = '' @position = 0 @inprogress = true end
# File lib/dalli/server.rb, line 51 def name "#{@hostname}:#{@port}" end
Chokepoint method for instrumentation
# File lib/dalli/server.rb, line 56 def request(op, *args) verify_state raise Dalli::NetworkError, "#{hostname}:#{port} is down: #{@error} #{@msg}" unless alive? begin send(op, *args) rescue Dalli::NetworkError raise rescue Dalli::MarshalError => ex Dalli.logger.error "Marshalling error for key '#{args.first}': #{ex.message}" Dalli.logger.error "You are trying to cache a Ruby object which cannot be serialized to memcached." Dalli.logger.error ex.backtrace.join("\n\t") false rescue Dalli::DalliError raise rescue => ex Dalli.logger.error "Unexpected exception in Dalli: #{ex.class.name}: #{ex.message}" Dalli.logger.error "This is a bug in Dalli, please enter an issue in Github if it does not already exist." Dalli.logger.error ex.backtrace.join("\n\t") down! end end
# File lib/dalli/server.rb, line 107 def serializer @options[:serializer] end
# File lib/dalli/server.rb, line 104 def unlock! end