From 5f9b4e6a8f71af212f999058cc692369cd959f30 Mon Sep 17 00:00:00 2001 From: vicente87 Date: Fri, 13 Dec 2024 09:44:15 +0100 Subject: [PATCH] Storage provider test --- pkg/resourcemanager/delegate.go | 11 ++++++----- 1 file changed, 6 insertions(+), 5 deletions(-) diff --git a/pkg/resourcemanager/delegate.go b/pkg/resourcemanager/delegate.go index 730735cd..566c52f6 100644 --- a/pkg/resourcemanager/delegate.go +++ b/pkg/resourcemanager/delegate.go @@ -32,7 +32,6 @@ import ( "strconv" "strings" - "sync" "time" "github.com/grycap/oscar/v3/pkg/types" @@ -47,7 +46,7 @@ const ( // tokenCache map to store tokens from services and endpoints -> [CLUSTER_ENDPOINT][SERVICE_NAME] var tokenCache = map[string]map[string]string{} -var mutex sync.Mutex +//var mutex sync.Mutex // DelegatedEvent wraps the original input event by adding the storage provider ID type DelegatedEvent struct { @@ -259,8 +258,8 @@ func reorganizeIfNearby(alternatives []Alternative, distances []float64, thresho func DelegateJob(service *types.Service, event string, logger *log.Logger) error { //Block access before executing the function - mutex.Lock() - defer mutex.Unlock() + //mutex.Lock() + //defer mutex.Unlock() //Determine priority level of each replica to delegate if service.Delegation == "topsis" { @@ -441,7 +440,9 @@ func DelegateJob(service *types.Service, event string, logger *log.Logger) error storage_provider := service.ClusterID //Create event depending on delegation level + fmt.Println("Storage_provider : ", storage_provider) eventJSON := eventBuild(event, storage_provider) + fmt.Println(string(eventJSON)) for _, replica := range service.Replicas { // Manage if replica.Type is "oscar" and have the capacity to receive a service @@ -471,7 +472,7 @@ func DelegateJob(service *types.Service, event string, logger *log.Logger) error postJobURL.Path = path.Join(postJobURL.Path, "job", replica.ServiceName) // Make request to get service's definition (including token) from cluster - fmt.Println(string(eventJSON)) + //fmt.Println(string(eventJSON)) req, err := http.NewRequest(http.MethodPost, postJobURL.String(), bytes.NewBuffer(eventJSON)) if err != nil {