DIRECTORY
Basics USING [bytesPerWord, LongDivMod],
BootFile USING [GetPageValue, IsVacant, SetPageValue],
Endian USING [FWORD],
GermPrivate USING[Error],
MiniEthernetDefs USING [ActivateDriver, KillDriver, RecvPacket, ReturnPacket],
MPCodes USING [germDeviceError, germTeledebugServer],
PrincOps USING [flagsVacant, PageNumber, PageValue, wordsPerPage],
PrincOpsUtils USING [AddressForPageNumber, LongCopy, LowHalf],
ProcessorFace USING [SetMP],
Pup USING [Address, nullAddress],
PupType USING [teledebugAck, teledebugGoReply, teledebugGoRequest, Type],
PupWKS USING [teleSwat],
SA4000Face USING [Command, GetDeviceAttributes, GetNextDevice, globalStateSize, Initialize, Initiate, nullDeviceHandle, Operation, operationSize, Poll],
TeledebugProtocol USING [CoreFetchAcknowledgement, coreFetchAcknowledgementSize, CoreFetchRequest, CoreStoreAcknowledgement, coreStoreAcknowledgementSize, CoreStoreRequest, DiskAddressSetAcknowledgement, DiskAddressSetRequest, DiskFetchAcknowledgement, diskFetchAcknowledgementSize, DiskStoreAcknowledgement, diskStoreAcknowledgementSize, DiskStoreRequest, Label];

