| /dports/lang/ghc/ghc-8.10.7/rts/ |
| H A D | Threads.c | 60 StgTSO *tso; in createThread() local
101 tso->flags = 0; in createThread()
102 tso->dirty = 1; in createThread()
107 tso->cap = cap; in createThread()
138 return tso; in createThread()
256 traceEventThreadWakeup (cap, tso, tso->cap->no); in tryWakeupThread()
263 msg->tso = tso; in tryWakeupThread()
267 (W_)tso->id, tso->cap->no); in tryWakeupThread()
550 (long)tso->id, tso, (long)tso->stackobj->stack_size, in threadStackOverflow()
800 tso = q->tso; in performTryPutMVar()
[all …]
|
| H A D | RaiseAsync.c | 59 if (tso->what_next == ThreadComplete || tso->what_next == ThreadKilled) { in throwToSingleThreaded__()
64 removeFromQueues(cap,tso); in throwToSingleThreaded__()
134 m = throwTo(cap, tso, tso, exception); in throwToSelf()
548 if (tso->what_next == ThreadComplete || tso->what_next == ThreadFinished) { in maybePerformBlockedException()
564 || ((tso->flags & TSO_INTERRUPTIBLE) && interruptible(tso)))) { in maybePerformBlockedException()
666 switch (tso->why_blocked) { in removeFromQueues()
791 fprintCCS_stderr(tso->prof.cccs,exception,tso); in raiseAsync()
800 ASSERT(tso->cap == cap); in raiseAsync()
802 stack = tso->stackobj; in raiseAsync()
805 dirty_TSO(cap, tso); in raiseAsync()
[all …]
|
| H A D | Schedule.h | 141 ASSERT(tso->_link == END_TSO_QUEUE); in appendToRunQueue()
143 cap->run_queue_hd = tso; in appendToRunQueue()
149 cap->run_queue_tl = tso; in appendToRunQueue()
162 setTSOLink(cap, tso, cap->run_queue_hd); in pushOnRunQueue()
163 tso->block_info.prev = END_TSO_QUEUE; in pushOnRunQueue()
167 cap->run_queue_hd = tso; in pushOnRunQueue()
169 cap->run_queue_tl = tso; in pushOnRunQueue()
209 appendToBlockedQueue(StgTSO *tso) in appendToBlockedQueue() argument
211 ASSERT(tso->_link == END_TSO_QUEUE); in appendToBlockedQueue()
213 blocked_queue_hd = tso; in appendToBlockedQueue()
[all …]
|
| H A D | Schedule.c | 580 setTSOLink(cap, tso->block_info.prev, tso->_link); in removeFromRunQueue()
586 setTSOPrev(cap, tso->_link, tso->block_info.prev); in removeFromRunQueue()
588 tso->_link = tso->block_info.prev = END_TSO_QUEUE; in removeFromRunQueue()
1568 StgTSO *tso; in scheduleDoGC() local
2428 StgTSO *tso; in suspendThread() local
2484 StgTSO *tso; in resumeThread() local
2598 tso->cap = cap; in scheduleWaitThread()
2600 task->incall->tso = tso; in scheduleWaitThread()
2875 throwToSingleThreaded(tso->cap,tso,NULL); in deleteThread()
2888 appendToRunQueue(tso->cap, tso); in deleteThread_()
[all …]
|
| H A D | ThreadPaused.c | 93 frame = tso->stackobj->sp; in stackSqueeze()
131 gap = updateAdjacentFrames(cap, tso, in stackSqueeze()
167 while ((StgPtr)gap > tso->stackobj->sp) { in stackSqueeze()
181 tso->stackobj->sp = (StgPtr)sp; in stackSqueeze()
193 threadPaused(Capability *cap, StgTSO *tso) in threadPaused() argument
213 maybePerformBlockedException (cap, tso); in threadPaused()
219 stack_end = tso->stackobj->stack + tso->stackobj->stack_size; in threadPaused()
221 frame = (StgClosure *)tso->stackobj->sp; in threadPaused()
402 stackSqueeze(cap, tso, (StgPtr)frame); in threadPaused()
403 tso->flags |= TSO_SQUEEZED; in threadPaused()
[all …]
|
| H A D | Threads.h | 15 StgTSO * unblockOne (Capability *cap, StgTSO *tso);
16 StgTSO * unblockOne_ (Capability *cap, StgTSO *tso, bool allow_migrate);
18 void checkBlockingQueues (Capability *cap, StgTSO *tso);
19 void tryWakeupThread (Capability *cap, StgTSO *tso);
20 void migrateThread (Capability *from, StgTSO *tso, Capability *to);
28 StgTSO *tso);
31 void updateThunk (Capability *cap, StgTSO *tso,
37 StgBool isThreadBound (StgTSO* tso);
40 void threadStackOverflow (Capability *cap, StgTSO *tso);
41 W_ threadStackUnderflow (Capability *cap, StgTSO *tso);
[all …]
|
| H A D | RaiseAsync.h | 19 StgTSO *tso,
25 StgTSO *tso,
29 StgTSO *tso,
34 StgTSO *tso,
38 StgTSO *tso,
49 int maybePerformBlockedException (Capability *cap, StgTSO *tso);
50 void awakenBlockedExceptionQueue (Capability *cap, StgTSO *tso);
|
| H A D | RtsAPI.c | 382 tso->stackobj->sp--; in pushClosure()
383 tso->stackobj->sp[0] = (W_) c; in pushClosure()
432 StgTSO *tso; in rts_eval() local
443 StgTSO *tso; in rts_eval_() local
457 StgTSO* tso; in rts_evalIO() local
473 StgTSO* tso; in rts_evalStableIOMain() local
483 scheduleWaitThread(tso,&r,cap); in rts_evalStableIOMain()
502 StgTSO* tso; in rts_evalStableIO() local
511 scheduleWaitThread(tso,&r,cap); in rts_evalStableIO()
527 StgTSO *tso; in rts_evalLazyIO() local
[all …]
|
| H A D | Trace.h | 98 #define traceSchedEvent(cap, tag, tso, other) \ argument
100 traceSchedEvent_(cap, tag, tso, other, 0); \
222 StgTSO *tso,
249 #define traceThreadStatus(class, tso) \ argument
251 traceThreadStatus_(tso); \
254 void traceThreadStatus_ (StgTSO *tso);
345 #define traceThreadStatus(class, tso) /* nothing */ argument
415 HASKELLEVENT_THREAD_LABEL(cap, tso, label)
568 traceSchedEvent(cap, EVENT_CREATE_THREAD, tso, tso->stackobj->stack_size); in traceEventCreateThread()
575 traceSchedEvent(cap, EVENT_RUN_THREAD, tso, tso->what_next); in traceEventRunThread()
[all …]
|
| /dports/multimedia/libv4l/linux-5.13-rc2/net/core/ |
| H A D | tso.c | 23 if (!tso->ipv6) { in tso_build_hdr()
26 iph->id = htons(tso->ip_id); in tso_build_hdr()
28 tso->ip_id++; in tso_build_hdr()
57 tso->size -= size; in tso_build_data()
58 tso->data += size; in tso_build_data()
60 if ((tso->size == 0) && in tso_build_data()
67 tso->next_frag_idx++; in tso_build_data()
77 tso->tlen = tlen; in tso_start()
80 tso->next_frag_idx = 0; in tso_start()
86 if ((tso->size == 0) && in tso_start()
[all …]
|
| /dports/multimedia/v4l_compat/linux-5.13-rc2/net/core/ |
| H A D | tso.c | 23 if (!tso->ipv6) { in tso_build_hdr()
26 iph->id = htons(tso->ip_id); in tso_build_hdr()
28 tso->ip_id++; in tso_build_hdr()
57 tso->size -= size; in tso_build_data()
58 tso->data += size; in tso_build_data()
60 if ((tso->size == 0) && in tso_build_data()
67 tso->next_frag_idx++; in tso_build_data()
77 tso->tlen = tlen; in tso_start()
80 tso->next_frag_idx = 0; in tso_start()
86 if ((tso->size == 0) && in tso_start()
[all …]
|
| /dports/multimedia/v4l-utils/linux-5.13-rc2/net/core/ |
| H A D | tso.c | 23 if (!tso->ipv6) { in tso_build_hdr()
26 iph->id = htons(tso->ip_id); in tso_build_hdr()
28 tso->ip_id++; in tso_build_hdr()
57 tso->size -= size; in tso_build_data()
58 tso->data += size; in tso_build_data()
60 if ((tso->size == 0) && in tso_build_data()
67 tso->next_frag_idx++; in tso_build_data()
77 tso->tlen = tlen; in tso_start()
80 tso->next_frag_idx = 0; in tso_start()
86 if ((tso->size == 0) && in tso_start()
[all …]
|
| /dports/astro/gpstk/GPSTk-8.0.0/core/tests/Math/ |
| H A D | Stats_TwoSampleStats_T.cpp | 56 gpstk::TwoSampleStats<T> tso; in statsTest() local
58 tso.Add(1, 2); in statsTest()
59 tso.Add(2, 5); in statsTest()
60 tso.Add(3, 1); in statsTest()
61 tso.Add(4, 4); in statsTest()
62 tso.Add(5, 3); in statsTest()
63 TUA(5, tso.N(), "Add()"); in statsTest()
66 TUAE(5, tso.MaximumX(), precision, "MaxX()"); in statsTest()
67 TUAE(1, tso.MinimumX(), precision, "MinX()"); in statsTest()
72 TUAE(5, tso.MaximumY(), precision, "MaxY()"); in statsTest()
[all …]
|
| /dports/lang/ghc/ghc-8.10.7/rts/posix/ |
| H A D | Select.c | 98 StgTSO *tso; in wakeUpSleepingThreads() local
102 tso = sleeping_queue; in wakeUpSleepingThreads()
106 sleeping_queue = tso->_link; in wakeUpSleepingThreads()
108 tso->_link = END_TSO_QUEUE; in wakeUpSleepingThreads()
222 StgTSO *tso, *prev, *next; in awaitEvent() local
256 for(tso = blocked_queue_hd; tso != END_TSO_QUEUE; tso = next) { in awaitEvent()
257 next = tso->_link; in awaitEvent()
268 switch (tso->why_blocked) { in awaitEvent()
388 for(tso = blocked_queue_hd; tso != END_TSO_QUEUE; tso = next) { in awaitEvent()
389 next = tso->_link; in awaitEvent()
[all …]
|
| /dports/math/singular/Singular-Release-4-2-1/kernel/GBEngine/ |
| H A D | syz2.cc | 231 poly tt = pMDivide(tso.lcm,tso.p1); in syCreateNewPairs_Hilb()
233 tso.syz = pMult_mm(tso.syz,tt); in syCreateNewPairs_Hilb()
237 tt = pMDivide(tso.lcm,tso.p2); in syCreateNewPairs_Hilb()
241 tso.syz = pAdd(pp,tso.syz); in syCreateNewPairs_Hilb()
290 memset(&tso,0,sizeof(tso)); in syHalfPair()
315 tso.lcm = pHead(tso.syz); in syHalfPair()
589 if ((tso.p1!=NULL) && (tso.p2!=NULL)) in syRedNextPairs_Hilb()
595 tso.p = ksOldCreateSpoly(tso.p2, tso.p1); in syRedNextPairs_Hilb()
621 kBucketInit(syzstr->bucket,tso.p,tso.length); in syRedNextPairs_Hilb()
634 kBucketInit(syzstr->bucket,tso.p,tso.length); in syRedNextPairs_Hilb()
[all …]
|
| H A D | syz3.cc | 675 assume (tso.ind1!=tso.ind2); in redOnePair()
695 (p_FDeg(tso.p1,currRing)+p_FDeg(tso.p2,currRing)==tso.order)) in redOnePair()
729 tso.syz = pSub(tso.syz,pMult(p,pCopy(old_repr->m[tso.ind1]))); in redOnePair()
736 tso.p = ksOldCreateSpoly(tso.p2,tso.p1); in redOnePair()
744 tso.syz = pMult_mm(tso.syz,tt); in redOnePair()
749 tt = pMDivide(tso.lcm,tso.p2); in redOnePair()
755 tso.syz = pAdd(p,tso.syz); in redOnePair()
1202 assume (tso.ind1!=tso.ind2); in redOnePairHIndex()
1259 tso.p = ksOldCreateSpoly(tso.p2,tso.p1); in redOnePairHIndex()
1272 tt = pMDivide(tso.lcm,tso.p2); in redOnePairHIndex()
[all …]
|
| /dports/lang/ghc/ghc-8.10.7/rts/win32/ |
| H A D | AsyncIO.c | 273 StgTSO *tso, *prev; in awaitRequests() local
289 for(tso = blocked_queue_hd; tso != END_TSO_QUEUE; in awaitRequests()
290 tso = tso->_link) { in awaitRequests()
292 switch(tso->why_blocked) { in awaitRequests()
309 blocked_queue_hd = tso->_link; in awaitRequests()
311 if (blocked_queue_tl == tso) { in awaitRequests()
316 tso->_link = END_TSO_QUEUE; in awaitRequests()
317 tso->why_blocked = NotBlocked; in awaitRequests()
322 tso->stackobj->sp[1] = (W_)tso->block_info.async_result; in awaitRequests()
328 if (tso->why_blocked != NotBlocked) { in awaitRequests()
[all …]
|
| /dports/devel/onetbb/oneTBB-2021.4.0/src/tbb/ |
| H A D | observer_proxy.cpp | 150 d1::task_scheduler_observer* tso = nullptr; in do_notify_entry_observers() local
186 tso = p->my_observer; in do_notify_entry_observers()
187 } while (!tso); in do_notify_entry_observers()
189 ++tso->my_busy_count; in do_notify_entry_observers()
199 tso->on_scheduler_entry(worker); in do_notify_entry_observers()
201 intptr_t bc = --tso->my_busy_count; in do_notify_entry_observers()
240 tso = p->my_observer; in do_notify_exit_observers()
241 } while (!tso); in do_notify_exit_observers()
245 ++tso->my_busy_count; in do_notify_exit_observers()
253 tso->on_scheduler_exit(worker); in do_notify_exit_observers()
[all …]
|
| /dports/math/deal.ii/dealii-803d21ff957e349b3799cd3ef2c840bc78734305/bundled/tbb-2018_U2/src/tbb/ |
| H A D | observer_proxy.cpp | 227 tso = p->my_observer; in do_notify_entry_observers()
228 } while( !tso ); in do_notify_entry_observers()
230 ++tso->my_busy_count; in do_notify_entry_observers()
239 tso->on_scheduler_entry(worker); in do_notify_entry_observers()
277 tso = p->my_observer; in do_notify_exit_observers()
278 } while( !tso ); in do_notify_exit_observers()
282 ++tso->my_busy_count; in do_notify_exit_observers()
290 tso->on_scheduler_exit(worker); in do_notify_exit_observers()
333 } while( !tso ); in ask_permission_to_leave()
335 ++tso->my_busy_count; in ask_permission_to_leave()
[all …]
|
| /dports/devel/concurrentqueue/concurrentqueue-1.0.3-15-g0753496/benchmarks/tbb/ |
| H A D | observer_proxy.cpp | 222 tso = p->my_observer; in do_notify_entry_observers()
223 } while( !tso ); in do_notify_entry_observers()
225 ++tso->my_busy_count; in do_notify_entry_observers()
234 tso->on_scheduler_entry(worker); in do_notify_entry_observers()
272 tso = p->my_observer; in do_notify_exit_observers()
273 } while( !tso ); in do_notify_exit_observers()
277 ++tso->my_busy_count; in do_notify_exit_observers()
285 tso->on_scheduler_exit(worker); in do_notify_exit_observers()
328 } while( !tso ); in ask_permission_to_leave()
330 ++tso->my_busy_count; in ask_permission_to_leave()
[all …]
|
| /dports/lang/ghc/ghc-8.8.4-boot/includes/rts/storage/ |
| H A D | TSO.h | 27 #define tsoLocked(tso) ((tso)->flags & TSO_LOCKED) argument
198 INLINE_HEADER StgPtr tso_SpLim (StgTSO* tso) in tso_SpLim() argument
200 return tso->stackobj->stack + RESERVED_STACK_WORDS; in tso_SpLim()
207 void dirty_TSO (Capability *cap, StgTSO *tso);
208 void setTSOLink (Capability *cap, StgTSO *tso, StgTSO *target);
209 void setTSOPrev (Capability *cap, StgTSO *tso, StgTSO *target);
|
| /dports/lang/ghc/ghc-8.10.7/includes/rts/storage/ |
| H A D | TSO.h | 27 #define tsoLocked(tso) ((tso)->flags & TSO_LOCKED) argument
254 INLINE_HEADER StgPtr tso_SpLim (StgTSO* tso) in tso_SpLim() argument
256 return tso->stackobj->stack + RESERVED_STACK_WORDS; in tso_SpLim()
263 void dirty_TSO (Capability *cap, StgTSO *tso);
264 void setTSOLink (Capability *cap, StgTSO *tso, StgTSO *target);
265 void setTSOPrev (Capability *cap, StgTSO *tso, StgTSO *target);
|
| /dports/math/stanmath/math-4.2.0/lib/tbb_2020.3/src/tbb/ |
| H A D | observer_proxy.cpp | 188 task_scheduler_observer_v3* tso=NULL; in do_notify_entry_observers() local
223 tso = p->my_observer; in do_notify_entry_observers()
224 } while( !tso ); in do_notify_entry_observers()
226 ++tso->my_busy_count; in do_notify_entry_observers()
235 tso->on_scheduler_entry(worker); in do_notify_entry_observers()
237 intptr_t bc = --tso->my_busy_count; in do_notify_entry_observers()
273 tso = p->my_observer; in do_notify_exit_observers()
274 } while( !tso ); in do_notify_exit_observers()
278 ++tso->my_busy_count; in do_notify_exit_observers()
286 tso->on_scheduler_exit(worker); in do_notify_exit_observers()
[all …]
|
| /dports/devel/tbb/oneTBB-2020.3/src/tbb/ |
| H A D | observer_proxy.cpp | 188 task_scheduler_observer_v3* tso=NULL; in do_notify_entry_observers() local
223 tso = p->my_observer; in do_notify_entry_observers()
224 } while( !tso ); in do_notify_entry_observers()
226 ++tso->my_busy_count; in do_notify_entry_observers()
235 tso->on_scheduler_entry(worker); in do_notify_entry_observers()
237 intptr_t bc = --tso->my_busy_count; in do_notify_entry_observers()
273 tso = p->my_observer; in do_notify_exit_observers()
274 } while( !tso ); in do_notify_exit_observers()
278 ++tso->my_busy_count; in do_notify_exit_observers()
286 tso->on_scheduler_exit(worker); in do_notify_exit_observers()
[all …]
|
| /dports/devel/taskflow/taskflow-3.2.0/3rd-party/tbb/src/tbb/ |
| H A D | observer_proxy.cpp | 188 task_scheduler_observer_v3* tso=NULL; in do_notify_entry_observers() local
223 tso = p->my_observer; in do_notify_entry_observers()
224 } while( !tso ); in do_notify_entry_observers()
226 ++tso->my_busy_count; in do_notify_entry_observers()
235 tso->on_scheduler_entry(worker); in do_notify_entry_observers()
237 intptr_t bc = --tso->my_busy_count; in do_notify_entry_observers()
273 tso = p->my_observer; in do_notify_exit_observers()
274 } while( !tso ); in do_notify_exit_observers()
278 ++tso->my_busy_count; in do_notify_exit_observers()
286 tso->on_scheduler_exit(worker); in do_notify_exit_observers()
[all …]
|