remove time.sleep

Author: boddumanohar

main.go

@@ -0,0 +1,108 @@
+package main
+
+import (
+	"bytes"
+	"encoding/json"
+	"fmt"
+	"io"
+	"net/http"
+	"time"
+
+	"k8s.io/klog"
+)
+
+const (
+	ClusterIP     = "http://34.8.181.238"                  // Replace with your actual cluster IP
+	ClusterID     = "af7863cd-3097-434e-9325-c1011a2c9366" // Replace with your actual cluster ID
+	ClusterSecret = "HZn4ktklT8ux2xab41hH"                 // Replace with your actual cluster secret
+)
+
+func CallSBCLI(method, path string, args interface{}) (interface{}, error) {
+
+	data := []byte(`{}`)
+	var err error
+
+	if args != nil {
+		data, err = json.Marshal(args)
+		if err != nil {
+			return nil, fmt.Errorf("%s: %w", method, err)
+		}
+	} else {
+		data = nil
+	}
+
+	requestURL := fmt.Sprintf("%s/%s", ClusterIP, path)
+	klog.Infof("Calling Simplyblock API: Method: %s: RequestURL: %s: Body: %s\n", method, requestURL, string(data))
+
+	req, err := http.NewRequest("GET", requestURL, bytes.NewReader(data))
+	if err != nil {
+		return nil, fmt.Errorf("%s: %w", method, err)
+	}
+
+	// authHeader := fmt.Sprintf("%s %s", ClusterID, ClusterSecret)
+
+	// req.Header.Add("Authorization", authHeader)
+	req.Header.Set("Content-Type", "application/json")
+
+	for key, values := range req.Header {
+		for _, value := range values {
+			fmt.Printf("Header: %s: %s\n", key, value)
+		}
+	}
+
+	httpClient := &http.Client{Timeout: 10 * time.Second}
+	//print request object
+	fmt.Printf("Request: %s %s, Headers: %v, Body: %s", method, requestURL, req.Header, string(data))
+	// resp, err := httpClient.Get(requestURL)
+	// if err != nil {
+	// 	return nil, fmt.Errorf("%s: %w", method, err)
+	// }
+
+	resp, err := httpClient.Do(req)
+	if err != nil {
+		return nil, fmt.Errorf("%s: %w", method, err)
+	}
+
+	defer resp.Body.Close()
+	if resp.StatusCode >= http.StatusInternalServerError {
+		return nil, fmt.Errorf("%s: HTTP error code: %d", method, resp.StatusCode)
+	}
+
+	var response struct {
+		Result  any    `json:"result"`
+		Results any    `json:"results"`
+		Error   string `json:"error"`
+	}
+
+	// copy resp.Body object
+	copiedBody, err := io.ReadAll(resp.Body)
+	if err != nil {
+		return nil, fmt.Errorf("%s: HTTP error code: %d Error: %w", method, resp.StatusCode, err)
+	}
+	fmt.Println("copiedBody:", string(copiedBody), "for request:", requestURL)
+	resp.Body = io.NopCloser(bytes.NewBuffer(copiedBody))
+
+	err = json.NewDecoder(resp.Body).Decode(&response)
+	if err != nil {
+		return nil, fmt.Errorf("%s: HTTP error code: %d Error: %w", method, resp.StatusCode, err)
+	}
+
+	if resp.StatusCode >= http.StatusBadRequest {
+		return nil, fmt.Errorf("%s: HTTP error code: %d Error: %s", method, resp.StatusCode, response.Error)
+	}
+
+	if response.Result != nil {
+		return response.Result, nil
+	}
+	return response.Results, nil
+}
+
+func main() {
+	resp, err := CallSBCLI("GET", "lvol/"+"ce6cb6a1-0c63-43e9-a095-66db8f2f4997/", nil)
+	if err != nil {
+		klog.Errorf("Error calling SBCLI: %v", err)
+	} else {
+		klog.Info("Successfully called SBCLI")
+	}
+	fmt.Printf("Response: %v\n", resp)
+}

pkg/spdk/controllerserver.go

@@ -22,7 +22,6 @@ import (
 	"fmt"
 	"strconv"
 	"strings"
-	"time"
 
 	"github.com/container-storage-interface/spec/lib/go/csi"
 	"google.golang.org/grpc/codes"
@@ -373,8 +372,6 @@ func (cs *controllerServer) publishVolume(volumeID string) (map[string]string, e
 		return nil, err
 	}
 	fmt.Println("spdkVol:", spdkVol)
-	time.Sleep(30 * time.Second) // simulate some delay for debugging
-	fmt.Println("slept for 30secs")
 	err = cs.spdkNode.PublishVolume(spdkVol.lvolID)
 	if err != nil {
 		return nil, err