lib/libdmsg/msg_lnk.c
static void
dmsg_lnk_relay(dmsg_msg_t *msg)
{
	dmsg_state_t *state = msg->state;
	h2span_relay_t *relay;

	assert(msg->any.head.cmd & DMSGF_REPLY);

	if (msg->any.head.cmd & DMSGF_DELETE) {
		pthread_mutex_lock(&cluster_mtx);
		fprintf(stderr, "RELAY DELETE FROM LNK_RELAY MSG\n");
		if ((relay = state->any.relay) != NULL) {
			dmsg_relay_delete(relay);
		} else {
			dmsg_state_reply(state, 0);
		}
		pthread_mutex_unlock(&cluster_mtx);
	}
}
/*
 * Messages received on relay SPANs.  These are open transactions so it is
 * in fact possible for the other end to close the transaction.
 *
 * XXX MPRACE on state structure
 */
Messages received on relay SPANs.  These are open transactions so it is
in fact possible for the other end to close the transaction.

XXX MPRACE on state structure
Messages received on relay SPANs . These are open transactions so it is in fact possible for the other end to close the transaction . XXX MPRACE on state structure
static void
dmsg_lnk_relay(dmsg_msg_t *msg)
{
	dmsg_state_t *state = msg->state;
	h2span_relay_t *relay;
	assert(msg->any.head.cmd & DMSGF_REPLY);
	if (msg->any.head.cmd & DMSGF_DELETE) {
		pthread_mutex_lock(&cluster_mtx);
		fprintf(stderr, "RELAY DELETE FROM LNK_RELAY MSG\n");
		if ((relay = state->any.relay) != NULL) {
			dmsg_relay_delete(relay);
		} else {
			dmsg_state_reply(state, 0);
		}
		pthread_mutex_unlock(&cluster_mtx);
	}
}
static void dmsg_lnk_relay ( dmsg_msg_t * msg ) { dmsg_state_t * state = msg -> state ; h2span_relay_t * relay ; assert ( msg -> any . head . cmd & DMSGF_REPLY ) ; if ( msg -> any . head . cmd & DMSGF_DELETE ) { pthread_mutex_lock ( & cluster_mtx ) ; fprintf ( stderr , " \n " ) ; if ( ( relay = state -> any . relay ) != NULL ) { dmsg_relay_delete ( relay ) ; } else { dmsg_state_reply ( state , 0 ) ; } pthread_mutex_unlock ( & cluster_mtx ) ; } }
Messages received on relay SPANs.
Messages received on relay SPANs .