Function dlg_replicated_create

modules/dialog/dlg_replication.c:171–431

* replicates a confirmed dialog from another OpenSIPS instance * by reading the relevant information using the Binary Packet Interface */

 * by reading the relevant information using the Binary Packet Interface
 */
int dlg_replicated_create(bin_packet_t *packet, struct dlg_cell *cell,
	str *ftag, str *ttag, unsigned int hid, int safe, int from_sync)
{
	int h_entry, rc;
	str callid = { NULL, 0 }, from_uri, to_uri, from_tag, to_tag;
	str cseq1, cseq2, contact1, contact2, adv_ct1, adv_ct2;
	str rroute1, rroute2, mangled_fu, mangled_tu;
	str sdp1, sdp2, sdp3, sdp4;
	str sock, vars, profiles;
	struct dlg_cell *dlg = NULL;
	const struct socket_info *caller_sock, *callee_sock;
	struct dlg_entry *d_entry;
	int_str tag_name;
	unsigned int h_id;
	unsigned int state;
	unsigned int start_ts;
	short pkg_ver = get_bin_pkg_version(packet);
	int dlg_val_type;

	LM_DBG("Received replicated dialog!\n");

	if (!cell) {
		DLG_BIN_POP(str, packet, callid, malformed);
		DLG_BIN_POP(str, packet, from_tag, malformed);
		DLG_BIN_POP(str, packet, to_tag, malformed);
		DLG_BIN_POP(str, packet, from_uri, malformed);
		DLG_BIN_POP(str, packet, to_uri, malformed);
		DLG_BIN_POP(int, packet, h_id, malformed);
	}

	DLG_BIN_POP(int, packet, start_ts, malformed);
	DLG_BIN_POP(int, packet, state, malformed);

	if (!cell) {
		h_entry = dlg_hash(&callid);
		d_entry = &d_table->entries[h_entry];

		if (!safe)
			dlg_lock(d_table, d_entry);

		if (pkg_ver == DLG_BIN_V4)
			dlg = lookup_dlg_unsafe(h_entry, h_id);
		else
			get_dlg_unsafe(d_entry, &callid, &from_tag, &to_tag, &dlg);

		if (dlg) {
			LM_DBG("Dialog with ci '%.*s' is already created\n",
			       callid.len, callid.s);
			/* unmark dlg as loaded from DB (otherwise it would have been
			 * dropped later when syncing from cluster is done) */
			dlg->flags &= ~DLG_FLAG_FROM_DB;
			if (from_sync || *dlg_sync_in_progress)
				dlg->flags |= DLG_FLAG_SYNCED;

			dlg_unlock(d_table, d_entry);
			return 0;
		}