@@ -526,8 +526,10 @@ int main(int argc, char* argv[]) {
526526 auto args = cloudsql::network::BloomFilterBitsArgs::deserialize (p);
527527 cloudsql::network::BloomFilterBitsArgs reply_args;
528528 reply_args.context_id = args.context_id ;
529- reply_args.filter_data = cluster_manager->get_local_bloom_bits (args.context_id );
530- reply_args.expected_elements = cluster_manager->get_local_expected_elements ();
529+ reply_args.filter_data =
530+ cluster_manager->get_local_bloom_bits (args.context_id );
531+ reply_args.expected_elements =
532+ cluster_manager->get_local_expected_elements ();
531533 reply_args.num_hashes = cluster_manager->get_local_num_hashes ();
532534
533535 auto resp_p = reply_args.serialize ();
@@ -582,7 +584,8 @@ int main(int argc, char* argv[]) {
582584 }
583585
584586 // Estimate expected elements for bloom filter
585- // For now, estimate based on table size (will be refined with actual count)
587+ // For now, estimate based on table size (will be refined with actual
588+ // count)
586589 size_t estimated_count = 1000 ;
587590 cloudsql::common::BloomFilter local_bloom (estimated_count);
588591
@@ -604,10 +607,9 @@ int main(int argc, char* argv[]) {
604607 // Store local bloom filter bits for coordinator to collect
605608 // The coordinator will aggregate these during Phase 1
606609 auto bloom_bits = local_bloom.serialize ();
607- cluster_manager->set_local_bloom_bits (
608- args.context_id , bloom_bits,
609- local_bloom.expected_elements (),
610- local_bloom.num_hashes ());
610+ cluster_manager->set_local_bloom_bits (args.context_id , bloom_bits,
611+ local_bloom.expected_elements (),
612+ local_bloom.num_hashes ());
611613
612614 bool overall_success = true ;
613615 std::string delivery_errors;
0 commit comments