Move cdb2api hndl into own file

Signed-off-by: Salil Chandra <schandra107@bloomberg.net>

Author: chands10

cdb2api/cdb2api.c

@@ -38,6 +38,7 @@
 #include <limits.h> // int_max
 
 #include "cdb2api.h"
+#include "cdb2api_hndl.h"
 
 #include "sqlquery.pb-c.h"
 #include "sqlresponse.pb-c.h"
@@ -57,7 +58,6 @@ static char *SOCKPOOL_OTHER_NAME = NULL;
 #define COMDB2DB "comdb2db"
 #define COMDB2DB_NUM 32432
 #define MAX_BUFSIZE_ONSTACK 8192
-#define CDB2HOSTNAME_LEN 128
 static char COMDB2DB_OVERRIDE[32] = {0};
 static int COMDB2DB_NUM_OVERRIDE = 0;
 
@@ -162,7 +162,6 @@ static double cdb2_min_tls_ver = CDB2_MIN_TLS_VER_DEFAULT;
 
 static pthread_mutex_t cdb2_ssl_sess_lock = PTHREAD_MUTEX_INITIALIZER;
 
-typedef struct cdb2_ssl_sess cdb2_ssl_sess;
 static cdb2_ssl_sess *cdb2_get_ssl_sessions(cdb2_hndl_tp *hndl);
 static int cdb2_set_ssl_sessions(cdb2_hndl_tp *hndl,
                                  cdb2_ssl_sess *sessions);
@@ -181,12 +180,6 @@ static int iam_identity = 0;
 
 #define DB_TZNAME_DEFAULT "America/New_York"
 
-#define MAX_NODES 128
-#define MAX_CONTEXTS 10 /* Maximum stack size for storing context messages */
-#define MAX_CONTEXT_LEN 100 /* Maximum allowed length of a context message */
-
-#define MAX_STACK 512 /* Size of call-stack which opened the handle */
-
 pthread_mutex_t cdb2_sockpool_mutex = PTHREAD_MUTEX_INITIALIZER;
 #define MAX_SOCKPOOL_FDS 8
 
@@ -197,17 +190,6 @@ static int log_calls = 0; /* ONE-TIME */
 
 static void reset_sockpool(void);
 
-struct cdb2_event {
-    cdb2_event_type types;
-    cdb2_event_ctrl ctrls;
-    cdb2_event_callback cb;
-    int global;
-    void *user_arg;
-    cdb2_event *next;
-    int argc;
-    cdb2_event_arg argv[1];
-};
-
 static pthread_mutex_t cdb2_event_mutex = PTHREAD_MUTEX_INITIALIZER;
 static cdb2_event cdb2_gbl_events;
 static int cdb2_gbl_event_version;
@@ -937,12 +919,6 @@ static int cdb2_do_tcpconnect(struct in_addr in, int port, int myport,
     return (sockfd); /* all OK */
 }
 
-struct context_messages {
-    char *message[MAX_CONTEXTS];
-    int count;
-    int has_changed;
-};
-
 /* Forward declarations. */
 static void cdb2_init_context_msgs(cdb2_hndl_tp *hndl);
 static int cdb2_free_context_msgs(cdb2_hndl_tp *hndl);
@@ -955,158 +931,8 @@ struct newsqlheader {
     int length;
 };
 
-typedef struct cdb2_query_list_item {
-    void *buf;
-    int len;
-    int is_read;
-    char *sql;
-    struct cdb2_query_list_item *next;
-} cdb2_query_list;
-
-struct cdb2_ssl_sess {
-    struct cdb2_ssl_sess *next;
-    char dbname[64];
-    char cluster[64];
-    int ref;
-    SSL_SESSION *sessobj;
-};
-
 static cdb2_ssl_sess cdb2_ssl_sess_cache;
 
