correct fn name in logs, cleanup

flowerinthenight · Jul 17, 2024 · ca2055e · ca2055e
1 parent 6132ea8
commit ca2055e
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 5 deletions.
diff --git a/service.go b/service.go
@@ -114,8 +114,6 @@ func (s *service) SoSWrite(hs pb.Hedge_SoSWriteServer) error {
 	ctx := hs.Context()
 	var writer *Writer
 
-	var count int
-
 loop:
 	for {
 		select {
@@ -154,7 +152,6 @@ loop:
 		}
 
 		writer.Write(in.Data)
-		count++
 	}
 
 	if writer != nil {

diff --git a/sos.go b/sos.go
@@ -183,7 +183,7 @@ func (w *Writer) start() {
 					w.sos.meta[node].client = pb.NewHedgeClient(w.sos.meta[node].conn)
 					w.sos.meta[node].writer, err = w.sos.meta[node].client.SoSWrite(ctx)
 					if err != nil {
-						return fmt.Errorf("DMemWrite (%v) failed: %w", nextName, err)
+						return fmt.Errorf("SoSWrite (%v) failed: %w", nextName, err)
 					}
 
 					w.sos.meta[node].grpc.Add(1)
@@ -357,7 +357,7 @@ func (r *Reader) Read(out chan []byte) {
 					r.sos.meta[node].reader, err = r.sos.meta[node].client.SoSRead(ctx)
 					if err != nil {
 						r.Lock()
-						r.err = fmt.Errorf("DMemRead failed: %v", err)
+						r.err = fmt.Errorf("SoSRead failed: %v", err)
 						r.Unlock()
 						return
 					}