File tree Expand file tree Collapse file tree 1 file changed +0
-7
lines changed Expand file tree Collapse file tree 1 file changed +0
-7
lines changed Original file line number Diff line number Diff line change 11package orderedbuffer
22
33import (
4- "fmt"
5- "os"
64 "sync"
75)
86
@@ -14,7 +12,6 @@ type OrderedBuffer[T any] struct {
1412}
1513
1614func NewOrderedBuffer [T any ](ch chan T ) * OrderedBuffer [T ] {
17- fmt .Fprintln (os .Stderr , "Creating new ResponsesStore" )
1815 var mu sync.RWMutex
1916 return & OrderedBuffer [T ]{
2017 responses : make (map [int ]T ),
@@ -27,23 +24,19 @@ func NewOrderedBuffer[T any](ch chan T) *OrderedBuffer[T] {
2724func (s * OrderedBuffer [T ]) send () {
2825 s .mu .Lock ()
2926 newIdx := s .lastSentIdx + 1
30- fmt .Fprintln (os .Stderr , "Checking for page" , newIdx )
3127 if resp , ok := s .responses [newIdx ]; ok {
32- fmt .Fprintln (os .Stderr , "Sending page" , newIdx )
3328 s .ch <- resp
3429 s .lastSentIdx = newIdx
3530 delete (s .responses , newIdx )
3631 s .mu .Unlock ()
3732 s .send ()
3833 return
3934 } else {
40- fmt .Fprintln (os .Stderr , "Page" , newIdx , "not ready yet" )
4135 }
4236 s .mu .Unlock ()
4337}
4438
4539func (s * OrderedBuffer [T ]) Store (i int , r T ) {
46- fmt .Fprintf (os .Stderr , "Storing page %d\n " , i )
4740 s .mu .Lock ()
4841 s .responses [i ] = r
4942 s .mu .Unlock ()
You can’t perform that action at this time.
0 commit comments