First pass at better signal handling:
[openafs.git] / src / rx / LINUX / rx_kmutex.h
1 /*
2  * Copyright 2000, International Business Machines Corporation and others.
3  * All Rights Reserved.
4  * 
5  * This software has been released under the terms of the IBM Public
6  * License.  For details, see the LICENSE file in the top-level source
7  * directory or online at http://www.openafs.org/dl/license10.html
8  */
9
10 /*
11  * rx_kmutex.h - mutex and condition variable macros for kernel environment.
12  *
13  * Linux implementation.
14  * This are noops until such time as the kernel no longer has a global lock.
15  */
16 #ifndef RX_KMUTEX_H_
17 #define RX_KMUTEX_H_
18
19 #include "../rx/rx_kernel.h"    /* for osi_Panic() */
20
21 /* AFS_GLOBAL_RXLOCK_KERNEL is defined so that the busy tq code paths are
22  * used. The thread can sleep when sending packets.
23  */
24 #define AFS_GLOBAL_RXLOCK_KERNEL 1
25
26
27 #ifdef CONFIG_SMP
28 #define RX_ENABLE_LOCKS 1
29
30 #ifndef _LINUX_CODA_FS_I
31 #define _LINUX_CODA_FS_I
32 struct coda_inode_info {};
33 #endif
34 #include "linux/wait.h"
35 #include "linux/sched.h"
36
37 typedef struct afs_kmutex {
38     struct semaphore sem;
39     int owner;
40 } afs_kmutex_t;
41
42 #if defined(AFS_LINUX24_ENV)
43 typedef wait_queue_head_t afs_kcondvar_t;
44 #else
45 typedef struct wait_queue *afs_kcondvar_t;
46 #endif
47
48 static inline int MUTEX_ISMINE(afs_kmutex_t *l)
49 {
50     return l->owner == current->pid;
51 }
52
53 #define MUTEX_INIT(a,b,c,d)     afs_mutex_init(a)
54 #define MUTEX_DESTROY(a)
55 #define MUTEX_ENTER             afs_mutex_enter
56 #define MUTEX_TRYENTER          afs_mutex_tryenter
57 #define MUTEX_EXIT              afs_mutex_exit
58
59 #if defined(AFS_LINUX24_ENV)
60 #define CV_INIT(cv,b,c,d)       init_waitqueue_head((wait_queue_head_t *)(cv))
61 #else
62 #define CV_INIT(cv,b,c,d)       init_waitqueue((struct wait_queue**)(cv))
63 #endif
64 #define CV_DESTROY(cv)
65 #define CV_WAIT_SIG(cv, m)      afs_cv_wait(cv, m, 1)
66 #define CV_WAIT(cv, m)          afs_cv_wait(cv, m, 0)
67 #define CV_TIMEDWAIT            afs_cv_timedwait
68
69 #if defined(AFS_LINUX24_ENV)
70 #define CV_SIGNAL(cv)           wake_up((wait_queue_head_t *)cv)
71 #define CV_BROADCAST(cv)        wake_up((wait_queue_head_t *)cv)
72 #else
73 #define CV_SIGNAL(cv)           wake_up((struct wait_queue**)cv)
74 #define CV_BROADCAST(cv)        wake_up((struct wait_queue**)cv)
75 #endif
76
77 #else
78
79 #define MUTEX_ISMINE(a)
80 #define osirx_AssertMine(addr, msg)
81
82 #define MUTEX_DESTROY(a)
83 #define MUTEX_ENTER(a)
84 #define MUTEX_TRYENTER(a) 1
85 #define MUTEX_EXIT(a)  
86 #define MUTEX_INIT(a,b,c,d) 
87 #define CV_INIT(a,b,c,d)
88 #define CV_DESTROY(a)
89 #endif
90
91 /* Since we're using the RX listener daemon, we don't need to hold off
92  * interrupts.
93  */
94 #define SPLVAR
95 #define NETPRI
96 #define USERPRI
97
98 #endif /* RX_KMUTEX_H_ */