1 //
2 //
3 // Copyright 2015 gRPC authors.
4 //
5 // Licensed under the Apache License, Version 2.0 (the "License");
6 // you may not use this file except in compliance with the License.
7 // You may obtain a copy of the License at
8 //
9 // http://www.apache.org/licenses/LICENSE-2.0
10 //
11 // Unless required by applicable law or agreed to in writing, software
12 // distributed under the License is distributed on an "AS IS" BASIS,
13 // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14 // See the License for the specific language governing permissions and
15 // limitations under the License.
16 //
17 //
18
19 #include <grpc/support/port_platform.h>
20
21 #if defined(GPR_POSIX_SYNC) && !defined(GPR_ABSEIL_SYNC) && \
22 !defined(GPR_CUSTOM_SYNC)
23
24 #include <errno.h>
25 #include <grpc/support/alloc.h>
26 #include <grpc/support/sync.h>
27 #include <grpc/support/time.h>
28 #include <time.h>
29
30 #include "absl/log/check.h"
31 #include "src/core/util/crash.h"
32
gpr_mu_init(gpr_mu * mu)33 void gpr_mu_init(gpr_mu* mu) {
34 #ifdef GRPC_ASAN_ENABLED
35 CHECK_EQ(pthread_mutex_init(&mu->mutex, nullptr), 0);
36 mu->leak_checker = static_cast<int*>(malloc(sizeof(*mu->leak_checker)));
37 CHECK_NE(mu->leak_checker, nullptr);
38 #else
39 CHECK_EQ(pthread_mutex_init(mu, nullptr), 0);
40 #endif
41 }
42
gpr_mu_destroy(gpr_mu * mu)43 void gpr_mu_destroy(gpr_mu* mu) {
44 #ifdef GRPC_ASAN_ENABLED
45 CHECK_EQ(pthread_mutex_destroy(&mu->mutex), 0);
46 free(mu->leak_checker);
47 #else
48 CHECK_EQ(pthread_mutex_destroy(mu), 0);
49 #endif
50 }
51
gpr_mu_lock(gpr_mu * mu)52 void gpr_mu_lock(gpr_mu* mu) {
53 #ifdef GRPC_ASAN_ENABLED
54 CHECK_EQ(pthread_mutex_lock(&mu->mutex), 0);
55 #else
56 CHECK_EQ(pthread_mutex_lock(mu), 0);
57 #endif
58 }
59
gpr_mu_unlock(gpr_mu * mu)60 void gpr_mu_unlock(gpr_mu* mu) {
61 #ifdef GRPC_ASAN_ENABLED
62 CHECK_EQ(pthread_mutex_unlock(&mu->mutex), 0);
63 #else
64 CHECK_EQ(pthread_mutex_unlock(mu), 0);
65 #endif
66 }
67
gpr_mu_trylock(gpr_mu * mu)68 int gpr_mu_trylock(gpr_mu* mu) {
69 int err = 0;
70 #ifdef GRPC_ASAN_ENABLED
71 err = pthread_mutex_trylock(&mu->mutex);
72 #else
73 err = pthread_mutex_trylock(mu);
74 #endif
75 CHECK(err == 0 || err == EBUSY);
76 return err == 0;
77 }
78
79 //----------------------------------------
80
gpr_cv_init(gpr_cv * cv)81 void gpr_cv_init(gpr_cv* cv) {
82 pthread_condattr_t attr;
83 CHECK_EQ(pthread_condattr_init(&attr), 0);
84 #if GPR_LINUX
85 CHECK_EQ(pthread_condattr_setclock(&attr, CLOCK_MONOTONIC), 0);
86 #endif // GPR_LINUX
87
88 #ifdef GRPC_ASAN_ENABLED
89 CHECK_EQ(pthread_cond_init(&cv->cond_var, &attr), 0);
90 cv->leak_checker = static_cast<int*>(malloc(sizeof(*cv->leak_checker)));
91 CHECK_NE(cv->leak_checker, nullptr);
92 #else
93 CHECK_EQ(pthread_cond_init(cv, &attr), 0);
94 #endif
95 }
96
gpr_cv_destroy(gpr_cv * cv)97 void gpr_cv_destroy(gpr_cv* cv) {
98 #ifdef GRPC_ASAN_ENABLED
99 CHECK_EQ(pthread_cond_destroy(&cv->cond_var), 0);
100 free(cv->leak_checker);
101 #else
102 CHECK_EQ(pthread_cond_destroy(cv), 0);
103 #endif
104 }
105
gpr_cv_wait(gpr_cv * cv,gpr_mu * mu,gpr_timespec abs_deadline)106 int gpr_cv_wait(gpr_cv* cv, gpr_mu* mu, gpr_timespec abs_deadline) {
107 int err = 0;
108 if (gpr_time_cmp(abs_deadline, gpr_inf_future(abs_deadline.clock_type)) ==
109 0) {
110 #ifdef GRPC_ASAN_ENABLED
111 err = pthread_cond_wait(&cv->cond_var, &mu->mutex);
112 #else
113 err = pthread_cond_wait(cv, mu);
114 #endif
115 } else {
116 struct timespec abs_deadline_ts;
117 #if GPR_LINUX
118 abs_deadline = gpr_convert_clock_type(abs_deadline, GPR_CLOCK_MONOTONIC);
119 #else
120 abs_deadline = gpr_convert_clock_type(abs_deadline, GPR_CLOCK_REALTIME);
121 abs_deadline = gpr_time_max(abs_deadline, gpr_now(abs_deadline.clock_type));
122 #endif // GPR_LINUX
123 abs_deadline_ts.tv_sec = static_cast<time_t>(abs_deadline.tv_sec);
124 abs_deadline_ts.tv_nsec = abs_deadline.tv_nsec;
125 #ifdef GRPC_ASAN_ENABLED
126 err = pthread_cond_timedwait(&cv->cond_var, &mu->mutex, &abs_deadline_ts);
127 #else
128 err = pthread_cond_timedwait(cv, mu, &abs_deadline_ts);
129 #endif
130 }
131 CHECK(err == 0 || err == ETIMEDOUT || err == EAGAIN);
132 return err == ETIMEDOUT;
133 }
134
gpr_cv_signal(gpr_cv * cv)135 void gpr_cv_signal(gpr_cv* cv) {
136 #ifdef GRPC_ASAN_ENABLED
137 CHECK_EQ(pthread_cond_signal(&cv->cond_var), 0);
138 #else
139 CHECK_EQ(pthread_cond_signal(cv), 0);
140 #endif
141 }
142
gpr_cv_broadcast(gpr_cv * cv)143 void gpr_cv_broadcast(gpr_cv* cv) {
144 #ifdef GRPC_ASAN_ENABLED
145 CHECK_EQ(pthread_cond_broadcast(&cv->cond_var), 0);
146 #else
147 CHECK_EQ(pthread_cond_broadcast(cv), 0);
148 #endif
149 }
150
151 //----------------------------------------
152
gpr_once_init(gpr_once * once,void (* init_function)(void))153 void gpr_once_init(gpr_once* once, void (*init_function)(void)) {
154 CHECK_EQ(pthread_once(once, init_function), 0);
155 }
156
157 #endif // defined(GPR_POSIX_SYNC) && !defined(GPR_ABSEIL_SYNC) &&
158 // !defined(GPR_CUSTOM_SYNC)
159