Mercurial > hg > audiodb
annotate lock.cpp @ 755:37c2b9cce23a multiprobeLSH
Adding mkc_lsh_update branch, trunk candidate with improved LSH: merged trunk 1095 and branch multiprobe_lsh
author | mas01mc |
---|---|
date | Thu, 25 Nov 2010 13:42:40 +0000 |
parents | cc2b97d020b1 |
children | 4eedc18634f5 |
rev | line source |
---|---|
mas01cr@509 | 1 extern "C" { |
mas01cr@509 | 2 #include "audioDB_API.h" |
mas01cr@509 | 3 } |
mas01cr@509 | 4 #include "audioDB-internals.h" |
mas01cr@498 | 5 |
mas01cr@498 | 6 int acquire_lock(int fd, bool exclusive) { |
mas01cr@498 | 7 struct flock lock; |
mas01cr@498 | 8 int status; |
mas01cr@498 | 9 |
mas01cr@498 | 10 lock.l_type = exclusive ? F_WRLCK : F_RDLCK; |
mas01cr@498 | 11 lock.l_whence = SEEK_SET; |
mas01cr@498 | 12 lock.l_start = 0; |
mas01cr@498 | 13 lock.l_len = 0; /* "the whole file" */ |
mas01cr@498 | 14 |
mas01cr@498 | 15 retry: |
mas01cr@498 | 16 do { |
mas01cr@498 | 17 status = fcntl(fd, F_SETLKW, &lock); |
mas01cr@498 | 18 } while (status != 0 && errno == EINTR); |
mas01cr@498 | 19 |
mas01cr@498 | 20 if (status) { |
mas01cr@498 | 21 if (errno == EAGAIN) { |
mas01cr@498 | 22 sleep(1); |
mas01cr@498 | 23 goto retry; |
mas01cr@498 | 24 } else { |
mas01cr@498 | 25 return status; |
mas01cr@498 | 26 } |
mas01cr@498 | 27 } |
mas01cr@498 | 28 return 0; |
mas01cr@498 | 29 } |
mas01cr@498 | 30 |
mas01cr@498 | 31 int divest_lock(int fd) { |
mas01cr@498 | 32 struct flock lock; |
mas01cr@498 | 33 |
mas01cr@498 | 34 lock.l_type = F_UNLCK; |
mas01cr@498 | 35 lock.l_whence = SEEK_SET; |
mas01cr@498 | 36 lock.l_start = 0; |
mas01cr@498 | 37 lock.l_len = 0; |
mas01cr@498 | 38 |
mas01cr@498 | 39 return fcntl(fd, F_SETLKW, &lock); |
mas01cr@498 | 40 } |