Fix internal function name

This commit is contained in:
Lukas Joswiak 2022-02-08 12:39:47 -08:00
parent dc4850e722
commit 1d15aa5580

View File

@ -228,7 +228,7 @@ class ConfigBroadcasterImpl {
// ensure strict serializability, some nodes may be temporarily restricted // ensure strict serializability, some nodes may be temporarily restricted
// from participation until the other nodes in the system are brought up to // from participation until the other nodes in the system are brought up to
// date. // date.
ACTOR static Future<Void> registerNode_internal(ConfigBroadcasterImpl* self, ACTOR static Future<Void> registerNodeInternal(ConfigBroadcasterImpl* self,
WorkerInterface w, WorkerInterface w,
Version lastSeenVersion) { Version lastSeenVersion) {
state NetworkAddress address = w.address(); state NetworkAddress address = w.address();
@ -301,7 +301,7 @@ class ConfigBroadcasterImpl {
.detail("ClientID", broadcastInterface.id()) .detail("ClientID", broadcastInterface.id())
.detail("MostRecentVersion", impl->mostRecentVersion); .detail("MostRecentVersion", impl->mostRecentVersion);
impl->actors.add(registerNode_internal(impl, w, lastSeenVersion)); impl->actors.add(registerNodeInternal(impl, w, lastSeenVersion));
// Push full snapshot to worker if it isn't up to date. // Push full snapshot to worker if it isn't up to date.
wait(impl->pushSnapshot(impl->mostRecentVersion, client)); wait(impl->pushSnapshot(impl->mostRecentVersion, client));