This repository was archived by the owner on Sep 27, 2019. It is now read-only.
File tree Expand file tree Collapse file tree 3 files changed +10
-1
lines changed Expand file tree Collapse file tree 3 files changed +10
-1
lines changed Original file line number Diff line number Diff line change @@ -56,6 +56,7 @@ void PelotonInit::Initialize() {
56
56
concurrency::EpochManagerFactory::GetInstance ().StartEpoch ();
57
57
58
58
// start GC.
59
+ gc::GCManagerFactory::Configure (settings::SettingsManager::GetInt (settings::SettingId::gc_num_threads));
59
60
gc::GCManagerFactory::GetInstance ().StartGC ();
60
61
61
62
// start index tuner
Original file line number Diff line number Diff line change @@ -99,7 +99,13 @@ SETTING_int(monoqueue_worker_pool_size,
99
99
// Number of connection threads used by peloton
100
100
SETTING_int(connection_thread_count,
101
101
" Number of connection threads (default: std::hardware_concurrency())" ,
102
- std::thread::hardware_concurrency (), false, false)
102
+ std::thread::hardware_concurrency (),
103
+ false, false)
104
+
105
+ SETTING_int(gc_num_threads,
106
+ " The number of Garbage collection threads to run" ,
107
+ 1 ,
108
+ true , true )
103
109
104
110
// ===----------------------------------------------------------------------===//
105
111
// WRITE AHEAD LOG
Original file line number Diff line number Diff line change @@ -116,6 +116,8 @@ const std::string SettingsManager::GetInfo() const {
116
116
GetBool (SettingId::codegen) ? " enabled" : " disabled" ));
117
117
info.append (StringUtil::Format (" %28s: %-28s\n " , " Optimization Timeout" ,
118
118
GetInt (SettingId::task_execution_timeout)));
119
+ info.append (StringUtil::Format (" %28s: %-28s\n " , " Number of GC threads" ,
120
+ GetInt (SettingId::gc_num_threads)));
119
121
return StringBoxUtil::Box (info);
120
122
}
121
123
You can’t perform that action at this time.
0 commit comments