Function receive_sync_request

modules/cachedb_local/cachedb_local_replication.c:177–218

}

int receive_sync_request(int node_id)
{
        int i;
        lcache_col_t *col;
        lcache_entry_t *data;
        bin_packet_t *sync_packet;
        lcache_t* cache_htable;

        for ( col=lcache_collection; col; col=col->next ) {
                LM_DBG("Found collection %.*s\n", col->col_name.len, col->col_name.s);

                if (!col->replicated)
                        continue;

                cache_htable = col->col_htable->htable;

                for (i =0; i < col->col_htable->size; i++) {
                        lock_get(&cache_htable[i].lock);
                        data = cache_htable[i].entries;
                        while(data) {
                                if (data->expires == 0 || data->expires > get_ticks()) {
                                        sync_packet = clusterer_api.sync_chunk_start(&cache_repl_cap,
                                                                        cluster_id, node_id, BIN_VERSION);
                                        if (!sync_packet) {
                                                LM_ERR("Can not create sync packet!\n");
												lock_release(&cache_htable[i].lock);
                                                return -1;
                                        }
                                        bin_push_str(sync_packet, &col->col_name);
                                        bin_push_str(sync_packet, &data->attr);
                                        bin_push_str(sync_packet, &data->value);
                                        bin_push_int(sync_packet, data->expires ?
                                                data->expires - get_ticks() : 0);
                                }
                                data = data->next;
                        }
                        lock_release(&cache_htable[i].lock);
                }
        }

        return 0;
}

void receive_cluster_event(enum clusterer_event ev, int node_id)
{