Function tm_replicate_packet

modules/tm/cluster.c:299–332

* Builds a replicated message */

 * Builds a replicated message
 */
static bin_packet_t *tm_replicate_packet(struct sip_msg *msg, int type)
{
	static bin_packet_t packet;
	str tmp;
	int port;

	/* XXX: could estimate better here, but let's assume we need msg->len */
	if (bin_init(&packet, &tm_repl_cap, type, TM_CLUSTER_VERSION,
			msg->len + 128) < 0) {
		LM_ERR("cannot initiate bin reply buffer\n");
		return NULL;
	}

	TM_BIN_PUSH(int, msg->rcv.proto, "proto");
	if (msg->rcv.bind_address->tag.len) {
		/* send interface tag if it exists, instead of hostname and port */
		tmp = msg->rcv.bind_address->tag;
		port = 0;
	} else {
		tmp = msg->rcv.bind_address->name;
		port = msg->rcv.bind_address->port_no;
	}
	TM_BIN_PUSH(str, &tmp, "dst host");
	TM_BIN_PUSH(int, port, "dst port");
	tmp.s = (char *)&msg->rcv.src_ip;
	tmp.len = sizeof(struct ip_addr);
	TM_BIN_PUSH(str, &tmp, "src host");
	TM_BIN_PUSH(int, msg->rcv.src_port, "src port");
	tmp.s = msg->buf;
	tmp.len = msg->len + 1; /* XXX: add '\0' terminator - receive_msg expects it */
	TM_BIN_PUSH(str, &tmp, "message");

	return &packet;
}

/**
 * Replicates an auto-CANCEL message to all nodes