Lines Matching defs:events

216 	reactor->events = spdk_ring_create(SPDK_RING_TYPE_MP_SC, 65536, SPDK_ENV_NUMA_ID_ANY);
217 	if (reactor->events == NULL) {
218 		SPDK_ERRLOG("Failed to allocate events ring\n");
356 		if (reactor->events != NULL) {
357 			spdk_ring_free(reactor->events);
567 	assert(reactor->events != NULL);
569 	rc = spdk_ring_enqueue(reactor->events, (void **)&event, 1, NULL);
598 	void *events[SPDK_EVENT_BATCH_SIZE];
602 	 * spdk_ring_dequeue() fills events and returns how many entries it wrote,
603 	 * so we will never actually read uninitialized data from events, but just to be sure
606 	memset(events, 0, sizeof(events));
614 		count = spdk_ring_dequeue(reactor->events, events, SPDK_EVENT_BATCH_SIZE);
616 		if (spdk_ring_count(reactor->events) != 0) {
617 			/* Trigger new notification if there are still events in event-queue waiting for processing. */
625 		count = spdk_ring_dequeue(reactor->events, events, SPDK_EVENT_BATCH_SIZE);
633 		struct spdk_event *event = events[i];
642 	spdk_mempool_put_bulk(g_spdk_event_mempool, events, count);