Skip to content

Commit b02a4bc

Browse files
author
Mikhail Faraponov
committed
Fixed issue with .bad files
1 parent 8df41d2 commit b02a4bc

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

diskqueue_test.go

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -821,7 +821,6 @@ func numberOfBadFiles(diskQueueName string, dataPath string) int64 {
821821

822822
func TestDiskSizeImplementationWithBadFiles(t *testing.T) {
823823
// write three files
824-
t.SkipNow()
825824

826825
l := NewTestLogger(t)
827826
dqName := "test_disk_queue_implementation_with_bad_files" + strconv.Itoa(int(time.Now().Unix()))
@@ -956,7 +955,7 @@ readCorruptedFile:
956955
<-dq.ReadChan()
957956

958957
// wait for DiskQueue to notice that file 2 is corrupted
959-
time.Sleep(20 * time.Millisecond)
958+
time.Sleep(1 * time.Second)
960959

961960
// check if the file was converted into a .bad file
962961
badFilesCount = numberOfBadFiles(dqName, tmpDir)

0 commit comments

Comments
 (0)