Home
last modified time | relevance | path

Searched refs:blocking (Results 1 - 25 of 97) sorted by relevance

1234

/third_party/mesa3d/src/asahi/compiler/
H A Dagx_lower_parallel_copy.c251 /* Split any blocking copies whose sources are only partially in agx_emit_parallel_copies()
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()
269 /* Update sources of blocking copies. in agx_emit_parallel_copies()
271 * Note: at this point, every blocking copy's source should be in agx_emit_parallel_copies()
275 struct agx_copy *blocking in agx_emit_parallel_copies() local
[all...]
/third_party/python/Modules/_multiprocessing/clinic/
H A Dsemaphore.c.h17 _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_ob in _multiprocessing_SemLock_acquire()
[all...]
/third_party/skia/third_party/externals/angle2/src/libANGLE/renderer/
H A DCLCommandQueueImpl.h27 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/
H A DCLCommandQueueCL.h28 bool blocking,
36 bool blocking,
44 bool blocking,
57 bool blocking,
98 bool blocking,
107 bool blocking,
117 bool blocking,
158 bool blocking,
H A DCLCommandQueueCL.cpp73 bool blocking, in enqueueReadBuffer()
81 const cl_bool block = blocking ? CL_TRUE : CL_FALSE; in enqueueReadBuffer()
97 bool blocking, in enqueueWriteBuffer()
105 const cl_bool block = blocking ? CL_TRUE : CL_FALSE; in enqueueWriteBuffer()
121 bool blocking, in enqueueReadBufferRect()
134 const cl_bool block = blocking ? CL_TRUE : CL_FALSE; in enqueueReadBufferRect()
151 bool blocking, in enqueueWriteBufferRect()
164 const cl_bool block = blocking ? CL_TRUE : CL_FALSE; in enqueueWriteBufferRect()
256 bool blocking, in enqueueMapBuffer()
265 const cl_bool block = blocking in enqueueMapBuffer()
72 enqueueReadBuffer(const cl::Buffer &buffer, bool blocking, size_t offset, size_t size, void *ptr, const cl::EventPtrs &waitEvents, CLEventImpl::CreateFunc *eventCreateFunc) enqueueReadBuffer() argument
96 enqueueWriteBuffer(const cl::Buffer &buffer, bool blocking, size_t offset, size_t size, const void *ptr, const cl::EventPtrs &waitEvents, CLEventImpl::CreateFunc *eventCreateFunc) enqueueWriteBuffer() argument
120 enqueueReadBufferRect(const cl::Buffer &buffer, bool blocking, const size_t bufferOrigin[3], const size_t hostOrigin[3], const size_t region[3], size_t bufferRowPitch, size_t bufferSlicePitch, size_t hostRowPitch, size_t hostSlicePitch, void *ptr, const cl::EventPtrs &waitEvents, CLEventImpl::CreateFunc *eventCreateFunc) enqueueReadBufferRect() argument
150 enqueueWriteBufferRect(const cl::Buffer &buffer, bool blocking, const size_t bufferOrigin[3], const size_t hostOrigin[3], const size_t region[3], size_t bufferRowPitch, size_t bufferSlicePitch, size_t hostRowPitch, size_t hostSlicePitch, const void *ptr, const cl::EventPtrs &waitEvents, CLEventImpl::CreateFunc *eventCreateFunc) enqueueWriteBufferRect() argument
255 enqueueMapBuffer(const cl::Buffer &buffer, bool blocking, cl::MapFlags mapFlags, size_t offset, size_t size, const cl::EventPtrs &waitEvents, CLEventImpl::CreateFunc *eventCreateFunc, cl_int &errorCode) enqueueMapBuffer() argument
280 enqueueReadImage(const cl::Image &image, bool blocking, const size_t origin[3], const size_t region[3], size_t rowPitch, size_t slicePitch, void *ptr, const cl::EventPtrs &waitEvents, CLEventImpl::CreateFunc *eventCreateFunc) enqueueReadImage() argument
306 enqueueWriteImage(const cl::Image &image, bool blocking, const size_t origin[3], const size_t region[3], size_t inputRowPitch, size_t inputSlicePitch, const void *ptr, const cl::EventPtrs &waitEvents, CLEventImpl::CreateFunc *eventCreateFunc) enqueueWriteImage() argument
426 enqueueMapImage(const cl::Image &image, bool blocking, cl::MapFlags mapFlags, const size_t origin[3], const size_t region[3], size_t *imageRowPitch, size_t *imageSlicePitch, const cl::EventPtrs &waitEvents, CLEventImpl::CreateFunc *eventCreateFunc, cl_int &errorCode) enqueueMapImage() argument
[all...]
/third_party/vk-gl-cts/framework/delibs/decpp/
H A DdeBlockBuffer.hpp72 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()
281 int ret = writeToCurrentBlock(numElements-numWritten, elements+numWritten, false /* non-blocking */); in tryWrite()
306 numWritten += writeToCurrentBlock(numElements-numWritten, elements+numWritten, true /* blocking */); in write()
360 int ret = readFromCurrentBlock(numElements-numRead, &elements[numRead], false /* non-blocking */); in tryRead()
385 numRead += readFromCurrentBlock(numElements-numRead, &elements[numRead], true /* blocking */); in read()
[all...]
/third_party/skia/third_party/externals/angle2/src/libANGLE/
H A DCLCommandQueue.cpp144 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, mapFlag in enqueueMapBuffer()
347 const bool blocking = blockingRead != CL_FALSE; enqueueReadImage() local
372 const bool blocking = blockingWrite != CL_FALSE; enqueueWriteImage() local
489 const bool blocking = blockingMap != CL_FALSE; enqueueMapImage() local
[all...]
/third_party/mesa3d/src/freedreno/ir3/
H A Dir3_lower_parallelcopy.c437 /* Split any blocking copies whose sources are only partially in _handle_copies()
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()
455 /* Update sources of blocking copies. in _handle_copies()
457 * Note: at this point, every blocking copy's source should be in _handle_copies()
461 struct copy_entry *blocking in _handle_copies() local
[all...]
/third_party/selinux/libselinux/src/
H A Davc_internal.c101 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/ltp/testcases/open_posix_testsuite/conformance/interfaces/mq_send/
H A D5-2.c103 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()
114 if (blocking != 1) { in main()
/third_party/ltp/testcases/open_posix_testsuite/conformance/interfaces/mq_timedreceive/
H A D5-2.c38 static int blocking; variable
41 printf("FAIL: the case is blocking, exit anyway\n"); in exit_handler()
42 blocking = 1; in exit_handler()
85 /* Parent is not blocking, let child abort */ in main()
95 if (failure == 1 || blocking == 1) { in main()
106 sleep(TIMEOUT + 3); /* Parent is probably blocking in main()
H A D18-1.c38 static int blocking; variable
41 printf("FAIL: the case is blocking, exit anyway\n"); in exit_handler()
42 blocking = 1; in exit_handler()
84 /* parent is not blocking on mq_timedreceive, kill child */ in main()
94 if (failure == 1 || blocking == 1) { in main()
106 sleep(TIMEOUT + 3); /* Parent is probably blocking, in main()
H A D18-2.c39 static int blocking; variable
42 printf("FAIL: the case is blocking, exit anyway\n"); in exit_handler()
43 blocking = 1; in exit_handler()
86 /* Parent is not blocking, let child abort */ in main()
96 if (failure == 1 || blocking == 1) { in main()
107 sleep(TIMEOUT + 3); /* Parent is probably blocking in main()
H A D8-1.c35 static int blocking; variable
38 printf("FAIL: the case is blocking, exit anyway\n"); in exit_handler()
39 blocking = 1; in exit_handler()
93 /* Parent is not blocking, let child abort */ in main()
104 if (failure == 1 || blocking == 1) { in main()
115 sleep(TIMEOUT + 3); /* Parent is probably blocking in main()
/third_party/ltp/testcases/open_posix_testsuite/conformance/interfaces/mq_timedsend/
H A D5-2.c109 int j, k, blocking = 0; in main() local
113 /* If sleep finished, child is probably blocking */ in main()
114 blocking = 1; //set blocking flag in main()
120 if (blocking != 1) { in main()
/third_party/node/deps/npm/node_modules/set-blocking/
H A Dindex.js1 module.exports = function (blocking) {
4 stream._handle.setBlocking(blocking)
/third_party/pulseaudio/src/pulsecore/
H A Dpipe.c37 static int set_block(int fd, int blocking) { in set_block() argument
47 if (blocking) in set_block()
61 arg = !blocking; in set_block()
96 /* Make non-blocking so that connect() won't block */ in pipe()
128 /* Restore blocking */ in pipe()
/third_party/python/Python/
H A Dbootstrap_hash.c86 py_getrandom(void *buffer, Py_ssize_t size, int blocking, int raise) in py_getrandom() argument
100 flags = blocking ? 0 : GRND_NONBLOCK; in py_getrandom()
155 if (errno == EAGAIN && !raise && !blocking) { in py_getrandom()
444 Prefer getrandom() over getentropy() because getrandom() supports blocking
445 and non-blocking mode: see the PEP 524. Python requires non-blocking RNG at
453 Only the getrandom() function supports non-blocking mode.
473 pyurandom(void *buffer, Py_ssize_t size, int blocking, int raise) in pyurandom() argument
498 res = py_getrandom(buffer, size, blocking, raise); in pyurandom()
521 On Linux 3.17 and newer, the getrandom() syscall is used in blocking mod
[all...]
/third_party/jerryscript/jerry-debugger/
H A Djerry_client_rawpacket.py64 def get_message(self, blocking):
82 if not blocking and not self.protocol.ready():
H A Djerry_client_websocket.py104 def get_message(self, blocking):
125 if not blocking and not self.protocol.ready():
/third_party/mesa3d/src/gallium/frontends/clover/core/
H A Dresource.cpp84 resource::add_map(command_queue &q, cl_map_flags flags, bool blocking, in add_map() argument
86 maps.emplace_back(q, *this, flags, blocking, origin, region); in add_map()
227 cl_map_flags flags, bool blocking, in mapping()
235 (!blocking ? PIPE_MAP_UNSYNCHRONIZED : 0)); in mapping()
226 mapping(command_queue &q, resource &r, cl_map_flags flags, bool blocking, const resource::vector &origin, const resource::vector &region) mapping() argument
H A Dresource.hpp56 mapping *add_map(command_queue &q, cl_map_flags flags, bool blocking,
115 bool blocking, const resource::vector &origin,
/third_party/mesa3d/src/gallium/frontends/clover/api/
H A Dtransfer.cpp360 clEnqueueReadBuffer(cl_command_queue d_q, cl_mem d_mem, cl_bool blocking,
382 if (blocking)
393 clEnqueueWriteBuffer(cl_command_queue d_q, cl_mem d_mem, cl_bool blocking,
415 if (blocking)
426 clEnqueueReadBufferRect(cl_command_queue d_q, cl_mem d_mem, cl_bool blocking,
455 if (blocking)
466 clEnqueueWriteBufferRect(cl_command_queue d_q, cl_mem d_mem, cl_bool blocking,
495 if (blocking)
621 clEnqueueReadImage(cl_command_queue d_q, cl_mem d_mem, cl_bool blocking,
647 if (blocking)
[all...]
/third_party/skia/third_party/externals/tint/tools/src/cmd/remote-compile/
H A Dsocket.cc63 bool setBlocking(SOCKET s, bool blocking) { in setBlocking() argument
65 u_long mode = blocking ? 0 : 1; in setBlocking()
72 arg = blocking ? (arg & ~O_NONBLOCK) : (arg | O_NONBLOCK); in setBlocking()
/third_party/python/Lib/
H A Dsched.py103 def run(self, blocking=True):
105 If blocking is False executes the scheduled events due to
147 if not blocking:

Completed in 12 milliseconds

1234