/* packet-couchbase.c

 *

 * Routines for Couchbase Protocol

 *

 * Copyright 2019, Trond Norbye <trond@couchbase.com>

 * Copyright 2018, Jim Walker <jim@couchbase.com>

 * Copyright 2015-2016, Dave Rigby <daver@couchbase.com>

 * Copyright 2011, Sergey Avseyev <sergey.avseyev@gmail.com>

 *

 * With contributions from Mark Woosey <mark@markwoosey.com>

 *

 *

 * Based on packet-memcache.c: mecmcache binary protocol.

 *

 * Routines for Memcache Binary Protocol

 * http://code.google.com/p/memcached/wiki/MemcacheBinaryProtocol

 *

 * Copyright 2009, Stig Bjorlykke <stig@bjorlykke.org>

 *

 * Routines for Memcache Textual Protocol

 * https://github.com/memcached/memcached/blob/master/doc/protocol.txt

 *

 * Copyright 2009, Rama Chitta <rama@gear6.com>

 *

 * Wireshark - Network traffic analyzer

 * By Gerald Combs <gerald@wireshark.org>

 * Copyright 1998 Gerald Combs

 *

 * SPDX-License-Identifier: GPL-2.0-or-later

 */

#include "config.h"

#include <epan/packet.h>

#include <epan/prefs.h>

#include <epan/expert.h>

#include <epan/tfs.h>

#include <epan/unit_strings.h>

#ifdef HAVE_SNAPPY

#include <snappy-c.h>

#endif

#include "packet-tcp.h"

#include "packet-tls.h"

#include <math.h>

#define COUCHBASE_DEFAULT_PORT        "11210"

#define COUCHBASE_HEADER_LEN   24

/* Magic Byte */

enum {

  /**

   * The magic used for a normal request sent from the client to the

   * server. Layout described in:

   * https://github.com/couchbase/kv_engine/blob/master/docs/BinaryProtocol.md#request-header

   */

  MAGIC_CLIENT_REQUEST = 0x80,

  /**

   * The magic used for a normal response sent from the server to

   * the client. Layout described in:

   * https://github.com/couchbase/kv_engine/blob/master/docs/BinaryProtocol.md#response-header

   */

  MAGIC_CLIENT_RESPONSE = 0x81,

  /**

   * The magic used when the client want to inject a set of extensions

   * to the command sent to the server. Layout described in:

   * https://github.com/couchbase/kv_engine/blob/master/docs/BinaryProtocol.md#request-header-with-flexible-framing-extras

   */

  MAGIC_CLIENT_RESPONSE_FLEX = 0x18,

  /**

   * The magic used by the server when the server needs to inject a set of

   * extensions in the response packet. Layout described in:

   * https://github.com/couchbase/kv_engine/blob/master/docs/BinaryProtocol.md#response-header-with-flexible-framing-extras

   */

  MAGIC_CLIENT_REQUEST_FLEX = 0x08,

  /**

   * The magic used for server initiated push requests. These packets

   * use the same layout as client flex request packets (with a different

   * namespace for the frame id's)

   */

  MAGIC_SERVER_REQUEST = 0x82,

  /**

   * The magic used for responses to server initiated push requests. These

   * packets use the same layout as client flex response packet (with

   * a different namespace for the frame id's)

   */

  MAGIC_SERVER_RESPONSE = 0x83

};

/** Does the magic represent a flex encoded packet type */

static bool is_flex_encoded(uint8_t magic) {

  switch (magic) {

    case MAGIC_CLIENT_RESPONSE_FLEX:

    case MAGIC_CLIENT_REQUEST_FLEX:

    case MAGIC_SERVER_REQUEST:

    case MAGIC_SERVER_RESPONSE:

      return true;

    case MAGIC_CLIENT_REQUEST:

    case MAGIC_CLIENT_RESPONSE:

    default:

      return false;

  }

}

/** Does the magic represent server initiated packet types */

static bool is_server_magic(uint8_t magic) {

  switch (magic) {

    case MAGIC_SERVER_REQUEST:

    case MAGIC_SERVER_RESPONSE:

      return true;

    case MAGIC_CLIENT_RESPONSE_FLEX:

    case MAGIC_CLIENT_REQUEST_FLEX:

    case MAGIC_CLIENT_REQUEST:

    case MAGIC_CLIENT_RESPONSE:

    default:

      return false;

  }

}

/** Does the magic represent a request or a response */

static bool is_request_magic(uint8_t magic) {

  switch (magic) {

    case MAGIC_SERVER_REQUEST:

    case MAGIC_CLIENT_REQUEST_FLEX:

    case MAGIC_CLIENT_REQUEST:

      return true;

    case MAGIC_SERVER_RESPONSE:

    case MAGIC_CLIENT_RESPONSE_FLEX:

    case MAGIC_CLIENT_RESPONSE:

    default:

      return false;

  }

}

 /* Response Status */

#define STATUS_SUCCESS            0x00

#define STATUS_KEY_ENOENT         0x01

#define STATUS_KEY_EEXISTS        0x02

#define STATUS_E2BIG              0x03

#define STATUS_EINVAL             0x04

#define STATUS_NOT_STORED         0x05

#define STATUS_DELTA_BADVAL       0x06

#define STATUS_NOT_MY_VBUCKET     0x07

#define STATUS_NO_VBUCKET         0x08

#define STATUS_LOCKED             0x09

#define STATUS_DCP_STREAM_NOT_FOUND 0x0a

#define STATUS_OPAQUE_NO_MATCH    0x0b

#define STATUS_EWOULDTHROTTLE     0x0c

#define STATUS_ECONFIGONLY        0x0d

#define STATUS_NOT_LOCKED         0x0e

#define STATUS_AUTH_STALE         0x1f

#define STATUS_AUTH_ERROR         0x20

#define STATUS_AUTH_CONTINUE      0x21

#define STATUS_ERANGE             0x22

#define STATUS_ROLLBACK           0x23

#define STATUS_EACCESS            0x24

#define STATUS_NOT_INITIALIZED    0x25

#define STATUS_RATELIMITED_NETWORK_INGRESS 0x30

#define STATUS_RATELIMITED_NETWORK_EGRESS 0x31

#define STATUS_RATELIMITED_MAX_CONNECTIONS 0x32

#define STATUS_RATELIMITED_MAX_COMMANDS 0x33

#define STATUS_SCOPE_SIZE_LIMIT_EXCEEDED 0x34

#define STATUS_UNKNOWN_COMMAND    0x81

#define STATUS_ENOMEM             0x82

#define STATUS_NOT_SUPPORTED      0x83

#define STATUS_EINTERNAL          0x84

#define STATUS_EBUSY              0x85

#define STATUS_ETMPFAIL           0x86

#define STATUS_XATTR_EINVAL       0x87

#define STATUS_UNKNOWN_COLLECTION         0x88

#define STATUS_NO_COLLECTIONS_MANIFEST    0x89

#define STATUS_CANNOT_APPLY_MANIFEST      0x8a

#define STATUS_MANIFEST_IS_AHEAD          0x8b

#define STATUS_UNKNOWN_SCOPE              0x8c

#define STATUS_DCP_STREAMID_INVALID       0x8d

#define STATUS_DURABILITY_INVALID_LEVEL         0xa0

#define STATUS_DURABILITY_IMPOSSIBLE            0xa1

#define STATUS_SYNC_WRITE_IN_PROGRESS           0xa2

#define STATUS_SYNC_WRITE_AMBIGUOUS             0xa3

#define STATUS_SYNC_WRITE_RECOMMIT_IN_PROGRESS  0xa4

#define STATUS_RANGE_SCAN_CANCELLED 0xa5

#define STATUS_RANGE_SCAN_MORE 0xa6

#define STATUS_RANGE_SCAN_COMPLETE 0xa7

#define STATUS_VBUUID_NOT_EQUAL 0xa8

#define STATUS_SUBDOC_PATH_ENOENT         0xc0

#define STATUS_SUBDOC_PATH_MISMATCH       0xc1

#define STATUS_SUBDOC_PATH_EINVAL         0xc2

#define STATUS_SUBDOC_PATH_E2BIG          0xc3

