1 Commits
+4 -4
View File
@@ -64,10 +64,10 @@ func (r *Recorder) record(ctx context.Context) {
case <-ctx.Done(): case <-ctx.Done():
return return
case data := <-r.recorderCh: case data := <-r.recorderCh:
r.mut.RLock() r.mut.Lock()
err := binary.Write(r.OutputFile, binary.LittleEndian, data) err := binary.Write(r.OutputFile, binary.LittleEndian, r.SDK.Data)
r.TotalBytes += len(data) r.TotalBytes += len(data)
r.mut.RUnlock() r.mut.Unlock()
if err != nil { if err != nil {
// NOTE: find a way of logging this somehow // NOTE: find a way of logging this somehow
@@ -129,7 +129,7 @@ func (r *Recorder) Record(ctx context.Context) error {
// Dropped the frame! // Dropped the frame!
} }
// Send the data to the UDP socket // Write the data to the file
select { select {
case r.recorderCh <- r.SDK.Buffer: case r.recorderCh <- r.SDK.Buffer:
// Sent the data // Sent the data