39 static void master_auth_rxmsg(dmsg_msg_t *msg);
41 static void master_link_rxmsg(dmsg_msg_t *msg);
96 static void master_auth_conn_rx(dmsg_msg_t *msg);
102 	dmsg_msg_t *msg;  in master_auth_signal()  local
110 	msg = dmsg_msg_alloc(&iocom->state0, 0,  in master_auth_signal()
113 	msg->any.lnk_conn.peer_mask = (uint64_t)-1;  in master_auth_signal()
114 	msg->any.lnk_conn.peer_type = DMSG_PEER_ROUTER;  in master_auth_signal()
115 	msg->any.lnk_conn.peer_mask = (uint64_t)-1;  in master_auth_signal()
117 	dmsg_msg_write(msg);  in master_auth_signal()
124 master_auth_conn_rx(dmsg_msg_t *msg)  in master_auth_conn_rx()  argument
126 	if (msg->any.head.cmd & DMSGF_DELETE)  in master_auth_conn_rx()
127 		dmsg_msg_reply(msg, 0);  in master_auth_conn_rx()
132 master_auth_rxmsg(dmsg_msg_t *msg __unused)  in master_auth_rxmsg()
151 master_link_rxmsg(dmsg_msg_t *msg)  in master_link_rxmsg()  argument
166 	state = msg->state;  in master_link_rxmsg()
168 	cmd = (state != &iocom->state0) ? state->icmd : msg->any.head.cmd;  in master_link_rxmsg()
175 		state->func(msg);  in master_link_rxmsg()
182 			dmsg_msg_lnk(msg);  in master_link_rxmsg()
185 			dmsg_msg_dbg(msg);  in master_link_rxmsg()
188 			iocom->usrmsg_callback(msg, 1);  in master_link_rxmsg()
200 dmsg_msg_dbg(dmsg_msg_t *msg)  in dmsg_msg_dbg()  argument
202 	dmsg_iocom_t *iocom = msg->state->iocom;  in dmsg_msg_dbg()
204 	switch(msg->tcmd & DMSGF_CMDSWMASK) {  in dmsg_msg_dbg()
210 		if (msg->aux_data)  in dmsg_msg_dbg()
211 			msg->aux_data[msg->aux_size - 1] = 0;  in dmsg_msg_dbg()
212 		iocom->usrmsg_callback(msg, 0);  in dmsg_msg_dbg()
219 		if (msg->aux_data)  in dmsg_msg_dbg()
220 			msg->aux_data[msg->aux_size - 1] = 0;  in dmsg_msg_dbg()
221 		if (msg->aux_data)  in dmsg_msg_dbg()
222 			write(2, msg->aux_data, strlen(msg->aux_data));  in dmsg_msg_dbg()
225 		iocom->usrmsg_callback(msg, 1);  in dmsg_msg_dbg()