bucket = key % client_list->tbl_len;
entry = client_list->table[bucket];
- apr_lock_aquire(client_lock /*, MM_LOCK_RD */);
+ apr_lock_acquire(client_lock /*, MM_LOCK_RD */);
while(entry && key != entry->key) {
prev = entry;
bucket = key % client_list->tbl_len;
entry = client_list->table[bucket];
- apr_lock_aquire(client_lock /*, MM_LOCK_RW */);
+ apr_lock_acquire(client_lock /*, MM_LOCK_RW */);
/* try to allocate a new entry */
if (!opaque_cntr) return NULL;
- apr_lock_aquire(opaque_lock /*, MM_LOCK_RW */);
+ apr_lock_acquire(opaque_lock /*, MM_LOCK_RW */);
op = (*opaque_cntr)++;
apr_lock_release(opaque_lock);
static int proxy_available;
static const char *lockname;
-static apr_lock_t *rewrite_mapr_lock_aquire = NULL;
+static apr_lock_t *rewrite_mapr_lock_acquire = NULL;
static apr_lock_t *rewrite_log_lock = NULL;
/*
if (lockname != NULL && *(lockname) != '\0')
{
- rv = apr_lock_child_init (&rewrite_mapr_lock_aquire, lockname, p);
+ rv = apr_lock_child_init (&rewrite_mapr_lock_acquire, lockname, p);
if (rv != APR_SUCCESS) {
ap_log_error(APLOG_MARK, APLOG_CRIT, rv, s,
- "mod_rewrite: could not init rewrite_mapr_lock_aquire "
+ "mod_rewrite: could not init rewrite_mapr_lock_acquire "
"in child");
}
}
/* take the lock */
- if (rewrite_mapr_lock_aquire) {
- apr_lock_aquire(rewrite_mapr_lock_aquire);
+ if (rewrite_mapr_lock_acquire) {
+ apr_lock_acquire(rewrite_mapr_lock_acquire);
}
/* write out the request key */
buf[i] = '\0';
/* give the lock back */
- if (rewrite_mapr_lock_aquire) {
- apr_lock_release(rewrite_mapr_lock_aquire);
+ if (rewrite_mapr_lock_acquire) {
+ apr_lock_release(rewrite_mapr_lock_acquire);
}
if (strcasecmp(buf, "NULL") == 0) {
(unsigned long)(r->server), (unsigned long)r,
type, redir, level, str2);
- apr_lock_aquire(rewrite_log_lock);
+ apr_lock_acquire(rewrite_log_lock);
nbytes = strlen(str3);
apr_file_write(conf->rewritelogfp, str3, &nbytes);
apr_lock_release(rewrite_log_lock);
lockname = ap_server_root_relative(p, lockname);
/* create the lockfile */
- rc = apr_lock_create (&rewrite_mapr_lock_aquire, APR_MUTEX, APR_LOCKALL, lockname, p);
+ rc = apr_lock_create (&rewrite_mapr_lock_acquire, APR_MUTEX, APR_LOCKALL, lockname, p);
if (rc != APR_SUCCESS) {
ap_log_error(APLOG_MARK, APLOG_ERR, rc, s,
"mod_rewrite: Parent could not create RewriteLock "
}
/* destroy the rewritelock */
- apr_lock_destroy (rewrite_mapr_lock_aquire);
- rewrite_mapr_lock_aquire = NULL;
+ apr_lock_destroy (rewrite_mapr_lock_acquire);
+ rewrite_mapr_lock_acquire = NULL;
lockname = NULL;
return(0);
}
apr_pool_create(&ptrans, tpool);
- apr_lock_aquire(worker_thread_count_mutex);
+ apr_lock_acquire(worker_thread_count_mutex);
worker_thread_count++;
apr_lock_release(worker_thread_count_mutex);
(void) ap_update_child_status(0, child_slot, SERVER_READY,
(request_rec*)NULL);
- apr_lock_aquire(accept_mutex);
+ apr_lock_acquire(accept_mutex);
while (!this_worker_should_exit) {
apr_int16_t event;
apr_status_t ret = apr_poll(pollset, &srv, -1);
ap_update_child_status(0, child_slot, SERVER_DEAD, (request_rec*)NULL);
- apr_lock_aquire(worker_thread_count_mutex);
+ apr_lock_acquire(worker_thread_count_mutex);
worker_thread_count--;
apr_lock_release(worker_thread_count_mutex);
pthread_mutex_unlock(&thread_accept_mutex);
break;
}
- if ((rv = SAFE_ACCEPT(apr_lock_aquire(process_accept_mutex)))
+ if ((rv = SAFE_ACCEPT(apr_lock_acquire(process_accept_mutex)))
!= APR_SUCCESS) {
ap_log_error(APLOG_MARK, APLOG_EMERG, rv, ap_server_conf,
- "apr_lock_aquire failed. Attempting to shutdown "
+ "apr_lock_acquire failed. Attempting to shutdown "
"process gracefully.");
workers_may_exit = 1;
}
(void) ap_update_child_status(process_slot, thread_slot, SERVER_READY,
(request_rec *) NULL);
- if ((rv = SAFE_ACCEPT(apr_lock_aquire(accept_mutex)))
+ if ((rv = SAFE_ACCEPT(apr_lock_acquire(accept_mutex)))
!= APR_SUCCESS) {
ap_log_error(APLOG_MARK, APLOG_EMERG, rv, ap_server_conf,
- "apr_lock_aquire failed. Attempting to shutdown "
+ "apr_lock_acquire failed. Attempting to shutdown "
"process gracefully.");
workers_may_exit = 1;
}
pthread_mutex_unlock(&thread_accept_mutex);
break;
}
- if ((rv = SAFE_ACCEPT(apr_lock_aquire(process_accept_mutex)))
+ if ((rv = SAFE_ACCEPT(apr_lock_acquire(process_accept_mutex)))
!= APR_SUCCESS) {
ap_log_error(APLOG_MARK, APLOG_EMERG, rv, ap_server_conf,
- "apr_lock_aquire failed. Attempting to shutdown "
+ "apr_lock_acquire failed. Attempting to shutdown "
"process gracefully.");
workers_may_exit = 1;
}
static void accept_mutex_on(void)
{
- apr_status_t rv = apr_lock_aquire(accept_lock);
+ apr_status_t rv = apr_lock_acquire(accept_lock);
if (rv != APR_SUCCESS) {
ap_log_error(APLOG_MARK, APLOG_EMERG, rv, NULL, "couldn't grab the accept mutex");
exit(APEXIT_CHILDFATAL);
static void accept_mutex_on(void)
{
- apr_status_t rc = apr_lock_aquire(accept_mutex);
+ apr_status_t rc = apr_lock_acquire(accept_mutex);
if (rc != APR_SUCCESS) {
ap_log_error(APLOG_MARK, APLOG_EMERG, rc, ap_server_conf,
new_job->next = NULL;
new_job->sock = sock;
- apr_lock_aquire(allowed_globals.jobmutex);
+ apr_lock_acquire(allowed_globals.jobmutex);
if (allowed_globals.jobtail != NULL)
allowed_globals.jobtail->next = new_job;
int sock;
acquire_semaphore(allowed_globals.jobsemaphore);
- apr_lock_aquire(allowed_globals.jobmutex);
+ apr_lock_acquire(allowed_globals.jobmutex);
if (shutdown_in_progress && !allowed_globals.jobhead) {
apr_lock_release(allowed_globals.jobmutex);
* but only if we are not in the process of shutting down
*/
if (!shutdown_in_progress) {
- apr_lock_aquire(allowed_globals.jobmutex);
+ apr_lock_acquire(allowed_globals.jobmutex);
context->lr->count--;
if (context->lr->count < 2) {
SetEvent(maintenance_event);
* start_mutex is used to ensure that only one child ever
* goes into the listen/accept loop at once.
*/
- status = apr_lock_aquire(start_mutex);
+ status = apr_lock_acquire(start_mutex);
if (status != APR_SUCCESS) {
ap_log_error(APLOG_MARK,APLOG_ERR, status, server_conf,
"Child %d: Failed to acquire the start_mutex. Process will exit.", my_pid);
workers_may_exit = 1;
/* Unblock threads blocked on the completion port */
- apr_lock_aquire(allowed_globals.jobmutex);
+ apr_lock_acquire(allowed_globals.jobmutex);
while (g_blocked_threads > 0) {
ap_log_error(APLOG_MARK,APLOG_INFO, APR_SUCCESS, server_conf,
"Child %d: %d threads blocked on the completion port", my_pid, g_blocked_threads);