| #include "stdio_impl.h" |
| #include "pthread_impl.h" |
| #include <limits.h> |
| |
| void __do_orphaned_stdio_locks() |
| { |
| FILE *f; |
| for (f=__pthread_self()->stdio_locks; f; f=f->next_locked) |
| a_store(&f->lock, 0x40000000); |
| } |
| |
| void __unlist_locked_file(FILE *f) |
| { |
| if (f->lockcount) { |
| if (f->next_locked) f->next_locked->prev_locked = f->prev_locked; |
| if (f->prev_locked) f->prev_locked->next_locked = f->next_locked; |
| else __pthread_self()->stdio_locks = f->next_locked; |
| } |
| } |
| |
| int ftrylockfile(FILE *f) |
| { |
| pthread_t self = __pthread_self(); |
| int tid = self->tid; |
| if (f->lock == tid) { |
| if (f->lockcount == LONG_MAX) |
| return -1; |
| f->lockcount++; |
| return 0; |
| } |
| if (f->lock < 0) f->lock = 0; |
| if (f->lock || a_cas(&f->lock, 0, tid)) |
| return -1; |
| f->lockcount = 1; |
| f->prev_locked = 0; |
| f->next_locked = self->stdio_locks; |
| if (f->next_locked) f->next_locked->prev_locked = f; |
| self->stdio_locks = f; |
| return 0; |
| } |