Method: Aerospike::BatchOperateCommand#parse_row

Defined in:
lib/aerospike/command/batch_operate_command.rb

#parse_row(result_code) ⇒ Object

Parse all results in the batch. Add records to shared list. If the record was not found, the bins will be nil.


131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
 
# File 'lib/aerospike/command/batch_operate_command.rb', line 131

def parse_row(result_code)
  generation = @data_buffer.read_int32(6)
  expiration = @data_buffer.read_int32(10)
  batch_index = @data_buffer.read_int32(14)
  field_count = @data_buffer.read_int16(18)
  op_count = @data_buffer.read_int16(20)

  skip_key(field_count)
  req_key = records[batch_index].key

  records[batch_index].result_code = result_code
  case result_code
  when 0, ResultCode::UDF_BAD_RESPONSE
    record = parse_record(req_key, op_count, generation, expiration)
    records[batch_index].record = record
  end
end