48 		ringbuffer_consumer_unregister(rb->consumers[0]);  in ringbuffer_fini()
72 	rb->consumers = reallocarray(rb->consumers, rb->n_consumers,  in ringbuffer_consumer_register()
73 				     sizeof(*rb->consumers));  in ringbuffer_consumer_register()
75 	rb->consumers[n] = rbc;  in ringbuffer_consumer_register()
86 		if (rb->consumers[i] == rbc) {  in ringbuffer_consumer_unregister()
99 	memmove(&rb->consumers[i], &rb->consumers[i + 1],  in ringbuffer_consumer_unregister()
101 		sizeof(*rb->consumers) * (rb->n_consumers - i));  in ringbuffer_consumer_unregister()
104 		free(rb->consumers);  in ringbuffer_consumer_unregister()
105 		rb->consumers = NULL;  in ringbuffer_consumer_unregister()
107 		rb->consumers = reallocarray(  in ringbuffer_consumer_unregister()
108 			rb->consumers, rb->n_consumers,  in ringbuffer_consumer_unregister()
110 			sizeof(*rb->consumers));  in ringbuffer_consumer_unregister()
170 		rbc = rb->consumers[i];  in ringbuffer_queue()
192 	/* Inform consumers of new data in non-blocking mode, by calling  in ringbuffer_queue()
197 		rbc = rb->consumers[i];  in ringbuffer_queue()