LevelDB project 1 10225501460 林子骥 10211900416 郭夏辉
You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

129 lines
5.0 KiB

1 month ago
1 month ago
1 month ago
1 month ago
  1. // Copyright (c) 2011 The LevelDB Authors. All rights reserved.
  2. // Use of this source code is governed by a BSD-style license that can be
  3. // found in the LICENSE file. See the AUTHORS file for names of contributors.
  4. //
  5. // Endian-neutral encoding:
  6. // * Fixed-length numbers are encoded with least-significant byte first
  7. // * In addition we support variable length "varint" encoding
  8. // * Strings are encoded prefixed by their length in varint format
  9. #ifndef STORAGE_LEVELDB_UTIL_CODING_H_
  10. #define STORAGE_LEVELDB_UTIL_CODING_H_
  11. #include <cstdint>
  12. #include <cstring>
  13. #include <iomanip>
  14. #include <iostream>
  15. #include <string>
  16. #include "leveldb/slice.h"
  17. #include "port/port.h"
  18. namespace leveldb {
  19. // Standard Put... routines append to a string
  20. void PutFixed32(std::string* dst, uint32_t value);
  21. void PutFixed64(std::string* dst, uint64_t value);
  22. void PutVarint32(std::string* dst, uint32_t value);
  23. void PutVarint64(std::string* dst, uint64_t value);
  24. void PutLengthPrefixedSlice(std::string* dst, const Slice& value);
  25. // Standard Get... routines parse a value from the beginning of a Slice
  26. // and advance the slice past the parsed value.
  27. bool GetVarint32(Slice* input, uint32_t* value);
  28. bool GetVarint64(Slice* input, uint64_t* value);
  29. bool GetLengthPrefixedSlice(Slice* input, Slice* result);
  30. // Pointer-based variants of GetVarint... These either store a value
  31. // in *v and return a pointer just past the parsed value, or return
  32. // nullptr on error. These routines only look at bytes in the range
  33. // [p..limit-1]
  34. const char* GetVarint32Ptr(const char* p, const char* limit, uint32_t* v);
  35. const char* GetVarint64Ptr(const char* p, const char* limit, uint64_t* v);
  36. // Returns the length of the varint32 or varint64 encoding of "v"
  37. int VarintLength(uint64_t v);
  38. // Lower-level versions of Put... that write directly into a character buffer
  39. // and return a pointer just past the last byte written.
  40. // REQUIRES: dst has enough space for the value being written
  41. char* EncodeVarint32(char* dst, uint32_t value);
  42. char* EncodeVarint64(char* dst, uint64_t value);
  43. // Lower-level versions of Put... that write directly into a character buffer
  44. // REQUIRES: dst has enough space for the value being written
  45. inline void EncodeFixed32(char* dst, uint32_t value) {
  46. uint8_t* const buffer = reinterpret_cast<uint8_t*>(dst);
  47. // Recent clang and gcc optimize this to a single mov / str instruction.
  48. buffer[0] = static_cast<uint8_t>(value);
  49. buffer[1] = static_cast<uint8_t>(value >> 8);
  50. buffer[2] = static_cast<uint8_t>(value >> 16);
  51. buffer[3] = static_cast<uint8_t>(value >> 24);
  52. }
  53. inline void EncodeFixed64(char* dst, uint64_t value) {
  54. uint8_t* const buffer = reinterpret_cast<uint8_t*>(dst);
  55. // Recent clang and gcc optimize this to a single mov / str instruction.
  56. buffer[0] = static_cast<uint8_t>(value);
  57. buffer[1] = static_cast<uint8_t>(value >> 8);
  58. buffer[2] = static_cast<uint8_t>(value >> 16);
  59. buffer[3] = static_cast<uint8_t>(value >> 24);
  60. buffer[4] = static_cast<uint8_t>(value >> 32);
  61. buffer[5] = static_cast<uint8_t>(value >> 40);
  62. buffer[6] = static_cast<uint8_t>(value >> 48);
  63. buffer[7] = static_cast<uint8_t>(value >> 56);
  64. }
  65. // Lower-level versions of Get... that read directly from a character buffer
  66. // without any bounds checking.
  67. inline uint32_t DecodeFixed32(const char* ptr) {
  68. const uint8_t* const buffer = reinterpret_cast<const uint8_t*>(ptr);
  69. // Recent clang and gcc optimize this to a single mov / ldr instruction.
  70. return (static_cast<uint32_t>(buffer[0])) |
  71. (static_cast<uint32_t>(buffer[1]) << 8) |
  72. (static_cast<uint32_t>(buffer[2]) << 16) |
  73. (static_cast<uint32_t>(buffer[3]) << 24);
  74. }
  75. inline uint64_t DecodeFixed64(const char* ptr) {
  76. const uint8_t* const buffer = reinterpret_cast<const uint8_t*>(ptr);
  77. // std::cout << "in decode, ptr in hex: ";
  78. // for (size_t i = 0; i < 8; ++i) { // 输出8个字节
  79. // std::cout << std::hex << std::setw(2) << std::setfill('0') << (int)buffer[i] << " ";
  80. // }
  81. // std::cout << std::endl;
  82. // Recent clang and gcc optimize this to a single mov / ldr instruction.
  83. return (static_cast<uint64_t>(buffer[0])) |
  84. (static_cast<uint64_t>(buffer[1]) << 8) |
  85. (static_cast<uint64_t>(buffer[2]) << 16) |
  86. (static_cast<uint64_t>(buffer[3]) << 24) |
  87. (static_cast<uint64_t>(buffer[4]) << 32) |
  88. (static_cast<uint64_t>(buffer[5]) << 40) |
  89. (static_cast<uint64_t>(buffer[6]) << 48) |
  90. (static_cast<uint64_t>(buffer[7]) << 56);
  91. }
  92. // Internal routine for use by fallback path of GetVarint32Ptr
  93. const char* GetVarint32PtrFallback(const char* p, const char* limit,
  94. uint32_t* value);
  95. inline const char* GetVarint32Ptr(const char* p, const char* limit,
  96. uint32_t* value) {
  97. if (p < limit) {
  98. uint32_t result = *(reinterpret_cast<const uint8_t*>(p));
  99. if ((result & 128) == 0) {
  100. *value = result;
  101. return p + 1;
  102. }
  103. }
  104. return GetVarint32PtrFallback(p, limit, value);
  105. }
  106. } // namespace leveldb
  107. #endif // STORAGE_LEVELDB_UTIL_CODING_H_