Lines Matching refs:cstab
248 static csdata *cstab = NULL; variable
458 sid = matocsserv_server_get_ip(cstab[servers[i]].ptr); in do_perfect_match()
460 sid = topology_get_rackid(matocsserv_server_get_ip(cstab[servers[i]].ptr)); in do_perfect_match()
462 sid = matocsserv_server_get_labelmask(cstab[servers[i]].ptr) & LabelUniqueMask; in do_perfect_match()
497 if (matocsserv_server_has_labels(cstab[servers[vi]].ptr,labelmasks[x])) { in do_perfect_match()
1042 csop->next = cstab[csid].opchunks; in chunk_addopchunk()
1043 cstab[csid].opchunks = csop; in chunk_addopchunk()
1050 for (csop=cstab[csid].opchunks ; csop!=NULL; csop=csop->next) { in chunk_statusopchunk()
1063 csopp = &(cstab[csid].opchunks); in chunk_delopchunk()
1111 dist = topology_distance(matocsserv_server_get_ip(cstab[csids[i]].ptr),clientip); in chunk_creation_servers()
1214 matocsserv_send_setchunkversion(cstab[s->csid].ptr,c->chunkid,c->version+1,c->version); in chunk_emergency_increase_version()
1241 if (!cstab[s->csid].valid) { in chunk_remove_disconnected_chunks()
1252 matocsserv_write_counters(cstab[s->csid].ptr,0); in chunk_remove_disconnected_chunks()
1555 matocsserv_write_counters(cstab[s->csid].ptr,x); in chunk_write_counters()
1729 chosen[i] = cstab[s->csid].ptr; in chunk_univ_multi_modify()
1731 matocsserv_send_createchunk(cstab[s->csid].ptr,c->chunkid,c->version); in chunk_univ_multi_modify()
1789 matocsserv_send_setchunkversion(cstab[s->csid].ptr,ochunkid,c->version+1,c->version); in chunk_univ_multi_modify()
1861 … matocsserv_send_duplicatechunk(cstab[s->csid].ptr,c->chunkid,c->version,oc->chunkid,oc->version); in chunk_univ_multi_modify()
1969 matocsserv_send_truncatechunk(cstab[s->csid].ptr,ochunkid,length,c->version+1,c->version); in chunk_univ_multi_truncate()
2035 …matocsserv_send_duptruncchunk(cstab[s->csid].ptr,c->chunkid,c->version,oc->chunkid,oc->version,len… in chunk_univ_multi_truncate()
2096 if (cstab[s->csid].valid) { in chunk_repair()
2124 if (s->version==bestversion && cstab[s->csid].valid) { in chunk_repair()
2193 …if (s->valid!=INVALID && s->valid!=DEL && s->valid!=WVER && s->valid!=TDWVER && cstab[s->csid].val… in chunk_get_version_and_csdata()
2194 …if (cnt<100 && matocsserv_get_csdata(cstab[s->csid].ptr,&(lstab[cnt].ip),&(lstab[cnt].port),&(lsta… in chunk_get_version_and_csdata()
2238 if (cstab[s->csid].valid && s->valid!=DEL) { in chunk_get_copies()
2239 if (matocsserv_get_csdata(cstab[s->csid].ptr,&ip,&port,NULL,NULL)==0) { in chunk_get_copies()
2277 if (cstab[s->csid].valid && s->valid!=DEL) { in chunk_get_version_and_copies()
2278 if (matocsserv_get_csdata(cstab[s->csid].ptr,&ip,&port,NULL,NULL)==0) { in chunk_get_version_and_copies()
2373 cstab[s->csid].mfr_state = REPL_IN_PROGRESS; in chunk_mfr_state_check()
2390 cstab[csid].newchunkdelay = NEWCHUNKDELAY; in chunk_server_has_chunk()
2412 …RIX64"_%08"PRIX32"), id looks wrong - just ignore it",matocsserv_getstrip(cstab[csid].ptr),chunkid… in chunk_server_has_chunk()
2424 …IX64"_%08"PRIX32"), so create it for future deletion",matocsserv_getstrip(cstab[csid].ptr),chunkid… in chunk_server_has_chunk()
2443 …sid=%"PRIu16" ; ip=%s",chunkid,(version&0x80000000)?1:0,csid,matocsserv_getstrip(cstab[csid].ptr)); in chunk_server_has_chunk()
2445 …DBUSY || s->valid==TDWVER)?1:0,validstr[s->valid],s->csid,matocsserv_getstrip(cstab[s->csid].ptr)); in chunk_server_has_chunk()
2509 matocsserv_write_counters(cstab[csid].ptr,1); in chunk_server_has_chunk()
2562 matocsserv_write_counters(cstab[csid].ptr,0); in chunk_damaged()
2602 matocsserv_write_counters(cstab[csid].ptr,0); in chunk_lost()
2608 cstab[csid].lostchunkdelay = LOSTCHUNKDELAY; in chunk_lost()
2626 switch (cstab[csid].mfr_state) { in chunk_get_mfrstatus()
2643 if (cstab[csid].prev<MAXCSCOUNT) { in chunk_server_remove_csid()
2644 cstab[cstab[csid].prev].next = cstab[csid].next; in chunk_server_remove_csid()
2646 csusedhead = cstab[csid].next; in chunk_server_remove_csid()
2648 if (cstab[csid].next<MAXCSCOUNT) { in chunk_server_remove_csid()
2649 cstab[cstab[csid].next].prev = cstab[csid].prev; in chunk_server_remove_csid()
2652 cstab[csid].next = MAXCSCOUNT; in chunk_server_remove_csid()
2653 cstab[csid].prev = csfreetail; in chunk_server_remove_csid()
2654 cstab[csfreetail].next = csid; in chunk_server_remove_csid()
2668 csfreehead = cstab[csid].next; in chunk_server_new_csid()
2669 cstab[csfreehead].prev = MAXCSCOUNT; in chunk_server_new_csid()
2672 cstab[csusedhead].prev = csid; in chunk_server_new_csid()
2674 cstab[csid].next = csusedhead; in chunk_server_new_csid()
2684 for (csid = csusedhead ; csid < MAXCSCOUNT ; csid = cstab[csid].next) { in chunk_server_check_delays()
2685 if (cstab[csid].newchunkdelay>0) { in chunk_server_check_delays()
2686 cstab[csid].newchunkdelay--; in chunk_server_check_delays()
2689 if (cstab[csid].lostchunkdelay>0) { in chunk_server_check_delays()
2690 cstab[csid].lostchunkdelay--; in chunk_server_check_delays()
2700 cstab[csid].ptr = ptr; in chunk_server_connected()
2701 cstab[csid].opchunks = NULL; in chunk_server_connected()
2702 cstab[csid].valid = 1; in chunk_server_connected()
2703 cstab[csid].registered = 0; in chunk_server_connected()
2704 cstab[csid].mfr_state = UNKNOWN_HARD; in chunk_server_connected()
2710 if (cstab[csid].registered==0 && cstab[csid].valid==1) { in chunk_server_register_end()
2711 cstab[csid].registered = 1; in chunk_server_register_end()
2729 cstab[csid].valid = 0; in chunk_server_disconnected()
2730 if (cstab[csid].registered==0) { in chunk_server_disconnected()
2733 csop = cstab[csid].opchunks; in chunk_server_disconnected()
2744 cstab[csid].opchunks = NULL; in chunk_server_disconnected()
2746 for (csid = csusedhead ; csid < MAXCSCOUNT ; csid = cstab[csid].next) { in chunk_server_disconnected()
2747 cstab[csid].mfr_state = UNKNOWN_HARD; in chunk_server_disconnected()
2775 matocsserv_disconnection_finished(cstab[ds->csid].ptr); in chunk_server_disconnection_loop()
2822 matocsserv_write_counters(cstab[s->csid].ptr,0); in chunk_got_delete_status()
2864 matocsserv_write_counters(cstab[s->csid].ptr,0); in chunk_got_replicate_status()
2892 matocsserv_write_counters(cstab[s->csid].ptr,0); in chunk_got_replicate_status()
2925 matocsserv_write_counters(cstab[s->csid].ptr,0); in chunk_got_replicate_status()
3016 matocsserv_write_counters(cstab[s->csid].ptr,0); in chunk_operation_status()
3166 if (matocsserv_get_csdata(cstab[csid].ptr,&sip,NULL,NULL,NULL)==0) { in chunk_mindist()
3224 if (matocsserv_get_csdata(cstab[dstcsid].ptr,&cuip,NULL,NULL,NULL)==0) { in chunk_get_undergoal_replicate_srccsid()
3226 …if (matocsserv_replication_read_counter(cstab[s->csid].ptr,now)<MaxReadRepl[lclass] && (s->valid==… in chunk_get_undergoal_replicate_srccsid()
3227 if (matocsserv_get_csdata(cstab[s->csid].ptr,&ip,NULL,NULL,NULL)==0) { in chunk_get_undergoal_replicate_srccsid()
3253 …if (matocsserv_replication_read_counter(cstab[s->csid].ptr,now)<MaxReadRepl[lclass] && (s->valid==… in chunk_get_undergoal_replicate_srccsid()
3254 if (matocsserv_get_csdata(cstab[s->csid].ptr,&ip,NULL,NULL,NULL)==0) { in chunk_get_undergoal_replicate_srccsid()
3273 …if (matocsserv_replication_read_counter(cstab[s->csid].ptr,now)<MaxReadRepl[lclass] && s->valid==V… in chunk_get_undergoal_replicate_srccsid()
3281 …if (matocsserv_replication_read_counter(cstab[s->csid].ptr,now)<MaxReadRepl[lclass] && s->valid==T… in chunk_get_undergoal_replicate_srccsid()
3302 …if (matocsserv_send_replicatechunk(cstab[dstcsid].ptr,c->chunkid,c->version,cstab[srccsid].ptr)<0)… in chunk_undergoal_replicate()
3482 …=%"PRIu16" ; ip=%s",c->chunkid,validstr[s->valid],s->csid,matocsserv_getstrip(cstab[s->csid].ptr)); in chunk_do_jobs()
3504 cstab[s->csid].mfr_state = REPL_IN_PROGRESS; in chunk_do_jobs()
3572 if (s->version==bestversion && cstab[s->csid].valid) { in chunk_do_jobs()
3583 …copy on (%s - ver:%08"PRIX32")",c->chunkid,c->version,matocsserv_getstrip(cstab[s->csid].ptr),s->v… in chunk_do_jobs()
3585 …copy on (%s - ver:%08"PRIX32")",c->chunkid,c->version,matocsserv_getstrip(cstab[s->csid].ptr),s->v… in chunk_do_jobs()
3602 …copy on (%s - ver:%08"PRIX32")",c->chunkid,c->version,matocsserv_getstrip(cstab[s->csid].ptr),s->v… in chunk_do_jobs()
3604 …sion on (%s - ver:%08"PRIX32")",c->chunkid,c->version,matocsserv_getstrip(cstab[s->csid].ptr),s->v… in chunk_do_jobs()
3619 if (matocsserv_deletion_counter(cstab[s->csid].ptr)<TmpMaxDel) { in chunk_do_jobs()
3641 matocsserv_send_deletechunk(cstab[s->csid].ptr,c->chunkid,0); in chunk_do_jobs()
3715 if (matocsserv_deletion_counter(cstab[s->csid].ptr)<TmpMaxDel) { in chunk_do_jobs()
3728 matocsserv_send_deletechunk(cstab[s->csid].ptr,c->chunkid,c->version); in chunk_do_jobs()
3746 if (matocsserv_deletion_counter(cstab[s->csid].ptr)<TmpMaxDel) { in chunk_do_jobs()
3749 matocsserv_send_deletechunk(cstab[s->csid].ptr,c->chunkid,0); in chunk_do_jobs()
3783 if (matocsserv_deletion_counter(cstab[s->csid].ptr)<TmpMaxDel) { in chunk_do_jobs()
3790 matocsserv_send_deletechunk(cstab[s->csid].ptr,c->chunkid,0); in chunk_do_jobs()
3808 if (matocsserv_deletion_counter(cstab[s->csid].ptr)<TmpMaxDel) { in chunk_do_jobs()
3815 matocsserv_send_deletechunk(cstab[s->csid].ptr,c->chunkid,0); in chunk_do_jobs()
3837 if (matocsserv_has_avail_space(cstab[s->csid].ptr)) { in chunk_do_jobs()
3848 …if (matocsserv_has_avail_space(cstab[s->csid].ptr) && matocsserv_deletion_counter(cstab[s->csid].p… in chunk_do_jobs()
3854 matocsserv_send_deletechunk(cstab[s->csid].ptr,c->chunkid,0); in chunk_do_jobs()
3942 if (matocsserv_replication_read_counter(cstab[s->csid].ptr,now)<MaxReadRepl[lclass]) { in chunk_do_jobs()
3946 if (matocsserv_get_csdata(cstab[s->csid].ptr,vrip+vripcnt,NULL,NULL,NULL)==0) { in chunk_do_jobs()
3953 if (matocsserv_get_csdata(cstab[s->csid].ptr,vrip+vripcnt,NULL,NULL,NULL)==0) { in chunk_do_jobs()
4192 srcusage = matocsserv_get_usage(cstab[servers[i]].ptr); in chunk_do_jobs()
4193 repl_read_counter = matocsserv_replication_read_counter(cstab[servers[i]].ptr,now); in chunk_do_jobs()
4196 dstusage = matocsserv_get_usage(cstab[dcsids[j]].ptr); in chunk_do_jobs()
4209 …if (matocsserv_server_get_ip(cstab[servers[k]].ptr)==matocsserv_server_get_ip(cstab[dcsids[j]].ptr… in chunk_do_jobs()
4213 …gy_get_rackid(matocsserv_server_get_ip(cstab[servers[k]].ptr))==topology_get_rackid(matocsserv_ser… in chunk_do_jobs()
4217 … ((matocsserv_server_get_labelmask(cstab[servers[k]].ptr) & LabelUniqueMask) == (matocsserv_server… in chunk_do_jobs()
4229 if (matocsserv_server_has_labels(cstab[dcsids[j]].ptr,labelmasks[k])) { in chunk_do_jobs()
4238 …if (labelmask==NULL || matocsserv_server_has_labels(cstab[dcsids[j]].ptr,labelmask)) { // if we ha… in chunk_do_jobs()
4244 …if (repl_read_counter < MaxReadRepl[lclass] && matocsserv_replication_write_counter(cstab[dcsids[j… in chunk_do_jobs()
4256 matocsserv_send_replicatechunk(cstab[dstcsid].ptr,c->chunkid,c->version,cstab[srccsid].ptr); in chunk_do_jobs()
4481 for (csid = csusedhead ; csid < MAXCSCOUNT ; csid = cstab[csid].next) { in chunk_jobs_main()
4482 switch (cstab[csid].mfr_state) { in chunk_jobs_main()
4486 cstab[csid].mfr_state = CAN_BE_REMOVED; in chunk_jobs_main()
4489 cstab[csid].mfr_state = WAS_IN_PROGRESS; in chunk_jobs_main()
4493 cstab[csid].mfr_state = UNKNOWN_SOFT; in chunk_jobs_main()
4649 matocsserv_disconnection_finished(cstab[ds->csid].ptr); in chunk_cleanup()
4655 matocsserv_disconnection_finished(cstab[ds->csid].ptr); in chunk_cleanup()
4677 cstab[i].next = i+1; in chunk_cleanup()
4678 cstab[i].prev = i-1; in chunk_cleanup()
4679 cstab[i].valid = 0; in chunk_cleanup()
4680 cstab[i].registered = 0; in chunk_cleanup()
4681 cstab[i].newchunkdelay = 0; in chunk_cleanup()
4682 cstab[i].lostchunkdelay = 0; in chunk_cleanup()
4684 cstab[0].prev = MAXCSCOUNT; in chunk_cleanup()
5017 cstab = malloc(sizeof(csdata)*MAXCSCOUNT); in chunk_strinit()
5018 passert(cstab); in chunk_strinit()
5020 cstab[i].next = i+1; in chunk_strinit()
5021 cstab[i].prev = i-1; in chunk_strinit()
5022 cstab[i].opchunks = NULL; in chunk_strinit()
5023 cstab[i].valid = 0; in chunk_strinit()
5024 cstab[i].registered = 0; in chunk_strinit()
5025 cstab[i].mfr_state = UNKNOWN_HARD; in chunk_strinit()
5026 cstab[i].newchunkdelay = 0; in chunk_strinit()
5027 cstab[i].lostchunkdelay = 0; in chunk_strinit()
5029 cstab[0].prev = MAXCSCOUNT; in chunk_strinit()