OLD | NEW |
1 /* Copyright (c) 2010, Google Inc. | 1 /* |
| 2 * |
| 3 * Copyright 2015-2016, Google Inc. |
2 * All rights reserved. | 4 * All rights reserved. |
3 * | 5 * |
4 * Redistribution and use in source and binary forms, with or without | 6 * Redistribution and use in source and binary forms, with or without |
5 * modification, are permitted provided that the following conditions are | 7 * modification, are permitted provided that the following conditions are |
6 * met: | 8 * met: |
7 * | 9 * |
8 * * Redistributions of source code must retain the above copyright | 10 * * Redistributions of source code must retain the above copyright |
9 * notice, this list of conditions and the following disclaimer. | 11 * notice, this list of conditions and the following disclaimer. |
10 * * Redistributions in binary form must reproduce the above | 12 * * Redistributions in binary form must reproduce the above |
11 * copyright notice, this list of conditions and the following disclaimer | 13 * copyright notice, this list of conditions and the following disclaimer |
12 * in the documentation and/or other materials provided with the | 14 * in the documentation and/or other materials provided with the |
13 * distribution. | 15 * distribution. |
14 * * Neither the name of Google Inc. nor the names of its | 16 * * Neither the name of Google Inc. nor the names of its |
15 * contributors may be used to endorse or promote products derived from | 17 * contributors may be used to endorse or promote products derived from |
16 * this software without specific prior written permission. | 18 * this software without specific prior written permission. |
17 * | 19 * |
18 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS | 20 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS |
19 * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT | 21 * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT |
20 * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR | 22 * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR |
21 * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT | 23 * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT |
22 * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, | 24 * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, |
23 * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT | 25 * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT |
24 * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, | 26 * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, |
25 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY | 27 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY |
26 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT | 28 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT |
27 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE | 29 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE |
28 * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. | 30 * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. |
29 * | 31 * |
30 * --- | |
31 * This file is an internal part spinlock.cc and once.cc | |
32 * It may not be used directly by code outside of //base. | |
33 */ | 32 */ |
34 | 33 |
35 #ifndef BASE_SPINLOCK_INTERNAL_H_ | 34 #ifndef GRPC_INTERNAL_CORE_IOMGR_POLLSET_SET_H |
36 #define BASE_SPINLOCK_INTERNAL_H_ | 35 #define GRPC_INTERNAL_CORE_IOMGR_POLLSET_SET_H |
37 | 36 |
38 #include <config.h> | 37 #include "src/core/iomgr/pollset.h" |
39 #include "base/basictypes.h" | |
40 #include "base/atomicops.h" | |
41 | 38 |
42 namespace base { | 39 /* A grpc_pollset_set is a set of pollsets that are interested in an |
43 namespace internal { | 40 action. Adding a pollset to a pollset_set automatically adds any |
| 41 fd's (etc) that have been registered with the set_set to that pollset. |
| 42 Registering fd's automatically adds them to all current pollsets. */ |
44 | 43 |
45 // SpinLockWait() waits until it can perform one of several transitions from | 44 typedef struct grpc_pollset_set grpc_pollset_set; |
46 // "from" to "to". It returns when it performs a transition where done==true. | |
47 struct SpinLockWaitTransition { | |
48 int32 from; | |
49 int32 to; | |
50 bool done; | |
51 }; | |
52 | 45 |
53 // Wait until *w can transition from trans[i].from to trans[i].to for some i | 46 grpc_pollset_set *grpc_pollset_set_create(void); |
54 // satisfying 0<=i<n && trans[i].done, atomically make the transition, | 47 void grpc_pollset_set_destroy(grpc_pollset_set *pollset_set); |
55 // then return the old value of *w. Make any other atomic tranistions | 48 void grpc_pollset_set_add_pollset(grpc_exec_ctx *exec_ctx, |
56 // where !trans[i].done, but continue waiting. | 49 grpc_pollset_set *pollset_set, |
57 int32 SpinLockWait(volatile Atomic32 *w, int n, | 50 grpc_pollset *pollset); |
58 const SpinLockWaitTransition trans[]); | 51 void grpc_pollset_set_del_pollset(grpc_exec_ctx *exec_ctx, |
59 void SpinLockWake(volatile Atomic32 *w, bool all); | 52 grpc_pollset_set *pollset_set, |
60 void SpinLockDelay(volatile Atomic32 *w, int32 value, int loop); | 53 grpc_pollset *pollset); |
| 54 void grpc_pollset_set_add_pollset_set(grpc_exec_ctx *exec_ctx, |
| 55 grpc_pollset_set *bag, |
| 56 grpc_pollset_set *item); |
| 57 void grpc_pollset_set_del_pollset_set(grpc_exec_ctx *exec_ctx, |
| 58 grpc_pollset_set *bag, |
| 59 grpc_pollset_set *item); |
61 | 60 |
62 } // namespace internal | 61 #endif /* GRPC_INTERNAL_CORE_IOMGR_POLLSET_H */ |
63 } // namespace base | |
64 #endif | |
OLD | NEW |