| /third_party/cef/libcef/common/ |
| D | task_impl.cc | 12 bool CefCurrentlyOn(CefThreadId threadId) { in CefCurrentlyOn() argument
14 CefTaskRunnerImpl::GetTaskRunner(threadId); in CefCurrentlyOn()
19 LOG(WARNING) << "No task runner for threadId " << threadId; in CefCurrentlyOn()
23 bool CefPostTask(CefThreadId threadId, CefRefPtr<CefTask> task) { in CefPostTask() argument
25 CefTaskRunnerImpl::GetTaskRunner(threadId); in CefPostTask()
31 LOG(WARNING) << "No task runner for threadId " << threadId; in CefPostTask()
35 bool CefPostDelayedTask(CefThreadId threadId, in CefPostDelayedTask() argument
39 CefTaskRunnerImpl::GetTaskRunner(threadId); in CefPostDelayedTask()
46 LOG(WARNING) << "No task runner for threadId " << threadId; in CefPostDelayedTask()
|
| D | task_runner_impl.cc | 31 CefRefPtr<CefTaskRunner> CefTaskRunner::GetForThread(CefThreadId threadId) { in GetForThread() argument
33 CefTaskRunnerImpl::GetTaskRunner(threadId); in GetForThread()
37 LOG(WARNING) << "Invalid thread id " << threadId; in GetForThread()
51 CefThreadId threadId) { in GetTaskRunner() argument
57 switch (threadId) { in GetTaskRunner()
133 bool CefTaskRunnerImpl::BelongsToThread(CefThreadId threadId) { in BelongsToThread() argument
135 GetTaskRunner(threadId); in BelongsToThread()
|
| /third_party/vk-gl-cts/framework/delibs/decpp/ |
| D | deThreadSafeRingBuffer.cpp | 42 Message (deUint16 threadId, deUint16 payload) in Message()
43 : data((threadId << 16) | payload) in Message()
72 deUint16 threadId = msg.getThreadId(); in run() local
74 if (threadId == 0xffff) in run()
77 DE_TEST_ASSERT(de::inBounds<int>(threadId, 0, (int)m_lastPayload.size())); in run()
78 …DE_TEST_ASSERT((m_lastPayload[threadId] == 0 && msg.getPayload() == 0) || m_lastPayload[threadId] … in run()
80 m_lastPayload[threadId] = msg.getPayload(); in run()
81 m_payloadSum[threadId] += (deUint32)msg.getPayload(); in run()
85 deUint32 getPayloadSum (deUint16 threadId) const in getPayloadSum()
87 return m_payloadSum[threadId]; in getPayloadSum()
[all …]
|
| D | deBlockBuffer.cpp | 44 Message (deUint16 threadId, deUint16 payload) in Message()
45 : data((threadId << 16) | payload) in Message()
85 deUint16 threadId = msg.getThreadId(); in run() local
87 if (threadId == 0xffff) in run()
102 DE_TEST_ASSERT(de::inBounds<int>(threadId, 0, (int)m_lastPayload.size())); in run()
103 …DE_TEST_ASSERT((m_lastPayload[threadId] == 0 && msg.getPayload() == 0) || m_lastPayload[threadId] … in run()
105 m_lastPayload[threadId] = msg.getPayload(); in run()
106 m_payloadSum[threadId] += (deUint32)msg.getPayload(); in run()
112 deUint32 getPayloadSum (deUint16 threadId) const in getPayloadSum()
114 return m_payloadSum[threadId]; in getPayloadSum()
[all …]
|
| /third_party/cef/libcef_dll/wrapper/ |
| D | cef_closure_task.cc | 60 bool CefPostTask(CefThreadId threadId, base::OnceClosure closure) { in CefPostTask() argument
61 return CefPostTask(threadId, new CefOnceClosureTask(std::move(closure))); in CefPostTask()
64 bool CefPostTask(CefThreadId threadId, const base::RepeatingClosure& closure) { in CefPostTask() argument
65 return CefPostTask(threadId, new CefRepeatingClosureTask(closure)); in CefPostTask()
68 bool CefPostDelayedTask(CefThreadId threadId, in CefPostDelayedTask() argument
72 threadId, new CefOnceClosureTask(std::move(closure)), delay_ms); in CefPostDelayedTask()
75 bool CefPostDelayedTask(CefThreadId threadId, in CefPostDelayedTask() argument
78 return CefPostDelayedTask(threadId, new CefRepeatingClosureTask(closure), in CefPostDelayedTask()
|
| /third_party/node/test/parallel/ |
| D | test-worker-message-port-drain.js | 14 threadId,
23 workerIdsToOutput.set(worker.threadId, workerOutput);
31 for (const [threadId, workerOutput] of workerIdsToOutput) {
32 assert.ok(workerOutput.includes(`1 threadId: ${threadId}`));
33 assert.ok(workerOutput.includes(`2 threadId: ${threadId}`));
37 console.log(`1 threadId: ${threadId}`);
38 console.log(`2 threadId: ${threadId}`);
|
| D | test-worker-event.js | 7 threadId: parentThreadId,
10 process.on('worker', common.mustCall(({ threadId }) => { field
11 assert.strictEqual(threadId, parentThreadId + 1);
|
| D | test-worker-environmentdata.js | 8 threadId,
31 if (threadId <= 2)
|
| /third_party/node/lib/internal/ |
| D | worker.js | 62 threadId,
121 debug(`[${threadId}] create new worker`, filename, options);
210 debug(`[${threadId}] created Worker with ID ${this.threadId}`);
269 debug(`[${threadId}] hears end event for Worker ${this.threadId}`);
274 debug(`[${threadId}] failing with custom error ${customErr} \
328 debug(`[${threadId}] explicitly closes stdout for ${this.threadId}`);
332 debug(`[${threadId}] explicitly closes stderr for ${this.threadId}`);
344 debug(`[${threadId}] terminates Worker with ID ${this.threadId}`);
383 get threadId() { getter in Worker
386 return this[kHandle].threadId;
[all …]
|
| /third_party/skia/third_party/externals/spirv-cross/shaders-reflection/asm/ |
| D | op-source-none-uav-1.asm.comp | 9 OpEntryPoint GLCompute %main "main" %threadId
15 OpName %threadId "threadId"
21 OpDecorate %threadId BuiltIn GlobalInvocationId
39 %threadId = OpVariable %_ptr_Input_v3int Input
42 %38 = OpLoad %v3int %threadId
|
| D | op-source-hlsl-uav-1.asm.comp | 9 OpEntryPoint GLCompute %main "main" %threadId
16 OpName %threadId "threadId"
22 OpDecorate %threadId BuiltIn GlobalInvocationId
40 %threadId = OpVariable %_ptr_Input_v3int Input
43 %38 = OpLoad %v3int %threadId
|
| D | op-source-none-uav-2.asm.comp | 9 OpEntryPoint GLCompute %main "main" %threadId
16 OpName %threadId "threadId"
24 OpDecorate %threadId BuiltIn GlobalInvocationId
43 %threadId = OpVariable %_ptr_Input_v3int Input
46 %38 = OpLoad %v3int %threadId
|
| D | op-source-hlsl-uav-2.asm.comp | 9 OpEntryPoint GLCompute %main "main" %threadId
17 OpName %threadId "threadId"
25 OpDecorate %threadId BuiltIn GlobalInvocationId
44 %threadId = OpVariable %_ptr_Input_v3int Input
47 %38 = OpLoad %v3int %threadId
|
| /third_party/cef/include/ |
| D | cef_task.h | 86 static CefRefPtr<CefTaskRunner> GetForThread(CefThreadId threadId);
105 virtual bool BelongsToThread(CefThreadId threadId) = 0;
129 bool CefCurrentlyOn(CefThreadId threadId);
136 bool CefPostTask(CefThreadId threadId, CefRefPtr<CefTask> task);
143 bool CefPostDelayedTask(CefThreadId threadId,
|
| /third_party/cef/include/capi/ |
| D | cef_task_capi.h | 100 cef_thread_id_t threadId);
131 cef_thread_id_t threadId);
137 CEF_EXPORT int cef_currently_on(cef_thread_id_t threadId);
143 CEF_EXPORT int cef_post_task(cef_thread_id_t threadId, cef_task_t* task);
150 CEF_EXPORT int cef_post_delayed_task(cef_thread_id_t threadId,
|
| /third_party/skia/third_party/externals/swiftshader/src/Vulkan/Debug/ |
| D | Server.cpp | 219 auto thread = lock.get(Thread::ID(req.threadId)); in Impl()
222 return dap::Error("Thread %d not found", req.threadId); in Impl()
323 if(auto thread = lock.get(Thread::ID(req.threadId))) in Impl()
326 event.threadId = req.threadId; in Impl()
341 event.threadId = threads.front()->id.value(); in Impl()
358 if(auto thread = lock.get(Thread::ID(req.threadId))) in Impl()
380 auto thread = lock.get(Thread::ID(req.threadId)); in Impl()
383 return dap::Error("Unknown thread %d", int(req.threadId)); in Impl()
395 auto thread = lock.get(Thread::ID(req.threadId)); in Impl()
398 return dap::Error("Unknown thread %d", int(req.threadId)); in Impl()
[all …]
|
| /third_party/cef/include/wrapper/ |
| D | cef_closure_task.h | 95 bool CefPostTask(CefThreadId threadId, base::OnceClosure closure);
96 bool CefPostTask(CefThreadId threadId, const base::RepeatingClosure& closure);
102 bool CefPostDelayedTask(CefThreadId threadId,
105 bool CefPostDelayedTask(CefThreadId threadId,
|
| /third_party/glslang/Test/baseResults/ |
| D | hlsl.structbuffer.floatidx.comp.out | 10 …temp structure{ temp 4-component vector of float color, temp 2-component vector of uint threadId})
11 …temp structure{ temp 4-component vector of float color, temp 2-component vector of uint threadId})
12 …ffer structure{ temp 4-component vector of float color, temp 2-component vector of uint threadId})
13 …y of structure{ temp 4-component vector of float color, temp 2-component vector of uint threadId})
14 …ructure{ temp 4-component vector of float color, temp 2-component vector of uint threadId} @data})
32 0:15 threadId: direct index for structure ( temp 2-component vector of uint)
33 …temp structure{ temp 4-component vector of float color, temp 2-component vector of uint threadId})
45 …temp structure{ temp 4-component vector of float color, temp 2-component vector of uint threadId})
85 …ructure{ temp 4-component vector of float color, temp 2-component vector of uint threadId} @data})
102 …temp structure{ temp 4-component vector of float color, temp 2-component vector of uint threadId})
[all …]
|
| /third_party/node/lib/internal/main/ |
| D | worker_thread.js | 34 threadId,
78 debug(`[${threadId}] is setting up worker child environment`);
162 debug(`[${threadId}] starts worker script ${filename} ` +
205 debug(`[${threadId}] gets uncaught exception`);
214 debug(`[${threadId}] uncaught exception handled = ${handled}`);
235 debug(`[${threadId}] uncaught exception serialized = ${!!serialized}`);
|
| /third_party/cef/libcef_dll/cpptoc/ |
| D | task_runner_cpptoc.cc | 34 cef_thread_id_t threadId) { in cef_task_runner_get_for_thread() argument
40 CefRefPtr<CefTaskRunner> _retval = CefTaskRunner::GetForThread(threadId); in cef_task_runner_get_for_thread()
90 cef_thread_id_t threadId) { in task_runner_belongs_to_thread() argument
100 bool _retval = CefTaskRunnerCppToC::Get(self)->BelongsToThread(threadId); in task_runner_belongs_to_thread()
|
| /third_party/cef/libcef_dll/ctocpp/ |
| D | task_runner_ctocpp.cc | 35 CefRefPtr<CefTaskRunner> CefTaskRunner::GetForThread(CefThreadId threadId) { in GetForThread() argument
41 cef_task_runner_t* _retval = cef_task_runner_get_for_thread(threadId); in GetForThread()
88 bool CefTaskRunnerCToCpp::BelongsToThread(CefThreadId threadId) { in BelongsToThread() argument
98 int _retval = _struct->belongs_to_thread(_struct, threadId); in BelongsToThread()
|
| /third_party/skia/third_party/externals/dawn/src/tests/perf_tests/ |
| D | DawnPerfTestPlatform.cpp | 137 std::string threadId = stream.str(); in AcquireTraceEventBuffer() local
140 std::back_inserter(traceEventBuffer), [&threadId](TraceEvent ev) { in AcquireTraceEventBuffer()
141 ev.threadId = threadId; in AcquireTraceEventBuffer()
|
| /third_party/node/test/report/ |
| D | test-report-fatal-error.js | 50 assert.strictEqual(require(report).header.threadId, null);
76 assert.strictEqual(require(report).header.threadId, null);
93 assert.strictEqual(require(report).header.threadId, null);
120 assert.strictEqual(json.header.threadId, null);
|
| /third_party/node/test/fixtures/ |
| D | worker-preload.js | 4 threadId
7 if (threadId < 2) {
|
| /third_party/node/lib/ |
| D | worker_threads.js | 9 threadId,
32 threadId, property
|