| /third_party/mesa3d/src/asahi/compiler/ |
| D | agx_lower_parallel_copy.c | 256 struct agx_copy *blocking = &ctx->entries[j]; in agx_emit_parallel_copies() local
258 if (blocking->done) in agx_emit_parallel_copies()
261 if (blocking->src <= entry->dest && in agx_emit_parallel_copies()
262 blocking->src + 1 >= entry->dest && in agx_emit_parallel_copies()
263 agx_size_align_16(blocking->size) == 2) { in agx_emit_parallel_copies()
264 split_32bit_copy(ctx, blocking); in agx_emit_parallel_copies()
275 struct agx_copy *blocking = &ctx->entries[j]; in agx_emit_parallel_copies() local
276 if (blocking->src >= entry->dest && in agx_emit_parallel_copies()
277 blocking->src < entry->dest + agx_size_align_16(entry->size)) { in agx_emit_parallel_copies()
278 blocking->src = entry->src + (blocking->src - entry->dest); in agx_emit_parallel_copies()
|
| /third_party/ltp/runtest/ |
| D | ipc | 6 # using blocking I/O
9 # using non-blocking I/O
13 # using blocking I/O
16 # using non-blocking I/O
19 # using blocking I/O
22 # using blocking I/O
25 # using non-blocking I/O
29 # using non-blocking I/O
|
| /third_party/python/Modules/_multiprocessing/clinic/ |
| D | semaphore.c.h | 17 _multiprocessing_SemLock_acquire_impl(SemLockObject *self, int blocking,
28 int blocking = 1; in _multiprocessing_SemLock_acquire() local
39 blocking = _PyLong_AsInt(args[0]); in _multiprocessing_SemLock_acquire()
40 if (blocking == -1 && PyErr_Occurred()) { in _multiprocessing_SemLock_acquire()
49 return_value = _multiprocessing_SemLock_acquire_impl(self, blocking, timeout_obj); in _multiprocessing_SemLock_acquire()
91 _multiprocessing_SemLock_acquire_impl(SemLockObject *self, int blocking,
102 int blocking = 1; in _multiprocessing_SemLock_acquire() local
113 blocking = _PyLong_AsInt(args[0]); in _multiprocessing_SemLock_acquire()
114 if (blocking == -1 && PyErr_Occurred()) { in _multiprocessing_SemLock_acquire()
123 return_value = _multiprocessing_SemLock_acquire_impl(self, blocking, timeout_obj); in _multiprocessing_SemLock_acquire()
|
| /third_party/skia/third_party/externals/angle2/src/libANGLE/renderer/ |
| D | CLCommandQueueImpl.h | 27 bool blocking,
35 bool blocking,
43 bool blocking,
56 bool blocking,
97 bool blocking,
106 bool blocking,
116 bool blocking,
157 bool blocking,
|
| /third_party/skia/third_party/externals/angle2/src/libANGLE/renderer/cl/ |
| D | CLCommandQueueCL.h | 28 bool blocking,
36 bool blocking,
44 bool blocking,
57 bool blocking,
98 bool blocking,
107 bool blocking,
117 bool blocking,
158 bool blocking,
|
| D | CLCommandQueueCL.cpp | 73 bool blocking, in enqueueReadBuffer() argument
81 const cl_bool block = blocking ? CL_TRUE : CL_FALSE; in enqueueReadBuffer()
97 bool blocking, in enqueueWriteBuffer() argument
105 const cl_bool block = blocking ? CL_TRUE : CL_FALSE; in enqueueWriteBuffer()
121 bool blocking, in enqueueReadBufferRect() argument
134 const cl_bool block = blocking ? CL_TRUE : CL_FALSE; in enqueueReadBufferRect()
151 bool blocking, in enqueueWriteBufferRect() argument
164 const cl_bool block = blocking ? CL_TRUE : CL_FALSE; in enqueueWriteBufferRect()
256 bool blocking, in enqueueMapBuffer() argument
265 const cl_bool block = blocking ? CL_TRUE : CL_FALSE; in enqueueMapBuffer()
[all …]
|
| /third_party/vk-gl-cts/framework/delibs/decpp/ |
| D | deBlockBuffer.hpp | 72 int writeToCurrentBlock (int numElements, const T* elements, bool blocking);
73 int readFromCurrentBlock(int numElements, T* elements, bool blocking);
175 int BlockBuffer<T>::writeToCurrentBlock (int numElements, const T* elements, bool blocking) in writeToCurrentBlock() argument
182 if (blocking) in writeToCurrentBlock()
218 int BlockBuffer<T>::readFromCurrentBlock (int numElements, T* elements, bool blocking) in readFromCurrentBlock() argument
225 if (blocking) in readFromCurrentBlock()
|
| /third_party/skia/third_party/externals/angle2/src/libANGLE/ |
| D | CLCommandQueue.cpp | 144 const bool blocking = blockingRead != CL_FALSE; in enqueueReadBuffer() local
151 mImpl->enqueueReadBuffer(buf, blocking, offset, size, ptr, waitEvents, eventCreateFuncPtr); in enqueueReadBuffer()
167 const bool blocking = blockingWrite != CL_FALSE; in enqueueWriteBuffer() local
174 mImpl->enqueueWriteBuffer(buf, blocking, offset, size, ptr, waitEvents, eventCreateFuncPtr); in enqueueWriteBuffer()
195 const bool blocking = blockingRead != CL_FALSE; in enqueueReadBufferRect() local
202 buf, blocking, bufferOrigin, hostOrigin, region, bufferRowPitch, bufferSlicePitch, in enqueueReadBufferRect()
224 const bool blocking = blockingWrite != CL_FALSE; in enqueueWriteBufferRect() local
231 buf, blocking, bufferOrigin, hostOrigin, region, bufferRowPitch, bufferSlicePitch, in enqueueWriteBufferRect()
322 const bool blocking = blockingMap != CL_FALSE; in enqueueMapBuffer() local
328 void *const map = mImpl->enqueueMapBuffer(buf, blocking, mapFlags, offset, size, waitEvents, in enqueueMapBuffer()
[all …]
|
| /third_party/selinux/libselinux/src/ |
| D | avc_internal.c | 101 int avc_netlink_open(int blocking) in avc_netlink_open() argument
112 if (!blocking && fcntl(fd, F_SETFL, O_NONBLOCK)) { in avc_netlink_open()
142 static int avc_netlink_receive(void *buf, unsigned buflen, int blocking) in avc_netlink_receive() argument
151 rc = poll(&pfd, 1, (blocking ? -1 : 0)); in avc_netlink_receive()
154 if (rc == 0 && !blocking) { in avc_netlink_receive()
|
| /third_party/mesa3d/src/freedreno/ir3/ |
| D | ir3_lower_parallelcopy.c | 442 struct copy_entry *blocking = &ctx->entries[j]; in _handle_copies() local
444 if (blocking->done) in _handle_copies()
447 if (blocking->src.reg <= entry->dst && in _handle_copies()
448 blocking->src.reg + 1 >= entry->dst && in _handle_copies()
449 !(blocking->flags & IR3_REG_HALF)) { in _handle_copies()
450 split_32bit_copy(ctx, blocking); in _handle_copies()
461 struct copy_entry *blocking = &ctx->entries[j]; in _handle_copies() local
462 if (blocking->src.reg >= entry->dst && in _handle_copies()
463 blocking->src.reg < entry->dst + copy_entry_size(entry)) { in _handle_copies()
464 blocking->src.reg = in _handle_copies()
[all …]
|
| /third_party/ltp/testcases/open_posix_testsuite/conformance/interfaces/mq_timedreceive/ |
| D | 18-1.c | 38 static int blocking; variable
42 blocking = 1; in exit_handler()
94 if (failure == 1 || blocking == 1) { in main()
|
| D | 18-2.c | 39 static int blocking; variable
43 blocking = 1; in exit_handler()
96 if (failure == 1 || blocking == 1) { in main()
|
| D | 5-2.c | 38 static int blocking; variable
42 blocking = 1; in exit_handler()
95 if (failure == 1 || blocking == 1) { in main()
|
| D | 8-1.c | 35 static int blocking; variable
39 blocking = 1; in exit_handler()
104 if (failure == 1 || blocking == 1) { in main()
|
| /third_party/ltp/testcases/open_posix_testsuite/conformance/interfaces/mq_send/ |
| D | 5-2.c | 103 int j, k, blocking = 0; in main() local
108 blocking = 1; //set blocking flag in main()
114 if (blocking != 1) { in main()
|
| /third_party/ltp/testcases/open_posix_testsuite/conformance/interfaces/mq_timedsend/ |
| D | 5-2.c | 109 int j, k, blocking = 0; in main() local
114 blocking = 1; //set blocking flag in main()
120 if (blocking != 1) { in main()
|
| /third_party/pulseaudio/src/pulsecore/ |
| D | pipe.c | 37 static int set_block(int fd, int blocking) { in set_block() argument
47 if (blocking) in set_block()
61 arg = !blocking; in set_block()
|
| /third_party/python/Python/ |
| D | bootstrap_hash.c | 111 py_getrandom(void *buffer, Py_ssize_t size, int blocking, int raise) in py_getrandom() argument
125 flags = blocking ? 0 : GRND_NONBLOCK; in py_getrandom()
180 if (errno == EAGAIN && !raise && !blocking) { in py_getrandom()
498 pyurandom(void *buffer, Py_ssize_t size, int blocking, int raise) in pyurandom() argument
523 res = py_getrandom(buffer, size, blocking, raise); in pyurandom()
|
| /third_party/node/deps/npm/node_modules/set-blocking/ |
| D | index.js | 1 module.exports = function (blocking) { argument
4 stream._handle.setBlocking(blocking)
|
| /third_party/mesa3d/src/gallium/frontends/clover/api/ |
| D | transfer.cpp | 360 clEnqueueReadBuffer(cl_command_queue d_q, cl_mem d_mem, cl_bool blocking, in clEnqueueReadBuffer() argument
382 if (blocking) in clEnqueueReadBuffer()
393 clEnqueueWriteBuffer(cl_command_queue d_q, cl_mem d_mem, cl_bool blocking, in clEnqueueWriteBuffer() argument
415 if (blocking) in clEnqueueWriteBuffer()
426 clEnqueueReadBufferRect(cl_command_queue d_q, cl_mem d_mem, cl_bool blocking, in clEnqueueReadBufferRect() argument
455 if (blocking) in clEnqueueReadBufferRect()
466 clEnqueueWriteBufferRect(cl_command_queue d_q, cl_mem d_mem, cl_bool blocking, in clEnqueueWriteBufferRect() argument
495 if (blocking) in clEnqueueWriteBufferRect()
621 clEnqueueReadImage(cl_command_queue d_q, cl_mem d_mem, cl_bool blocking, in clEnqueueReadImage() argument
647 if (blocking) in clEnqueueReadImage()
[all …]
|
| /third_party/skia/third_party/externals/swiftshader/third_party/marl/ |
| D | README.md | 186 …thread. Forgetting to unbind will result in the `marl::Scheduler` destructor blocking indefinitely.
188 #### Don't use externally blocking calls in marl tasks
192 …blocking function on a marl worker thread will prevent that worker thread from being able to switc…
194 Short blocking calls are acceptable, such as a mutex lock to access a data structure. However be ca…
196 If you need to make a blocking call from a marl worker thread, you may wish to use [`marl::blocking…
|
| /third_party/skia/third_party/externals/opengl-registry/extensions/SGIX/ |
| D | SGIX_async.txt | 31 1) Asynchronous commands are non-blocking. For example, an
33 immediately rather than blocking until the command completes.
61 completed. This extension provides both blocking and non-blocking
145 * Would it be better to define an extension that provides non-blocking
148 Ans: No. Non-blocking commands would require the GL to preserve
151 between a non-blocking command and all subsequent commands
153 commands until the non-blocking command completes, or maintain
221 Implementations of asynchronous commands may also be non-blocking.
222 For example, a non-blocking query command returns control to the
241 completes, and PollAsyncSGIX, which is non-blocking. Both
[all …]
|
| /third_party/openGLES/extensions/SGIX/ |
| D | SGIX_async.txt | 31 1) Asynchronous commands are non-blocking. For example, an
33 immediately rather than blocking until the command completes.
61 completed. This extension provides both blocking and non-blocking
145 * Would it be better to define an extension that provides non-blocking
148 Ans: No. Non-blocking commands would require the GL to preserve
151 between a non-blocking command and all subsequent commands
153 commands until the non-blocking command completes, or maintain
221 Implementations of asynchronous commands may also be non-blocking.
222 For example, a non-blocking query command returns control to the
241 completes, and PollAsyncSGIX, which is non-blocking. Both
[all …]
|
| /third_party/alsa-lib/ |
| D | NOTES | 43 The default behavior of blocking at snd_pcm_open is changed to
44 non-blocking since version 1.0.11. That is, snd_pcm_open() returns
51 For taking back the compatible behavior of open blocking mode, set
|
| /third_party/openssl/doc/man3/ |
| D | BIO_should_retry.pod | 77 If the underlying I/O structure is in a blocking mode almost all current
84 retry even if the underlying I/O structure is blocking, if a handshake
89 While an application may retry a failed non blocking call immediately
98 conditions of several non blocking BIOs in a single select() call
106 is to use non blocking I/O and use a timeout on the select() (or
111 The OpenSSL ASN1 functions cannot gracefully deal with non blocking I/O:
|