isc_mempool_setfreemax(commctx, 6);
isc_mempool_setfillcount(commctx, 2);
- result = isc_mutex_init(&lookup_lock);
- check_result(result, "isc_mutex_init");
+ isc_mutex_init(&lookup_lock);
}
typedef struct dig_ednsoptname {
isc_result_totext(result));
}
- RUNTIME_CHECK(isc_mutex_init(&namelock) == ISC_R_SUCCESS);
- if (printstats)
- RUNTIME_CHECK(isc_mutex_init(&statslock) == ISC_R_SUCCESS);
+ isc_mutex_init(&namelock);
+
+ if (printstats) {
+ isc_mutex_init(&statslock);
+ }
presign();
TIME_NOW(&sign_start);
&server->in_roothints),
"setting up root hints");
- CHECKFATAL(isc_mutex_init(&server->reload_event_lock),
- "initializing reload event lock");
+ isc_mutex_init(&server->reload_event_lock);
+
server->reload_event =
isc_event_allocate(named_g_mctx, server,
NAMED_EVENT_RELOAD,
listener->mctx = NULL;
ISC_LINK_INIT(listener, link);
- result = isc_mutex_init(&listener->lock);
- if (result != ISC_R_SUCCESS) {
- isc_mem_put(server->mctx, listener, sizeof(*listener));
- return (ISC_R_FAILURE);
- }
+ isc_mutex_init(&listener->lock);
isc_mem_attach(server->mctx, &listener->mctx);
}
/* Initialize the lock */
- result = isc_mutex_init(&cd->lock);
- if (result != ISC_R_SUCCESS)
- goto failed;
+ isc_mutex_init(&cd->lock);
/* Open the library */
dlopen_flags = RTLD_NOW|RTLD_GLOBAL;
triedload = true;
/* Initialize the lock */
- result = isc_mutex_init(&cd->lock);
- if (result != ISC_R_SUCCESS)
- goto failed;
+ isc_mutex_init(&cd->lock);
/* Open the library */
cd->dl_handle = LoadLibraryA(cd->dl_path);
isc_stdtime_get(&now);
- result = isc_mutex_init(&client_lock);
- check_result(result, "isc_mutex_init(&client_lock)");
+ isc_mutex_init(&client_lock);
+
ISC_LIST_INIT(clients);
/*
isc_mem_debugging = ISC_MEM_DEBUGRECORD;
- RUNTIME_CHECK(isc_mutex_init(&lock) == ISC_R_SUCCESS);
+ isc_mutex_init(&lock);
mctx = NULL;
RUNTIME_CHECK(isc_mem_create(0, 0, &mctx) == ISC_R_SUCCESS);
RUNTIME_CHECK(isc_app_start() == ISC_R_SUCCESS);
- RUNTIME_CHECK(isc_mutex_init(&lock) == ISC_R_SUCCESS);
+ isc_mutex_init(&lock);
mctx = NULL;
RUNTIME_CHECK(isc_mem_create(0, 0, &mctx) == ISC_R_SUCCESS);
/*
* Copyright (C) 1999-2001, 2016 Internet Systems Consortium, Inc. ("ISC")
- *
+ *
* This Source Code Form is subject to the terms of the Mozilla Public
* License, v. 2.0. If a copy of the MPL was not distributed with this
* file, You can obtain one at http://mozilla.org/MPL/2.0/.
isc_mem_attach(mctx, &db->mctx);
/* initialize the reference count mutex */
- result = isc_mutex_init(&db->instance_lock);
- if (result != ISC_R_SUCCESS) {
- UNEXPECTED_ERROR(__FILE__, __LINE__,
- "isc_mutex_init() failed: %s",
- isc_result_totext(result));
- goto cleanup;
- }
+ isc_mutex_init(&db->instance_lock);
/* build the all nodes query list */
result = build_querylist(mctx, allnodes_str, &db->zone,
static void
initialize_action(void) {
- RUNTIME_CHECK(isc_mutex_init(&insecure_prefix_lock) == ISC_R_SUCCESS);
+ isc_mutex_init(&insecure_prefix_lock);
}
/*
static inline dns_adbfind_t *
new_adbfind(dns_adb_t *adb) {
dns_adbfind_t *h;
- isc_result_t result;
h = isc_mempool_get(adb->ahmp);
if (h == NULL)
/*
* private members
*/
- result = isc_mutex_init(&h->lock);
- if (result != ISC_R_SUCCESS) {
- isc_mempool_put(adb->ahmp, h);
- return (NULL);
- }
+ isc_mutex_init(&h->lock);
ISC_EVENT_INIT(&h->event, sizeof(isc_event_t), 0, 0, 0, NULL, NULL,
NULL, NULL, h);
isc_mem_attach(mem, &adb->mctx);
- result = isc_mutex_init(&adb->lock);
- if (result != ISC_R_SUCCESS)
- goto fail0b;
-
- result = isc_mutex_init(&adb->mplock);
- if (result != ISC_R_SUCCESS)
- goto fail0c;
-
- result = isc_mutex_init(&adb->reflock);
- if (result != ISC_R_SUCCESS)
- goto fail0d;
-
- result = isc_mutex_init(&adb->overmemlock);
- if (result != ISC_R_SUCCESS)
- goto fail0e;
-
- result = isc_mutex_init(&adb->entriescntlock);
- if (result != ISC_R_SUCCESS)
- goto fail0f;
-
- result = isc_mutex_init(&adb->namescntlock);
- if (result != ISC_R_SUCCESS)
- goto fail0g;
+ isc_mutex_init(&adb->lock);
+ isc_mutex_init(&adb->mplock);
+ isc_mutex_init(&adb->reflock);
+ isc_mutex_init(&adb->overmemlock);
+ isc_mutex_init(&adb->entriescntlock);
+ isc_mutex_init(&adb->namescntlock);
#define ALLOCENTRY(adb, el) \
do { \
isc_mempool_destroy(&adb->afmp);
DESTROYLOCK(&adb->namescntlock);
- fail0g:
DESTROYLOCK(&adb->entriescntlock);
- fail0f:
DESTROYLOCK(&adb->overmemlock);
- fail0e:
DESTROYLOCK(&adb->reflock);
- fail0d:
DESTROYLOCK(&adb->mplock);
- fail0c:
DESTROYLOCK(&adb->lock);
- fail0b:
if (adb->excl != NULL)
isc_task_detach(&adb->excl);
isc_mem_putanddetach(&adb->mctx, adb, sizeof(dns_adb_t));
memset(bc, 0, sizeof(dns_badcache_t));
isc_mem_attach(mctx, &bc->mctx);
- result = isc_mutex_init(&bc->lock);
- if (result != ISC_R_SUCCESS)
- goto cleanup;
+ isc_mutex_init(&bc->lock);
bc->table = isc_mem_get(bc->mctx, sizeof(*bc->table) * size);
if (bc->table == NULL) {
destroy_lock:
DESTROYLOCK(&bc->lock);
- cleanup:
isc_mem_putanddetach(&bc->mctx, bc, sizeof(dns_badcache_t));
return (result);
}
byaddr->task = NULL;
isc_task_attach(task, &byaddr->task);
- result = isc_mutex_init(&byaddr->lock);
- if (result != ISC_R_SUCCESS)
- goto cleanup_event;
+ isc_mutex_init(&byaddr->lock);
dns_fixedname_init(&byaddr->name);
cleanup_lock:
DESTROYLOCK(&byaddr->lock);
- cleanup_event:
ievent = (isc_event_t *)byaddr->event;
isc_event_free(&ievent);
byaddr->event = NULL;
}
}
- result = isc_mutex_init(&cache->lock);
- if (result != ISC_R_SUCCESS)
- goto cleanup_mem;
-
- result = isc_mutex_init(&cache->filelock);
- if (result != ISC_R_SUCCESS)
- goto cleanup_lock;
+ isc_mutex_init(&cache->lock);
+ isc_mutex_init(&cache->filelock);
cache->references = 1;
cache->live_tasks = 0;
*cachep = cache;
return (ISC_R_SUCCESS);
- cleanup_db:
+cleanup_db:
dns_db_detach(&cache->db);
- cleanup_dbargv:
+cleanup_dbargv:
for (i = extra; i < cache->db_argc; i++)
if (cache->db_argv[i] != NULL)
isc_mem_free(cmctx, cache->db_argv[i]);
if (cache->db_argv != NULL)
isc_mem_put(cmctx, cache->db_argv,
cache->db_argc * sizeof(char *));
- cleanup_dbtype:
+cleanup_dbtype:
isc_mem_free(cmctx, cache->db_type);
- cleanup_filelock:
+cleanup_filelock:
DESTROYLOCK(&cache->filelock);
- cleanup_stats:
+cleanup_stats:
isc_stats_detach(&cache->stats);
- cleanup_lock:
DESTROYLOCK(&cache->lock);
- cleanup_mem:
- if (cache->name != NULL)
+cleanup_mem:
+ if (cache->name != NULL) {
isc_mem_free(cmctx, cache->name);
+ }
isc_mem_detach(&cache->hmctx);
isc_mem_putanddetach(&cache->mctx, cache, sizeof(*cache));
return (result);
{
isc_result_t result;
- result = isc_mutex_init(&cleaner->lock);
- if (result != ISC_R_SUCCESS)
- goto fail;
+ isc_mutex_init(&cleaner->lock);
cleaner->increment = DNS_CACHE_CLEANERINCREMENT;
cleaner->state = cleaner_s_idle;
if (cleaner->iterator != NULL)
dns_dbiterator_destroy(&cleaner->iterator);
DESTROYLOCK(&cleaner->lock);
- fail:
+
return (result);
}
return (ISC_R_NOMEMORY);
memset(new_zones, 0, sizeof(*new_zones));
- result = isc_mutex_init(&new_zones->lock);
- if (result != ISC_R_SUCCESS)
- goto cleanup_newzones;
+ isc_mutex_init(&new_zones->lock);
isc_refcount_init(&new_zones->refs, 1);
cleanup_refcount:
isc_refcount_destroy(&new_zones->refs);
isc_mutex_destroy(&new_zones->lock);
- cleanup_newzones:
isc_mem_put(mctx, new_zones, sizeof(*new_zones));
return (result);
if (client == NULL)
return (ISC_R_NOMEMORY);
- result = isc_mutex_init(&client->lock);
- if (result != ISC_R_SUCCESS) {
- isc_mem_put(mctx, client, sizeof(*client));
- return (result);
- }
+ isc_mutex_init(&client->lock);
client->actx = actx;
client->taskmgr = taskmgr;
if (resarg == NULL)
return (ISC_R_NOMEMORY);
- result = isc_mutex_init(&resarg->lock);
- if (result != ISC_R_SUCCESS) {
- isc_mem_put(client->mctx, resarg, sizeof(*resarg));
- return (result);
- }
+ isc_mutex_init(&resarg->lock);
resarg->actx = actx;
resarg->client = client;
if (rctx == NULL)
result = ISC_R_NOMEMORY;
else {
- result = isc_mutex_init(&rctx->lock);
- if (result != ISC_R_SUCCESS) {
- isc_mem_put(mctx, rctx, sizeof(*rctx));
- rctx = NULL;
- }
+ isc_mutex_init(&rctx->lock);
}
if (result != ISC_R_SUCCESS)
goto cleanup;
if (reqarg == NULL)
return (ISC_R_NOMEMORY);
- result = isc_mutex_init(&reqarg->lock);
- if (result != ISC_R_SUCCESS) {
- isc_mem_put(client->mctx, reqarg, sizeof(*reqarg));
- return (result);
- }
+ isc_mutex_init(&reqarg->lock);
reqarg->actx = actx;
reqarg->client = client;
if (ctx == NULL)
result = ISC_R_NOMEMORY;
else {
- result = isc_mutex_init(&ctx->lock);
- if (result != ISC_R_SUCCESS) {
- isc_mem_put(client->mctx, ctx, sizeof(*ctx));
- ctx = NULL;
- }
+ isc_mutex_init(&ctx->lock);
}
if (result != ISC_R_SUCCESS)
goto cleanup;
if (uarg == NULL)
return (ISC_R_NOMEMORY);
- result = isc_mutex_init(&uarg->lock);
- if (result != ISC_R_SUCCESS) {
- isc_mem_put(client->mctx, uarg, sizeof(*uarg));
- return (result);
- }
+ isc_mutex_init(&uarg->lock);
uarg->actx = actx;
uarg->client = client;
return (ISC_R_NOMEMORY);
}
- result = isc_mutex_init(&uctx->lock);
- if (result != ISC_R_SUCCESS) {
- dns_view_detach(&view);
- isc_mem_put(client->mctx, uctx, sizeof(*uctx));
- return (ISC_R_NOMEMORY);
- }
+ isc_mutex_init(&uctx->lock);
tclone = NULL;
isc_task_attach(task, &tclone);
if (result != ISC_R_SUCCESS)
goto clean1;
- result = isc_mutex_init(&dbtable->lock);
- if (result != ISC_R_SUCCESS)
- goto clean2;
+ isc_mutex_init(&dbtable->lock);
result = isc_rwlock_init(&dbtable->tree_lock, 0, 0);
if (result != ISC_R_SUCCESS)
clean3:
DESTROYLOCK(&dbtable->lock);
- clean2:
dns_rbt_destroy(&dbtable->rbt);
clean1:
mgr->blackhole = NULL;
mgr->stats = NULL;
- result = isc_mutex_init(&mgr->lock);
- if (result != ISC_R_SUCCESS)
- goto deallocate;
-
- result = isc_mutex_init(&mgr->buffer_lock);
- if (result != ISC_R_SUCCESS)
- goto kill_lock;
-
- result = isc_mutex_init(&mgr->depool_lock);
- if (result != ISC_R_SUCCESS)
- goto kill_buffer_lock;
-
- result = isc_mutex_init(&mgr->rpool_lock);
- if (result != ISC_R_SUCCESS)
- goto kill_depool_lock;
-
- result = isc_mutex_init(&mgr->dpool_lock);
- if (result != ISC_R_SUCCESS)
- goto kill_rpool_lock;
-
- result = isc_mutex_init(&mgr->bpool_lock);
- if (result != ISC_R_SUCCESS)
- goto kill_dpool_lock;
-
- result = isc_mutex_init(&mgr->spool_lock);
- if (result != ISC_R_SUCCESS)
- goto kill_bpool_lock;
+ isc_mutex_init(&mgr->lock);
+ isc_mutex_init(&mgr->buffer_lock);
+ isc_mutex_init(&mgr->depool_lock);
+ isc_mutex_init(&mgr->rpool_lock);
+ isc_mutex_init(&mgr->dpool_lock);
+ isc_mutex_init(&mgr->bpool_lock);
+ isc_mutex_init(&mgr->spool_lock);
mgr->depool = NULL;
if (isc_mempool_create(mgr->mctx, sizeof(dns_dispatchevent_t),
isc_mempool_destroy(&mgr->depool);
kill_spool_lock:
DESTROYLOCK(&mgr->spool_lock);
- kill_bpool_lock:
DESTROYLOCK(&mgr->bpool_lock);
- kill_dpool_lock:
DESTROYLOCK(&mgr->dpool_lock);
- kill_rpool_lock:
DESTROYLOCK(&mgr->rpool_lock);
- kill_depool_lock:
DESTROYLOCK(&mgr->depool_lock);
- kill_buffer_lock:
DESTROYLOCK(&mgr->buffer_lock);
- kill_lock:
DESTROYLOCK(&mgr->lock);
- deallocate:
isc_mem_put(mctx, mgr, sizeof(dns_dispatchmgr_t));
isc_mem_detach(&mctx);
{
dns_qid_t *qid;
unsigned int i;
- isc_result_t result;
REQUIRE(VALID_DISPATCHMGR(mgr));
REQUIRE(buckets < 2097169); /* next prime > 65536 * 32 */
}
}
- result = isc_mutex_init(&qid->lock);
- if (result != ISC_R_SUCCESS) {
- if (qid->sock_table != NULL) {
- isc_mem_put(mgr->mctx, qid->sock_table,
- buckets * sizeof(dispsocketlist_t));
- }
- isc_mem_put(mgr->mctx, qid->qid_table,
- buckets * sizeof(dns_displist_t));
- isc_mem_put(mgr->mctx, qid, sizeof(*qid));
- return (result);
- }
+ isc_mutex_init(&qid->lock);
for (i = 0; i < buckets; i++) {
ISC_LIST_INIT(qid->qid_table[i]);
disp->portpool = NULL;
disp->dscp = -1;
- result = isc_mutex_init(&disp->lock);
- if (result != ISC_R_SUCCESS)
- goto deallocate;
+ isc_mutex_init(&disp->lock);
disp->failsafe_ev = allocate_devent(disp);
if (disp->failsafe_ev == NULL) {
*/
kill_lock:
DESTROYLOCK(&disp->lock);
- deallocate:
isc_mempool_put(mgr->dpool, disp);
return (result);
goto kill_ctlevent;
}
- result = isc_mutex_init(&disp->sepool_lock);
- if (result != ISC_R_SUCCESS) {
- goto kill_sepool;
- }
+ isc_mutex_init(&disp->sepool_lock);
isc_mempool_setname(disp->sepool, "disp_sepool");
isc_mempool_setmaxalloc(disp->sepool, 32768);
/*
* Error returns.
*/
- kill_sepool:
- isc_mempool_destroy(&disp->sepool);
kill_ctlevent:
isc_event_free(&disp->ctlevent);
kill_task:
return (ISC_R_NOMEMORY);
memset(dset, 0, sizeof(*dset));
- result = isc_mutex_init(&dset->lock);
- if (result != ISC_R_SUCCESS)
- goto fail_alloc;
+ isc_mutex_init(&dset->lock);
dset->dispatches = isc_mem_get(mctx, sizeof(dns_dispatch_t *) * n);
if (dset->dispatches == NULL) {
fail_lock:
DESTROYLOCK(&dset->lock);
-
- fail_alloc:
isc_mem_put(mctx, dset, sizeof(dns_dispatchset_t));
return (result);
}
if (librpz == NULL)
return (ISC_R_SUCCESS);
- result = isc_mutex_init(&dnsrps_mutex);
- if (result != ISC_R_SUCCESS)
- return (result);
+ isc_mutex_init(&dnsrps_mutex);
librpz->set_log(&dnsrps_log_fnc, NULL);
static void
mutex_init(void) {
- RUNTIME_CHECK(isc_mutex_init(&dt_mutex) == ISC_R_SUCCESS);
+ isc_mutex_init(&dt_mutex);
}
static void
static void
dyndb_initialize(void) {
- RUNTIME_CHECK(isc_mutex_init(&dyndb_lock) == ISC_R_SUCCESS);
+ isc_mutex_init(&dyndb_lock);
INIT_LIST(dyndb_implementations);
}
if (node == NULL)
return (ISC_R_NOMEMORY);
- result = isc_mutex_init(&node->lock);
- if (result != ISC_R_SUCCESS) {
- UNEXPECTED_ERROR(__FILE__, __LINE__,
- "isc_mutex_init() failed: %s",
- isc_result_totext(result));
- isc_mem_put(mctx, node, sizeof(*node));
- return (ISC_R_UNEXPECTED);
- }
+ isc_mutex_init(&node->lock);
dns_name_init(&node->name, NULL);
result = dns_name_dup(name, mctx, &node->name);
return (result);
}
- result = isc_mutex_init(&ecdb->lock);
- if (result != ISC_R_SUCCESS) {
- UNEXPECTED_ERROR(__FILE__, __LINE__,
- "isc_mutex_init() failed: %s",
- isc_result_totext(result));
- if (dns_name_dynamic(&ecdb->common.origin))
- dns_name_free(&ecdb->common.origin, mctx);
- isc_mem_put(mctx, ecdb, sizeof(*ecdb));
- return (ISC_R_UNEXPECTED);
- }
+ isc_mutex_init(&ecdb->lock);
ecdb->references = 1;
ISC_LIST_INIT(ecdb->nodes);
static void
key_mutex_init(void) {
- RUNTIME_CHECK(isc_mutex_init(&key_mutex) == ISC_R_SUCCESS);
+ isc_mutex_init(&key_mutex);
}
static void
if (result != ISC_R_SUCCESS)
goto cleanup_db;
- result = isc_mutex_init(&reflock);
- if (result != ISC_R_SUCCESS)
- goto cleanup_dst;
+ isc_mutex_init(&reflock);
initialize_done = true;
return;
- cleanup_dst:
- dst_lib_destroy();
cleanup_db:
if (dbimp != NULL)
dns_ecdb_unregister(&dbimp);
lookup->task = NULL;
isc_task_attach(task, &lookup->task);
- result = isc_mutex_init(&lookup->lock);
- if (result != ISC_R_SUCCESS)
- goto cleanup_event;
+ isc_mutex_init(&lookup->lock);
dns_fixedname_init(&lookup->name);
cleanup_lock:
DESTROYLOCK(&lookup->lock);
-
- cleanup_event:
ievent = (isc_event_t *)lookup->event;
isc_event_free(&ievent);
lookup->event = NULL;
lctx = isc_mem_get(mctx, sizeof(*lctx));
if (lctx == NULL)
return (ISC_R_NOMEMORY);
- result = isc_mutex_init(&lctx->lock);
- if (result != ISC_R_SUCCESS) {
- isc_mem_put(mctx, lctx, sizeof(*lctx));
- return (result);
- }
+ isc_mutex_init(&lctx->lock);
lctx->inc = NULL;
result = incctx_create(mctx, origin, &lctx->inc);
if (result != ISC_R_SUCCESS)
goto cleanup;
- result = isc_mutex_init(&dctx->lock);
- if (result != ISC_R_SUCCESS)
- goto cleanup;
+ isc_mutex_init(&dctx->lock);
+
if (version != NULL)
dns_db_attachversion(dctx->db, version, &dctx->version);
else if (!dns_db_iscache(db))
static void
thread_key_mutex_init(void) {
- RUNTIME_CHECK(isc_mutex_init(&thread_key_mutex) == ISC_R_SUCCESS);
+ isc_mutex_init(&thread_key_mutex);
}
static isc_result_t
isc_result_t
dns_portlist_create(isc_mem_t *mctx, dns_portlist_t **portlistp) {
dns_portlist_t *portlist;
- isc_result_t result;
REQUIRE(portlistp != NULL && *portlistp == NULL);
portlist = isc_mem_get(mctx, sizeof(*portlist));
if (portlist == NULL)
return (ISC_R_NOMEMORY);
- result = isc_mutex_init(&portlist->lock);
- if (result != ISC_R_SUCCESS) {
- isc_mem_put(mctx, portlist, sizeof(*portlist));
- return (result);
- }
+ isc_mutex_init(&portlist->lock);
isc_refcount_init(&portlist->refcount, 1);
portlist->list = NULL;
portlist->allocated = 0;
static isc_mutex_t wks_lock;
static void init_lock(void) {
- RUNTIME_CHECK(isc_mutex_init(&wks_lock) == ISC_R_SUCCESS);
+ isc_mutex_init(&wks_lock);
}
static bool
{
dns_requestmgr_t *requestmgr;
isc_socket_t *sock;
- isc_result_t result;
int i;
unsigned int dispattr;
if (requestmgr == NULL)
return (ISC_R_NOMEMORY);
- result = isc_mutex_init(&requestmgr->lock);
- if (result != ISC_R_SUCCESS) {
- isc_mem_put(mctx, requestmgr, sizeof(*requestmgr));
- return (result);
- }
+ isc_mutex_init(&requestmgr->lock);
+
for (i = 0; i < DNS_REQUEST_NLOCKS; i++) {
- result = isc_mutex_init(&requestmgr->locks[i]);
- if (result != ISC_R_SUCCESS) {
- while (--i >= 0)
- DESTROYLOCK(&requestmgr->locks[i]);
- DESTROYLOCK(&requestmgr->lock);
- isc_mem_put(mctx, requestmgr, sizeof(*requestmgr));
- return (result);
- }
+ isc_mutex_init(&requestmgr->locks[i]);
}
requestmgr->timermgr = timermgr;
requestmgr->socketmgr = socketmgr;
goto cleanup_badcache;
}
for (i = 0; i < ntasks; i++) {
- result = isc_mutex_init(&res->buckets[i].lock);
- if (result != ISC_R_SUCCESS)
- goto cleanup_buckets;
+ isc_mutex_init(&res->buckets[i].lock);
+
res->buckets[i].task = NULL;
result = isc_task_create(taskmgr, 0, &res->buckets[i].task);
if (result != ISC_R_SUCCESS) {
ISC_LIST_INIT(res->dbuckets[i].list);
res->dbuckets[i].mctx = NULL;
isc_mem_attach(view->mctx, &res->dbuckets[i].mctx);
- result = isc_mutex_init(&res->dbuckets[i].lock);
- if (result != ISC_R_SUCCESS) {
- isc_mem_detach(&res->dbuckets[i].mctx);
- goto cleanup_dbuckets;
- }
+ isc_mutex_init(&res->dbuckets[i].lock);
dbuckets_created++;
}
res->primefetch = NULL;
res->nfctx = 0;
- result = isc_mutex_init(&res->lock);
- if (result != ISC_R_SUCCESS)
- goto cleanup_dispatches;
-
- result = isc_mutex_init(&res->nlock);
- if (result != ISC_R_SUCCESS)
- goto cleanup_lock;
-
- result = isc_mutex_init(&res->primelock);
- if (result != ISC_R_SUCCESS)
- goto cleanup_nlock;
+ isc_mutex_init(&res->lock);
+ isc_mutex_init(&res->nlock);
+ isc_mutex_init(&res->primelock);
task = NULL;
result = isc_task_create(taskmgr, 0, &task);
cleanup_primelock:
DESTROYLOCK(&res->primelock);
-
- cleanup_nlock:
DESTROYLOCK(&res->nlock);
-
- cleanup_lock:
DESTROYLOCK(&res->lock);
- cleanup_dispatches:
if (res->dispatches6 != NULL)
dns_dispatchset_destroy(&res->dispatches6);
if (res->dispatches4 != NULL)
dns_dispatchset_destroy(&res->dispatches4);
- cleanup_dbuckets:
for (i = 0; i < dbuckets_created; i++) {
DESTROYLOCK(&res->dbuckets[i].lock);
isc_mem_detach(&res->dbuckets[i].mctx);
if (result != ISC_R_SUCCESS)
goto cleanup_rwlock;
- result = isc_mutex_init(&zones->maint_lock);
- if (result != ISC_R_SUCCESS)
- goto cleanup_mutex;
-
+ isc_mutex_init(&zones->maint_lock);
isc_refcount_init(&zones->refs, 1);
zones->rps_cstr = rps_cstr;
DESTROYLOCK(&zones->maint_lock);
-cleanup_mutex:
isc_rwlock_destroy(&zones->search_lock);
cleanup_rwlock:
return (ISC_R_NOMEMORY);
memset(rrl, 0, sizeof(*rrl));
isc_mem_attach(view->mctx, &rrl->mctx);
- result = isc_mutex_init(&rrl->lock);
- if (result != ISC_R_SUCCESS) {
- isc_mem_putanddetach(&rrl->mctx, rrl, sizeof(*rrl));
- return (result);
- }
+ isc_mutex_init(&rrl->lock);
isc_stdtime_get(&rrl->ts_bases[0]);
view->rrl = rrl;
imp->flags = flags;
imp->mctx = NULL;
isc_mem_attach(mctx, &imp->mctx);
- result = isc_mutex_init(&imp->driverlock);
- if (result != ISC_R_SUCCESS)
- goto cleanup_mctx;
+ isc_mutex_init(&imp->driverlock);
imp->dbimp = NULL;
result = dns_db_register(drivername, dns_sdb_create, imp, mctx,
cleanup_mutex:
DESTROYLOCK(&imp->driverlock);
- cleanup_mctx:
isc_mem_put(mctx, imp, sizeof(dns_sdbimplementation_t));
return (result);
}
static isc_result_t
createnode(dns_sdb_t *sdb, dns_sdbnode_t **nodep) {
dns_sdbnode_t *node;
- isc_result_t result;
node = isc_mem_get(sdb->common.mctx, sizeof(dns_sdbnode_t));
if (node == NULL)
ISC_LIST_INIT(node->buffers);
ISC_LINK_INIT(node, link);
node->name = NULL;
- result = isc_mutex_init(&node->lock);
- if (result != ISC_R_SUCCESS) {
- isc_mem_put(sdb->common.mctx, node, sizeof(dns_sdbnode_t));
- return (result);
- }
+ isc_mutex_init(&node->lock);
dns_rdatacallbacks_init(&node->callbacks);
node->references = 1;
node->magic = SDBLOOKUP_MAGIC;
isc_mem_attach(mctx, &sdb->common.mctx);
- result = isc_mutex_init(&sdb->lock);
- if (result != ISC_R_SUCCESS)
- goto cleanup_mctx;
+ isc_mutex_init(&sdb->lock);
result = dns_name_dupwithoffsets(origin, mctx, &sdb->common.origin);
if (result != ISC_R_SUCCESS)
dns_name_free(&sdb->common.origin, mctx);
cleanup_lock:
(void)isc_mutex_destroy(&sdb->lock);
- cleanup_mctx:
isc_mem_put(mctx, sdb, sizeof(dns_sdb_t));
isc_mem_detach(&mctx);
static isc_result_t
createnode(dns_sdlz_db_t *sdlz, dns_sdlznode_t **nodep) {
dns_sdlznode_t *node;
- isc_result_t result;
node = isc_mem_get(sdlz->common.mctx, sizeof(dns_sdlznode_t));
if (node == NULL)
ISC_LIST_INIT(node->buffers);
ISC_LINK_INIT(node, link);
node->name = NULL;
- result = isc_mutex_init(&node->lock);
- if (result != ISC_R_SUCCESS) {
- UNEXPECTED_ERROR(__FILE__, __LINE__,
- "isc_mutex_init() failed: %s",
- isc_result_totext(result));
- isc_mem_put(sdlz->common.mctx, node, sizeof(dns_sdlznode_t));
- return (ISC_R_UNEXPECTED);
- }
+ isc_mutex_init(&node->lock);
dns_rdatacallbacks_init(&node->callbacks);
node->references = 1;
node->magic = SDLZLOOKUP_MAGIC;
goto mem_cleanup;
/* initialize the reference count mutex */
- result = isc_mutex_init(&sdlzdb->refcnt_lock);
- if (result != ISC_R_SUCCESS)
- goto name_cleanup;
+ isc_mutex_init(&sdlzdb->refcnt_lock);
/* set the rest of the database structure attributes */
sdlzdb->dlzimp = imp;
*dbp = (dns_db_t *) sdlzdb;
return (result);
-
- /*
- * reference count mutex could not be initialized, clean up
- * name memory
- */
- name_cleanup:
- dns_name_free(&sdlzdb->common.origin, mctx);
mem_cleanup:
isc_mem_put(mctx, sdlzdb, sizeof(dns_sdlz_db_t));
return (result);
* initialize the driver lock, error if we cannot
* (used if a driver does not support multiple threads)
*/
- result = isc_mutex_init(&imp->driverlock);
- if (result != ISC_R_SUCCESS) {
- UNEXPECTED_ERROR(__FILE__, __LINE__,
- "isc_mutex_init() failed: %s",
- isc_result_totext(result));
- goto cleanup_mctx;
- }
+ isc_mutex_init(&imp->driverlock);
imp->dlz_imp = NULL;
/* destroy the driver lock, we don't need it anymore */
DESTROYLOCK(&imp->driverlock);
- cleanup_mctx:
/*
* return the memory back to the available memory pool and
* remove it from the memory context.
isc_result_t
dns_ssutable_create(isc_mem_t *mctx, dns_ssutable_t **tablep) {
- isc_result_t result;
dns_ssutable_t *table;
REQUIRE(tablep != NULL && *tablep == NULL);
table = isc_mem_get(mctx, sizeof(dns_ssutable_t));
if (table == NULL)
return (ISC_R_NOMEMORY);
- result = isc_mutex_init(&table->lock);
- if (result != ISC_R_SUCCESS) {
- isc_mem_put(mctx, table, sizeof(dns_ssutable_t));
- return (result);
- }
+ isc_mutex_init(&table->lock);
table->references = 1;
table->mctx = NULL;
isc_mem_attach(mctx, &table->mctx);
stats->counters = NULL;
stats->references = 1;
- result = isc_mutex_init(&stats->lock);
- if (result != ISC_R_SUCCESS)
- goto clean_stats;
+ isc_mutex_init(&stats->lock);
result = isc_stats_create(mctx, &stats->counters, ncounters);
if (result != ISC_R_SUCCESS)
clean_mutex:
DESTROYLOCK(&stats->lock);
- clean_stats:
isc_mem_put(mctx, stats, sizeof(*stats));
return (result);
UNUSED(state);
- result = isc_mutex_init(&lock);
- assert_int_equal(result, ISC_R_SUCCESS);
+ isc_mutex_init(&lock);
result = isc_task_create(taskmgr, 0, &task);
assert_int_equal(result, ISC_R_SUCCESS);
memset(event->proofs, 0, sizeof(event->proofs));
event->optout = false;
event->secure = false;
- result = isc_mutex_init(&val->lock);
- if (result != ISC_R_SUCCESS)
- goto cleanup_event;
+
+ isc_mutex_init(&val->lock);
+
val->event = event;
val->options = options;
val->attributes = 0;
cleanup_mutex:
DESTROYLOCK(&val->lock);
- cleanup_event:
isc_task_detach(&tclone);
isc_event_free(ISC_EVENT_PTR(&event));
goto cleanup_name;
}
- result = isc_mutex_init(&view->lock);
- if (result != ISC_R_SUCCESS)
- goto cleanup_name;
+ isc_mutex_init(&view->lock);
view->zonetable = NULL;
result = dns_zt_create(mctx, rdclass, &view->zonetable);
view->dtenv = NULL;
view->dttypes = 0;
- result = isc_mutex_init(&view->new_zone_lock);
- if (result != ISC_R_SUCCESS) {
- goto cleanup_failcache;
- }
+ isc_mutex_init(&view->new_zone_lock);
result = dns_order_create(view->mctx, &view->order);
if (result != ISC_R_SUCCESS) {
cleanup_new_zone_lock:
DESTROYLOCK(&view->new_zone_lock);
- cleanup_failcache:
dns_badcache_destroy(&view->failcache);
cleanup_dynkeys:
zone->mctx = NULL;
isc_mem_attach(mctx, &zone->mctx);
- result = isc_mutex_init(&zone->lock);
- if (result != ISC_R_SUCCESS) {
- goto free_zone;
- }
+ isc_mutex_init(&zone->lock);
result = ZONEDB_INITLOCK(&zone->dblock);
if (result != ISC_R_SUCCESS) {
free_mutex:
DESTROYLOCK(&zone->lock);
- free_zone:
isc_mem_putanddetach(&zone->mctx, zone, sizeof(*zone));
return (result);
}
ISC_LIST_INIT(zmgr->high);
ISC_LIST_INIT(zmgr->low);
- result = isc_mutex_init(&zmgr->iolock);
- if (result != ISC_R_SUCCESS)
- goto free_startuprefreshrl;
+ isc_mutex_init(&zmgr->iolock);
zmgr->magic = ZONEMGR_MAGIC;
free_iolock:
DESTROYLOCK(&zmgr->iolock);
#endif
- free_startuprefreshrl:
- isc_ratelimiter_detach(&zmgr->startuprefreshrl);
free_startupnotifyrl:
isc_ratelimiter_detach(&zmgr->startupnotifyrl);
free_refreshrl:
static void
thread_key_mutex_init(void) {
- RUNTIME_CHECK(isc_mutex_init(&thread_key_mutex) == ISC_R_SUCCESS);
+ isc_mutex_init(&thread_key_mutex);
}
static isc_result_t
head.ai_port = port;
head.actx = actx;
head.dnsclient = client;
- result = isc_mutex_init(&head.list_lock);
- if (result != ISC_R_SUCCESS) {
- return (EAI_FAIL);
- }
+ isc_mutex_init(&head.list_lock);
ISC_LIST_INIT(head.resstates);
result = make_resstates(mctx, hostname, &head, conf);
isc_result_t
isc_counter_create(isc_mem_t *mctx, int limit, isc_counter_t **counterp) {
- isc_result_t result;
isc_counter_t *counter;
REQUIRE(counterp != NULL && *counterp == NULL);
if (counter == NULL)
return (ISC_R_NOMEMORY);
- result = isc_mutex_init(&counter->lock);
- if (result != ISC_R_SUCCESS) {
- isc_mem_put(mctx, counter, sizeof(*counter));
- return (result);
- }
+ isc_mutex_init(&counter->lock);
counter->mctx = NULL;
isc_mem_attach(mctx, &counter->mctx);
if (httpdmgr == NULL)
return (ISC_R_NOMEMORY);
- result = isc_mutex_init(&httpdmgr->lock);
- if (result != ISC_R_SUCCESS) {
- isc_mem_put(mctx, httpdmgr, sizeof(isc_httpdmgr_t));
- return (result);
- }
+ isc_mutex_init(&httpdmgr->lock);
httpdmgr->mctx = NULL;
isc_mem_attach(mctx, &httpdmgr->mctx);
httpdmgr->sock = NULL;
#define ISC_QUEUE_INIT(queue, link) \
do { \
- (void) isc_mutex_init(&(queue).taillock); \
- (void) isc_mutex_init(&(queue).headlock); \
+ isc_mutex_init(&(queue).taillock); \
+ isc_mutex_init(&(queue).headlock); \
(queue).tail = (queue).head = NULL; \
} while (0)
ISC_LIST_INIT(lctx->messages);
- result = isc_mutex_init(&lctx->lock);
- if (result != ISC_R_SUCCESS) {
- isc_mem_putanddetach(&mctx, lctx, sizeof(*lctx));
- return (result);
- }
+ isc_mutex_init(&lctx->lock);
/*
* Normally setting the magic number is the last step done
static void
initialize_action(void) {
- RUNTIME_CHECK(isc_mutex_init(&contextslock) == ISC_R_SUCCESS);
+ isc_mutex_init(&contextslock);
ISC_LIST_INIT(contexts);
totallost = 0;
}
}
if ((flags & ISC_MEMFLAG_NOLOCK) == 0) {
- result = isc_mutex_init(&ctx->lock);
- if (result != ISC_R_SUCCESS) {
- (memfree)(arg, ctx);
- return (result);
- }
+ isc_mutex_init(&ctx->lock);
}
if (init_max_size == 0U)
isc_result_t
isc_mutexblock_init(isc_mutex_t *block, unsigned int count) {
- isc_result_t result;
unsigned int i;
for (i = 0; i < count; i++) {
- result = isc_mutex_init(&block[i]);
- if (result != ISC_R_SUCCESS) {
- while (i > 0U) {
- i--;
- DESTROYLOCK(&block[i]);
- }
- return (result);
- }
+ isc_mutex_init(&block[i]);
}
return (ISC_R_SUCCESS);
initialize(void) {
char *pk11_provider;
- RUNTIME_CHECK(isc_mutex_init(&alloclock) == ISC_R_SUCCESS);
- RUNTIME_CHECK(isc_mutex_init(&sessionlock) == ISC_R_SUCCESS);
+ isc_mutex_init(&alloclock);
+ isc_mutex_init(&sessionlock);
pk11_provider = getenv("PKCS11_PROVIDER");
if (pk11_provider != NULL)
#include <isc/mutex.h>
#include <isc/result.h>
#include <isc/strerr.h>
+#include <isc/string.h>
#include <isc/types.h>
typedef pthread_cond_t isc_condition_t;
#else
#define isc_mutex_init(mp) \
isc__mutex_init((mp), __FILE__, __LINE__)
-isc_result_t isc__mutex_init(isc_mutex_t *mp, const char *file, unsigned int line);
+void isc__mutex_init(isc_mutex_t *mp, const char *file, unsigned int line);
#endif
#endif
#if ISC_MUTEX_PROFILE
-isc_result_t
+void
isc_mutex_init_profile(isc_mutex_t *mp, const char * _file, int _line);
isc_result_t
isc_mutex_lock_profile(isc_mutex_t *mp, const char * _file, int _line);
void
isc_mutex_statsprofile(FILE *fp);
-isc_result_t
+void
isc_mutex_init_errcheck(isc_mutex_t *mp);
#endif /* ISC_MUTEX_PROFILE */
static pthread_mutex_t statslock = PTHREAD_MUTEX_INITIALIZER;
-isc_result_t
+void
isc_mutex_init_profile(isc_mutex_t *mp, const char *file, int line) {
int i, err;
timevalclear(&mp->stats->lockers[i].locked_total);
timevalclear(&mp->stats->lockers[i].wait_total);
}
-
- return (ISC_R_SUCCESS);
}
isc_result_t
errcheck_initialized = true;
}
-isc_result_t
+void
isc_mutex_init_errcheck(isc_mutex_t *mp) {
isc_result_t result;
int err;
RUNTIME_CHECK(result == ISC_R_SUCCESS);
err = pthread_mutex_init(mp, &errcheck);
- if (err == ENOMEM)
- return (ISC_R_NOMEMORY);
- return ((err == 0) ? ISC_R_SUCCESS : ISC_R_UNEXPECTED);
+ if (err != 0) {
+ strerror_r(err, strbuf, sizeof(strbuf));
+ isc_error_fatal(file, line, "pthread_mutex_init failed: %s", strbuf);
+ }
}
#endif
}
#endif /* HAVE_PTHREAD_MUTEX_ADAPTIVE_NP */
-isc_result_t
+void
isc__mutex_init(isc_mutex_t *mp, const char *file, unsigned int line) {
- char strbuf[ISC_STRERRORSIZE];
- isc_result_t result = ISC_R_SUCCESS;
int err;
#ifdef HAVE_PTHREAD_MUTEX_ADAPTIVE_NP
+ isc_result_t result = ISC_R_SUCCESS;
result = isc_once_do(&once_attr, initialize_attr);
RUNTIME_CHECK(result == ISC_R_SUCCESS);
#else /* HAVE_PTHREAD_MUTEX_ADAPTIVE_NP */
err = pthread_mutex_init(mp, ISC__MUTEX_ATTRS);
#endif /* HAVE_PTHREAD_MUTEX_ADAPTIVE_NP */
-
- if (err == ENOMEM)
- return (ISC_R_NOMEMORY);
if (err != 0) {
+ char strbuf[ISC_STRERRORSIZE];
strerror_r(err, strbuf, sizeof(strbuf));
isc_error_fatal(file, line, "pthread_mutex_init failed: %s", strbuf);
}
- return (result);
}
#endif
quota->max = max;
quota->used = 0;
quota->soft = 0;
- return (isc_mutex_init("a->lock));
+ isc_mutex_init("a->lock);
+ /* XXXOND: Todo make return void */
+ return (ISC_R_SUCCESS);
}
void
rl->state = isc_ratelimiter_idle;
ISC_LIST_INIT(rl->pending);
- result = isc_mutex_init(&rl->lock);
- if (result != ISC_R_SUCCESS)
- goto free_mem;
+ isc_mutex_init(&rl->lock);
result = isc_timer_create(timermgr, isc_timertype_inactive,
NULL, NULL, rl->task, ratelimiter_tick,
free_mutex:
DESTROYLOCK(&rl->lock);
-free_mem:
isc_mem_put(mctx, rl, sizeof(*rl));
return (result);
}
initialize_action(void) {
isc_result_t result;
- RUNTIME_CHECK(isc_mutex_init(&lock) == ISC_R_SUCCESS);
+ isc_mutex_init(&lock);
ISC_LIST_INIT(description_tables);
ISC_LIST_INIT(identifier_tables);
isc_rwlock_init(isc_rwlock_t *rwl, unsigned int read_quota,
unsigned int write_quota)
{
- isc_result_t result;
-
REQUIRE(rwl != NULL);
/*
write_quota = RWLOCK_DEFAULT_WRITE_QUOTA;
rwl->write_quota = write_quota;
- result = isc_mutex_init(&rwl->lock);
- if (result != ISC_R_SUCCESS)
- return (result);
+ isc_mutex_init(&rwl->lock);
isc_condition_init(&rwl->readable);
isc_condition_init(&rwl->writeable);
if (stats == NULL)
return (ISC_R_NOMEMORY);
- result = isc_mutex_init(&stats->lock);
- if (result != ISC_R_SUCCESS)
- goto clean_stats;
+ isc_mutex_init(&stats->lock);
stats->counters = isc_mem_get(mctx, sizeof(isc_stat_t) * ncounters);
if (stats->counters == NULL) {
clean_mutex:
DESTROYLOCK(&stats->lock);
-
-clean_stats:
isc_mem_put(mctx, stats, sizeof(*stats));
return (result);
isc__taskmgr_t *manager = (isc__taskmgr_t *)manager0;
isc__task_t *task;
bool exiting;
- isc_result_t result;
REQUIRE(VALID_MANAGER(manager));
REQUIRE(taskp != NULL && *taskp == NULL);
task->threadid = atomic_fetch_add_explicit(&manager->curq, 1,
memory_order_relaxed)
% manager->workers;
- result = isc_mutex_init(&task->lock);
- if (result != ISC_R_SUCCESS) {
- isc_mem_put(manager->mctx, task, sizeof(*task));
- return (result);
- }
+ isc_mutex_init(&task->lock);
+
task->state = task_state_idle;
task->references = 1;
INIT_LIST(task->events);
manager->common.magic = ISCAPI_TASKMGR_MAGIC;
manager->mode = isc_taskmgrmode_normal;
manager->mctx = NULL;
- RUNTIME_CHECK(isc_mutex_init(&manager->lock) == ISC_R_SUCCESS);
- RUNTIME_CHECK(isc_mutex_init(&manager->excl_lock) == ISC_R_SUCCESS);
+ isc_mutex_init(&manager->lock);
+ isc_mutex_init(&manager->excl_lock);
- RUNTIME_CHECK(isc_mutex_init(&manager->halt_lock) == ISC_R_SUCCESS);
+ isc_mutex_init(&manager->halt_lock);
isc_condition_init(&manager->halt_cond);
manager->workers = workers;
for (i = 0; i < workers; i++) {
INIT_LIST(manager->queues[i].ready_tasks);
INIT_LIST(manager->queues[i].ready_priority_tasks);
- RUNTIME_CHECK(isc_mutex_init(&manager->queues[i].lock)
- == ISC_R_SUCCESS);
+ isc_mutex_init(&manager->queues[i].lock);
isc_condition_init(&manager->queues[i].work_available);
manager->queues[i].manager = manager;
UNUSED(state);
- result = isc_mutex_init(&lock);
- assert_int_equal(result, ISC_R_SUCCESS);
+ isc_mutex_init(&lock);
isc_condition_init(&cv);
UNUSED(state);
- result = isc_mutex_init(&lock);
- assert_int_equal(result, ISC_R_SUCCESS);
+ isc_mutex_init(&lock);
isc_condition_init(&cv);
UNUSED(state);
- result = isc_mutex_init(&lock);
- assert_int_equal(result, ISC_R_SUCCESS);
+ isc_mutex_init(&lock);
isc_condition_init(&cv);
isc_time_settoepoch(&endtime);
eventcnt = 0;
- result = isc_mutex_init(&mx);
- assert_int_equal(result, ISC_R_SUCCESS);
+ isc_mutex_init(&mx);
isc_condition_init(&cv);
seconds = 1;
nanoseconds = 0;
- result = isc_mutex_init(&mx);
- assert_int_equal(result, ISC_R_SUCCESS);
+ isc_mutex_init(&mx);
isc_condition_init(&cv);
*/
DE_CONST(arg, timer->arg);
timer->index = 0;
- result = isc_mutex_init(&timer->lock);
- if (result != ISC_R_SUCCESS) {
- isc_task_detach(&timer->task);
- isc_mem_put(manager->mctx, timer, sizeof(*timer));
- return (result);
- }
+ isc_mutex_init(&timer->lock);
ISC_LINK_INIT(timer, link);
timer->common.impmagic = TIMER_MAGIC;
timer->common.magic = ISCAPI_TIMER_MAGIC;
isc_mem_put(mctx, manager, sizeof(*manager));
return (ISC_R_NOMEMORY);
}
- result = isc_mutex_init(&manager->lock);
- if (result != ISC_R_SUCCESS) {
- isc_heap_destroy(&manager->heap);
- isc_mem_put(mctx, manager, sizeof(*manager));
- return (result);
- }
+ isc_mutex_init(&manager->lock);
isc_mem_attach(mctx, &manager->mctx);
isc_condition_init(&manager->wakeup);
if (isc_thread_create(run, manager, &manager->thread) !=
* Start an ISC library application.
*/
- result = isc_mutex_init(&ctx->readylock);
- if (result != ISC_R_SUCCESS)
- return (result);
+ isc_mutex_init(&ctx->readylock);
isc_condition_init(&ctx->ready);
- result = isc_mutex_init(&ctx->lock);
- if (result != ISC_R_SUCCESS)
- goto cleanup;
+ isc_mutex_init(&ctx->lock);
ISC_LIST_INIT(ctx->on_run);
/*
* Initialize the lock.
*/
- RUNTIME_CHECK(isc_mutex_init(&sock->lock) == ISC_R_SUCCESS);
+ isc_mutex_init(&sock->lock);
sock->common.magic = ISCAPI_SOCKET_MAGIC;
sock->common.impmagic = SOCKET_MAGIC;
FDLOCK_COUNT * sizeof(isc_mutex_t));
for (i = 0; i < FDLOCK_COUNT; i++) {
- result = isc_mutex_init(&thread->fdlock[i]);
- if (result != ISC_R_SUCCESS) {
- return (result);
- }
+ isc_mutex_init(&thread->fdlock[i]);
}
if (pipe(thread->pipe_fds) != 0) {
manager->common.impmagic = SOCKET_MANAGER_MAGIC;
manager->mctx = NULL;
ISC_LIST_INIT(manager->socklist);
- RUNTIME_CHECK(isc_mutex_init(&manager->lock) == ISC_R_SUCCESS);
-
+ isc_mutex_init(&manager->lock);
isc_condition_init(&manager->shutdown_ok);
/*
main_thread = GetCurrentThread();
- result = isc_mutex_init(&ctx->lock);
- if (result != ISC_R_SUCCESS)
- return (result);
+ isc_mutex_init(&ctx->lock);
ctx->shutdown_requested = false;
ctx->running = false;
#endif /* _WIN32_WINNT < 0x0400 */
#define isc_mutex_init(mp) \
- (InitializeCriticalSection((mp)), ISC_R_SUCCESS)
+ InitializeCriticalSection((mp))
#define isc_mutex_lock(mp) \
(EnterCriticalSection((mp)), ISC_R_SUCCESS)
#define isc_mutex_unlock(mp) \
/*
* Initialize the lock.
*/
- result = isc_mutex_init(&sock->lock);
- if (result != ISC_R_SUCCESS)
- goto error;
+ isc_mutex_init(&sock->lock);
socket_log(__LINE__, sock, NULL, EVENT, NULL, 0, 0,
"allocated");
manager->mctx = NULL;
manager->stats = NULL;
ISC_LIST_INIT(manager->socklist);
- result = isc_mutex_init(&manager->lock);
- if (result != ISC_R_SUCCESS) {
- isc_mem_put(mctx, manager, sizeof(*manager));
- return (result);
- }
+ isc_mutex_init(&manager->lock);
isc_condition_init(&manager->shutdown_ok);
isc_mem_attach(mctx, &manager->mctx);
if (manager == NULL)
return (ISC_R_NOMEMORY);
- result = isc_mutex_init(&manager->lock);
- if (result != ISC_R_SUCCESS)
- goto cleanup_manager;
-
- result = isc_mutex_init(&manager->listlock);
- if (result != ISC_R_SUCCESS)
- goto cleanup_lock;
-
- result = isc_mutex_init(&manager->reclock);
- if (result != ISC_R_SUCCESS)
- goto cleanup_listlock;
+ isc_mutex_init(&manager->lock);
+ isc_mutex_init(&manager->listlock);
+ isc_mutex_init(&manager->reclock);
manager->excl = NULL;
result = isc_taskmgr_excltask(taskmgr, &manager->excl);
cleanup_reclock:
(void) isc_mutex_destroy(&manager->reclock);
-
- cleanup_listlock:
(void) isc_mutex_destroy(&manager->listlock);
-
- cleanup_lock:
(void) isc_mutex_destroy(&manager->lock);
- cleanup_manager:
isc_mem_put(manager->mctx, manager, sizeof(*manager));
return (result);
mgr->sctx = NULL;
ns_server_attach(sctx, &mgr->sctx);
- result = isc_mutex_init(&mgr->lock);
- if (result != ISC_R_SUCCESS)
- goto cleanup_ctx;
+ isc_mutex_init(&mgr->lock);
mgr->excl = NULL;
result = isc_taskmgr_excltask(taskmgr, &mgr->excl);
strlcpy(ifp->name, name, sizeof(ifp->name));
ifp->clientmgr = NULL;
- result = isc_mutex_init(&ifp->lock);
- if (result != ISC_R_SUCCESS)
- goto lock_create_failure;
+ isc_mutex_init(&ifp->lock);
result = ns_clientmgr_create(mgr->mctx, mgr->sctx,
mgr->taskmgr, mgr->timermgr,
clientmgr_create_failure:
DESTROYLOCK(&ifp->lock);
- lock_create_failure:
ifp->magic = 0;
isc_mem_put(mgr->mctx, ifp, sizeof(*ifp));
if (result != ISC_R_SUCCESS)
return;
- result = isc_mutex_init(&reflock);
- if (result != ISC_R_SUCCESS)
- goto cleanup_mctx;
+ isc_mutex_init(&reflock);
initialize_done = true;
return;
-
- cleanup_mctx:
- if (ns_g_mctx != NULL)
- isc_mem_detach(&ns_g_mctx);
}
isc_result_t
* This mutex is destroyed when the client is destroyed in
* exit_check().
*/
- result = isc_mutex_init(&client->query.fetchlock);
- if (result != ISC_R_SUCCESS)
- return (result);
+ isc_mutex_init(&client->query.fetchlock);
+
client->query.fetch = NULL;
client->query.prefetch = NULL;
client->query.authdb = NULL;
stats->counters = NULL;
stats->references = 1;
- result = isc_mutex_init(&stats->lock);
- if (result != ISC_R_SUCCESS)
- goto clean_stats;
+ isc_mutex_init(&stats->lock);
result = isc_stats_create(mctx, &stats->counters, ncounters);
if (result != ISC_R_SUCCESS)
clean_mutex:
DESTROYLOCK(&stats->lock);
- clean_stats:
isc_mem_put(mctx, stats, sizeof(*stats));
return (result);