Revert "Add environment variable to control max win sent length"

This reverts commit 833eb3f.

bluefog/common/mpi_controller.cc

@@ -23,7 +23,6 @@
 #include <algorithm>
 #include <cassert>
 #include <thread>
-#include <stdio.h>
 
 #include "cuda_util.h"
 #include "operations.h"
@@ -35,11 +34,7 @@ namespace common {
 // Due to unclear reason that mpi_put/get/accumlate under the
 // mpi_lock epoch cannot send too long vector in one time, we
 // define this number as the maximum size of win_ops can send.
-static const char* BLUEFOG_MAX_WIN_SENT = std::getenv("BLUEFOG_MAX_WIN_SENT_LENGTH");
-static const int MAX_WIN_SENT =
-    BLUEFOG_MAX_WIN_SENT == nullptr
-        ? 2000
-        : std::strtol(BLUEFOG_MAX_WIN_SENT, nullptr, 10);
+constexpr int MAX_WIN_SENT = 2000;
 
 // MPIController
 void MPIController::Initialize() {

examples/pytorch_benchmark.py

@@ -25,7 +25,6 @@
 import torch.utils.data.distributed
 from torchvision import models
 import bluefog.torch as bf
-from bluefog.common import topology_util
 
 
 # Benchmark settings
@@ -108,14 +107,12 @@ def forward(self, x):
     if args.no_rma:
         print("Use neighbor collective")
         # This distributed optimizer uses neighbor communication.
-        bf.set_topology(topology_util.RingGraph(bf.size(), connect_style=1))
         optimizer = bf.DistributedNeighborAllreduceOptimizer(
             optimizer, named_parameters=model.named_parameters()
         )
     else:
         # This distributed optimizer uses one-sided communication
         print("Use win_put ops.")
-        bf.set_topology(topology_util.RingGraph(bf.size(), connect_style=1))
         optimizer = bf.DistributedBluefogOptimizer(
             optimizer, named_parameters=model.named_parameters()
         )