#define STATUS_SUBDOC_DOC_E2DEEP          0xc4

#define STATUS_SUBDOC_VALUE_CANTINSERT    0xc5

#define STATUS_SUBDOC_DOC_NOTJSON         0xc6

#define STATUS_SUBDOC_NUM_ERANGE          0xc7

#define STATUS_SUBDOC_DELTA_ERANGE        0xc8

#define STATUS_SUBDOC_PATH_EEXISTS        0xc9

#define STATUS_SUBDOC_VALUE_ETOODEEP      0xca

#define STATUS_SUBDOC_INVALID_COMBO       0xcb

#define STATUS_SUBDOC_MULTI_PATH_FAILURE  0xcc

#define STATUS_SUBDOC_SUCCESS_DELETED            0xcd

#define STATUS_SUBDOC_XATTR_INVALID_FLAG_COMBO   0xce

#define STATUS_SUBDOC_XATTR_INVALID_KEY_COMBO    0xcf

#define STATUS_SUBDOC_XATTR_UNKNOWN_MACRO        0xd0

#define STATUS_SUBDOC_XATTR_UNKNOWN_VATTR        0xd1

#define STATUS_SUBDOC_XATTR_CANT_MODIFY_VATTR    0xd2

#define STATUS_SUBDOC_MULTI_PATH_FAILURE_DELETED 0xd3

#define STATUS_SUBDOC_INVALID_XATTR_ORDER        0xd4

#define STATUS_SUBDOC_XATTR_UNKNOWN_VATTR_MACRO  0xd5

#define STATUS_SUBDOC_CAN_ONLY_REVIVE_DELETED_DOCUMENTS 0xd6

#define STATUS_SUBDOC_DELETED_DOCUMENT_CANT_HAVE_VALUE  0xd7

 /* Command Opcodes */

#define CLIENT_OPCODE_GET                     0x00

#define CLIENT_OPCODE_SET                     0x01

#define CLIENT_OPCODE_ADD                     0x02

#define CLIENT_OPCODE_REPLACE                 0x03

#define CLIENT_OPCODE_DELETE                  0x04

#define CLIENT_OPCODE_INCREMENT               0x05

#define CLIENT_OPCODE_DECREMENT               0x06

#define CLIENT_OPCODE_QUIT                    0x07

#define CLIENT_OPCODE_FLUSH                   0x08

#define CLIENT_OPCODE_GETQ                    0x09

#define CLIENT_OPCODE_NOOP                    0x0a

#define CLIENT_OPCODE_VERSION                 0x0b

#define CLIENT_OPCODE_GETK                    0x0c

#define CLIENT_OPCODE_GETKQ                   0x0d

#define CLIENT_OPCODE_APPEND                  0x0e

#define CLIENT_OPCODE_PREPEND                 0x0f

#define CLIENT_OPCODE_STAT                    0x10

#define CLIENT_OPCODE_SETQ                    0x11

#define CLIENT_OPCODE_ADDQ                    0x12

#define CLIENT_OPCODE_REPLACEQ                0x13

#define CLIENT_OPCODE_DELETEQ                 0x14

#define CLIENT_OPCODE_INCREMENTQ              0x15

#define CLIENT_OPCODE_DECREMENTQ              0x16

#define CLIENT_OPCODE_QUITQ                   0x17

#define CLIENT_OPCODE_FLUSHQ                  0x18

#define CLIENT_OPCODE_APPENDQ                 0x19

#define CLIENT_OPCODE_PREPENDQ                0x1a

#define CLIENT_OPCODE_VERBOSITY               0x1b

#define CLIENT_OPCODE_TOUCH                   0x1c

#define CLIENT_OPCODE_GAT                     0x1d

#define CLIENT_OPCODE_GATQ                    0x1e

#define CLIENT_OPCODE_HELLO                   0x1f

 /* SASL operations */

#define CLIENT_OPCODE_SASL_LIST_MECHS         0x20

#define CLIENT_OPCODE_SASL_AUTH               0x21

#define CLIENT_OPCODE_SASL_STEP               0x22

/* Control */

#define CLIENT_OPCODE_IOCTL_GET               0x23

#define CLIENT_OPCODE_IOCTL_SET               0x24

#define CLIENT_OPCODE_CONFIG_VALIDATE         0x25

#define CLIENT_OPCODE_CONFIG_RELOAD           0x26

#define CLIENT_OPCODE_AUDIT_PUT               0x27

#define CLIENT_OPCODE_AUDIT_CONFIG_RELOAD     0x28

#define CLIENT_OPCODE_SHUTDOWN                0x29

#define CLIENT_OPCODE_SET_ACTIVE_ENCRYPTION_KEYS 0x2d

#define CLIENT_OPCODE_PRUNE_ENCRYPTION_KEYS   0x2e

 /* Range operations.

  * These commands are used for range operations and exist within

  * protocol_binary.h for use in other projects. Range operations are

  * not expected to be implemented in the memcached server itself.

  */

#define CLIENT_OPCODE_RGET                    0x30

#define CLIENT_OPCODE_RSET                    0x31

#define CLIENT_OPCODE_RSETQ                   0x32

#define CLIENT_OPCODE_RAPPEND                 0x33

#define CLIENT_OPCODE_RAPPENDQ                0x34

#define CLIENT_OPCODE_RPREPEND                0x35

#define CLIENT_OPCODE_RPREPENDQ               0x36

#define CLIENT_OPCODE_RDELETE                 0x37

#define CLIENT_OPCODE_RDELETEQ                0x38

#define CLIENT_OPCODE_RINCR                   0x39

#define CLIENT_OPCODE_RINCRQ                  0x3a

#define CLIENT_OPCODE_RDECR                   0x3b

#define CLIENT_OPCODE_RDECRQ                  0x3c

 /* VBucket commands */

#define CLIENT_OPCODE_SET_VBUCKET             0x3d

#define CLIENT_OPCODE_GET_VBUCKET             0x3e

#define CLIENT_OPCODE_DEL_VBUCKET             0x3f

 /* TAP commands */

#define CLIENT_OPCODE_TAP_CONNECT             0x40

#define CLIENT_OPCODE_TAP_MUTATION            0x41

#define CLIENT_OPCODE_TAP_DELETE              0x42

#define CLIENT_OPCODE_TAP_FLUSH               0x43

#define CLIENT_OPCODE_TAP_OPAQUE              0x44

#define CLIENT_OPCODE_TAP_VBUCKET_SET         0x45

#define CLIENT_OPCODE_TAP_CHECKPOINT_START    0x46

#define CLIENT_OPCODE_TAP_CHECKPOINT_END      0x47

#define CLIENT_OPCODE_GET_ALL_VB_SEQNOS       0x48

#define CLIENT_OPCODE_GET_EX                  0x49

#define CLIENT_OPCODE_GET_EX_REPLICA          0x4a

/* DCP commands */

#define CLIENT_OPCODE_DCP_OPEN_CONNECTION         0x50

#define CLIENT_OPCODE_DCP_ADD_STREAM              0x51

#define CLIENT_OPCODE_DCP_CLOSE_STREAM            0x52

#define CLIENT_OPCODE_DCP_STREAM_REQUEST          0x53

#define CLIENT_OPCODE_DCP_FAILOVER_LOG_REQUEST    0x54

#define CLIENT_OPCODE_DCP_STREAM_END              0x55

#define CLIENT_OPCODE_DCP_SNAPSHOT_MARKER         0x56

#define CLIENT_OPCODE_DCP_MUTATION                0x57

#define CLIENT_OPCODE_DCP_DELETION                0x58

#define CLIENT_OPCODE_DCP_EXPIRATION              0x59

#define CLIENT_OPCODE_DCP_FLUSH                   0x5a

#define CLIENT_OPCODE_DCP_SET_VBUCKET_STATE       0x5b

#define CLIENT_OPCODE_DCP_NOOP                    0x5c

#define CLIENT_OPCODE_DCP_BUFFER_ACKNOWLEDGEMENT  0x5d

#define CLIENT_OPCODE_DCP_CONTROL                 0x5e

#define CLIENT_OPCODE_DCP_SYSTEM_EVENT            0x5f

#define CLIENT_OPCODE_DCP_PREPARE                 0x60

