corporate.fm / hobbes
this repo has no description
2
fork

Configure Feed

Select the types of activity you want to include in your feed.

Recruit TLogs as a multiple of replication factor

garrison 726ca9f7 5e6847ec

+12 -2
+12 -2
lib/servers/manager.ex
··· 387 387 388 388 %Config{} = config = state.config 389 389 390 + # TODO: config.num_tlog_teams 391 + assert rem(config.num_tlogs, config.num_replicas) == 0 392 + num_tlog_teams = div(config.num_tlogs, config.num_replicas) 393 + open_tlog_teams = div(open_tlog_slots, config.num_replicas) 394 + 390 395 ids = allocate_server_ids(state, 391 396 storage: min(open_storage_slots, config.num_storage_teams * config.num_replicas), 392 - tlog: min(open_tlog_slots, config.num_tlogs), 397 + tlog: min(open_tlog_teams, num_tlog_teams) * config.num_replicas, 393 398 begin_buffer: min(num_begin_buffers, config.num_begin_buffers), 394 399 commit_buffer: min(num_commit_buffers, config.num_commit_buffers), 395 400 sequencer: 1, resolver: 1, distributor: 1) ··· 465 470 466 471 %Config{} = config = state.config 467 472 473 + # TODO: config.num_tlog_teams 474 + assert rem(config.num_tlogs, config.num_replicas) == 0 475 + num_tlog_teams = div(config.num_tlogs, config.num_replicas) 476 + open_tlog_teams = div(open_tlog_slots, config.num_replicas) 477 + 468 478 ids = allocate_server_ids(state, 469 - tlog: min(open_tlog_slots, config.num_tlogs), 479 + tlog: min(open_tlog_teams, num_tlog_teams) * config.num_replicas, 470 480 begin_buffer: min(num_begin_buffers, config.num_begin_buffers), 471 481 commit_buffer: min(num_commit_buffers, config.num_commit_buffers), 472 482 sequencer: 1, resolver: 1, distributor: 1)