fix network mode

PlakarKorp · Oct 16, 2023 · 3acf166 · 3acf166
1 parent 0d36bb1
commit 3acf166
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/storage/client/client.go b/storage/client/client.go
@@ -379,14 +379,13 @@ func (repository *ClientRepository) PutMetadata(indexID uuid.UUID, data []byte)
 }
 
 func (repository *ClientRepository) PutBlob(checksum [32]byte, data []byte) error {
-	result, err := repository.sendRequest("ReqStorePutIndex", network.ReqStorePutBlob{
+	result, err := repository.sendRequest("ReqStorePutBlob", network.ReqStorePutBlob{
 		Checksum: checksum,
 		Data:     data,
 	})
 	if err != nil {
 		return err
 	}
-
 	return result.Payload.(network.ResStorePutBlob).Err
 }
 

diff --git a/storage/storage.go b/storage/storage.go
@@ -232,6 +232,7 @@ func (repository *Repository) wLock() {
 }
 func (repository *Repository) wUnlock() {
 	<-repository.wChan
+	logger.Trace("storage", "wUnlock -> %d", len(repository.wChan))
 	// <-repository.maxParallelism
 }
 
@@ -246,6 +247,7 @@ func (repository *Repository) rLock() {
 }
 func (repository *Repository) rUnlock() {
 	<-repository.rChan
+	logger.Trace("storage", "rUnlock -> %d", len(repository.rChan))
 	// <-repository.maxParallelism
 }
 
@@ -260,6 +262,7 @@ func (repository *Repository) sLock() {
 }
 func (repository *Repository) sUnlock() {
 	<-repository.sChan
+	logger.Trace("storage", "sUnlock -> %d", len(repository.sChan))
 	// <-repository.maxParallelism
 }