Home
last modified time | relevance | path

Searched refs:lock (Results 1 – 25 of 36) sorted by relevance

12

/spdk/lib/vhost/
H A Drte_vhost_user.c912 pthread_mutex_lock(&user_dev->lock);
915 pthread_mutex_unlock(&user_dev->lock);
925 pthread_mutex_unlock(&user_dev->lock);
933 pthread_mutex_unlock(&user_dev->lock);
945 pthread_mutex_unlock(&user_dev->lock);
953 pthread_mutex_unlock(&user_dev->lock);
964 pthread_mutex_unlock(&user_dev->lock);
979 pthread_mutex_lock(&user_dev->lock);
986 pthread_mutex_unlock(&user_dev->lock);
1144 pthread_mutex_lock(&user_dev->lock);
[all...]
H A Dvhost_scsi.c203 /* `remove_scsi_tgt` is running under vhost-user lock, so we in remove_scsi_tgt()
1486 if (vsession->task_cnt > 0 || (pthread_mutex_trylock(&user_dev->lock) != 0)) { in destroy_session_poller_cb()
1520 pthread_mutex_unlock(&user_dev->lock); in destroy_session_poller_cb()
1525 pthread_mutex_lock(&user_dev->lock); in destroy_session_poller_cb()
1537 pthread_mutex_unlock(&user_dev->lock); in vhost_scsi_stop()
H A Dvhost_blk.c1394 if (vsession->task_cnt > 0 || (pthread_mutex_trylock(&user_dev->lock) != 0)) { in free_task_pool()
1424 pthread_mutex_unlock(&user_dev->lock); in alloc_vq_task_pool()
H A Dvhost_internal.h186 /* Use this lock to protect multiple sessions. */
187 pthread_mutex_t lock;
474 * Must be called under the vhost user device's session access lock.
188 pthread_mutex_t lock; global() member
/spdk/lib/trace/
H A Dtrace_flags.c21 pthread_spinlock_t lock; member
303 pthread_spin_lock(&g_owner_ids.lock); in spdk_trace_register_owner()
307 pthread_spin_unlock(&g_owner_ids.lock); in spdk_trace_register_owner()
320 pthread_spin_unlock(&g_owner_ids.lock); in spdk_trace_register_owner()
341 pthread_spin_lock(&g_owner_ids.lock); in spdk_trace_unregister_owner()
346 pthread_spin_unlock(&g_owner_ids.lock); in spdk_trace_unregister_owner()
359 pthread_spin_lock(&g_owner_ids.lock); in spdk_trace_owner_set_description()
361 pthread_spin_unlock(&g_owner_ids.lock); in spdk_trace_owner_set_description()
381 pthread_spin_lock(&g_owner_ids.lock); in spdk_trace_owner_append_description()
383 pthread_spin_unlock(&g_owner_ids.lock); in spdk_trace_owner_append_description()
[all …]
/spdk/module/bdev/zone_block/
H A Dvbdev_zone_block.c51 pthread_spinlock_t lock; member
138 pthread_spin_destroy(&bdev_node->zones[i].lock); in _device_unregister_cb()
225 pthread_spin_lock(&zone->lock); in zone_block_open_zone()
232 pthread_spin_unlock(&zone->lock); in zone_block_open_zone()
236 pthread_spin_unlock(&zone->lock); in zone_block_open_zone()
258 pthread_spin_lock(&zone->lock); in zone_block_reset_zone()
262 pthread_spin_unlock(&zone->lock); in zone_block_reset_zone()
270 pthread_spin_unlock(&zone->lock); in zone_block_reset_zone()
283 pthread_spin_unlock(&zone->lock); in zone_block_reset_zone()
291 pthread_spin_lock(&zone->lock); in zone_block_close_zone()
[all...]
/spdk/lib/nvme/
H A Dnvme.c42 nvme_robust_mutex_lock(&g_spdk_nvme_driver->lock); in nvme_ctrlr_detach_async_finish()
48 nvme_robust_mutex_unlock(&g_spdk_nvme_driver->lock); in nvme_ctrlr_detach_async_finish()
58 nvme_robust_mutex_lock(&g_spdk_nvme_driver->lock); in nvme_ctrlr_detach_async()
69 nvme_robust_mutex_unlock(&g_spdk_nvme_driver->lock); in nvme_ctrlr_detach_async()
87 nvme_robust_mutex_unlock(&g_spdk_nvme_driver->lock); in nvme_ctrlr_detach_async()
305 * \param robust_mutex optional robust mutex to lock while polling qpair
345 * \param robust_mutex optional robust mutex to lock while polling qpair
614 ret = nvme_robust_mutex_init_shared(&g_spdk_nvme_driver->lock); in nvme_driver_init()
622 /* The lock in the shared g_spdk_nvme_driver object is now ready to in nvme_driver_init()
626 nvme_robust_mutex_lock(&g_spdk_nvme_driver->lock); in nvme_driver_init()
[all...]
H A Dnvme_pcie.c94 nvme_robust_mutex_unlock(&g_spdk_nvme_driver->lock); in _nvme_pcie_event_process()
96 nvme_robust_mutex_lock(&g_spdk_nvme_driver->lock); in _nvme_pcie_event_process()
136 nvme_robust_mutex_unlock(&g_spdk_nvme_driver->lock); in _nvme_pcie_hotplug_monitor()
138 nvme_robust_mutex_lock(&g_spdk_nvme_driver->lock); in _nvme_pcie_hotplug_monitor()
822 /* This function must only be called while holding g_spdk_nvme_driver->lock */
/spdk/test/unit/lib/thread/thread.c/
H A Dthread_ut.c1808 struct spdk_spinlock lock; in spdk_spin()
1814 spdk_spin_init(&lock); in spdk_spin()
1817 /* Trying to take a lock while not on an SPDK thread is an error */ in spdk_spin()
1819 spdk_spin_lock(&lock); in spdk_spin()
1823 /* Trying to check if a lock is held while not on an SPDK thread is an error */ in spdk_spin()
1825 spdk_spin_held(&lock); in spdk_spin()
1831 spdk_spin_destroy(&lock); in spdk_spin()
1839 spdk_spin_init(&lock); in spdk_spin()
1844 spdk_spin_lock(&lock); in spdk_spin()
1849 spdk_spin_unlock(&lock); in spdk_spin()
1794 struct spdk_spinlock lock; spdk_spin() local
[all...]
/spdk/module/blob/bdev/
H A Dblob_bdev.c23 struct spdk_spinlock lock; member
365 spdk_spin_lock(&blob_bdev->lock); in bdev_blob_free()
367 spdk_spin_unlock(&blob_bdev->lock); in bdev_blob_free()
378 spdk_spin_destroy(&blob_bdev->lock); in bdev_blob_destroy_channel()
388 spdk_spin_lock(&blob_bdev->lock); in bdev_blob_destroy_channel()
394 spdk_spin_unlock(&blob_bdev->lock); in bdev_blob_destroy_channel()
404 * Because the value of blob_bdev->refs was taken while holding the lock here and the same in bdev_blob_destroy()
419 spdk_spin_lock(&blob_bdev->lock); in bdev_blob_destroy()
426 spdk_spin_unlock(&blob_bdev->lock); in bdev_blob_destroy()
436 * Because the value of blob_bdev->refs was taken while holding the lock her
[all...]
/spdk/test/common/lib/
H A Dtest_env.c415 pthread_mutex_t lock; in spdk_ring_create()
432 if (pthread_mutex_init(&ring->lock, NULL)) { in spdk_ring_create()
454 pthread_mutex_destroy(&ring->lock); in spdk_ring_enqueue()
468 pthread_mutex_lock(&ring->lock); in spdk_ring_enqueue()
481 pthread_mutex_unlock(&ring->lock); in spdk_ring_dequeue()
498 pthread_mutex_lock(&ring->lock); in spdk_ring_dequeue()
511 pthread_mutex_unlock(&ring->lock);
408 pthread_mutex_t lock; global() member
/spdk/module/bdev/ocf/
H A Dctx.c
H A Dctx.h22 pthread_mutex_t lock; global() member
/spdk/lib/ioat/
H A Dioat.c17 pthread_mutex_t lock; member
22 .lock = PTHREAD_MUTEX_INITIALIZER,
467 /* Caller must hold g_ioat_driver.lock */
501 /* This function must only be called while holding g_ioat_driver.lock */
545 pthread_mutex_lock(&g_ioat_driver.lock); in spdk_ioat_probe()
553 pthread_mutex_unlock(&g_ioat_driver.lock); in spdk_ioat_probe()
566 pthread_mutex_lock(&driver->lock); in spdk_ioat_detach()
568 pthread_mutex_unlock(&driver->lock); in spdk_ioat_detach()
/spdk/test/thread/
H A Dthread.sh18 run_test "thread_spdk_lock" $testdir/lock/spdk_lock
H A DMakefile16 DIRS-y += lock
/spdk/test/unit/lib/nvme/nvme_io_msg.c/
H A Dnvme_io_msg_ut.c48 pthread_mutex_init(&ctrlr.external_io_msgs->lock, NULL); in test_nvme_io_msg_process()
81 pthread_mutex_init(&ctrlr.external_io_msgs->lock, NULL); in test_nvme_io_msg_send()
/spdk/lib/nvmf/
H A Dvfio_user.c519 pthread_mutex_t lock;
545 pthread_mutex_t lock;
1221 pthread_mutex_destroy(&endpoint->lock); in nvmf_vfio_user_destroy()
1238 pthread_mutex_destroy(&vu_transport->lock);
1301 err = pthread_mutex_init(&vu_transport->lock, NULL); in nvmf_vfio_user_create()
1310 pthread_mutex_destroy(&vu_transport->lock); in nvmf_vfio_user_create()
1365 pthread_mutex_destroy(&vu_transport->lock); in memory_page_size()
2723 pthread_mutex_lock(&endpoint->lock); in memory_region_remove_cb()
2754 pthread_mutex_unlock(&endpoint->lock); in memory_region_remove_cb()
2788 pthread_mutex_lock(&endpoint->lock); in memory_region_remove_cb()
507 pthread_mutex_t lock; global() member
533 pthread_mutex_t lock; global() member
[all...]
H A Dfc.c209 pthread_mutex_t lock;
448 pthread_mutex_lock(&g_nvmf_ftransport->lock); in nvmf_fc_assign_idlest_poll_group()
463 pthread_mutex_unlock(&g_nvmf_ftransport->lock); in nvmf_fc_assign_idlest_poll_group()
474 pthread_mutex_lock(&g_nvmf_ftransport->lock); in nvmf_fc_poll_group_valid()
481 pthread_mutex_unlock(&g_nvmf_ftransport->lock); in nvmf_fc_poll_group_valid()
540 pthread_mutex_lock(&g_nvmf_ftransport->lock); in nvmf_fc_poll_group_remove_hwqp()
547 pthread_mutex_unlock(&g_nvmf_ftransport->lock); in nvmf_fc_poll_group_remove_hwqp()
1982 if (pthread_mutex_init(&g_nvmf_ftransport->lock, NULL)) { in nvmf_fc_create()
2106 pthread_mutex_lock(&ftransport->lock); in nvmf_fc_poll_group_create()
2109 pthread_mutex_unlock(&ftransport->lock);
207 pthread_mutex_t lock; global() member
[all...]
/spdk/test/unit/lib/nvme/nvme.c/
H A Dnvme_ut.c151 nvme_robust_mutex_unlock(&g_spdk_nvme_driver->lock); in nvme_transport_ctrlr_scan()
153 nvme_robust_mutex_lock(&g_spdk_nvme_driver->lock); in nvme_transport_ctrlr_scan()
214 CU_ASSERT(pthread_mutex_init(&dummy.lock, &attr) == 0); in test_spdk_nvme_probe()
234 pthread_mutex_destroy(&dummy.lock); in test_spdk_nvme_connect()
253 CU_ASSERT(pthread_mutex_init(&g_spdk_nvme_driver->lock, &attr) == 0); in test_spdk_nvme_connect()
370 CU_ASSERT(pthread_mutex_init(&test_driver.lock, &attr) == 0); in test_nvme_init_controllers()
437 pthread_mutex_destroy(&test_driver.lock); in test_nvme_driver_init()
530 CU_ASSERT(pthread_mutex_init(&test_driver.lock, NULL) == 0); in test_spdk_nvme_detach()
576 pthread_mutex_destroy(&test_driver.lock); in test_nvme_completion_poll_cb()
1553 CU_ASSERT(pthread_mutex_init(&test_driver.lock, NUL in test_spdk_nvme_detach_async()
[all...]
/spdk/doc/
H A Dconcurrency.md15 the heap, protecting it with a lock, and then having all threads of execution
16 acquire the lock only when accessing the data. This model has many great
21 version. You add a lock around the data.
27 Unfortunately, as the number of threads scales up, contention on the lock around
34 global location that all threads access after acquiring a lock, SPDK will often
93 accessed without a lock to submit I/O. To abstract that, we generalized the
H A Devent.md50 Each reactor has a lock-free queue for incoming events to that core, and
/spdk/lib/rocksdb/
H A Denv_spdk.cc521 virtual Status LockFile(const std::string &fname, FileLock **lock) override in LockFile() argument
528 SPDK_BLOBFS_OPEN_CREATE, (struct spdk_file **)lock); in LockFile()
536 virtual Status UnlockFile(FileLock *lock) override in UnlockFile() argument
539 spdk_file_close((struct spdk_file *)lock, g_sync_args.channel); in UnlockFile()
/spdk/test/unit/lib/nvmf/vfio_user.c/
H A Dvfio_user_ut.c241 pthread_mutex_init(&endpoint->lock, NULL); in test_nvmf_vfio_user_create_destroy()
/spdk/test/common/config/pkgdep/patches/qat/
H A D0001-strlcpy-to-strscpy.patch

12