Skip to content

Commit

Permalink
global: Replace sql_db_cache_new with sql_db_cache_new2
Browse files Browse the repository at this point in the history
  • Loading branch information
cmouse committed Sep 4, 2018
1 parent 29c5ddc commit 544fa8e
Show file tree
Hide file tree
Showing 3 changed files with 4 additions and 24 deletions.
2 changes: 1 addition & 1 deletion src/lib-dict-backend/dict-sql.c
Expand Up @@ -108,7 +108,7 @@ sql_dict_init(struct dict *driver, const char *uri,
/* currently pgsql and sqlite don't support "ON DUPLICATE KEY" */
dict->has_on_duplicate_key = strcmp(driver->name, "mysql") == 0;

if (sql_db_cache_new2(dict_sql_db_cache, &sql_set, &dict->db, error_r) < 0) {
if (sql_db_cache_new(dict_sql_db_cache, &sql_set, &dict->db, error_r) < 0) {
pool_unref(&pool);
return -1;
}
Expand Down
21 changes: 2 additions & 19 deletions src/lib-sql/sql-db-cache.c
Expand Up @@ -88,8 +88,8 @@ static void sql_db_cache_drop_oldest(struct sql_db_cache *cache)
sql_db_cache_free_tail(cache);
}

int sql_db_cache_new2(struct sql_db_cache *cache, const struct sql_settings *set,
struct sql_db **db_r, const char **error_r)
int sql_db_cache_new(struct sql_db_cache *cache, const struct sql_settings *set,
struct sql_db **db_r, const char **error_r)
{
struct sql_db_cache_context *ctx;
struct sql_db *db;
Expand Down Expand Up @@ -127,23 +127,6 @@ int sql_db_cache_new2(struct sql_db_cache *cache, const struct sql_settings *set
return 0;
}

struct sql_db *
sql_db_cache_new(struct sql_db_cache *cache,
const char *db_driver, const char *connect_string)
{
const char *error;
struct sql_db *db;
struct sql_settings set = {
.driver = db_driver,
.connect_string = connect_string,
};

if (sql_db_cache_new2(cache, &set, &db, &error) < 0)
i_fatal("%s", error);

return db;
}

struct sql_db_cache *sql_db_cache_init(unsigned int max_unused_connections)
{
struct sql_db_cache *cache;
Expand Down
5 changes: 1 addition & 4 deletions src/lib-sql/sql-db-cache.h
Expand Up @@ -4,10 +4,7 @@
struct sql_db_cache;

/* Like sql_init(), but use a connection pool. */
struct sql_db *
sql_db_cache_new(struct sql_db_cache *cache,
const char *db_driver, const char *connect_string);
int sql_db_cache_new2(struct sql_db_cache *cache, const struct sql_settings *set,
int sql_db_cache_new(struct sql_db_cache *cache, const struct sql_settings *set,
struct sql_db **db_r, const char **error_r);

struct sql_db_cache *sql_db_cache_init(unsigned int max_unused_connections);
Expand Down

0 comments on commit 544fa8e

Please sign in to comment.