Searched refs:queue_lock (Results 1 – 4 of 4) sorted by relevance
72 pthread_spin_lock(&conn->queue_lock); in jsonrpc_server_dequeue_request()77 pthread_spin_unlock(&conn->queue_lock); in jsonrpc_server_dequeue_request()89 pthread_spin_lock(&conn->queue_lock); in jsonrpc_server_free_conn_request()95 pthread_spin_unlock(&conn->queue_lock); in jsonrpc_server_free_conn_request()139 pthread_spin_destroy(&conn->queue_lock); in jsonrpc_server_conn_remove()152 pthread_spin_lock(&conn->queue_lock); in spdk_jsonrpc_conn_add_close_cb()159 pthread_spin_unlock(&conn->queue_lock); in spdk_jsonrpc_conn_add_close_cb()170 pthread_spin_lock(&conn->queue_lock); in spdk_jsonrpc_conn_del_close_cb()176 pthread_spin_unlock(&conn->queue_lock); in spdk_jsonrpc_conn_del_close_cb()201 if (pthread_spin_init(&conn->queue_lock, PTHREAD_PROCESS_PRIVATE)) { in jsonrpc_server_accept()[all …]
191 pthread_spin_lock(&conn->queue_lock); in jsonrpc_parse_request()194 pthread_spin_unlock(&conn->queue_lock); in jsonrpc_parse_request()335 pthread_spin_lock(&conn->queue_lock); in jsonrpc_free_request()344 pthread_spin_unlock(&conn->queue_lock); in jsonrpc_free_request()
56 pthread_spinlock_t queue_lock; member
176 pthread_spin_init(&conn->queue_lock, PTHREAD_PROCESS_PRIVATE); in test_parse_request() 315 pthread_spin_init(&conn->queue_lock, PTHREAD_PROCESS_PRIVATE); in test_parse_request_streaming()