response_lrpop (LeftOrRight lr)
    {
      if (lr == IS_LEFT) {
	    setPCode (TAIR_RESP_LPOP_PACKET);
      } else {
	    setPCode (TAIR_RESP_RPOP_PACKET);
      }

      config_version = 0;
      values.clear ();
    }

    request_lrpop (LeftOrRight lr)
    {
      if (lr == IS_LEFT)
	    setPCode (TAIR_REQ_LPOP_PACKET);
      else
	    setPCode (TAIR_REQ_RPOP_PACKET);

      server_flag = 0;
      area = 0;
      version = 0;
      expire = 0;
      count = 1;
    }

 request_sadd_multi() {
     setPCode(TAIR_REQ_SADDMULTI_PACKET);
     area = 0;
     expire = 0;
     keys_values_map.clear();
     sfree = 1;
 }

 response_hmset ()
 {
   config_version = 0;
   setPCode (TAIR_RESP_HMSET_PACKET);
   code = 0;
   retvalue = 0;
 }

 response_hget ()
 {
   config_version = 0;
   setPCode (TAIR_RESP_HGET_PACKET);
   code = 0;
   version = 0;
 }

 flow_control_set() : type(tair::stat::IN),
                      lower_mb(-1),
                      upper_mb(-1),
                      ns(-1),
                      success(false) {
     setPCode(TAIR_FLOW_CONTROL_SET);
 }

 request_hvals (request_hvals & packet)
 {
   setPCode (packet.getPCode ());
   server_flag = packet.server_flag;
   area = packet.area;
   key.clone (packet.key);
 }

    request_prefix_incdec(const request_prefix_incdec &rhs) {
        setPCode(TAIR_REQ_PREFIX_INCDEC_PACKET);
        server_flag = rhs.server_flag;
        area = rhs.area;
        key_count = rhs.key_count;
        packet_id = rhs.packet_id;
        if (rhs.pkey != NULL) {
            pkey = new data_entry(*rhs.pkey);
        } else {
            pkey = NULL;
        }

        if (rhs.key_counter_map != NULL) {
            key_counter_map = new key_counter_map_t;
            key_counter_map_t::const_iterator it = rhs.key_counter_map->begin();
            while (it != rhs.key_counter_map->end()) {
                data_entry *key = new data_entry(*it->first);
                counter_wrapper *wrapper = new counter_wrapper(*it->second);
                key_counter_map->insert(make_pair(key, wrapper));
                ++it;
            }
        } else {
            key_counter_map = NULL;
        }
    }

    void clone(request_mput &packet, bool need_alloc)
    {
      if (this == &packet) {
        return ;
      }
      clear();
      setPCode(TAIR_REQ_MPUT_PACKET);
      server_flag = packet.server_flag;
      area = packet.area;
      count = packet.count;
      len = packet.len;
      compressed = packet.compressed;
      packet_data_len = packet.packet_data_len;

      if (need_alloc) {
        if (compressed) {
          packet_data = new char[packet_data_len];
          memcpy(packet_data, packet.packet_data, packet_data_len);
        }

        alloc = true;
        record_vec = new mput_record_vec();
        mput_record_vec::iterator it;
        for (it = packet.record_vec->begin(); it != packet.record_vec->end(); ++it) {
          mput_record* rec = new mput_record(**it);
          record_vec->push_back(rec);
        }
      } else {
        alloc = packet.alloc;
        record_vec = packet.record_vec;
        packet_data = packet.packet_data;
      }

      packet_id = packet.packet_id;
    }

 request_get_items(request_get_items& packet) : request_get(packet)
 {
    setPCode(TAIR_REQ_GETITEMS_PACKET);
    count = packet.count;
    offset = packet.offset;
    type = packet.type;
 }

 request_exists(const uint16_t iarea, const data_entry &ikey)
 {
   setPCode(TAIR_REQ_EXISTS_PACKET);
   server_flag = 0;
   area = iarea;
   key = ikey;
 }

    response_lrange ()
    {
      setPCode (TAIR_RESP_LRANGE_PACKET);

      config_version = 0;
      values.clear ();
    }

 request_lrange (int pcode)
 {
   setPCode (pcode);
   server_flag = 0;
   area = 0;
   start = 0;
   end = 0;
 }

 request_put()
 {
    setPCode(TAIR_REQ_PUT_PACKET);
    server_flag = 0;
    area = 0;
    version = 0;
    expired = 0;
 }

 request_mupdate()
 {
    setPCode(TAIR_REQ_MUPDATE_PACKET);
    server_flag = 0;
    count = 0;
    len = 8;
    key_and_values = NULL;
 }

    request_zrevrank (request_zrevrank & packet)
    {
      setPCode (packet.getPCode ());
      server_flag = packet.server_flag;
      area = packet.area;

      key.clone (packet.key);
    }

 request_prefix_puts() {
   setPCode(TAIR_REQ_PREFIX_PUTS_PACKET);
   area = 0;
   key_count = 0;
   packet_id = 0;
   pkey = NULL;
   kvmap = NULL;
 }

 request_sadd()
 {
   setPCode(TAIR_REQ_SADD_PACKET);
   server_flag = 0;
   area = 0;
   version = 0;
   expire = 0;
 }

 request_expire (request_expire & packet)
 {
   setPCode (packet.getPCode ());
   server_flag = packet.server_flag;
   area = packet.area;
   expiretime = packet.expiretime;
   key.clone (packet.key);
 }

    request_persist (request_persist & packet)
    {
      setPCode (packet.getPCode ());
      server_flag = packet.server_flag;
      area = packet.area;

      key.clone (packet.key);
    }