| /external/volley/core/src/main/java/com/android/volley/ |
| D | AsyncNetwork.java | 8 * http://www.apache.org/licenses/LICENSE-2.0
29 * https://github.com/google/volley/wiki/Asynchronous-Volley for more details.
48 * Non-blocking method to perform the specified request.
56 * Blocking method to perform network request.
72 response.set(networkResponse); in performRequest()
78 error.set(volleyError); in performRequest()
95 throw new VolleyError("Neither response entry was set"); in performRequest()
100 * This method sets the non blocking executor to be used by the network for non-blocking tasks.
110 * This method sets the blocking executor to be used by the network for potentially blocking
121 * This method sets the scheduled executor to be used by the network for non-blocking tasks to
[all …]
|
| /external/pigweed/pw_clock_tree_mcuxpresso/public/pw_clock_tree_mcuxpresso/ |
| D | clock_tree.h | 7 // https://www.apache.org/licenses/LICENSE-2.0
33 CLOCK_EnableFroClk(CLKCTL0->FRODIVOEN | fro_output_); in DoEnable()
39 CLOCK_EnableFroClk(CLKCTL0->FRODIVOEN & ~fro_output_); in DoDisable()
80 /// Set MCLK IN clock frequency.
86 /// Set MCLK IN clock frequency to 0 Hz.
96 /// Alias for a blocking MCLK IN clock tree element.
99 /// Alias for a non-blocking MCLK IN clock tree element where updates cannot
118 /// Set CLK IN clock frequency.
125 CLKCTL0->SYSOSCBYPASS = kCLOCK_OscClkIn; in DoEnable()
129 /// Set CLK IN clock frequency to 0 Hz.
[all …]
|
| /external/rust/crates/tokio/src/runtime/context/ |
| D | runtime.rs | 15 /// Not in a runtime context **or** a blocking region.
22 /// Tracks that the current thread has entered a blocking function call.
23 pub(crate) blocking: BlockingRegionGuard, field
35 pub(crate) fn enter_runtime<F, R>(handle: &scheduler::Handle, allow_block_in_place: bool, f: F) -> R in enter_runtime()
37 F: FnOnce(&mut BlockingRegionGuard) -> R, in enter_runtime()
43 // Set the entered flag in enter_runtime()
44 c.runtime.set(EnterRuntime::Entered { in enter_runtime()
54 c.rng.set(Some(rng)); in enter_runtime()
57 blocking: BlockingRegionGuard::new(), in enter_runtime()
65 return f(&mut guard.blocking); in enter_runtime()
[all …]
|
| /external/rust/crates/rayon-core/src/ |
| D | latch.rs | 11 /// mechanism. A latch starts as false. Eventually someone calls `set()` and
12 /// it becomes true. You can test if it has been set by calling `probe()`.
15 /// that will wait until the latch is set, blocking efficiently. That
19 /// The intention is that `set()` is called once, but `probe()` may be
21 /// effects that occurred before `set()` become visible.
30 /// - Once `probe()` returns true, all memory effects from the `set()`
31 /// are visible (in other words, the set should synchronize-with
33 /// - Once `set()` occurs, the next `probe()` *will* observe it. This
34 /// typically requires a seq-cst ordering. See [the "tickle-then-get-sleepy" scenario in the sleep
35 /// README](/src/sleep/README.md#tickle-then-get-sleepy) for details.
[all …]
|
| /external/openthread/third_party/mbedtls/repo/include/mbedtls/ |
| D | net_sockets.h | 5 * BSD-style sockets API.
24 * SPDX-License-Identifier: Apache-2.0 OR GPL-2.0-or-later
41 #define MBEDTLS_ERR_NET_SOCKET_FAILED -0x0042
43 #define MBEDTLS_ERR_NET_CONNECT_FAILED -0x0044
45 #define MBEDTLS_ERR_NET_BIND_FAILED -0x0046
47 #define MBEDTLS_ERR_NET_LISTEN_FAILED -0x0048
49 #define MBEDTLS_ERR_NET_ACCEPT_FAILED -0x004A
51 #define MBEDTLS_ERR_NET_RECV_FAILED -0x004C
53 #define MBEDTLS_ERR_NET_SEND_FAILED -0x004E
55 #define MBEDTLS_ERR_NET_CONN_RESET -0x0050
[all …]
|
| /external/libchrome/dbus/ |
| D | bus.h | 2 // Use of this source code is governed by a BSD-style license that can be
12 #include <set>
37 // Bus is used to establish a connection with D-Bus, create object
42 // descriptor used for D-Bus communication. By default, the bus will use
48 // In the D-Bus library, we use the two threads:
50 // - The origin thread: the thread that created the Bus object.
51 // - The D-Bus thread: the thread servicing |dbus_task_runner|.
53 // The origin thread is usually Chrome's UI thread. The D-Bus thread is
54 // usually a dedicated thread for the D-Bus library.
56 // BLOCKING CALLS
[all …]
|
| /external/volley/core/src/main/java/com/android/volley/toolbox/ |
| D | AsyncHttpStack.java | 8 * http://www.apache.org/licenses/LICENSE-2.0
35 * https://github.com/google/volley/wiki/Asynchronous-Volley for more details.
64 * This method sets the non blocking executor to be used by the stack for non-blocking tasks.
73 * This method sets the blocking executor to be used by the stack for potentially blocking
81 /** Gets blocking executor to perform any potentially blocking tasks. */
86 /** Gets non-blocking executor to perform any non-blocking tasks. */
118 entry.set(response); in executeRequest()
129 entry.set(response); in executeRequest()
140 entry.set(response); in executeRequest()
|
| /external/ltp/utils/sctp/func_tests/ |
| D | test_1_to_1_nonblock.c | 2 * Copyright (c) 2003 Hewlett-Packard Development Company, L.P
5 * This file has test cases to test the Non-Blocking mode of connect(),
8 * TEST1: Non blocking accept return EAGAIN if connect is not called
9 * TEST2: Non blocking connect should return EINPROGRESS
10 * TEST3: accept() passes when connect called in Non-blocking mode
11 * TEST4: Non blocking recvmsg should return EAGAIN
12 * TEST5: recvmsg() should succeed if data present to receive in non blocking
29 * the Free Software Foundation, 59 Temple Place - Suite 330,
30 * Boston, MA 02111-1307, USA.
34 * lksctp developers <lksctp-developers@lists.sourceforge.net>
[all …]
|
| /external/mbedtls/include/mbedtls/ |
| D | net_sockets.h | 5 * BSD-style sockets API.
24 * SPDX-License-Identifier: Apache-2.0 OR GPL-2.0-or-later
38 #define MBEDTLS_ERR_NET_SOCKET_FAILED -0x0042
40 #define MBEDTLS_ERR_NET_CONNECT_FAILED -0x0044
42 #define MBEDTLS_ERR_NET_BIND_FAILED -0x0046
44 #define MBEDTLS_ERR_NET_LISTEN_FAILED -0x0048
46 #define MBEDTLS_ERR_NET_ACCEPT_FAILED -0x004A
48 #define MBEDTLS_ERR_NET_RECV_FAILED -0x004C
50 #define MBEDTLS_ERR_NET_SEND_FAILED -0x004E
52 #define MBEDTLS_ERR_NET_CONN_RESET -0x0050
[all …]
|
| /external/sdv/vsomeip/third_party/boost/asio/include/boost/asio/posix/ |
| D | basic_descriptor.hpp | 5 // Copyright (c) 2003-2021 Christopher M. Kohlhoff (chris at kohlhoff dot com)
162 /// Move-construct a descriptor from another.
169 * @note Following the move, the moved-from object is in the same state as if
178 /// Move-assign a descriptor from another.
185 * @note Following the move, the moved-from object is in the same state as if
252 * @param ec Set to indicate what error occurred, if any.
290 * @param ec Set to indicate what error occurred, if any. Note that, even if
346 * @param ec Set to indicate what error occurred, if any.
390 * @param ec Set to indicate what error occurred, if any.
419 /// Gets the non-blocking mode of the descriptor.
[all …]
|
| /external/ltp/testcases/open_posix_testsuite/conformance/interfaces/mq_timedsend/ |
| D | 5-2.c | 3 * Created by: julie.n.fleischer REMOVE-THIS AT intel DOT com
10 * Test that if the message queue is full and O_NONBLOCK is not set,
60 sprintf(gqname, "/mq_timedsend_5-2_%d", getpid()); in main()
65 if (gqueue == (mqd_t) - 1) { in main()
71 * situations -- parent uses to stop it's sleep and wait again for in main()
83 /* set up timeout to be as long as possible */ in main()
87 sleep(1); // give parent time to set up handler in main()
90 strlen(msgptr), 1, &ts) == -1) { in main()
109 int j, k, blocking = 0; in main() local
113 /* If sleep finished, child is probably blocking */ in main()
[all …]
|
| /external/pigweed/pw_clock_tree/public/pw_clock_tree/ |
| D | clock_tree.h | 7 // https://www.apache.org/licenses/LICENSE-2.0
91 uint32_t DecRef() { return --ref_count_; } in DecRef()
153 if (this->IncRef() > 1) { in Acquire()
159 Status status = this->DoEnable(); in Acquire()
161 this->DecRef(); in Acquire()
170 if (this->DecRef() > 0) { in Release()
176 Status status = this->DoDisable(); in Release()
178 this->IncRef(); in Release()
184 /// Class that represents a no-op clock source clock tree element that can
230 if (this->ref_count() == 0) { in UpdateSource()
[all …]
|
| /external/parameter-framework/asio-1.10.6/include/asio/ |
| D | basic_socket.hpp | 5 // Copyright (c) 2003-2015 Christopher M. Kohlhoff (chris at kohlhoff dot com)
31 * stream-oriented and datagram-oriented sockets.
87 this->get_service().open(this->get_implementation(), protocol, ec); in basic_socket()
112 this->get_service().open(this->get_implementation(), protocol, ec); in basic_socket()
114 this->get_service().bind(this->get_implementation(), endpoint, ec); in basic_socket()
136 this->get_service().assign(this->get_implementation(), in basic_socket()
141 /// Move-construct a basic_socket from another.
148 * @note Following the move, the moved-from object is in the same state as if
157 /// Move-assign a basic_socket from another.
164 * @note Following the move, the moved-from object is in the same state as if
[all …]
|
| /external/cronet/net/third_party/quiche/src/quiche/quic/core/io/ |
| D | socket_posix.inc | 2 // Use of this source code is governed by a BSD-style license that can be
24 // accept4() is a Linux-specific extension that is available in glibc 2.10+.
86 // any other would-be-unavailable Statuses to `absl::StatusCode::kNotFound`.
139 << "Could not set flags for socket " << fd << " with error: " << status;
204 absl::Status SetSocketBlocking(SocketFd fd, bool blocking) {
205 if (blocking) {
213 SocketProtocol protocol, bool blocking) {
216 if (!blocking) {
223 if (!socket.ok() || blocking) {
228 // If non-blocking could not be set directly on socket creation, need to do
[all …]
|
| D | event_loop_connecting_client_socket.cc | 2 // Use of this source code is governed by a BSD-style license that can be
68 status = socket_api::SetSocketBlocking(descriptor_, /*blocking=*/true); in ConnectBlocking()
71 << "Failed to set socket to address: " << peer_address_.ToString() in ConnectBlocking()
72 << " as blocking for connect with error: " << status; in ConnectBlocking()
81 << "Non-blocking connect to should-be blocking socket to address:" in ConnectBlocking()
93 status = socket_api::SetSocketBlocking(descriptor_, /*blocking=*/false); in ConnectBlocking()
97 << " to non-blocking after connect with error: " << status; in ConnectBlocking()
115 async_visitor_->ConnectComplete(status); in ConnectAsync()
141 async_visitor_->ConnectComplete(absl::CancelledError()); in Disconnect()
145 async_visitor_->ReceiveComplete(absl::CancelledError()); in Disconnect()
[all …]
|
| /external/selinux/libselinux/man/man3/ |
| D | avc_netlink_loop.3 | 1 .\" Hey Emacs! This file is -*- nroff -*- source.
7 avc_netlink_release_fd, avc_netlink_check_nb, avc_netlink_loop \- SELinux
15 .BI "int avc_netlink_open(int " blocking ");"
44 .I blocking
45 argument controls whether the O_NONBLOCK flag is set on the socket descriptor.
47 calls this function internally, specifying non-blocking behavior.
64 returns control of the netlink socket to the userspace AVC, re-enabling
75 enters a loop blocking on the netlink socket and processing messages as they
81 returns a non-negative file descriptor number on success. Other functions
82 with a return value return zero on success. On error, \-1 is returned and
[all …]
|
| /external/ltp/testcases/open_posix_testsuite/conformance/interfaces/mq_send/ |
| D | 5-2.c | 3 * Created by: julie.n.fleischer REMOVE-THIS AT intel DOT com
10 * Test that if the message queue is full and O_NONBLOCK is not set, mq_send()
59 sprintf(gqname, "/mq_send_5-2_%d", getpid()); in main()
64 if (gqueue == (mqd_t) - 1) { in main()
70 * situations -- parent uses to stop it's sleep and wait again for in main()
82 sleep(1); // give parent time to set up handler in main()
84 if (mq_send(gqueue, msgptr, strlen(msgptr), 1) == -1) { in main()
103 int j, k, blocking = 0; in main() local
107 /* If sleep finished, child is probably blocking */ in main()
108 blocking = 1; //set blocking flag in main()
[all …]
|
| /external/libchrome/base/threading/ |
| D | thread_restrictions.cc | 2 // Use of this source code is governed by a BSD-style license that can be
30 << "Function marked as blocking was called from a scope that disallows " in AssertBlockingAllowed()
31 "blocking! If this task is running inside the TaskScheduler, it needs " in AssertBlockingAllowed()
33 "this blocking work asynchronous or, as a last resort, you may use " in AssertBlockingAllowed()
38 g_blocking_disallowed.Get().Set(true); in DisallowBlocking()
43 g_blocking_disallowed.Get().Set(true); in ScopedDisallowBlocking()
48 g_blocking_disallowed.Get().Set(was_disallowed_); in ~ScopedDisallowBlocking()
53 g_blocking_disallowed.Get().Set(false); in ScopedAllowBlocking()
58 g_blocking_disallowed.Get().Set(was_disallowed_); in ~ScopedAllowBlocking()
62 g_base_sync_primitives_disallowed.Get().Set(true); in DisallowBaseSyncPrimitives()
[all …]
|
| /external/libpcap/ |
| D | pcap_setnonblock.3pcap | 22 pcap_setnonblock, pcap_getnonblock \- set or get the state of
23 non-blocking mode on a capture device
42 puts a capture handle into ``non-blocking'' mode, or takes it out
43 of ``non-blocking'' mode, depending on whether the
45 argument is non-zero or zero. It has no effect on ``savefiles''.
55 ``non-blocking'' mode, an attempt to read from the capture descriptor
62 immediately rather than blocking waiting for packets to arrive.
81 a capture handle is not in ``non-blocking mode''; a call to
83 is required in order to put it into ``non-blocking'' mode.
86 returns the current ``non-blocking'' state of the capture descriptor; it
|
| /external/python/cpython2/Doc/library/ |
| D | threading.rst | 1 :mod:`threading` --- Higher-level threading interface
5 :synopsis: Higher-level threading interface.
9 --------------
11 This module constructs higher-level threading interfaces on top of the lower
23 :mod:`multiprocessing` module. However, no schedule has been set for the
32 .. impl-detail::
35 can execute Python code at once (even though certain performance-oriented
38 resources of multi-core machines, you are advised to use
40 if you want to run multiple I/O-bound tasks simultaneously.
62 See :ref:`condition-objects`.
[all …]
|
| /external/cronet/net/spdy/ |
| D | spdy_session_pool.h | 2 // Use of this source code is governed by a BSD-style license that can be
13 #include <set>
35 #include "third_party/abseil-cpp/absl/types/optional.h"
58 // https://tools.ietf.org/html/draft-bishop-httpbis-grease-00.
91 // Constructor - this is called by the SpdySessionPool.
215 // |is_blocking_request_for_session| will be set to |true| if there is not
216 // another "blocking" request already pending. For example, the first request
217 // created will be considered "blocking", but subsequent requests will not as
218 // long as the "blocking" request is not destroyed. Once the "blocking"
219 // request is destroyed, the next created request will be marked "blocking".
[all …]
|
| /external/python/cpython3/Doc/library/ |
| D | threading.rst | 1 :mod:`threading` --- Thread-based parallelism
5 :synopsis: Thread-based parallelism.
9 --------------
11 This module constructs higher-level threading interfaces on top of the lower
20 to push tasks to a background thread without blocking execution of the
23 :mod:`queue` provides a thread-safe interface for exchanging data between
36 .. impl-detail::
40 can execute Python code at once (even though certain performance-oriented
43 resources of multi-core machines, you are advised to use
46 multiple I/O-bound tasks simultaneously.
[all …]
|
| /external/mesa3d/src/gfxstream/host/ |
| D | RenderChannelImpl.h | 7 // http://www.apache.org/licenses/LICENSE-2.0
17 #include "render-utils/RenderChannel.h"
32 uint32_t contextId = -1);
39 // Set the event |callback| to be notified when the host changes the
45 // Set the mask of events the guest wants to be notified of from the
55 // Blocking call that waits until a buffer is ready to be sent from guest to host.
64 // Blocking call that waits until a buffer is ready to be read from host to guest.
76 // Send a buffer to the guest, this call is blocking. On success,
81 // Read data from the guest. If |blocking| is true, the call will be
82 // blocking. On success, move item into |*buffer| and return true. On
[all …]
|
| /external/swiftshader/third_party/marl/ |
| D | README.md | 43 marl::schedule([=] { // All marl primitives are capture-by-value.
49 // Blocking in a task?
78 cd <path-to-marl>
79 git submodule update --init
87 cd <path-to-marl>
90 cmake .. -DMARL_BUILD_EXAMPLES=1 -DMARL_BUILD_TESTS=1
94 The resulting binaries will be found in `<path-to-marl>/build`
101 cd <path-to-marl>
104 emcmake cmake .. -DMARL_BUILD_EXAMPLES=1
105 make hello_task -j 8
[all …]
|
| /external/cronet/net/third_party/quiche/src/quiche/quic/core/qpack/ |
| D | qpack_blocking_manager.h | 2 // Use of this source code is governed by a BSD-style license that can be
10 #include <set>
24 // Class to keep track of blocked streams and blocking dynamic table entries:
25 // https://quicwg.org/base-drafts/draft-ietf-quic-qpack.html#blocked-decoding
26 // https://quicwg.org/base-drafts/draft-ietf-quic-qpack.html#blocked-insertion
51 // Returns true if sending blocking references on stream |stream_id| would not
54 // then it is always allowed to send more blocking references on it.
60 // Returns the index of the blocking entry with the smallest index,
61 // or std::numeric_limits<uint64_t>::max() if there are no blocking entries.
65 // https://quicwg.org/base-drafts/draft-ietf-quic-qpack.html#known-received-count.
[all …]
|