| /external/skia/src/core/ |
| D | SkTaskGroup2D.cpp | 11 fThreadsGroup->batch(fThreadCnt, [this](int threadId){ in start() argument
12 this->work(threadId); in start()
26 void SkSpinningTaskGroup2D::work(int threadId) { in work() argument
37 if (workCol < fWidth && fKernel->work2D(threadId, workCol, threadId)) { in work()
41 this->initAnUninitializedColumn(initCol, threadId); in work()
46 void SkFlexibleTaskGroup2D::work(int threadId) { in work() argument
47 int row = threadId; in work()
54 while (threadId < fHeight - numRowsCompleted) { in work()
65 fKernel->work2D(row, rowData.fNextColumn, threadId)) { in work()
84 this->initAnUninitializedColumn(initCol, threadId); // Initialize something in work()
|
| D | SkTaskGroup2D.h | 69 virtual void work(int threadId) = 0;
74 void initAnUninitializedColumn(int& initCol, int threadId) { in initAnUninitializedColumn() argument
77 didSomeInit = fKernel->initColumn(initCol++, threadId); in initAnUninitializedColumn()
100 void work(int threadId) override;
109 void work(int threadId) override;
|
| /external/deqp/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 | 43 Message (deUint16 threadId, deUint16 payload) in Message()
44 : data((threadId << 16) | payload) in Message()
84 deUint16 threadId = msg.getThreadId(); in run() local
86 if (threadId == 0xffff) in run()
101 DE_TEST_ASSERT(de::inBounds<int>(threadId, 0, (int)m_lastPayload.size())); in run()
102 …DE_TEST_ASSERT((m_lastPayload[threadId] == 0 && msg.getPayload() == 0) || m_lastPayload[threadId] … in run()
104 m_lastPayload[threadId] = msg.getPayload(); in run()
105 m_payloadSum[threadId] += (deUint32)msg.getPayload(); in run()
111 deUint32 getPayloadSum (deUint16 threadId) const in getPayloadSum()
113 return m_payloadSum[threadId]; in getPayloadSum()
[all …]
|
| /external/skqp/src/core/ |
| D | SkTaskGroup2D.cpp | 11 fThreadsGroup->batch(fThreadCnt, [this](int threadId){ in start() argument
12 this->work(threadId); in start()
26 void SkSpinningTaskGroup2D::work(int threadId) { in work() argument
27 int& nextColumn = fRowData[threadId].fNextColumn; in work()
36 fWork(threadId, nextColumn); in work()
50 void SkFlexibleTaskGroup2D::work(int threadId) { in work() argument
52 int& rowIndex = fThreadData[threadId].fRowIndex; in work()
|
| D | SkTaskGroup2D.h | 48 virtual void work(int threadId) = 0;
69 void work(int threadId) override;
87 void work(int threadId) override;
|
| D | SkTypeface_remote.h | 74 std::thread::id threadId, in SkTypefaceProxy() argument
80 , fThreadId{threadId}
|
| /external/mesa3d/src/gallium/drivers/swr/rasterizer/core/ |
| D | rdtsc_core.h | 98 void rdtscInit(int threadId);
106 #define RDTSC_INIT(threadId) rdtscInit(threadId) argument
113 #define RDTSC_INIT(threadId) argument
132 INLINE void rdtscInit(int threadId) in rdtscInit() argument
135 if (!gBucketsInitialized && (threadId == 0)) in rdtscInit()
145 std::string name = threadId == 0 ? "API" : "WORKER"; in rdtscInit()
|
| D | threads.cpp | 96 uint32_t threadId = 0; in CalculateProcessorTopology() local
103 while (BitScanForwardSizeT((unsigned long*)&threadId, gmask.Mask)) in CalculateProcessorTopology()
106 KAFFINITY threadMask = KAFFINITY(1) << threadId; in CalculateProcessorTopology()
125 threadMaskPerProcGroup[procGroup] |= (KAFFINITY(1) << threadId); in CalculateProcessorTopology()
131 procNum.Number = UCHAR(threadId); in CalculateProcessorTopology()
148 pCore->threadIds.push_back(threadId); in CalculateProcessorTopology()
167 uint32_t threadId = uint32_t(-1); in CalculateProcessorTopology() local
175 if (threadId != uint32_t(-1)) in CalculateProcessorTopology()
184 core.threadIds.push_back(threadId); in CalculateProcessorTopology()
190 threadId = std::strtoul(&line.c_str()[data_start], &c, 10); in CalculateProcessorTopology()
[all …]
|
| /external/webrtc/webrtc/examples/androidapp/src/org/appspot/apprtc/util/ |
| D | LooperExecutor.java | 29 private long threadId; field in LooperExecutor
37 threadId = Thread.currentThread().getId(); in run()
79 return (Thread.currentThread().getId() == threadId); in checkOnLooperThread()
88 if (Thread.currentThread().getId() == threadId) { in execute()
|
| D | AppRTCUtils.java | 29 private final Long threadId; field in AppRTCUtils.NonThreadSafe
33 threadId = Thread.currentThread().getId(); in NonThreadSafe()
38 return threadId.equals(Thread.currentThread().getId()); in calledOnValidThread()
|
| /external/apache-harmony/jdwp/src/test/java/org/apache/harmony/jpda/tests/jdwp/share/ |
| D | JDWPProxyTestCase.java | 35 private final long threadId; field in JDWPProxyTestCase.EventContext
39 public EventContext(long threadId, long frameId, Location location) { in EventContext() argument
40 this.threadId = threadId; in EventContext()
46 return threadId; in getThreadId()
|
| /external/apache-harmony/jdwp/src/test/java/org/apache/harmony/jpda/tests/jdwp/VirtualMachine/ |
| D | ResumeTest.java | 226 long threadId = 0; field in ResumeTest.ThreadInfo
317 threadInfo.threadId = threadID; in createThreadInfos()
326 if (threadInfo.threadId == 0) { in createThreadInfos()
359 + threadInfo.threadId in checkThreadStatus()
366 packet.setNextValueAsThreadID(threadInfo.threadId); in checkThreadStatus()
370 threadInfo.threadId + in checkThreadStatus()
388 "checked thread " + threadInfo.threadId + in checkThreadStatus()
|
| /external/apache-harmony/jdwp/src/test/java/org/apache/harmony/jpda/tests/jdwp/ObjectReference/ |
| D | InvokeMethodWithSuspensionTest.java | 38 protected CommandPacket buildInvokeCommand(long threadId, long classID, in buildInvokeCommand() argument
41 ReplyPacket replyPacket = debuggeeWrapper.vmMirror.getThreadFrames(threadId, 0, 1); in buildInvokeCommand()
48 long receiverId = debuggeeWrapper.vmMirror.getThisObject(threadId, topFrameId); in buildInvokeCommand()
54 command.setNextValueAsThreadID(threadId); in buildInvokeCommand()
|
| D | InvokeMethodAfterMultipleThreadSuspensionTest.java | 40 protected CommandPacket buildInvokeCommand(long threadId, long classID, in buildInvokeCommand() argument
43 ReplyPacket replyPacket = debuggeeWrapper.vmMirror.getThreadFrames(threadId, 0, 1); in buildInvokeCommand()
50 long receiverId = debuggeeWrapper.vmMirror.getThisObject(threadId, topFrameId); in buildInvokeCommand()
56 command.setNextValueAsThreadID(threadId); in buildInvokeCommand()
|
| /external/lzma/C/ |
| D | Threads.c | 38 DWORD threadId; in Thread_Create() local
39 *p = CreateThread(0, 0, func, param, 0, &threadId); in Thread_Create()
43 unsigned threadId; in Thread_Create()
44 *p = (HANDLE)_beginthreadex(NULL, 0, func, param, 0, &threadId); in Thread_Create()
|
| /external/apache-harmony/jdwp/src/test/java/org/apache/harmony/jpda/tests/jdwp/StackFrame/ |
| D | JDWPStackFrameAccessTest.java | 192 long threadId = getThreadIdFromName(threadName); in suspendDebuggee() local
194 debuggeeWrapper.vmMirror.suspendThread(threadId); in suspendDebuggee()
195 return threadId; in suspendDebuggee()
198 private void resumeTest(long threadId) { in resumeTest() argument
200 debuggeeWrapper.vmMirror.resumeThread(threadId); in resumeTest()
206 for (long threadId : allThreadIds) { in getThreadIdFromName()
207 String currentThreadName = jdwpGetThreadName(threadId); in getThreadIdFromName()
209 return threadId; in getThreadIdFromName()
|
| /external/apache-harmony/jdwp/src/test/java/org/apache/harmony/jpda/tests/jdwp/Events/ |
| D | SingleStepWithPendingExceptionTest.java | 90 long threadId = debuggeeWrapper.vmMirror.waitForBreakpoint(breakpointRequestId); in testSingleStepWithPendingException() local
93 int singleStepRequestId = setSingleStepOut(threadId); in testSingleStepWithPendingException()
130 private int setSingleStepOut(long threadId) { in setSingleStepOut() argument
131 ReplyPacket replyPacket = debuggeeWrapper.vmMirror.setStep(new String[0], threadId, in setSingleStepOut()
|
| /external/testng/src/test/java/test/thread/ |
| D | BaseThreadTest.java | 40 protected void logThread(long threadId) { in logThread() argument
42 log("BaseThreadTest", "Logging thread:" + threadId); in logThread()
43 m_threadIds.add(threadId); in logThread()
|
| /external/testng/src/test/java/test/testng285/ |
| D | BugBase.java | 18 void log(long threadId) { in log() argument
19 m_threadIds.add(threadId); in log()
|
| /external/apache-harmony/jdwp/src/test/java/org/apache/harmony/jpda/tests/jdwp/ClassType/ |
| D | InvokeMethodWithSuspensionTest.java | 38 protected CommandPacket buildInvokeCommand(long threadId, long classID, in buildInvokeCommand() argument
44 command.setNextValueAsThreadID(threadId); in buildInvokeCommand()
|
| D | InvokeMethodAfterMultipleThreadSuspensionTest.java | 40 protected CommandPacket buildInvokeCommand(long threadId, long classID, in buildInvokeCommand() argument
46 command.setNextValueAsThreadID(threadId); in buildInvokeCommand()
|
| D | NewInstanceAfterMultipleThreadSuspensionTest.java | 39 protected CommandPacket buildInvokeCommand(long threadId, long classID, in buildInvokeCommand() argument
45 command.setNextValueAsThreadID(threadId); in buildInvokeCommand()
|
| D | NewInstanceWithSuspensionTest.java | 37 protected CommandPacket buildInvokeCommand(long threadId, long classID, in buildInvokeCommand() argument
43 command.setNextValueAsThreadID(threadId); in buildInvokeCommand()
|
| /external/volley/src/main/java/com/android/volley/ |
| D | Request.java | 243 final long threadId = Thread.currentThread().getId(); in finish() local
251 mEventLog.add(tag, threadId); in finish()
258 mEventLog.add(tag, threadId); in finish()
|