We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 72c8dc1 commit da870b6Copy full SHA for da870b6
1 file changed
conn.go
@@ -9,6 +9,7 @@ import (
9
"os"
10
"os/exec"
11
"regexp"
12
+ "sync"
13
"time"
14
15
"golang.org/x/sync/errgroup"
@@ -151,14 +152,24 @@ func (c conn) waitWithTimeout() error {
151
152
}
153
154
type tailBuffer struct {
155
+ mu sync.Mutex
156
+
157
limit int
- bytes.Buffer
158
+ buff bytes.Buffer
159
160
161
func (b *tailBuffer) Write(p []byte) (n int, err error) {
- if len(p)+b.Buffer.Len() > b.limit {
- b.Reset()
162
+ b.mu.Lock()
163
+ defer b.mu.Unlock()
164
+ if len(p)+b.buff.Len() > b.limit {
165
+ b.buff.Reset()
166
- n, err = b.Buffer.Write(p)
167
+ n, err = b.buff.Write(p)
168
return
169
170
171
+func (b *tailBuffer) String() string {
172
173
174
+ return b.buff.String()
175
+}
0 commit comments