| /third_party/ltp/testcases/kernel/syscalls/ipc/msgget/ |
| D | msgget03.c | 9 * message queues.
24 static int *queues; variable
49 queues = SAFE_MALLOC(maxmsgs * sizeof(int)); in setup()
52 queues[num] = -1; in setup()
56 queues[num] = res; in setup()
59 tst_res(TINFO, "The maximum number of message queues (%d) reached", in setup()
67 if (!queues) in cleanup()
71 if (queues[num] != -1) in cleanup()
72 SAFE_MSGCTL(queues[num], IPC_RMID, NULL); in cleanup()
75 free(queues); in cleanup()
|
| /third_party/ltp/testcases/kernel/uevents/ |
| D | uevent02.c | 59 .msg = "add@/devices/virtual/net/ltp-tun0/queues/rx-0", in verify_uevent()
63 "DEVPATH=/devices/virtual/net/ltp-tun0/queues/rx-0", in verify_uevent()
64 "SUBSYSTEM=queues", in verify_uevent()
69 .msg = "add@/devices/virtual/net/ltp-tun0/queues/tx-0", in verify_uevent()
73 "DEVPATH=/devices/virtual/net/ltp-tun0/queues/tx-0", in verify_uevent()
74 "SUBSYSTEM=queues", in verify_uevent()
79 .msg = "remove@/devices/virtual/net/ltp-tun0/queues/rx-0", in verify_uevent()
83 "DEVPATH=/devices/virtual/net/ltp-tun0/queues/rx-0", in verify_uevent()
84 "SUBSYSTEM=queues", in verify_uevent()
89 .msg = "remove@/devices/virtual/net/ltp-tun0/queues/tx-0", in verify_uevent()
[all …]
|
| /third_party/gstreamer/gstreamer/plugins/elements/ |
| D | gstmultiqueue.h | 60 /* number of queues */
63 /* The list of individual queues */
64 GList *queues; member
78 /* queues lock). Protects nbqueues, queues, global */
95 /* signals emitted when ALL queues are either full or empty */
|
| D | gstmultiqueue.c | 43 * * If more than one stream is used with the element, the streams' queues
75 * other queues.
77 * The #GstMultiQueue::underrun signal is emitted when all of the queues
79 * queues is filled.
233 * there is data in the queues. Normally, the byte and time limits are not hit
472 * no data in any of the queues inside the multiqueue instance (underrun). in gst_multi_queue_class_init()
485 * Reports that one of the queues in the multiqueue is full (overrun). in gst_multi_queue_class_init()
519 "Amount of data the queues can grow if one of them is empty (bytes, 0=disable)" in gst_multi_queue_class_init()
525 "Amount of buffers the queues can grow if one of them is empty (0=disable)" in gst_multi_queue_class_init()
531 "Amount of time the queues can grow if one of them is empty (in ns, 0=disable)" in gst_multi_queue_class_init()
[all …]
|
| /third_party/python/Doc/library/ |
| D | asyncio-queue.rst | 3 .. _asyncio-queues:
6 Queues title
9 **Source code:** :source:`Lib/asyncio/queues.py`
13 asyncio queues are designed to be similar to classes of the
14 :mod:`queue` module. Although asyncio queues are not thread-safe,
17 Note that methods of asyncio queues don't have a *timeout* parameter;
153 Queues can be used to distribute workload between several
|
| D | asyncio-api-index.rst | 73 Queues chapter
76 Queues should be used to distribute work amongst multiple asyncio Tasks,
99 * See also the :ref:`Queues documentation page <asyncio-queues>`.
|
| D | asyncio.rst | 28 database connection libraries, distributed task queues, etc.
42 * distribute tasks via :ref:`queues <asyncio-queues>`;
|
| D | datatypes.rst | 8 types such as dates and times, fixed-type arrays, heap queues, double-ended
9 queues, and enumerations.
|
| /third_party/boost/libs/thread/doc/ |
| D | sync_queues_ref.qbk | 9 [section:synchronized_queues Synchronized Queues -- EXPERIMENTAL]
13 ….org/JTC1/SC22/WG21/docs/papers/2013/n3533.html [*N3533 - C++ Concurrent Queues]] C++1y proposal f…
19 Queues provide a mechanism for communicating data between components of a system.
21 … elements with other queue operations. So, concurrent pushes and pops on queues require a differen…
30 Concurrent queues are a well know mechanism for communicating data between different threads.
32 Concurrent queues have inherently copy/move semantics for the data handling operation. Reference-re…
46 [section:bounded_unbounded Bounded-Unbounded Queues]
52 [section:locking Locking/Lock-free Queues]
54 Locking queues can by nature block waiting for the queue to be non-empty or non-full.
56 …queues will have some trouble waiting for the queue to be non-empty or non-full queues. These queu…
[all …]
|
| /third_party/boost/boost/graph/distributed/ |
| D | queue.hpp | 46 * Synchronization of distributed queues occurs in the @ref empty and
67 * queues, so when that process finishes execution of the loop body
69 * may have nonempty local queues to execute. Once all local queues
202 /** Synchronize the distributed queue and determine if all queues
205 * \returns \c true when all local queues are empty, or false if at least
206 * one of the local queues is nonempty.
248 * This function will synchronize all of the local queues for a given
251 * synchronization of distributed queues occurs via the @c empty or @c
|
| /third_party/grpc/src/cpp/server/ |
| D | server_builder.cc | 272 // needs to create some completion queues to listen for incoming requests. in BuildAndStart()
273 // 'sync_server_cqs' are those internal completion queues. in BuildAndStart()
275 // This is different from the completion queues added to the server via in BuildAndStart()
276 // ServerBuilder's AddCompletionQueue() method (those completion queues in BuildAndStart()
308 // Create completion queues to listen to incoming rpc requests in BuildAndStart()
340 // Register all the completion queues with the server. i.e in BuildAndStart()
341 // 1. sync_server_cqs: internal completion queues created IF this is a sync in BuildAndStart()
343 // 2. cqs_: Completion queues added via AddCompletionQueue() call in BuildAndStart()
358 // listening to incoming channels. Such completion queues must be registered in BuildAndStart()
359 // as non-listening queues. In debug mode, these should have their server list in BuildAndStart()
[all …]
|
| /third_party/boost/boost/numeric/ublas/opencl/ |
| D | misc.hpp | 34 1, //number of command queues in a_sum()
47 1, //number of command queues in a_sum()
60 1, //number of command queues in a_sum()
73 1, //number of command queues in a_sum()
124 1, //number of command queues in norm_2()
137 1, //number of command queues in norm_2()
150 1, //number of command queues in norm_2()
163 1, //number of command queues in norm_2()
|
| /third_party/Linux_Kernel/include/linux/ |
| D | ipc_namespace.h | 49 /* # queues in this ns, protected by mq_lock */
90 * Per app minimum openable message queues - 8. This does not map well
91 * to the fact that we limit the number of queues on a per namespace
93 * that no given app should have a hard time opening 8 queues.
|
| /third_party/ffmpeg/libavfilter/ |
| D | framequeue.h | 39 * Structure to hold global options and statistics for frame queues.
42 * frame queues, including memory consumption caps.
77 * Pre-allocated bucket for queues of size 1.
133 * Must not be used with empty queues.
|
| /third_party/flutter/engine/flutter/fml/ |
| D | task_runner.cc | 53 auto queues = MessageLoopTaskQueues::GetInstance(); in RunsTasksOnCurrentThread() local
54 if (queues->Owns(current_queue_id, loop_queue_id)) { in RunsTasksOnCurrentThread()
57 if (queues->Owns(loop_queue_id, current_queue_id)) { in RunsTasksOnCurrentThread()
|
| /third_party/ltp/testcases/open_posix_testsuite/ |
| D | BUILD | 34 Message Queues
36 POSIX message queues have been available in FreeBSD since 6.x. Please add:
106 Message Queues
115 To build against the posix1b message queues, see the semaphores information for posix1b.
120 To build against the Michal Wronski/Krzysztof Benedyczak message queues,
|
| /third_party/grpc/include/grpcpp/ |
| D | server_impl.h | 168 /// \param sync_server_cqs The completion queues to use if the server is a
170 /// these queues
181 /// server completion queues passed via sync_server_cqs param.
197 /// \param cqs Completion queues for handling asynchronous services. The
198 /// caller is required to keep all completion queues live until the server is
200 /// \param num_cqs How many completion queues does \a cqs hold.
315 /// The following completion queues are ONLY used in case of Sync API
317 /// these completion queues to poll for new RPCs
|
| /third_party/ltp/testcases/open_posix_testsuite/Documentation/ |
| D | COVERAGE.mqueues | 1 Coverage-Area: Message Queues (MSG)
5 COVERAGE DOCUMENT FOR MESSAGE QUEUES
8 This document lists the items that will be tested for POSIX message queues.
|
| /third_party/boost/libs/heap/doc/ |
| D | heap.qbk | 32 _heap_ is an implementation of priority queues. Priority queues are queue data structures, that ord…
49 Priority queues are queues of objects, that are ordered by their priority. They support the operati…
52 [note _heap_ implements priority queues as max-heaps to be consistent with the STL heap functions. …
136 Priority queues provide iterators, that can be used to traverse their elements. All heap iterators …
162 [section:comparing Comparing Priority Queues & Equivalence]
173 [section:merge Merging Priority Queues]
176 [h3 Mergable Priority Queues]
205 Some priority queues of _heap_ are mutable, that means the priority of their elements can be change…
|
| /third_party/ltp/testcases/kernel/syscalls/ipc/lib/ |
| D | libipc.c | 177 * Get the number of message queues already in use
194 "calculate used message queues"); in get_used_msgqueues()
200 * Get the max number of message queues allowed on system
207 /* Get the max number of message queues allowed on system */ in get_max_msgqueues()
|
| /third_party/ffmpeg/libavutil/ |
| D | hwcontext_vulkan.h | 61 * nb_graphics_queues indicates how many queues were enabled for the
67 * Queue family index to use for transfer operations, and the amount of queues
75 * Queue family index for compute ops, and the amount of queues enabled.
76 * In case there are no dedicated compute queues, nb_comp_queues must be
|
| /third_party/flutter/skia/fuzz/ |
| D | coverage | 53 QUEUES=("$1/api_parse_path/fuzzer0/queue/*" "$1/color_deserialize/fuzzer0/queue/*" "$1/skcodec_scal…
60 for i in `seq ${#QUEUES[@]}`
62 FILES=${QUEUES[i]}
|
| /third_party/python/Lib/asyncio/ |
| D | __init__.py | 16 from .queues import *
34 queues.__all__ +
|
| /third_party/grpc/doc/core/ |
| D | epoll-polling-engine.md | 26 …ks associated with that event. The thread that performs the work finally queues a completion event…
42 * A gRPC server can have multiple server completion queues (i.e completion queues which are used to…
45 * Every listening socket's fd is added to all the server completion queues' pollsets. (Currently we…
51 …ccept()` on the new incoming channel) is added to all the server completion queues' pollsets [^5]).
|
| /third_party/grpc/src/csharp/Grpc.Core/Internal/ |
| D | GrpcThreadPool.cs | 31 /// Pool of threads polling on a set of completions queues.
56 /// Creates a thread pool threads polling on a set of completions queues.
69 "Thread pool size cannot be smaller than the number of completion queues used."); in GrpcThreadPool()
125 /// Threads can either stop because all completion queues shut down or
|