blob: cffe99dd390f82c0dccad5b1911c3b84c25826f2 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
|
/* -----------------------------------------------------------------------------
*
* (c) The GHC Team, 2000-2009
*
* Sparking support for GRAN, PAR and THREADED_RTS versions of the RTS.
*
* ---------------------------------------------------------------------------*/
#ifndef SPARKS_H
#define SPARKS_H
#include "WSDeque.h"
#include "BeginPrivate.h"
/* typedef for SparkPool in RtsTypes.h */
#if defined(THREADED_RTS)
typedef WSDeque SparkPool;
// Initialisation
void initSparkPools (void);
// Take a spark from the "write" end of the pool. Can be called
// by the pool owner only.
INLINE_HEADER StgClosure* reclaimSpark(SparkPool *pool);
// Returns True if the spark pool is empty (can give a false positive
// if the pool is almost empty).
INLINE_HEADER rtsBool looksEmpty(SparkPool* deque);
StgClosure * tryStealSpark (Capability *cap);
void freeSparkPool (SparkPool *pool);
void createSparkThread (Capability *cap);
void traverseSparkQueue(evac_fn evac, void *user, Capability *cap);
void pruneSparkQueue (Capability *cap);
INLINE_HEADER void discardSparks (SparkPool *pool);
INLINE_HEADER long sparkPoolSize (SparkPool *pool);
/* -----------------------------------------------------------------------------
* PRIVATE below here
* -------------------------------------------------------------------------- */
INLINE_HEADER StgClosure* reclaimSpark(SparkPool *pool)
{
return popWSDeque(pool);
}
INLINE_HEADER rtsBool looksEmpty(SparkPool* deque)
{
return looksEmptyWSDeque(deque);
}
INLINE_HEADER long sparkPoolSize (SparkPool *pool)
{
return dequeElements(pool);
}
INLINE_HEADER void discardSparks (SparkPool *pool)
{
discardElements(pool);
}
#endif // THREADED_RTS
#include "EndPrivate.h"
#endif /* SPARKS_H */
|
