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
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
|
/*
* file: mpx.h
*
* Header file for the MPX Operating System.
*
* This file contains constant, structure and function
* prototypes for the MPX Operating System
*/
/* MPX System request numbers. */
#define EXIT_CODE 0 /* Process requesting termination. code. */
#define CON 1 /* The console device - keyboard & monitor. */
#define PRT 2 /* The printer device - LPT1. */
#define COM 3 /* The serial port - COM1. */
/* MPX System request types. */
#define READ 0 /* Read from device. */
#define WRITE 1 /* Write to device. */
#define WAIT 2 /* Semaphore P operation for device. */
#define SIGNAL 3 /* Semaphore V operation for device. */
#define MAXSIZE 20 /* Size of the directory array. */
struct dirstruct { /* Data type for a directory entry. */
char dirnam[9]; /* The name of a .mpx file. */
int dirsiz; /* The size of the file (in bytes). */
};
typedef struct dirstruct dir; /* Use dir as the data typer name. */
/**
* PCB
*/
#define FREE 0
#define SYS_PROCESS 1
#define APP_PROCESS 2
#define READY 0
#define RUNNING 1
#define BLOCKED 2
#define NOT_SUSPENDED 0
#define SUSPENDED 1
#define STACK_SIZE 400
struct pcbstruct {
struct pcbstruct * chain;
struct pcbstruct * next;
struct pcbstruct * prev;
char name[9];
short type;
short priority;
short state;
short suspend;
unsigned stack_ptr;
unsigned stack[STACK_SIZE];
unsigned loadaddr;
unsigned parm_add; // added during mod because sys_call said so
int mem_size;
};
typedef struct pcbstruct pcb;
#define INPUT_BUFFER_MAX 40
#define NO_OP 0
#define READ_OP 1
#define WRITE_OP 2
#define MCR 0x3fc
#define IER 0x3f9
#define LCR 0x3fb
#define RBR 0x3f8
#define THR 0x3f8
#define BRDR_LSB 0x3f8
#define BRDR_MSB 0x3f9
#define IIR 0x3fa
#define IMR 0x21 /* Port address of IMR */
#define CMR 0x43 /* Command mode register */
#define IRQ0 0x01 /* Mask for Timer */
#define CLOCK_ENABLE (0xff - IRQ0) /* Mask to clear Timer bit */
#define CLOCK_DISABLE (0x00 + 1) /* Mask to set Timer bit */
/* Device Control Block */
struct dcb_struct {
unsigned current_op;
unsigned * event_flag;
far int * length;
far char * buffer;
int count;
far char * c_buffer;
char ring[INPUT_BUFFER_MAX];
int ring_front;
int ring_rear;
int ring_count;
int ring_size;
};
typedef struct dcb_struct dcb;
/* Function prototypes. */
/* main.c */
int main(void);
/* comhan.c */
void comhan(void); /* The MPX/OS command handler. */
int get_cmd(char args[]);
void cmd_version(void);
void cmd_date(char *[]);
void cmd_directory(void);
int cmd_stop(void);
void cmd_help(char *[]);
void cmd_prompt(char *[]);
void cmd_alias(char *[]);
void cmd_show(char *[]);
void cmd_allocate(char *[]);
void cmd_free(char *[]);
void cmd_load(char *[]);
void cmd_resume(char *[]);
void cmd_run(char *[]);
void cmd_suspend(char *[]);
void cmd_terminate(char *[]);
void cmd_setpri(char *[]);
void cmd_dispatch();
void cmd_clock(char *[]);
void sys_req(int,int,char *,int *); /* MPX system request function. */
int directory(dir *, int); /* Support function to load the */
/* directory array. */
/**
* PCB.C
*/
pcb * search_pcb(pcb *, char[]);
pcb * get_pcb(pcb *);
int free_pcb(pcb *, pcb *);
int build_pcb(pcb *, char[] /*name*/, int /*type*/, int /*state*/,
int /*suspend*/, int /*priority*/, unsigned /*_cs*/, unsigned /*_ip*/,
unsigned /*_ds*/, unsigned /*psw*/);
int insert_pcb(pcb**, pcb *, int);
int remove_pcb(pcb**, pcb *);
/**
* DCB.c
*/
void dcb_enqueue(dcb*, char);
char dcb_dequeue(dcb*);
void dcb_init(dcb*);
/**
* Sys_sppt.c
*/
void sys_inti(void);
void sys_exit(void);
void clock_open(void);
void clock_close(void);
void stop_clock(void);
void start_clock(void);
int set_clock(int, int, int);
void read_clock(int*, int*, int*);
void interrupt dispatch(void);
void interrupt sys_call(void);
void interrupt clock_int(void);
/**
* Load.c
*/
int load(unsigned *,char []);
/**
* Com.c
*/
int com_open(int *, int);
void com_close(void);
void interrupt com_int(void);
int com_read(char far *, int far *);
int com_write(char far *, int far *);
int com_read_int();
int com_write_int();
/**
* Printer.c
*/
#define PCR 0x3be
#define PDR 0x3bc
int prt_open(int *);
int prt_write(char far *, int *);
int prt_close(void);
void interrupt prt_int(void);
/*
* Global variable EXTERN directives.
*
* These extern declarations allow the variables to be
* accessed from any source code file which includes
* this header file. The memory space for the variables
* is declared in a *.c file.
*/
#define DIR_SIZE 20
extern dcb com;
extern dir direct[]; /* Array of directory entries - see direct.c */
extern int directory(dir *direct, int dir_size);
extern pcb * pcb_list;
extern pcb * ready_queue;
extern pcb * io_init_queue;
extern pcb * cop; /* The currently operating process. */
extern unsigned sys_stack[];
extern unsigned sp_save; /* So that mod 4 can return to cmd_dispatch */
|
