| /external/grpc-grpc/src/core/lib/gpr/ |
| D | sync_windows.cc | 29 void gpr_mu_init(gpr_mu* mu) { in gpr_mu_init() argument
30 InitializeCriticalSection(&mu->cs); in gpr_mu_init()
31 mu->locked = 0; in gpr_mu_init()
34 void gpr_mu_destroy(gpr_mu* mu) { DeleteCriticalSection(&mu->cs); } in gpr_mu_destroy() argument
36 void gpr_mu_lock(gpr_mu* mu) { in gpr_mu_lock() argument
37 EnterCriticalSection(&mu->cs); in gpr_mu_lock()
38 GPR_ASSERT(!mu->locked); in gpr_mu_lock()
39 mu->locked = 1; in gpr_mu_lock()
42 void gpr_mu_unlock(gpr_mu* mu) { in gpr_mu_unlock() argument
43 mu->locked = 0; in gpr_mu_unlock()
[all …]
|
| D | sync_posix.cc | 36 void gpr_mu_init(gpr_mu* mu) { in gpr_mu_init() argument
37 GPR_ASSERT(pthread_mutex_init(mu, nullptr) == 0); in gpr_mu_init()
40 void gpr_mu_destroy(gpr_mu* mu) { GPR_ASSERT(pthread_mutex_destroy(mu) == 0); } in gpr_mu_destroy() argument
42 void gpr_mu_lock(gpr_mu* mu) { in gpr_mu_lock() argument
47 GPR_ASSERT(pthread_mutex_lock(mu) == 0); in gpr_mu_lock()
50 void gpr_mu_unlock(gpr_mu* mu) { in gpr_mu_unlock() argument
52 GPR_ASSERT(pthread_mutex_unlock(mu) == 0); in gpr_mu_unlock()
55 int gpr_mu_trylock(gpr_mu* mu) { in gpr_mu_trylock() argument
57 int err = pthread_mutex_trylock(mu); in gpr_mu_trylock()
75 int gpr_cv_wait(gpr_cv* cv, gpr_mu* mu, gpr_timespec abs_deadline) { in gpr_cv_wait() argument
[all …]
|
| /external/clang/test/SemaCXX/ |
| D | warn-thread-safety-negative.cpp | 50 Mutex mu; member in SimpleTest::Bar
51 int a GUARDED_BY(mu);
54 void baz() EXCLUSIVE_LOCKS_REQUIRED(!mu) { in baz()
55 mu.Lock(); in baz()
57 mu.Unlock(); in baz()
63 Mutex mu; member in SimpleTest::Foo
64 int a GUARDED_BY(mu);
68 mu.Lock(); // expected-warning {{acquiring mutex 'mu' requires negative capability '!mu'}} in foo()
71 mu.Unlock(); in foo()
78 void baz() EXCLUSIVE_LOCKS_REQUIRED(!mu) { in baz()
[all …]
|
| D | warn-thread-safety-analysis.cpp | 48 MutexLock(Mutex *mu) EXCLUSIVE_LOCK_FUNCTION(mu);
49 MutexLock(Mutex *mu, bool adopt) EXCLUSIVE_LOCKS_REQUIRED(mu);
55 ReaderMutexLock(Mutex *mu) SHARED_LOCK_FUNCTION(mu);
56 ReaderMutexLock(Mutex *mu, bool adopt) SHARED_LOCKS_REQUIRED(mu);
62 ReleasableMutexLock(Mutex *mu) EXCLUSIVE_LOCK_FUNCTION(mu);
151 Mutex mu; member in MutexWrapper
152 int x __attribute__((guarded_by(mu)));
153 void MyLock() __attribute__((exclusive_lock_function(mu)));
159 sls_mw.mu.Lock(); in sls_fun_0()
161 sls_mw.mu.Unlock(); in sls_fun_0()
[all …]
|
| D | warn-thread-safety-verbose.cpp | 45 Mutex mu; member in Test
46 int a GUARDED_BY(mu); // expected-note3 {{Guarded_by declared here.}}
48 void foo1() EXCLUSIVE_LOCKS_REQUIRED(mu);
49 void foo2() SHARED_LOCKS_REQUIRED(mu);
50 void foo3() LOCKS_EXCLUDED(mu);
69 mu.ReaderLock(); in test5()
71 mu.Unlock(); in test5()
75 mu.ReaderLock(); in test6()
77 mu.Unlock(); in test6()
81 mu.Lock(); in test7()
[all …]
|
| D | warn-thread-safety-parsing.cpp | 45 Mutex mu; member in MuWrapper
47 return mu; in getMu()
50 return μ in getMuPointer()
344 int gb_var_arg_1 GUARDED_BY(muWrapper.mu);
345 int gb_var_arg_2 GUARDED_BY(muDoubleWrapper.muWrapper->mu);
415 int * pgb_var_arg_1 PT_GUARDED_BY(muWrapper.mu);
416 int * pgb_var_arg_2 PT_GUARDED_BY(muDoubleWrapper.muWrapper->mu);
476 Mutex aa_var_arg_1 ACQUIRED_AFTER(muWrapper.mu);
477 Mutex aa_var_arg_2 ACQUIRED_AFTER(muDoubleWrapper.muWrapper->mu);
539 Mutex ab_var_arg_1 ACQUIRED_BEFORE(muWrapper.mu);
[all …]
|
| /external/syzkaller/vendor/google.golang.org/grpc/ |
| D | balancer_conn_wrappers.go | 41 mu sync.Mutex member
52 b.mu.Lock()
53 defer b.mu.Unlock()
65 b.mu.Lock()
66 defer b.mu.Unlock()
101 mu sync.Mutex member
146 ccb.mu.Lock()
149 ccb.mu.Unlock()
195 ccb.mu.Lock()
196 defer ccb.mu.Unlock()
[all …]
|
| D | clientconn.go | 637 mu sync.Mutex member
646 csm.mu.Lock()
647 defer csm.mu.Unlock()
663 csm.mu.Lock()
664 defer csm.mu.Unlock()
669 csm.mu.Lock()
670 defer csm.mu.Unlock()
692 mu sync.RWMutex member
740 cc.mu.Lock()
745 cc.mu.Unlock()
[all …]
|
| D | balancer_v1_wrapper.go | 83 mu sync.Mutex member
112 bw.mu.Lock()
118 bw.mu.Unlock()
131 bw.mu.Lock()
135 bw.mu.Unlock()
139 bw.mu.Lock()
142 bw.mu.Unlock()
164 bw.mu.Lock()
173 bw.mu.Unlock()
177 bw.mu.Lock()
[all …]
|
| D | balancer.go | 158 mu sync.Mutex member
171 rr.mu.Lock()
172 defer rr.mu.Unlock()
221 rr.mu.Lock()
222 defer rr.mu.Unlock()
252 rr.mu.Lock()
253 defer rr.mu.Unlock()
278 rr.mu.Lock()
279 defer rr.mu.Unlock()
291 rr.mu.Lock()
[all …]
|
| D | picker_wrapper.go | 40 mu sync.Mutex member
97 bp.mu.Lock()
99 bp.mu.Unlock()
106 bp.mu.Unlock()
110 acw.mu.Lock()
112 acw.mu.Unlock()
161 bp.mu.Lock()
163 bp.mu.Unlock()
174 bp.mu.Unlock()
185 bp.mu.Unlock()
[all …]
|
| /external/bouncycastle/bcprov/src/main/java/org/bouncycastle/math/ec/ |
| D | Tnaf.java | 82 public static BigInteger norm(final byte mu, ZTauElement lambda) in norm() argument
95 if (mu == 1) in norm()
99 else if (mu == -1) in norm()
123 public static SimpleBigDecimal norm(final byte mu, SimpleBigDecimal u, in norm() argument
137 if (mu == 1) in norm()
141 else if (mu == -1) in norm()
167 SimpleBigDecimal lambda1, byte mu) in round() argument
176 if (!((mu == 1) || (mu == -1))) in round()
189 if (mu == 1) in round()
205 if (mu == 1) in round()
[all …]
|
| /external/bouncycastle/repackaged/bcprov/src/main/java/com/android/org/bouncycastle/math/ec/ |
| D | Tnaf.java | 83 public static BigInteger norm(final byte mu, ZTauElement lambda) in norm() argument
96 if (mu == 1) in norm()
100 else if (mu == -1) in norm()
124 public static SimpleBigDecimal norm(final byte mu, SimpleBigDecimal u, in norm() argument
138 if (mu == 1) in norm()
142 else if (mu == -1) in norm()
168 SimpleBigDecimal lambda1, byte mu) in round() argument
177 if (!((mu == 1) || (mu == -1))) in round()
190 if (mu == 1) in round()
206 if (mu == 1) in round()
[all …]
|
| /external/grpc-grpc/test/core/gpr/ |
| D | sync_test.cc | 43 gpr_mu mu; /* Protects all fields below. member
54 gpr_mu_init(&q->mu); in queue_init()
63 gpr_mu_destroy(&q->mu); in queue_destroy()
70 gpr_mu_lock(&q->mu); in queue_append()
79 gpr_cv_wait(&q->non_full, &q->mu, gpr_inf_future(GPR_CLOCK_MONOTONIC)); in queue_append()
88 gpr_mu_unlock(&q->mu); in queue_append()
95 if (gpr_mu_trylock(&q->mu)) { in queue_try_append()
104 gpr_mu_unlock(&q->mu); in queue_try_append()
114 gpr_mu_lock(&q->mu); in queue_remove()
120 while (q->length == 0 && !gpr_cv_wait(&q->non_empty, &q->mu, abs_deadline)) { in queue_remove()
[all …]
|
| /external/tensorflow/tensorflow/core/platform/default/ |
| D | mutex.h | 67 explicit mutex_lock(mutex_type& mu) EXCLUSIVE_LOCK_FUNCTION(mu) : mu_(&mu) { in mutex_lock() argument
71 mutex_lock(mutex_type& mu, std::try_to_lock_t) EXCLUSIVE_LOCK_FUNCTION(mu) in mutex_lock() argument
72 : mu_(&mu) { in mutex_lock()
73 if (!mu.try_lock()) { in mutex_lock()
106 explicit tf_shared_lock(mutex_type& mu) SHARED_LOCK_FUNCTION(mu) : mu_(&mu) { in tf_shared_lock() argument
110 tf_shared_lock(mutex_type& mu, std::try_to_lock_t) SHARED_LOCK_FUNCTION(mu) in tf_shared_lock() argument
111 : mu_(&mu) { in tf_shared_lock()
112 if (!mu.try_lock_shared()) { in tf_shared_lock()
160 friend ConditionResult WaitForMilliseconds(mutex_lock* mu,
168 inline ConditionResult WaitForMilliseconds(mutex_lock* mu, in WaitForMilliseconds() argument
[all …]
|
| /external/syzkaller/vendor/golang.org/x/net/http2/ |
| D | pipe.go | 17 mu sync.Mutex member
33 p.mu.Lock()
34 defer p.mu.Unlock()
44 p.mu.Lock()
45 defer p.mu.Unlock()
47 p.c.L = &p.mu
73 p.mu.Lock()
74 defer p.mu.Unlock()
76 p.c.L = &p.mu
108 p.mu.Lock()
[all …]
|
| D | client_conn_pool.go | 37 mu sync.Mutex // TODO: maybe switch to RWMutex member
65 p.mu.Lock()
68 p.mu.Unlock()
73 p.mu.Unlock()
77 p.mu.Unlock()
111 c.p.mu.Lock()
116 c.p.mu.Unlock()
128 p.mu.Lock()
131 p.mu.Unlock()
147 p.mu.Unlock()
[all …]
|
| /external/grpc-grpc/include/grpc/support/ |
| D | sync.h | 39 GPRAPI void gpr_mu_init(gpr_mu* mu);
43 GPRAPI void gpr_mu_destroy(gpr_mu* mu);
48 GPRAPI void gpr_mu_lock(gpr_mu* mu);
52 GPRAPI void gpr_mu_unlock(gpr_mu* mu);
58 GPRAPI int gpr_mu_trylock(gpr_mu* mu);
80 GPRAPI int gpr_cv_wait(gpr_cv* cv, gpr_mu* mu, gpr_timespec abs_deadline);
185 gpr_mu mu; /* Protects all fields below.
196 gpr_mu_init(&q->mu);
205 gpr_mu_destroy(&q->mu);
212 gpr_mu_lock(&q->mu);
[all …]
|
| /external/tensorflow/tensorflow/core/kernels/batching_util/ |
| D | serial_device_batch_scheduler_test.cc | 98 mutex mu; in TEST() local
101 auto queue_callback = [&mu, &processed_batches, &finish_processing]( in TEST()
105 mu.lock(); in TEST()
107 mu.unlock(); in TEST()
134 mutex mu; in TEST() local
141 options.get_pending_on_serial_device = [&mu, &pending]() { in TEST()
142 mutex_lock l(mu); in TEST()
150 auto queue_callback = [&mu, &processed_batches, &start_processing, &pending, in TEST()
156 mutex_lock l(mu); in TEST()
163 mutex_lock l(mu); in TEST()
[all …]
|
| /external/tensorflow/tensorflow/contrib/distributions/python/kernel_tests/ |
| D | vector_laplace_diag_test.py | 39 mu = -1.
43 ds.VectorLaplaceDiag(mu, diag)
46 mu = [-1.]
49 dist = ds.VectorLaplaceDiag(mu, diag, validate_args=True)
57 mu = array_ops.zeros((1, 3))
60 base_dist = ds.VectorLaplaceDiag(mu, diag, validate_args=True)
69 mu = [-1., 1]
72 dist = ds.VectorLaplaceDiag(mu, diag, validate_args=True)
73 self.assertAllEqual(mu, dist.mean().eval())
76 mu = [-1.]
[all …]
|
| D | mvn_diag_test.py | 46 mu = -1.
50 ds.MultivariateNormalDiag(mu, diag)
53 mu = [-1.]
56 dist = ds.MultivariateNormalDiag(mu, diag, validate_args=True)
64 mu = array_ops.zeros((1, 3))
67 base_dist = ds.MultivariateNormalDiag(mu, diag, validate_args=True)
76 mu = [-1., 1]
79 dist = ds.MultivariateNormalDiag(mu, diag, validate_args=True)
80 self.assertAllEqual(mu, dist.mean().eval())
83 mu = [-1.]
[all …]
|
| D | vector_exponential_diag_test.py | 38 mu = -1.
42 ds.VectorExponentialDiag(mu, diag)
45 mu = [-1.]
48 dist = ds.VectorExponentialDiag(mu, diag, validate_args=True)
52 mu = [-1., 1]
55 dist = ds.VectorExponentialDiag(mu, diag, validate_args=True)
59 mu = [-1.]
62 dist = ds.VectorExponentialDiag(mu, diag, validate_args=True)
66 mu = [-1.]
69 dist = ds.VectorExponentialDiag(mu, diag, validate_args=True)
[all …]
|
| /external/syzkaller/vendor/google.golang.org/grpc/internal/channelz/ |
| D | funcs.go | 58 mu sync.RWMutex member
63 d.mu.Lock()
65 d.mu.Unlock()
69 d.mu.RLock()
70 defer d.mu.RUnlock()
235 mu sync.RWMutex member
245 c.mu.Lock()
248 c.mu.Unlock()
252 c.mu.Lock()
260 c.mu.Unlock()
[all …]
|
| /external/clang/docs/ |
| D | ThreadSafetyAnalysis.rst | 20 *guarded by* the mutex ``mu``, then the analysis will issue a warning whenever
21 a piece of code reads or writes to ``foo`` without first locking ``mu``.
35 Mutex mu;
36 int balance GUARDED_BY(mu);
39 balance += amount; // WARNING! Cannot write balance without locking mu.
42 void withdrawImpl(int amount) REQUIRES(mu) {
43 balance -= amount; // OK. Caller must have locked mu.
48 mu.Lock();
49 withdrawImpl(amount); // OK. We've locked mu.
50 } // WARNING! Failed to unlock mu.
[all …]
|
| /external/tensorflow/tensorflow/python/kernel_tests/distributions/ |
| D | normal_test.py | 68 mu = array_ops.zeros(mu_shape)
72 self.evaluate(array_ops.shape(normal_lib.Normal(mu, sigma).sample())))
103 mu = array_ops.zeros((10, 3))
105 normal = normal_lib.NormalWithSoftplusScale(loc=mu, scale=rho)
106 self.assertAllEqual(self.evaluate(mu), self.evaluate(normal.loc))
113 mu = constant_op.constant([3.0] * batch_size)
116 normal = normal_lib.Normal(loc=mu, scale=sigma)
138 expected_log_pdf = stats.norm(self.evaluate(mu),
146 mu = constant_op.constant([[3.0, -3.0]] * batch_size)
150 normal = normal_lib.Normal(loc=mu, scale=sigma)
[all …]
|