HTTP/1 transport

Signed-off-by: Lazar Cvetković <l.cvetkovic.997@gmail.com>

Author: cvetkovic

internal/data_plane/proxy/reverse_proxy/proxy_factory.go

@@ -1,10 +1,7 @@
 package reverse_proxy
 
 import (
-	"context"
-	"crypto/tls"
 	"github.com/sirupsen/logrus"
-	"golang.org/x/net/http2"
 	"net"
 	"net/http"
 	"net/http/httputil"
@@ -16,12 +13,13 @@ var EmptyReverseProxyDirector = func(request *http.Request) {}
 func CreateReverseProxy() *httputil.ReverseProxy {
 	return &httputil.ReverseProxy{
 		Director: EmptyReverseProxyDirector,
-		Transport: &http2.Transport{
-			DialTLSContext: func(ctx context.Context, network, addr string, cfg *tls.Config) (net.Conn, error) {
-				return net.Dial(network, addr)
-			},
-			AllowHTTP:       true,
-			IdleConnTimeout: 2 * time.Second,
+		Transport: &http.Transport{
+			DialContext: (&net.Dialer{
+				Timeout: 5 * time.Second,
+			}).DialContext,
+			IdleConnTimeout:     5 * time.Second,
+			MaxIdleConns:        100,
+			MaxIdleConnsPerHost: 10,
 		},
 		BufferPool:    NewBufferPool(),
 		FlushInterval: 0,

internal/worker_node/managers/readiness_probes.go

@@ -1,8 +1,6 @@
 package managers
 
 import (
-	"context"
-	"crypto/tls"
 	"fmt"
 	"io"
 	"net"
@@ -11,7 +9,6 @@ import (
 	"time"
 
 	"github.com/sirupsen/logrus"
-	"golang.org/x/net/http2"
 )
 
 const ProbeURLFormat = "localhost:%d"
@@ -28,12 +25,13 @@ func createProbingDialer(network, addr string) (net.Conn, error) {
 
 var httpProbingClient = http.Client{
 	Timeout: 25 * time.Millisecond,
-	Transport: &http2.Transport{
-		DialTLSContext: func(ctx context.Context, network, addr string, cfg *tls.Config) (net.Conn, error) {
-			return net.Dial(network, addr)
-		},
-		AllowHTTP:       true,
-		IdleConnTimeout: 1 * time.Second,
+	Transport: &http.Transport{
+		DialContext: (&net.Dialer{
+			Timeout: 5 * time.Second,
+		}).DialContext,
+		IdleConnTimeout:     5 * time.Second,
+		MaxIdleConns:        100,
+		MaxIdleConnsPerHost: 10,
 	},
 }
 

scripts/common.sh

@@ -81,10 +81,10 @@ function SetupWorkerNodes() {
         RemoteExec $1 "cd ~/cluster_manager; git pull; git lfs pull"
 
         COMPILER_TAGS=""
-        if sudo lshw -C display | grep -q NVIDIA
-        then
-            COMPILER_TAGS="-tags nvidia_gpu"
-        fi
+        #if sudo lshw -C display | grep -q NVIDIA
+        #then
+        #    COMPILER_TAGS="-tags nvidia_gpu"
+        #fi
 
         # Compile worker node daemon
         RemoteExec $1 "sudo mkdir -p /cluster_manager/cmd/worker_node"

scripts/setup_node.sh

@@ -93,7 +93,9 @@ then
 elif [ "$RUNTIME" = "dandelion" ]
 then
     # Install Cargo for Dandelion setup
-    sudo apt install cargo -y
+    wget https://static.rust-lang.org/rustup.sh
+    chmod +x rustup.sh
+    ./rustup.sh -y
 fi
 
 # Install GPU drivers