Method: LS4::GatewayService#rpc_getd_data
- Defined in:
- lib/ls4/service/gateway.rb
#rpc_getd_data(okey) ⇒ Object
159 160 161 162 163 164 165 166 167 168 169 170 171 172 |
# File 'lib/ls4/service/gateway.rb', line 159 def rpc_getd_data(okey) ar = MessagePack::RPC::AsyncResult.new DataClientBus.get(okey, 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 |