(self, wait)
| 233 | return filedescriptor |
| 234 | |
| 235 | def do_acquire_read_lock(self, wait): |
| 236 | filedescriptor = self._open(os.O_CREAT | os.O_RDONLY) |
| 237 | if not wait: |
| 238 | try: |
| 239 | fcntl.flock(filedescriptor, fcntl.LOCK_SH | fcntl.LOCK_NB) |
| 240 | return True |
| 241 | except IOError: |
| 242 | os.close(filedescriptor) |
| 243 | self._filedescriptor.remove() |
| 244 | return False |
| 245 | else: |
| 246 | fcntl.flock(filedescriptor, fcntl.LOCK_SH) |
| 247 | return True |
| 248 | |
| 249 | def do_acquire_write_lock(self, wait): |
| 250 | filedescriptor = self._open(os.O_CREAT | os.O_WRONLY) |