mirror of
https://fuchsia.googlesource.com/third_party/pigweed.googlesource.com/pigweed/pigweed
synced 2024-09-21 14:16:26 +00:00
88adfe8b91
- Move EntryHeaderFormat and the EntryHeader struct to pw_kvs/format.h. - Rename EntryHeaderFormat to EntryFormat. Change-Id: Ic5e53c688cd3a483101c7985def6e4bef9c3cbaf
117 lines
3.4 KiB
C++
117 lines
3.4 KiB
C++
// Copyright 2020 The Pigweed Authors
|
|
//
|
|
// Licensed under the Apache License, Version 2.0 (the "License"); you may not
|
|
// use this file except in compliance with the License. You may obtain a copy of
|
|
// the License at
|
|
//
|
|
// https://www.apache.org/licenses/LICENSE-2.0
|
|
//
|
|
// Unless required by applicable law or agreed to in writing, software
|
|
// distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
|
|
// WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
|
|
// License for the specific language governing permissions and limitations under
|
|
// the License.
|
|
|
|
#include <iostream>
|
|
#include <sstream>
|
|
#include <string>
|
|
|
|
#include "pw_kvs/crc16_checksum.h"
|
|
#include "pw_kvs/in_memory_fake_flash.h"
|
|
#include "pw_kvs/key_value_store.h"
|
|
|
|
namespace pw::kvs {
|
|
namespace {
|
|
|
|
using std::byte;
|
|
|
|
ChecksumCrc16 checksum;
|
|
constexpr EntryFormat format{.magic = 0xBAD'C0D3, .checksum = &checksum};
|
|
|
|
constexpr char kHelpText[] = R"(
|
|
pw_kvs debug CLI
|
|
|
|
Commands:
|
|
|
|
init Initializes the KVS
|
|
put KEY VALUE Sets a key to a specified value
|
|
get KEY Looks up the value for a key
|
|
delete KEY Deletes a key from the KVS
|
|
contents Prints the contents of the KVS
|
|
quit Exits the CLI
|
|
)";
|
|
|
|
void Run() {
|
|
// 4 x 4k sectors, 16 byte alignment
|
|
FakeFlashBuffer<4 * 1024, 4> test_flash(16);
|
|
|
|
FlashPartition test_partition(&test_flash, 0, test_flash.sector_count());
|
|
test_partition.Erase(0, test_partition.sector_count());
|
|
|
|
KeyValueStoreBuffer<256, 256> kvs(&test_partition, format);
|
|
kvs.Init();
|
|
|
|
while (true) {
|
|
printf("\n> ");
|
|
fflush(stdout);
|
|
|
|
std::string line;
|
|
if (!std::getline(std::cin, line)) {
|
|
putchar('\n');
|
|
break;
|
|
}
|
|
|
|
std::istringstream data(line);
|
|
std::string cmd, key, value;
|
|
data >> cmd >> key >> value;
|
|
|
|
if (cmd == "init") {
|
|
printf("Init() -> %s\n", kvs.Init().str());
|
|
} else if (cmd == "delete" || cmd == "d") {
|
|
printf("Delete(\"%s\") -> %s\n", key.c_str(), kvs.Delete(key).str());
|
|
} else if (cmd == "put" || cmd == "p") {
|
|
printf("Put(\"%s\", \"%s\") -> %s\n",
|
|
key.c_str(),
|
|
value.c_str(),
|
|
kvs.Put(key, as_bytes(span(value))).str());
|
|
} else if (cmd == "get" || cmd == "g") {
|
|
byte buffer[128] = {};
|
|
Status status = kvs.Get(key, buffer).status();
|
|
printf("Get(\"%s\") -> %s\n", key.c_str(), status.str());
|
|
if (status.ok()) {
|
|
printf(" Key: \"%s\"\n", key.c_str());
|
|
printf("Value: \"%s\"\n", reinterpret_cast<const char*>(buffer));
|
|
}
|
|
} else if (cmd == "contents" || cmd == "c") {
|
|
int i = 0;
|
|
printf("KVS CONTENTS ----------------------------------------------\n");
|
|
for (auto& entry : kvs) {
|
|
char value[64] = {};
|
|
if (StatusWithSize result = entry.Get(as_writable_bytes(span(value)));
|
|
result.ok()) {
|
|
printf("%2d: %s='%s'\n", ++i, entry.key(), value);
|
|
} else {
|
|
printf(
|
|
"FAILED to Get key %s: %s\n", entry.key(), result.status().str());
|
|
}
|
|
}
|
|
printf("---------------------------------------------- END CONTENTS\n");
|
|
} else if (cmd == "help" || cmd == "h") {
|
|
printf("%s", kHelpText);
|
|
} else if (cmd == "quit" || cmd == "q") {
|
|
break;
|
|
} else {
|
|
printf("Unrecognized command: %s\n", cmd.c_str());
|
|
printf("Type 'help' for options\n");
|
|
}
|
|
}
|
|
}
|
|
|
|
} // namespace
|
|
} // namespace pw::kvs
|
|
|
|
int main() {
|
|
pw::kvs::Run();
|
|
return 0;
|
|
}
|