#define CLIENT_OPCODE_DCP_SEQNO_ACK               0x61

#define CLIENT_OPCODE_DCP_COMMIT                  0x62

#define CLIENT_OPCODE_DCP_ABORT                   0x63

#define CLIENT_OPCODE_DCP_SEQNO_ADVANCED          0x64

#define CLIENT_OPCODE_DCP_OSO_SNAPSHOT            0x65

#define CLIENT_OPCODE_GET_FUSION_STORAGE_SNAPSHOT 0x70

#define CLIENT_OPCODE_RELEASE_FUSION_STORAGE_SNAPSHOT 0x71

#define CLIENT_OPCODE_MOUNT_FUSION_VB             0x72

#define CLIENT_OPCODE_UNMOUNT_FUSION_VB           0x73

#define CLIENT_OPCODE_SYNC_FUSION_LOGSTORE        0x74

#define CLIENT_OPCODE_START_FUSION_UPLOADER       0x75

#define CLIENT_OPCODE_STOP_FUSION_UPLOADER        0x76

#define CLIENT_OPCODE_DELETE_FUSION_NAMESPACE     0x77

#define CLIENT_OPCODE_GET_FUSION_NAMESPACES       0x78

 /* Commands from EP (eventually persistent) and bucket engines */

#define CLIENT_OPCODE_STOP_PERSISTENCE        0x80

#define CLIENT_OPCODE_START_PERSISTENCE       0x81

#define CLIENT_OPCODE_SET_PARAM               0x82

#define CLIENT_OPCODE_GET_REPLICA             0x83

#define CLIENT_OPCODE_CREATE_BUCKET           0x85

#define CLIENT_OPCODE_DELETE_BUCKET           0x86

#define CLIENT_OPCODE_LIST_BUCKETS            0x87

#define CLIENT_OPCODE_EXPAND_BUCKET           0x88

#define CLIENT_OPCODE_SELECT_BUCKET           0x89

#define CLIENT_OPCODE_START_REPLICATION       0x90

#define CLIENT_OPCODE_OBSERVE_SEQNO           0x91

#define CLIENT_OPCODE_OBSERVE                 0x92

#define CLIENT_OPCODE_EVICT_KEY               0x93

#define CLIENT_OPCODE_GET_LOCKED              0x94

#define CLIENT_OPCODE_UNLOCK_KEY              0x95

#define CLIENT_OPCODE_SYNC                    0x96

#define CLIENT_OPCODE_LAST_CLOSED_CHECKPOINT  0x97

#define CLIENT_OPCODE_RESTORE_FILE            0x98

#define CLIENT_OPCODE_RESTORE_ABORT           0x99

#define CLIENT_OPCODE_RESTORE_COMPLETE        0x9a

#define CLIENT_OPCODE_ONLINE_UPDATE_START     0x9b

#define CLIENT_OPCODE_ONLINE_UPDATE_COMPLETE  0x9c

#define CLIENT_OPCODE_ONLINE_UPDATE_REVERT    0x9d

#define CLIENT_OPCODE_DEREGISTER_TAP_CLIENT   0x9e

#define CLIENT_OPCODE_RESET_REPLICATION_CHAIN 0x9f

#define CLIENT_OPCODE_GET_META                0xa0

#define CLIENT_OPCODE_GETQ_META               0xa1

#define CLIENT_OPCODE_SET_WITH_META           0xa2

#define CLIENT_OPCODE_SETQ_WITH_META          0xa3

#define CLIENT_OPCODE_ADD_WITH_META           0xa4

#define CLIENT_OPCODE_ADDQ_WITH_META          0xa5

#define CLIENT_OPCODE_SNAPSHOT_VB_STATES      0xa6

#define CLIENT_OPCODE_VBUCKET_BATCH_COUNT     0xa7

#define CLIENT_OPCODE_DEL_WITH_META           0xa8

#define CLIENT_OPCODE_DELQ_WITH_META          0xa9

#define CLIENT_OPCODE_CREATE_CHECKPOINT       0xaa

#define CLIENT_OPCODE_NOTIFY_VBUCKET_UPDATE   0xac

#define CLIENT_OPCODE_ENABLE_TRAFFIC          0xad

#define CLIENT_OPCODE_DISABLE_TRAFFIC         0xae

#define CLIENT_OPCODE_IFCONFIG                0xaf

#define CLIENT_OPCODE_CHANGE_VB_FILTER        0xb0

#define CLIENT_OPCODE_CHECKPOINT_PERSISTENCE  0xb1

#define CLIENT_OPCODE_RETURN_META             0xb2

#define CLIENT_OPCODE_COMPACT_DB              0xb3

#define CLIENT_OPCODE_SET_CLUSTER_CONFIG      0xb4

#define CLIENT_OPCODE_GET_CLUSTER_CONFIG      0xb5

#define CLIENT_OPCODE_GET_RANDOM_KEY          0xb6

#define CLIENT_OPCODE_SEQNO_PERSISTENCE       0xb7

#define CLIENT_OPCODE_GET_KEYS                0xb8

#define CLIENT_OPCODE_COLLECTIONS_SET_MANIFEST 0xb9

#define CLIENT_OPCODE_COLLECTIONS_GET_MANIFEST 0xba

#define CLIENT_OPCODE_COLLECTIONS_GET_ID       0xbb

#define CLIENT_OPCODE_COLLECTIONS_GET_SCOPE_ID 0xbc

#define CLIENT_OPCODE_SET_DRIFT_COUNTER_STATE 0xc1

#define CLIENT_OPCODE_GET_ADJUSTED_TIME       0xc2

/* Sub-document API commands */

#define CLIENT_OPCODE_SUBDOC_GET              0xc5

#define CLIENT_OPCODE_SUBDOC_EXISTS           0xc6

#define CLIENT_OPCODE_SUBDOC_DICT_ADD         0xc7

#define CLIENT_OPCODE_SUBDOC_DICT_UPSERT      0xc8

#define CLIENT_OPCODE_SUBDOC_DELETE           0xc9

#define CLIENT_OPCODE_SUBDOC_REPLACE          0xca

#define CLIENT_OPCODE_SUBDOC_ARRAY_PUSH_LAST  0xcb

#define CLIENT_OPCODE_SUBDOC_ARRAY_PUSH_FIRST 0xcc

#define CLIENT_OPCODE_SUBDOC_ARRAY_INSERT     0xcd

#define CLIENT_OPCODE_SUBDOC_ARRAY_ADD_UNIQUE 0xce

#define CLIENT_OPCODE_SUBDOC_COUNTER          0xcf

#define CLIENT_OPCODE_SUBDOC_MULTI_LOOKUP     0xd0

#define CLIENT_OPCODE_SUBDOC_MULTI_MUTATION   0xd1

#define CLIENT_OPCODE_SUBDOC_GET_COUNT        0xd2

#define CLIENT_OPCODE_SUBDOC_REPLACE_BODY_WITH_XATTR 0xd3

#define CLIENT_OPCODE_RANGE_SCAN_CREATE       0xda

#define CLIENT_OPCODE_RANGE_SCAN_CONTINUE     0xdb

#define CLIENT_OPCODE_RANGE_SCAN_CANCEL       0xdc

#define CLIENT_OPCODE_PREPARE_SNAPSHOT        0xe0

#define CLIENT_OPCODE_RELEASE_SNAPSHOT        0xe1

#define CLIENT_OPCODE_DOWNLOAD_SNAPSHOT       0xe2

#define CLIENT_OPCODE_GET_FILE_FRAGMENT       0xe3

#define CLIENT_OPCODE_SCRUB                   0xf0

#define CLIENT_OPCODE_ISASL_REFRESH           0xf1

#define CLIENT_OPCODE_SSL_CERTS_REFRESH       0xf2

#define CLIENT_OPCODE_GET_CMD_TIMER           0xf3

#define CLIENT_OPCODE_SET_CTRL_TOKEN          0xf4

#define CLIENT_OPCODE_GET_CTRL_TOKEN          0xf5

#define CLIENT_OPCODE_UPDATE_EXTERNAL_USER_PERMISSIONS 0xf6

#define CLIENT_OPCODE_RBAC_REFRESH            0xf7

