Function replicate_entity_update

modules/b2b_entities/b2be_clustering.c:181–258

}

void replicate_entity_update(b2b_dlg_t *dlg, int etype, unsigned int hash_index,
	str *b2bl_param, int event_type, bin_packet_t *storage)
{
	int rc;
	bin_packet_t packet;
	b2b_table htable = (etype == B2B_SERVER) ? server_htable : client_htable;
	str storage_cnt_buf;
	int pkt_type;

	B2BE_LOCK_GET(htable, hash_index);

	if (dlg->state < B2B_CONFIRMED) {
		B2BE_LOCK_RELEASE(htable, hash_index);
		return;
	}

	switch (event_type) {
	case -1:
		pkt_type = REPL_ENTITY_PARAM_UPDATE;
		break;
	case B2B_EVENT_ACK:
		pkt_type = REPL_ENTITY_ACK;
		break;
	case B2B_EVENT_UPDATE:
		pkt_type = REPL_ENTITY_UPDATE;
		break;
	default:
		LM_ERR("Bad entity event %d\n", event_type);
		B2BE_LOCK_RELEASE(htable, hash_index);
		return;
	}

	if (bin_init(&packet, &entities_repl_cap, pkt_type, B2BE_BIN_VERSION, 0) < 0) {
		LM_ERR("Failed to init bin packet\n");
		B2BE_LOCK_RELEASE(htable, hash_index);
		return;
	}

	if (pkt_type == REPL_ENTITY_PARAM_UPDATE) {  /* replicate only the b2bl param update */
		bin_pack_entity_coords(&packet, dlg, etype);
		bin_push_str(&packet, b2bl_param);
	} else {
		bin_pack_entity(&packet, dlg, etype);

		if (storage->buffer.s) {
			bin_get_content_start(storage, &storage_cnt_buf);
			if (storage_cnt_buf.len > 0 &&
				bin_append_buffer(&packet, &storage_cnt_buf) < 0) {
				LM_ERR("Failed to push the entity storage content into the packet\n");
				B2BE_LOCK_RELEASE(htable, hash_index);
				goto end;
			}
		}
	}

	B2BE_LOCK_RELEASE(htable, hash_index);

	rc = cl_api.send_all(&packet, b2be_cluster);