Searched refs:db (Results 1 - 25 of 32) sorted by relevance

12

/dovecot/src/lib-sql/
H A Ddriver-pgsql.c85 static const char *pgsql_prefix(struct pgsql_db *db) argument
87 return db->host == NULL ? "pgsql" :
88 t_strdup_printf("pgsql(%s)", db->host);
91 static void driver_pgsql_set_state(struct pgsql_db *db, enum sql_db_state state) argument
93 i_assert(state == SQL_DB_STATE_BUSY || db->cur_result == NULL);
97 if (db->ioloop != NULL)
98 io_loop_set_current(db->orig_ioloop);
99 sql_db_set_state(&db->api, state);
100 if (db->ioloop != NULL)
101 io_loop_set_current(db
104 driver_pgsql_next_callback(struct pgsql_db *db) argument
117 driver_pgsql_stop_io(struct pgsql_db *db) argument
125 driver_pgsql_close(struct pgsql_db *db) argument
146 last_error(struct pgsql_db *db) argument
161 connect_callback(struct pgsql_db *db) argument
206 driver_pgsql_connect_timeout(struct pgsql_db *db) argument
217 struct pgsql_db *db = (struct pgsql_db *)_db; local
263 struct pgsql_db *db = (struct pgsql_db *)_db; local
277 struct pgsql_db *db; local
296 struct pgsql_db *db = (struct pgsql_db *)_db; local
306 driver_pgsql_set_idle(struct pgsql_db *db) argument
316 consume_results(struct pgsql_db *db) argument
344 struct pgsql_db *db = (struct pgsql_db *)_result->db; local
385 struct pgsql_db *db = (struct pgsql_db *)result->api.db; local
420 struct pgsql_db *db = (struct pgsql_db *)result->api.db; local
442 struct pgsql_db *db = (struct pgsql_db *)result->api.db; local
465 struct pgsql_db *db = (struct pgsql_db *)result->api.db; local
476 struct pgsql_db *db = (struct pgsql_db *)result->api.db; local
508 struct pgsql_db *db = (struct pgsql_db *)_db; local
535 struct pgsql_db *db = (struct pgsql_db *)_result->db; local
540 driver_pgsql_exec(struct sql_db *db, const char *query) argument
552 driver_pgsql_query(struct sql_db *db, const char *query, sql_query_callback_t *callback, void *context) argument
568 struct pgsql_db *db = context; local
573 driver_pgsql_sync_init(struct pgsql_db *db) argument
601 driver_pgsql_sync_deinit(struct pgsql_db *db) argument
607 driver_pgsql_sync_query(struct pgsql_db *db, const char *query) argument
647 struct pgsql_db *db = (struct pgsql_db *)_db; local
659 struct pgsql_db *db = (struct pgsql_db *)_result->db; local
823 struct pgsql_db *db = (struct pgsql_db *)_result->db; local
848 driver_pgsql_transaction_begin(struct sql_db *db) argument
929 struct pgsql_db *db = (struct pgsql_db *)result->db; local
949 struct pgsql_db *db = (struct pgsql_db *)result->db; local
1036 struct pgsql_db *db = (struct pgsql_db *)ctx->ctx.db; local
1074 struct pgsql_db *db = (struct pgsql_db *)_ctx->db; local
1115 struct pgsql_db *db = (struct pgsql_db *)_ctx->db; local
[all...]
H A Ddriver-sqlite.c12 /* retry time if db is busy (in ms) */
43 struct sqlite_db *db = (struct sqlite_db *)_db; local
45 if (db->connected)
48 db->rc = sqlite3_open(db->dbfile, &db->sqlite);
50 if (db->rc == SQLITE_OK) {
51 db->connected = TRUE;
52 sqlite3_busy_timeout(db->sqlite, sqlite_busy_timeout);
55 i_error("sqlite: open(%s) failed: %s", db
65 struct sqlite_db *db = (struct sqlite_db *)_db; local
73 struct sqlite_db *db; local
90 struct sqlite_db *db = (struct sqlite_db *)_db; local
132 struct sqlite_db *db = (struct sqlite_db *)_db; local
144 driver_sqlite_query(struct sql_db *db, const char *query, sql_query_callback_t *callback, void *context) argument
159 struct sqlite_db *db = (struct sqlite_db *)_db; local
190 struct sqlite_db *db = (struct sqlite_db *) result->api.db; local
301 struct sqlite_db *db = (struct sqlite_db *)result->api.db; local
310 struct sqlite_db *db = (struct sqlite_db *)_db; local
338 struct sqlite_db *db = (struct sqlite_db *)ctx->ctx.db; local
365 struct sqlite_db *db = (struct sqlite_db *) ctx->ctx.db; local
385 struct sqlite_db *db = (struct sqlite_db *)ctx->ctx.db; local
[all...]
H A Ddriver-mysql.c73 static const char *mysql_prefix(struct mysql_db *db) argument
75 return db->host == NULL ? "mysql" :
76 t_strdup_printf("mysql(%s)", db->host);
81 struct mysql_db *db = (struct mysql_db *)_db; local
83 unsigned long client_flags = db->client_flags;
88 i_assert(db->api.state == SQL_DB_STATE_DISCONNECTED);
90 sql_db_set_state(&db->api, SQL_DB_STATE_CONNECTING);
92 if (db->host == NULL) {
97 } else if (*db->host == '/') {
98 unix_socket = db
169 driver_mysql_parse_connect_string(struct mysql_db *db, const char *connect_string) argument
254 struct mysql_db *db; local
270 struct mysql_db *db = (struct mysql_db *)_db; local
280 driver_mysql_do_query(struct mysql_db *db, const char *query) argument
300 struct mysql_db *db = (struct mysql_db *)_db; local
330 struct mysql_db *db = (struct mysql_db *)_db; local
338 driver_mysql_query(struct sql_db *db, const char *query, sql_query_callback_t *callback, void *context) argument
353 struct mysql_db *db = (struct mysql_db *)_db; local
407 struct mysql_db *db = (struct mysql_db *)_result->db; local
513 struct mysql_db *db = (struct mysql_db *)_result->db; local
530 driver_mysql_transaction_begin(struct sql_db *db) argument
607 struct mysql_db *db = (struct mysql_db *)_ctx->db; local
[all...]
H A Ddriver-sqlpool.c20 struct sql_db *db; member in struct:sqlpool_connection
46 struct sqlpool_db *db; member in struct:sqlpool_request
74 sqlpool_add_connection(struct sqlpool_db *db, struct sqlpool_host *host,
84 sqlpool_request_new(struct sqlpool_db *db, const char *query) argument
89 request->db = db;
118 request->db->requests_head == request);
119 DLLIST2_REMOVE(&request->db->requests_head,
120 &request->db->requests_tail, request);
154 sqlpool_request_send_next(struct sqlpool_db *db, struc argument
182 sqlpool_find_host_with_least_connections(struct sqlpool_db *db, unsigned int *host_idx_r) argument
203 sqlpool_have_successful_connections(struct sqlpool_db *db) argument
215 sqlpool_handle_connect_failed(struct sqlpool_db *db, struct sql_db *conndb) argument
247 struct sqlpool_db *db = context; local
262 sqlpool_add_connection(struct sqlpool_db *db, struct sqlpool_host *host, unsigned int host_idx) argument
284 sqlpool_add_new_connection(struct sqlpool_db *db) argument
297 sqlpool_find_available_connection(struct sqlpool_db *db, unsigned int unwanted_host_idx, bool *all_disconnected_r) argument
330 driver_sqlpool_get_connection(struct sqlpool_db *db, unsigned int unwanted_host_idx, const struct sqlpool_connection **conn_r) argument
371 driver_sqlpool_get_sync_connection(struct sqlpool_db *db, const struct sqlpool_connection **conn_r) argument
393 driver_sqlpool_parse_hosts(struct sqlpool_db *db, const char *connect_string) argument
452 sqlpool_add_all_once(struct sqlpool_db *db) argument
468 struct sqlpool_db *db; local
488 driver_sqlpool_abort_requests(struct sqlpool_db *db) argument
500 struct sqlpool_db *db = (struct sqlpool_db *)_db; local
522 struct sqlpool_db *db = (struct sqlpool_db *)_db; local
539 struct sqlpool_db *db = (struct sqlpool_db *)_db; local
550 struct sqlpool_db *db = (struct sqlpool_db *)_db; local
565 driver_sqlpool_timeout(struct sqlpool_db *db) argument
587 driver_sqlpool_prepend_request(struct sqlpool_db *db, struct sqlpool_request *request) argument
598 driver_sqlpool_append_request(struct sqlpool_db *db, struct sqlpool_request *request) argument
612 struct sqlpool_db *db = request->db; local
647 struct sqlpool_db *db = (struct sqlpool_db *)_db; local
672 struct sqlpool_db *db = (struct sqlpool_db *)_db; local
731 struct sqlpool_db *db = (struct sqlpool_db *)_ctx->db; local
752 struct sqlpool_db *db = (struct sqlpool_db *)_ctx->db; local
797 struct sqlpool_db *db = (struct sqlpool_db *)_db; local
[all...]
H A Dsql-api.c68 struct sql_db *db; local
77 db = driver->v.init(connect_string);
79 db = driver_sqlpool_init(connect_string, driver);
80 i_array_init(&db->module_contexts, 5);
81 return db;
86 struct sql_db *db = *_db; local
90 timeout_remove(&db->to_reconnect);
91 db->v.deinit(db);
94 enum sql_db_flags sql_get_flags(struct sql_db *db) argument
99 sql_connect(struct sql_db *db) argument
121 sql_disconnect(struct sql_db *db) argument
127 sql_escape_string(struct sql_db *db, const char *string) argument
132 sql_escape_blob(struct sql_db *db, const unsigned char *data, size_t size) argument
138 sql_exec(struct sql_db *db, const char *query) argument
144 sql_query(struct sql_db *db, const char *query, sql_query_callback_t *callback, void *context) argument
150 sql_query_s(struct sql_db *db, const char *query) argument
156 default_sql_prepared_statement_init(struct sql_db *db, const char *query_template) argument
240 sql_prepared_statement_init(struct sql_db *db, const char *query_template) argument
260 sql_statement_init_fields(struct sql_statement *stmt, struct sql_db *db) argument
267 sql_statement_init(struct sql_db *db, const char *query_template) argument
597 sql_transaction_begin(struct sql_db *db) argument
665 sql_db_set_state(struct sql_db *db, enum sql_db_state state) argument
[all...]
H A Ddriver-cassandra.c20 #define IS_CONNECTED(db) \
21 ((db)->api.state != SQL_DB_STATE_DISCONNECTED && \
22 (db)->api.state != SQL_DB_STATE_CONNECTING)
73 struct cassandra_db *db; member in struct:cassandra_callback
233 static void driver_cassandra_prepare_pending(struct cassandra_db *db);
237 static void driver_cassandra_send_queries(struct cassandra_db *db);
266 static void driver_cassandra_set_state(struct cassandra_db *db, enum sql_db_state state) argument
270 if (db->ioloop != NULL)
271 io_loop_set_current(db->orig_ioloop);
272 sql_db_set_state(&db
277 driver_cassandra_close(struct cassandra_db *db, const char *error) argument
343 driver_cassandra_input_id(struct cassandra_db *db, unsigned int id) argument
361 driver_cassandra_input(struct cassandra_db *db) argument
385 driver_cassandra_set_callback(CassFuture *future, struct cassandra_db *db, driver_cassandra_callback_t *callback, void *context) argument
404 struct cassandra_db *db = context; local
425 struct cassandra_db *db = (struct cassandra_db *)_db; local
445 struct cassandra_db *db = (struct cassandra_db *)_db; local
468 driver_cassandra_parse_connect_string(struct cassandra_db *db, const char *connect_string) argument
596 driver_cassandra_get_metrics_json(struct cassandra_db *db, string_t *dest) argument
644 driver_cassandra_metrics_write(struct cassandra_db *db) argument
674 struct cassandra_db *db; local
727 struct cassandra_db *db = (struct cassandra_db *)_db; local
752 driver_cassandra_result_unlink(struct cassandra_db *db, struct cassandra_result *result) argument
771 struct cassandra_db *db = (struct cassandra_db *)result->api.db; local
809 struct cassandra_db *db = (struct cassandra_db *)_result->db; local
844 struct cassandra_db *db = (struct cassandra_db *)result->api.db; local
871 struct cassandra_db *db = (struct cassandra_db *)result->api.db; local
889 counters_inc_error(struct cassandra_db *db, CassError error) argument
916 struct cassandra_db *db = (struct cassandra_db *)result->api.db; local
980 struct cassandra_db *db = (struct cassandra_db *)result->api.db; local
993 struct cassandra_db *db = (struct cassandra_db *)result->api.db; local
1009 struct cassandra_db *db = (struct cassandra_db *)result->api.db; local
1043 struct cassandra_db *db = (struct cassandra_db *)result->api.db; local
1090 driver_cassandra_send_queries(struct cassandra_db *db) argument
1110 driver_cassandra_query_init(struct cassandra_db *db, const char *query, enum cassandra_query_type query_type, bool is_prepared, sql_query_callback_t *callback, void *context) argument
1135 struct cassandra_db *db = (struct cassandra_db *)_db; local
1144 driver_cassandra_exec(struct sql_db *db, const char *query) argument
1149 driver_cassandra_query(struct sql_db *db, const char *query, sql_query_callback_t *callback, void *context) argument
1157 struct cassandra_db *db = context; local
1162 driver_cassandra_sync_init(struct cassandra_db *db) argument
1177 driver_cassandra_sync_deinit(struct cassandra_db *db) argument
1190 driver_cassandra_sync_query(struct cassandra_db *db, const char *query, enum cassandra_query_type query_type) argument
1230 struct cassandra_db *db = (struct cassandra_db *)_db; local
1303 struct cassandra_db *db = (struct cassandra_db *)result->api.db; local
1357 struct cassandra_db *db = (struct cassandra_db *)(*_result)->db; local
1476 driver_cassandra_transaction_begin(struct sql_db *db) argument
1535 struct cassandra_db *db = (struct cassandra_db *)_ctx->db; local
1591 struct cassandra_db *db = (struct cassandra_db *)_ctx->db; local
1786 struct cassandra_db *db = (struct cassandra_db *)prep_stmt->prep_stmt.db; local
1807 driver_cassandra_prepare_pending(struct cassandra_db *db) argument
1821 driver_cassandra_prepared_statement_init(struct sql_db *db, const char *query_template) argument
1982 struct cassandra_db *db = (struct cassandra_db *)_stmt->db; local
[all...]
H A Dsql-db-cache.c7 #include "sql-db-cache.h"
19 void (*orig_deinit)(struct sql_db *db);
30 static void sql_db_cache_db_deinit(struct sql_db *db) argument
32 struct sql_db_cache_context *ctx = SQL_DB_CACHE_CONTEXT(db);
40 ctx->cache->unused_tail = db;
43 head_ctx->next = db;
46 ctx->cache->unused_head = db;
72 struct sql_db *db; local
75 db = cache->unused_tail;
76 ctx = SQL_DB_CACHE_CONTEXT(db);
96 struct sql_db *db; local
[all...]
H A Dsql-api-private.h34 #define SQL_DB_IS_READY(db) \
35 ((db)->state == SQL_DB_STATE_IDLE)
58 void (*deinit)(struct sql_db *db);
60 int (*connect)(struct sql_db *db);
61 void (*disconnect)(struct sql_db *db);
62 const char *(*escape_string)(struct sql_db *db, const char *string);
64 void (*exec)(struct sql_db *db, const char *query);
65 void (*query)(struct sql_db *db, const char *query,
67 struct sql_result *(*query_s)(struct sql_db *db, const char *query);
69 struct sql_transaction_context *(*transaction_begin)(struct sql_db *db);
158 struct sql_db *db; member in struct:sql_prepared_statement
162 struct sql_db *db; member in struct:sql_statement
178 struct sql_db *db; member in struct:sql_result
193 struct sql_db *db; member in struct:sql_transaction_context
[all...]
H A Dsql-api.h88 void sql_deinit(struct sql_db **db);
91 enum sql_db_flags sql_get_flags(struct sql_db *db);
96 int sql_connect(struct sql_db *db);
98 void sql_disconnect(struct sql_db *db);
101 const char *sql_escape_string(struct sql_db *db, const char *string);
103 const char *sql_escape_blob(struct sql_db *db,
107 void sql_exec(struct sql_db *db, const char *query);
111 void sql_query(struct sql_db *db, const char *query,
113 #define sql_query(db, query, callback, context) \
114 sql_query(db, quer
[all...]
/dovecot/src/lib-storage/
H A Dmail-duplicate.h9 bool mail_duplicate_check(struct mail_duplicate_db *db,
11 void mail_duplicate_mark(struct mail_duplicate_db *db,
15 void mail_duplicate_db_flush(struct mail_duplicate_db *db);
19 void mail_duplicate_db_deinit(struct mail_duplicate_db **db);
H A Dmail-duplicate.c198 mail_duplicate_file_new(struct mail_duplicate_db *db) argument
203 i_assert(db->path != NULL);
209 file->path = p_strdup(pool, db->path);
210 file->new_fd = file_dotlock_open(&db->dotlock_set, file->path, 0,
218 file->path, db->dotlock_set.timeout);
238 bool mail_duplicate_check(struct mail_duplicate_db *db, argument
243 if (db->file == NULL) {
244 if (db->path == NULL) {
248 db->file = mail_duplicate_file_new(db);
258 mail_duplicate_mark(struct mail_duplicate_db *db, const void *id, size_t id_size, const char *user, time_t timestamp) argument
286 mail_duplicate_db_flush(struct mail_duplicate_db *db) argument
340 struct mail_duplicate_db *db; local
362 struct mail_duplicate_db *db = *_db; local
[all...]
/dovecot/src/auth/
H A Ddb-oauth2.c17 #include "db-oauth2.h"
153 struct db_oauth2 *db)
155 return parse_setting_from_defs(db->pool, setting_defs,
156 &db->set, key, value);
161 struct db_oauth2 *db; local
166 for(db = db_oauth2_head; db != NULL; db = db->next) {
167 if (strcmp(db
152 parse_setting(const char *key, const char *value, struct db_oauth2 *db) argument
243 db_oauth2_ref(struct db_oauth2 *db) argument
251 struct db_oauth2 *ptr, *db = *_db; local
618 db_oauth2_lookup(struct db_oauth2 *db, struct db_oauth2_request *req, const char *token, struct auth_request *request, db_oauth2_lookup_callback_t *callback, void *context) argument
[all...]
H A Ddb-passwd-file.c8 #include "db-passwd-file.h"
81 else if (!pw->db->userdb || **args == '\0') {
94 if (pw->db->userdb_warn_missing) {
101 } else if (!pw->db->userdb || **args == '\0')
119 if (pw->db->userdb)
132 if (*args != NULL && **args != '\0' && pw->db->userdb) {
152 passwd_file_new(struct db_passwd_file *db, const char *expanded_path) argument
157 pw->db = db;
161 if (hash_table_is_created(db
303 db_passwd_file_set_userdb(struct db_passwd_file *db) argument
316 struct db_passwd_file *db; local
369 db_passwd_file_parse(struct db_passwd_file *db) argument
382 struct db_passwd_file *db = *_db; local
428 db_passwd_file_lookup(struct db_passwd_file *db, struct auth_request *request, const char *username_format, struct passwd_user **user_r) argument
[all...]
H A Ddb-checkpassword.h21 void db_checkpassword_deinit(struct db_checkpassword **db);
23 void db_checkpassword_call(struct db_checkpassword *db,
H A Ddb-oauth2.h16 struct db_oauth2 *db; member in struct:db_oauth2_request
38 void db_oauth2_lookup(struct db_oauth2 *db, struct db_oauth2_request *req, const char *token, struct auth_request *request, db_oauth2_lookup_callback_t *callback, void *context);
39 #define db_oauth2_lookup(db, req, token, request, callback, context) \
40 db_oauth2_lookup(db, req, token + \
H A Ddb-passwd-file.h19 struct db_passwd_file *db; member in struct:passwd_file
47 int db_passwd_file_lookup(struct db_passwd_file *db,
54 void db_passwd_file_parse(struct db_passwd_file *db);
55 void db_passwd_file_unref(struct db_passwd_file **db);
H A Ddb-checkpassword.c18 #include "db-checkpassword.h"
26 struct db_checkpassword *db; member in struct:chkpw_auth_request
80 hash_table_remove(request->db->clients,
82 child_wait_remove_pid(request->db->child_wait, request->pid);
277 /* extra fields could come from master db */
380 checkpassword_exec(struct db_checkpassword *db, struct auth_request *request, argument
409 cmd = checkpassword_get_cmd(request, db->checkpassword_path,
410 db->checkpassword_reply_path);
419 struct db_checkpassword *db)
422 hash_table_lookup(db
418 sigchld_handler(const struct child_wait_status *status, struct db_checkpassword *db) argument
449 db_checkpassword_call(struct db_checkpassword *db, struct auth_request *request, const char *auth_password, db_checkpassword_callback_t *callback, void (*request_callback)()) argument
545 struct db_checkpassword *db; local
558 struct db_checkpassword *db = *_db; local
[all...]
H A Dpassdb-oauth2.c5 #include "db-oauth2.h"
9 struct db_oauth2 *db; member in struct:oauth2_passdb_module
40 db_oauth2_lookup(module->db, req, password, request, oauth2_verify_plain_continue, request);
49 module->db = db_oauth2_init(args);
56 db_oauth2_unref(&module->db);
H A Duserdb-checkpassword.c8 #include "db-checkpassword.h"
12 struct db_checkpassword *db; member in struct:checkpassword_userdb_module
49 db_checkpassword_call(module->db, request, NULL,
62 module->db = db_checkpassword_init(checkpassword_path,
72 db_checkpassword_deinit(&module->db);
H A Dpassdb-checkpassword.c9 #include "db-checkpassword.h"
13 struct db_checkpassword *db; member in struct:checkpassword_passdb_module
65 db_checkpassword_call(module->db, request, password,
112 db_checkpassword_call(module->db, request, NULL,
125 module->db = db_checkpassword_init(checkpassword_path,
135 db_checkpassword_deinit(&module->db);
H A Ddb-sql.h25 struct sql_db *db; member in struct:sql_connection
H A Ddb-sql.c10 #include "db-sql.h"
109 conn->db = sql_init(conn->set.driver, conn->set.connect);
122 sql_disconnect(conn->db);
128 sql_deinit(&conn->db);
134 if (sql_connect(conn->db) < 0 && worker) {
H A Duserdb-sql.c9 #include "db-sql.h"
98 return sql_escape_string(module->conn->db, str);
127 sql_query(module->conn->db, query,
167 sql_query(module->conn->db, query,
283 flags = sql_get_flags(module->conn->db);
/dovecot/src/lib-dict-backend/
H A Ddict-sql-private.h8 struct sql_db *db; member in struct:sql_dict
/dovecot/src/plugins/expire/
H A Dexpire-plugin.c37 struct dict *db; member in struct:expire_mail_user
143 ret = dict_lookup(euser->db, pool_datastack_create(),
166 dctx = dict_transaction_begin(euser->db);
380 dict_deinit(&euser->db);
411 struct dict *db; local
430 if (dict_init(dict_uri, &dict_set, &db, &error) < 0) {
441 euser->db = db;

Completed in 44 milliseconds

12