#define CLIENT_OPCODE_AUTH_PROVIDER           0xf8

#define CLIENT_OPCODE_DROP_PRIVILEGE          0xfb

#define CLIENT_OPCODE_ADJUST_TIMEOFDAY        0xfc

#define CLIENT_OPCODE_EWOULDBLOCK_CTL         0xfd

#define CLIENT_OPCODE_GET_ERROR_MAP           0xfe

 /* vBucket states */

#define VBUCKET_ACTIVE                              0x01

#define VBUCKET_PENDING                             0x02

#define VBUCKET_REPLICA                             0x03

#define VBUCKET_DEAD                                0x04

 /* Data Types */

#define DT_RAW_BYTES          0x00

#define DT_JSON               0x01

#define DT_SNAPPY             0x02

#define DT_XATTR              0x04

void proto_register_couchbase(void);

void proto_reg_handoff_couchbase(void);

static int proto_couchbase;

static int hf_magic;

static int hf_opcode;

static int hf_server_opcode;

static int hf_extlength;

static int hf_keylength;

static int hf_value_length;

static int hf_datatype;

static int hf_datatype_json;

static int hf_datatype_snappy;

static int hf_datatype_xattr;

static int hf_vbucket;

static int hf_status;

static int hf_total_bodylength;

static int hf_opaque;

static int hf_cas;

static int hf_ttp;

static int hf_ttr;

static int hf_collection_key_id;

static int hf_collection_key_logical;

static int hf_collection_manifest_id;

static int hf_flex_extras_length;

static int hf_flex_keylength;

static int hf_extras;

static int hf_extras_flags;

static int hf_extras_flags_backfill;

static int hf_extras_flags_dump;

static int hf_extras_flags_list_vbuckets;

static int hf_extras_flags_takeover_vbuckets;

static int hf_extras_flags_support_ack;

static int hf_extras_flags_request_keys_only;

static int hf_extras_flags_checkpoint;

static int hf_extras_flags_dcp_connection_type;

static int hf_extras_flags_dcp_add_stream_takeover;

static int hf_extras_flags_dcp_add_stream_diskonly;

static int hf_extras_flags_dcp_add_stream_latest;

static int hf_extras_flags_dcp_snapshot_marker_memory;

static int hf_extras_flags_dcp_snapshot_marker_disk;

static int hf_extras_flags_dcp_snapshot_marker_chk;

static int hf_extras_flags_dcp_snapshot_marker_ack;

static int hf_extras_flags_dcp_snapshot_marker_history;

static int hf_extras_flags_dcp_snapshot_marker_may_contain_dups;

static int hf_extras_flags_dcp_include_xattrs;

static int hf_extras_flags_dcp_no_value;

static int hf_extras_flags_dcp_include_delete_times;

static int hf_extras_flags_dcp_collections;

static int hf_extras_flags_dcp_oso_snapshot_begin;

static int hf_extras_flags_dcp_oso_snapshot_end;

static int hf_subdoc_doc_flags;

static int hf_subdoc_doc_flags_mkdoc;

static int hf_subdoc_doc_flags_add;

static int hf_subdoc_doc_flags_accessdeleted;

static int hf_subdoc_doc_flags_createasdeleted;

static int hf_subdoc_doc_flags_revivedocument;

static int hf_subdoc_doc_flags_replicaread;

static int hf_subdoc_doc_flags_reserved;

static int hf_subdoc_flags;

static int hf_subdoc_flags_mkdirp;

static int hf_subdoc_flags_xattrpath;

static int hf_subdoc_flags_expandmacros;

static int hf_subdoc_flags_reserved;

static int hf_extras_seqno;

static int hf_extras_mutation_seqno;

static int hf_extras_opaque;

static int hf_extras_reserved;

static int hf_extras_start_seqno;

static int hf_extras_end_seqno;

static int hf_extras_high_completed_seqno;

static int hf_extras_max_visible_seqno;

static int hf_extras_timestamp;

static int hf_extras_marker_version;

static int hf_extras_vbucket_uuid;

static int hf_extras_snap_start_seqno;

static int hf_extras_snap_end_seqno;

static int hf_extras_expiration;

static int hf_extras_delta;

static int hf_extras_initial;

static int hf_extras_unknown;

static int hf_extras_by_seqno;

static int hf_extras_rev_seqno;

static int hf_extras_prepared_seqno;

static int hf_extras_commit_seqno;

static int hf_extras_abort_seqno;

static int hf_extras_deleted;

static int hf_extras_lock_time;

static int hf_extras_nmeta;

static int hf_extras_nru;

static int hf_extras_bytes_to_ack;

static int hf_extras_delete_time;

static int hf_extras_delete_unused;

static int hf_extras_system_event_id;

static int hf_extras_system_event_version;

static int hf_extras_pathlen;

static int hf_extras_dcp_oso_snapshot_flags;

static int hf_server_extras_cccp_epoch;

static int hf_server_extras_cccp_revno;

static int hf_server_clustermap_value;

static int hf_server_authentication;

static int hf_server_external_users;

static int hf_server_get_authorization;

static int hf_key;

static int hf_path;

static int hf_value;

static int hf_uint64_response;

static int hf_observe;

static int hf_observe_vbucket;

static int hf_observe_keylength;

static int hf_observe_key;

static int hf_observe_status;

static int hf_observe_cas;

static int hf_observe_vbucket_uuid;

static int hf_observe_failed_over;

static int hf_observe_last_persisted_seqno;

static int hf_observe_current_seqno;

static int hf_observe_old_vbucket_uuid;

static int hf_observe_last_received_seqno;

static int hf_get_errmap_version;

static int hf_failover_log;

static int hf_failover_log_size;

static int hf_failover_log_vbucket_uuid;

static int hf_failover_log_vbucket_seqno;

static int hf_vbucket_states;

static int hf_vbucket_states_state;

static int hf_vbucket_states_size;

static int hf_vbucket_states_id;

static int hf_vbucket_states_seqno;

static int hf_bucket_type;

static int hf_bucket_config;

static int hf_config_key;

static int hf_config_value;

static int hf_multipath_opcode;

static int hf_multipath_index;

static int hf_multipath_pathlen;

static int hf_multipath_path;

static int hf_multipath_valuelen;

static int hf_multipath_value;

static int hf_meta_flags;

static int hf_meta_expiration;

static int hf_meta_revseqno;

static int hf_meta_cas;

static int hf_skip_conflict;

static int hf_force_accept;

static int hf_regenerate_cas;

static int hf_force_meta;

static int hf_is_expiration;

static int hf_meta_options;

static int hf_metalen;

static int hf_meta_reqextmeta;

static int hf_meta_deleted;

static int hf_exptime;

static int hf_extras_meta_seqno;

static int hf_confres;

static int hf_hello_features;

static int hf_hello_features_feature;

static int hf_xattr_length;

static int hf_xattr_pair_length;

static int hf_xattr_key;

static int hf_xattr_value;

static int hf_xattrs;

static int hf_flex_extras;

static int hf_flex_extras_n;

static int hf_flex_frame_id_byte0;

static int hf_flex_frame_id_req;

static int hf_flex_frame_id_res;

static int hf_flex_frame_id_req_esc;

static int hf_flex_frame_id_res_esc;

static int hf_flex_frame_len;

static int hf_flex_frame_len_esc;

static int hf_flex_frame_tracing_duration;

static int hf_flex_frame_ru_count;

static int hf_flex_frame_wu_count;

static int hf_flex_frame_durability_req;

static int hf_flex_frame_dcp_stream_id;

static int hf_flex_frame_impersonated_user;

static int hf_range_scan_uuid;

static int hf_range_scan_item_limit;

static int hf_range_scan_time_limit;

static int hf_range_scan_byte_limit;

static expert_field ei_warn_shall_not_have_value;

static expert_field ei_warn_shall_not_have_extras;

static expert_field ei_warn_shall_not_have_key;

static expert_field ei_compression_error;

static expert_field ei_warn_unknown_flex_unsupported;

static expert_field ei_warn_unknown_flex_id;

static expert_field ei_warn_unknown_flex_len;

static expert_field ei_value_missing;

static expert_field ei_warn_must_have_extras;

