Skip to content

Hide more things in cdb2api #5753

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
chands10 merged 1 commit into from
Feb 23, 2026
Merged

Hide more things in cdb2api #5753

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
13 changes: 12 additions & 1 deletion cdb2api/cdb2api.c
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -1427,6 +1427,7 @@ void cdb2_set_max_retries(int max_retries)
}
#endif

#ifdef CDB2API_SERVER
void cdb2_hndl_set_min_retries(cdb2_hndl_tp *hndl, int min_retries)
{
if (min_retries > 0) {
Expand All @@ -1440,6 +1441,7 @@ void cdb2_hndl_set_max_retries(cdb2_hndl_tp *hndl, int max_retries)
hndl->max_retries = max_retries;
}
}
#endif

void cdb2_set_comdb2db_config(char *cfg_file)
{
Expand Down Expand Up @@ -2349,6 +2351,7 @@ static int read_available_comdb2db_configs(cdb2_hndl_tp *hndl, char comdb2db_hos
return 0;
}

#ifdef CDB2API_SERVER
int cdb2_get_comdb2db(char **comdb2dbname, char **comdb2dbclass)
{
if (!strlen(cdb2_comdb2dbname)) {
Expand All @@ -2358,6 +2361,7 @@ int cdb2_get_comdb2db(char **comdb2dbname, char **comdb2dbclass)
(*comdb2dbclass) = strdup((strcmp(cdb2_comdb2dbname, "comdb3db") == 0) ? "dev" : "prod");
return 0;
}
#endif

/* populate comdb2db_hosts based on hostname info of comdb2db_name
* returns -1 if error or no hosts were found
Expand Down Expand Up @@ -3157,6 +3161,7 @@ static int cdb2_socket_pool_get_ll(cdb2_hndl_tp *hndl, const char *typestr, int
return fd;
}

#ifdef CDB2API_SERVER
/* Get the file descriptor of a socket matching the given type string from
* the pool. Returns -1 if none is available or the file descriptor on
* success. Don't support local cache since it may not return fd */
Expand All @@ -3166,6 +3171,7 @@ int cdb2_socket_pool_get_fd(cdb2_hndl_tp *hndl, const char *typestr, int dbnum,
LOG_CALL("%s(%s,%d,%p): fd=%d\n", __func__, typestr, dbnum, port, fd);
return fd;
}
#endif

static int typestr_type_is_default(const char *typestr)
{
Expand All @@ -3184,7 +3190,8 @@ static int typestr_type_is_default(const char *typestr)
/* Get the sbuf of a socket matching the given type string from
* the pool. Returns NULL if none is available or the sbuf on
* success. */
COMDB2BUF *cdb2_socket_pool_get(cdb2_hndl_tp *hndl, const char *typestr, int dbnum, int *port, int *was_from_local_cache)
static COMDB2BUF *cdb2_socket_pool_get(cdb2_hndl_tp *hndl, const char *typestr, int dbnum, int *port,
int *was_from_local_cache)
{
COMDB2BUF *sb = NULL;

Expand Down Expand Up @@ -6818,10 +6825,12 @@ int cdb2_snapshot_file(cdb2_hndl_tp *hndl, int *snapshot_file,
}
#endif

#ifdef CDB2API_SERVER
void cdb2_set_debug_trace(cdb2_hndl_tp *hndl)
{
hndl->debug_trace = 1;
}
#endif

#ifdef CDB2API_TEST
void cdb2_dump_ports(cdb2_hndl_tp *hndl, FILE *out)
Expand Down Expand Up @@ -8616,10 +8625,12 @@ int cdb2_is_ssl_encrypted(cdb2_hndl_tp *hndl)
return hndl->sb == NULL ? 0 : sslio_has_ssl(hndl->sb);
}

#ifdef CDB2API_SERVER
void cdb2_setIdentityBlob(cdb2_hndl_tp *hndl, void *id)
{
hndl->id_blob = (CDB2SQLQUERY__IdentityBlob *)id;
}
#endif

static cdb2_ssl_sess *cdb2_get_ssl_sessions(cdb2_hndl_tp *hndl)
{
Expand Down
5 changes: 4 additions & 1 deletion cdb2api/cdb2api_int.h
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -29,9 +29,10 @@
extern "C" {
#endif

COMDB2BUF *cdb2_socket_pool_get(cdb2_hndl_tp *hndl, const char *typestr, int dbnum, int *port, int *was_from_local_cache);
#ifdef CDB2API_SERVER
// use this one for fastsql since client_sbuf and server_sbuf are different
int cdb2_socket_pool_get_fd(cdb2_hndl_tp *hndl, const char *typestr, int dbnum, int *port);
#endif
void cdb2_socket_pool_donate_ext(const cdb2_hndl_tp *hndl, const char *typestr, int fd, int ttl, int dbnum);

#ifdef CDB2API_SERVER
Expand All @@ -42,6 +43,7 @@ int cdb2_send_2pc(cdb2_hndl_tp *hndl, char *dbname, char *pname, char *ptier, ch
COMDB2BUF *cdb2_cdb2buf_openread(const char *filename);
int cdb2_read_line(char *line, int maxlen, COMDB2BUF *s, const char *buf, int *chrno);

#ifdef CDB2API_SERVER
void cdb2_setIdentityBlob(cdb2_hndl_tp *hndl, void *id);

void cdb2_hndl_set_max_retries(cdb2_hndl_tp *hndl, int max_retries);
Expand All @@ -50,6 +52,7 @@ void cdb2_hndl_set_min_retries(cdb2_hndl_tp *hndl, int min_retries);
int cdb2_get_comdb2db(char **comdb2db_name, char **comdb2db_class);

void cdb2_set_debug_trace(cdb2_hndl_tp *hndl);
#endif

struct cdb2_identity {
void (*resetIdentity_start)();
Expand Down