2020-12-22 03:54:55 +05:30
|
|
|
package race
|
2020-10-19 02:57:30 +02:00
|
|
|
|
|
|
|
|
import (
|
|
|
|
|
"fmt"
|
|
|
|
|
"io"
|
|
|
|
|
"time"
|
|
|
|
|
)
|
|
|
|
|
|
2020-12-26 14:55:15 +05:30
|
|
|
// SyncedReadCloser is compatible with io.ReadSeeker and performs
|
2020-12-22 03:54:55 +05:30
|
|
|
// gate-based synced writes to enable race condition testing.
|
2020-12-26 14:55:15 +05:30
|
|
|
type SyncedReadCloser struct {
|
2020-10-19 02:57:30 +02:00
|
|
|
data []byte
|
|
|
|
|
p int64
|
|
|
|
|
length int64
|
2021-11-25 18:54:16 +02:00
|
|
|
openGate chan struct{}
|
2020-10-19 02:57:30 +02:00
|
|
|
enableBlocking bool
|
|
|
|
|
}
|
|
|
|
|
|
2020-12-26 14:55:15 +05:30
|
|
|
// NewSyncedReadCloser creates a new SyncedReadCloser instance.
|
|
|
|
|
func NewSyncedReadCloser(r io.ReadCloser) *SyncedReadCloser {
|
2020-10-19 02:57:30 +02:00
|
|
|
var (
|
2020-12-26 14:55:15 +05:30
|
|
|
s SyncedReadCloser
|
2020-10-19 02:57:30 +02:00
|
|
|
err error
|
|
|
|
|
)
|
2022-02-23 13:54:46 +01:00
|
|
|
s.data, err = io.ReadAll(r)
|
2020-10-19 02:57:30 +02:00
|
|
|
if err != nil {
|
|
|
|
|
return nil
|
|
|
|
|
}
|
2025-07-09 14:47:26 -05:00
|
|
|
defer func() {
|
|
|
|
|
_ = r.Close()
|
|
|
|
|
}()
|
2020-10-19 02:57:30 +02:00
|
|
|
s.length = int64(len(s.data))
|
2021-11-25 18:54:16 +02:00
|
|
|
s.openGate = make(chan struct{})
|
2020-10-19 02:57:30 +02:00
|
|
|
s.enableBlocking = true
|
|
|
|
|
return &s
|
|
|
|
|
}
|
|
|
|
|
|
2020-12-26 14:55:15 +05:30
|
|
|
// NewOpenGateWithTimeout creates a new open gate with a timeout
|
|
|
|
|
func NewOpenGateWithTimeout(r io.ReadCloser, d time.Duration) *SyncedReadCloser {
|
|
|
|
|
s := NewSyncedReadCloser(r)
|
2020-10-19 02:57:30 +02:00
|
|
|
s.OpenGateAfter(d)
|
|
|
|
|
return s
|
|
|
|
|
}
|
|
|
|
|
|
2020-12-26 14:55:15 +05:30
|
|
|
// SetOpenGate sets the status of the blocking gate
|
|
|
|
|
func (s *SyncedReadCloser) SetOpenGate(status bool) {
|
2020-10-19 02:57:30 +02:00
|
|
|
s.enableBlocking = status
|
|
|
|
|
}
|
|
|
|
|
|
2020-12-26 14:55:15 +05:30
|
|
|
// OpenGate opens the gate allowing all requests to be completed
|
|
|
|
|
func (s *SyncedReadCloser) OpenGate() {
|
2021-11-25 18:54:16 +02:00
|
|
|
s.openGate <- struct{}{}
|
2020-10-19 02:57:30 +02:00
|
|
|
}
|
|
|
|
|
|
2020-12-26 14:55:15 +05:30
|
|
|
// OpenGateAfter schedules gate to be opened after a duration
|
|
|
|
|
func (s *SyncedReadCloser) OpenGateAfter(d time.Duration) {
|
2020-10-19 02:57:30 +02:00
|
|
|
time.AfterFunc(d, func() {
|
2021-11-25 18:54:16 +02:00
|
|
|
s.openGate <- struct{}{}
|
2020-10-19 02:57:30 +02:00
|
|
|
})
|
|
|
|
|
}
|
|
|
|
|
|
2020-12-26 14:55:15 +05:30
|
|
|
// Seek implements seek method for io.ReadSeeker
|
|
|
|
|
func (s *SyncedReadCloser) Seek(offset int64, whence int) (int64, error) {
|
2020-10-19 02:57:30 +02:00
|
|
|
var err error
|
|
|
|
|
switch whence {
|
|
|
|
|
case io.SeekStart:
|
|
|
|
|
s.p = 0
|
|
|
|
|
case io.SeekCurrent:
|
|
|
|
|
if s.p+offset < s.length {
|
|
|
|
|
s.p += offset
|
|
|
|
|
break
|
|
|
|
|
}
|
|
|
|
|
err = fmt.Errorf("offset is too big")
|
|
|
|
|
case io.SeekEnd:
|
|
|
|
|
if s.length-offset >= 0 {
|
|
|
|
|
s.p = s.length - offset
|
|
|
|
|
break
|
|
|
|
|
}
|
|
|
|
|
err = fmt.Errorf("offset is too big")
|
|
|
|
|
}
|
|
|
|
|
return s.p, err
|
|
|
|
|
}
|
|
|
|
|
|
2020-12-26 14:55:15 +05:30
|
|
|
// Read implements read method for io.ReadSeeker
|
|
|
|
|
func (s *SyncedReadCloser) Read(p []byte) (n int, err error) {
|
2020-10-19 02:57:30 +02:00
|
|
|
// If the data fits in the buffer blocks awaiting the sync instruction
|
|
|
|
|
if s.p+int64(len(p)) >= s.length && s.enableBlocking {
|
2021-11-25 18:54:16 +02:00
|
|
|
<-s.openGate
|
2020-10-19 02:57:30 +02:00
|
|
|
}
|
|
|
|
|
n = copy(p, s.data[s.p:])
|
|
|
|
|
s.p += int64(n)
|
|
|
|
|
if s.p == s.length {
|
|
|
|
|
err = io.EOF
|
|
|
|
|
}
|
|
|
|
|
return n, err
|
|
|
|
|
}
|
|
|
|
|
|
2021-11-25 18:54:16 +02:00
|
|
|
// Close closes an io.ReadSeeker
|
2020-12-26 14:55:15 +05:30
|
|
|
func (s *SyncedReadCloser) Close() error {
|
2020-10-19 02:57:30 +02:00
|
|
|
return nil
|
|
|
|
|
}
|
|
|
|
|
|
2020-12-26 14:55:15 +05:30
|
|
|
// Len returns the length of data in reader
|
|
|
|
|
func (s *SyncedReadCloser) Len() int {
|
2020-10-19 02:57:30 +02:00
|
|
|
return int(s.length)
|
|
|
|
|
}
|