static expert_field ei_warn_must_have_key;

static expert_field ei_warn_illegal_extras_length;

static expert_field ei_warn_illegal_value_length;

static expert_field ei_warn_unknown_magic_byte;

static expert_field ei_warn_unknown_opcode;

static expert_field ei_warn_unknown_extras;

static expert_field ei_note_status_code;

static expert_field ei_separator_not_found;

static expert_field ei_illegal_value;

static int ett_couchbase;

static int ett_extras;

static int ett_extras_flags;

static int ett_observe;

static int ett_failover_log;

static int ett_vbucket_states;

static int ett_multipath;

static int ett_config;

static int ett_config_key;

static int ett_hello_features;

static int ett_datatype;

static int ett_xattrs;

static int ett_xattr_pair;

static int ett_flex_frame_extras;

static int ett_collection_key;

static const value_string magic_vals[] = {

  { MAGIC_CLIENT_REQUEST, "Request" },

  { MAGIC_CLIENT_RESPONSE, "Response" },

  { MAGIC_CLIENT_RESPONSE_FLEX, "Response with flexible framing extras" },

  { MAGIC_CLIENT_REQUEST_FLEX, "Request with flexible framing extras" },

  { MAGIC_SERVER_REQUEST, "Server Request"},

  { MAGIC_SERVER_RESPONSE, "Server Response"},

  { 0, NULL }

};

#define FLEX_ESCAPE 0x0F

/*

  The flex extension identifiers are different for request/response

  i.e. 0 in a response is not 0 in a request

  Response IDs

 */

#define FLEX_RESPONSE_ID_RX_TX_DURATION 0

#define FLEX_RESPONSE_ID_RU_USAGE 1

#define FLEX_RESPONSE_ID_WU_USAGE 2

/* Request IDs */

#define FLEX_REQUEST_ID_REORDER 0

#define FLEX_REQUEST_ID_DURABILITY 1

#define FLEX_REQUEST_ID_DCP_STREAM_ID 2

#define FLEX_REQUEST_ID_OPEN_TRACING 3

#define FLEX_REQUEST_ID_IMPERSONATE 4

#define FLEX_REQUEST_ID_PRESERVE_TTL 5

static const value_string flex_frame_response_ids[] = {

  { FLEX_RESPONSE_ID_RX_TX_DURATION, "Server Recv->Send duration"},

  { FLEX_RESPONSE_ID_RU_USAGE, "Read units"},

  { FLEX_RESPONSE_ID_WU_USAGE, "Write units"},

  { 0, NULL }

};

static const value_string flex_frame_request_ids[] = {

  { FLEX_REQUEST_ID_REORDER, "Out of order Execution"},

  { FLEX_REQUEST_ID_DURABILITY, "Durability Requirements"},

  { FLEX_REQUEST_ID_DCP_STREAM_ID, "DCP Stream Identifier"},

  { FLEX_REQUEST_ID_OPEN_TRACING, "Open Tracing"},

  { FLEX_REQUEST_ID_IMPERSONATE, "Impersonate User"},

  { FLEX_REQUEST_ID_PRESERVE_TTL, "Preserve TTL"},

  { 0, NULL }

};

static const value_string flex_frame_durability_req[] = {

  { 1, "Majority"},

  { 2, "Majority and persist on active"},

  { 3, "Persist to majority"},

  { 0, NULL }

};

static const value_string status_vals[] = {

  { STATUS_SUCCESS,           "Success"                 },

  { STATUS_KEY_ENOENT,        "Key not found"           },

  { STATUS_KEY_EEXISTS,       "Key exists"              },

  { STATUS_E2BIG,             "Value too big"           },

  { STATUS_EINVAL,            "Invalid arguments"       },

  { STATUS_NOT_STORED,        "Key not stored"          },

  { STATUS_DELTA_BADVAL,      "Bad value to incr/decr"  },

  { STATUS_NOT_MY_VBUCKET,    "Not my vBucket"          },

  { STATUS_NO_VBUCKET,        "Not connected to a bucket" },

  { STATUS_LOCKED,            "The requested resource is locked" },

  { STATUS_DCP_STREAM_NOT_FOUND, "No DCP Stream for this request" },

  { STATUS_OPAQUE_NO_MATCH,   "Opaque does not match" },

  { STATUS_EWOULDTHROTTLE,    "Command would have been throttled" },

  { STATUS_ECONFIGONLY,       "Command can't be executed in config-only bucket" },

  { STATUS_NOT_LOCKED,        "Unlock request for an unlocked document" },

  { STATUS_AUTH_STALE,        "Authentication context is stale. Should reauthenticate." },

  { STATUS_AUTH_ERROR,        "Authentication error"    },

  { STATUS_AUTH_CONTINUE,     "Authentication continue" },

  { STATUS_ERANGE,            "Range error"             },

  { STATUS_ROLLBACK,          "Rollback"                },

  { STATUS_EACCESS,           "Access error"            },

  { STATUS_NOT_INITIALIZED,

    "The Couchbase cluster is currently initializing this node, and "

    "the Cluster manager has not yet granted all users access to the cluster."},

  { STATUS_RATELIMITED_NETWORK_INGRESS, "Rate limit: Network ingress"},

  { STATUS_RATELIMITED_NETWORK_EGRESS, "Rate limit: Network Egress"},

  { STATUS_RATELIMITED_MAX_CONNECTIONS, "Rate limit: Max Connections"},

  { STATUS_RATELIMITED_MAX_COMMANDS, "Rate limit: Max Commands"},

  {STATUS_SCOPE_SIZE_LIMIT_EXCEEDED, "To much data in Scope"},

  { STATUS_UNKNOWN_COMMAND,   "Unknown command"         },

  { STATUS_ENOMEM,            "Out of memory"           },

  { STATUS_NOT_SUPPORTED,     "Command isn't supported" },

  { STATUS_EINTERNAL,         "Internal error"          },

  { STATUS_EBUSY,             "Server is busy"          },

  { STATUS_ETMPFAIL,          "Temporary failure"       },

  { STATUS_XATTR_EINVAL,

    "There is something wrong with the syntax of the provided XATTR."},

  { STATUS_UNKNOWN_COLLECTION,

    "Operation attempted with an unknown collection."},

  { STATUS_NO_COLLECTIONS_MANIFEST,

    "No collections manifest has been set"},

  { STATUS_CANNOT_APPLY_MANIFEST,

    "Cannot apply the given manifest"},

  { STATUS_MANIFEST_IS_AHEAD,

    "Operation attempted with a manifest ahead of the server"},

  { STATUS_UNKNOWN_SCOPE,

    "Operation attempted with an unknown scope."},

  { STATUS_DCP_STREAMID_INVALID,

    "DCP Stream ID is invalid"},

  { STATUS_DURABILITY_INVALID_LEVEL,

    "The specified durability level is invalid" },

  { STATUS_DURABILITY_IMPOSSIBLE,

    "The specified durability requirements are not currently possible" },

  { STATUS_SYNC_WRITE_IN_PROGRESS,

    "A SyncWrite is already in progress on the specified key"},

  { STATUS_SYNC_WRITE_AMBIGUOUS,

    "The SyncWrite request has not completed in the specified time and has ambiguous result"},

  { STATUS_SYNC_WRITE_RECOMMIT_IN_PROGRESS,

    "The SyncWrite is being re-committed after a change in active node"},

  { STATUS_RANGE_SCAN_CANCELLED, "RangeScan was cancelled"},

  { STATUS_RANGE_SCAN_MORE, "RangeScan has more data available"},

  { STATUS_RANGE_SCAN_COMPLETE, "RangeScan has completed"},

  { STATUS_VBUUID_NOT_EQUAL, "VB UUID does not equal server value"},

  { STATUS_SUBDOC_PATH_ENOENT,

    "Subdoc: Path not does not exist"},

  { STATUS_SUBDOC_PATH_MISMATCH,

    "Subdoc: Path mismatch"},

  { STATUS_SUBDOC_PATH_EINVAL,

    "Subdoc: Invalid path"},

  { STATUS_SUBDOC_PATH_E2BIG,

    "Subdoc: Path too large"},

  { STATUS_SUBDOC_DOC_E2DEEP,

    "Subdoc: Document too deep"},

  { STATUS_SUBDOC_VALUE_CANTINSERT,

    "Subdoc: Cannot insert specified value"},

  { STATUS_SUBDOC_DOC_NOTJSON,

    "Subdoc: Existing document not JSON"},

  { STATUS_SUBDOC_NUM_ERANGE,

    "Subdoc: Existing number outside valid arithmetic range"},

  { STATUS_SUBDOC_DELTA_ERANGE,

    "Subdoc: Delta outside valid arithmetic range"},

  { STATUS_SUBDOC_PATH_EEXISTS,

    "Subdoc: Document path already exists"},

  { STATUS_SUBDOC_VALUE_ETOODEEP,

    "Subdoc: Inserting value would make document too deep"},

  { STATUS_SUBDOC_INVALID_COMBO,

    "Subdoc: Invalid combination for multi-path command"},

  { STATUS_SUBDOC_MULTI_PATH_FAILURE,

    "Subdoc: One or more paths in a multi-path command failed"},

  { STATUS_SUBDOC_SUCCESS_DELETED,

    "Subdoc: The operation completed successfully, but operated on a deleted document."},

  { STATUS_SUBDOC_XATTR_INVALID_FLAG_COMBO,

    "Subdoc: The combination of the subdoc flags for the xattrs doesn't make any sense."},

  { STATUS_SUBDOC_XATTR_INVALID_KEY_COMBO,

    "Subdoc: Only a single xattr key may be accessed at the same time."},

  { STATUS_SUBDOC_XATTR_UNKNOWN_MACRO,

    "Subdoc: The server has no knowledge of the requested macro."},

  { STATUS_SUBDOC_XATTR_UNKNOWN_VATTR,

    "Subdoc: The server has no knowledge of the requested virtual xattr."},

  { STATUS_SUBDOC_XATTR_CANT_MODIFY_VATTR,

    "Subdoc: Virtual xattrs can't be modified."},

  { STATUS_SUBDOC_MULTI_PATH_FAILURE_DELETED,

    "Subdoc: Specified key was found as a deleted document, but one or more path operations failed."},

  { STATUS_SUBDOC_INVALID_XATTR_ORDER,

    "Subdoc: According to the spec all xattr commands should come first, followed by the commands for the document body."},

  { STATUS_SUBDOC_XATTR_UNKNOWN_VATTR_MACRO,

    "Subdoc: The server does not know about this virtual macro."},

  { STATUS_SUBDOC_CAN_ONLY_REVIVE_DELETED_DOCUMENTS,

    "Subdoc: The document isn't dead (and we wanted to revive the document)."},

  { STATUS_SUBDOC_DELETED_DOCUMENT_CANT_HAVE_VALUE,

    "Subdoc: A deleted document can't have a user value."},

  { 0, NULL }

};

