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

increase the priority of reboot and recruitment requests

Browse Source
This commit is contained in:
Evan Tschannen 2019-11-11 15:17:11 -08:00
parent fd5c57d4e3
commit 1e5677b55a
4 changed files with 17 additions and 0 deletions

4
fdbclient/ClientWorkerInterface.h

@ -39,6 +39,10 @@ struct ClientWorkerInterface {
UID id() const { return reboot.getEndpoint().token; }
NetworkAddress address() const { return reboot.getEndpoint().getPrimaryAddress(); }
void initEndpoints() {
reboot.getEndpoint( TaskPriority::ReadSocket );
}
template <class Ar>
void serialize( Ar& ar ) {
serializer(ar, reboot, profiler);

11
fdbserver/WorkerInterface.actor.h

@ -71,6 +71,17 @@ struct WorkerInterface {
WorkerInterface() {}
WorkerInterface( const LocalityData& locality ) : locality( locality ) {}
void initEndpoints() {
clientInterface.initEndpoints();
tLog.getEndpoint( TaskPriority::Worker );
master.getEndpoint( TaskPriority::Worker );
masterProxy.getEndpoint( TaskPriority::Worker );
resolver.getEndpoint( TaskPriority::Worker );
logRouter.getEndpoint( TaskPriority::Worker );
debugPing.getEndpoint( TaskPriority::Worker );
coordinationPing.getEndpoint( TaskPriority::Worker );
}
template <class Ar>
void serialize(Ar& ar) {
serializer(ar, clientInterface, locality, tLog, master, masterProxy, dataDistributor, ratekeeper, resolver, storage, logRouter, debugPing, coordinationPing, waitFailure, setMetricsRate, eventLogRequest, traceBatchDumpRequest, testerInterface, diskStoreRequest, execReq, workerSnapReq);

1
fdbserver/worker.actor.cpp

@ -799,6 +799,7 @@ ACTOR Future<Void> workerServer(
state std::string coordFolder = abspath(_coordFolder);
state WorkerInterface interf( locality );
interf.initEndpoints();
folder = abspath(folder);

1
flow/network.h

@ -44,6 +44,7 @@ enum class TaskPriority {
Coordination = 8800,
FailureMonitor = 8700,
ResolutionMetrics = 8700,
Worker = 8660,
ClusterController = 8650,
MasterTLogRejoin = 8646,
ProxyStorageRejoin = 8645,