-/* A cnonce is composed of
-   - 32 bits of machine ID
-   - 32 bits of process PID
-   - 32 or 64 bits of handle address
-   - 52 bits for the epoch time in microseconds
-   - 12 bits for the sequence number
-
-   The allocation allows a handle to run at a maximum transaction rate of
-   4096 txn/us (~4 billion transactions per second) till September 17, 2112.
-
-   See next_cnonce() for details. */
-#define CNONCE_STR_FMT "%lx-%x-%llx-"
-#define CNONCE_STR_SZ 60 /* 16 + 1 + 8 + 1 + 16 + 1 + 16 + 1 (NUL) */
-
-#define CNT_BITS 12
-#define TIME_MASK (-1ULL << CNT_BITS)
-#define CNT_MASK (-1ULL ^ TIME_MASK)
-
-typedef struct cnonce {
-    long hostid;
-    int pid;
-    struct cdb2_hndl *hndl;
-    uint64_t seq;
-    int ofs;
-    char str[CNONCE_STR_SZ];
-} cnonce_t;
-
-#define DBNAME_LEN 64
-#define TYPE_LEN 64
-#define POLICY_LEN 24
-
-struct cdb2_hndl {
-    char dbname[DBNAME_LEN];
-    char cluster[64];
-    char type[TYPE_LEN];
-    char hosts[MAX_NODES][CDB2HOSTNAME_LEN];
-    uint64_t timestampus; // client query timestamp of first try
-    int ports[MAX_NODES];
-    int hosts_connected[MAX_NODES];
-    char shards[MAX_NODES][DBNAME_LEN];
-    char cached_host[CDB2HOSTNAME_LEN]; /* hostname of a sockpool connection */
-    int cached_port;      /* port of a sockpool connection */
-    SBUF2 *sb;
-    int dbnum;
-    int num_hosts;          /* total number of hosts */
-    int num_hosts_sameroom; /* number of hosts that are in my datacenter (aka room) */
-    int num_shards;
-    int num_shards_sameroom;
-    int node_seq;           /* fail over to the `node_seq'-th host */
-    int in_trans;
-    int temp_trans;
-    int is_retry;
-    int is_chunk;
-    int is_set;
-    char newsql_typestr[DBNAME_LEN + TYPE_LEN + POLICY_LEN + 16];
-    char policy[POLICY_LEN];
-    int master;
-    int connected_host;
-    char *query;
-    char *query_hint;
-    char *hint;
-    int use_hint;
-    int flags;
-    char errstr[1024];
-    cnonce_t cnonce;
-    char *sql;
-    int ntypes;
-    int *types;
-    uint8_t *last_buf;
-    CDB2SQLRESPONSE *lastresponse;
-    uint8_t *first_buf;
-    CDB2SQLRESPONSE *firstresponse;
-    int error_in_trans;
-    int client_side_error;
-    int n_bindvars;
-    CDB2SQLQUERY__Bindvalue **bindvars;
-    cdb2_query_list *query_list;
-    int snapshot_file;
-    int snapshot_offset;
-    int query_no;
-    int retry_all;
-    int num_set_commands;
-    int num_set_commands_sent;
-    int is_read;
-    unsigned long long rows_read;
-    int read_intrans_results;
-    int first_record_read;
-    char **commands;
-    int ack;
-    int is_hasql;
-    int is_admin;
-    int clear_snap_line;
-    int debug_trace;
-    int max_retries;
-    int min_retries;
-    ssl_mode c_sslmode; /* client SSL mode */
-    peer_ssl_mode s_sslmode; /* server SSL mode */
-    int sslerr; /* 1 if unrecoverable SSL error. */
-    char *sslpath; /* SSL certificates */
-    char *cert;
-    char *key;
-    char *ca;
-    char *crl;
-    int cache_ssl_sess;
-    double min_tls_ver;
-    cdb2_ssl_sess *sess;
-    int nid_dbname;
-    /* 1 if it's a newly established session which needs to be cached. */
-    int newsess;
-    struct context_messages context_msgs;
-    char *env_tz;
-    int sent_client_info;
-    char stack[MAX_STACK];
-    int send_stack;
-    void *user_arg;
-    int *gbl_event_version; /* Cached global event version */
-    int api_call_timeout;
-    int connect_timeout;
-    int comdb2db_timeout;
-    int socket_timeout;
-    int request_fp; /* 1 if requesting the fingerprint; 0 otherwise. */
-    cdb2_event *events;
-    // Protobuf allocator data used only for row data i.e. lastresponse
-    void *protobuf_data;
-    int protobuf_size;
-    int protobuf_offset;
-    ProtobufCAllocator allocator;
-    int auto_consume_timeout_ms;
-    int max_auto_consume_rows;
-    struct cdb2_hndl *fdb_hndl;
-    int is_child_hndl;
-    CDB2SQLQUERY__IdentityBlob *id_blob;
-};
-
 static void *cdb2_protobuf_alloc(void *allocator_data, size_t size)
 {
     struct cdb2_hndl *hndl = allocator_data;