Lines Matching refs:peer_dev

331 	struct camdd_dev	*peer_dev;  member
1700 			    dev->peer_dev->target_queue_depth;
1701 			uint32_t peer_blocksize = dev->peer_dev->blocksize;
1781 		 && (dev->peer_bytes_queued < dev->peer_dev->blocksize))
2059 	EV_SET(&ke, (uintptr_t)&dev->peer_dev->work_queue, EVFILT_USER, 0,
2103 	pthread_mutex_lock(&dev->peer_dev->mutex);
2105 	if (dev->peer_dev->flags & CAMDD_DEV_FLAG_ACTIVE) {
2112 			STAILQ_INSERT_TAIL(&dev->peer_dev->work_queue, buf1,
2119 		retval = kevent(dev->peer_dev->kq, &ke, 1, NULL, 0, NULL);
2128 	pthread_mutex_unlock(&dev->peer_dev->mutex);
2165 	EV_SET(&ke, (uintptr_t)&dev->peer_dev->peer_done_queue, EVFILT_USER, 0,
2173 	pthread_mutex_lock(&dev->peer_dev->mutex);
2179 	STAILQ_INSERT_TAIL(&dev->peer_dev->peer_done_queue, peer_buf,
2181 	dev->peer_dev->num_peer_done_queue++;
2187 	retval = kevent(dev->peer_dev->kq, &ke, 1, NULL, 0, NULL);
2196 	pthread_mutex_unlock(&dev->peer_dev->mutex);
3330 	devs[0]->peer_dev = devs[1];
3331 	devs[1]->peer_dev = devs[0];
3332 	devs[0]->next_peer_pos_bytes = devs[0]->peer_dev->next_io_pos_bytes;
3333 	devs[1]->next_peer_pos_bytes = devs[1]->peer_dev->next_io_pos_bytes;