Function receive_entity_delete

modules/b2b_logic/entity_storage.c:572–637

}

static void receive_entity_delete(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;
	int tuple_repl_type;
	int lifetime;
	b2bl_entity_id_t *entity = NULL, **entity_head = NULL;
	int i;

	LM_DBG("Received DELETE 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);

	tuple = b2bl_search_tuple_safe(hash_index, local_index);
	if (!tuple) {
		/* tuple might have already expired locally */
		LM_DBG("Tuple [%.*s] not found, discarding entity [%.*s] delete\n",
			b2bl_key->len, b2bl_key->s, entity_key->len, entity_key->s);
		B2BL_LOCK_RELEASE(hash_index);
		return;
	}

	bin_pop_int(storage, &tuple_repl_type);

	switch (tuple_repl_type) {
	case REPL_TUPLE_UPDATE:
		bin_pop_int(storage, &tuple->state);
		bin_pop_int(storage, &lifetime);

		tuple->lifetime = lifetime ? get_ticks() + lifetime : 0;

		if (unpack_context_vals(tuple, storage) < 0) {
			LM_ERR("Failed to unpack context values\n");
			B2BL_LOCK_RELEASE(hash_index);
			return;
		}
		break;
	case REPL_TUPLE_NO_INFO:
		/* tuple already deleted on sender, no info to pop */
		break;
	default:
		LM_ERR("Bad tuple replication type: %d\n", tuple_repl_type);
		B2BL_LOCK_RELEASE(hash_index);
		return;
	}

	entity = b2bl_search_entity(tuple, entity_key, entity_type, &entity_head);
	if (entity)
		b2bl_delete_entity(entity, tuple, hash_index, 0);
	else
		LM_DBG("Entity [%.*s] does not exist\n", entity_key->len, entity_key->s);