Function receive_entity_create

modules/b2b_logic/entity_storage.c:231–438

}

static void receive_entity_create(enum b2b_entity_type entity_type,
	str *entity_key, str *b2bl_key, bin_packet_t *storage)
{
	unsigned int hash_index, local_index;
	b2bl_tuple_t *tuple = NULL, *old_tuple;
	int tuple_repl_type;
	str scenario_id;
	str sdp;
	str extra_headers;
	int lifetime;
	b2b_dlginfo_t dlginfo;
	b2bl_entity_id_t *entity = NULL, **entity_head = NULL;
	str entity_sid, to_uri, proxy, from_uri, from_dname, hdrs;
	struct b2b_params init_params;

	LM_DBG("Received CREATE event for entity [%.*s]\n",
		entity_key->len, entity_key->s);

	if (b2bl_parse_key(b2bl_key, &hash_index, &local_index) < 0) {
		LM_ERR("Bad tuple key: %.*s\n", b2bl_key->len, b2bl_key->s);
		return;
	}

	B2BL_LOCK_GET(hash_index);

	old_tuple = b2bl_search_tuple_safe(hash_index, local_index);

	bin_pop_int(storage, &tuple_repl_type);

	switch (tuple_repl_type) {
	case REPL_TUPLE_NEW:
		if (!old_tuple) {
			bin_pop_str(storage, &scenario_id);
			bin_pop_str(storage, &extra_headers);
		} else {
			LM_DBG("Tuple [%.*s] already created\n", b2bl_key->len, b2bl_key->s);
			bin_skip_str(storage, 2);
		}

		if (old_tuple) {
			tuple = old_tuple;
		} else {
			memset(&init_params, 0, sizeof init_params);

			if (!scenario_id.s)
				init_params.id = B2B_INTERNAL_ID_PTR;
			else if (!str_strcmp(&scenario_id, const_str(B2B_TOP_HIDING_SCENARY)))
				init_params.id = B2B_TOP_HIDING_ID_PTR;
			else
				init_params.id = &scenario_id;

			init_params.req_route = global_req_rt_ref;
			init_params.reply_route = global_reply_rt_ref;

			tuple = b2bl_insert_new(NULL, hash_index, &init_params,
				&extra_headers,
				local_index, &b2bl_key, INSERTDB_FLAG, TUPLE_REPL_RECV);
			if (!tuple) {