Function receive_entity_ack

modules/b2b_logic/entity_storage.c:529–570

}

static void receive_entity_ack(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;

	LM_DBG("Received ACK 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) {
		LM_ERR("Tuple [%.*s] not found\n", b2bl_key->len, b2bl_key->s);
		B2BL_LOCK_RELEASE(hash_index);
		return;
	}

	bin_pop_int(storage, &tuple_repl_type);
	if (tuple_repl_type != REPL_TUPLE_UPDATE) {
		LM_ERR("Bad tuple replication type: %d\n", tuple_repl_type);
		B2BL_LOCK_RELEASE(hash_index);
		return;
	}

	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);
}

static void receive_entity_delete(enum b2b_entity_type entity_type,
	str *entity_key, str *b2bl_key, bin_packet_t *storage)