Function cl_sync_chunk_start

modules/clusterer/sync.c:210–276

static int no_sync_chunks_sent;

bin_packet_t *cl_sync_chunk_start(str *capability, int cluster_id, int dst_id,
                                  short data_version)
{
	str bin_buffer;
	int prev_chunk_size = 0;
	int aloc_new_pkt = 0;
	bin_packet_t *new_packet = NULL;

	if (sync_packet_last) {
		bin_get_buffer(sync_packet_last, &bin_buffer);
		prev_chunk_size = bin_buffer.len - sync_prev_buf_len;
		/* assume this chunk will have aprox the same size as the previous one
		 * and check if there is enough space in the packet */
		if (bin_buffer.len + prev_chunk_size > sync_packet_size)
			aloc_new_pkt = 1;
	} else
		aloc_new_pkt = 1;

	if (aloc_new_pkt) {  /* next chunk will be in a new packet */
		if (sync_packet_last) {
			*sync_last_chunk_sz = prev_chunk_size;

			/* properly end the previous packet (to be sent later) */
			msg_add_trailer(sync_packet_last, cluster_id, dst_id);
			sync_last_chunk_sz = NULL;
		}

		new_packet = malloc(sizeof *new_packet);
		if (!new_packet) {
			LM_ERR("No more pkg memory\n");
			return NULL;
		}
		new_packet->next = NULL;

		if (_bin_init(new_packet,&cl_extra_cap,CLUSTERER_SYNC,BIN_SYNC_VERSION,0,1)<0) {
			LM_ERR("Failed to init bin packet\n");
			free(new_packet);
			return NULL;
		}

		bin_push_str(new_packet, capability);
		bin_push_int(new_packet, data_version);
		if (sync_packet_last)
			sync_packet_last->next = new_packet;
		else
			sync_packets = new_packet;
		sync_packet_last = new_packet;
		sync_packets_cnt++;
	}

	if (sync_last_chunk_sz)
		*sync_last_chunk_sz = prev_chunk_size;

	/* reserve and remember a holder for the upcoming data chunk size */
	bin_get_buffer(sync_packet_last, &bin_buffer);
	bin_push_int(sync_packet_last, 0);
	sync_last_chunk_sz = (int *)(bin_buffer.s + bin_buffer.len);