Fix typo

anyproto · Dec 4, 2023 · be4ee9b · be4ee9b
1 parent a218667
commit be4ee9b
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 5 deletions.
diff --git a/commonspace/requestmanager/requestmanager.go b/commonspace/requestmanager/requestmanager.go
@@ -120,7 +120,7 @@ func (r *requestManager) QueueRequest(peerId string, req *spacesyncproto.ObjectS
 	defer r.Unlock()
 	pl, exists := r.pools[peerId]
 	if !exists {
-		pl = тewRequestPool(r.workers, r.queueSize)
+		pl = newRequestPool(r.workers, r.queueSize)
 		r.pools[peerId] = pl
 		pl.Run()
 	}

diff --git a/commonspace/requestmanager/requestpool.go b/commonspace/requestmanager/requestpool.go
@@ -8,10 +8,10 @@ import (
 	"go.uber.org/zap"
 )
 
-// тewRequestPool creates new requestPool
+// newRequestPool creates new requestPool
 // workers - how many processes will execute tasks
 // maxSize - limit for queue size
-func тewRequestPool(workers, maxSize int) *requestPool {
+func newRequestPool(workers, maxSize int) *requestPool {
 	ctx, cancel := context.WithCancel(context.Background())
 	ss := &requestPool{
 		ctx:     ctx,

diff --git a/commonspace/requestmanager/requestpool_test.go b/commonspace/requestmanager/requestpool_test.go
@@ -16,7 +16,7 @@ func TestRequestPool_Add(t *testing.T) {
 		setBlock := func() {
 			<-ch
 		}
-		rp := тewRequestPool(2, 2)
+		rp := newRequestPool(2, 2)
 		err := rp.TryAdd("1", setBlock)
 		require.NoError(t, err)
 		err = rp.TryAdd("2", setBlock)
@@ -46,7 +46,7 @@ func TestRequestPool_Add(t *testing.T) {
 		firstVal := atomic.Int32{}
 		secondVal := atomic.Int32{}
 		thirdVal := atomic.Int32{}
-		rp := тewRequestPool(2, 2)
+		rp := newRequestPool(2, 2)
 		err := rp.TryAdd("1", func() {
 			firstVal.Store(1)
 		})