HTTP adjustment

jik18001 · Oct 11, 2023 · e30673e · e30673e
1 parent 051f076
commit e30673e
Show file tree

Hide file tree

Showing 4 changed files with 20 additions and 8 deletions.
diff --git a/CA/server.go b/CA/server.go
@@ -364,7 +364,12 @@ func StartCA(c *CAContext) {
 		time.Sleep(time.Duration(60-second+1) * time.Second)
 	}
 	// Initialize CA context
-	tr := &http.Transport{}
+	tr := &http.Transport{
+		MaxIdleConnsPerHost: 10,
+		MaxConnsPerHost:     300,
+		WriteBufferSize:     1024 * 1024, // 1MB
+		ReadBufferSize:      1024 * 1024, // 1MB
+	}
 	c.Client = &http.Client{
 		Transport: tr,
 	}

diff --git a/Logger/server.go b/Logger/server.go
@@ -257,7 +257,12 @@ func PeriodicTask(ctx *LoggerContext) {
 // Start the logger
 func StartLogger(c *LoggerContext) {
 	// set up HTTP client
-	tr := &http.Transport{}
+	tr := &http.Transport{
+		MaxIdleConnsPerHost: 10,
+		MaxConnsPerHost:     300,
+		WriteBufferSize:     1024 * 1024, // 1MB
+		ReadBufferSize:      1024 * 1024, // 1MB
+	}
 	c.Client = &http.Client{
 		Transport: tr,
 	}

diff --git a/gossiper/gossiper_server.go b/gossiper/gossiper_server.go
@@ -431,9 +431,10 @@ func StartGossiperServer(c *GossiperContext) {
 	//InitializeGossiperStorage(c)
 	// Create the http client to be used.
 	tr := &http.Transport{
-		MaxIdleConnsPerHost:   3000,
-		MaxConnsPerHost:       3000,
-		ExpectContinueTimeout: 10,
+		MaxIdleConnsPerHost: 10,
+		MaxConnsPerHost:     300,
+		WriteBufferSize:     1024 * 1024, // 1MB
+		ReadBufferSize:      1024 * 1024, // 1MB
 	}
 	c.Client = &http.Client{
 		Transport: tr,

diff --git a/monitor/monitor-server.go b/monitor/monitor-server.go
@@ -40,9 +40,10 @@ func StartMonitorServer(c *MonitorContext) {
 	}
 	time.Sleep(time.Duration(c.Clockdrift_miliseconds) * time.Millisecond)
 	tr := &http.Transport{
-		MaxIdleConnsPerHost:   3000,
-		MaxConnsPerHost:       3000,
-		ExpectContinueTimeout: 10,
+		MaxIdleConnsPerHost: 10,
+		MaxConnsPerHost:     300,
+		WriteBufferSize:     1024 * 1024, // 1MB
+		ReadBufferSize:      1024 * 1024, // 1MB
 	}
 	c.Client = &http.Client{
 		Transport: tr,