Skip to content

Commit dd27df9

Browse files
committed
fixes
1 parent d0f4c31 commit dd27df9

2 files changed

Lines changed: 1 addition & 4 deletions

File tree

protocol/logger/job_logger.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -354,7 +354,7 @@ func (logger *BufferedLiveLogger) SendLog(wrapper *protocol.TimelineRecordFeedLi
354354
}
355355
if logger.data.CompareAndSwap(data, &ndata) {
356356
go logger.sendLogs(ndata.logchan, ndata.logdrain, ndata.logfinished)
357-
return data.queueLog(wrapper)
357+
return ndata.queueLog(wrapper)
358358
} else {
359359
close(ndata.logchan)
360360
close(ndata.logfinished)

protocol/logger/job_logger_test.go

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,6 @@ package logger
33
import (
44
"fmt"
55
"testing"
6-
"time"
76

87
"github.com/ChristopherHX/github-act-runner/protocol"
98

@@ -103,15 +102,13 @@ func TestBufferedLiveLogger(t *testing.T) {
103102

104103
t.Run("close", func(t *testing.T) {
105104
t.Parallel()
106-
time.Sleep(1122 * time.Microsecond)
107105
require.NoError(t, bufferedLogger.Close())
108106
})
109107

110108
t.Run("sendLogs", func(t *testing.T) {
111109
t.Parallel()
112110
var err error
113111
for i := range 100 {
114-
time.Sleep(1 * time.Millisecond)
115112
err = bufferedLogger.SendLog(&protocol.TimelineRecordFeedLinesWrapper{
116113
Count: 1,
117114
Value: []string{fmt.Sprintf("line %v", (i + 1))},

0 commit comments

Comments
 (0)