1d6b92ffaSHans Petter Selasky /*
2d6b92ffaSHans Petter Selasky * Copyright (c) 2004-2009 Voltaire, Inc. All rights reserved.
3d6b92ffaSHans Petter Selasky * Copyright (c) 2002-2005 Mellanox Technologies LTD. All rights reserved.
4d6b92ffaSHans Petter Selasky * Copyright (c) 1996-2003 Intel Corporation. All rights reserved.
5d6b92ffaSHans Petter Selasky *
6d6b92ffaSHans Petter Selasky * This software is available to you under a choice of one of two
7d6b92ffaSHans Petter Selasky * licenses. You may choose to be licensed under the terms of the GNU
8d6b92ffaSHans Petter Selasky * General Public License (GPL) Version 2, available from the file
9d6b92ffaSHans Petter Selasky * COPYING in the main directory of this source tree, or the
10d6b92ffaSHans Petter Selasky * OpenIB.org BSD license below:
11d6b92ffaSHans Petter Selasky *
12d6b92ffaSHans Petter Selasky * Redistribution and use in source and binary forms, with or
13d6b92ffaSHans Petter Selasky * without modification, are permitted provided that the following
14d6b92ffaSHans Petter Selasky * conditions are met:
15d6b92ffaSHans Petter Selasky *
16d6b92ffaSHans Petter Selasky * - Redistributions of source code must retain the above
17d6b92ffaSHans Petter Selasky * copyright notice, this list of conditions and the following
18d6b92ffaSHans Petter Selasky * disclaimer.
19d6b92ffaSHans Petter Selasky *
20d6b92ffaSHans Petter Selasky * - Redistributions in binary form must reproduce the above
21d6b92ffaSHans Petter Selasky * copyright notice, this list of conditions and the following
22d6b92ffaSHans Petter Selasky * disclaimer in the documentation and/or other materials
23d6b92ffaSHans Petter Selasky * provided with the distribution.
24d6b92ffaSHans Petter Selasky *
25d6b92ffaSHans Petter Selasky * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
26d6b92ffaSHans Petter Selasky * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
27d6b92ffaSHans Petter Selasky * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
28d6b92ffaSHans Petter Selasky * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS
29d6b92ffaSHans Petter Selasky * BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN
30d6b92ffaSHans Petter Selasky * ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
31d6b92ffaSHans Petter Selasky * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
32d6b92ffaSHans Petter Selasky * SOFTWARE.
33d6b92ffaSHans Petter Selasky *
34d6b92ffaSHans Petter Selasky */
35d6b92ffaSHans Petter Selasky
36d6b92ffaSHans Petter Selasky #if HAVE_CONFIG_H
37d6b92ffaSHans Petter Selasky # include <config.h>
38d6b92ffaSHans Petter Selasky #endif /* HAVE_CONFIG_H */
39d6b92ffaSHans Petter Selasky
40d6b92ffaSHans Petter Selasky #include <complib/cl_event.h>
41d6b92ffaSHans Petter Selasky #include <complib/cl_debug.h>
42d6b92ffaSHans Petter Selasky #include <sys/time.h>
43d6b92ffaSHans Petter Selasky #include <sys/errno.h>
44d6b92ffaSHans Petter Selasky
cl_event_construct(IN cl_event_t * p_event)45d6b92ffaSHans Petter Selasky void cl_event_construct(IN cl_event_t * p_event)
46d6b92ffaSHans Petter Selasky {
47d6b92ffaSHans Petter Selasky CL_ASSERT(p_event);
48d6b92ffaSHans Petter Selasky
49d6b92ffaSHans Petter Selasky p_event->state = CL_UNINITIALIZED;
50d6b92ffaSHans Petter Selasky }
51d6b92ffaSHans Petter Selasky
cl_event_init(IN cl_event_t * const p_event,IN const boolean_t manual_reset)52d6b92ffaSHans Petter Selasky cl_status_t cl_event_init(IN cl_event_t * const p_event,
53d6b92ffaSHans Petter Selasky IN const boolean_t manual_reset)
54d6b92ffaSHans Petter Selasky {
55d6b92ffaSHans Petter Selasky CL_ASSERT(p_event);
56d6b92ffaSHans Petter Selasky
57d6b92ffaSHans Petter Selasky cl_event_construct(p_event);
58d6b92ffaSHans Petter Selasky
59d6b92ffaSHans Petter Selasky pthread_cond_init(&p_event->condvar, NULL);
60d6b92ffaSHans Petter Selasky pthread_mutex_init(&p_event->mutex, NULL);
61d6b92ffaSHans Petter Selasky p_event->signaled = FALSE;
62d6b92ffaSHans Petter Selasky p_event->manual_reset = manual_reset;
63d6b92ffaSHans Petter Selasky p_event->state = CL_INITIALIZED;
64d6b92ffaSHans Petter Selasky
65d6b92ffaSHans Petter Selasky return CL_SUCCESS;
66d6b92ffaSHans Petter Selasky }
67d6b92ffaSHans Petter Selasky
cl_event_destroy(IN cl_event_t * const p_event)68d6b92ffaSHans Petter Selasky void cl_event_destroy(IN cl_event_t * const p_event)
69d6b92ffaSHans Petter Selasky {
70d6b92ffaSHans Petter Selasky CL_ASSERT(cl_is_state_valid(p_event->state));
71d6b92ffaSHans Petter Selasky
72d6b92ffaSHans Petter Selasky /* Destroy only if the event was constructed */
73d6b92ffaSHans Petter Selasky if (p_event->state == CL_INITIALIZED) {
74d6b92ffaSHans Petter Selasky pthread_cond_broadcast(&p_event->condvar);
75d6b92ffaSHans Petter Selasky pthread_cond_destroy(&p_event->condvar);
76d6b92ffaSHans Petter Selasky pthread_mutex_destroy(&p_event->mutex);
77d6b92ffaSHans Petter Selasky }
78d6b92ffaSHans Petter Selasky
79d6b92ffaSHans Petter Selasky p_event->state = CL_UNINITIALIZED;
80d6b92ffaSHans Petter Selasky }
81d6b92ffaSHans Petter Selasky
cl_event_signal(IN cl_event_t * const p_event)82d6b92ffaSHans Petter Selasky cl_status_t cl_event_signal(IN cl_event_t * const p_event)
83d6b92ffaSHans Petter Selasky {
84d6b92ffaSHans Petter Selasky /* Make sure that the event was started */
85d6b92ffaSHans Petter Selasky CL_ASSERT(p_event->state == CL_INITIALIZED);
86d6b92ffaSHans Petter Selasky
87d6b92ffaSHans Petter Selasky pthread_mutex_lock(&p_event->mutex);
88d6b92ffaSHans Petter Selasky p_event->signaled = TRUE;
89d6b92ffaSHans Petter Selasky /* Wake up one or all depending on whether the event is auto-resetting. */
90d6b92ffaSHans Petter Selasky if (p_event->manual_reset)
91d6b92ffaSHans Petter Selasky pthread_cond_broadcast(&p_event->condvar);
92d6b92ffaSHans Petter Selasky else
93d6b92ffaSHans Petter Selasky pthread_cond_signal(&p_event->condvar);
94d6b92ffaSHans Petter Selasky
95d6b92ffaSHans Petter Selasky pthread_mutex_unlock(&p_event->mutex);
96d6b92ffaSHans Petter Selasky
97d6b92ffaSHans Petter Selasky return CL_SUCCESS;
98d6b92ffaSHans Petter Selasky }
99d6b92ffaSHans Petter Selasky
cl_event_reset(IN cl_event_t * const p_event)100d6b92ffaSHans Petter Selasky cl_status_t cl_event_reset(IN cl_event_t * const p_event)
101d6b92ffaSHans Petter Selasky {
102d6b92ffaSHans Petter Selasky /* Make sure that the event was started */
103d6b92ffaSHans Petter Selasky CL_ASSERT(p_event->state == CL_INITIALIZED);
104d6b92ffaSHans Petter Selasky
105d6b92ffaSHans Petter Selasky pthread_mutex_lock(&p_event->mutex);
106d6b92ffaSHans Petter Selasky p_event->signaled = FALSE;
107d6b92ffaSHans Petter Selasky pthread_mutex_unlock(&p_event->mutex);
108d6b92ffaSHans Petter Selasky
109d6b92ffaSHans Petter Selasky return CL_SUCCESS;
110d6b92ffaSHans Petter Selasky }
111d6b92ffaSHans Petter Selasky
cl_event_wait_on(IN cl_event_t * const p_event,IN const uint32_t wait_us,IN const boolean_t interruptible)112d6b92ffaSHans Petter Selasky cl_status_t cl_event_wait_on(IN cl_event_t * const p_event,
113d6b92ffaSHans Petter Selasky IN const uint32_t wait_us,
114d6b92ffaSHans Petter Selasky IN const boolean_t interruptible)
115d6b92ffaSHans Petter Selasky {
116d6b92ffaSHans Petter Selasky cl_status_t status;
117d6b92ffaSHans Petter Selasky int wait_ret;
118d6b92ffaSHans Petter Selasky struct timespec timeout;
119d6b92ffaSHans Petter Selasky struct timeval curtime;
120d6b92ffaSHans Petter Selasky
121d6b92ffaSHans Petter Selasky /* Make sure that the event was Started */
122d6b92ffaSHans Petter Selasky CL_ASSERT(p_event->state == CL_INITIALIZED);
123d6b92ffaSHans Petter Selasky
124d6b92ffaSHans Petter Selasky pthread_mutex_lock(&p_event->mutex);
125d6b92ffaSHans Petter Selasky
126d6b92ffaSHans Petter Selasky /* Return immediately if the event is signalled. */
127d6b92ffaSHans Petter Selasky if (p_event->signaled) {
128d6b92ffaSHans Petter Selasky if (!p_event->manual_reset)
129d6b92ffaSHans Petter Selasky p_event->signaled = FALSE;
130d6b92ffaSHans Petter Selasky
131d6b92ffaSHans Petter Selasky pthread_mutex_unlock(&p_event->mutex);
132d6b92ffaSHans Petter Selasky return CL_SUCCESS;
133d6b92ffaSHans Petter Selasky }
134d6b92ffaSHans Petter Selasky
135d6b92ffaSHans Petter Selasky /* If just testing the state, return CL_TIMEOUT. */
136d6b92ffaSHans Petter Selasky if (wait_us == 0) {
137d6b92ffaSHans Petter Selasky pthread_mutex_unlock(&p_event->mutex);
138d6b92ffaSHans Petter Selasky return CL_TIMEOUT;
139d6b92ffaSHans Petter Selasky }
140d6b92ffaSHans Petter Selasky
141d6b92ffaSHans Petter Selasky if (wait_us == EVENT_NO_TIMEOUT) {
142d6b92ffaSHans Petter Selasky /* Wait for condition variable to be signaled or broadcast. */
143d6b92ffaSHans Petter Selasky if (pthread_cond_wait(&p_event->condvar, &p_event->mutex))
144d6b92ffaSHans Petter Selasky status = CL_NOT_DONE;
145d6b92ffaSHans Petter Selasky else
146d6b92ffaSHans Petter Selasky status = CL_SUCCESS;
147d6b92ffaSHans Petter Selasky } else {
148d6b92ffaSHans Petter Selasky /* Get the current time */
149d6b92ffaSHans Petter Selasky if (gettimeofday(&curtime, NULL) == 0) {
150d6b92ffaSHans Petter Selasky unsigned long n_sec =
151d6b92ffaSHans Petter Selasky (curtime.tv_usec + (wait_us % 1000000)) * 1000;
152d6b92ffaSHans Petter Selasky timeout.tv_sec = curtime.tv_sec + (wait_us / 1000000)
153d6b92ffaSHans Petter Selasky + (n_sec / 1000000000);
154d6b92ffaSHans Petter Selasky timeout.tv_nsec = n_sec % 1000000000;
155d6b92ffaSHans Petter Selasky
156d6b92ffaSHans Petter Selasky wait_ret = pthread_cond_timedwait(&p_event->condvar,
157d6b92ffaSHans Petter Selasky &p_event->mutex,
158d6b92ffaSHans Petter Selasky &timeout);
159d6b92ffaSHans Petter Selasky if (wait_ret == 0)
160d6b92ffaSHans Petter Selasky status =
161d6b92ffaSHans Petter Selasky (p_event->
162d6b92ffaSHans Petter Selasky signaled ? CL_SUCCESS : CL_NOT_DONE);
163d6b92ffaSHans Petter Selasky else if (wait_ret == ETIMEDOUT)
164d6b92ffaSHans Petter Selasky status = CL_TIMEOUT;
165d6b92ffaSHans Petter Selasky else
166d6b92ffaSHans Petter Selasky status = CL_NOT_DONE;
167d6b92ffaSHans Petter Selasky } else
168d6b92ffaSHans Petter Selasky status = CL_ERROR;
169d6b92ffaSHans Petter Selasky }
170d6b92ffaSHans Petter Selasky if (!p_event->manual_reset)
171d6b92ffaSHans Petter Selasky p_event->signaled = FALSE;
172d6b92ffaSHans Petter Selasky
173d6b92ffaSHans Petter Selasky pthread_mutex_unlock(&p_event->mutex);
174d6b92ffaSHans Petter Selasky return status;
175d6b92ffaSHans Petter Selasky }
176