Function replicate_entity_create

modules/b2b_entities/b2be_clustering.c:122–179

}

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

	B2BE_LOCK_GET(htable, hash_index);

	if (dlg->replicated) {
		B2BE_LOCK_RELEASE(htable, hash_index);
		return;
	} else
		dlg->replicated = 1;

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

	bin_pack_entity(&packet, dlg, etype);

	if (storage->buffer.s) {  /* the callback was called */
		bin_get_content_start(storage, &storage_cnt_buf);
		if (storage_cnt_buf.len > 0 &&  /* content has been pushed */
			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);
	switch (rc) {
	case CLUSTERER_CURR_DISABLED:
		LM_INFO("Current node is disabled in cluster: %d\n", b2be_cluster);
		goto end;
	case CLUSTERER_DEST_DOWN:
		LM_INFO("All destinations in cluster: %d are down or probing\n",
			b2be_cluster);
		goto end;
	case CLUSTERER_SEND_ERR:
		LM_ERR("Error sending in cluster: %d\n", b2be_cluster);
		goto end;
	}

	LM_DBG("Replicated entity [%.*s] [%.*s]\n", dlg->tag[1].len, dlg->tag[1].s,
		dlg->callid.len, dlg->callid.s);

end:
	bin_free_packet(&packet);
	return;
}