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
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
|
/* --------------------------------------------------------------------------
Time-stamp: <Sun Mar 18 2001 21:23:50 Stardate: [-30]6349.45 hwloidl>
Low Level Communications Header (LLC.h)
Contains the definitions used by the Low-level Communications
module of the GUM Haskell runtime environment.
Based on the Graph for PVM implementation.
Phil Trinder, Glasgow University, 13th Dec 1994
Adapted for the 4.xx RTS
H-W. Loidl, Heriot-Watt, November 1999
----------------------------------------------------------------------- */
#ifndef __LLC_H
#define __LLC_H
#ifdef PAR
//@node Low Level Communications Header, , ,
//@section Low Level Communications Header
//@menu
//* Includes::
//* Macros and Constants::
//* PVM macros::
//* Externs::
//@end menu
//@node Includes, Macros and Constants, Low Level Communications Header, Low Level Communications Header
//@subsection Includes
#include "Rts.h"
#include "Parallel.h"
#include "PEOpCodes.h"
#include "pvm3.h"
//@node Macros and Constants, PVM macros, Includes, Low Level Communications Header
//@subsection Macros and Constants
#define ANY_TASK (-1) /* receive messages from any task */
#define ANY_GLOBAL_TASK ANY_TASK
#define ANY_OPCODE (-1) /* receive any opcode */
#define ALL_GROUP (-1) /* wait for barrier from every group member */
#define PEGROUP "PE"
#define MGRGROUP "MGR"
#define SYSGROUP "SYS"
#define PETASK "PE"
//@node PVM macros, Externs, Macros and Constants, Low Level Communications Header
//@subsection PVM macros
#define sync(gp,op) do { \
broadcast(gp,op); \
pvm_barrier(gp,ALL_GROUP); \
} while(0)
#define broadcast(gp,op) do { \
pvm_initsend(PvmDataDefault); \
pvm_bcast(gp,op); \
} while(0)
#define checkComms(c,s) do { \
if ((c)<0) { \
pvm_perror(s); \
stg_exit(EXIT_FAILURE); \
}} while(0)
#define _my_gtid pvm_mytid()
#define GetPacket() pvm_recv(ANY_TASK,ANY_OPCODE)
#define PacketsWaiting() (pvm_probe(ANY_TASK,ANY_OPCODE) != 0)
#define SPARK_THREAD_DESCRIPTOR 1
#define GLOBAL_THREAD_DESCRIPTOR 2
#define _extract_jump_field(v) (v)
#define MAX_DATA_WORDS_IN_PACKET 1024
/* basic PVM packing */
#define PutArg1(a) pvm_pklong((long *)&(a),1,1)
#define PutArg2(a) pvm_pklong((long *)&(a),1,1)
#define PutArgN(n,a) pvm_pklong((long *)&(a),1,1)
#define PutArgs(b,n) pvm_pklong((long *)b,n,1)
#define PutLit(l) { int a = l; PutArgN(?,a); }
/* basic PVM unpacking */
#define GetArg1(a) pvm_upklong((long *)&(a),1,1)
#define GetArg2(a) pvm_upklong((long *)&(a),1,1)
#define GetArgN(n,a) pvm_upklong((long *)&(a),1,1)
#define GetArgs(b,n) pvm_upklong((long *)b,n,1)
//@node Externs, , PVM macros, Low Level Communications Header
//@subsection Externs
/* basic message passing routines */
extern void sendOp (OpCode,GlobalTaskId),
sendOp1 (OpCode,GlobalTaskId,StgWord),
sendOp2 (OpCode,GlobalTaskId,StgWord,StgWord),
sendOpV (OpCode,GlobalTaskId,int,...),
sendOpN (OpCode,GlobalTaskId,int,StgPtr),
sendOpNV (OpCode,GlobalTaskId,int,StgPtr,int,...);
extern void broadcastOpN(OpCode op, char *group, int n, StgPtr args);
/* extracting data out of a packet */
OpCode getOpcode (rtsPacket p);
void getOpcodeAndSender (rtsPacket p, OpCode *popcode,
GlobalTaskId *psender_id);
GlobalTaskId senderTask (rtsPacket p);
rtsPacket waitForPEOp(OpCode op, GlobalTaskId who, void(*processUnexpected)(rtsPacket) );
/* Init and shutdown routines */
void startUpPE (void);
void shutDownPE(void);
int getExitCode(int nbytes, GlobalTaskId *sender_idp);
/* aux functions */
char *getOpName (unsigned op); // returns string of opcode
void processUnexpectedMessage (rtsPacket);
//void NullException(void);
#endif /*PAR */
#endif /*defined __LLC_H */
|
