Method Run

test/brpc_redis_unittest.cpp:913–930

        : _rs(rs) {}    

    brpc::RedisCommandHandlerResult Run(brpc::RedisConnContext* ctx,
                                        const std::vector<butil::StringPiece>& args,
                                        brpc::RedisReply* output,
                                        bool flush_batched) {
        if (args.size() < 1) {
            output->SetError("ERR wrong number of arguments for 'AUTH' command");
            return brpc::REDIS_CMD_HANDLED;
        }
        const std::string password(args[1].data(), args[1].size());
        if (_rs->_password != password) {
            output->SetError("ERR invalid username/password");
            return brpc::REDIS_CMD_HANDLED;
        }
        auto auth_session = new AuthSession(password);
        ctx->reset_session(auth_session);
        output->SetStatus("OK");
        return brpc::REDIS_CMD_HANDLED;
    }

private:
    RedisServiceImpl* _rs;