2 Copyright (C) 2006, 2007, 2008, 2009, 2010, 2011, 2012, 2013, 2014, 2015,
4 Ben Kibbey <bjk@luxsci.net>
6 This file is part of pwmd.
8 Pwmd is free software: you can redistribute it and/or modify
9 it under the terms of the GNU General Public License as published by
10 the Free Software Foundation, either version 2 of the License, or
11 (at your option) any later version.
13 Pwmd is distributed in the hope that it will be useful,
14 but WITHOUT ANY WARRANTY; without even the implied warranty of
15 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
16 GNU General Public License for more details.
18 You should have received a copy of the GNU General Public License
19 along with Pwmd. If not, see <http://www.gnu.org/licenses/>.
28 #ifdef HAVE_SYS_TIME_H
36 #ifdef HAVE_SYS_SELECT_H
37 #include <sys/select.h>
39 #include <sys/types.h>
43 #ifdef HAVE_SYS_FILE_H
56 #define INIT_TIMESPEC(t, ts) do { \
57 long s = (t*100000000)/1000000000; \
58 long l = (t*100000000)%1000000000; \
59 clock_gettime(CLOCK_REALTIME, &ts); \
61 if (ts.tv_nsec + l >= 1000000000) { \
70 #define MUTEX_LOCK_DEBUG(m) do { \
71 log_write("%s(%i): %s(): LOCK %p", __FILE__, __LINE__, \
75 #define MUTEX_UNLOCK_DEBUG(m) do { \
76 log_write("%s(%i): %s(): UNLOCK %p", __FILE__, __LINE__, \
80 #define MUTEX_LOCK_DEBUG(m)
81 #define MUTEX_UNLOCK_DEBUG(m)
84 #define MUTEX_LOCK(m) do { \
85 MUTEX_LOCK_DEBUG(m); \
86 pthread_mutex_lock(m); \
89 #define MUTEX_UNLOCK(m) do { \
90 MUTEX_UNLOCK_DEBUG(m); \
91 pthread_mutex_unlock(m); \
94 #define TIMED_LOCK_DURATION 100000
96 #define TRY_FLOCK(ctx, fd, type, rc) do { \
97 long ka = (long)config_get_integer ("global", "keepalive_interval"); \
98 int to = config_get_integer ("global", "lock_timeout"); \
99 for (long elapsed = 0; ; elapsed++) { \
100 struct timeval tv = { 0, TIMED_LOCK_DURATION }; \
101 int n = flock (fd, type|LOCK_NB); \
102 if (n == -1 && errno == EWOULDBLOCK) \
104 if (to == -1 || elapsed >= to) { \
105 rc = GPG_ERR_LOCKED; \
108 select (0, NULL, NULL, NULL, &tv); \
109 if (ctx && ka && elapsed && !((elapsed+1*10) % (ka*10))) { \
110 rc = send_status (ctx, STATUS_KEEPALIVE, NULL); \
116 rc = gpg_error_from_errno (errno); \
122 #define TRY_FLOCK(ctx, fd, type, rc) do { \
127 #define MUTEX_TIMED_LOCK(ctx, m, timeout, rc) do { \
128 long ka = (long)config_get_integer ("global", "keepalive_interval"); \
129 for (long elapsed = 0; ; elapsed++) { \
130 struct timeval tv = { 0, TIMED_LOCK_DURATION }; \
131 if (pthread_mutex_trylock(m) == EBUSY) { \
132 if (timeout == -1 || elapsed >= timeout) { \
133 rc = GPG_ERR_LOCKED; \
136 select (0, NULL, NULL, NULL, &tv); \
137 if (ctx && ka && elapsed && !((elapsed+1*10) % (ka*10))) { \
138 rc = send_status (ctx, STATUS_KEEPALIVE, NULL); \
144 MUTEX_LOCK_DEBUG(m); \
150 #define MUTEX_TRYLOCK(ctx, m, rc, t) do { \
153 if ((n = pthread_mutex_trylock(m)) == EBUSY) { \
156 rc = send_status(ctx, STATUS_LOCKED, NULL); \
157 if (!rc && t != 0) { \
158 MUTEX_TIMED_LOCK(ctx, m, t, rc); \
161 MUTEX_LOCK_DEBUG(m); \
165 rc = GPG_ERR_LOCKED; \
168 rc = gpg_error_from_errno(n); \
170 MUTEX_LOCK_DEBUG(m); \