Lines Matching refs:thr
50 static FdSync *allocsync(ThreadState *thr, uptr pc) {
51 FdSync *s = (FdSync*)user_alloc(thr, pc, sizeof(FdSync));
62 static void unref(ThreadState *thr, uptr pc, FdSync *s) {
68 user_free(thr, pc, s);
73 static FdDesc *fddesc(ThreadState *thr, uptr pc, int fd) {
81 void *p = user_alloc(thr, pc, size);
83 MemoryResetRange(thr, (uptr)&fddesc, (uptr)p, size);
87 user_free(thr, pc, p);
93 static void init(ThreadState *thr, uptr pc, int fd, FdSync *s) {
94 FdDesc *d = fddesc(thr, pc, fd);
98 unref(thr, pc, d->sync);
102 unref(thr, pc, s);
106 unref(thr, pc, s);
109 d->creation_tid = thr->tid;
110 d->creation_stack = CurrentStackId(thr, pc);
112 MemoryRangeImitateWrite(thr, pc, (uptr)d, 8);
121 void FdOnFork(ThreadState *thr, uptr pc) {
131 MemoryResetRange(thr, pc, (uptr)d, 8);
153 void FdAcquire(ThreadState *thr, uptr pc, int fd) {
156 FdDesc *d = fddesc(thr, pc, fd);
158 DPrintf("#%d: FdAcquire(%d) -> %p\n", thr->tid, fd, s);
159 MemoryRead(thr, pc, (uptr)d, kSizeLog8);
161 Acquire(thr, pc, (uptr)s);
164 void FdRelease(ThreadState *thr, uptr pc, int fd) {
167 FdDesc *d = fddesc(thr, pc, fd);
169 DPrintf("#%d: FdRelease(%d) -> %p\n", thr->tid, fd, s);
170 MemoryRead(thr, pc, (uptr)d, kSizeLog8);
172 Release(thr, pc, (uptr)s);
175 void FdAccess(ThreadState *thr, uptr pc, int fd) {
176 DPrintf("#%d: FdAccess(%d)\n", thr->tid, fd);
179 FdDesc *d = fddesc(thr, pc, fd);
180 MemoryRead(thr, pc, (uptr)d, kSizeLog8);
183 void FdClose(ThreadState *thr, uptr pc, int fd) {
184 DPrintf("#%d: FdClose(%d)\n", thr->tid, fd);
187 FdDesc *d = fddesc(thr, pc, fd);
189 MemoryWrite(thr, pc, (uptr)d, kSizeLog8);
192 MemoryResetRange(thr, pc, (uptr)d, 8);
193 unref(thr, pc, d->sync);
199 void FdFileCreate(ThreadState *thr, uptr pc, int fd) {
200 DPrintf("#%d: FdFileCreate(%d)\n", thr->tid, fd);
203 init(thr, pc, fd, &fdctx.filesync);
206 void FdDup(ThreadState *thr, uptr pc, int oldfd, int newfd) {
207 DPrintf("#%d: FdDup(%d, %d)\n", thr->tid, oldfd, newfd);
211 FdDesc *od = fddesc(thr, pc, oldfd);
212 MemoryRead(thr, pc, (uptr)od, kSizeLog8);
213 FdClose(thr, pc, newfd);
214 init(thr, pc, newfd, ref(od->sync));
217 void FdPipeCreate(ThreadState *thr, uptr pc, int rfd, int wfd) {
218 DPrintf("#%d: FdCreatePipe(%d, %d)\n", thr->tid, rfd, wfd);
219 FdSync *s = allocsync(thr, pc);
220 init(thr, pc, rfd, ref(s));
221 init(thr, pc, wfd, ref(s));
222 unref(thr, pc, s);
225 void FdEventCreate(ThreadState *thr, uptr pc, int fd) {
226 DPrintf("#%d: FdEventCreate(%d)\n", thr->tid, fd);
229 init(thr, pc, fd, allocsync(thr, pc));
232 void FdSignalCreate(ThreadState *thr, uptr pc, int fd) {
233 DPrintf("#%d: FdSignalCreate(%d)\n", thr->tid, fd);
236 init(thr, pc, fd, 0);
239 void FdInotifyCreate(ThreadState *thr, uptr pc, int fd) {
240 DPrintf("#%d: FdInotifyCreate(%d)\n", thr->tid, fd);
243 init(thr, pc, fd, 0);
246 void FdPollCreate(ThreadState *thr, uptr pc, int fd) {
247 DPrintf("#%d: FdPollCreate(%d)\n", thr->tid, fd);
250 init(thr, pc, fd, allocsync(thr, pc));
253 void FdSocketCreate(ThreadState *thr, uptr pc, int fd) {
254 DPrintf("#%d: FdSocketCreate(%d)\n", thr->tid, fd);
258 init(thr, pc, fd, &fdctx.socksync);
261 void FdSocketAccept(ThreadState *thr, uptr pc, int fd, int newfd) {
262 DPrintf("#%d: FdSocketAccept(%d, %d)\n", thr->tid, fd, newfd);
266 Acquire(thr, pc, (uptr)&fdctx.connectsync);
267 init(thr, pc, newfd, &fdctx.socksync);
270 void FdSocketConnecting(ThreadState *thr, uptr pc, int fd) {
271 DPrintf("#%d: FdSocketConnecting(%d)\n", thr->tid, fd);
275 Release(thr, pc, (uptr)&fdctx.connectsync);
278 void FdSocketConnect(ThreadState *thr, uptr pc, int fd) {
279 DPrintf("#%d: FdSocketConnect(%d)\n", thr->tid, fd);
282 init(thr, pc, fd, &fdctx.socksync);
