Function TestNewFileWriter_LargeFile

internal/utils/bfs/file_writer_test.go:60–105

(t *testing.T)

}

func TestNewFileWriter_LargeFile(t *testing.T) {
	bFile, err := bfs.OpenBlocksFile("testdata/test.b", bfs.DefaultBlockFileOptions)
	if err != nil {
		t.Fatal(err)
	}

	defer func() {
		if !testutils.IsSingleTesting() {
			_ = bFile.RemoveAll()
		} else {
			_ = bFile.Close()
		}
	}()

	writer, err := bFile.OpenFileWriter(bfs.Hash("123456@LARGE"), -1, false)
	if err != nil {
		t.Fatal(err)
	}

	err = writer.WriteMeta(http.StatusOK, fasttime.Now().Unix()+86400, -1)
	if err != nil {
		t.Fatal(err)
	}

	var countBlocks = 1 << 10
	if !testutils.IsSingleTesting() {
		countBlocks = 2
	}

	var data = bytes.Repeat([]byte{'A'}, 16<<10)

	var before = time.Now()
	for i := 0; i < countBlocks; i++ {
		_, err = writer.WriteBody(data)
		if err != nil {
			t.Fatal(err)
		}
	}

	err = writer.Close()
	if err != nil {
		t.Fatal(err)
	}

	logs.Println("cost:", time.Since(before).Seconds()*1000, "ms")
}

func TestFileWriter_WriteBodyAt(t *testing.T) {
	bFile, err := bfs.OpenBlocksFile("testdata/test.b", bfs.DefaultBlockFileOptions)