| /dports/security/vault/vault-1.8.2/vendor/github.com/apple/foundationdb/fdbserver/workloads/ |
| H A D | RandomMoveKeys.actor.cpp | 90 …vector<StorageServerInterface> getRandomTeam(vector<StorageServerInterface> storageServers, int te… in getRandomTeam()
91 if( storageServers.size() < teamSize ) { in getRandomTeam()
96 g_random->randomShuffle( storageServers ); in getRandomTeam()
100 while (t.size() < teamSize && storageServers.size()) { in getRandomTeam()
101 auto s = storageServers.back(); in getRandomTeam()
102 storageServers.pop_back(); in getRandomTeam()
182 state vector<StorageServerInterface> storageServers = wait( getStorageServers( cx ) ); in worker()
183 eliminateDuplicates(storageServers); in worker()
189 …vector<StorageServerInterface> team = self->getRandomTeam(storageServers, self->configuration.stor… in worker()
|
| H A D | ConsistencyCheck.actor.cpp | 500 for(int i = 0; i < storageServers.size(); i++) in getStorageSizeEstimate()
512 for(int i = 0; i < storageServers.size(); i++) in getStorageSizeEstimate()
666 for(int s=0; s<storageServers.size(); s++) in checkDataConsistency()
696 for(int j = 0; j < storageServers.size(); j++) in checkDataConsistency()
948 for(int j = 0; j < storageServers.size(); j++) in checkDataConsistency()
961 .detail("StorageServer", storageServers[j]); in checkDataConsistency()
1043 for(i = 0; i < storageServers.size(); i++) in checkForUndesirableServers()
1062 for(j = i + 1; j < storageServers.size(); j++) in checkForUndesirableServers()
1064 if(storageServers[i].address() == storageServers[j].address()) in checkForUndesirableServers()
1067 .detail("Address", storageServers[i].address()); in checkForUndesirableServers()
[all …]
|
| H A D | TargetedKill.actor.cpp | 85 state vector<StorageServerInterface> storageServers = wait( getStorageServers( cx ) ); in assassin() local
114 int o = g_random->randomInt(0,storageServers.size()); in assassin()
115 for( int i = 0; i < storageServers.size(); i++) { in assassin()
116 StorageServerInterface ssi = storageServers[o]; in assassin()
120 o = ++o%storageServers.size(); in assassin()
|
| /dports/ftp/php-fastdfs/fastdfs-6.06/client/ |
| H A D | fdfs_test1.c | 154 ConnectionInfo storageServers[FDFS_MAX_SERVERS_EACH_GROUP]; in main() local
161 pTrackerServer, group_name, storageServers, \ in main()
166 pServerEnd = storageServers + storage_count; in main()
167 for (pServer=storageServers; pServer<pServerEnd; pServer++) in main()
171 (int)(pServer - storageServers) + 1, \ in main()
416 ConnectionInfo storageServers[FDFS_MAX_SERVERS_EACH_GROUP]; in main() local
420 storageServers, FDFS_MAX_SERVERS_EACH_GROUP, \ in main()
436 storageServers[i].ip_addr, \ in main()
437 storageServers[i].port); in main()
|
| H A D | fdfs_test.c | 160 ConnectionInfo storageServers[FDFS_MAX_SERVERS_EACH_GROUP]; in main() local
166 pTrackerServer, storageServers, \ in main()
171 pServerEnd = storageServers + storage_count; in main()
172 for (pServer=storageServers; pServer<pServerEnd; pServer++) in main()
176 (int)(pServer - storageServers) + 1, \ in main()
443 ConnectionInfo storageServers[FDFS_MAX_SERVERS_EACH_GROUP]; in main() local
447 storageServers, FDFS_MAX_SERVERS_EACH_GROUP, \ in main()
464 storageServers[i].ip_addr, \ in main()
465 storageServers[i].port); in main()
|
| H A D | tracker_client.h | 187 pTrackerServer, storageServers, nMaxServerCount, \ argument
190 pTrackerServer, NULL, storageServers, nMaxServerCount, \
219 ConnectionInfo *storageServers, const int nMaxServerCount, \
|
| H A D | tracker_client.c | 1019 ConnectionInfo *storageServers, const int nMaxServerCount, \ in tracker_query_storage_store_list_with_group() argument
1126 memset(storageServers, 0, sizeof(ConnectionInfo) * nMaxServerCount); in tracker_query_storage_store_list_with_group()
1132 pServerEnd = storageServers + (*storage_count); in tracker_query_storage_store_list_with_group()
1133 for (pStorageServer=storageServers; pStorageServer<pServerEnd; \ in tracker_query_storage_store_list_with_group()
|
| /dports/ftp/php-fastdfs/fastdfs-6.06/client/test/ |
| H A D | fdfs_test1.c | 154 ConnectionInfo storageServers[FDFS_MAX_SERVERS_EACH_GROUP]; in main() local
161 pTrackerServer, group_name, storageServers, \ in main()
166 pServerEnd = storageServers + storage_count; in main()
167 for (pServer=storageServers; pServer<pServerEnd; pServer++) in main()
171 (int)(pServer - storageServers) + 1, \ in main()
416 ConnectionInfo storageServers[FDFS_MAX_SERVERS_EACH_GROUP]; in main() local
420 storageServers, FDFS_MAX_SERVERS_EACH_GROUP, \ in main()
436 storageServers[i].ip_addr, \ in main()
437 storageServers[i].port); in main()
|
| H A D | fdfs_test.c | 160 ConnectionInfo storageServers[FDFS_MAX_SERVERS_EACH_GROUP]; in main() local
166 pTrackerServer, storageServers, \ in main()
171 pServerEnd = storageServers + storage_count; in main()
172 for (pServer=storageServers; pServer<pServerEnd; pServer++) in main()
176 (int)(pServer - storageServers) + 1, \ in main()
443 ConnectionInfo storageServers[FDFS_MAX_SERVERS_EACH_GROUP]; in main() local
447 storageServers, FDFS_MAX_SERVERS_EACH_GROUP, \ in main()
464 storageServers[i].ip_addr, \ in main()
465 storageServers[i].port); in main()
|
| /dports/ftp/fastdfs/fastdfs-6.06/client/ |
| H A D | fdfs_test1.c | 154 ConnectionInfo storageServers[FDFS_MAX_SERVERS_EACH_GROUP]; in main() local
161 pTrackerServer, group_name, storageServers, \ in main()
166 pServerEnd = storageServers + storage_count; in main()
167 for (pServer=storageServers; pServer<pServerEnd; pServer++) in main()
171 (int)(pServer - storageServers) + 1, \ in main()
416 ConnectionInfo storageServers[FDFS_MAX_SERVERS_EACH_GROUP]; in main() local
420 storageServers, FDFS_MAX_SERVERS_EACH_GROUP, \ in main()
436 storageServers[i].ip_addr, \ in main()
437 storageServers[i].port); in main()
|
| H A D | fdfs_test.c | 160 ConnectionInfo storageServers[FDFS_MAX_SERVERS_EACH_GROUP]; in main() local
166 pTrackerServer, storageServers, \ in main()
171 pServerEnd = storageServers + storage_count; in main()
172 for (pServer=storageServers; pServer<pServerEnd; pServer++) in main()
176 (int)(pServer - storageServers) + 1, \ in main()
443 ConnectionInfo storageServers[FDFS_MAX_SERVERS_EACH_GROUP]; in main() local
447 storageServers, FDFS_MAX_SERVERS_EACH_GROUP, \ in main()
464 storageServers[i].ip_addr, \ in main()
465 storageServers[i].port); in main()
|
| H A D | tracker_client.h | 187 pTrackerServer, storageServers, nMaxServerCount, \ argument
190 pTrackerServer, NULL, storageServers, nMaxServerCount, \
219 ConnectionInfo *storageServers, const int nMaxServerCount, \
|
| H A D | tracker_client.c | 1019 ConnectionInfo *storageServers, const int nMaxServerCount, \ in tracker_query_storage_store_list_with_group() argument
1126 memset(storageServers, 0, sizeof(ConnectionInfo) * nMaxServerCount); in tracker_query_storage_store_list_with_group()
1132 pServerEnd = storageServers + (*storage_count); in tracker_query_storage_store_list_with_group()
1133 for (pStorageServer=storageServers; pStorageServer<pServerEnd; \ in tracker_query_storage_store_list_with_group()
|
| /dports/ftp/fastdfs/fastdfs-6.06/client/test/ |
| H A D | fdfs_test1.c | 154 ConnectionInfo storageServers[FDFS_MAX_SERVERS_EACH_GROUP]; in main() local
161 pTrackerServer, group_name, storageServers, \ in main()
166 pServerEnd = storageServers + storage_count; in main()
167 for (pServer=storageServers; pServer<pServerEnd; pServer++) in main()
171 (int)(pServer - storageServers) + 1, \ in main()
416 ConnectionInfo storageServers[FDFS_MAX_SERVERS_EACH_GROUP]; in main() local
420 storageServers, FDFS_MAX_SERVERS_EACH_GROUP, \ in main()
436 storageServers[i].ip_addr, \ in main()
437 storageServers[i].port); in main()
|
| H A D | fdfs_test.c | 160 ConnectionInfo storageServers[FDFS_MAX_SERVERS_EACH_GROUP]; in main() local
166 pTrackerServer, storageServers, \ in main()
171 pServerEnd = storageServers + storage_count; in main()
172 for (pServer=storageServers; pServer<pServerEnd; pServer++) in main()
176 (int)(pServer - storageServers) + 1, \ in main()
443 ConnectionInfo storageServers[FDFS_MAX_SERVERS_EACH_GROUP]; in main() local
447 storageServers, FDFS_MAX_SERVERS_EACH_GROUP, \ in main()
464 storageServers[i].ip_addr, \ in main()
465 storageServers[i].port); in main()
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/apple/foundationdb/fdbserver/ |
| H A D | ClusterRecruitmentInterface.h | 90 vector<WorkerInterface> storageServers; member
99 …serializer(ar, tLogs, satelliteTLogs, proxies, resolvers, storageServers, oldLogRouters, dcId, sat… in serialize()
|
| H A D | Status.actor.cpp | 545 vector<std::pair<StorageServerInterface, EventMap>> storageServers, in processStatusFetcher() argument
631 for(ss = storageServers.begin(); ss != storageServers.end(); ++ss) { in processStatusFetcher()
1497 …ErrorOr<vector<std::pair<StorageServerInterface, EventMap>>> storageServers = wait(storageServerFu… in workloadStatusFetcher() local
1498 if(!storageServers.present()) { in workloadStatusFetcher()
1499 throw storageServers.getError(); in workloadStatusFetcher()
1507 for(auto &ss : storageServers.get()) { in workloadStatusFetcher()
1929 state vector<std::pair<StorageServerInterface, EventMap>> storageServers; in clusterGetStatus() local
2031 storageServers = _storageServers.get(); in clusterGetStatus()
2063 …ics, latestError, traceFileOpenErrors, programStarts, processIssues, storageServers, tLogs, proxie… in clusterGetStatus()
|
| H A D | masterserver.actor.cpp | 349 while( idx < recruits.storageServers.size() ) { in newSeedServers()
351 .detail("CandidateWorker", recruits.storageServers[idx].locality.toString()); in newSeedServers()
354 …isr.seedTag = dcId_tags.count(recruits.storageServers[idx].locality.dcId()) ? dcId_tags[recruits.s… in newSeedServers()
359 …ErrorOr<InitializeStorageReply> newServer = wait( recruits.storageServers[idx].storage.tryGetReply… in newSeedServers()
369 if(!dcId_tags.count(recruits.storageServers[idx].locality.dcId())) { in newSeedServers()
370 dcId_tags[recruits.storageServers[idx].locality.dcId()] = Tag(nextLocality, 0); in newSeedServers()
374 Tag& tag = dcId_tags[recruits.storageServers[idx].locality.dcId()]; in newSeedServers()
|
| H A D | ClusterController.actor.cpp | 654 result.storageServers.push_back(primaryStorageServers[i].interf); in findWorkersForConfiguration()
772 result.storageServers.push_back(primaryStorageServers[i].interf); in findWorkersForConfiguration()
|