|
|
|
@ -34,9 +34,9 @@ using grpc::ServerBuilder; |
|
|
|
|
using grpc::ServerContext; |
|
|
|
|
using grpc::ServerReaderWriter; |
|
|
|
|
using grpc::Status; |
|
|
|
|
using keyvaluestore::KeyValueStore; |
|
|
|
|
using keyvaluestore::Request; |
|
|
|
|
using keyvaluestore::Response; |
|
|
|
|
using keyvaluestore::KeyValueStore; |
|
|
|
|
|
|
|
|
|
struct kv_pair { |
|
|
|
|
const char* key; |
|
|
|
@ -44,16 +44,13 @@ struct kv_pair { |
|
|
|
|
}; |
|
|
|
|
|
|
|
|
|
static const kv_pair kvs_map[] = { |
|
|
|
|
{"key1", "value1"}, |
|
|
|
|
{"key2", "value2"}, |
|
|
|
|
{"key3", "value3"}, |
|
|
|
|
{"key4", "value4"}, |
|
|
|
|
{"key5", "value5"}, |
|
|
|
|
{"key1", "value1"}, {"key2", "value2"}, {"key3", "value3"}, |
|
|
|
|
{"key4", "value4"}, {"key5", "value5"}, |
|
|
|
|
}; |
|
|
|
|
|
|
|
|
|
const char * get_value_from_map(const char* key) { |
|
|
|
|
for(size_t i = 0; i < sizeof(kvs_map) / sizeof(kv_pair); ++i) { |
|
|
|
|
if(strcmp(key, kvs_map[i].key) == 0) { |
|
|
|
|
const char* get_value_from_map(const char* key) { |
|
|
|
|
for (size_t i = 0; i < sizeof(kvs_map) / sizeof(kv_pair); ++i) { |
|
|
|
|
if (strcmp(key, kvs_map[i].key) == 0) { |
|
|
|
|
return kvs_map[i].value; |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
@ -62,9 +59,10 @@ const char * get_value_from_map(const char* key) { |
|
|
|
|
|
|
|
|
|
// Logic and data behind the server's behavior.
|
|
|
|
|
class KeyValueStoreServiceImpl final : public KeyValueStore::Service { |
|
|
|
|
Status GetValues(ServerContext* context, ServerReaderWriter<Response, Request> *stream) override { |
|
|
|
|
Status GetValues(ServerContext* context, |
|
|
|
|
ServerReaderWriter<Response, Request>* stream) override { |
|
|
|
|
Request request; |
|
|
|
|
while(stream->Read(&request)) { |
|
|
|
|
while (stream->Read(&request)) { |
|
|
|
|
Response response; |
|
|
|
|
response.set_value(get_value_from_map(request.key().c_str())); |
|
|
|
|
stream->Write(response); |
|
|
|
|