Skip to content

Commit

Permalink
mad squirrels ejection (#6640)
Browse files Browse the repository at this point in the history
  • Loading branch information
maximyurchuk authored Jul 12, 2024
1 parent 9d5b4e2 commit 6186f0c
Show file tree
Hide file tree
Showing 9 changed files with 5 additions and 49 deletions.
31 changes: 0 additions & 31 deletions ydb/core/actorlib_impl/mad_squirrel.cpp

This file was deleted.

3 changes: 0 additions & 3 deletions ydb/core/actorlib_impl/ya.make
Original file line number Diff line number Diff line change
Expand Up @@ -13,9 +13,6 @@ SRCS(
load_network.h
long_timer.cpp
long_timer.h
mad_squirrel.cpp
mad_squirrel.h
melancholic_gopher.cpp
name_service_client_protocol.cpp
name_service_client_protocol.h
proto_ready_actor.h
Expand Down
2 changes: 1 addition & 1 deletion ydb/core/driver_lib/cli_utils/cli_actorsystem_perftest.cpp
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
#include "cli.h"
#include <ydb/core/actorlib_impl/mad_squirrel.h>
#include "melancholic_gopher.h"
#include <ydb/library/actors/core/actorsystem.h>
#include <ydb/library/actors/core/scheduler_basic.h>
#include <ydb/library/actors/core/executor_pool_basic.h>
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
#include "mad_squirrel.h"
#include "melancholic_gopher.h"
#include <ydb/library/actors/core/events.h>
#include <ydb/library/actors/core/log.h>
#include <ydb/library/actors/core/hfunc.h>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,6 @@

namespace NActors {

IActor* CreateMadSquirrel(); // will send messages to itself in round
IActor* CreateMelancholicGopher(double surveyForSeconds, const TActorId &reportTo); // will spin for survey period and then wakeup next in line
IActor* CreateGopherMother(const TVector<std::pair<ui32, double>> &lineProfile, ui32 lines, ui32 shotsInRound); // would spawn gophers according to profile (poolid, period) in lines number

Expand Down
2 changes: 2 additions & 0 deletions ydb/core/driver_lib/cli_utils/ya.make
Original file line number Diff line number Diff line change
Expand Up @@ -29,6 +29,8 @@ SRCS(
cli_minikql_compile_and_exec.cpp
cli_scheme_cache_append.cpp
cli_scheme_initroot.cpp
melancholic_gopher.cpp
melancholic_gopher.h
)

PEERDIR(
Expand Down
10 changes: 0 additions & 10 deletions ydb/core/driver_lib/run/kikimr_services_initializers.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,6 @@

#include <ydb/core/actorlib_impl/destruct_actor.h>
#include <ydb/core/actorlib_impl/load_network.h>
#include <ydb/core/actorlib_impl/mad_squirrel.h>

#include "ydb/core/audit/audit_log.h"

Expand Down Expand Up @@ -578,15 +577,6 @@ void TBasicServicesInitializer::InitializeServices(NActors::TActorSystemSetup* s
setup->CpuManager = CreateCpuManagerConfig(systemConfig, appData);
setup->MonitorStuckActors = systemConfig.GetMonitorStuckActors();

for (ui32 poolId = 0; poolId != setup->GetExecutorsCount(); ++poolId) {
const auto &execConfig = systemConfig.GetExecutor(poolId);
if (execConfig.HasInjectMadSquirrels()) {
for (ui32 i = execConfig.GetInjectMadSquirrels(); i > 0; --i) {
setup->LocalServices.push_back(std::pair<TActorId, TActorSetupCmd>(TActorId(), TActorSetupCmd(CreateMadSquirrel(), TMailboxType::HTSwap, poolId)));
}
}
}

auto schedulerConfig = CreateSchedulerConfig(systemConfig.GetScheduler());
schedulerConfig.MonCounters = GetServiceCounters(counters, "utils");
setup->Scheduler.Reset(CreateSchedulerThread(schedulerConfig));
Expand Down
1 change: 0 additions & 1 deletion ydb/core/driver_lib/run/run.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,6 @@
#include <ydb/library/actors/interconnect/interconnect_tcp_proxy.h>
#include <ydb/library/actors/interconnect/interconnect_tcp_server.h>
#include <ydb/library/actors/interconnect/interconnect_mon.h>
#include <ydb/core/actorlib_impl/mad_squirrel.h>
#include <ydb/core/config/init/dummy.h>

#include <ydb/core/control/immediate_control_board_actor.h>
Expand Down
2 changes: 1 addition & 1 deletion ydb/core/protos/config.proto
Original file line number Diff line number Diff line change
Expand Up @@ -69,7 +69,7 @@ message TActorSystemConfig {
optional uint32 Threads = 2;
optional uint64 SpinThreshold = 3;
optional TAffinity Affinity = 4;
optional uint32 InjectMadSquirrels = 5;
optional uint32 InjectMadSquirrels = 5; // Obsolete, no more mad squirrels anymore
optional string Name = 6;
optional uint32 TimePerMailboxMicroSecs = 7;
optional uint32 EventsPerMailbox = 8;
Expand Down

0 comments on commit 6186f0c

Please sign in to comment.