Method: LS4::GatewayService#rpc_readd

Defined in:
lib/ls4/service/gateway.rb

#rpc_readd(okey, offset, size) ⇒ Object 



174
175
176
177
178
179
180
181
182
183
184
185
186
187
 
# File 'lib/ls4/service/gateway.rb', line 174

def rpc_readd(okey, offset, size)
  ar = MessagePack::RPC::AsyncResult.new
  DataClientBus.read(okey, offset, size, true) {|data,error|
    if error
      $log.warn("failed to get data from DS: okey=#{okey}: #{error} rsid=#{okey.rsid}")
      $log.debug_backtrace error.backtrace if error.is_a?(Exception)
      ar.error(error.to_s)
    else
      #data ||= ""
      ar.result(data)
    end
  }
  ar
end