Lines Matching refs:mp_request_list
74 TAILQ_HEAD(mp_request_list, mp_request);
76 struct mp_request_list list;
78 } mp_request_list = { variable
79 .list = TAILQ_HEAD_INITIALIZER(mp_request_list.list),
127 TAILQ_FOREACH(req, &mp_request_list.list, next) { in find_request_by_id()
303 pthread_mutex_lock(&mp_request_list.lock); in handle_request()
387 TAILQ_INSERT_TAIL(&mp_request_list.list, entry, next); in handle_request()
389 pthread_mutex_unlock(&mp_request_list.lock); in handle_request()
392 pthread_mutex_unlock(&mp_request_list.lock); in handle_request()
411 pthread_mutex_lock(&mp_request_list.lock); in handle_sync_response()
461 TAILQ_REMOVE(&mp_request_list.list, entry, next); in handle_sync_response()
485 TAILQ_REMOVE(&mp_request_list.list, entry, next); in handle_sync_response()
531 TAILQ_REMOVE(&mp_request_list.list, entry, next); in handle_sync_response()
541 pthread_mutex_unlock(&mp_request_list.lock); in handle_sync_response()
544 pthread_mutex_unlock(&mp_request_list.lock); in handle_sync_response()
559 pthread_mutex_lock(&mp_request_list.lock); in handle_rollback_response()
586 TAILQ_REMOVE(&mp_request_list.list, entry, next); in handle_rollback_response()
590 pthread_mutex_unlock(&mp_request_list.lock); in handle_rollback_response()
593 pthread_mutex_unlock(&mp_request_list.lock); in handle_rollback_response()
605 pthread_mutex_lock(&mp_request_list.lock); in handle_response()
618 pthread_mutex_unlock(&mp_request_list.lock); in handle_response()
708 pthread_mutex_lock(&mp_request_list.lock); in request_to_primary()
751 TAILQ_INSERT_TAIL(&mp_request_list.list, entry, next); in request_to_primary()
756 &mp_request_list.lock, &ts); in request_to_primary()
766 TAILQ_REMOVE(&mp_request_list.list, entry, next); in request_to_primary()
769 pthread_mutex_unlock(&mp_request_list.lock); in request_to_primary()
772 pthread_mutex_unlock(&mp_request_list.lock); in request_to_primary()