TeledebugImpl: PROGRAM
IMPORTS Basics, BootFile, GermPrivate, MiniEthernetDefs, PrincOpsUtils, ProcessorFace, SA4000Face
EXPORTS GermPrivate--TeleDebug-- = {

etherIOCBSize: CARDINAL = 30;

MyPup: TYPE = RECORD [
SELECT OVERLAID * FROM
a => [coreStoreRequest: TeledebugProtocol.CoreStoreRequest],
b => [coreStoreAcknowledgement: TeledebugProtocol.CoreStoreAcknowledgement],
c => [coreFetchRequest: TeledebugProtocol.CoreFetchRequest],
d => [coreFetchAcknowledgement: TeledebugProtocol.CoreFetchAcknowledgement],
e => [diskStoreRequest: TeledebugProtocol.DiskStoreRequest],
f => [diskStoreAcknowledgement: TeledebugProtocol.DiskStoreAcknowledgement],
g => [diskFetchAcknowledgement: TeledebugProtocol.DiskFetchAcknowledgement],
h => [diskAddressSetRequest: TeledebugProtocol.DiskAddressSetRequest],
i => [diskAddressSetAcknowledgement:
TeledebugProtocol.DiskAddressSetAcknowledgement],
ENDCASE];

diskAddressPup: TeledebugProtocol.DiskAddressSetRequest;
bytes: INTEGER;
id: Endian.FWORD;
pAllocateNext: LONG POINTER; -- iocb's and stuff in first 64K
pup: MyPup;
sa4000IOCB: LONG POINTER TO SA4000Face.Operation;
sender: Pup.Address;
temp: CARDINAL;
type: PupType.Type;

TeleDebug: PUBLIC PROC [scratchPage: PrincOps.PageNumber, dFirst64KStorage: LONG DESCRIPTOR FOR ARRAY OF WORD] = {
Allocate: PROC [size: CARDINAL] RETURNS [lp: LONG POINTER] = {
pAllocateNext _ (lp _ pAllocateNext) + LONG[((size + 15)/16)*16];
};
LongTime: PROC RETURNS [BOOL] = {RETURN[FALSE]};
SetNoLabel: PROC [p: LONG POINTER] = {
p^ _ -1;
PrincOpsUtils.LongCopy[from: p, to: p + 1, nwords: SIZE[TeledebugProtocol.Label] - 1];
};

pAllocateNext _ BASE[dFirst64KStorage]; -- reset first 64K allocator
SA4000Face.Initialize[0,
LOOPHOLE[PrincOpsUtils.LowHalf[Allocate[SA4000Face.globalStateSize]]]];
sa4000IOCB _ Allocate[SA4000Face.operationSize];
IF ~MiniEthernetDefs.ActivateDriver[Allocate[etherIOCBSize]] THEN
GermPrivate.Error[MPCodes.germDeviceError];
ProcessorFace.SetMP[MPCodes.germTeledebugServer];
DO
sender _ Pup.nullAddress; -- talk to anybody
[bytes, id, type] _ MiniEthernetDefs.RecvPacket[
@sender, PupWKS.teleSwat, @pup, SIZE[MyPup, Basics.bytesPerWord], LongTime];
SELECT type FROM
pageFetchRequest => {
OPEN p: pup.coreFetchAcknowledgement;
pPage: PrincOps.PageNumber = p.page;
IF bytes # SIZE[TeledebugProtocol.CoreFetchRequest, Basics.bytesPerWord] THEN LOOP;
IF ~BootFile.IsVacant[pPage] THEN {
pv: PrincOps.PageValue _ BootFile.GetPageValue[pPage];
p.flags _ LOOPHOLE[pv.state.flags];
PrincOpsUtils.LongCopy[
from: PrincOpsUtils.AddressForPageNumber[pPage], to: @p.data, nwords: PrincOps.wordsPerPage];
BootFile.SetPageValue[pPage, pv];
}
ELSE p.flags _ LOOPHOLE[PrincOps.flagsVacant];
bytes _ TeledebugProtocol.coreFetchAcknowledgementSize*Basics.bytesPerWord;
};
pageStoreRequest => {
OPEN p: pup.coreStoreRequest;
pPage: PrincOps.PageNumber = p.page;
IF bytes # SIZE[TeledebugProtocol.CoreStoreRequest, Basics.bytesPerWord] THEN LOOP;
IF ~BootFile.IsVacant[pPage] THEN {
v: PrincOps.PageValue _ BootFile.GetPageValue[pPage];
v.state.flags.readonly _ FALSE;
BootFile.SetPageValue[pPage, v];
PrincOpsUtils.LongCopy[
to: PrincOpsUtils.AddressForPageNumber[pPage], from: @p.data, nwords: PrincOps.wordsPerPage];
v.state.flags _ LOOPHOLE[p.flags];
BootFile.SetPageValue[pPage, v];
}
ELSE p.flags _ LOOPHOLE[PrincOps.flagsVacant];
bytes _ TeledebugProtocol.coreStoreAcknowledgementSize*Basics.bytesPerWord;
};
diskAddress => {
IF bytes #SIZE[TeledebugProtocol.DiskAddressSetRequest, Basics.bytesPerWord] THEN LOOP;
PrincOpsUtils.LongCopy[  -- just save it.
to: @diskAddressPup, from: @pup.diskAddressSetRequest,
nwords: SIZE[TeledebugProtocol.DiskAddressSetRequest]];
};
diskFetchRequest => {
OPEN p: pup.diskFetchAcknowledgement;
IF bytes # SIZE[TeledebugProtocol.DiskAddressSetRequest, Basics.bytesPerWord] THEN LOOP;
PrincOpsUtils.LongCopy[                          -- save disk address request.
to: @diskAddressPup, from: @pup.diskAddressSetRequest,
nwords: SIZE[TeledebugProtocol.DiskAddressSetRequest]];
IF ~RunDisk[vrr, scratchPage, @p.label, @p.data] THEN SetNoLabel[@p.label];
bytes _ TeledebugProtocol.diskFetchAcknowledgementSize*Basics.bytesPerWord;
};
diskStoreRequest => {
OPEN p: pup.diskStoreRequest;
IF bytes # SIZE[TeledebugProtocol.DiskStoreRequest, Basics.bytesPerWord] THEN LOOP;
IF ~RunDisk[vvw, scratchPage, @p.label, @p.data] THEN
SetNoLabel[@pup.diskStoreAcknowledgement.label];
bytes _ TeledebugProtocol.diskStoreAcknowledgementSize*Basics.bytesPerWord;
};
PupType.teledebugGoRequest => {
GoConfirm: PROC RETURNS [BOOL] = INLINE {
tenSecondsCount: CARDINAL = LAST[CARDINAL];
MiniEthernetDefs.ReturnPacket[PupType.teledebugAck, id, @pup, 0];
temp _ tenSecondsCount;
[bytes, id, type] _ MiniEthernetDefs.RecvPacket[
@sender, PupWKS.teleSwat, @pup, SIZE[MyPup, Basics.bytesPerWord], TenSeconds];
RETURN[bytes = -1 OR type = PupType.teledebugGoReply];
};
TenSeconds: PROC RETURNS [BOOL] = {RETURN[(temp _ temp - 1) = 0]};
IF bytes = 0 AND GoConfirm[] THEN {MiniEthernetDefs.KillDriver[]; RETURN}
ELSE LOOP; -- unexpected respose; ignore
};
ENDCASE => LOOP;
MiniEthernetDefs.ReturnPacket[PupType.teledebugAck, id, @pup, bytes];
ENDLOOP;
};

RunDisk: PROC [c: SA4000Face.Command, scratchPage: PrincOps.PageNumber, labelP, dataP: POINTER] RETURNS [BOOL] = {
OPEN o: sa4000IOCB, SA4000Face;
IF diskAddressPup.device # sa4000 THEN RETURN[FALSE];
o.device _ nullDeviceHandle;
THROUGH [0..diskAddressPup.deviceOrdinal] DO
IF (o.device _ GetNextDevice[o.device]) = nullDeviceHandle THEN RETURN[FALSE];
ENDLOOP;
[quotient: temp, remainder: o.clientHeader.sector] _ Basics.LongDivMod[
num: diskAddressPup.page, den: GetDeviceAttributes[o.device].sectorsPerTrack];
o.clientHeader.head _ temp MOD GetDeviceAttributes[o.device].movingHeads;
o.clientHeader.cylinder _ temp/GetDeviceAttributes[o.device].movingHeads;
o.labelPtr _ labelP; o.dataPtr _ PrincOpsUtils.AddressForPageNumber[scratchPage];
o.incrementDataPtr _ FALSE; o.command _ c; o.pageCount _ 1;
IF c = vvw THEN
PrincOpsUtils.LongCopy[from: LONG[dataP], to: o.dataPtr, nwords: PrincOps.wordsPerPage];
THROUGH [0..8) DO
SA4000Face.Initiate[sa4000IOCB];
DO
SELECT SA4000Face.Poll[sa4000IOCB] FROM
inProgress => LOOP;
goodCompletion => {
IF c = vrr THEN PrincOpsUtils.LongCopy[
to: LONG[dataP], from: o.dataPtr, nwords: PrincOps.wordsPerPage];
RETURN[TRUE];
};
ENDCASE --ERROR-- => EXIT;
ENDLOOP;
ENDLOOP;
RETURN[FALSE];
};

}.

