apple/foundationdb
1
0
Fork 0
mirror of https://github.com/apple/foundationdb.git synced 2025-06-02 19:25:52 +08:00
Code Issues Packages Projects Releases Wiki Activity

Add number comment to limitReason_t entries

Browse Source
This commit is contained in:
Meng Xu 2020-07-15 10:57:45 -07:00
parent 02505669d3
commit 27a21e23bd
1 changed files with 16 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
fdbserver/Ratekeeper.actor.cpp
View File

@ -33,17 +33,17 @@
#include "flow/actorcompiler.h" // This must be the last #include. #include "flow/actorcompiler.h" // This must be the last #include.
enum limitReason_t { enum limitReason_t {
unlimited, // TODO: rename to workload? unlimited, // TODO: rename to workload?
storage_server_write_queue_size, storage_server_write_queue_size, // 1
storage_server_write_bandwidth_mvcc, storage_server_write_bandwidth_mvcc,
storage_server_readable_behind, storage_server_readable_behind,
log_server_mvcc_write_bandwidth, log_server_mvcc_write_bandwidth,
log_server_write_queue, log_server_write_queue, // 5
storage_server_min_free_space, // a storage server's normal limits are being reduced by low free space storage_server_min_free_space, // a storage server's normal limits are being reduced by low free space
storage_server_min_free_space_ratio, // a storage server's normal limits are being reduced by a low free space ratio storage_server_min_free_space_ratio, // a storage server's normal limits are being reduced by a low free space ratio
log_server_min_free_space, log_server_min_free_space,
log_server_min_free_space_ratio, log_server_min_free_space_ratio,
storage_server_durability_lag, storage_server_durability_lag, // 10
storage_server_list_fetch_failed, storage_server_list_fetch_failed,
limitReason_t_end limitReason_t_end
}; };
@ -1150,12 +1150,16 @@ void updateRate(RatekeeperData* self, RatekeeperLimits* limits) {
} }
int64_t totalDiskUsageBytes = 0; int64_t totalDiskUsageBytes = 0;
for(auto & t : self->tlogQueueInfo) for (auto& t : self->tlogQueueInfo) {
if (t.value.valid) if (t.value.valid) {
totalDiskUsageBytes += t.value.lastReply.storageBytes.used; totalDiskUsageBytes += t.value.lastReply.storageBytes.used;
for(auto & s : self->storageQueueInfo) }
if (s.value.valid) }
for (auto& s : self->storageQueueInfo) {
if (s.value.valid) {
totalDiskUsageBytes += s.value.lastReply.storageBytes.used; totalDiskUsageBytes += s.value.lastReply.storageBytes.used;
}
}
if (now() - self->lastSSListFetchedTimestamp > SERVER_KNOBS->STORAGE_SERVER_LIST_FETCH_TIMEOUT) { if (now() - self->lastSSListFetchedTimestamp > SERVER_KNOBS->STORAGE_SERVER_LIST_FETCH_TIMEOUT) {
limits->tpsLimit = 0.0; limits->tpsLimit = 0.0;
@ -1248,8 +1252,9 @@ ACTOR Future<Void> ratekeeper(RatekeeperInterface rkInterf, Reference<AsyncVar<S
.detail("Rate", (SERVER_KNOBS->TARGET_BYTES_PER_STORAGE_SERVER - SERVER_KNOBS->SPRING_BYTES_STORAGE_SERVER) / ((((double)SERVER_KNOBS->MAX_READ_TRANSACTION_LIFE_VERSIONS) / SERVER_KNOBS->VERSIONS_PER_SECOND) + 2.0)); .detail("Rate", (SERVER_KNOBS->TARGET_BYTES_PER_STORAGE_SERVER - SERVER_KNOBS->SPRING_BYTES_STORAGE_SERVER) / ((((double)SERVER_KNOBS->MAX_READ_TRANSACTION_LIFE_VERSIONS) / SERVER_KNOBS->VERSIONS_PER_SECOND) + 2.0));
tlogInterfs = dbInfo->get().logSystemConfig.allLocalLogs(); tlogInterfs = dbInfo->get().logSystemConfig.allLocalLogs();
for( int i = 0; i < tlogInterfs.size(); i++ ) for (int i = 0; i < tlogInterfs.size(); i++) {
tlogTrackers.push_back( splitError( trackTLogQueueInfo(&self, tlogInterfs[i]), err ) ); tlogTrackers.push_back( splitError( trackTLogQueueInfo(&self, tlogInterfs[i]), err ) );
}
self.remoteDC = dbInfo->get().logSystemConfig.getRemoteDcId(); self.remoteDC = dbInfo->get().logSystemConfig.getRemoteDcId();