Mercurial > cgi-bin > hgwebdir.cgi > VMS > VMS_Implementations > VMS_impls > VMS__MC_shared_impl

view VMS.h @ 22:1dbc7f6e3e67

find changesets by author, revision, files, or words in the commit message
Full VMS test -- works
author Me
date Wed, 30 Jun 2010 13:10:59 -0700
parents 4b58b9a2527b
children aa634ef7cc35
line source
1 /*
2 * Copyright 2009 OpenSourceStewardshipFoundation.org
3 * Licensed under GNU General Public License version 2
4 *
5 * Author: seanhalle@yahoo.com
6 *
7 */
8
9 #ifndef _VMS_H
10 #define _VMS_H
11
12 #include "VMS_primitive_data_types.h"
13 #include "Queue_impl/BlockingQueue.h"
14 #include <windows.h>
15 #include <winbase.h>
16
17 //This value is the number of hardware threads in the shared memory
18 // machine -- make double that number scheduling slots, plus extra for master
19 #define NUM_CORES 4
20 #define NUM_SCHED_SLOTS 9
21
22 #define SUCCESS 0
23
24 //#define thdAttrs NULL //For PThreads
25
26 typedef struct _SchedSlot SchedSlot;
27 typedef struct _SlaveReqst SlaveReqst;
28 typedef struct _VirtProcr VirtProcr;
29
30 typedef bool8 (*SlaveScheduler) ( SchedSlot *, void * );
31 typedef void (*RequestHandler) ( SlaveReqst * );
32 typedef void (*VirtProcrFnPtr) ( void *, VirtProcr * );
33 typedef void VirtProcrFn( void *, VirtProcr * );
34
35
36 typedef struct
37 {
38 void *endThdPt;
39 unsigned int coreNum;
40 // void *framePtr;
41 // void *stackPtr;
42 }
43 ThdParams;
44
45
46 struct _SchedSlot
47 {
48 int workIsDone;
49 int needsProcrAssigned;
50 VirtProcr *procrAssignedToSlot;
51 };
52 //SchedSlot
53
54
55 struct _SlaveReqst
56 {
57 VirtProcr *slaveFrom;
58 int reqType; //for future when have I/O and OS services
59 void *semReqData;
60
61 SlaveReqst *nextRequest;
62 };
63 //SlaveReqst
64
65 struct _VirtProcr
66 { int procrID; //for debugging -- count up each time create
67 int coreAnimatedBy;
68 void *stackPtr;
69 void *framePtr;
70 void *nextInstrPt;
71
72 void *coreLoopStartPt; //allows proto-runtime to be linked later
73 void *coreLoopFramePtr; //restore before jmp back to core loop
74 void *coreLoopStackPtr; //restore before jmp back to core loop
75
76 void *initialData;
77
78 SchedSlot *schedSlot;
79 SlaveReqst *requests;
80
81 void *semanticData;
82 };
83 //VirtProcr
84
85
86
87 typedef struct
88 {
89 SlaveScheduler slaveScheduler;
90 RequestHandler requestHandler;
91
92 SchedSlot **schedSlots;
93 SchedSlot **filledSlots;
94 int numFilled;
95
96 int stillRunning;
97
98 VirtProcr *masterVirtPr;
99 void *semanticEnv;
100 void *OSEventStruc; //for future, when add I/O to BLIS
101
102 void *coreLoopShutDownPt; //addr to jump to to shut down a coreLoop
103 }
104 MasterEnv;
105
106
107 //==========================================================
108
109 DWORD WINAPI coreLoop( LPVOID paramsIn );
110 //void * coreLoop( void *paramsIn ); //standard PThreads fn prototype
111 void masterLoop( void *initData, VirtProcr *masterPr );
112
113
114 //===================== Global Vars ===================
115
116
117 HANDLE coreLoopThdHandles[ NUM_CORES ]; //windows handle to thread
118 ThdParams *coreLoopThdParams[ NUM_CORES ];
119 DWORD coreLoopThdIds[ NUM_CORES ];
120
121 //TODO: Debug: figure out if need to be volatile or not
122 volatile MasterEnv *_VMSMasterEnv;
123
124 //workQ is global, static, and volatile so that core loop has its location
125 // hard coded, and reloads every time through the loop -- that way don't
126 // need to save any regs used by core loop (will see if this really works)
127 volatile CASQueueStruc *_VMSWorkQ;
128
129 //==========================
130 void
131 VMS__init();
132
133 void
134 VMS__start();
135
136 VirtProcr *
137 VMS__create_procr( VirtProcrFnPtr fnPtr, void *initialData );
138
139 inline void
140 VMS__send_sem_request( void *semReqData, VirtProcr *callingPr );
141
142 void
143 VMS__suspend_processor( VirtProcr *callingPr );
144
145 //============================= Statistics ==================================
146
147 typedef unsigned long long TSCount;
148
149 #define saveTimeStampCountInto(low, high) \
150 asm volatile("RDTSC; \
151 movl %%eax, %0; \
152 movl %%edx, %1;" \
153 /* outputs */ : "=m" (low), "=m" (high)\
154 /* inputs */ : \
155 /* clobber */ : "%eax", "%edx" \
156 );
157
158 inline TSCount getTSCount();
159
160 int numProcrsCreated;
161
162 #endif /* _VMS_H */
163