xen/librumpxen_xendev/busdev.c

71 	struct rumpxenbus_data_common dc;
85 rumpxenbus_write_trouble(struct rumpxenbus_data_common *dc, const char *what)
92 		printf(" %d bytes:", dc->wbuf_used);
93 		for (i=0; i<dc->wbuf_used; i++) {
95 			printf("%02x", dc->wbuf.buffer[i]);
101 	dc->wbuf_used = 0; /* discard everything buffered */
106 #define wbuf      dc.wbuf
107 #define wbuf_used dc.wbuf_used
114 	struct rumpxenbus_data_common *const dc = &dd->dc;
117 	DPRINTF(("/dev/xen/xenbus[%p,dd=%p]: write...\n",dc,dd));
150 			err = rumpxenbus_process_request(&dd->dc);
177 void rumpxenbus_block_before(struct rumpxenbus_data_common *dc)
180 		container_of(dc, struct rumpxenbus_data_dev, dc);
184 void rumpxenbus_block_after(struct rumpxenbus_data_common *dc)
187 		container_of(dc, struct rumpxenbus_data_dev, dc);
196 	struct rumpxenbus_data_common *const dc = &dd->dc;
202 		 dc,dd, !(fp->f_flag & FNONBLOCK)));
210 			 dc->queued_enomem));
211 		if (dc->queued_enomem) {
216 			dc->queued_enomem = 0;
232 			dd->rmsg = rumpxenbus_next_event_msg(&dd->dc,
286 void rumpxenbus_dev_xb_wakeup(struct rumpxenbus_data_common *dc)
289 		container_of(dc, struct rumpxenbus_data_dev, dc);
290 	DPRINTF(("/dev/xen/xenbus[%p,dd=%p]: wakeup\n",dd,dc));
303 	rumpxenbus_dev_restart_wakeup(&dd->dc);
311 	struct rumpxenbus_data_common *const dc = &dd->dc;
315 		 dc,dd,events));
325 		if (dd->rmsg || dc->queued_enomem || dd->want_restart)
356 	rumpxenbus_dev_user_shutdown(&dd->dc);
392 	dd->dc.du = 0;
394 	DPRINTF(("/dev/xen/xenbus[%p,du=%p]: open: alloc...\n",&dd->dc,dd));
396 	err = rumpxenbus_dev_user_open(&dd->dc);
411 		 &dd->dc, dd, dd->dc.du));