static value_string_ext status_vals_ext = VALUE_STRING_EXT_INIT(status_vals);

static const value_string client_opcode_vals[] = {

  { CLIENT_OPCODE_GET,                        "Get"                      },

  { CLIENT_OPCODE_SET,                        "Set"                      },

  { CLIENT_OPCODE_ADD,                        "Add"                      },

  { CLIENT_OPCODE_REPLACE,                    "Replace"                  },

  { CLIENT_OPCODE_DELETE,                     "Delete"                   },

  { CLIENT_OPCODE_INCREMENT,                  "Increment"                },

  { CLIENT_OPCODE_DECREMENT,                  "Decrement"                },

  { CLIENT_OPCODE_QUIT,                       "Quit"                     },

  { CLIENT_OPCODE_FLUSH,                      "Flush"                    },

  { CLIENT_OPCODE_GETQ,                       "Get Quietly"              },

  { CLIENT_OPCODE_NOOP,                       "NOOP"                     },

  { CLIENT_OPCODE_VERSION,                    "Version"                  },

  { CLIENT_OPCODE_GETK,                       "Get Key"                  },

  { CLIENT_OPCODE_GETKQ,                      "Get Key Quietly"          },

  { CLIENT_OPCODE_APPEND,                     "Append"                   },

  { CLIENT_OPCODE_PREPEND,                    "Prepend"                  },

  { CLIENT_OPCODE_STAT,                       "Statistics"               },

  { CLIENT_OPCODE_SETQ,                       "Set Quietly"              },

  { CLIENT_OPCODE_ADDQ,                       "Add Quietly"              },

  { CLIENT_OPCODE_REPLACEQ,                   "Replace Quietly"          },

  { CLIENT_OPCODE_DELETEQ,                    "Delete Quietly"           },

  { CLIENT_OPCODE_INCREMENTQ,                 "Increment Quietly"        },

  { CLIENT_OPCODE_DECREMENTQ,                 "Decrement Quietly"        },

  { CLIENT_OPCODE_QUITQ,                      "Quit Quietly"             },

  { CLIENT_OPCODE_FLUSHQ,                     "Flush Quietly"            },

  { CLIENT_OPCODE_APPENDQ,                    "Append Quietly"           },

  { CLIENT_OPCODE_PREPENDQ,                   "Prepend Quietly"          },

  { CLIENT_OPCODE_VERBOSITY,                  "Verbosity"                },

  { CLIENT_OPCODE_TOUCH,                      "Touch"                    },

  { CLIENT_OPCODE_GAT,                        "Get and Touch"            },

  { CLIENT_OPCODE_GATQ,                       "Gat and Touch Quietly"    },

  { CLIENT_OPCODE_HELLO,                      "Hello"                    },

  { CLIENT_OPCODE_SASL_LIST_MECHS,            "List SASL Mechanisms"     },

  { CLIENT_OPCODE_SASL_AUTH,                  "SASL Authenticate"        },

  { CLIENT_OPCODE_SASL_STEP,                  "SASL Step"                },

  { CLIENT_OPCODE_IOCTL_GET,                  "IOCTL Get"                },

  { CLIENT_OPCODE_IOCTL_SET,                  "IOCTL Set"                },

  { CLIENT_OPCODE_CONFIG_VALIDATE,            "Config Validate"          },

  { CLIENT_OPCODE_CONFIG_RELOAD,              "Config Reload"            },

  { CLIENT_OPCODE_AUDIT_PUT,                  "Audit Put"                },

  { CLIENT_OPCODE_AUDIT_CONFIG_RELOAD,        "Audit Config Reload"      },

  { CLIENT_OPCODE_SHUTDOWN,                   "Shutdown"                 },

  { CLIENT_OPCODE_SET_ACTIVE_ENCRYPTION_KEYS, "Set Active Encryption Keys"},

  { CLIENT_OPCODE_PRUNE_ENCRYPTION_KEYS,      "Prune Encryption Keys"    },

  { CLIENT_OPCODE_RGET,                       "Range Get"                },

  { CLIENT_OPCODE_RSET,                       "Range Set"                },

  { CLIENT_OPCODE_RSETQ,                      "Range Set Quietly"        },

  { CLIENT_OPCODE_RAPPEND,                    "Range Append"             },

  { CLIENT_OPCODE_RAPPENDQ,                   "Range Append Quietly"     },

  { CLIENT_OPCODE_RPREPEND,                   "Range Prepend"            },

  { CLIENT_OPCODE_RPREPENDQ,                  "Range Prepend Quietly"    },

  { CLIENT_OPCODE_RDELETE,                    "Range Delete"             },

  { CLIENT_OPCODE_RDELETEQ,                   "Range Delete Quietly"     },

  { CLIENT_OPCODE_RINCR,                      "Range Increment"          },

  { CLIENT_OPCODE_RINCRQ,                     "Range Increment Quietly"  },

  { CLIENT_OPCODE_RDECR,                      "Range Decrement"          },

  { CLIENT_OPCODE_RDECRQ,                     "Range Decrement Quietly"  },

  { CLIENT_OPCODE_SET_VBUCKET,                "Set VBucket"              },

  { CLIENT_OPCODE_GET_VBUCKET,                "Get VBucket"              },

  { CLIENT_OPCODE_DEL_VBUCKET,                "Delete VBucket"           },

  { CLIENT_OPCODE_TAP_CONNECT,                "TAP Connect"              },

  { CLIENT_OPCODE_TAP_MUTATION,               "TAP Mutation"             },

  { CLIENT_OPCODE_TAP_DELETE,                 "TAP Delete"               },

  { CLIENT_OPCODE_TAP_FLUSH,                  "TAP Flush"                },

  { CLIENT_OPCODE_TAP_OPAQUE,                 "TAP Opaque"               },

  { CLIENT_OPCODE_TAP_VBUCKET_SET,            "TAP VBucket Set"          },

  { CLIENT_OPCODE_TAP_CHECKPOINT_START,       "TAP Checkpoint Start"     },

  { CLIENT_OPCODE_TAP_CHECKPOINT_END,         "TAP Checkpoint End"       },

  { CLIENT_OPCODE_GET_ALL_VB_SEQNOS,          "Get All VBucket Seqnos"   },

  { CLIENT_OPCODE_GET_EX,                     "GetEx"                    },

  { CLIENT_OPCODE_GET_EX_REPLICA,             "GetEx Replica"            },

  { CLIENT_OPCODE_DCP_OPEN_CONNECTION,        "DCP Open Connection"      },

  { CLIENT_OPCODE_DCP_ADD_STREAM,             "DCP Add Stream"           },

  { CLIENT_OPCODE_DCP_CLOSE_STREAM,           "DCP Close Stream"         },

  { CLIENT_OPCODE_DCP_STREAM_REQUEST,         "DCP Stream Request"       },

  { CLIENT_OPCODE_DCP_FAILOVER_LOG_REQUEST,   "DCP Get Failover Log"     },

  { CLIENT_OPCODE_DCP_STREAM_END,             "DCP Stream End"           },

  { CLIENT_OPCODE_DCP_SNAPSHOT_MARKER,        "DCP Snapshot Marker"      },

  { CLIENT_OPCODE_DCP_MUTATION,               "DCP (Key) Mutation"       },

  { CLIENT_OPCODE_DCP_DELETION,               "DCP (Key) Deletion"       },

  { CLIENT_OPCODE_DCP_EXPIRATION,             "DCP (Key) Expiration"     },

  { CLIENT_OPCODE_DCP_FLUSH,                  "DCP Flush"                },

  { CLIENT_OPCODE_DCP_SET_VBUCKET_STATE,      "DCP Set VBucket State"    },

  { CLIENT_OPCODE_DCP_NOOP,                   "DCP NOOP"                 },

  { CLIENT_OPCODE_DCP_BUFFER_ACKNOWLEDGEMENT, "DCP Buffer Acknowledgement"},

  { CLIENT_OPCODE_DCP_CONTROL,                "DCP Control"              },

  { CLIENT_OPCODE_DCP_SYSTEM_EVENT,           "DCP System Event"         },

  { CLIENT_OPCODE_DCP_PREPARE,                "DCP Prepare"              },

  { CLIENT_OPCODE_DCP_SEQNO_ACK,              "DCP Seqno Acknowledgement"},

  { CLIENT_OPCODE_DCP_COMMIT,                 "DCP Commit"               },

  { CLIENT_OPCODE_DCP_ABORT,                  "DCP Abort"                },

  { CLIENT_OPCODE_DCP_SEQNO_ADVANCED,         "DCP Seqno Advanced"       },

  { CLIENT_OPCODE_DCP_OSO_SNAPSHOT,           "DCP Out of Sequence Order Snapshot"},

  { CLIENT_OPCODE_GET_FUSION_STORAGE_SNAPSHOT, "Get Fusion Storage Snapshot"},

  { CLIENT_OPCODE_RELEASE_FUSION_STORAGE_SNAPSHOT, "Release Fusion Storage Snapshot"},

  { CLIENT_OPCODE_MOUNT_FUSION_VB,            "Mount Fusion VBucket"     },

  { CLIENT_OPCODE_UNMOUNT_FUSION_VB,          "Unmount Fusion VBucket"   },

  { CLIENT_OPCODE_SYNC_FUSION_LOGSTORE,       "Sync Fusion Logstore"     },

  { CLIENT_OPCODE_START_FUSION_UPLOADER,      "Start Fusion Uploader"    },

  { CLIENT_OPCODE_STOP_FUSION_UPLOADER,       "Stop Fusion Uploader"     },

  { CLIENT_OPCODE_DELETE_FUSION_NAMESPACE,    "Delete Fusion Namespace"  },

  { CLIENT_OPCODE_GET_FUSION_NAMESPACES,      "Get Fusion Namespaces"    },

  { CLIENT_OPCODE_STOP_PERSISTENCE,           "Stop Persistence"         },

  { CLIENT_OPCODE_START_PERSISTENCE,          "Start Persistence"        },

  { CLIENT_OPCODE_SET_PARAM,                  "Set Parameter"            },

  { CLIENT_OPCODE_GET_REPLICA,                "Get Replica"              },

  { CLIENT_OPCODE_CREATE_BUCKET,              "Create Bucket"            },

  { CLIENT_OPCODE_DELETE_BUCKET,              "Delete Bucket"            },

  { CLIENT_OPCODE_LIST_BUCKETS,               "List Buckets"             },

  { CLIENT_OPCODE_EXPAND_BUCKET,              "Expand Bucket"            },

  { CLIENT_OPCODE_SELECT_BUCKET,              "Select Bucket"            },

  { CLIENT_OPCODE_START_REPLICATION,          "Start Replication"        },

  { CLIENT_OPCODE_OBSERVE_SEQNO,              "Observe Sequence Number"  },

  { CLIENT_OPCODE_OBSERVE,                    "Observe"                  },

  { CLIENT_OPCODE_EVICT_KEY,                  "Evict Key"                },

  { CLIENT_OPCODE_GET_LOCKED,                 "Get Locked"               },

  { CLIENT_OPCODE_UNLOCK_KEY,                 "Unlock Key"               },

  { CLIENT_OPCODE_SYNC,                       "Sync"                     },

  { CLIENT_OPCODE_LAST_CLOSED_CHECKPOINT,     "Last Closed Checkpoint"   },

  { CLIENT_OPCODE_RESTORE_FILE,               "Restore File"             },

  { CLIENT_OPCODE_RESTORE_ABORT,              "Restore Abort"            },

  { CLIENT_OPCODE_RESTORE_COMPLETE,           "Restore Complete"         },

  { CLIENT_OPCODE_ONLINE_UPDATE_START,        "Online Update Start"      },

  { CLIENT_OPCODE_ONLINE_UPDATE_COMPLETE,     "Online Update Complete"   },

  { CLIENT_OPCODE_ONLINE_UPDATE_REVERT,       "Online Update Revert"     },

  { CLIENT_OPCODE_DEREGISTER_TAP_CLIENT,      "Deregister TAP Client"    },

  { CLIENT_OPCODE_RESET_REPLICATION_CHAIN,    "Reset Replication Chain"  },

  { CLIENT_OPCODE_GET_META,                   "Get Meta"                 },

  { CLIENT_OPCODE_GETQ_META,                  "Get Meta Quietly"         },

  { CLIENT_OPCODE_SET_WITH_META,              "Set with Meta"            },

  { CLIENT_OPCODE_SETQ_WITH_META,             "Set with Meta Quietly"    },

  { CLIENT_OPCODE_ADD_WITH_META,              "Add with Meta"            },

  { CLIENT_OPCODE_ADDQ_WITH_META,             "Add with Meta Quietly"    },

  { CLIENT_OPCODE_SNAPSHOT_VB_STATES,         "Snapshot VBuckets States" },

  { CLIENT_OPCODE_VBUCKET_BATCH_COUNT,        "VBucket Batch Count"      },

  { CLIENT_OPCODE_DEL_WITH_META,              "Delete with Meta"         },

  { CLIENT_OPCODE_DELQ_WITH_META,             "Delete with Meta Quietly" },

  { CLIENT_OPCODE_CREATE_CHECKPOINT,          "Create Checkpoint"        },

  { CLIENT_OPCODE_NOTIFY_VBUCKET_UPDATE,      "Notify VBucket Update"    },

  { CLIENT_OPCODE_ENABLE_TRAFFIC,             "Enable Traffic"           },

  { CLIENT_OPCODE_DISABLE_TRAFFIC,            "Disable Traffic"          },

  { CLIENT_OPCODE_IFCONFIG,                   "Ifconfig"                 },

  { CLIENT_OPCODE_CHANGE_VB_FILTER,           "Change VBucket Filter"    },

  { CLIENT_OPCODE_CHECKPOINT_PERSISTENCE,     "Checkpoint Persistence"   },

  { CLIENT_OPCODE_RETURN_META,                "Return Meta"              },

  { CLIENT_OPCODE_COMPACT_DB,                 "Compact Database"         },

  { CLIENT_OPCODE_SET_CLUSTER_CONFIG,         "Set Cluster Config"       },

  { CLIENT_OPCODE_GET_CLUSTER_CONFIG,         "Get Cluster Config"       },

  { CLIENT_OPCODE_GET_RANDOM_KEY,             "Get Random Key"           },

  { CLIENT_OPCODE_SEQNO_PERSISTENCE,          "Seqno Persistence"        },

  { CLIENT_OPCODE_GET_KEYS,                   "Get Keys"                 },

  { CLIENT_OPCODE_COLLECTIONS_SET_MANIFEST,   "Set Collection's Manifest" },

  { CLIENT_OPCODE_COLLECTIONS_GET_MANIFEST,   "Get Collection's Manifest" },

  { CLIENT_OPCODE_COLLECTIONS_GET_ID,         "Get Collection ID"        },

  { CLIENT_OPCODE_COLLECTIONS_GET_SCOPE_ID,   "Get Scope ID"             },

  { CLIENT_OPCODE_SET_DRIFT_COUNTER_STATE,    "Set Drift Counter State"  },

  { CLIENT_OPCODE_GET_ADJUSTED_TIME,          "Get Adjusted Time"        },

  { CLIENT_OPCODE_SUBDOC_GET,                 "Subdoc Get"               },

  { CLIENT_OPCODE_SUBDOC_EXISTS,              "Subdoc Exists"            },

  { CLIENT_OPCODE_SUBDOC_DICT_ADD,            "Subdoc Dictionary Add"    },

  { CLIENT_OPCODE_SUBDOC_DICT_UPSERT,         "Subdoc Dictionary Upsert" },

  { CLIENT_OPCODE_SUBDOC_DELETE,              "Subdoc Delete"            },

  { CLIENT_OPCODE_SUBDOC_REPLACE,             "Subdoc Replace"           },

  { CLIENT_OPCODE_SUBDOC_ARRAY_PUSH_LAST,     "Subdoc Array Push Last"   },

  { CLIENT_OPCODE_SUBDOC_ARRAY_PUSH_FIRST,    "Subdoc Array Push First"  },

  { CLIENT_OPCODE_SUBDOC_ARRAY_INSERT,        "Subdoc Array Insert"      },

  { CLIENT_OPCODE_SUBDOC_ARRAY_ADD_UNIQUE,    "Subdoc Array Add Unique"  },

  { CLIENT_OPCODE_SUBDOC_COUNTER,             "Subdoc Counter"           },

  { CLIENT_OPCODE_SUBDOC_MULTI_LOOKUP,        "Subdoc Multipath Lookup"  },

  { CLIENT_OPCODE_SUBDOC_MULTI_MUTATION,      "Subdoc Multipath Mutation"},

  { CLIENT_OPCODE_SUBDOC_GET_COUNT,           "Subdoc Get Count"         },

  { CLIENT_OPCODE_SUBDOC_REPLACE_BODY_WITH_XATTR, "Subdoc Replace Body With Xattr"},

  { CLIENT_OPCODE_RANGE_SCAN_CREATE,          "RangeScan Create"         },

  { CLIENT_OPCODE_RANGE_SCAN_CONTINUE,        "RangeScan Continue"       },

  { CLIENT_OPCODE_RANGE_SCAN_CANCEL,          "RangeScan Cancel"         },

  { CLIENT_OPCODE_PREPARE_SNAPSHOT,           "Prepare Snapshot"         },

  { CLIENT_OPCODE_RELEASE_SNAPSHOT,           "Release Snapshot"         },

  { CLIENT_OPCODE_DOWNLOAD_SNAPSHOT,          "Download Snapshot"        },

  { CLIENT_OPCODE_GET_FILE_FRAGMENT,          "Get File Fragment"        },

  { CLIENT_OPCODE_SCRUB,                      "Scrub"                    },

  { CLIENT_OPCODE_ISASL_REFRESH,              "isasl Refresh"            },

  { CLIENT_OPCODE_SSL_CERTS_REFRESH,          "SSL Certificates Refresh" },

  { CLIENT_OPCODE_GET_CMD_TIMER,              "Internal Timer Control"   },

  { CLIENT_OPCODE_SET_CTRL_TOKEN,             "Set Control Token"        },

  { CLIENT_OPCODE_GET_CTRL_TOKEN,             "Get Control Token"        },

  { CLIENT_OPCODE_UPDATE_EXTERNAL_USER_PERMISSIONS, "Update External User Permissions"},

  { CLIENT_OPCODE_RBAC_REFRESH,               "RBAC Refresh"             },

  { CLIENT_OPCODE_AUTH_PROVIDER,              "Auth Provider"            },

  { CLIENT_OPCODE_DROP_PRIVILEGE,             "Drop Privilege"           },

  { CLIENT_OPCODE_ADJUST_TIMEOFDAY,           "Adjust Timeofday"         },

  { CLIENT_OPCODE_EWOULDBLOCK_CTL,            "EWOULDBLOCK Control"      },

  { CLIENT_OPCODE_GET_ERROR_MAP,              "Get Error Map"            },

  /* Internally defined values not valid here */

  { 0, NULL }

};

