...
1
2
3
4
5
6
7 package socket
8
9 import (
10 "runtime"
11 "unsafe"
12 )
13
14
15
16
17
18 func (m *Message) raceRead() {
19 for _, b := range m.Buffers {
20 if len(b) > 0 {
21 runtime.RaceReadRange(unsafe.Pointer(&b[0]), len(b))
22 }
23 }
24 if b := m.OOB; len(b) > 0 {
25 runtime.RaceReadRange(unsafe.Pointer(&b[0]), len(b))
26 }
27 }
28 func (m *Message) raceWrite() {
29 for _, b := range m.Buffers {
30 if len(b) > 0 {
31 runtime.RaceWriteRange(unsafe.Pointer(&b[0]), len(b))
32 }
33 }
34 if b := m.OOB; len(b) > 0 {
35 runtime.RaceWriteRange(unsafe.Pointer(&b[0]), len(b))
36 }
37 }
38
View as plain text