Function cr_status_update

modules/drouting/dr_clustering.c:204–238

static int cr_status_update(bin_packet_t *packet)
{
	struct head_db *part;
	str cr_id;
	str part_name;
	int flags;
	pcr_t *cr;

	bin_pop_str(packet, &part_name);
	bin_pop_str(packet, &cr_id);
	bin_pop_int(packet, &flags);

	part = get_partition( &part_name );
	if (part==NULL || part->rdata==NULL)
		return -1;

	lock_start_read(part->ref_lock);

	cr = get_carrier_by_id(part->rdata->carriers_tree, &cr_id);
	if (cr) {
		if ((cr->flags&DR_CR_FLAG_IS_OFF)!=flags) {
			/* import the status flags */
			cr->flags = ((~DR_CR_FLAG_IS_OFF)&cr->flags)|(DR_CR_FLAG_IS_OFF&flags);
			/* set the DIRTY flag to force flushing to DB */
			cr->flags |= DR_CR_FLAG_DIRTY;
			dr_raise_cr_event( part, cr, MI_SSTR("replicated info"));
		}
		lock_stop_read(part->ref_lock);
		return 0;
	}

	lock_stop_read(part->ref_lock);

	return -1;
}


static void dr_recv_sync_packet(bin_packet_t *packet)