Commit ea7605d3 authored by zhujiashun's avatar zhujiashun

redis_server_protocol: update redis-server

parent 038228d3
...@@ -60,19 +60,19 @@ public: ...@@ -60,19 +60,19 @@ public:
GetCommandHandler(RedisServiceImpl* rsimpl) GetCommandHandler(RedisServiceImpl* rsimpl)
: _rsimpl(rsimpl) {} : _rsimpl(rsimpl) {}
brpc::RedisCommandHandler::Result Run(const std::vector<std::string>& commands, brpc::RedisCommandHandler::Result Run(int size, const char* args[],
brpc::RedisReply* output, brpc::RedisReply* output,
bool is_last) override { bool is_last) override {
if ((int)commands.size() <= 1) { if (size <= 1) {
output->SetError("ERR wrong number of arguments for 'get' command"); output->SetError("ERR wrong number of arguments for 'get' command");
return brpc::RedisCommandHandler::OK; return brpc::RedisCommandHandler::OK;
} }
const std::string& key = commands[1]; const std::string key(args[1]);
std::string value; std::string value;
if (_rsimpl->Get(key, &value)) { if (_rsimpl->Get(key, &value)) {
output->SetString(value); output->SetString(value);
} else { } else {
output->SetNilString(); output->SetNullString();
} }
return brpc::RedisCommandHandler::OK; return brpc::RedisCommandHandler::OK;
} }
...@@ -86,15 +86,15 @@ public: ...@@ -86,15 +86,15 @@ public:
SetCommandHandler(RedisServiceImpl* rsimpl) SetCommandHandler(RedisServiceImpl* rsimpl)
: _rsimpl(rsimpl) {} : _rsimpl(rsimpl) {}
brpc::RedisCommandHandler::Result Run(const std::vector<std::string>& commands, brpc::RedisCommandHandler::Result Run(int size, const char* args[],
brpc::RedisReply* output, brpc::RedisReply* output,
bool is_last) override { bool is_last) override {
if ((int)commands.size() <= 2) { if (size <= 2) {
output->SetError("ERR wrong number of arguments for 'set' command"); output->SetError("ERR wrong number of arguments for 'set' command");
return brpc::RedisCommandHandler::OK; return brpc::RedisCommandHandler::OK;
} }
const std::string& key = commands[1]; const std::string key(args[1]);
const std::string& value = commands[2]; const std::string value(args[2]);
_rsimpl->Set(key, value); _rsimpl->Set(key, value);
output->SetStatus("OK"); output->SetStatus("OK");
return brpc::RedisCommandHandler::OK; return brpc::RedisCommandHandler::OK;
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment