Commit5cf9b25

committed

yeah yeah fine

1 parentcb6ff4a commit5cf9b25Copy full SHA for 5cf9b25

File tree

+18

-5

lines changed

+18

-5

lines changed

Lines changed: 10 additions & 4 deletions

Original file line number	Diff line number	Diff line change
`@@ -8,12 +8,16 @@ import (`
`8`	`8`	`"testing"`
`9`	`9`	`"time"`
`10`	`10`
`11`		`-"github.com/coder/coder/v2/testutil"`
`12`	`11`	`"github.com/google/uuid"`
	`12`	`+"github.com/spf13/afero"`
`13`	`13`	`"github.com/stretchr/testify/require"`
`14`	`14`	`"golang.org/x/sync/errgroup"`
	`15`	`+`
	`16`	`+"github.com/coder/coder/v2/testutil"`
`15`	`17`	`)`
`16`	`18`
	`19`	`+varemptyFS fs.FS=afero.NewIOFS(afero.NewMemMapFs())`
	`20`	`+`
`17`	`21`	`funcTestConcurrency(t*testing.T) {`
`18`	`22`	`t.Parallel()`
`19`	`23`
`@@ -23,7 +27,7 @@ func TestConcurrency(t *testing.T) {`
`23`	`27`	`// Wait long enough before returning to make sure that all of the goroutines`
`24`	`28`	`// will be waiting in line, ensuring that no one duplicated a fetch.`
`25`	`29`	`time.Sleep(testutil.IntervalMedium)`
`26`		`-returnnil,nil`
	`30`	`+returnemptyFS,nil`
`27`	`31`	`})`
`28`	`32`
`29`	`33`	`batches:=1000`
`@@ -56,7 +60,7 @@ func TestRelease(t *testing.T) {`
`56`	`60`	`t.Parallel()`
`57`	`61`
`58`	`62`	`c:=newTestCache(func(_ context.Context,_ uuid.UUID) (fs.FS,error) {`
`59`		`-returnnil,nil`
	`63`	`+returnemptyFS,nil`
`60`	`64`	`})`
`61`	`65`
`62`	`66`	`batches:=100`
`@@ -69,7 +73,9 @@ func TestRelease(t *testing.T) {`
`69`	`73`	`batchSize:=10`
`70`	`74`	`for_,id:=rangeids {`
`71`	`75`	`forrangebatchSize {`
`72`		`-c.Acquire(t.Context(),id)`
	`76`	`+fs,err:=c.Acquire(t.Context(),id)`
	`77`	`+require.NoError(t,err)`
	`78`	`+require.Equal(t,emptyFS,fs)`
`73`	`79`	`}`
`74`	`80`	`}`
`75`	`81`

Lines changed: 8 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -3,12 +3,15 @@ package lazy_test`
`3`	`3`	`import (`
`4`	`4`	`"testing"`
`5`	`5`
`6`		`-"github.com/coder/coder/v2/coderd/util/lazy"`
`7`	`6`	`"github.com/stretchr/testify/require"`
`8`	`7`	`"golang.org/x/xerrors"`
	`8`	`+`
	`9`	`+"github.com/coder/coder/v2/coderd/util/lazy"`
`9`	`10`	`)`
`10`	`11`
`11`	`12`	`funcTestLazyWithErrorOK(t*testing.T) {`
	`13`	`+t.Parallel()`
	`14`	`+`
`12`	`15`	`l:=lazy.NewWithError(func() (int,error) {`
`13`	`16`	`return1,nil`
`14`	`17`	`})`
`@@ -19,6 +22,8 @@ func TestLazyWithErrorOK(t *testing.T) {`
`19`	`22`	`}`
`20`	`23`
`21`	`24`	`funcTestLazyWithErrorErr(t*testing.T) {`
	`25`	`+t.Parallel()`
	`26`	`+`
`22`	`27`	`l:=lazy.NewWithError(func() (int,error) {`
`23`	`28`	`return0,xerrors.New("oh no! everything that could went horribly wrong!")`
`24`	`29`	`})`
`@@ -29,6 +34,8 @@ func TestLazyWithErrorErr(t *testing.T) {`
`29`	`34`	`}`
`30`	`35`
`31`	`36`	`funcTestLazyWithErrorPointers(t*testing.T) {`
	`37`	`+t.Parallel()`
	`38`	`+`
`32`	`39`	`a:=1`
`33`	`40`	`l:=lazy.NewWithError(func() (*int,error) {`
`34`	`41`	`return&a,nil`

Comments

(0)