Method Run

test/brpc_redis_unittest.cpp:1202–1231

    class MultiTransactionHandler : public brpc::RedisCommandHandler {
    public:
        brpc::RedisCommandHandlerResult Run(const std::vector<butil::StringPiece>& args,
                                            brpc::RedisReply* output,
                                            bool flush_batched) override {
            if (args[0] == "multi") {
                output->SetError("ERR duplicate multi");
                return brpc::REDIS_CMD_CONTINUE;
            }
            if (args[0] != "exec") {
                std::vector<std::string> comm;
                for (int i = 0; i < (int)args.size(); ++i) {
                    comm.push_back(args[i].as_string());
                }
                _commands.push_back(comm);
                output->SetStatus("QUEUED");
                return brpc::REDIS_CMD_CONTINUE;
            }
            output->SetArray(_commands.size());
            s_mutex.lock();
            for (size_t i = 0; i < _commands.size(); ++i) {
                if (_commands[i][0] == "incr") {
                    int64_t value;
                    value = ++int_map[_commands[i][1]];
                    (*output)[i].SetInteger(value);
                } else {
                    (*output)[i].SetStatus("unknown command");
                }
            }
            s_mutex.unlock();
            return brpc::REDIS_CMD_HANDLED;
        }
    private:
        std::vector<std::vector<std::string> > _commands;
    };