static value_string_ext client_opcode_vals_ext = VALUE_STRING_EXT_INIT(client_opcode_vals);

typedef enum {

    SERVER_OPCODE_CLUSTERMAP_CHANGE_NOTIFICATION = 0x01,

    SERVER_OPCODE_AUTHENTICATE = 0x02,

    SERVER_OPCODE_ACTIVE_EXTERNAL_USERS = 0x03,

    SERVER_OPCODE_GET_AUTHORIZATION = 0x04

} server_opcode_t;

static const value_string server_opcode_vals[] = {

        { SERVER_OPCODE_CLUSTERMAP_CHANGE_NOTIFICATION, "ClustermapChangeNotification"},

        { SERVER_OPCODE_AUTHENTICATE, "Authenticate"},

        { SERVER_OPCODE_ACTIVE_EXTERNAL_USERS, "ActiveExternalUsers"},

        { SERVER_OPCODE_GET_AUTHORIZATION, "GetAuthorization"},

        {0, NULL}

};

static value_string_ext server_opcode_vals_ext = VALUE_STRING_EXT_INIT(server_opcode_vals);

static const value_string dcp_connection_type_vals[] = {

  {0, "Consumer"},

  {1, "Producer"},

  {2, "Notifier"},

  {0, NULL}

};

static const value_string vbucket_states_vals[] = {

  {1, "Active"},

  {2, "Replica"},

  {3, "Pending"},

  {4, "Dead"},

  {0, NULL}

};

static int * const datatype_vals[] = {

  &hf_datatype_json,

  &hf_datatype_snappy,

  &hf_datatype_xattr,

  NULL

};

static int * const subdoc_flags[] = {

  &hf_subdoc_flags_mkdirp,

  &hf_subdoc_flags_xattrpath,

  &hf_subdoc_flags_expandmacros,

  &hf_subdoc_flags_reserved,

  NULL

};

static int * const subdoc_doc_flags[] = {

  &hf_subdoc_doc_flags_mkdoc,

  &hf_subdoc_doc_flags_add,

  &hf_subdoc_doc_flags_accessdeleted,

  &hf_subdoc_doc_flags_createasdeleted,

  &hf_subdoc_doc_flags_revivedocument,

  &hf_subdoc_doc_flags_replicaread,

  &hf_subdoc_doc_flags_reserved,

  NULL

};

static int * const set_with_meta_extra_flags[] = {

        &hf_force_meta,

        &hf_force_accept,

        &hf_regenerate_cas,

        &hf_skip_conflict,

        NULL