Lines Matching refs:input
381 bool ReadKeyFromWriteBatchEntry(Slice* input, Slice* key, bool cf_record) { in ReadKeyFromWriteBatchEntry() argument
382 assert(input != nullptr && key != nullptr); in ReadKeyFromWriteBatchEntry()
384 input->remove_prefix(1); in ReadKeyFromWriteBatchEntry()
389 if (!GetVarint32(input, &cf)) { in ReadKeyFromWriteBatchEntry()
395 return GetLengthPrefixedSlice(input, key); in ReadKeyFromWriteBatchEntry()
414 Status ReadRecordFromWriteBatch(Slice* input, char* tag, in ReadRecordFromWriteBatch() argument
418 *tag = (*input)[0]; in ReadRecordFromWriteBatch()
419 input->remove_prefix(1); in ReadRecordFromWriteBatch()
423 if (!GetVarint32(input, column_family)) { in ReadRecordFromWriteBatch()
428 if (!GetLengthPrefixedSlice(input, key) || in ReadRecordFromWriteBatch()
429 !GetLengthPrefixedSlice(input, value)) { in ReadRecordFromWriteBatch()
435 if (!GetVarint32(input, column_family)) { in ReadRecordFromWriteBatch()
441 if (!GetLengthPrefixedSlice(input, key)) { in ReadRecordFromWriteBatch()
446 if (!GetVarint32(input, column_family)) { in ReadRecordFromWriteBatch()
452 if (!GetLengthPrefixedSlice(input, key) || in ReadRecordFromWriteBatch()
453 !GetLengthPrefixedSlice(input, value)) { in ReadRecordFromWriteBatch()
458 if (!GetVarint32(input, column_family)) { in ReadRecordFromWriteBatch()
463 if (!GetLengthPrefixedSlice(input, key) || in ReadRecordFromWriteBatch()
464 !GetLengthPrefixedSlice(input, value)) { in ReadRecordFromWriteBatch()
469 if (!GetVarint32(input, column_family)) { in ReadRecordFromWriteBatch()
474 if (!GetLengthPrefixedSlice(input, key) || in ReadRecordFromWriteBatch()
475 !GetLengthPrefixedSlice(input, value)) { in ReadRecordFromWriteBatch()
481 if (!GetLengthPrefixedSlice(input, blob)) { in ReadRecordFromWriteBatch()
494 if (!GetLengthPrefixedSlice(input, xid)) { in ReadRecordFromWriteBatch()
499 if (!GetLengthPrefixedSlice(input, xid)) { in ReadRecordFromWriteBatch()
504 if (!GetLengthPrefixedSlice(input, xid)) { in ReadRecordFromWriteBatch()
530 Slice input(wb->rep_.data() + begin, static_cast<size_t>(end - begin)); in Iterate() local
546 while (((s.ok() && !input.empty()) || UNLIKELY(s.IsTryAgain()))) { in Iterate()
557 s = ReadRecordFromWriteBatch(&input, &tag, &column_family, &key, &value, in Iterate()