| /dragonfly/sys/kern/ |
| H A D | kern_dmsg.c | 113 bzero(iocom, sizeof(*iocom)); in kdmsg_iocom_init()
123 iocom->state0.iocom = iocom; in kdmsg_iocom_init()
124 iocom->state0.parent = &iocom->state0; in kdmsg_iocom_init()
198 kdmsg_iocom_t *iocom = state->iocom; in kdmsg_lnk_conn_reply() local
601 iocom->exit_func(iocom); in kdmsg_iocom_thread_wr()
791 state->iocom = iocom; in kdmsg_state_msgrx()
809 sdummy.iocom = iocom; in kdmsg_state_msgrx()
903 KKASSERT(state->iocom == iocom); in kdmsg_state_msgrx()
1462 state->iocom = iocom; in kdmsg_state_msgtx()
1798 state->iocom = iocom; in kdmsg_msg_alloc()
[all …]
|
| H A D | subr_diskiocom.c | 194 struct disk *dp = msg->state->iocom->handle; in disk_rcvdmsg()
225 if (msg->state == &msg->state->iocom->state0) { in disk_rcvdmsg()
652 rmsg->aux_data = kmalloc(bytes, state->iocom->mmsg, M_INTWAIT); in diskiodone()
|
| /dragonfly/lib/libdmsg/ |
| H A D | msg.c | 118 bzero(iocom, sizeof(*iocom)); in dmsg_iocom_init()
135 dmsg_ioq_init(iocom, &iocom->ioq_rx); in dmsg_iocom_init()
138 iocom->state0.iocom = iocom; in dmsg_iocom_init()
260 dmsg_iocom_t *iocom = state->iocom; in dmsg_msg_alloc() local
275 dmsg_iocom_t *iocom = state->iocom; in dmsg_msg_alloc_locked() local
303 state->iocom = iocom; in dmsg_msg_alloc_locked()
440 iocom, iocom->flags); in dmsg_iocom_core()
520 iocom->signal_callback(iocom); in dmsg_iocom_core()
560 iocom->altmsg_callback(iocom); in dmsg_iocom_core()
1791 iocom = state->iocom;
[all …]
|
| H A D | service.c | 52 dmsg_iocom_t iocom; in dmsg_master_service() local
57 dmsg_iocom_init(&iocom, in dmsg_master_service()
71 dmsg_iocom_core(&iocom); in dmsg_master_service()
72 dmsg_iocom_done(&iocom); in dmsg_master_service()
74 dmio_printf(iocom, 1, in dmsg_master_service()
76 info->fd, iocom.ioq_rx.error, iocom.ioq_tx.error); in dmsg_master_service()
146 dmsg_msg_lnk_signal(iocom); in master_link_signal()
154 dmsg_iocom_t *iocom; in master_link_rxmsg() local
167 iocom = state->iocom; in master_link_rxmsg()
202 dmsg_iocom_t *iocom = msg->state->iocom; in dmsg_msg_dbg() local
[all …]
|
| H A D | crypto.c | 541 iocom->ioq_rx.error = in dmsg_crypto_negotiate()
550 iocom->ioq_rx.error = in dmsg_crypto_negotiate()
558 if (iocom->ioq_rx.error) { in dmsg_crypto_negotiate()
560 dmio_printf(iocom, 1, "%s\n", in dmsg_crypto_negotiate()
582 iocom->ioq_rx.error = in dmsg_crypto_negotiate()
588 iocom->ioq_rx.error = in dmsg_crypto_negotiate()
592 if (iocom->ioq_rx.error) { in dmsg_crypto_negotiate()
698 dmio_printf(iocom, 5, in dmsg_crypto_decrypt()
708 dmio_printf(iocom, 5, in dmsg_crypto_decrypt()
746 dmio_printf(iocom, 5, in dmsg_crypto_encrypt()
[all …]
|
| H A D | dmsg.h | 60 #define dmio_printf(iocom, level, ctl, ...) \ argument
173 struct dmsg_iocom *iocom; member
400 void (*state_func)(dmsg_iocom_t *iocom),
404 void dmsg_iocom_restate(dmsg_iocom_t *iocom,
405 void (*state_func)(dmsg_iocom_t *iocom),
408 void dmsg_iocom_signal(dmsg_iocom_t *iocom);
409 void dmsg_iocom_done(dmsg_iocom_t *iocom);
423 void dmsg_iocom_core(dmsg_iocom_t *iocom);
427 void dmsg_iocom_drain(dmsg_iocom_t *iocom);
428 void dmsg_iocom_flush1(dmsg_iocom_t *iocom);
[all …]
|
| H A D | msg_lnk.c | 361 dmsg_iocom_t *iocom = msg->state->iocom; in dmsg_msg_lnk() local
391 dmsg_iocom_t *iocom = state->iocom; in dmsg_lnk_conn() local
399 dmio_printf(iocom, 3, in dmsg_lnk_conn()
527 dmsg_iocom_t *iocom = state->iocom; in dmsg_lnk_span() local
629 dmio_printf(iocom, 3, in dmsg_lnk_span()
631 iocom, slink, in dmsg_lnk_span()
660 dmio_printf(iocom, 3, in dmsg_lnk_span()
662 iocom, slink, in dmsg_lnk_span()
919 if (slink->state->iocom == conn->state->iocom) in dmsg_relay_scan_specific()
1233 dmsg_printf(iocom, in dmsg_shell_tree()
[all …]
|
| /dragonfly/sys/vfs/hammer2/ |
| H A D | hammer2_iocom.c | 59 kdmsg_iocom_init(&hmp->iocom, hmp, in hammer2_iocom_init()
69 if (hmp->iocom.mmsg) in hammer2_iocom_uninit()
70 kdmsg_iocom_uninit(&hmp->iocom); in hammer2_iocom_uninit()
97 bzero(&hmp->iocom.auto_lnk_conn.peer_id, in hammer2_cluster_reconnect()
115 hmp->iocom.auto_lnk_conn.peer_mask &= in hammer2_cluster_reconnect()
123 bzero(&hmp->iocom.auto_lnk_conn.peer_label, in hammer2_cluster_reconnect()
125 ksnprintf(hmp->iocom.auto_lnk_conn.peer_label, in hammer2_cluster_reconnect()
126 sizeof(hmp->iocom.auto_lnk_conn.peer_label), in hammer2_cluster_reconnect()
321 rmsg = kdmsg_msg_alloc(&hmp->iocom.state0, in hammer2_update_spans()
377 if (hmp->iocom.conn_state) { in hammer2_volconf_update()
[all …]
|
| H A D | hammer2.h | 1126 kdmsg_iocom_t iocom; /* volume-level dmsg interface */ member
|
| /dragonfly/sbin/hammer2/ |
| H A D | cmd_debug.c | 85 struct dmsg_iocom iocom;
100 dmsg_iocom_init(&iocom, fd, 0,
110 dmsg_iocom_core(&iocom);
200 shell_ttymsg(dmsg_iocom_t *iocom) in shell_ttymsg() argument
213 pstate = &iocom->state0; in shell_ttymsg()
239 iocom->flags |= DMSG_IOCOMF_EOF; in shell_ttymsg()
254 dmsg_iocom_t *iocom = msg->state->iocom; in hammer2_shell_parse() local
264 dmsg_printf(iocom, "ping reply\n"); in hammer2_shell_parse()
301 dmsg_printf(iocom, "debug> "); in hammer2_shell_parse()
307 dmsg_iocom_t *iocom = msg->state->iocom; in shell_ping() local
[all …]
|
| H A D | cmd_service.c | 50 dmsg_iocom_t iocom; member
99 static void hammer2_volconf_signal(dmsg_iocom_t *iocom);
487 hammer2_volconf_signal(dmsg_iocom_t *iocom) in hammer2_volconf_signal() argument
489 atomic_set_int(&iocom->flags, DMSG_IOCOMF_EOF); in hammer2_volconf_signal()
519 static void autoconn_disconnect_signal(dmsg_iocom_t *iocom);
737 autoconn_disconnect_signal(dmsg_iocom_t *iocom) in autoconn_disconnect_signal() argument
740 atomic_set_int(&iocom->flags, DMSG_IOCOMF_EOF); in autoconn_disconnect_signal()
|
| /dragonfly/sys/sys/ |
| H A D | dmsg.h | 741 struct kdmsg_iocom *iocom; member
784 struct kdmsg_iocom *iocom; member
848 void kdmsg_iocom_init(kdmsg_iocom_t *iocom, void *handle, u_int32_t flags,
851 void kdmsg_iocom_reconnect(kdmsg_iocom_t *iocom, struct file *fp,
853 void kdmsg_iocom_autoinitiate(kdmsg_iocom_t *iocom,
855 void kdmsg_iocom_uninit(kdmsg_iocom_t *iocom);
856 void kdmsg_drain_msgq(kdmsg_iocom_t *iocom);
|
| H A D | disk.h | 190 void disk_clusterctl_wakeup(kdmsg_iocom_t *iocom);
|
| /dragonfly/sys/dev/disk/xdisk/ |
| H A D | xdisk.c | 131 kdmsg_iocom_t iocom; member
145 static void xaio_exit(kdmsg_iocom_t *iocom);
311 kdmsg_iocom_init(&xaio->iocom, xaio, in xdisk_attach()
314 xaio->iocom.exit_func = xaio_exit; in xdisk_attach()
329 ksnprintf(xaio->iocom.auto_lnk_conn.peer_label, in xdisk_attach()
330 sizeof(xaio->iocom.auto_lnk_conn.peer_label), in xdisk_attach()
339 kdmsg_iocom_autoinitiate(&xaio->iocom, NULL); in xdisk_attach()
357 xaio_exit(kdmsg_iocom_t *iocom) in xaio_exit() argument
359 xa_iocom_t *xaio = iocom->handle; in xaio_exit()
366 kdmsg_iocom_uninit(&xaio->iocom); in xaio_exit()
[all …]
|