tsan/rtl/tsan_fd.cpp

49 static FdSync *allocsync(ThreadState *thr, uptr pc) {
50   FdSync *s = (FdSync*)user_alloc_internal(thr, pc, sizeof(FdSync),
62 static void unref(ThreadState *thr, uptr pc, FdSync *s) {
68       user_free(thr, pc, s, false);
73 static FdDesc *fddesc(ThreadState *thr, uptr pc, int fd) {
81     void *p = user_alloc_internal(thr, pc, size, kDefaultAlignment, false);
83     MemoryResetRange(thr, (uptr)&fddesc, (uptr)p, size);
87       user_free(thr, pc, p, false);
94 static void init(ThreadState *thr, uptr pc, int fd, FdSync *s,
96   FdDesc *d = fddesc(thr, pc, fd);
100     unref(thr, pc, d->sync);
104     unref(thr, pc, s);
108     unref(thr, pc, s);
111   d->creation_tid = thr->tid;
112   d->creation_stack = CurrentStackId(thr, pc);
115     MemoryRangeImitateWrite(thr, pc, (uptr)d, 8);
118     MemoryRead(thr, pc, (uptr)d, kSizeLog8);
128 void FdOnFork(ThreadState *thr, uptr pc) {
138       MemoryResetRange(thr, pc, (uptr)d, 8);
160 void FdAcquire(ThreadState *thr, uptr pc, int fd) {
163   FdDesc *d = fddesc(thr, pc, fd);
165   DPrintf("#%d: FdAcquire(%d) -> %p\n", thr->tid, fd, s);
166   MemoryRead(thr, pc, (uptr)d, kSizeLog8);
168     Acquire(thr, pc, (uptr)s);
171 void FdRelease(ThreadState *thr, uptr pc, int fd) {
174   FdDesc *d = fddesc(thr, pc, fd);
176   DPrintf("#%d: FdRelease(%d) -> %p\n", thr->tid, fd, s);
177   MemoryRead(thr, pc, (uptr)d, kSizeLog8);
179     Release(thr, pc, (uptr)s);
182 void FdAccess(ThreadState *thr, uptr pc, int fd) {
183   DPrintf("#%d: FdAccess(%d)\n", thr->tid, fd);
186   FdDesc *d = fddesc(thr, pc, fd);
187   MemoryRead(thr, pc, (uptr)d, kSizeLog8);
190 void FdClose(ThreadState *thr, uptr pc, int fd, bool write) {
191   DPrintf("#%d: FdClose(%d)\n", thr->tid, fd);
194   FdDesc *d = fddesc(thr, pc, fd);
197     MemoryWrite(thr, pc, (uptr)d, kSizeLog8);
207     MemoryRead(thr, pc, (uptr)d, kSizeLog8);
211   MemoryResetRange(thr, pc, (uptr)d, 8);
212   unref(thr, pc, d->sync);
218 void FdFileCreate(ThreadState *thr, uptr pc, int fd) {
219   DPrintf("#%d: FdFileCreate(%d)\n", thr->tid, fd);
222   init(thr, pc, fd, &fdctx.filesync);
225 void FdDup(ThreadState *thr, uptr pc, int oldfd, int newfd, bool write) {
226   DPrintf("#%d: FdDup(%d, %d)\n", thr->tid, oldfd, newfd);
230   FdDesc *od = fddesc(thr, pc, oldfd);
231   MemoryRead(thr, pc, (uptr)od, kSizeLog8);
232   FdClose(thr, pc, newfd, write);
233   init(thr, pc, newfd, ref(od->sync), write);
236 void FdPipeCreate(ThreadState *thr, uptr pc, int rfd, int wfd) {
237   DPrintf("#%d: FdCreatePipe(%d, %d)\n", thr->tid, rfd, wfd);
238   FdSync *s = allocsync(thr, pc);
239   init(thr, pc, rfd, ref(s));
240   init(thr, pc, wfd, ref(s));
241   unref(thr, pc, s);
244 void FdEventCreate(ThreadState *thr, uptr pc, int fd) {
245   DPrintf("#%d: FdEventCreate(%d)\n", thr->tid, fd);
248   init(thr, pc, fd, allocsync(thr, pc));
251 void FdSignalCreate(ThreadState *thr, uptr pc, int fd) {
252   DPrintf("#%d: FdSignalCreate(%d)\n", thr->tid, fd);
255   init(thr, pc, fd, 0);
258 void FdInotifyCreate(ThreadState *thr, uptr pc, int fd) {
259   DPrintf("#%d: FdInotifyCreate(%d)\n", thr->tid, fd);
262   init(thr, pc, fd, 0);
265 void FdPollCreate(ThreadState *thr, uptr pc, int fd) {
266   DPrintf("#%d: FdPollCreate(%d)\n", thr->tid, fd);
269   init(thr, pc, fd, allocsync(thr, pc));
272 void FdSocketCreate(ThreadState *thr, uptr pc, int fd) {
273   DPrintf("#%d: FdSocketCreate(%d)\n", thr->tid, fd);
277   init(thr, pc, fd, &fdctx.socksync);
280 void FdSocketAccept(ThreadState *thr, uptr pc, int fd, int newfd) {
281   DPrintf("#%d: FdSocketAccept(%d, %d)\n", thr->tid, fd, newfd);
285   Acquire(thr, pc, (uptr)&fdctx.connectsync);
286   init(thr, pc, newfd, &fdctx.socksync);
289 void FdSocketConnecting(ThreadState *thr, uptr pc, int fd) {
290   DPrintf("#%d: FdSocketConnecting(%d)\n", thr->tid, fd);
294   Release(thr, pc, (uptr)&fdctx.connectsync);
297 void FdSocketConnect(ThreadState *thr, uptr pc, int fd) {
298   DPrintf("#%d: FdSocketConnect(%d)\n", thr->tid, fd);
301   init(thr, pc, fd, &fdctx.socksync);