Lines Matching refs:a_fd

180 static FINDLOCK_T	lock_acquire(LOCK_T *a_lock, int *a_fd, char *a_root,
184 static int lock_release(int a_fd, char *a_key, char *a_object,
186 static int lock_status(int a_fd, char *a_key, char *a_object,
193 int a_fd, char *a_object, char *a_key);
194 static int _decrementLockCount(int a_fd, LOCK_T *a_theLock);
195 static int _addLock(char *r_key, int a_fd, char *a_object,
197 static int _incrementLockCount(int a_fd, LOCK_T *a_theLock);
198 static FINDLOCK_T _lock_acquire(LOCK_T *a_lock, int a_fd, char *a_key,
205 static boolean_t _validateLock(int a_fd, LOCK_T *a_theLock, int a_quiet);
618 lock_acquire(LOCK_T *a_theLock, int *a_fd, char *a_root, char *a_key, in lock_acquire() argument
633 if ((*a_fd) < 0) { in lock_acquire()
634 (*a_fd) = _openLockFile(a_altRoot); in lock_acquire()
635 if ((*a_fd) < 0) { in lock_acquire()
650 result = _lock_acquire(a_theLock, *a_fd, a_key, a_object, in lock_acquire()
661 (void) close(*a_fd); in lock_acquire()
662 *a_fd = -1; in lock_acquire()
676 (void) close(*a_fd); in lock_acquire()
677 *a_fd = -1; in lock_acquire()
707 (void) close(*a_fd); in lock_acquire()
708 *a_fd = -1; in lock_acquire()
728 (void) close(*a_fd); in lock_acquire()
729 *a_fd = -1; in lock_acquire()
755 (void) close(*a_fd); in lock_acquire()
763 *a_fd = _openLockFile(a_root); in lock_acquire()
764 if (*a_fd < 0) { in lock_acquire()
771 (void) close(*a_fd); in lock_acquire()
772 *a_fd = -1; in lock_acquire()
794 lock_release(int a_fd, char *a_key, char *a_object, int a_quiet) in lock_release() argument
807 result = _findLock(&theLock, &recordNum, a_fd, a_object, a_key); in lock_release()
867 (void) _decrementLockCount(a_fd, &theLock); in lock_release()
895 lock_status(int a_fd, char *a_key, char *a_object, int a_quiet) in lock_status() argument
919 for (; pread(a_fd, pld, pls, pls*recordNum) == pls; recordNum++) { in lock_status()
995 _lock_acquire(LOCK_T *a_theLock, int a_fd, char *a_key, in _lock_acquire() argument
1011 result = _findLock(a_theLock, &recordNum, a_fd, a_object, in _lock_acquire()
1018 if (_validateLock(a_fd, a_theLock, a_quiet) == B_TRUE) { in _lock_acquire()
1071 if (_incrementLockCount(a_fd, a_theLock) == 0) { in _lock_acquire()
1088 if (_addLock(key, a_fd, a_object, a_exclusive, in _lock_acquire()
1132 if (_incrementLockCount(a_fd, a_theLock) == 0) { in _lock_acquire()
1621 int a_fd, char *a_object, char *a_key) in _findLock() argument
1650 pos = lseek(a_fd, 0L, SEEK_SET); in _findLock()
1659 for (; pread(a_fd, pld, pls, pls*recordNum) == pls; recordNum++) { in _findLock()
1732 _addLock(char *r_key, int a_fd, char *a_object, int a_exclusive, pid_t a_pid, in _addLock() argument
1746 pos = lseek(a_fd, 0L, SEEK_END); in _addLock()
1778 result = pwrite(a_fd, &theLock, LOCK_SIZE, pos); in _addLock()
1794 _incrementLockCount(int a_fd, LOCK_T *a_theLock) in _incrementLockCount() argument
1820 result = pwrite(a_fd, pld, pls, pll->lockRecordNum*pls); in _incrementLockCount()
1851 _validateLock(int a_fd, LOCK_T *a_theLock, int a_quiet) in _validateLock() argument
1900 _decrementLockCount(a_fd, a_theLock); in _validateLock()
1906 _decrementLockCount(int a_fd, LOCK_T *a_theLock) in _decrementLockCount() argument
1935 result = pwrite(a_fd, pld, pls, pll->lockRecordNum*pls); in _decrementLockCount()
1958 lastPos = lseek(a_fd, 0L, SEEK_END); /* get size of lock file */ in _decrementLockCount()
1985 res = ftruncate(a_fd, lastPos-pls); in _decrementLockCount()
2008 result = pread(a_fd, tmpLock._lrLockData, pls, lastRecord*pls); in _decrementLockCount()
2021 res = ftruncate(a_fd, lastPos-pls); in _decrementLockCount()
2037 result = pwrite(a_fd, tmpLock._lrLockData, pls, pll->lockRecordNum*pls); in _decrementLockCount()