Lines Matching refs:dbi
173 dbinstance_t *dbi = NULL;
180 dbi = ndbi;
182 ndbi = ISC_LIST_NEXT(dbi, link);
184 if (dbi->dbconn != NULL)
185 PQfinish((PGconn *) dbi->dbconn);
187 destroy_sqldbinstance(dbi);
207 dbinstance_t *dbi = NULL;
212 head = dbi = ISC_LIST_HEAD(*dblist);
217 if (isc_mutex_trylock(&dbi->instance_lock) == ISC_R_SUCCESS)
218 return dbi; /* success, return the DBI for use. */
221 dbi = ISC_LIST_NEXT(dbi, link);
224 if (dbi == NULL) {
226 dbi = head;
290 dbinstance_t *dbi = NULL;
311 dbi = postgres_find_avail_conn((db_list_t *) dbdata);
319 dbi = (dbinstance_t *) dbdata;
331 if (dbi == NULL) {
345 if (dbi->allnodes_q == NULL) {
352 if (dbi->allowxfr_q == NULL) {
359 if (dbi->authority_q == NULL) {
366 if (dbi->findzone_q == NULL) {
377 if (dbi->lookup_q == NULL) {
410 dbi->zone = postgres_escape_string(zone);
411 if (dbi->zone == NULL) {
416 dbi->zone = NULL;
431 dbi->record = postgres_escape_string(record);
432 if (dbi->record == NULL) {
437 dbi->record = NULL;
453 dbi->client = postgres_escape_string(client);
454 if (dbi->client == NULL) {
459 dbi->client = NULL;
475 querystring = build_querystring(ns_g_mctx, dbi->allnodes_q);
478 querystring = build_querystring(ns_g_mctx, dbi->allowxfr_q);
481 querystring = build_querystring(ns_g_mctx, dbi->authority_q);
484 querystring = build_querystring(ns_g_mctx, dbi->findzone_q);
487 querystring = build_querystring(ns_g_mctx, dbi->lookup_q);
539 *rs = PQexec((PGconn *)dbi->dbconn, querystring );
554 PQreset((PGconn *) dbi->dbconn);
556 if (PQstatus((PGconn *) dbi->dbconn) == CONNECTION_OK)
593 if (dbi == NULL)
596 /* free dbi->zone string */
597 if (dbi->zone != NULL)
598 isc_mem_free(ns_g_mctx, dbi->zone);
600 /* free dbi->record string */
601 if (dbi->record != NULL)
602 isc_mem_free(ns_g_mctx, dbi->record);
604 /* free dbi->client string */
605 if (dbi->client != NULL)
606 isc_mem_free(ns_g_mctx, dbi->client);
617 /* release the lock so another thread can use this dbi */
618 isc_mutex_unlock(&dbi->instance_lock);
1056 dbinstance_t *dbi = NULL;
1139 NULL, &dbi);
1144 NULL, &dbi);
1149 NULL, &dbi);
1154 argv[4], NULL, &dbi);
1178 ISC_LINK_INIT(dbi, link);
1179 ISC_LIST_APPEND(*dblist, dbi, link);
1184 dbi->dbconn = PQconnectdb(argv[2]);
1189 if (dbi->dbconn == NULL) {
1199 PQstatus((PGconn *) dbi->dbconn) != CONNECTION_OK &&
1202 PQreset((PGconn *) dbi->dbconn);
1213 if (PQstatus((PGconn *) dbi->dbconn) != CONNECTION_OK) {
1224 dbi = NULL;
1232 if (PQstatus((PGconn *) dbi->dbconn) != CONNECTION_OK) {
1244 *dbdata = dbi;
1262 if (dbi != NULL)
1263 destroy_sqldbinstance(dbi);
1287 dbinstance_t *dbi;
1291 dbi = (dbinstance_t *) dbdata;
1294 if (dbi->dbconn != NULL)
1295 PQfinish((PGconn *) dbi->dbconn);
1298 destroy_sqldbinstance(dbi);