logos-storage/logos-storage-go-bindings
1
0
Fork 0
mirror of https://github.com/logos-storage/logos-storage-go-bindings.git synced 2026-01-02 13:33:10 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add cancellation test

Browse Source
This commit is contained in:
Arnaud 2025-10-17 13:18:53 +02:00
parent 43e6e5e81f
commit fca7f76ac1
No known key found for this signature in database
GPG Key ID: 20E40A5D3110766F
1 changed files with 3 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
codex/upload_test.go
View File

@ -45,7 +45,6 @@ func TestUploadReader(t *testing.T) {
func TestUploadReaderCancel(t *testing.T) {
ctx, cancel := context.WithCancel(context.Background())
defer cancel()
codex := newCodexNode(t)
buf := bytes.NewBuffer(make([]byte, 1024*1024*10))
@ -107,10 +106,8 @@ func TestUploadFile(t *testing.T) {
func TestUploadFileCancel(t *testing.T) {
ctx, cancel := context.WithCancel(context.Background())
defer cancel()
// create a tmp file with large content
tmpFile, err := os.Create("./testdata/large_file.txt")
tmpFile, err := os.Create(os.TempDir() + "/large_file.txt")
if err != nil {
t.Fatalf("Failed to create temp file: %v", err)
}
@ -126,8 +123,8 @@ func TestUploadFileCancel(t *testing.T) {
channelError := make(chan error, 1)
go func() {
_, e := codex.UploadFile(ctx, UploadOptions{Filepath: tmpFile.Name()})
channelError <- e
_, err := codex.UploadFile(ctx, UploadOptions{Filepath: tmpFile.Name()})
channelError <- err
}()
cancel()