LOG
Time: March 21, 1980  6:58 PM	By: Forrest	Action: Create file
Time: March 24, 1980  11:45 AM	By: Forrest	Action: initialize sender, fix maxVirtualPages
Time: April 1, 1980  2:53 PM	By: Forrest	Action: Add Disk Implementation
Time: April 7, 1980  7:11 PM	By: Forrest	Action: Added SetDiskAddress+Fetch enhancement
Time: April 10, 1980  12:19 PM	By: Forrest	Action: RCPProtocol => TeledebugProtocol
Time: April 22, 1980  5:41 PM	By: McJones	Action: Add avoidCleanup: TRUE to ActivateDriver call
Time: June 25, 1980  4:21 PM	By: McJones	Action: OISDisk=>PilotDisk; OISProcessorFace=>ProcessorFace; SA4000Face.Operation: clientLabel+diskLabel=>labelPtr
Time: September 17, 1980  12:45 PM	By: Forrest	Action: change to use returnPacket; zero socket each trip around loop; use GetF, Utilities.LongPointerFromPage
Time: May 24, 1983 12:06 pm	By: Andrew Birrell	Action: Fixed IsVacant for out-of-bounds pages



tTeledebugImpl.mesa
Copyright c 1985 by Xerox Corporation.  All rights reserved.
This is an initial, ugly, ugly, implementation.
Forrest September 17, 1980  2:27 PM
Birrell, October 31, 1983 12:13 pm
Russ Atkinson, February 20, 1985 6:32:33 pm PST
Hal Murray, May 24, 1986 4:01:54 pm PDT

