Function receive_tm_repl

modules/tm/cluster.c:165–232

}

static void receive_tm_repl(bin_packet_t *packet)
{
	int proto;
	int port;
	str tmp;
	struct receive_info ri;

	memset(&ri, 0, sizeof ri);
	LM_DBG("received %d packet from %d in cluster %d\n",
			packet->type, packet->src_id, tm_repl_cluster);

	if (packet->type != TM_CLUSTER_REPLY &&
			packet->type != TM_CLUSTER_REQUEST &&
			packet->type != TM_CLUSTER_AUTO_CANCEL) {
		LM_WARN("Invalid tm binary packet command: %d (from node: %d in cluster: %d)\n",
				packet->type, packet->src_id, tm_repl_cluster);
		return;
	}

	/* first part is common to all messages */
	TM_BIN_POP(int, &proto, "proto");
	TM_BIN_POP(str, &tmp, "dst host");
	TM_BIN_POP(int, &port, "dst port");

	ri.bind_address = grep_internal_sock_info(&tmp, port, proto);
	if (!ri.bind_address) {
		LM_WARN("received replicated message for an interface"
				" we don't know %s:%.*s:%d; discarding...\n",
				proto2a(proto), tmp.len, tmp.s, port);
		return;
	}
	if (!(ri.bind_address->flags & SI_IS_ANYCAST)) {
		LM_WARN("received replicated message for a non-anycast interface"
				" %s:%.*s:%d\n",
				proto2a(proto), tmp.len, tmp.s, port);
	}
	ri.dst_port = ri.bind_address->port_no;
	ri.dst_ip = ri.bind_address->address;
	ri.proto = proto;
	/* XXX: do we care about this? Only UDP should work with anycast */
	ri.proto_reserved1 = ri.proto_reserved2 = 0;

	TM_BIN_POP(str, &tmp, "src host");
	memcpy((char *)&ri.src_ip, tmp.s, tmp.len);
	TM_BIN_POP(int, &ri.src_port, "src port");
	TM_BIN_POP(str, &tmp, "message");
	/* we need to substract the '\0' termination from message len */
	tmp.len--;

	/* only auto-CANCEL is treated differently */
	switch (packet->type) {
	case TM_CLUSTER_AUTO_CANCEL:
		if_update_stat(tm_enable_stats, tm_cluster_cancel_rx , 1);
		if (tm_repl_auto_cancel) {
			tm_repl_cancel(packet, &tmp, &ri);
			return;
		}
		LM_WARN("auto-CANCEL handling is disabled, but got one auto-CANCEL here!\n");