4e6b77edb744963e5d8c8bf18b4b244e89d201aa
[openafs.git] / src / afs / OBSD / osi_sleep.c
1 /*
2  * $Id$
3  */
4
5 /*
6 copyright 2002
7 the regents of the university of michigan
8 all rights reserved
9
10 permission is granted to use, copy, create derivative works 
11 and redistribute this software and such derivative works 
12 for any purpose, so long as the name of the university of 
13 michigan is not used in any advertising or publicity 
14 pertaining to the use or distribution of this software 
15 without specific, written prior authorization.  if the 
16 above copyright notice or any other identification of the 
17 university of michigan is included in any copy of any 
18 portion of this software, then the disclaimer below must 
19 also be included.
20
21 this software is provided as is, without representation 
22 from the university of michigan as to its fitness for any 
23 purpose, and without warranty by the university of 
24 michigan of any kind, either express or implied, including 
25 without limitation the implied warranties of 
26 merchantability and fitness for a particular purpose. the 
27 regents of the university of michigan shall not be liable 
28 for any damages, including special, indirect, incidental, or 
29 consequential damages, with respect to any claim arising 
30 out of or in connection with the use of the software, even 
31 if it has been or is hereafter advised of the possibility of 
32 such damages.
33 */
34
35 /*
36  * Copyright 2000, International Business Machines Corporation and others.
37  * All Rights Reserved.
38  *
39  * This software has been released under the terms of the IBM Public
40  * License.  For details, see the LICENSE file in the top-level source
41  * directory or online at http://www.openafs.org/dl/license10.html
42  */
43
44 #include <afsconfig.h>
45 #include "afs/param.h"
46
47 RCSID
48     ("$Header$");
49
50 #include "afs/sysincludes.h"    /* Standard vendor system headers */
51 #include "afs/afsincludes.h"    /* Afs-based standard headers */
52 #include "afs/afs_stats.h"      /* afs statistics */
53
54 static char waitV;
55
56
57 /* cancel osi_Wait */
58 void
59 afs_osi_CancelWait(struct afs_osi_WaitHandle *achandle)
60 {
61     caddr_t proc;
62
63     AFS_STATCNT(osi_CancelWait);
64     proc = achandle->proc;
65     if (proc == NULL)
66         return;
67     achandle->proc = NULL;
68     wakeup(&waitV);
69 }
70
71 /* afs_osi_Wait
72  * Waits for data on ahandle, or ams ms later.  ahandle may be null.
73  * Returns 0 if timeout and EINTR if signalled.
74  */
75 int
76 afs_osi_Wait(afs_int32 ams, struct afs_osi_WaitHandle *ahandle, int aintok)
77 {
78     int timo, code = 0;
79     struct timeval atv, endTime;
80
81     AFS_STATCNT(osi_Wait);
82
83     atv.tv_sec = ams / 1000;
84     atv.tv_usec = (ams % 1000) * 1000;
85     timeradd(&atv, &time, &endTime);
86
87     if (ahandle)
88         ahandle->proc = (caddr_t) curproc;
89     AFS_ASSERT_GLOCK();
90     AFS_GUNLOCK();
91
92     do {
93         timersub(&endTime, &time, &atv);
94         timo = atv.tv_sec * hz + atv.tv_usec * hz / 1000000 + 1;
95         if (aintok) {
96             code = tsleep(&waitV, PCATCH | PVFS, "afs_W1", timo);
97             if (code)
98                 code = (code == EWOULDBLOCK) ? 0 : EINTR;
99         } else
100             tsleep(&waitV, PVFS, "afs_W2", timo);
101
102         /* if we were cancelled, quit now */
103         if (ahandle && (ahandle->proc == NULL)) {
104             /* we've been signalled */
105             break;
106         }
107     } while (timercmp(&time, &endTime, <));
108
109     AFS_GLOCK();
110     return code;
111 }
112
113 void
114 afs_osi_Sleep(void *event)
115 {
116     AFS_ASSERT_GLOCK();
117     AFS_GUNLOCK();
118     tsleep(event, PVFS, "afs", 0);
119     AFS_GLOCK();
120 }
121
122 int
123 afs_osi_SleepSig(void *event)
124 {
125     AFS_ASSERT_GLOCK();
126     AFS_GUNLOCK();
127     tsleep(event, PVFS, "afs", 0);
128     AFS_GLOCK();
129     return 0;
130 }
131
132 int
133 afs_osi_Wakeup(void *event)
134 {
135     wakeup(event);
136     return 1;
137 }