"Locals" to Debug and RunDisk
also check id??? (what to do if wrong)
Send ack
ΚR˜
codeš
œ™Kšœ
Οm
œ1™<Kš
œ/™/Kš
œ#™#K™"K™/K™'—K™š
Οk	˜	Kšœžœ˜(Kšœ	žœ(˜6Kšœžœžœ˜Kšœžœ˜Kšœžœ8˜NKšœžœ(˜5Kšœ	žœ4˜BKšœžœ+˜>Kšœžœ	˜Kšœžœ˜!Kšœžœ<˜IKšœžœ˜Kšœžœˆ
˜˜
KšœžœΥ˜μK˜—šœž˜KšžœZ˜aKšžœΟc
œ˜$K˜Kšœžœ˜K˜Kš
œ™šœžœžœ˜šžœ
žœž˜K˜<K˜LK˜<K˜LK˜<K˜LK˜LK˜F˜$K˜1—Kšžœ˜	K˜——K˜8Kšœžœ
˜Kšœžœ
˜Kšœžœ
žœŸ ˜=K˜Kšœžœ
žœ
žœ˜1K˜Kšœžœ
˜K˜K˜šΟn	œžœ
žœ6žœ
ž
œ
žœ
žœ
žœ
žœ˜rš œžœžœžœžœ
žœ˜>Kšœ'žœ˜AKš
œ˜—Kš œžœ
žœžœžœ
žœ˜0š 
œžœžœ
žœ˜&Kš
œ˜Kšœ3žœ˜VKš
œ˜K˜—KšœžœŸ˜D˜Kšžœ?˜G—K˜0šžœ;ž˜AK˜+—Kš
œ1˜1š
ž˜KšœŸ˜,˜0Kšœ žœ(˜L—šžœž˜˜Kšžœ!˜%Kš
œ$˜$Kšžœ	žœ:žœ
žœ
˜Sšžœžœ˜#Kš
œ6˜6Kšœ
žœ˜#š
œ˜Kš
œ]˜]—Kš
œ!˜!Kš
œ
˜
—Kšžœžœ˜.Kš
œK˜KKš
œ˜—˜Kšžœ˜Kš
œ$˜$Kšžœ	žœ:žœ
žœ
˜Sšžœžœ˜#Kš
œ5˜5Kšœžœ
˜Kš
œ ˜ š
œ˜Kš
œ]˜]—Kšœžœ
˜"Kš
œ ˜ Kš
œ
˜
—Kšžœžœ˜.Kš
œK˜KKš
œ˜—˜Kšžœžœ>žœ
žœ
˜WšœŸ˜)K˜6Kšœžœ+˜7—Kš
œ˜—˜Kšžœ!˜%Kšžœ	žœ?žœ
žœ
˜Xšœ1Ÿ˜NK˜6Kšœžœ+˜7—Kšžœ/žœ˜KKš
œK˜KKš
œ˜—˜Kšžœ˜Kšžœ	žœ:žœ
žœ
˜Sšžœ/ž˜5K˜0—Kš
œK˜KKš
œ˜—š
œ˜š
 	œžœ
žœžœžœ˜)Kšœžœžœ
žœ˜+Kš
œA˜AK˜˜0Kšœ žœ*˜N—Kš
œ&™&Kšžœžœ"˜6Kš
œ˜—Kš
 
œžœ
žœžœžœ˜BKšžœžœ
žœ!žœ
˜IKšžœ
žœŸ˜(Kš
œ˜—Kšžœžœ
˜—Kš
œ™Kš
œE˜EKšžœ
˜—Kš
œ˜K˜—š œžœJžœžœžœž
œ
˜rKšžœ˜Kšžœ žœ
žœ
žœ˜5K˜šžœ#ž˜,Kšžœ9žœ
žœ
žœ˜NKšžœ
˜—˜GK˜N—Kšœžœ+˜IK˜IKš
œQ˜QKšœžœ!˜;šžœ	ž˜Kšœžœ7˜X—šžœž˜K˜ š
ž˜šžœž˜'Kšœžœ
˜š
œ˜šžœ	žœ˜'Kšœžœ9˜A—Kšžœ
žœ˜
Kš
œ˜—Kšžœ
Ÿ	œžœ
˜—Kšžœ
˜—Kšžœ
˜—Kšžœ
žœ˜Kš
œ˜K˜—Kš
œ˜K˜—Kš
ž˜Kšœžœ ˜=Kšœžœ;˜YKšœžœ,˜HKšœžœ;˜WKšœžœ5˜SKšœžœ'žœ˜_Kšœžœ˜›
Kšœ žœ{˜
K˜]K˜K˜—…— Θ)Ž