acl::redis_pipeline_message类 参考

#include <redis_client_pipeline.hpp>

acl::redis_pipeline_message 的协作图:

Public 成员函数
	redis_pipeline_message (redis_command *cmd, redis_pipeline_type_t type, bool use_mbox=true)
	~redis_pipeline_message (void)
redis_pipeline_message &	set_type (redis_pipeline_type_t type)
redis_pipeline_type_t	get_type (void) const
redis_command *	get_cmd (void)
void	set_option (size_t nchild, int *timeout)
void	set_request (size_t argc, const char **argv, size_t *lens)
void	set_addr (const char *addr)
size_t	get_nchild (void) const
int *	get_timeout (void) const
void	push (const redis_result *result)
const redis_result *	wait (void)
const char *	get_addr (void) const
size_t	get_redirect_count (void) const

Public 属性
size_t	argc_
const char **	argv_
size_t *	lens_

详细描述

the message for transfering between redis command, redis client pipline and redis pipeline channel, which holds the redis command or not.

在文件 redis_client_pipeline.hpp 第 35 行定义.

构造及析构函数说明

redis_pipeline_message()

acl::redis_pipeline_message::redis_pipeline_message ( redis_command *  cmd, redis_pipeline_type_t  type, bool  use_mbox = true  )

inline

在文件 redis_client_pipeline.hpp 第 37 行定义.

        : cmd_(cmd)
        , type_(type)
        , nchild_(0)
        , timeout_(NULL)
        , result_(NULL)
        , addr_(NULL)
        , redirect_count_(0)
        , argc_(0)
        , argv_(NULL)
        , lens_(NULL)
        {
                if (use_mbox) {
                        mbox_ = new mbox<redis_pipeline_message>(false, false);
                        tbox_ = NULL;
                } else {
                        tbox_ = new tbox<redis_pipeline_message>(false);
                        mbox_ = NULL;
                }
        }

~redis_pipeline_message()

acl::redis_pipeline_message::~redis_pipeline_message ( void  )

inline

在文件 redis_client_pipeline.hpp 第 59 行定义.

                                      {
                delete mbox_;
                delete tbox_;
        }

成员函数说明

get_addr()

const char* acl::redis_pipeline_message::get_addr ( void  ) const

inline

在文件 redis_client_pipeline.hpp 第 124 行定义.

                                         {
                return addr_;
        }

get_cmd()

redis_command* acl::redis_pipeline_message::get_cmd ( void  )

inline

在文件 redis_client_pipeline.hpp 第 73 行定义.

                                     {
                return cmd_;
        }

get_nchild()

size_t acl::redis_pipeline_message::get_nchild ( void  ) const

inline

在文件 redis_client_pipeline.hpp 第 98 行定义.

                                      {
                return nchild_;
        }

get_redirect_count()

size_t acl::redis_pipeline_message::get_redirect_count ( void  ) const

inline

在文件 redis_client_pipeline.hpp 第 128 行定义.

                                              {
                return redirect_count_;
        }

get_timeout()

int* acl::redis_pipeline_message::get_timeout ( void  ) const

inline

在文件 redis_client_pipeline.hpp 第 102 行定义.

                                     {
                return timeout_;
        }

get_type()

redis_pipeline_type_t acl::redis_pipeline_message::get_type ( void  ) const

inline

在文件 redis_client_pipeline.hpp 第 69 行定义.

                                                   {
                return type_;
        }

push()

void acl::redis_pipeline_message::push ( const redis_result *  result )

inline

在文件 redis_client_pipeline.hpp 第 106 行定义.

                                              {
                result_ = result;
                if (mbox_) {
                        mbox_->push(this, false);
                } else {
                        tbox_->push(this, false);
                }
        }

set_addr()

void acl::redis_pipeline_message::set_addr ( const char *  addr )

inline

在文件 redis_client_pipeline.hpp 第 91 行定义.

                                        {
                addr_ = addr;
                if (addr) {
                        redirect_count_++;
                }
        }

set_option()

void acl::redis_pipeline_message::set_option ( size_t  nchild, int *  timeout  )

inline

在文件 redis_client_pipeline.hpp 第 77 行定义.

                                                     {
                nchild_  = nchild;
                timeout_ = timeout;
                result_  = NULL;
                addr_    = NULL;
                redirect_count_ = 0;
        }

set_request()

void acl::redis_pipeline_message::set_request ( size_t  argc, const char **  argv, size_t *  lens  )

inline

在文件 redis_client_pipeline.hpp 第 85 行定义.

                                                                       {
                argc_    = argc;
                argv_    = argv;
                lens_    = lens;
        }

引用了 argc_, argv_ , 以及 lens_.

set_type()

redis_pipeline_message& acl::redis_pipeline_message::set_type ( redis_pipeline_type_t  type )

inline

在文件 redis_client_pipeline.hpp 第 64 行定义.

                                                                     {
                type_ = type;
                return *this;
        }

wait()

const redis_result* acl::redis_pipeline_message::wait ( void  )

inline

在文件 redis_client_pipeline.hpp 第 115 行定义.

                                       {
                if (mbox_) {
                        mbox_->pop();
                } else {
                        tbox_->pop();
                }
                return result_;
        }

类成员变量说明

argc_

size_t acl::redis_pipeline_message::argc_

在文件 redis_client_pipeline.hpp 第 145 行定义.

被这些函数引用 set_request().

argv_

const char** acl::redis_pipeline_message::argv_

在文件 redis_client_pipeline.hpp 第 146 行定义.

被这些函数引用 set_request().

lens_

size_t* acl::redis_pipeline_message::lens_

在文件 redis_client_pipeline.hpp 第 147 行定义.

被这些函数引用 set_request().

---

该类的文档由以下文件生成:

• include/acl_cpp/redis/redis_client_pipeline.hpp