Trailing-Edge
-
PDP-10 Archives
-
bb-lw55a-bm
-
galaxy-sources/qsrque.mac
There are 44 other files named qsrque.mac in the archive. Click here to see a list.
TITLE QSRQUE -- Batch Queue Message Handlers for QUASAR
SUBTTL Preliminaries
; COPYRIGHT (c) DIGITAL EQUIPMENT CORPORATION 1975, 1988.
; ALL RIGHTS RESERVED.
;
; THIS SOFTWARE IS FURNISHED UNDER A LICENSE AND MAY BE USED AND COPIED
; ONLY IN ACCORDANCE WITH THE TERMS OF SUCH LICENSE AND WITH THE
; INCLUSION OF THE ABOVE COPYRIGHT NOTICE. THIS SOFTWARE OR ANY OTHER
; COPIES THEREOF MAY NOT BE PROVIDED OR OTHERWISE MADE AVAILABLE TO ANY
; OTHER PERSON. NO TITLE TO AND OWNERSHIP OF THE SOFTWARE IS HEREBY
; TRANSFERRED.
;
; THE INFORMATION IN THIS SOFTWARE IS SUBJECT TO CHANGE WITHOUT NOTICE
; AND SHOULD NOT BE CONSTRUED AS A COMMITMENT BY DIGITAL EQUIPMENT
; CORPORATION.
;
; DIGITAL ASSUMES NO RESPONSIBILITY FOR THE USE OR RELIABILITY OF ITS
; SOFTWARE ON EQUIPMENT THAT IS NOT SUPPLIED BY DIGITAL.
SEARCH QSRMAC,ORNMAC,GLXMAC ;PARAMETER FILE
PROLOGUE(QSRQUE) ;GENERATE THE NECESSARY SYMBOLS
QUEMAN==:0 ;Maintenance edit number
QUEDEV==:42 ;Development edit number
VERSIN (QUE) ;Generate edit number
Subttl Table of Contents
; Table of Contents for QSRQUE
;
; Section Page
;
;
; 1. Revision history . . . . . . . . . . . . . . . . . . . 3
; 2. STOPCDs found in QSRQUE . . . . . . . . . . . . . . . 4
; 3. Queue Headers and Module Storage . . . . . . . . . . . 5
; 4. Queue Database Initialization . . . . . . . . . . . . 6
; 5. Batch and Spooling Message Handlers . . . . . . . . . 7
; 6. RELEASE - Function 2 . . . . . . . . . . . . . . . . . 8
; 7. CHECKPOINT - Function 3 . . . . . . . . . . . . . . . 9
; 8. REQUEUE - Function 4 . . . . . . . . . . . . . . . . . 11
; 9. Q$RNXT - Check for NEXTJOB message from a remote node 13
; 10. CREATE - Function 7 . . . . . . . . . . . . . . . . . 14
; 11. SHORT CREATE MESSAGE PROCESSOR (SOON TO BE ONLY CREATE 16
; 12. SHORT CREATE MESSAGE ACTION ROUTINES . . . . . . . . . 18
; 13. MODIFY - Function 11 . . . . . . . . . . . . . . . . . 23
; 14. KILL - Function 12 . . . . . . . . . . . . . . . . . . 27
; 15. REMKIL - Forward a KILL message to a remote cluster no 28
; 16. DEFER - Function 16 . . . . . . . . . . . . . . . . . 29
; 17. HOLD/RELEASE - Function 25 . . . . . . . . . . . . . . 31
; 18. SPOOL - IPCC Function .IPCSU (26) . . . . . . . . . . 32
; 19. LOGOUT - IPCC Function .IPCSL (27) . . . . . . . . . . 33
; 20. Global Subroutines . . . . . . . . . . . . . . . . . . 35
; 21. Q$FSPL - Find a SPL Queue entry . . . . . . . . . . . 36
; 22. Q$INCL - Append a File to a Request . . . . . . . . . 38
; 23. Q$SUSE - Search USE for an ITN . . . . . . . . . . . . 39
; 24. Q$ADEP - Add a dependency to a jobs dependency list . 40
; 25. Q$CDEP - Check a jobs dependency list . . . . . . . . 41
; 26. Subroutines to maintain DELETE list . . . . . . . . . 42
; 27. Q$DLFL - Delete a spooled file . . . . . . . . . . . . 43
; 28. Q$DLFR - Rebuild an entry in the DELETE list . . . . . 45
; 29. DLFREQ - Add an EQ to the DELETE list . . . . . . . . 46
; 30. Q$NOTIFY - ROUTINE TO VALIDATE A /NOTIFY REQUEST . . . 47
; 31. Q$KPRO - ROUTINE TO TAKE A REQUEST OUT OF A PROCESSING 49
; 32. Subroutines . . . . . . . . . . . . . . . . . . . . . 50
; 33. VALMSG - Routine to validate message from known compon 51
; 34. KILUSE - ROUTINE TO ABORT A JOB IN THE USE QUEUE . . . 52
; 35. FNDREQ - Utility for KILL/MODIFY to find all matches . 53
; 36. SPROTO - Build a CREATE Message Prototype . . . . . . 55
; 37. MAJMOD - Perform MODIFY on Major Queue Items . . . . . 56
; 38. BLDKMS - Routine to build KILL/MODIFY/DEFER acknowledg 57
; 39. TYPPLR - Routine to pluralize a message . . . . . . . 58
; 40. NOTIFY - ROUTINE TO NOTIFY THE USER HIS JOB IS DONE . 59
SUBTTL Revision history
COMMENT \
***** Release 4.2 -- begin maintenance edits *****
2 4.2.1557 27-Oct-83
Preserve queue request across modify commands. And skip
the MDA stuff in MODI.5 Old QUASAR edit number 1222.
3 4.2.1582 20-Jul-84
If the priority of a PRINT or SUBMIT request has been changed
indicate so in the acknowledgment.
4 4.2.1589 5-Sep-84
Allow input queue to be a valid queue type for the short create
message function .QBODP
5 4.2.1591 13-Sep-84
Prevent CRS crashes due to GTJFN failures. Instead inform OPR
of the failure and flush the request.
6 4.2.1607 20-Feb-85
In Q$MODIFY, set new bit .QIMOD to indicate that this is a modify
request. In Q$CREATE, check to see if it is a modify; if it is, then do not
increment the QE.
7 4.2.1610 28-Feb-85
Insure that notification requests get processed in the next scheduling
pass.
10 4.2.1612 8-Mar-85
Correct short create processing of the /USER switch to place into
.EQOID of the EQ corresponding to the job request the user number corresponding
to the user specified in the /USER switch.
11 4.2.1619 24-Jun-85
Correct the X macro definition that defines object types so that short
create physical unit blocks will not be rejected.
***** Release 5.0 -- begin development edits *****
10 5.1003 7-Jan-83
Move to new development area. Add version vector. Clean up
edit organization. Update TOC.
11 5.1070 30-Jan-84
Modify to support QUEUE% JSYS
12 5.1162 21-Sep-84
Add table entry for SNA object type
13 5.1173 23-Oct-84
Add a new block .QCSNA to be used by SNASUB for processing of
NOTRANSLATE, RECORD and TAB
***** Release 5.0 -- begin maintenance edits *****
20 Increment maintenance edit level for GALAXY 5.
21 5.1231 7-Feb-86
At CRQNOT:+3L change the range check from CAIG to CAILE so that we
are checking for 0 (NO) and 1 (YES).
***** Release 6.0 -- begin development edits *****
25 6.1042 29-Oct-87
Add support for the processing of remote printer requests.
26 6.1044 29-Oct-87
Modify routine FNDREQ to match only the right half of the QE's
type word when looking for a match in KILL and MODIFY requests. This
ensures that remote printer requests will be matched successfully.
27 6.1067 9-Nov-87
Add support for dealing with NEXTJOB messages that come from
LISSPL.
30 6.1070 9-Nov-87
Save the pointer to the FD before calling D$ESTR. Also pass the
current FP flag word in S2 to D$ESTR.
31 6.1120 5-Dec-87
Change Q$CREATE to include a CR-LF in its remote printer request
ACK messages and NOTIFY to pass an ASCIZ notify message back to the remote
print requestor.
32 6.1123 6-Dec-87
If a MODIFY message changes the node name of a request, then set
the default node name bit EQ.NND to zero.
33 6.1175 7-Feb-88
Add support for the EXEC command CANCEL PRINT/DESTINATION.
34 6.1177 11-Feb-88
Add support for specifying that batch log files and spooled files
be scheduled on specified local printers.
35 6.1179 12-Feb-88
Indicate in the print request /NOTIFY message for remote print
requests the queue name (for DQS print requests) or the port or service
name (for LAT print requests) and the node where the print request was
spooled to (DQS) or printed at (LAT).
36 6.1181 15-Feb-88
Fix some bugs in processing remote CANCEL PRINT requests found
while debugging with a private EXEC.
37 6.1183 16-Feb-88
Reject a INFORMATION OUTPUT/DESTINATION request if Cluster GALAXY
is not running.
40 6.1218 6-Mar-88
If a remote print request notify message is longer than 80 printable
characters, then insert a CR-LF.
41 6.1225 8-Mar-88
Update copyright notice.
42 6.1257 14-May-88
For cancel requests to be forwarded to a remote node in the cluster,
place the user name in block KIL.RU. Also, when building an ABORT message
from a KILL message that originated from a remote node, place the remote
user name in block ABO.RU and the node that the request came from in block
ABO.ND so that LPTSPL can display this information in its log block and
also indicate this information to ORION/OPR.
\ ;End of Revision History
SUBTTL STOPCDs found in QSRQUE
COMMENT\
BDN BAD DEVICE NAME INTERNALLY GENERATED
CRD CREATE REJECTED DEFER DATA
CRL CREATE REJECTED LOGOUT DATA
CRM CREATE REJECTED MODIFY
CRS CREATE REJECTED SPOOLING DATA
IDN INVALID DIRECTORY NUMBER
IUN INVALID USER NUMBER
\
SUBTTL Queue Headers and Module Storage
INTERN TBLHDR
INTERN NQUEUE
INTERN REQIDN
;BUILD THE QUEUE HEADERS
TBLHDR: QUEHDR
NQUEUE==<.-TBLHDR>/QHSIZE
LSTITN: BLOCK 1 ;LAST ITN ASSIGNED
REQIDN: EXP 0 ;REQUEST ID
THSPSB: BLOCK 1 ;ADDRESS OF THE PSB OF THE
;SENDER OF THE CURRENT MESSAGE
;FILLED IN BY VALMSG
DELLST: BLOCK 1 ;LIST NUMBER FOR DELETE LIST
DELNUM: BLOCK 1 ;# DELETE ENTRIES IN CORE
USRNAM: BLOCK 10 ;[33]USER NAME FOR KILL MSG VALIDATION
STATS: [0,,0] ;INVALID
[ASCIZ/reading/] ;.OTRDR (READER QUEUE)
[ASCIZ/network/] ;.OTNET (NETWORK QUEUE)
[ASCIZ/printing/] ;.OTLPT (PRINTER QUEUE)
[ASCIZ/executing/] ;.OTBAT (BATCH QUEUE)
[ASCIZ/punching/] ;.OTCDP (CARD PUNCH QUEUE)
[ASCIZ/punching/] ;.OTPTP (PAPER TAPE PUNCH QUEUE)
[ASCIZ/plotting/] ;.OTPLT (PLOTTER QUEUE)
[0,,0] ;.OTJOB
[0,,0] ;.OTTRM
[0,,0] ;.OTOPR
[0,,0] ;.OTIBM
[0,,0] ;.OTMNT
[ASCIZ/transfering/] ;.OTFTS (FILE TRANSFER QUEUE)
[ASCIZ/interpreting/] ;.OTBIN (SPRINT)
[ASCIZ /retrieving/] ;.OTRET
[0,,0] ;.OTNOT
[0,,0] ;.OTDBM
[0,,0] ;.OTFAL
[0,,0] ;.OTSNA
;DEFINE TABLE OF VALID OBJECT TYPES FOR ATTRIBUTES
;EACH ATTRIBUTE TYPE WILL HAVE A BIT MASK FOR EACH VALID OBJECT TYPE
DEFINE X(TEXT,SYM,OBJ) <
ZZ==0
IRP OBJ,<IFLE OBJ,<ZZ==OBJ>
IFG OBJ,<ZZ==ZZ+1B<OBJ>>>
EXP ZZ>
ATRCDS: ATTRIB ;;BUILD THE TABLE
REQUEUE: EXP 0 ;REQUEUE FLAG FOR Q$LOGOUT
CNFBLK: EXP 15 ;[27]CLUSTER NODE NUMBERS TABLE
INFBLK: EXP .INMAX ;[27]INFO% ARGUMENT BLOCK
GETBLK: EXP 3 ;[27]REMOTE GETJI BLOCK
SUBTTL Queue Database Initialization
Q$INIT::PUSHJ P,I%NOW ;GET NOW
MOVEM S1,LSTITN ;AND SAVE IT AS LAST ITN
PUSHJ P,L%CLST ;CREATE A LIST
MOVEM S1,DELLST ;SAVE THE LIST NUMBER
SETZM DELNUM ;ZERO DELETE LIST COUNT
MOVEI S1,.CFCSE ;[27]NODE NUMBER FUNCTION
MOVEI S2,CNFBLK ;[27]NODE NUMBER ARGUMENT BLOCK
CNFIG% ;[27]PICK UP THE CLUSTER NODE NUMBERS
ERJMP Q$INI1 ;[27]DON'T NOTIFY ON AN ERROR
$RETT ;[27]RETURN
Q$INI1: SETOM CNFBLK+.CFCS1 ;[27]INDICATE NO ACK OR NOTIFY
$RETT ;[27]RETURN
SUBTTL Batch and Spooling Message Handlers
;THE MESSAGE HANDLERS ARE TOP LEVEL ROUTINES WHICH PROCESS THE
; VARIOUS MESSAGES THAT ARE SENT TO QUASAR. THEY ARE
; CALLED DIRECTLY OUT OF THE MAIN PROCESSING LOOP WITH
; ACCUMULATOR "M" POINTING TO THE FIRST WORD OF THE MESSAGE.
; THE MESSAGE HANDLERS HAVE FULL USE OF ALL ACCUMULATORS
; EXCEPTING "M" AND THE "P" REGS.
INTERN Q$RELEASE ;FUNCTION 2 -- RELEASE
INTERN Q$CHECKPOINT ;FUNCTION 3 -- CHECKPOINT
INTERN Q$REQUEUE ;FUNCTION 4 -- REQUEUE
INTERN Q$RNXT ;[27] CHECK FOR REMOTE NEXTJOB MESSAGE
INTERN Q$CREATE ;FUNCTION 7 -- CREATE
INTERN Q$CRER ; -- REBUILD FAILSOFT ENTRY
INTERN Q$CRQE ;FUNCTION 37 -- SHORT CREATE MESSAGE
INTERN Q$MODIFY ;FUNCTION 11 -- MODIFY
INTERN Q$KILL ;FUNCTION 12 -- KILL
INTERN Q$DEFER ;FUNCTION 16 -- DEFER
INTERN Q$HOLD ;FUNCTION 25 -- HOLD/RELEASE
;SOME IPCC MESSAGES ARE SENT TO QUASAR FROM THE MONITOR EXEC PROCESS.
; THEY ARE TREATED IN THE SAME MANNER AS USER GENERATED
; CALLS (I.E. ACCUMULATOR "M" POINTS TO THE MESSAGE)
INTERN Q$SPOOL ;SPOOLING FILE REQUEST -- FUNCTION .IPCSU (26)
INTERN Q$LOGOUT ;LOGOUT OF A JOB -- FUNCTION .IPCSL (27)
;IF .QIFNC IS SET IN THE OPERATION FIELD OF A MESSAGE, THE CALL IS
; CONSIDERED INTERNAL, AND SPECIAL HANDLING OR INTERPRETATION
; OF THE VARIOUS FIELDS IN THE MESSAGE, (PARTICULARLY THE
; OTHER 17 BITS OF THE TYPE FIELD) MAY OCCUR. ANY SPECIAL
; HANDLING OF THIS FORM WILL BE DESCRIBED IN THE ROUTINE
; HEADER COMMENTS. IF .QIFNC IS SET THE REST OF THE TYPE FIELD
; DOES NOT HAVE TO REFLECT THE MESSAGE TYPE SINCE IF Q$CREATE
; RECEIVES AN INTERNAL CALL, THE MESSAGE IS OBVIOUSLY A CREATE
; MESSAGE.
SUBTTL RELEASE - Function 2
;THE RELEASE MESSAGE IS SENT TO QUASAR BY ONE OF THE KNOWN SYSTEM
; COMPONENTS TO RELEASE A JOB FROM THE QUEUE.
Q$RELEASE:
MOVEI T1,REL.SZ ;LOAD MINIMUM SIZE
PUSHJ P,VALMSG ;VALIDATE THE MESSAGE
SKIPE G$ERR## ;DID VALMSG SET THE ERROR FLAGS
$RETT ;YES, REJECT THIS MESSAGE
MOVE S1,REL.IT(M) ;GET THE TASKS ITN
PUSHJ P,Q$SUSE ;SEARCH THE USE QUEUE
JUMPF E$SNY## ;NOT FOUND
MOVE AP,S1 ;COPY ENTRY ADR INTO AP
PUSHJ P,D$PPRL## ;RELEASE THE MDR IF THERE IS ONE
MOVE T1,.QEOBJ(AP) ;GET OBJECT QUEUE ENTRY FOR REQUEST
MOVE T2,OBJPID(T1) ;THE PID FOR THE PROCESSOR
CAME T2,G$SND## ;DOES REQUEST BELONG TO HIM?
PJRST E$SNY## ;NO, GIVE "NOT YOURS" ERROR
MOVEM T1,G$OBJA## ;[35]SAVE OBJECT ADDRESS FOR NOTIFY
LOAD S1,.QEROB+.ROBTY(AP),AR.TYP ;[25]GET REQUESTED OBJECT TYPE
PUSHJ P,A$OB2Q## ;CONVERT TO QUEUE HEADER ADR
PUSH P,S1 ;SAVE THE HEADER
CAIN S1,HDRINP ;IS IT THE INPUT QUEUE
PUSHJ P,S$INRL## ;YES, RELEASE THE SPOOLED STUFF
POP P,S1 ;GET HDR ADDRESS BACK
LOAD S1,.QHPAG(S1),QH.SCH ;GET ADDRESS OF SCHED VECTOR
PUSHJ P,SCHRJI(S1) ;AND CALL RELEASE ENTRY POINT
LOAD S1,.QESTN(AP),QE.DPA ;GET THE DISK ADDRESS
PUSHJ P,F$RLRQ## ;AND RELS SPACE
$COUNT (MREL)
PUSHJ P,Q$DDEP ;DELETE DEPENDENCY LIST
LOAD S1,.QESEQ(AP),QE.NOT ;GET NOTIFY BITS
SKIPE S1 ;NONE SET,,SKIP THE NOTIFY
PUSHJ P,NOTIFY ;YES,,GO DO IT
MOVE S1,REL.FL(M) ;[27]PICK UP THE FLAG WORD
TXNN S1,RF.ACT!RF.DEL ;[27]ACCOUNTING INFO OR DELETED FILES?
JRST Q$RE.1 ;[27]NO, RETURN QE
MOVEM M,G$SAB+SAB.MS ;[27]PLACE RELEASE MESSAGE ADDRESS HERE
MOVEI S1,PAGSIZ ;[27]MESSAGE SIZE
MOVEM S1,G$SAB+SAB.LN ;[27]PLACE IN THE SAB
MOVE S1,.QEPID(AP) ;[27]PICK UP LISSPL'S PID
MOVEM S1,G$SAB+SAB.PD ;[27]PLACE IN THE SAB
$CALL C$SEND ;[27]FORWARD RELEASE MESSAGE TO LISSPL
SETOM G$REM## ;[27]INDICATE A REMOTE RELEASE MESSAGE
Q$RE.1: MOVEI H,HDRUSE ;[27]LOAD ADR OF USE HEADER
PJRST M$RFRE## ;AND RETURN THE ENTRY
SUBTTL CHECKPOINT - Function 3
;A CHECKPOINT message is sent periodically by the various known processors
; so that QUASAR can update the request for restart in case of system
; failure and/or to update active job status in-core.
Q$CHECKPOINT:
MOVEI T1,CHE.MS ;LOAD MINIMUM MESSAGE SIZE
PUSHJ P,VALMSG ;VALIDATE THE MESSAGE
SKIPE G$ERR## ;DID VALMSG SET THE ERROR FLAGS
$RETT ;YES, REJECT THIS MESSAGE
MOVE S1,CHE.IT(M) ;GET THE SPECIFIED ITN
PUSHJ P,Q$SUSE ;SEARCH THE USE QUEUE
JUMPF E$SNY## ;NOT THERE!!
MOVE T1,S1 ;COPY ADDRESS INTO T1
MOVE T2,.QEOBJ(T1) ;GET OBJECT ADDRESS
MOVE T3,OBJPID(T2) ;GET PID OF OWNER
CAME T3,G$SND## ;SAME AS SENDER?
PJRST E$SNY## ;NO, GIVE AN ERROR
$COUNT(MCHK)
LOAD S1,CHE.FL(M) ;GET FLAGS WORD
TXNN S1,CH.FCH ;DOING A CHECKPOINT?
JRST CHEC.1 ;NO, SEE IF DOING A STATUS
LOAD S1,.QESTN(T1),QE.DPA ;GET THE DPA
PUSHJ P,F$RDRQ## ;READ THE REQUEST
MOVE T2,S1 ;SAVE PAGE ADR IN T2
HRRI S2,.EQCHK(S1) ;AND PLACE TO PUT IT
HRLI S2,CHE.IN(M) ;FIRST OF THE INFORMATION WORDS
BLT S2,.EQCHK+<EQCKSZ-1>(S1) ;AND BLT IT
MOVEI T3,1 ;LOAD A BIT
STORE T3,.EQSEQ(S1),EQ.JBC ;JOB HAS BEEN CHECKPOINTED!!
PUSHJ P,F$WRRQ## ;WRITE IT OUT
LOAD S2,.QESTN(T1),QE.DPA ;GET PREVIOUS DPA
STORE S1,.QESTN(T1),QE.DPA ;STORE NEW DPA
MOVE S1,S2 ;GET OLD DPA INTO S1
PUSHJ P,F$RLRQ## ;AND RELEASE IT
MOVE S1,T2 ;GET ADDRESS OF PAGE
PUSHJ P,M%RPAG ;AND RELEASE THE PAGE
CHEC.1: LOAD S1,CHE.FL(M) ;GET FLAG WORD
TXNN S1,CH.FST ;DOES HE WANT TO SET STATUS?
$RETT ;NO, RETURN
LOAD S1,.MSTYP(M),MS.CNT ;GET MESSAGE LENGTH
SUBI S1,CHE.ST ;SUBTRACT START OF STATUS BLOCK
JUMPLE S1,.RETT ;IF NO STATUS, FORGET IT
;CONTINUED ON THE NEXT PAGE
;CONTINUED FROM THE PREVIOUS PAGE
LOAD S2,.QEOBJ(T1) ;GET ADDRESS OF OBJ BLOCK
ADDI S2,OBJST1 ;POINT TO THE STATUS BLOCK
ADDI S1,-1(S2) ;GET DESTINATION OF BLT
HRLI S2,CHE.ST(M) ;AND SOURCE
BLT S2,0(S1) ;AND MOVE THE STATUS
$RETT ;RETURN
SUBTTL REQUEUE - Function 4
;The REQUEUE message is sent by a known component when the job currently
; being processed by a particular object is to be released from the
; object and placed back into the queue.
Q$REQUEUE:
PUSHJ P,.SAVE1 ;Save P1
MOVEI T1,REQ.SZ ;MINIMUM SIZE OF THE MESSAGE
PUSHJ P,VALMSG ;VALIDATE THE SIZE OF IT
SKIPE G$ERR## ;IS IT OK
$RETT ;NO, RETURN NOW
MOVE S1,REQ.IT(M) ;GET THE ITN OF THE TASK
PUSHJ P,Q$SUSE ;SEARCH THE USE QUEUE
JUMPF E$SNY## ;NOT THERE!!
MOVE AP,S1 ;COPY ADDRESS INTO AP
MOVE T2,.QEOBJ(AP) ;GET OBJECT ADDRESS
MOVE S1,OBJPID(T2) ;GET PID OF OWNER
CAME S1,G$SND## ;SAME AS SENDER?
PJRST E$SNY## ;NO, GIVE AN ERROR
LOAD S1,.QEROB+.ROBTY(AP),AR.TYP ;[25]GET REQUESTED OBJECT TYPE
PUSHJ P,A$OB2Q## ;CONVERT TO QUEUE HEADER ADR
MOVE H,S1 ;COPY QUE HDR INTO H
CAIE H,HDRRET ;THE RETRIEVAL QUEUE?
JRST REQU.1 ;NO, PROCEED NORMALLY
HRRI S1,.QELIM(AP) ;ACTUALLY POINTING TO TIMESTAMP WORD
HRLI S1,REQ.IN(M)
BLT S1,.QELIM+4(AP) ;COPY TAPE INFO INTO .EQ
REQU.1: LOAD S1,.QHPAG(H),QH.SCH ;GET ADDRESS OF SCHED VECTOR
PUSHJ P,SCHRJI(S1) ;AND RELEASE THE INTERLOCK
PUSH P,H ;SAVE OUR HEADER ADDRESS
MOVE S1,H ;PUT DESTINATION QUE IN S1
MOVEI H,HDRUSE ;LOAD H WITH SOURCE QUEUE
PUSHJ P,M$MOVE## ;MOVE THE ENTRY OUT OF THE USE QUEUE
SKIPE S1,.QEMDR(AP) ;CHECK AND LOAD THE MDR ADDRESS
MOVEM AP,.MRQEA(S1) ;RELINK THE QE TO THE MDR
$COUNT (MREQ) ;COUNT'EM UP !!!
LOAD S1,OBJTYP(T2),AR.TYP ;[25]GET THE OBJECT TYPE
CAIE S1,.OTBAT ;IS IT BATCH ???
JRST REQ.1A ;NO,,SKIP THIS
SETOM REQUEUE ;LITE THE REQUEUE FLAG
PUSHJ P,S$REQU## ;PRINT ANY SPOOLED OUTPUT NOW
SETZM REQUEUE ;CLEAR THE REQUEUE FLAG
MOVE S1,AP ;GET THE QE ADDRESS IN S1
PUSHJ P,D$PPRE## ;RESET THE JOB MDR TO A PSEUDO PROCESS
REQ.1A: LOAD S1,REQ.FL(M),RQ.HBO ;GET THE REQUEUE-HOLD BIT
JUMPN S1,REQU.2 ;IF LIT,,SKIP THIS
LOAD S1,REQ.FL(M),RQ.TIM ;GET TIME TO WAIT IN MINUTES
LOAD P1,.QEROB+.ROBTY(AP) ;Get the object type
CAIE P1,.OTNOT ;Is it NOTIFY?
JUMPE S1,REQU.2 ;No, and none there, skip this
JUMPE S1,[ MOVE S1,G$NOW## ;Yes, and none there
AOS S1 ;Make it the future
JRST REQ.1B ] ;And rejoin
PUSHJ P,A$AFT## ;Create UDT with that time
;CONTINUED ON THE NEXT PAGE
;CONTINUED FROM THE PREVIOUS PAGE
REQ.1B: MOVEM S1,.QECRE(AP) ;Save a new /AFTER time.
MOVE S2,P1 ;Get the object type for S$AFTR
PUSHJ P,S$AFTR## ;SCHEDULE WAKEUP IN 'N' MINUTES
REQU.2: POP P,H ;RESTORE OUR QUEUE HEADER ADDRESS
LOAD S1,.QESEQ(AP),QE.RDE ;WAS THIS REQUEST CANCELLED ???
JUMPN S1,Q$KPRO ;YES,,GO DELETE IT FROM THE QUEUE
MOVE S1,REQ.FL(M) ;GET THE REQUEUE FLAGS
TXNN S1,RQ.HBO ;HOLD BY OPERATOR?
TXNN S1,RQ.RLC ;NO, USE LAST CHECKPOINT?
SKIPA ;NO, WE MUST READ/WRITE DISK
$RETT ;NO DISK MODS,,JUST RETURN
LOAD S1,.QESTN(AP),QE.DPA ;GET THE DPA
PUSHJ P,F$RDRQ## ;READ THE REQUEST
MOVE T1,S1 ;SAVE THE ADDRESS FOR A WHILE
HRRI S2,.EQCHK(T1) ;AND PLACE TO PUT IT
HRLI S2,REQ.IN(M) ;FIRST OF THE INFORMATION WORDS
MOVX T2,RQ.RLC ;RESTART AT LAST CHECKPOINT?
TDNN T2,REQ.FL(M) ;TEST AND SKIP IF SO
BLT S2,.EQCHK+<EQCKSZ-1>(T1) ;ELSE, BLT IT
LOAD S2,REQ.FL(M),RQ.HBO ;HOLD THE JOB?
JUMPE S2,REQU.3 ;NO, CONTINUE ON
MOVX S2,QE.HBO ;GET HOLD BY OPERATOR
IORM S2,.QESEQ(AP) ;SET IT
MOVX S2,EQ.HBO ;GET THE EQ VERSION
IORM S2,.EQSEQ(T1) ;AND SET IT
REQU.3: PUSHJ P,F$WRRQ## ;RE-WRITE THE REQUEST
LOAD S2,.QESTN(AP),QE.DPA ;GET THE OLD DPA
STORE S1,.QESTN(AP),QE.DPA ;STORE THE NEW DPA
MOVE S1,S2 ;GET THE OLD DPA
PUSHJ P,F$RLRQ## ;RELEASE THE OLD ONE
MOVE S1,T1 ;GET PAGE ADDRESS
PUSHJ P,M%RPAG ;RETURN THE PAGE
$RETT ;RETURN
SUBTTL Q$RNXT - Check for NEXTJOB message from a remote node
;Q$RNXT checks if the NEXTJOB message is from a remote node in the
;cluster. If it is, then it is passed to Q$CREATE. If the NEXTJOB
;message originated locally, then it is rejected.
Q$RNXT: LOAD S1,.EQSEQ(M),EQ.RLT ;[27]PICK UP THE ORIGINS BIT
SKIPN S1 ;[27]FROM A REMOTE NODE?
PJRST E$IMT## ;[27]NO, INDICATE AN ERROR
MOVE S1,M ;[27]PICK UP THE EQ ADDRESS
$CALL A$WHEEL## ;[27]IS THE SENDER PRIVILEGED?
JUMPT Q$CREA ;[27]YES, GO PROCESS THE MESSAGE
PJRST E$IMT## ;[27]NO, INDICATE AN ERROR
SUBTTL CREATE - Function 7
;The CREATE message is sent to QUASAR by any unknown component to place
; something in one of the INPUT or OUTPUT queues.
; The Q$CRER is called by the failsoft system initialization to
; place an entry into one of the queues from the failsoft file.
; That entry is called with S1 containing the address of the request
; and S2 containing the DPA.
Q$CRER: PUSHJ P,.SAVE4 ;SAVE P1-P4
$SAVE M ;SAVE M
MOVE M,S1 ;PUT EQ ADDRESS INTO M
MOVX S1,.QIFNC ;LOAD THE INTERNAL FUNCTION CODE
STORE S1,.MSTYP(M),MS.TYP ;STORE IT
MOVE P4,S2 ;PUT THE DPA IN S2
ZERO .EQSEQ(M),EQ.NOT ;NO /NOTIFY FOR RESTARTS
JRST CREA.0 ;AND GO DO THE CREATE
Q$CREATE:
PUSHJ P,.SAVE4 ;SAVE P1 THRU P4
SETZ P4, ;NO DPA HERE
CREA.0: SETZM G$CRS## ;Set GTJFN error flag to 0
LOAD P2,.EQSEQ(M),EQ.RLT ;[27]PICK UP REQUEST ORIGIN BIT
JUMPN P2,CREA.1 ;[27]SKIP THE LENGTH CHECKS IF REMOTE
LOAD S1,.MSTYP(M),MS.CNT ;Get length of message
CAIGE S1,EQHSIZ ;MUST BE AT LEAST EQHSIZ
PJRST E$MTS## ;INDICATE MESSAGE TOO SHORT
LOAD S1,.EQLEN(M),EQ.LOH ;MUST CHECK HEADER SIZE AS WELL
CAIGE S1,EQHSIZ ;THAT IS ALSO THE MINIMUM VALUE
PJRST E$MTS## ;TOO BAD, GIVE MESSAGE TOO SHORT
CREA.1: LOAD S1,.EQROB+.ROBTY(M),AR.TYP ;[27]GET REQUESTED OBJECT TYPE
PUSHJ P,A$OB2Q## ;CONVERT TO QUEUE HEADER
JUMPF E$UQS## ;UNKNOWN QUEUE SPECIFIED
MOVE H,S1 ;LOAD COPY
LOAD P3,.MSTYP(M),MS.TYP ;GET THE TYPE FIELD
TXNE P3,.QIFNC ;IS IT INTERNAL?
SKIPN S1,.EQITN(M) ;YES, LOAD OLD ITN IF NON-ZERO
AOS S1,LSTITN ;GET A NEW ITN
STORE S1,.EQITN(M) ;AND STORE IN MSG FOR LATER
TXNE P3,.QIMOD ;IS THIS FROM A MODIFY?
JRST CREA.2 ;YES, DON'T INCREMENT REQUEST ID
TXNN P3,.QIFNC+.QIRET ;INTERNAL CALL or ARCHIVE MSG ???
SKIPL G$QUEU## ;NO,,IS CREATING TURNED OFF ???
SKIPA ;INTERNAL or ARCHIVE or CREATES ON !!
PJRST E$OHR## ;EXTERNAL and CREATES OFF IS AN ERROR
AOS S1,REQIDN ;GET THE REQUEST ID
MOVEM S1,.EQRID(M) ;SAVE IT IN THE MESSAGE
CREA.2: JUMPN P2,CREA.4 ;[27]DON'T FILL IN DEFAULTS IF REMOTE
LOAD S1,.QHPAG(H),QH.SCH ;BASE OF SCHEDULING ENTRIES
PUSHJ P,SCHDEF(S1) ;GO FILL THE DEFAULTS FOR THIS QUEUE
SKIPE G$ERR## ;DID IT GET PAST THE CHECKS
$RETT ;NO, SCHDEF REJECTED IT!!
;CONTINUED ON THE NEXT PAGE
;CONTINUED FROM THE PREVIOUS PAGE
CREA.3: MOVE S1,M ;GET CREATE REQUEST ADDRESS
PUSHJ P,I$QCDR## ;CHECK FOR SPOOLED CDR FILES IN REQUEST
MOVE S1,.EQAFT(M) ;GET THE AFTER PARAMETER
CAMGE S1,G$NOW## ;NO, IS IT BEFORE NOW?
CREA.4: MOVE S1,G$NOW## ;YES, USE NOW. THIS DISALLOWS
MOVEM S1,.EQAFT(M) ;/AFT:YESTERDAY TO GIVE HI-PRIO
CREA.5: PUSHJ P,M$GFRE## ;GET A FREE CELL
PUSHJ P,L%CLST ;CREATE THE DEPENDENCY LIST
STORE S1,.QEDIN(AP),QE.DLN ;AND STORE THE LIST NUMBER
LOAD T1,.EQSPC(M),EQ.NUM ;GET NUMBER OF FILES IN REQUEST
LOAD T2,.EQLEN(M),EQ.LOH ;GET LENGTH OF HEADER
ADD T2,M ;MAKE T2 POINT TO FIRST FP
SETZ P1 ;[30]CLEAR PREVIOUS STR FIRST TIME THRU
CREA.6: LOAD S2,.FPINF(T2),FP.CPY ;[30]PICK UP THE TEMPORARY FILE BIT
LOAD S1,.FPLEN(T2),FP.LEN ;[30]GET LENGTH OF THIS FP
ADDB T2,S1 ;[30]PUT FD ADDRESS IN T2 AND S1
PUSHJ P,D$ESTR## ;EXTRACT THE STRUCTURE FROM THE FD
SKIPE G$CRS## ;Error due to GTJFN failure?
JRST [ LOAD S1,.QEDIN(AP),QE.DLN ;Yes, delete the
PUSHJ P,L%DLST ;dependency list
PUSHJ P,M$RFRE## ;Return the cell
MOVE S1,G$CRS## ;Get the error code
LOAD S2,.EQROB+.ROBTY(M),AR.TYP ;[25]Get the object type
$WTO(<^1/S2/ job ^W/.EQJOB(M)/, request #^D/.EQRID(M)/ rejected ^M^J^T/BLANKS/ ^E/S1/>)
SETZM G$ACK ;No ACK to the job
$RETT ] ;Go clean up
JUMPF E$IFS## ;GIVE ERROR IF BAD STRUCTURE
CAMN S1,P1 ;SAME AS LAST FILE
JRST CREA.7 ;YES, ON TO NEXT FILE
MOVE P1,S1 ;[30]GET PREVIOUS STRUCTURE
MOVE S2,AP ;PUT QE ADDRESS IN S2
PUSHJ P,D$ASTD## ;ADD A STRUCTURE DEPENDENCY
CREA.7: LOAD S1,.FDLEN(T2),FD.LEN ;GET THE FD LENGTH
ADD T2,S1 ;POINT TO NEXT FP (IF THERE IS ONE)
SOJG T1,CREA.6 ;AND LOOP FOR ALL FILES
SKIPN S1,.EQROB+.ROBND(M) ;DID HE SPECIFY A HOST ID
MOVE S1,G$LNAM## ;NO,,GET THE HOST SITE ID
PUSHJ P,N$NODE## ;MAKE SURE ITS IN OUR DATA BASE
MOVEM S1,.EQROB+.ROBND(M) ;SAVE HOST ID
MOVE S1,.EQITN(M) ;GET THE ITN
MOVEM S1,.QEITN(AP) ;AND STORE IT
MOVE S1,M ;POINT S1 TO THE EQ
PUSHJ P,I$EQQE## ;MOVE INFO FROM EQ TO QE
MOVSI S1,.EQJBB(M) ;GET THE SOURCE ADDRESS
HRRI S1,.QEJBB(AP) ;GET THE DESTINATION ADDRESS
BLT S1,.QEJBB+JIBSIZ-1(AP) ;COPY THE JIB OVER
LOAD S1,.EQPRI(M),EQ.LOG ;[34]PICK UP THE LOG FILE BIT
STORE S1,.QESEQ(AP),QE.LOG ;[34]SAVE IN THE QE
MOVSI S1,.EQACT(M) ;GET SOURCE ACCOUNT STRING
HRRI S1,.QEACT(AP) ;GET DESTINATION
BLT S1,.QEACT+7(AP) ;COPY THE ACCOUNT STRING
LOAD S1,.EQSPC(M),EQ.PRO ;GET THE PROTECTION FIELD
STORE S1,.QEPRT(AP),QE.PRO ;STORE IT
HRLI S1,.EQROB(M) ;POINT TO ROB IN EQ
HRRI S1,.QEROB(AP) ;AND POINT TO ROB IN QE
BLT S1,.QEROB+ROBSIZ-1(AP) ;AND MOVE THE BLOCK
MOVSI S1,.EQLIM(M) ;SOURCE OF 'EQLMSZ' LIMIT WORDS
HRRI S1,.QELIM(AP) ;DESTINATION OF 'EQLMSZ' LIMIT WORDS
BLT S1,.QELIM+EQLMSZ-1(AP) ;BLT THEM ACROSS
LOAD S1,.EQSEQ(M),EQ.NOT ;GET THE NOTIFY BITS
JUMPN P2,CREA.9 ;[27]REMOTE ALREADY HAS NOTIFY SET UP
SKIPE S1 ;DOES HE WANT /NOTIFY ???
PUSHJ P,Q$NOTIFY ;YES,,SET IT UP !!!
SKIPN S1,.QEJBN(AP) ;[27]PICK UP THE SENDERS JOB NUMBER
LOAD S1,G$PRVS##,MD.PJB ;[27]GET THE SENDERS JOB NUMBER
STORE S1,.EQNJN(M),EQ.JNM ;[27]SAVE HERE FOR REMOTE QUASAR
HLRE S1,CNFBLK+.CFCS1 ;[27]PICK UP THIS NODE'S CLUSTER NUMBER
SKIPG S1 ;[27]IS THERE A CLUSTER NODE NUMBER?
JRST CREA11 ;[27]NO, INDICATE IN THE QE
STORE S1,.EQNJN(M),EQ.NNM ;[27]PLACE IN THE QE
JRST CREA12 ;[27]BYPASS REMOTE ORIGIN SETUP
CREA.9: CAIN S1,%NOTTY ;[27]NOTIFY TO TERMINAL?
JRST CREA10 ;[27]YES, CONTINUE ON
SETZ S1, ;[27]NO, SO DON'T NOTIFY AT ALL
STORE S1,.EQSEQ(M),EQ.NOT ;[27]INDICATE DO NOT NOTIFY
CREA10: LOAD S1,.EQNJN(M),EQ.JNM ;[27]PICK UP REMOTE USER'S JOB NUMBER
MOVEM S1,.QEJBN(AP) ;[27]PLACE IN THE QE
LOAD S1,.EQNJN(M),EQ.NNM ;[27]PICK UP THE CLUSTER NODE NUMBER
STORE S1,.QESTN(AP),QE.NOD ;[27]SAVE IN THE QE
MOVE S1,.EQPID(M) ;[27]PICK UP LISSPL'S PID
MOVEM S1,.QEPID(AP) ;[27]PLACE IN THE QE
MOVE S1,.EQNOD(M) ;[33]PICK UP REQUESTOR'S NODE NAME
MOVEM S1,.QENOD(AP) ;[33]PLACE IN THE QE
SKIPA ;[27]GO PICK UP AFTER TIME
CREA11: SETOM .EQNJN(M) ;[27]INDICATE CAN'T ACK OR NOTIFY
CREA12: MOVE S1,.EQAFT(M) ;[27]GET CREATE OR AFTER TIME
MOVEM S1,.QECRE(AP) ;AND STORE IT
LOAD S2,.EQROB+.ROBTY(M) ;Pick up the object type
PUSHJ P,S$AFTR## ;SCHEDULE /AFTER IF WE HAVE TO
JUMPN P4,CRE12A ;[27]SKIP THIS IF WE HAVE A DPA
MOVE S1,M ;[27]NO, GET THE ADDRESS
PUSHJ P,F$WRRQ## ;[27]AND FAILSOFT IT
MOVE P4,S1 ;[27]PUT THE DPA IN P4
CRE12A: STORE P4,.QESTN(AP),QE.DPA ;[27]STORE THE DISK ADDRESS:
CREA13: LOAD S1,.QHPAG(H),QH.SCH ;GET BASE OF SCHED VECTOR
PUSHJ P,SCHLNK(S1) ;AND LINK IN THE REQUEST
$COUNT (SCRE) ;NUMBER OF SUCCESSFUL CREATES
MOVE S1,AP ;GET THE QE ADDR IN S1
PUSHJ P,I$LPTT## ;[25]DETERMINE IF A REMOTE LPT OR NOT
DOSCHD ;LETS TRY TO SCHEDULE IT
SKIPN G$ACK## ;DOES CALLER WANT ACKNOWLEDGEMENT
$RETT ;NO, ALL DONE
LOAD S1,.QEROB+.ROBTY(AP),AR.TYP ;[25]GET THE OBJECT TYPE
CAIE S1,.OTBIN ;IS IT THE BATCH INPUT QUEUE ???
CAIN S1,.OTBAT ; OR IS IT BATCH QUEUE ???
JRST [ GETLIM T1,.QELIM(AP),TIME ;Number of seconds requested
IDIVI T1,^D3600 ;Hours in T1
IDIVI T2,^D60 ;Minutes in T2, seconds in T3
$TEXT(G$CCHR##,<[Batch job ^W/.QEJOB(AP)/ queued, request #^D/.QERID(AP)/, limit ^D/T1/:^D2R0/T2/:^D2R0/T3/]^A>)
JRST CREA15 ] ;Check for priority change
GETLIM S2,.QELIM(AP),OLIM ;GET OUTPUT LIMIT
SKIPN P2 ;[27]SKIPE IF ORIGINATED REMOTELY
$TEXT(G$CCHR##,<[^1/S1/ job ^W/.QEJOB(AP)/ queued, request #^D/.QERID(AP)/^A>) ;[FTS]
SKIPE P2 ;[27]SKIP IF A LOCAL REQUEST
$TEXT(G$CCHR##,<[^1/S1/ job ^W/.QEJOB(AP)/ queued on system ^N/G$LNAM##/, request #^D/.QERID(AP)/^A>) ;[27]
CAXN S1,.OTFTS ;[FTS] FILE TRANSFER ???
JRST CREA14 ;[FTS] YES,,FINISH UP
$TEXT(G$CCHR##,<, limit ^D/S2/^A>) ;[FTS]
LOAD S1,.EQSPC(M),EQ.NUM ;GET THE NUMBER OF FILES
CAILE S1,1 ;MORE THEN 1 ???
$TEXT (G$CCHR##,<, ^D/S1/ files^A>) ;YES,,SAY SO
CREA14: MOVEI S1,"]" ;GET TERMINATING BRACKET
PUSHJ P,G$CCHR## ;TYPE IT
CREA15: LOAD S1,.EQSEQ(M),EQ.CHP ;Pick up the priority
SKIPE S1 ;Has it been changed?
$TEXT(G$CCHR##,<^J^M[Priority has been modified]>) ;Yes
JUMPN P2,CREA16 ;[31]Do differently if remote
MOVEI S1,.CHNUL ;Get a <NUL>
PUSHJ P,G$CCHR## ;Make it ASCIZ
PJRST G$MSND## ;Go send this ACK
CREA16: $TEXT(G$CCHR##,<^M^J^0>) ;[31]Add on a CR
MOVEI S1,G$MSG+.OHDRS+ARG.DA ;[27]PICK UP MESSAGE ADDRESS
$CALL Q$RACK ;[27]ACK THE REMOTE USER
$RETT ;[27]INDICATE SUCCESS TO THE CALLER
BLANKS: ASCIZ/ / ;Used in a $WTO
SUBTTL SHORT CREATE MESSAGE PROCESSOR (SOON TO BE ONLY CREATE MSG)
;CALL: M/SHORT CREATE MESSAGE ADDRESS
;
;RET: TRUE ALWAYS
;
;THE FOLLOWING AC'S ARE USED:
;
; P1/ The Base Create Message Address
; P2/ The Queue Type (set by the .QCQUE block) (Input or Output)
;
; T1/ The Message Block Type (Set by A$GBLK)
; T2/ The Message Block Length (Set by A$GBLK)
; T3/ The Message Block Address (Set by A$GBLK)
; T4/ The First Data Word of the Message Block (Set at CRQE.3)
Q$CRQE: PUSHJ P,.SAVE2 ;SAVE P1 WHILE WE ARE HERE
$SAVE M ;SAVE THE MESSAGE ADDRESS ALSO
SETZM P2 ;CLEAR P2 (WILL BE USED FOR QUEUE TYPE)
PUSHJ P,M%GPAG ;GET A PAGE FOR THE CREATE MESSAGE
MOVE P1,S1 ;SAVE THE PAGE ADDRESS
MOVE S1,[%%.QSR,,EQHSIZ] ;SETUP .EQLEN
STORE S1,.EQLEN(P1) ;SAVE IT
MOVE S1,[EQHSIZ,,.QOCRE] ;SETUP LENGTH,,MSG TYPE
STORE S1,.MSTYP(P1) ;SAVE IT
MOVE S1,.MSFLG(M) ;GET THE USERS FLAG WORD
STORE S1,.MSFLG(P1) ;PUT IT IN OUR MESSAGE
MOVE S1,.MSCOD(M) ;GET THE USERS ACK CODE
STORE S1,.MSCOD(P1) ;PUT IT IN OUR MESSAGE
LOAD S1,.MSTYP(M),MS.TYP ;PICK UP THE FUNCTION CODE
CAIE S1,.QOCQE ;SEE IF IT IS SHORT CREATE MESSAGE
JRST CRQE.0 ;NO, MUST BE FROM QUEUE%
MOVX S1,.QCQUE ;GET THE QUEUE TYPE BLOCK
PUSHJ P,A$FNDB## ;FIND IT IN THE MESSAGE
JUMPF CRQE.5 ;NOT THERE,,THATS AN ERROR
LOAD S1,0(S1),AR.TYP ;[25]GET THE QUEUE TYPE
CRQE.0: MOVEM S1,.EQROB+.ROBTY(P1) ;SAVE IT IN THE MESSAGE
PUSHJ P,A$OB2Q## ;FIND THE QUEUE HEADER
LOAD P2,.QHTYP(S1),QH.TYP ;GET THE GENERIC QUEUE TYPE
CAXE P2,.QHTOU ;IS IT FOR THE OUTPUT QUEUES ???
CAXN P2,.QHTIP ;OR IS IT FOR THE INPUT QUEUES ???
JRST CRQE.1 ;OK,,CONTINUE
MOVE S1,.EQROB+.ROBTY(P1) ;GET THE OBJECT TYPE
CAXN P2,.QHFRR ;ARE WE FREE RUNNING
CAXE S1,.OTDBM ;AND DBMS ???
JRST CRQE.5 ;NO,,THATS NOT GOOD SO RETURN
CRQE.1: PUSHJ P,A$GBLK## ;GET THE FIRST/NEXT MESSAGE BLOCK
JUMPF CRQE.4 ;NO MORE,,LETS TRY THE CREATE
SOJLE T2,CRQE.5 ;MAKE SURE LENGTH IS CORRECT
MOVSI S1,-TBLEN ;GET AOBJN AC FOR BLOCK TYPE SEARCH
;CONTINUED ON THE NEXT PAGE
;CONTINUED FROM THE PREVIOUS PAGE
CRQE.2: HRRZ S2,BLKTBL(S1) ;GET A BLOCK TYPE
CAMN S2,T1 ;DO WE MATCH ???
JRST CRQE.3 ;WE MATCH,,SO GO PROCESS THE BLOCK
AOBJN S1,CRQE.2 ;NO MATCH,,TRY THE NEXT BLOCK
JRST CRQE.5 ;BLOCK NOT FOUND,,THATS AN ERROR
CRQE.3: MOVE T4,0(T3) ;GET THE FIRST DATA WORD OF MSG BLK
HLRZ S1,BLKTBL(S1) ;GET THE PROCESSOR ADDRESS
PUSHJ P,0(S1) ;GO DO IT !!!
JUMPT CRQE.1 ;ALL OK,,CONTINUE PROCESSING
JRST CRQE.5 ;ELSE GO FINISH UP
CRQE.4: MOVE M,P1 ;POINT TO OUR NEW CREATE MSG
PUSHJ P,Q$CREATE ;GO TRY TO CREATE THE QUEUE ENTRY
SKIPA ;SKIP OVER THE ERROR CALL
CRQE.5: PUSHJ P,E$ICM## ;SET 'INVALID CREATE MSG' ERROR
MOVE S1,P1 ;GET 'OUR' CREATE MSG ADDRESS
PUSHJ P,M%RPAG ;RELEASE THE PAGE
$RETT ;RETURN
BLKTBL: CRQFIL,,.QBFIL ;FILESPEC BLOCK
CRQCOP,,.QBCOP ;/COPIES BLOCK
CRQFRM,,.QBFRM ;/FORM: BLOCK
CRQFMT,,.QBFMT ;PRINT TYPE (ASCII,FORTRAN, ETC)
CRQODP,,.QBODP ;OUTPUT DISPOSITION (/DISP:)
CRQUNT,,.QBUNT ;UNIT TYPE BLOCK (LOWER, UPPER,UNIT:)
CRQAFT,,.QBAFT ;/AFTER: BLOCK
CRQLIM,,.QBLIM ;/LIMIT: BLOCK
CRQUNQ,,.QBUNQ ;/UNIQUE: BLOCK
CRQRES,,.QBRES ;/RESTART: BLOCK
CRQLOG,,.QBLOG ;/OUTPUT: BLOCK
CRQACT,,.QBACT ;/ACCOUNT: BLOCK
.RETT,,.QBFNC ;QUEUE TYPE (BATCH, PRINT, ETC)
CRQNOD,,.QBNOD ;DESTINATION NODE BLOCK
CRQNAM,,.QBNAM ;USERS NAME BLOCK
CRQOID,,.QBOID ;USERS NUMBER BLOCK
CRQNOT,,.QBNOT ;/NOTIFY BLOCK
CRQBLT,,.QBBLT ;INPUT DISPOSITION (/BATLOG:)
CRQJBN,,.QBJBN ;JOB NAME BLOCK
CRQCDI,,.QBCDI ;CONNECTED DIRECTORY BLOCK
CRQNTE,,.QBNTE ;/NOTE: BLOCK
CRQBGN,,.QBBGN ;/BEGIN: BLOCK
CRQPRI,,.QBPRI ;/PRIORITY BLOCK
; CRQFRR,,.QBFRR ;LIMIT WORD BLOCK FOR FREE RUNNING OBJS
CRQSNA,,.QBSNA ;FP Word for SNA-Workstations
TBLEN==.-BLKTBL
SUBTTL SHORT CREATE MESSAGE ACTION ROUTINES
CRQFIL: CAILE T2,FDXSIZ ;MUST BE LESS OR EQUAL TO MAX FD SIZE
$RETF ;NO,,RETURN NOW
MOVEI S1,EQHSIZ(P1) ;POINT TO THE FP
SKIPE 0(S1) ;ONLY SUPPORT ONE FILESPEC FOR NOW !!!
$RETF ;MORE THEN ONE,,RETURN NOW
MOVEI S2,EQHSIZ+FPMSIZ+1(T2) ;GET THE TOTAL MESSAGE LENGTH
STORE S2,.MSTYP(P1),MS.CNT ;SAVE IT IN THE MESSAGE
MOVX S2,FPMSIZ ;GET THE FP LENGTH
STORE S2,.FPLEN(S1),FP.LEN ;SAVE IT IN THE FP
ADD S1,S2 ;POINT TO THE FD
MOVEI S2,1(T2) ;GET THE TOTAL FD LENGTH IN S2
STORE S2,.FDLEN(S1),FD.LEN ;SAVE IT IN THE FD
ADD T2,S1 ;GET THE END BLT ADDRESS
HRRI S1,.FDFIL(S1) ;POINT TO THE ACTUAL FILESPEC AREA
HRL S1,T3 ;GET THE SOURCE ADDRESS
BLT S1,0(T2) ;COPY THE FILESPEC OVER
AOS .EQSPC(P1) ;MAKE THE FILE COUNT = 1
$RETT ;RETURN OK
CRQCOP: CAIN T2,1 ;BLOCK LENGTH MUST BE 1
CAIE P2,.QHTOU ;AND QUEUE TYPE MUST BE 'OUTPUT'
$RETF ;NO,,RETURN NOW
MOVEI S1,EQHSIZ(P1) ;POINT TO THE FP
STORE T4,.FPINF(S1),FP.FCY ;SAVE IT IN THE FP
$RETT ;RETURN OK
CRQFRM: CAIN T2,1 ;BLOCK LENGTH MUST BE 1
CAIE P2,.QHTOU ;AND QUEUE TYPE MUST BE 'OUTPUT'
$RETF ;NO,,THATS AN ERROR
STOLIM T4,.EQLIM(P1),FORM ;SAVE THE FORM TYPE
$RETT ;RETURN OK
CRQFMT: CAIN T2,1 ;BLOCK LENGTH MUST BE 1
CAILE T4,.FPMAX ;FORMAT MUST BE LESS OR EQUAL TO MAX
$RETF ;NO,,THATS AN ERROR
JUMPLE T4,.RETF ;CANT BE LESS OR EQUAL TO 0
MOVEI S1,EQHSIZ(P1) ;POINT TO THE FP
STORE T4,.FPINF(S1),FP.FFF ;SAVE THE FILE FORMAT
$RETT ;RETURN OK
CRQODP: CAIE T2,1 ;Block length must be 1
$RETF ;Error
CAIE P2,.QHTOU ;And this must be an output queue
CAIN P2,.QHTIP ;Or an input queue
SKIPA ;Either input or output queue
$RETF ;An error
CAIL T4,0 ;CAN'T BE NEGATIVE
CAILE T4,%DELETE ;WITHIN RANGE?
$RETF ;NO,,THATS AN ERROR
MOVEI S1,EQHSIZ(P1) ;POINT TO THE FP
MOVE T4,[EXP 0,FP.DEL](T4) ;RECODE THE DISPOSITION
IORM T4,.FPINF(S1) ;AND SET IT
$RETT ;RETURN OK
;CONTINUED ON THE NEXT PAGE
;CONTINUED FROM THE PREVIOUS PAGE
CRQUNT: SOJN T2,.RETF ;BLOCK LENGTH MUST BE 1
LOAD S1,T4,RO.ATR ;GET DEVICE ATTRIBUTES IN S1
CAILE S1,%ATMAX ;WITHIN RANGE?
$RETF ;NO,,THATS AN ERROR
JUMPL S1,.RETF ;CAN NOT BE LESS THAN ZERO
LOAD T1,.EQROB+.ROBTY(P1) ;GET THE OBJECT TYPE
MOVX S2,1B0 ;GET A BIT FOR TEST
MOVN T1,T1 ;SETUP TO DO RIGHT SHIFT
LSH S2,(T1)
TDNN S2,ATRCDS(S1) ;VALID FOR THIS OBJECT?
$RETF ;NO,,THATS AN ERROR
STORE S1,.EQROB+.ROBAT(P1),RO.ATR ;STORE THE ATTRIBUTE
CAIE S1,%PHYCL ;IS IT PHYSICAL?
$RETT ;NO,,JUST RETURN
LOAD S2,T4,RO.UNI ;YES,,GET THE UNIT
CAILE S2,7 ;WITHIN RANGE?
$RETF ;NO,,THATS AN ERROR
STORE S2,.EQROB+.ROBAT(P1),RO.UNI ;STORE THE UNIT NUMBER
$RETT
CRQAFT: SOJN T2,.RETF ;BLOCK SIZE MUST BE 1
MOVEM T4,.EQAFT(P1) ;SAVE THE /AFTER PARM
$RETT ;AND RETURN
CRQLIM: SOJN T2,.RETF ;BLOCK LENGTH MUST BE 1
CAIN P2,.QHTOU ;IS THIS AN OUTPUT QUEUE ???
STOLIM T4,.EQLIM(P1),OLIM ;YES,,SAVE IT HERE
CAIN P2,.QHTIP ;OR IS IT AN INPUT QUEUE ???
STOLIM T4,.EQLIM(P1),TIME ;YES,,SAVE IT HERE
$RETT ;AND RETURN
CRQUNQ: CAIN T2,1 ;BLOCK LENGTH MUST BE 1
CAIE P2,.QHTIP ;AND QUEUE TYPE MUST BE INPUT
$RETF ;NO,,RETURN NOW
CAIL T4,%EQUNO ;MUST BE EQUAL TO NO
CAILE T4,%EQUYE ; OR YES
$RETF ;ELSE THATS AN ERROR
STOLIM T4,.EQLIM(P1),UNIQ ;OK,,SAVE THE /UNIQUE VALUE
$RETT ;AND RETRUN
;CONTINUED ON THE NEXT PAGE
;CONTINUED FROM THE PREVIOUS PAGE
CRQRES: CAIN T2,1 ;BLOCK LENGTH MUST BE 1
CAIE P2,.QHTIP ;AND QUEUE TYPE MUST BE INPUT
$RETF ;NO,,RETURN NOW
CAIL T4,%EQRNO ;MUST BE EQUAL TO NO
CAILE T4,%EQRYE ; OR YES
$RETF ;IF NOT,,THATS AN ERROR
STOLIM T4,.EQLIM(P1),REST ;OK,,SAVE THE /RESTART VALUE
$RETT ;AND RETURN
CRQLOG: CAIN T2,1 ;BLOCK LENGTH MUST BE 1
CAIE P2,.QHTIP ;AND QUEUE TYPE MUST BE INPUT
$RETF ;NO,,RETURN NOW
CAIL T4,%EQONL ;MUST BE NO LOG, ALWAYS LOG,
CAILE T4,%EQOLE ; OR LOG ON ERROR ONLY
$RETF ;NO,,THATS AN ERROR
STOLIM T4,.EQLIM(P1),OUTP ;OK,,SAVE THE /OUTPUT: VALUE
$RETT ;AND RETRUN
CRQACT: CAILE T2,10 ;ACCOUNT STRING MUST BE LESS THEN 10
$RETF ;ELSE THATS AN ERROR
MOVEI S1,.EQACT(P1) ;GET THE DESTINATION ADDRESS
ADDI T2,-1(S1) ;GET THE END ADDRESS
HRL S1,T3 ;GET THE SOURCE ADDRESS
BLT S1,0(T2) ;COPY IT OVER
$RETT ;AND RETURN
CRQNOD: CAIE T2,1 ;BLOCK LENGTH MUST BE 1
$RETF ;NO,,THATS AN ERROR
STORE T4,.EQROB+.ROBND(P1) ;OK,,SAVE THE NODE NAME/NUMBER
$RETT ;AND RETURN
CRQNAM: CAILE T2,EQNMSZ ;SIZE MUST BE VALID
$RETF ;ELSE THATS AN ERROR
MOVEI S1,.EQOWN(P1) ;GET THE DESTINATION ADDRESS
ADDI T2,-1(S1) ;GET THE END ADDRESS
HRL S1,T3 ;GET THE SOURCE ADDRESS
BLT S1,0(T2) ;COPY IT OVER
$RETT ;AND RETURN
CRQOID: CAIE T2,1 ;BLOCK LENGTH MUST BE 1
$RETF ;NO,,THATS AN ERROR
CAMN T4,G$SID## ;Don't check privs if same user
JRST CRQOI1 ;Same user, don't check privs
PUSHJ P,A$WHEEL## ;Check for privs
JUMPF .RETF ;Not a WHEEL, lose
MOVEM T4,G$SID## ;Update default USER ID
CRQOI1: STORE T4,.EQOID(P1) ;Save the USER NUMBER
MOVE S2,T4 ;Prepare for the DIRST
HRROI S1,.EQOWN(P1) ;Point to owner string placement
DIRST ;Update the owner string
ERJMP .RETF ;Error
$RETT ;And return
;CONTINUED ON THE NEXT PAGE
;CONTINUED FROM THE PREVIOUS PAGE
CRQNOT: CAIE T2,1 ;BLOCK LENGTH MUST BE 1
$RETF ;NO,,THATS AN ERROR
;**;[21]At CRQNOT:+2L change 2 lines JYCW 7-Feb-86
CAIL T4,0 ;[21]Must be zero (DON'T NOTIFY) or
CAILE T4,.QBNTY ;[21]One (NOTIFY)
$RETF ;ELSE THATS AN ERROR
STORE T4,.EQSEQ(P1),EQ.NOT ;SAVE IT
$RETT ;AND RETURN
CRQBLT: CAIN T2,1 ;BLOCK LENGTH MUST BE 1
CAIE P2,.QHTIP ;AND QUEUE TYPE MUST BE INPUT
$RETF ;NO,,THATS AN ERROR
CAIL T4,%BAPND ;VALUE MUST BE APPEND OR SUPERCEDE,
CAILE T4,%BSPOL ; OR SPOOL
$RETF ;IF NOT,,THATS AN ERROR
STOLIM T4,.EQLIM(P1),BLOG ;OK,,SAVE IT
$RETT ;AND RETURN
CRQJBN: CAIE T2,1 ;BLOCK LENGTH MUST BE 1
$RETF ;ELSE THATS AN ERROR
STORE T4,.EQJOB(P1) ;SAVE IT AS THE JOB NAME
$RETT ;AND RETURN
CRQCDI:
TOPS10<
MOVEI S1,-1(T3) ;GET THE BLOCK ADDRESS
MOVE S2,P1 ;AND THE EQ PAGE ADDRESS
PJRST I$QCDI## ;AND GO PROCESS THE CONNECTED DIRECTORY
> ; End of TOPS10
TOPS20<
CAIE T2,1 ;BLOCK LENGTH MUST BE 1
$RETF ;ELSE THATS AN ERROR
PUSHJ P,A$WHEEL## ;USER MUST BE A WHEEL TO USE THIS BLOCK
JUMPF .RETF ;NO,,THATS AN ERROR
MOVEM T4,G$CDI## ;OK,,SAVE THE CONNECTED DIRECTORY #
$RETT ;AND RETURN
> ; End of TOPS20
CRQNTE: CAIG T2,2 ;LENGTH MUST BE LESS OR EQUAL TO 2
CAIE P2,.QHTOU ;AND MUST BE AN OUTPUT QUEUE
$RETF ;ELSE THATS AN ERROR
DMOVE S1,0(T3) ;GET 2 WORDS OF THE BLOCK
STOLIM S1,.EQLIM(P1),NOT1 ;SAVE THE FIRST NOTE WORD
CAIN T2,2 ;ARE THERE 2 WORDS ???
STOLIM S2,.EQLIM(P1),NOT2 ;YES,,SAVE THE SECOND NOTE WORD
$RETT ;AND RETURN
CRQBGN: CAIN T2,1 ;LENGTH MUST BE 1
CAIE P2,.QHTOU ;AND THIS MUST BE AN OUTPUT QUEUE
$RETF ;ELSE THATS AN ERROR
MOVEI S1,EQHSIZ(P1) ;POINT TO THE FP
STORE T4,.FPFST(S1) ;AND SAVE THE STARTING PAGE NUMBER
$RETT ;RETURN
;CONTINUED ON THE NEXT PAGE
;CONTINUED FROM THE PREVIOUS PAGE
CRQPRI: CAIE T2,1 ;LENGTH MUST BE 1
$RETF ;ELSE THATS AN ERROR
PUSHJ P,A$WHEEL## ;SEE IF THE GUY IS A WHEEL !!!
CAXLE T4,MXUPRI ;GREATER THEN THE MAX USER PRIORITY ?
SKIPF ;YES,,IS THE GUY A WHEEL ???
SKIPA ;YES,,HE WINS
MOVX T4,MXUPRI ;NO,,MAKE IT THE MAX USER PRIORITY
STORE T4,.EQSEQ(P1),EQ.PRI ;SAVE THE PRIORITY
$RETT ;AND RETURN
CRQFRR: CAXN P2,.QHFRR ;ONLY VALID FOR FREE RUNNING DEVICES
CAXLE T2,EQLMSZ ;LENGTH MUST FIT IN LIMIT WORDS
$RETF ;NO,,THATS AN ERROR
MOVSS T3 ;GET SOURCE ADDRESS,,0
HRRI T3,.EQLIM(P1) ;GET SOURCE,,DESTINATION
ADDI T2,.EQLIM(P1) ;GET END ADDRESS
BLT T3,-1(T2) ;COPY LIMIT WORDS OVER
$RETT ;RETURN
CRQSNA: CAIE T2,1 ;Block length must be 1
$RETF ;No, so lose
MOVEI S1,EQHSIZ(P1) ;Point to the FP
LOAD T3,(T4),FP.TAB ;Get TAB flag
STORE T3,.FPINF(S1),FP.TAB ;Save the TAB flag
LOAD T3,(T4),FP.NXL ;Get the NOTRANSLATE flag
STORE T3,.FPINF(S1),FP.NXL ;Save the NOTRANSLATE flag
LOAD T3,(T4),FP.RCL ;Get the RECORD length
STORE T3,.FPINF(S1),FP.RCL ;Save the RECORD length
$RETT ;Return OK
SUBTTL MODIFY - Function 11
;THE MODIFY MESSAGE IS SENT TO QUASAR BY ANY UNKNOWN COMPONENT TO CHANGE
; THE PARAMETERS OF A REQUEST IN A PROCESSING OR AFTER QUEUE
;MODIFY PREFORMS THE FOLLOWING FUNCTIONS:
; 1 ) VALIDATE THE ARGUMENTS
; 2 ) BUILD A TEMPORARY QUEUE OF REQUESTS THAT MATCH
; 3 ) PERFORM THE MODIFY REQUEST ON EACH ELEMENT OF THE TEMPORARY QUEUE
; 4 ) CALL Q$CREATE FOR THE RESULTANT MODIFIED REQUEST
Q$MODIFY:
PUSHJ P,.SAVE4 ;SAVE P1-P4
$COUNT (MMOD) ;NUMBER OF MODIFY MESSAGES
LOAD P1,.MSTYP(M),MS.CNT ;GET THE COUNT FIELD
CAIGE P1,MOD.SZ ;TOO SMALL
PJRST E$MTS## ;INDICATE MESSAGE TOO SHORT
LOAD S1,MOD.OT(M),AR.TYP ;[25]GET THE OBJECT TYPE
PUSHJ P,A$OB2Q## ;CONVERT TO QUEUE HEADER
JUMPF E$UQS## ;"UNKNOWN QUEUE SPECIFIED"
MOVE H,S1 ;COPY HEADER ADDRESS
;BEFORE ACTUAL PROCESSING, CHECK THE REQUEST FOR INVALID LENGTHS AND GROUPS
ADDI P1,(M) ;P1 = FIRST WORD NOT IN THE MESSAGE
MOVEI P2,MOD.FG(M) ;P2 = THE FIRST GROUP HEADER
MODI.1: CAIG P1,MOD.GN(P2) ;OFF THE END OF THE MESSAGE
JRST MODI.2 ;YES, NOW BEGIN PROCESSING
LOAD P3,MOD.GN(P2),MODGPN ;GET THE GROUP NUMBER
LOAD P4,MOD.GN(P2),MODGLN ;AND NUMBER OF GROUP ELEMENTS
JUMPE P4,E$BMG## ;CANNOT BE ZERO
ADDI P4,(P2) ;P4 = NEXT GROUP HEADER
CAIG P3,NGROUP ;INVALID GROUP NUMBER
CAIGE P1,(P4) ;OR INVALID LENGTH
PJRST E$BMG## ;YES, BAD MESSAGE FORMAT
MOVEI P2,(P4) ;POINT TO THE NEXT GROUP
JRST MODI.1 ;CONTINUE FOR ALL PROVIDED GROUPS
;HAVING VERIFIED THE LENGTHS, BEGIN FINDING THE SPECIFIED REQUESTS
MODI.2: PUSH P,G$ACK## ;SAVE CALLERS "ACK" STATUS
ZERO G$ACK## ;SO DON'T GET MESSAGES FROM CREATE
ZERO MODI.C+0 ;ZERO NUMBER OF REQUESTS MODIFIED
SETOM MODI.C+1 ;INITIALLY, DON'T PRINT NUMBER OF FILES
ZERO MODI.C+2 ;NOT CANCELLING JOBS
ZERO MODHDR+.QHLNK ;CLEAR LINKS OF FAKE HEADER
PUSHJ P,MODSET ;SET UP ARGUMENTS FOR FNDREQ
PUSHJ P,FNDREQ ;FIND REQUESTS IN REQUESTED QUEUE
MOVEM S1,MODI.C+3 ;START COUNTING PROTECTION FAILURES
MOVEM M,MODI.A ;SAVE ORIGINAL MESSAGE ADDRESS
;"MODIFY" IS CONTINUED ON THE NEXT PAGE
;CONTINUED FROM PREVIOUS PAGE
;NOW, FLUSH THE TEMPORARY QUEUE, MODIFYING, RE-CREATING AS WE GO
MODI.3: LOAD AP,MODHDR+.QHLNK,QH.PTF ;GET THE TOP OF THE TEMPORARY QUEUE
JUMPE AP,MODI.6 ;PROCESSED THEM ALL (OR NONE)
LOAD S1,.QEROB+.ROBTY(AP),AR.TYP ;[25]GET REQUESTED OBJECT TYPE
PUSHJ P,A$OB2Q## ;CONVERT TO QUEUE HEADER ADR
MOVE H,S1 ;AND PUT IT IN H
PUSH P,.QERID(AP) ;SAVE THIS REQUESTS ID FOR LATER
PUSH P,.QENID(AP) ;SAVE /NOTIFY ID
PUSH P,.QEJBN(AP) ;SAVE JOB NUMBER
LOAD S1,.QESTN(AP),QE.DPA ;GET THE RETREIVAL POINTER
PUSHJ P,F$RDRQ## ;READ IN THE ORIGINAL REQUEST
MOVEM S1,MODI.B ;SAVE FOR LATER RELEASE
MOVE AP,S1 ;ARGUMENT FOR MODIFIER ROUTINES
MOVE M,MODI.A ;GET MODIFY MESSAGE BACK
LOAD P1,.MSTYP(M),MS.CNT ;NOW LOOP FOR ALL GROUP HEADERS
ADDI P1,(M) ;P1 = FIRST WORD NOT IN THE MESSAGE
MOVEI P2,MOD.FG(M) ;P2 = THE FIRST GROUP
MODI.4: CAIG P1,MOD.GN(P2) ;OFF THE END OF THE MESSAGE
JRST MODI.5 ;YES, DONE WITH THIS MATCH
LOAD P3,MOD.GN(P2),MODGPN ;GET THE GROUP NUMBER
MOVEI S1,(P2) ;ARGUMENT FOR MODIFIERS
PUSHJ P,@GRPDIS(P3) ;CALL THE PROPER MODIFIER FOR THIS GROUP
LOAD P3,MOD.GN(P2),MODGLN ;ADJUST FOR THE NEXT GROUP
ADDI P2,(P3) ;P2 = THE NEXT GROUP
JRST MODI.4 ;CONTINUE FOR ALL GROUPS PROVIDED
;HERE AFTER ALL GROUP MODIFIES HAVE BEEN DONE, LINK IN THE NEW REQUEST
MODI.5: MOVE M,MODI.B ;ARGUMENT FOR CREATE = MODIFIED REQUEST
MOVX T1,.QIFNC+.QIMOD ;INTERNAL CALL AND MODIFY
STORE T1,.MSTYP(M),MS.TYP ;SET FOR Q$CREATE
PUSHJ P,Q$CREATE ;PUT MODIFIED REQUEST BACK IN PLACE
SKIPE G$ERR## ;DID THE CREATE WORK
$STOP(CRM,CREATE REJECTED MODIFY)
POP P,S1 ;GET THE USERS JOB NUMBER BACK
LOAD S1,S1,QE.UJN ;GET JUST HIS JOB NUMBER
STORE S1,.QEJBN(AP),QE.UJN ;AND SAVE IT
POP P,.QENID(AP) ;RESTORE THE OLD /NOTIFY ID
POP P,.QERID(AP) ;RESTORE THE OLD REQUEST ID
LOAD AP,MODHDR+.QHLNK,QH.PTF ;GET OLD QUEUE ENTRY BACK
LOAD S1,.QESTN(AP),QE.DPA ;THE RETREIVAL POINTER
PUSHJ P,F$RLRQ## ;RELEASE OLD FAILSOFT COPY
PUSHJ P,Q$DDEP ;GET RID OF THE DEPENDENCY LIST
MOVEI H,MODHDR ;POINT TO THE TEMPORARY QUEUE
PUSHJ P,M$DLNK## ;REMOVE ENTRY ALREADY MODIFIED
LOAD H,.QEOBJ(AP) ;QUEUE THIS ENTRY CAME FROM (PROC, OR AFTER)
PUSHJ P,M$PFRE## ;RETURN TO PROPER FREE LIST
MOVE S1,MODI.B ;ADDRESS OF OLD FAILSOFT COPY
PUSHJ P,M%RPAG ;NO LONGER NEED IT
JRST MODI.3 ;GET ANY OTHER MATCHING REQUESTS
;NOW, GENERATE "ACK" AND RETURN TO THE CALLER
MODI.6: POP P,G$ACK## ;RESTORE "ACK" STATUS
MOVE M,MODI.A ;GET MODIFY MESSAGE BACK
MOVEI T1,MODI.C ;ARGUMENT BLOCK FOR BLDKMS
MOVEI T2,[ASCIZ/ modified/] ;TEXT TO APPEND
PJRST BLDKMS ;BUILD KILL/MODIFY STRING AND RETURN
; SUBROUTINES USED BY MODIFY
;ROUTINE CALL BE MODIFY LOOP TO SET UP ARGUMENTS FOR FNDREQ
MODSET: MOVNI T1,1 ;INDICATE MODIFY REQUEST
MOVEI T2,MOD.RQ(M) ;RDB FOR KILL/MODIFY
MOVE T3,MOD.OT(M) ;GET OBJECT TYPE
MOVEI T4,MODS.1 ;SUBROUTINE TO CALL FOR MATCHES
$RETT ;RETURN FOR CALL TO FNDREQ
;HERE WHEN FNDREQ FINDS A MATCH FOR THE MODIFY BLOCK, ACCUMULATE IN THE TEMP QUEUE
MODS.1: STORE H,.QEOBJ(AP) ;SAVE QUEUE THAT CONTAINED THIS ENTRY
PUSHJ P,M$DLNK## ;REMOVE FROM PROCESSING OR AFTER QUEUE
MOVEI H,MODHDR ;POINT TO THE TEMPORARY QUEUE
PUSHJ P,M$ELNK## ;LINK IN AT THE END
AOS MODI.C+0 ;INCREMENT COUNT OF MODIFIED REQS
$RETT ;RETURN FOR NEXT MATCH
;THE DISPATCH TABLE FOR GROUP MODIFIES
GRPDIS: EXP MAJMOD ;GROUP 0 = MAJOR QUEUE PARAMETERS
EXP GRPMOD ;GROUP 1 = QUEUE DEPENDENT PARAMETERS
NGROUP==<.-GRPDIS>-1 ;HIGHEST KNOWN GROUP NUMBER
GRPMOD: LOAD P3,.QHPAG(H),QH.SCH ;GET SCHEDULING BASE
PJRST SCHMOD(P3) ;DO QUEUE DEPENDENT MODIFY
MODHDR: BLOCK QHSIZE ;HEADER FOR THE TEMPORARY QUEUE
MODI.A: BLOCK 1 ;ORIGINAL 'M'
MODI.B: BLOCK 1 ;WHERE REQUEST HAS BEEN READ BY FAILSOFT
MODI.C: BLOCK 4 ;ARGUMENT BLOCK FOR BLDKMS
SUBTTL KILL - Function 12
;THE KILL MESSAGE IS SENT TO QUASAR BY ANY UNKNOWN COMPONENT TO
; DELETE AN ENTRY FROM A QUEUE.
;KILL PERFORMS THE FOLLOWING FUNCTIONS:
; 1) LOOP THROUGH THE USE QUEUE ABORTING MATCHES.
; 2) LOOP THROUGH THE PROCESSING QUEUE DELETING MATCHES.
Q$KILL: PUSHJ P,.SAVE3 ;SAVE P1-P3
$COUNT (MKIL) ;[33]NUMBER OF KILL MESSAGES
LOAD T1,.MSTYP(M),MS.CNT ;GET MESSAGE SIZE
CAIGE T1,KIL.SZ-<RDBSIZ-.RDBVS> ;BIG ENOUGH?
PJRST E$MTS## ;INDICATE MESSAGE TOO SHORT
SETZM G$REMN## ;[33]ASSUME REQUEST ORIGINATED LOCALLY
SKIPN S1,KIL.PD(M) ;[33]PID PRESENT IN THE MESSAGE?
JRST KILL.1 ;[33]NO, A LOCAL REQUEST
CAME S1,G$SND ;[33]PID SAME AS THE SENDER'S?
JRST KILL.0 ;[33]NO, IN BEHALF OF REQUEST
MOVE S1,KIL.ND(M) ;[33]PICK UP THE NODE NAME
CAMN S1,G$LNAM## ;[33]LOCAL NODE SPECIFIED?
JRST KILL.1 ;[33]YES, TREAT AS A LOCAL REQUEST
SINGLE< PJRST E$CNE##> ;[37]QUIT IF CLUSTER GALAXY NOT ENABLED
$CALL REMKIL ;[33]FORWARD THE MSG TO NEBULA
$RET ;[33]PRESERVE THE T/F INDICATOR
KILL.0: MOVE S1,KIL.ND(M) ;[33]PICK UP REQUESTOR'S NODE NAME
MOVEM S1,G$REMN## ;[33]SAVE FOR QE MATCHES
KILL.1: LOAD S1,KIL.OT(M) ;[33]GET THE OBJECT TYPE
CAIN S1,.OTMNT ;IS IT A MOUNT REQUEST CANCEL ???
PJRST I$KMNT## ;YES,,GO PROCESS IT AND EXIT
PUSHJ P,A$OB2Q## ;CONVERT TO QUEUE HEADER ADDRESS
JUMPF E$UQS## ;ERROR IF UNKNOWN QUEUE
MOVE H,S1 ;LOAD HDR ADDRESS INTO H
SETZM P1 ;INDICATE KILL REQUEST (FOR FNDREQ)
MOVEI P2,KIL.RQ(M) ;REQUEST DESCR BLOCK FOR FNDREQ
LOAD P3,KIL.OT(M) ;GET OBJECT TYPE FOR FNDREQ
ZERO KILL.A+0 ;ZERO NUMBER KILLED
SETOM KILL.A+1 ;DON'T COUNT FILES
ZERO KILL.A+2 ;NUMBER CANCELLED
;NOW, SETUP AND LOOP THRU THE NECESSARY QUEUES
PUSH P,H ;SAVE PROCESSING QUEUE HDR
MOVE T4,[P1,,T1] ;MOVE PERMENANT ARGS TO REAL ARGS
BLT T4,T3 ;COPY P1 - P3
MOVEI T4,KILUSE ;SUBROUTINE TO CALL
MOVEI H,HDRUSE ;LOAD ADR OF USE QUEUE HDR
PUSHJ P,FNDREQ ;FIND A MATCHING REQUEST
MOVEM S1,KILL.A+3 ;START COUNTING PROT FAILURES
MOVE T4,[P1,,T1] ;NEED ARGUMENTS AGAIN
BLT T4,T3 ;SO MOVE THEM
MOVEI T4,Q$KPRO ;SUBROUTINE TO CALL
POP P,H ;GET ADR OF PROCESSING Q HDR
PUSHJ P,FNDREQ ;AND CHECK IT
ADDM S1,KILL.A+3 ;COUNT PROTECTION FAILURES
MOVE T1,KILL.A+2 ;GET NUMBER OF ABORTS SENT
ADDM T1,KILL.A ;ADD TO TOTAL JOBS KILLED
MOVEI T1,KILL.A ;ARGUMENT BLOCK FOR BLDKMS
MOVEI T2,[ASCIZ/ canceled/] ;TEXT TO APPEND
PJRST BLDKMS ;BUILD KILL/MODIFY STRING AND RETURN
KILL.A: BLOCK 4 ;ARGUMENT BLOCK FOR BLDKMS
SUBTTL REMKIL - Forward a KILL message to a remote cluster node
;REMKIL is called by Q$KILL after it detects that the KILL message is to
;be forwarded to a remote cluster node. REMKIL first checks if the user
;is privileged or not. If the user is not privileged, then the user can
;only cancel his own requests on the remote system.
;
;Call is: M/ Address of the KILL message
;Returns true: The KILL message successfully sent
;Returns false: NEBULA is not running or an unprivileged user specified
; a /USER: name other than his own
REMKIL: $SAVE <P1> ;[33]SAVE THIS AC
SKIPN KIL.RQ+.RDBOW(M) ;[33]WAS /USR: SPECIFIED?
JRST REMK.1 ;[33]NO, ADD USER NAME TO REQUEST
$CALL A$WHEEL ;[33]IS THE USER PRIVILEGED?
JUMPT REMK.2 ;[33]YES, CHECK IF NEBULA IS RUNNING
MOVE S2,G$SID## ;[33]PICK UP THE USER I.D.
HRROI S1,USRNAM ;[33]WHERE TO PLACE THE USER NAME
DIRST% ;[33]PLACE THE USER NAME IN THE MSG
ERJMP E$CDU## ;[33]INDICATE AN ERROR OCCURRED
HRROI S1,USRNAM ;[33]WHERE TO PLACE THE USER NAME
HRROI S2,KIL.RQ+.RDBOW(M) ;[33]PICK UP USER SPECIFIED USER NAME
$CALL S%SCMP ;[33]CHECK FOR A MATCH
TXNE S1,SC%LSS!SC%SUB!SC%GTR ;[33]INCLUDE THIS ONE?
PJRST E$IUN## ;[33]INDICATE INVALID USER NAME
JRST REMK.2 ;[33]CHECK IF NEBULA IS RUNNING
REMK.1: MOVE S2,G$SID## ;[33]PICK UP THE USER I.D.
HRROI S1,KIL.RQ+.RDBOW(M) ;[33]WHERE TO PLACE IN THE MESSAGE
DIRST% ;[33]PLACE THE USER NAME IN THE MSG
ERJMP E$CDU## ;[33]INDICATE AN ERROR OCCURRED
REMK.2: SKIPE G$NEBP## ;[33]IS NEBULA'S PID KNOWN?
JRST REMK.3 ;[33]YES, SO GET A MESSAGE PAGE
$CALL A$NPID## ;[33]]PICK UP NEBULA'S PID
JUMPF E$NNR## ;[33]IF FALSE, NEBULA'S NOT RUNNING
REMK.3: $CALL M%GPAG ;[33]PICK UP A PAGE FOR THE MSG
MOVEM S1,G$SAB##+SAB.MS ;[33]SAVE IN THE SAB
MOVE P1,S1 ;[33]SAVE HERE ALSO
MOVEI S2,PAGSIZ ;[33]PICK UP THE MESSAGE SIZE
MOVEM S2,G$SAB##+SAB.LN ;[33]AND SAVE IT IN THE SAB
LOAD S2,.MSTYP(M),MS.CNT ;[33]PICK UP THE MESSAGE LENGTH
ADD S2,S1 ;[33]ADDRESS OF END OF MESSAGE+1
HRL S1,M ;[33]SOURCE,,DESTINATION
BLT S1,-1(S2) ;[33]COPY MSG TO REFORMATTED MSG
MOVE S2,G$SID## ;[42]PICK UP LOGGED-IN DIRECTORY NUMBER
HRROI S1,KIL.RU(P1) ;[42]POINT TO MESSAGE BLOCK
DIRST% ;[42]PLACE IN THE MESSAGE
ERJMP E$CDU## ;[42]QUIT ON AN ERROR
MOVSI S1,EQNMSZ ;[42]PICK UP THE SIZE OF THE BLOCK
ADDM S1,.MSTYP(P1) ;[42]UPDATE THE MESSAGE LENGTH
$CALL SNDNEB## ;[33]FORWARD THE MESSAGE TO NEBULA
JUMPF E$NNR## ;[36]INDICATE AN ERROR
SETZM G$ACK## ;[36]DON'T SEND AN ACK MESSAGE
$RET ;[36]RETURN
SUBTTL DEFER - Function 16
;THE DEFER MESSAGE IS SENT TO QUASAR BY ANY UNKNOWN COMPONENT TO
; RELEASE OR KILL DEFERED SPOOL REQUESTS
;
;DEFER PERFORMS THE FOLLOWING FUNCTIONS:
; 1)VALIDATE THE ARGUMENTS
; 2)LOOP THROUGH THE SPOOL QUEUE FINDING ENTRIES FOR THIS JOB
; 3)CALL Q$CREATE FOR MATCHES, SETTING EQ.RDE IF THIS IS A KILL
; 4)RETURN AN ACK IF WANTED SAYING HOW MANY JOBS, FILES WERE
; RELEASED OR KILLED; ALSO HOW MANY "PROTECTION" FAILURES
; I.E. JOB NUMBER MATCHES WITH WRONG DIRECTORY
Q$DEFER:
PUSHJ P,.SAVE4 ;SAVE P1-P4
$COUNT (MDEF) ;NUMBER OF DEFER MESSAGES
LOAD T1,.MSTYP(M),MS.CNT ;GET LENGTH OF MESSAGE
CAIGE T1,DFR.SZ ;IS IT ALL THERE
PJRST E$MTS## ;NOT LONG ENOUGH, GIVE ERROR
ZERO DEFE.A+0 ;CLEAR COUNT OF JOBS AFFECTED
ZERO DEFE.A+1 ;AND OF FILES
ZERO DEFE.A+2 ;NOT CANCELLING JOBS
ZERO DEFE.A+3 ;AND OF PROTECTION FAILURES
LOAD P1,DFR.JB(M),DF.JOB ;GET JOB NUMBER FROM MESSAGE
LOAD P2,<HDRSPL+.QHLNK>,QH.PTF ;GET THE FIRST ENTRY IN THE SPOOL QUEUE
LOAD T1,DFR.JB(M),DF.FNC ;GET THE FUNCTION REQUESTED
ZERO P3 ;INDICATE RELEASE (FOR LOOP)
CAIN T1,.DFKIL ;IS IT KILL?
MOVEI P3,1 ;YES, INDICATE FOR LOOP
LOAD P4,DFR.OT(M) ;GET OBJECT TYPE
DEFE.1: JUMPE P2,DEFE.6 ;END OF SPOOL QUEUE, RETURN
LOAD T2,SPLJOB(P2),SPYJOB ;GET THE JOB # FROM THIS QUEUE ENTRY
CAME P4,SPLROB+.ROBTY(P2) ;IS IT THE RIGHT OBJECT TYPE?
JUMPN P4,DEFE.5 ;NO, JUMP IF REQUESTED SPECIFIC QUEUE
CAME T2,P1 ;IS THIS FOR THE RIGHT JOB
JRST DEFE.5 ;WRONG JOB OR WRONG QUEUE
LOAD T1,SPLOID(P2) ;GET OWNER ID OF THIS ENTRY
LOAD T2,G$SID## ;GET SENDER'S ID
CAME T1,T2 ;IS IT THE SAME AS SENDER'S?
JRST DEFE.4 ;NO,PROTECTION FAILURE
AOS DEFE.A+0 ;FOUND A MATCHING JOB, COUNT IT
LOAD S1,SPLJOB(P2),SPYDPA ;GET THE DPA
PUSHJ P,F$RDRQ## ;READ THE REQUEST
LOAD T1,.EQSPC(S1),EQ.NUM ;PICK UP THE # OF FILES IN THE REQUEST
ADDM T1,DEFE.A+1 ;COUNT THEM FOR ACK
;CONTINUED ON THE NEXT PAGE
;CONTINUED FROM THE PREVIOUS PAGE
MOVX S2,.QIFNC ;LOAD INTERNAL FUNCTION CODE
STORE S2,.MSTYP(S1),MS.TYP ;AND SAVE IN REQUEST
JUMPE P3,DEFE.2 ;KILL ???,,NO THEN CREATE
PUSHJ P,DLFREQ ;CALL DELETE FILES
JRST DEFE.3 ;CONTINUE ON.
DEFE.2: PUSH P,M ;SAVE THE MESSAGE ADDRESS
PUSH P,S1 ;SAVE THE EQ ADDRESS.
MOVE M,S1 ;MAKE M POINT TO THE EQ
PUSHJ P,Q$CREATE ;CREATE THE QUEUE ENTRY.
SKIPE G$ERR## ;WAS THERE AN ERROR ???
$STOP(CRD,CREATE REJECTED DEFER DATA)
POP P,S1 ;RESTORE THE EQ ADDRESS TO S1.
PUSHJ P,M%RPAG ;RELEASE THE EQ.
POP P,M ;RESTORE THE MESSAGE ADDRESS.
DEFE.3: LOAD S1,SPLJOB(P2),SPYDPA ;GET THE POINTER TO THE DISK
PUSHJ P,F$RLRQ## ;RELEASE THE OLD REQUEST
MOVEI H,HDRSPL ;GET THE HEADER OF THE SPOOL QUEUE
MOVE AP,P2 ;GET THE CURRENT ENTRY
LOAD P2,.QELNK(P2),QE.PTN ;STEP TO NEXT ENTRY
PUSHJ P,M$RFRE## ;FREE UP THIS ONE
JRST DEFE.1 ;GO LOOP THROUGH QUEUE
DEFE.4: AOS DEFE.A+3 ;COUNT PROTECTION FAILURES
DEFE.5: LOAD P2,.QELNK(P2),QE.PTN ;STEP TO NEXT ENTRY
JRST DEFE.1 ;AND LOOP ON
DEFE.6: MOVEI T1,DEFE.A ;ARGUMENT BLOCK FOR BLDKMS
MOVEI T2,[ASCIZ/ killed/] ;ASSUME WE KILLED THEM
SKIPN P3 ;DID WE
MOVEI T2,[ASCIZ/ released/] ;NO, SAY RELEASED
PJRST BLDKMS ;SEND ACK IF REQUESTED
DEFE.A: BLOCK 4 ;ARGUMENT BLOCK FOR BLDKMS
SUBTTL HOLD/RELEASE - Function 25
Q$HOLD: PUSHJ P,A$WHEEL## ;SEE IF CALLER WAS PRIV'ED
JUMPF E$IPE## ;LOSE IF NOT
LOAD S1,HBO.OT(M),AR.TYP ;[25]GET THE OBJECT TYPE
PUSHJ P,A$OB2Q## ;MAKE INTO A QUEUE HEADER
JUMPF E$UQS## ;COULDN'T FIND IT!!
MOVE H,S1 ;PUT QUEUE HEADER IN H
SETO T1, ;MAKE FNDREQ THINK IT IS A MODIFY
MOVEI T2,HBO.RQ(M) ;POINT TO THE RDB TO MATCH
LOAD T3,HBO.OT(M) ;GET THE OBJECT TYPE
MOVEI T4,HOLD.1 ;AND ROUTINE TO CALL
SETZM HOLD.A ;CLEAR THE COUNTER
PUSHJ P,FNDREQ ;GO MATCH REQUESTS
MOVE S1,HOLD.A ;GET # OF JOBS AFFECTED.
SKIPN G$ACK ;DOES HE WANT AN ACK?
$RETT ;NO, JUST RETURN
PUSHJ P,TYPPLJ ;TYPE '1 JOB' '2 JOBS' ETC.
MOVEI T1,[ASCIZ / held/] ;GET THE ACTION
LOAD S1,HBO.FL(M),HB.FRL ;GET THE RELEASE FLAG
SKIPE S1 ;IS IT ON?
MOVEI T1,[ASCIZ / released/] ;YES
$TEXT(G$CCHR##,<^T/0(T1)/^A>)
SETZ S1, ;CLEAR THE FLAGS
PUSHJ P,G$MSND## ;SEND THE ACK
$RETT ;AND RETURN
;HERE ON CALL FROM FNDREQ - AP POINTS TO THE .QE
HOLD.1: LOAD T1,HBO.FL(M),HB.FRL ;GET RELEASE FLAG
LOAD T2,.QESEQ(AP),QE.HBO ;GET CURRENT STATE OF JOB
XOR T2,T1 ;COMBINE THEM TO SEE IF THIS IS A NOOP
JUMPN T2,.RETT ;JUMP IF IT IS
TXC T1,1 ;FLIP THE BIT
LOAD S1,.QESTN(AP),QE.DPA ;GET THE DPA
PUSHJ P,F$RDRQ## ;READ THE REQUEST
STORE T1,.QESEQ(AP),QE.HBO ;STORE IN QE
STORE T1,.EQSEQ(S1),EQ.HBO ;STORE IN EQ
MOVE T1,S1 ;SAVE THE ADDRESS
PUSHJ P,F$WRRQ## ;REWRITE THE REQUEST
LOAD S2,.QESTN(AP),QE.DPA ;GET THE OLD DPA
STORE S1,.QESTN(AP),QE.DPA ;STORE THE NEW ONE
MOVE S1,S2 ;LOAD THE OLD ONE INTO S1
PUSHJ P,F$RLRQ## ;RELEASE THE REQUEST
MOVE S1,T1 ;GET THE PAGE
PUSHJ P,M%RPAG ;RELEASE IT
MOVE S1,AP ;GET THE QE ADDRESS
LOAD S2,HBO.FL(M),HB.FRL ;GET RELEASE FLAG
PUSHJ P,D$HOLD## ;FIX UP MOUNT QUEUES
AOS HOLD.A ;INCREMENT THE COUNT
DOSCHD ;FORCE A SCHEDULE, SOMETHING CHANGED
$RETT ;AND RETURN
HOLD.A: BLOCK 1 ;COUNTER FOR JOBS HELD/RELEASED
SUBTTL SPOOL - IPCC Function .IPCSU (26)
;THE SPOOL MESSAGE IS SENT TO QUASAR BY THE OPERATING SYSTEM UPON
; THE CLOSE OF A SPOOLED FILE.
;AFTER CONVERTING THE ACTUAL SPOOL MESSAGE FROM [SYSTEM]IPCC INTO THE
; CANONICAL FORM, ALL SPOOLING HANDLERS WILL USE THAT DATA STRUCTURE
Q$SPOOL: PUSHJ P,I$CSM## ;CONVERT TO STANDARD FORMAT
MOVEI T1,(S1) ;USE THAT FROM NOW ON
MOVX T2,CS.DFR ;CHECK FOR DEFERRED MODE SPOOLING
TDNE T2,CSM.JB(T1) ;DID THE USER REQUEST IT
JRST SPOO.1 ;YES, GO ADD TO THE SPL QUEUE
$COUNT (ISPL) ;NUMBER OF IMMEDIATE SPOOLS
PUSHJ P,SPROTO ;BUILD EXTERNAL PROTOTYPE
PUSHJ P,Q$INCL ;INCLUDE THE NEW FILE (ONLY)
PUSH P,AP ;SAVE ADDR OF PROTOTYPE BUILT
MOVE M,AP ;MAKE IT THE MESSAGE
PUSHJ P,Q$CREATE ;CALL THE CREATE PROCESSOR
SKIPN G$CRS## ;GTJFN error?
SKIPN G$ERR## ;No, any other errors?
SKIPA ;No, continue on
$STOP(CRS,CREATE REJECTED SPOOLING DATA)
POP P,S1 ;ADDR OF REQUEST
ADR2PG S1 ;MAKE IT A PAGE NUMBER
PJRST M%RELP ;RETURN THROUGH RELEASE PAGE
SPOO.1: $COUNT (DSPL) ;NUMBER OF DEFERED SPOOLS
PUSHJ P,Q$FSPL ;FIND THE MATCHING REQUEST
PUSHJ P,Q$INCL ;INCLUDE THIS FILE
LOAD S1,.MSTYP(AP),MS.CNT ;GET CURRENT REQUEST SIZE
STORE S1,SPLRQZ(E),SPYLEN ;SAVE IN SPOOL QUEUE
MOVE S1,AP ;GET REQUEST ADDRESS
PUSHJ P,F$WRRQ## ;WRITE IT OUT
LOAD S2,SPLJOB(E),SPYDPA ;LOAD THE OLD DPA INTO S2
STORE S1,SPLJOB(E),SPYDPA ;SAVE THE NEW RETRIEVAL POINTER
SKIPE S1,S2 ;GET OLD DPA ( 0 IF INITIAL BUILD)
PUSHJ P,F$RLRQ## ;RELEASE OLD COPY IF THERE IS ONE
MOVE S1,AP ;COPY ADDRESS
PJRST M%RPAG ;RETURN THE PAGE AND EXIT
SUBTTL LOGOUT - IPCC Function .IPCSL (27)
;THE LOGOUT MESSAGE IS SENT BY THE OPERATING SYSTEM UPON
; EXECUTION OF A LOGOUT UUO OR LGOUT JSYS.
;IF .QIFNC IS SET INDICATING AN INTERNAL CALL, THEN COMING FROM S$RELEASE
; AT THE END OF A BATCH JOB. CL.BQE IN CLM.JB IS THE ADDRESS OF THE
; .QExxx FORM OF THAT BATCH JOB
Q$LOGOUT:
PUSHJ P,.SAVE4 ;SAVE P1-P4
ZERO P4 ;INDICATE NOT A BATCH CALL
LOAD T1,.MSTYP(M),.QIFNC ;GET INTERNAL CALL INDICATOR
SKIPE T1 ;A QUICK CHECK FOR INTERNAL CALL
LOAD P4,CLM.JB(M),CL.BQE ;IS, GET THE BATCH JOB QUEUE ENTRY
MOVEI S1,(M) ;GET ADDRESS OF SYSTEM LOGOUT MESSAGE
JUMPN T1,LOGO.1 ;JUMP IF INTERNAL CALL NOW
PUSHJ P,I$CLM## ;CONVERT TO CANONICAL LOGOUT MESSAGE
LOAD T1,CLM.JB(S1),CL.BAT ;GET THE BATCH JOB BIT
JUMPN T1,.RETT ;IGNORE IT HERE, BATCON WILL RELEASE IT
LOGO.1: LOAD P1,CLM.JB(S1),CL.JOB ;GET THE JOB NUMBER FOR THE LOOP
LOAD P2,<HDRSPL+.QHLNK>,QH.PTF ;GET THE FIRST IN THE SPL QUEUE
JUMPE P4,LOGO.2 ;JUMP IF NOT A BATCH JOB
LOAD S1,.QESTN(P4),QE.DPA ;ELSE GET THE DPA
PUSHJ P,F$RDRQ## ;READ THE INPUT REQUEST
MOVE P4,S1 ;AND STORE ADDRESS IN P4
LOGO.2: JUMPE P2,LOGO.5 ;END OF THE QUEUE, RETURN
LOAD T1,SPLJOB(P2),SPYJOB ;JOB NUMBER OF THIS ENTRY
CAME T1,P1 ;SAME JOB
JRST LOGO.4 ;NO, TRY THE NEXT
LOAD S1,SPLJOB(P2),SPYDPA ;GET THE DPA
PUSHJ P,F$RDRQ## ;READ THE REQUEST
JUMPE P4,LOGO.3 ;JUMP IF THIS IS NOT A BATCH JOB
ZERO S2 ;IN CASE WE DON'T FIND A MATCH
LOAD T1,SPLROB+.ROBTY(P2) ;GET OBJECT TYPE
CAIN T1,.OTLPT ;WATCH THIS BRUTE FORCE METHOD
GETLIM S2,.EQLIM(P4),SLPT ;YES, GET SPOOLED LPT LIMIT
CAIN T1,.OTCDP ;LOOKING AT THE PUNCH QUEUE
GETLIM S2,.EQLIM(P4),SCDP ;YES, GET SPOOLED CDP LIMIT
CAIN T1,.OTPTP ;THE PAPER TAPE QUEUE
GETLIM S2,.EQLIM(P4),SPTP ;YES, GET SPOOLED PTP LIMIT
CAIN T1,.OTPLT ;LAST CHANCE, THE PLOTTER
GETLIM S2,.EQLIM(P4),SPLT ;YES, GET SPOOLED PLT LIMIT
SKIPE S2 ;FIND ONE ( OR DON'T LIMIT IT)
STOLIM S2,.EQLIM(S1),OLIM ;STORE SOMETHING AS JOB LIMIT
LOAD T1,.EQJOB(P4) ;GET BATCH JOB NAME
STORE T1,.EQJOB(S1) ;AS OUTPUT NAME
LOAD T1,.EQSEQ(P4),EQ.SEQ ;GET SEQUENCE NUMBER
STORE T1,.EQSEQ(S1),EQ.SEQ ;STORE IT
LOAD T1,.EQSEQ(P4),EQ.PRI ;GET EXT-PRIO FIELD
STORE T1,.EQSEQ(S1),EQ.PRI ;STORE IT
LOAD T1,.EQSEQ(P4),EQ.PRV ;GET THE PRIVS
STORE T1,.EQSEQ(S1),EQ.PRV ;STORE THEM
;CONTINUED ON THE NEXT PAGE
;CONTINUED FROM THE PREVIOUS PAGE
HRLI T1,.EQACT(P4) ;GET THE ORIGIONAL ACCT STRING ADDRESS
HRRI T1,.EQACT(S1) ;GET ITS DESTINATION ADDRESS
BLT T1,.EQACT+7(S1) ;COPY IT OVER !!!
LOAD T1,.EQSPC(P4),EQ.PRO ;GET REQUEST PROTECTION
STORE T1,.EQSPC(S1),EQ.PRO ;STORE IT AWAY
MOVEI T1,EQHSIZ ;GET THE EQ HEADER SIZE
CAXG T1,EQISIZ ;MAKE SURE THERE IS SOMETHING TO MOVE
JRST LOGO.3 ;NO,,THEN JUST CONTINUE ON
MOVSI T1,EQISIZ(P4) ;BEGINING OF OS DEP DATA
HRRI T1,EQISIZ(S1) ;IN BOTH REQUESTS
BLT T1,EQHSIZ-1(S1) ;AND BLT IT
; NOW, CREATE THE REQUEST POINTED TO BY 'S1'
LOGO.3: PUSH P,S1 ;SAVE REQUEST ADDRESS
MOVE M,S1 ;POINT TO IT
MOVX S1,.QIFNC ;LOAD INTERNAL FUNCTION CODE
STORE S1,.MSTYP(M),MS.TYP ;AND SAVE IN THE REQUEST
PUSHJ P,Q$CREATE ;CREATE THE REQUEST
SKIPE G$ERR## ;WAS THERE AN ERROR?
$STOP(CRL,CREATE REJECTED LOGOUT DATA)
POP P,S1 ;ADDR OF REQUEST
PUSHJ P,M%RPAG ;RELEASE IT
LOAD S1,SPLJOB(P2),SPYDPA ;GET THE RETRIEVAL POINTER
PUSHJ P,F$RLRQ## ;AND DELETE THE OLD REQUEST
MOVEI H,HDRSPL ;GET A QUEUE HEADER
MOVE AP,P2 ;CURRENT ENTRY
LOAD P2,.QELNK(P2),QE.PTN ;FIND THE NEXT
PUSHJ P,M$RFRE## ;RETURN SPL QUEUE CELL
JRST LOGO.2 ;GET THE NEXT ENTRY
LOGO.4: LOAD P2,.QELNK(P2),QE.PTN ;FIND THE NEXT
JRST LOGO.2 ;GET THE NEXT ENTRY
;HERE WHEN WE ARE ALL DONE
LOGO.5: SKIPE S1,P4 ;CHECK AND LOAD THE BATCH PAGE ADDRESS
PUSHJ P,M%RPAG ;RETURN THE PAGE IF FROM BATCH
MOVE S1,P1 ;PUT THE JOB NUMBER IN S1
SKIPN REQUEUE ;IF WE ARE NOT REQUEUE'ING,,THEN
PJRST D$LOGOUT## ;RETURN THROUGH THE MDA LOGOUT CODE
$RETT ;IF REQUEUE'ING,,RETURN
SUBTTL Global Subroutines
;ENTRY POINTS
INTERN Q$FSPL ;FIND A MATCHING SPOOLING REQUEST
INTERN Q$INCL ;INCLUDE A FILE INTO A PROTOTYPE AREA
INTERN Q$SUSE ;SEARCH USE QUEUE FOR A GIVEN ITN
INTERN Q$DDEP ;DESTROY JOBS DEPENDENCY LIST
INTERN Q$CDEP ;CHECK THE DEPENDENCY LIST FOR A JOB
INTERN Q$KPRO ;ROUTINE TO KILL A JOB IN THE PROCESSING QUEUE
SUBTTL Q$FSPL - Find a SPL Queue entry
;Q$FSPL IS CALLED WITH T1 POINTING TO THE CANONICAL SPOOL MESSAGE.
; IT WILL FIND THE APPROPRIATE REQUEST IN THE SPL QUEUE THAT
; CAN ACCEPT ANOTHER FILE (Q$INCL) FOR THE CRITERIA DESCRIBED
; IN THE DEFINITION OF THE CANONICAL SPOOL MESSAGE
;RETURN E = THE SPL QUEUE ENTRY (WILL MAKE ONE IF NONE)
; AP = THE EXTERNAL QUEUE REQUEST READY FOR CREATE CALL
Q$FSPL: PUSHJ P,.SAVE2 ;SAVE A REGISTER
LOAD S2,CSM.OI(T1) ;S2 = THE OWNER ID
LOAD T2,CSM.JB(T1),CS.JOB ;T2 = THE USERS JOB NUMBER
LOAD T4,CSM.FD(T1),CS.FDA ;GET ADDRESS OF THE FD
LOAD T4,.FDLEN(T4),FD.LEN ;AND GET THE FD LENGTH
LOAD E,<HDRSPL+.QHLNK>,QH.PTF ;FIND FIRST IN SPL QUEUE
JUMPE E,FSPL.6 ;EMPTY QUEUE, START IT
FSPL.1: LOAD P1,SPLOID(E) ;GET THE OWNER ID FOR THE REQUEST
CAME S2,P1 ;FOR THE SAME USER
JRST FSPL.5 ;NO, TRY NEXT
LOAD P1,SPLJOB(E),SPYJOB ;GET THE JOB NUMBER
CAME P1,T2 ;FOR THE SAME JOB
JRST FSPL.5 ;NO, TRY NEXT
LOAD P1,SPLRQZ(E),SPYLEN ;GET CURRENT SIZE
ADDI P1,FPMSIZ(T4) ;SIZE OF FILE TO BE INCLUDED
CAILE P1,1000 ;REQUEST BECOME TOO BIG
JRST FSPL.5 ;YES, LOOK FOR ANOTHER
LOAD P1,CSM.AF(T1) ;GET AFTER PARAMETER FROM CSM
CAME P1,SPLAFT(E) ;SAME AS THIS SPL ENTRY?
JRST FSPL.5 ;NO, LOSE
LOAD P1,CSM.FM(T1) ;GET FORMS TYPE FROM CSM
CAME P1,SPLFRM(E) ;SAME AS THIS SPL ENTRY?
JRST FSPL.5 ;NO, TRY ANOTHER
DMOVE P1,CSM.NT(T1) ;GET THE TWO NOTE WORDS
CAMN P1,SPLNOT(E) ;IS THE FIRST WORD THE SAME?
CAME P1,SPLNOT+1(E) ;YES, THE SECOND?
JRST FSPL.5 ;LOSE ON ONE OF THEM
LOAD P1,CSM.RO+.ROBTY(T1) ;GET OBJECT TYPE
CAME P1,SPLROB+.ROBTY(E) ;IS IT THE SAME?
JRST FSPL.5 ;NO, TRY AGAIN
LOAD P1,CSM.RO+.ROBND(T1) ;GET THE NODE
CAME P1,SPLROB+.ROBND(E) ;IS IT THE SAME
JRST FSPL.5 ;NO, LOSE
LOAD P1,CSM.RO+.ROBAT(T1) ;GET DEC ATTRIBUTES (OR UNIT #)
LOAD P2,CSM.RO+.ROBUA(T1) ;GET CUST. ATTRIBUTES
SKIPN P1 ;IF BOTH ARE = 0,
JUMPE P2,FSPL.4 ; GENERIC REQUEST MATCHES ANYTHING
;CONTINUED ON THE NEXT PAGE
;CONTINUED FROM THE PREVIOUS PAGE
SKIPN SPLROB+.ROBAT(E) ;SEE IF SPL ENTRY IS GENERIC
SKIPE SPLROB+.ROBUA(E) ; IF BOTH ARE 0
JRST FSPL.2 ;NOT GENERIC, DO THE COMPARE
MOVEM P1,SPLROB+.ROBAT(E) ;STORE NEW VALUES
MOVEM P2,SPLROB+.ROBUA(E) ; " " "
JRST FSPL.4 ;AND CONTINUE ON
FSPL.2: CAMN P1,SPLROB+.ROBAT(E) ;DO ATTRIBUTES MATCH?
CAME P2,SPLROB+.ROBUA(E) ; AND CUSTOMER DEFINED ONES?
JRST FSPL.5 ;NO, LOSE
FSPL.4: LOAD S1,SPLJOB(E),SPYDPA ;GET THE DPA
PUSHJ P,F$RDRQ## ;READ THE REQUEST
MOVE AP,S1 ;SAVE ADR IN AP
MOVSI S1,SPLROB(E) ;POINT TO ROB IN SPL QUEUE
HRRI S1,.EQROB(AP) ;POINT TO ROB IN THE EQ
BLT S1,.EQROB+ROBSIZ-1(AP) ;AND MOVE IT
$RETT ;AND RETURN
FSPL.5: LOAD E,.QELNK(E),QE.PTN ;FIND THE NEXT
JUMPN E,FSPL.1 ;LOOK AT IT IF THERE
FSPL.6: MOVEI H,HDRSPL ;GET A QUEUE HEADER
PUSHJ P,M$GFRE## ;GET A CELL
MOVE E,AP ;WANT IT IN E
PUSHJ P,M$ELNK## ;LINK IT IN AT THE END
MOVSI S1,CSM.RO(T1) ;POINT TO THE ROB IN THE CSM
HRRI S1,SPLROB(E) ;AND TO THE NEW SPL ENTRY
BLT S1,SPLROB+ROBSIZ-1(E) ;AND MOVE IT
LOAD S1,CSM.OI(T1) ;GET THE USERS ID
STORE S1,SPLOID(E) ;STORE THAT TOO
LOAD S1,CSM.JB(T1),CS.JOB ;GET THE JOB NUMBER
STORE S1,SPLJOB(E),SPYJOB ;SAVE THAT TOO
ZERO SPLJOB(E),SPYDPA ;NOT FAILSOFT YET
MOVEI S1,EQHSIZ ;ALL REQUEST START AT THIS SIZE
STORE S1,SPLRQZ(E),SPYLEN ;STORE THE INITIAL LENGTH
PJRST SPROTO ;BUILD THE PROTOTYPE AND RETURN
SUBTTL Q$INCL - Append a File to a Request
;Q$INCL IS CALLED WITH:
; AP = THE CURRENT SPOOL REQUEST
; T1 = THE CANONICAL SPOOL MESSAGE FOR THE NEW FILE
;RETURNS WITH THE NEW FILE INCLUDED IN THE REQUEST AP
Q$INCL: PUSHJ P,.SAVE1 ;GET A WORK REGISTER
MOVE S2,CSM.FP(T1) ;GET THE FLAG SETTINGS
MOVEI S1,1 ;GET A BIT
TXNE S2,FP.SPL ;IS IT A SPOOLED FILE?
STORE S1,.EQSEQ(AP),EQ.SPL ;[34]YES, SET SPOOLING REQUEST FLAG
TXNE S2,FP.SPL ;[34]IS IT A SPOOLED FILED?
STORE S1,.EQPRI(AP),EQ.SPO ;[34]YES, SET SPOOLING REQUEST FLAG
TXNE S2,FP.FLG ;[34]IS IT A LOG FILE?
STORE S1,.EQPRI(AP),EQ.LOG ;[34]YES, SET LOG FILE REQUEST FLAG
LOAD P1,.MSTYP(AP),MS.CNT ;GET LENGTH OF CURRENT MESSAGE
MOVE S2,P1 ;MAKE A COPY
LOAD S1,CSM.FD(T1),CS.FDA ;S1 = ADDRESS OF FD FOR FILE
LOAD S1,.FDLEN(S1),FD.LEN ;S1 = LENGTH OF THE FD
ADDI P1,FPMSIZ(S1) ;P1 = LENGTH OF NEW REQUEST
STORE P1,.MSTYP(AP),MS.CNT ;INCLUDE LENGTH FOR THIS FILE
ADD S2,AP ;AP + OLD LEN = NEXT FILE POINTER
MOVEI P1,FPMSIZ ;LENGTH OF DEFAULT FP AREA
STORE P1,.FPLEN(S2),FP.LEN ;STORE THAT AS WELL
MOVE P1,CSM.FP(T1) ;GET FLAGS REQUESTED BY THE CALLER
STORE P1,.FPINF(S2) ;AS FILE INFORMATION
MOVEI P1,1 ;START AT LINE 1
STORE P1,.FPFST(S2) ;STORE STARTING POINT
ZERO .FPFR1(S2) ;/REPORT WORD 1
ZERO .FPFR2(S2) ; AND WORD 2
MOVEI S2,FPMSIZ(S2) ;BUMP TO FD AREA
LOAD P1,CSM.FD(T1),CS.FDA ;POINT TO THE FD TO INCLUDE
HRLS P1 ;SET UP FOR BLT
HRRI P1,(S2) ;DESTINATION
ADDI S2,(S1) ;COMPUTE THE LAST LOCATION (S1 FROM ABOVE)
BLT P1,-1(S2) ;MOVE THE NEW FILE SPEC INTO THE REQUEST
INCR .EQSPC(AP),EQ.NUM ;BUMP NUMBER OF FILES IN REQUEST
LOAD S1,CSM.FS(T1) ;GET THE NUMBER OF BLOCKS IN THE FILE
GETLIM S2,.EQLIM(AP),NBLK ;GET BLOCKS IN REQUEST
ADD S1,S2 ;INCLUDE THE NEW FILE
STOLIM S1,.EQLIM(AP),NBLK ;UPDATE COUNTERS
SKIPE .EQJOB(AP) ;ANY JOB NAME YET
$RETT ;YES, RETURN NOW
LOAD S1,CSM.EN(T1) ;GET THE 'ENTERED' NAME
STORE S1,.EQJOB(AP) ;MAKE THAT THE REQUEST NAME
$RETT ;AND RETURN
SUBTTL Q$SUSE - Search USE for an ITN
;Call: S1/ ITN
;
;T Return S1/ address of .QE
;
;F Return ITN not found
Q$SUSE: MOVE S2,S1 ;COPY ARGUMENT TO S2
LOAD S1,HDRUSE+.QHLNK,QH.PTF ;POINT TO FIRST USE ITEM
SUSE.1: JUMPE S1,.RETF ;NO MORE THERE, LOSE
CAMN S2,.QEITN(S1) ;DOES THIS MATCH?
$RETT ;YES, RETURN
LOAD S1,.QELNK(S1),QE.PTN ;POINT TO THE NEXT
JRST SUSE.1 ;AND LOOP
SUBTTL Q$ADEP - Add a dependency to a jobs dependency list
SUBTTL Q$DDEP - Destroy a jobs dependency list
;Q$DDEP is called to destroy the dependency list for a job. This
; will include any cleanup that is necessary for each
; dependency.
;Call: AP/ the address of the QE
;
;T Ret: always
Q$DDEP: LOAD S1,.QEDIN(AP),QE.DLN ;GET THE LIST NUMBER
PJRST L%DLST ;AND DESTROY IT
SUBTTL Q$CDEP - Check a jobs dependency list
;Q$CDEP is called to determine whether or not all of a job's dependencies
; have been satisfied.
;Call: AP/ address of the job's QE
;
;T Ret: if all dependencies have been satisfied
;
;F Ret: if there are any unsatisfied dependencies
Q$CDEP: PUSHJ P,.SAVE1 ;SAVE P1
LOAD S1,.QEDIN(AP),QE.DLN ;GET LIST NUMBER
MOVE P1,S1 ;AND SAVE IT IN P1
PUSHJ P,L%FIRST ;AND POSITION TO THE FIRST
JUMPF .RETT ;NO DEPENDENCIES, ALL IS WELL
JRST CDEP.2 ;SKIP INTO THE LOOP
CDEP.1: MOVE S1,P1 ;GET THE LIST NUMBER
PUSHJ P,L%NEXT ;POSITION TO THE NEXT ONE
JUMPF .RETT ;NO MORE, JUST RETURN
CDEP.2: LOAD S1,.DIBDS(S2),DI.TYP ;GET DEPENDENCY TYPE
CAIE S1,.DTSTR ;IS IT A STRUCTURE?
JRST CDEP.1 ;NO, ON TO THE NEXT ONE
MOVE S1,.DIBDT(S2) ;YES, GET STR ADDRESS
PUSHJ P,D$CSTR## ;CHECK IT OUT
JUMPT CDEP.1 ;KEEP LOOPING IF ON-LINE
$RETF ;AND FAIL
SUBTTL Subroutines to maintain DELETE list
;The following subroutines are used to maintain a list of files (primarily
; spooled files) which must be deleted by QUASAR.
INTERN Q$DLFL ;DELETE A FILE
INTERN Q$DLFR ;REBUILD DELETE LIST ENTRY POINT
; DLFREQ ;ADD ALL SPOOLED FILES FROM EQ
;The entries in this DELETE list have the following format:
; !=======================================================!
; ! Address of in-core copy of request !
; !-------------------------------------------------------!
; ! DPA of on-disk copy of request !
; !-------------------------------------------------------!
; ! Number of files in request (decremented) !
; !-------------------------------------------------------!
; ! Offset of next FP !
; !-------------------------------------------------------!
; ! File-structure containing next file to delete !
; !-------------------------------------------------------!
; ! Spooled CDR unique filename handle !
; !=======================================================!
DLF.AD==0 ;ADR OF IN-CORE COPY (0 IF ON-DISK ONLY)
DLF.DP==1 ;DPA OF ON-DISK COPY
DLF.NF==2 ;NUMBER OF FILES IN REQUEST
DLF.FP==3 ;OFFSET OF NEXT FP TO DELETE
DLF.ST==4 ;FILE STRUCTURE OF REQUEST (STR ADDRESS)
DLF.CD==5 ;SPOOLED CDR UNIQUE FILENAME HANDLE
DLF.SZ==6 ;SIZE OF DLF LIST ENTRY
MAXDEL==5 ;MAX NUMBER OF DELETE REQUESTS TO
; KEEP IN CORE
SUBTTL Q$DLFL - Delete a spooled file
;Q$DLFL is called to delete one file from the list of requests which
; require deleting spooled files.
;
;Call: no arguments
;
;T Ret: a request was found
;
;F Ret: no request was found
Q$DLFL: PUSHJ P,.SAVE1 ;SAVE P1
MOVE S1,DELLST ;GET LIST NUMBER OF DELETE LIST
PUSHJ P,L%FIRST ;GET TO FIRST ENTRY
JUMPF .RETF ;NOTHING TO DELETE, RETURN
MOVE P1,S2 ;SAVE ADDRESS IN P1
DLFL.1: MOVE S1,DLF.ST(P1) ;GET THE STRUCTURE
JUMPN S1,DLF.1A ;JUMP IF THERE IS ONE
PUSHJ P,DLFSTR ;EXTRACT THE STRUCTURE
JUMPF DLFL.4 ;IF BAD, ON TO NEXT FILE
MOVEM S1,DLF.ST(P1) ;ELSE, SAVE STR ADDRESS
DLF.1A: PUSHJ P,D$CSTR## ;VERIFY ON-LINENESS
JUMPT DLFL.2 ;JUMP IF OK
MOVE S1,DELLST ;GET LIST NUMBER
PUSHJ P,L%NEXT ;ON TO NEXT ENTRY
JUMPF .RETF ;RETURN IF DONE
JRST DLFL.1 ;ELSE LOOP
DLFL.2: MOVX S1,FOB.SZ ;GET FOB SIZE
MOVEI S2,DLFL.A ;AND FOB ADDRESS
PUSHJ P,.ZCHNK ;ZERO IT OUT
MOVE S1,DLF.AD(P1) ;GET THE ADDRESS OF THE PAGE (EQ)
JUMPN S1,DLFL.3 ;JUMP IF IT IS IN CORE
MOVE S1,DLF.DP(P1) ;GET THE DPA
PUSHJ P,F$RDRQ## ;AND READ THE REQUEST
MOVEM S1,DLF.AD(P1) ;SAVE THE ADDRESS
AOS DELNUM ;INCREMENT THE IN-CORE COUNT
DLFL.3: ADD S1,DLF.FP(P1) ;GET ADDRESS OF THE NEXT FP
LOAD S2,.FPINF(S1),FP.SPL ;GET THE SPOOLED FILE BIT
JUMPE S2,DLFL.4 ;JUMP IF NOT SPOOLED
LOAD S2,.FPLEN(S1),FP.LEN ;GET FP LENGTH
ADD S2,S1 ;POINT TO THE FD
MOVEM S2,DLFL.A+FOB.FD ;STORE IN THE FOB
MOVX S1,FOB.SZ ;LOAD THE FOB SIZE
MOVEI S2,DLFL.A ;AND THE FOB ADDRESS
PUSHJ P,F%DEL ;DELETE THE FILE
;CONTINUED ON THE NEXT PAGE
;CONTINUED FROM THE PREVIOUS PAGE
DLFL.4: SOSG DLF.NF(P1) ;DECREMENT FILE COUNT
JRST DLFL.5 ;DONE WITH THIS REQUEST, DELETE IT
MOVE S1,DLF.FP(P1) ;GET CURRENT FP OFFSET
ADD S1,DLF.AD(P1) ;ADD BASE TO GET ADDRESS
LOAD S2,.FPLEN(S1),FP.LEN ;GET FP LENGTH
ADDM S2,DLF.FP(P1) ;BUMP THE ENTRY
ADD S1,S2 ;AND POINT TO THE FD
LOAD S2,.FDLEN(S1),FD.LEN ;GET THE FD LENGTH
ADDM S2,DLF.FP(P1) ;AND GET OFFSET OF NEXT FP
PUSHJ P,DLFSTR ;EXTRACT THE STR
JUMPF DLFL.4 ;ON TO NEXT FILE IF STR IS BAD
$RETT ;ELSE, JUST RETURN
DLFL.5: SKIPN S2,DLF.CD(P1) ;GET SPOOLED FILENAME HANDLE
JRST DLFL.6 ;THERE ISN'T ONE
MOVE S1,DLF.AD(P1) ;GET EQ ADDRESS
MOVE S1,.EQOID(S1) ;GET DIRECTORY NUMBER
PUSHJ P,I$DCDR## ;DELETE SPOOLED CDR FILES
DLFL.6: MOVE S1,DLF.AD(P1) ;GET THE PAGE ADDRESS
PUSHJ P,M%RPAG ;AND RELEASE IT
SOS DELNUM ;DECREMENT THE COUNT
MOVE S1,DLF.DP(P1) ;GET THE DPA
PUSHJ P,F$RLRQ## ;RELEASE THE REQUEST
MOVE S1,DELLST ;GET LIST NUMBER
PUSHJ P,L%DENT ;DELETE THE CURRENT ENTRY
$RETT ;AND RETURN
DLFL.A: BLOCK FOB.SZ ;A FOB
SUBTTL Q$DLFR - Rebuild an entry in the DELETE list
;Q$DLFR is the rebuild routine for the failsoft initialization code on
; entries with rebuild code %RBDEL.
;
;Call: S1/ the EQ address
; S2/ the DPA
Q$DLFR: PUSHJ P,.SAVE2 ;SAVE P1-P2
DMOVE P1,S1 ;SAVE ARGS IN P1, P2
PUSHJ P,M%GPAG ;GET A PAGE
EXCH S1,P1 ;SAVE IT AS THE ARGUMENT
HRLS S1 ;GET SOURCE,,0
HRR S1,P1 ;GET SOURCE,,DEST
BLT S1,PAGSIZ-1(P1) ;AND MOVE THE DATA SINCE THE
; ARGUMENT PAGE IS RETURNED
JRST DLFR.1 ;AND HANDLE THE REST SORT OF NORMALLY
SUBTTL DLFREQ - Add an EQ to the DELETE list
;DLFREQ is called to place an EQ into the list of requests for file
; deletion.
;
;Call: S1/ address of the EQ
DLFREQ: PUSHJ P,.SAVE2 ;SAVE P1 - P2
MOVE P1,S1 ;SAVE THE ADDRESS
SETZ P2, ;NO DPA HERE
DLFR.1: MOVE S1,DELLST ;GET LIST NUMBER
PUSHJ P,L%LAST ;POSITION TO THE END
MOVEI S2,DLF.SZ ;GET ENTRY SIZE
MOVE S1,DELLST ;GET THE LIST NUMBER
PUSHJ P,L%CENT ;CREATE THE ENTRY
SKIPT ;Did we get an entry successfully?
PUSHJ P,S..CCE## ;Stop if not
MOVEM P1,DLF.AD(S2) ;SAVE THE EQ ADDRESS
LOAD S1,.MSTYP(P1),MS.CNT ;GET THE EQ LENGTH
HRLZS S1 ;GET LEN,,0
HRR S1,P1 ;GET LEN,,ADR
MOVE P1,S2 ;SAVE ADDRESS OF THE ENTRY
MOVX S2,%RBDEL ;GET REBUILD CODE
JUMPN P2,DLFR.2 ;JUMP IF WE HAVE A DPA
PUSHJ P,F$FSRQ## ;FAILSOFT THE REQUEST
MOVE P2,S1 ;GET THE DPA IN P2
DLFR.2: MOVEM P2,DLF.DP(P1) ;SAVE THE DPA
LOAD S1,DLF.AD(P1) ;GET THE EQ ADDRESS
LOAD S2,.EQSPC(S1),EQ.NUM ;GET THE NUMBER OF FILES
MOVEM S2,DLF.NF(P1) ;STORE IT
LOAD S2,.EQLEN(S1),EQ.LOH ;GET LENGTH OF HEADER
MOVEM S2,DLF.FP(P1) ;STORE OFFSET OF FIRST FP
SETZM DLF.ST ;CLEAR THE STR WORD
PUSHJ P,I$GCDR## ;GET SPOOLED CDR FILENAME HANDLE IF ANY
MOVEM S1,DLF.CD(P1) ;STORE IT
AOS S1,DELNUM ;INCREMENT THE COUNT
CAIG S1,MAXDEL ;TOO MANY?
$RETT ;NO, JUST RETURN
SETZ S1, ;CLEAR A AC
EXCH S1,DLF.AD(P1) ;LOAD ADDRESS AND CLEAR STORAGE
SOS DELNUM ;DECREMENT IN-CORE COUNT
PJRST M%RPAG ;GIVE UP THE PAGE AND RETURN
;HERE TO EXTRACT THE STRUCTURE FROM THE 'CURRENT' FILE [DLF.FP(P1)] AND
; STORE IT IN DLF.ST(P1). RETURNS FALSE IF STR NAME IS BAD.
DLFSTR: MOVE S1,DLF.FP(P1) ;GET OFFSET OF THE FP
ADD S1,DLF.AD(P1) ;AND GET THE ADDRESS
LOAD S2,.FPLEN(S1),FP.LEN ;GET FP LENGTH
ADD S1,S2 ;AND POINT TO FIRST FD
PUSHJ P,D$ESTR## ;EXTRACT THE STRUCTURE
JUMPF .RETF ;FAIL???
MOVEM S1,DLF.ST(P1) ;STORE IT
$RETT ;AND RETURN
SUBTTL Q$NOTIFY - ROUTINE TO VALIDATE A /NOTIFY REQUEST
;CALL: S1/ The Notify Type (%NOTTY, %NOTML, %NOTJB)
;
;RET: TRUE ALWAYS
Q$NOTIFY: PUSHJ P,.SAVE1 ;SAVE P1 FOR A MINUTE
MOVE P1,S1 ;SAVE THE NOTIFY CODE
PUSHJ P,NOTBIN ;CARD-READER-INTERPRETER NOTIFY?
JUMPT NOTI.2 ;YES - GO PLUG IN SOME GOOD NUMBERS
LOAD S1,G$PRVS##,MD.PJB ;GET THE SENDERS JOB NUMBER
LOAD S2,HDRUSE+.QHLNK,QH.PTF ;GET THE FIRST ENTRY IN THE USE QUEUE
NOTI.1: JUMPE S2,NOTI.3 ;NO MORE,,SET UP NORMAL NOTIFY
LOAD T1,.QEJBN(S2),QE.BJN ;GET THE BATCH JOB NBR (IF THERE IS ONE)
CAMN S1,T1 ;DOES SNDRS # = QUEUE # ???
JRST NOTI.2 ;YES,,MUST BE REQUEST FROM A BATCH JOB
LOAD S2,.QELNK(S2),QE.PTN ;NO,,GET THE NEXT USE QUEUE ENTRY
JRST NOTI.1 ;AND GO CHECK IT OUT
NOTI.2: LOAD S1,.QEJBN(S2),QE.UJN ;GET THE ORIGIONAL JOB NUMBER
MOVEM S1,.QEJBN(AP) ;SAVE IT
MOVE S1,.QENID(S2) ;GET THE ORIGIONAL NOTIFY ID
MOVEM S1,.QENID(AP) ;SAVE IT
LOAD S1,.QESEQ(S2),QE.NOT ;GET THE ORIGIONAL NOTIFY TYPE
STORE S1,.QESEQ(AP),QE.NOT ;SAVE IT
$RETT ;AND RETURN
NOTI.3: STORE S1,.QEJBN(AP) ;NOT FROM BATCH,,SAVE THE USERS JOB #
CAXN P1,%NOTJB ;IS THIS A NOTIFY JOB REQUEST ???
MOVE S2,G$SND## ;YES,,GET HIS PID
CAXN P1,%NOTML ;DO WE WANT TO NOTIFY VIA MAIL ???
MOVX P1,%NOTTY ;YES,,TO BAD ITS NOT SUPPORTED !!!
CAXE P1,%NOTTY ;DO WE WANT TO NOTIFY HIS TERMINAL ???
JRST NOTI.4 ;NO,,CONTINUE ON
MOVX S2,JI.JLT ;GET 'LOGIN-TIME' FUNCTION CODE
PUSHJ P,I%JINF ;GET THE JOBS LOGIN TIME
JUMPF NOTI.5 ;IF AN ERROR,,RESET /NOTIFY VALUES
NOTI.4: STORE S2,.QENID(AP) ;ELSE SAVE THE JOBS LOGIN TIME
MOVX S2,JI.USR ;MAKE ONE LAST CHECK...
PUSHJ P,I%JINF ;GET THE USER NUMBER
JUMPF NOTI.5 ;NOT THERE,,RESET /NOTIFY VALUES
CAMN S2,G$SID## ;JOBS USER MUST = SENDERS ID.
$RETT ;IT DOES,,SO RETURN
NOTI.5: ZERO .QESEQ(AP),QE.NOT ;CLEAR THE NOTIFY BITS
SETZM .QEJBN(AP) ;ZAP THE JOB NUMBER
SETZM .QENID(AP) ;AND THE NOTIFY ID
$RETT ;AND RETURN
; Here to check for SPRINT submitting a batch job. We want to notify
; the original submitter of the job SPRINT is currently processing.
; This routine KNOWS that there can only be one card-reader-interpreter
; job running at a time.
; Call: PUSHJ P,NOTBIN
;
; TRUE return: S2:= originating QE address
; FALSE return: cannot determine original EQ
;
NOTBIN: MOVEI S1,.QEROB(AP) ;GET REQUEST OBJECT BLOCK ADDRESS
MOVE S2,.ROBTY(S1) ;GET OBJECT TYPE WORD
CAIE S2,.OTBAT ;BATCH JOB BEING SUBMITTED?
$RETF ;NOPE
MOVE S1,G$SND## ;GET PID OF CURRENT SENDER
$SAVE <H> ;SAVE FROM DESTRUCTION
PUSHJ P,A$FPSB## ;SEARCH FOR THE PID IN THE PSB CHAIN
JUMPF .RETF ;NOT FROM A KNOWN COMPONENT
LOAD S2,PSBLIM(S1),PSLCUR ;GET NUMBER OF CURRENT JOBS FOR SPOOLER
JUMPE S2,.RETF ;SANITY CHECK SAYS SHOULD BE AT LEAST 1
LOAD S2,PSBFLG(S1),PSFNOT ;GET NUMBER OF OBJECT TYPES
MOVNS S2 ;NEGATE THE COUNT
HRLI S2,PSBOBJ(S1) ;GET ADDRESS OF OBJECT BLOCKS
MOVSS S2 ;MAKE AN AOBJN POINTER
NOTB.2: HRRZ S1,(S2) ;GET AN OBJECT TYPE
CAIE S1,.OTBIN ;CARD-READER-INTERPRETER?
AOBJN S2,NOTB.2 ;NOPE
JUMPGE S2,.RETF ;CHECKED ALL OBJECT TYPES?
LOAD S2,HDRUSE+.QHLNK,QH.PTF ;POINT TO FIRST ENTRY IN THE USER QUEUE
SKIPA ;SKIP FIRST TIME THROUGH
NOTB.3: LOAD S2,.QELNK(S2),QE.PTN ;GET NEXT ENTRY ADDRESS
JUMPE S2,.RETF ;CHECK FOR ENF OF QUEUE
MOVE S1,.QEOBJ(S2) ;GET OBJECT BLOCK ADDRESS
MOVE S1,OBJTYP(S1) ;GET OBJECT TYPE
CAIE S1,.OTBIN ;FOUND SPRINT YET?
JRST NOTB.3 ;TRY ANOTHER QUEUE ENTRY
$RETT ;RETURN WITH S2:= QE ADDRESS
SUBTTL Q$KPRO - ROUTINE TO TAKE A REQUEST OUT OF A PROCESSING QUEUE
;CALL: AP/Request Address
; H/ Queue Header Address
;
;RET: True Always
Q$KPRO: AOS KILL.A+0 ;INCREMENT KILLED COUNT
LOAD T1,.QESEQ(AP),QE.SPL ;GET SPOOLED BIT
JUMPE T1,KILP.2 ;JUMP IF NO SPOOLED FILES IN REQUEST
MOVX S1,FOB.SZ ;LOAD SIZE OF A FOB
MOVEI S2,KILFOB ;AND ADDRESS
PUSHJ P,.ZCHNK ;AND ZERO THE FOB FOR LATER
LOAD S1,.QESTN(AP),QE.DPA ;LOAD THE DPA
PUSHJ P,F$RDRQ## ;READ THE REQUEST
MOVE T2,S1 ;SAVE THE ADDRESS
LOAD S2,.EQSPC(S1),EQ.NUM ;GET NUMBER OF FILES
CAIE S2,1 ;ONLY ONE FILE?
JRST KILP.1 ;MORE THAN 1 OR SPOOLED CDR FILES
LOAD S2,.EQLEN(S1),EQ.LOH ;GET LENGTH OF HEADER
ADD S1,S2 ;POINT TO FIRST FP
LOAD S2,.FPINF(S1),FP.SPL ;GET THE SPOOLED BIT
JUMPE S2,KILP.2 ;NOT SPOOLED, JUST KILL REQUEST
LOAD S2,.FPLEN(S1),FP.LEN ;GET THE FP LENGTH
ADD S1,S2 ;POINT TO THE FD
MOVEM S1,KILFOB+FOB.FD ;STORE FD ADR IN THE FOB
MOVX S1,FOB.SZ ;LOAD THE FOB SIZE
MOVEI S2,KILFOB ;AND THE FOB ADDRESS
PUSHJ P,F%DEL ;DELETE THE FILE
MOVE S1,T2 ;GET THE ADDRESS
PUSHJ P,M%RPAG ;RELEASE THE PAGE
JRST KILP.2 ;AND FINISH UP
KILP.1: MOVE S1,T2 ;GET THE EQ ADDRESS
PUSHJ P,DLFREQ ;GO ADD TO LIST OF FILES TO DELETE
KILP.2: PUSHJ P,Q$DDEP ;DELETE THE DEPENDENCY LIST
MOVE S1,AP ;GET THE QE ADDRESS IN S1
PUSHJ P,D$PPRL## ;DELETE THE MDR FOR THIS REQUEST
LOAD S1,.QESTN(AP),QE.DPA ;GET THE DPA
PUSHJ P,F$RLRQ## ;RELEASE IT
PUSHJ P,M$RFRE## ;RELEASE THE REQUEST
$RETT ;AND RETURN
KILFOB: BLOCK FOB.SZ ;A FOB FOR F%DEL
SUBTTL Subroutines
; VALMSG VALIDATE MESSAGES FROM KNOWN COMPONENTS
; FNDREQ UTILITY FOR KILL/MODIFY TO FIND ALL MATCHES IN A QUEUE
; SPROTO BUILD SPOOL TO QUEUE PROTOTYPE
; MAJMOD PERFORM MODIFY ON GLOBAL QUEUE PARAMETERS
; BLDKMS BUILD THE KILL/MODIFY/DEFER ACKNOWLEDGEMENT STRING
; TYPPLR ROUTINE TO PLURALIZE A MESSAGE
; NOTIFY ;ROUTINE TO SEND A NOTIFY MESSAGE TO ORION
SUBTTL VALMSG - Routine to validate message from known component
;VALMSG IS CALLED WITH THE MINIMUM SIZE OF THE MESSAGE IN T1. IF
; THE MESSAGE IS INVALID, EXIT THROUGH QSR??% TO SET GLOBAL ERROR
; CALLER MUST CHECK G$ERR TO DETERMINE IF OK TO PROCEED
;
;ON SUCCESS, LOCATION THSPSB IS FILLED WITH THE ADDRESS OF THE PSB
; FOR THE SENDER
VALMSG: LOAD T2,.MSTYP(M),MS.CNT ;GET SIZE OF MESSAGE
CAMGE T2,T1 ;GREATER OR EQUAL?
PJRST E$MTS## ;INDICATE MESSAGE TOO SHORT
MOVE S1,G$SND## ;GET PID OF CURRENT SENDER
PUSHJ P,A$FPSB## ;FIND HIS PSB
JUMPE S1,E$NKC## ;INDICATE NO PSB
MOVEM S1,THSPSB ;SAVE THE PSB
$RETT ;AND RETURN
SUBTTL KILUSE - ROUTINE TO ABORT A JOB IN THE USE QUEUE
;CALL: AP/Queue Entry Address
;
;RET: True Always
KILUSE: PUSHJ P,.SAVE1 ;SAVE P1
PUSHJ P,.SAVET ;SAVE ALL T AC'S
MOVEI T3,G$MSG## ;LOAD ADR OF THE MESSAGE
LOAD T4,.QEOBJ(AP) ;GET OBJECT ADDRESS
LOAD S1,OBJPID(T4) ;GET PROCESSORS PID
MOVEM S1,G$SAB##+SAB.PD ;STORE AS RECIEVERS PID
MOVX S1,ABO.SZ ;GET THE MESSAGE LENGTH
MOVEM S1,G$SAB##+SAB.LN ;SAVE IT IN THE SAB
MOVEM T3,G$SAB##+SAB.MS ;SAVE THE MSG ADDRESS IN THE SAB
MOVEI S1,OBJTYP(T4) ;POINT TO OBJECT TYPE
MOVEI S2,ABO.TY(T3) ;POINT TO MOVE OBJECT BLOCK TO
PUSHJ P,A$CPOB## ;COPY IT
MOVE T4,[ABO.SZ,,.QOABO] ;LOAD THE MESSAGE HDR
STORE T4,.MSTYP(T3) ;AND STORE IT
LOAD P1,.QEITN(AP) ;GET THE ITN
STORE P1,ABO.IT(T3) ;STORE IN ABORT MESSAGE
MOVX T4,ABOUSR ;"ABORTED BY USER"
STORE T4,ABO.CD(T3) ;STORE THE CODE
LOAD T4,G$SID## ;GET ID OF SENDER
STORE T4,ABO.ID(T3) ;AND STORE IN THE MESSAGE
SKIPN T4,G$REMN## ;[42]REQUEST ORIGINATE REMOTELY?
JRST KILU.1 ;[42]NO, SEND THE MESSAGE NOW
HRLI S1,KIL.RU(M) ;[42]PICK UP REQUESTOR NAME ADDRESS
HRRI S1,ABO.RU(T3) ;[42]WHERE TO PLACE IN THE MESSAGE
MOVEI S2,<ABO.RU+EQNMSZ-1>(T3);[42]END OF NAME IN THE MESSAGE
BLT S1,0(S2) ;[42]PLACE REQUESTOR NAME IN MESSAGE
MOVEM T4,ABO.ND(T3) ;[42]PLACE REQUESTOR'S NODE NAME IN MSG
MOVEI S1,EQNMSZ+1 ;[42]PICK UP SIZE OF THE TWO BLOCKS
ADDM S1,G$SAB##+SAB.LN ;[42]UPDATE THE SAB
MOVSS S1 ;[42]PLACE LENGTH WHERE EXPECTED IN MSG
ADDM S1,.MSTYP(T3) ;[42]UPDATE THE MESSAGE LENGTH
MOVEI S1,ABORMU ;[42]INDICATE REMOTE USER
STORE S1,ABO.CD(T3) ;[42]PLACE IN THE MESSAGE
KILU.1: PUSHJ P,C$SEND## ;[42]SEND THE MESSAGE
MOVE S1,P1 ;GET THE ITN
PUSHJ P,Q$SUSE ;SEE IF STILL IN THE USE QUEUE
JUMPF .RETT ;NO, WE DID NOT ABORT IT
MOVX S2,QE.RDE ;GET THE RDE BIT
IORM S2,.QESEQ(S1) ;AND SET IT
AOS KILL.A+2 ;INCREMENT ABORTED COUNT
$RETT ;AND RETURN
SUBTTL FNDREQ - Utility for KILL/MODIFY to find all matches
;FNDREQ IS CALLED WITH THE FOLLOWING ARGUMENTS
; H = THE QUEUE TO SEARCH
; T1 = CODE (0 = KILL, -1 = MODIFY)
; T2 = ADDRESS OF AN RDB TO MATCH AGAINST
; T3 = OBJECT TYPE
; T4 = SUBROUTINE TO CALL UPON FINDING A MATCH
;USES AP TO TRAVERSE THE QUEUE
;THE SUBROUTINE WHICH IS CALLED UPON FINDING A MATCHING REQUEST (@T4)
; IS CALLED WITH THE ADDRESS OF THE REQUEST IN "AP", AND "H"
; SETUP. IT MAY USE T1-T4,AP, AND H.
;
;RETURNS NUMBER OF PROTECTION FAILURES IN S1
FNDREQ: SETZB S1,FNDR.E ;CLEAR THE # PROT FAILS
LOAD AP,.QHLNK(H),QH.PTF ;GET FIRST IN QUEUE
JUMPE AP,.RETT ;DON'T BOTHER IF EMPTY
PUSHJ P,.SAVE1 ;NEED ANOTHER REG
MOVEM T1,FNDR.A ;SAVE THE ORIGINAL ARGUMENTS
MOVEM T2,FNDR.B ;SO THAT THE CALLER CAN USE
MOVEM T3,FNDR.C ;THEM WHEN I CALL THE SUBROUTINE
MOVEM T4,FNDR.D ;UPON FINDING A MATCH
FNDR.1: LOAD T4,.QEROB+.ROBTY(AP),AR.TYP ;[26]GET OBJECT TYPE OF THIS ENTRY
CAME T4,FNDR.C ;FOR THE SAME QUEUE
JRST FNDR.4 ;NO, TRY THE NEXT IN THE QUEUE
MOVE S1,FNDR.B ;POINT TO THE MASK BLOCK FOR CHKMCH
PUSHJ P,I$RMCH## ;SEE IF THIS THE A MATCHING REQUEST
JUMPF FNDR.4 ;JUMP IF NOT A MATCH
;WITH A REQUEST IN AP THAT MATCHES, DO A LITTLE ACCESS CHECKING
LOAD S1,.QESEQ(AP),QE.RDE ;REQUEST ALREADY GONE?
JUMPN S1,FNDR.4 ;YES, DON'T GET IT AGAIN
SKIPN G$QOPR## ;IS THIS AN OPERATOR REQUEST ???
JRST FNDR.2 ;NO,,SKIP THIS CHECK
SKIPN S1,G$RMTE## ;ANY REMOTE STATION SPECIFIED ???
JRST FNDR.3 ;NO NODE SPECIFIED,,HE WINS !!!
MOVE S2,.QEROB+.ROBND(AP) ;GET THE REQUESTS DESTINATION NODE
PUSHJ P,N$MTCH## ;DO THEY MATCH ???
JUMPT FNDR.3 ;YES,,HE WINS
JUMPF FNDR.4 ;NO,,HE LOSES
FNDR.2: LOAD S1,G$SID## ;GET MESSAGE SENDER ID
LOAD S2,.QEOID(AP) ;REQUEST OWNER ID
;CONTINUED ON THE NEXT PAGE
;CONTINUED FROM PREVIOUS PAGE
CAMN S2,S1 ;DOING SOMETHING TO OWN REQUEST
SKIPL FNDR.A ;YES, TRYING TO MODIFY IT
SKIPA ;NO, NEED TO DO ACCESS CHECKS
JRST FNDR.3 ;USER MAY ALWAYS MODIFY OWN REQUEST
LOAD S1,.QEPRT(AP),QE.PRO ;GET REQUEST PROTECTION
HRLI S1,ACC.KM ;CHECK ACCESS TYPE
PUSHJ P,I$CHAC## ;CHECK REQUESTORS RIGHTS
JUMPT FNDR.3 ;JUMP IF ACCESS ALLOWED
AOS FNDR.E ;COUNT PROTECTION FAILURES
JRST FNDR.4 ;AND TRY THE NEXT
;SINCE ITS OK TO KILL/MODIFY THIS REQUEST, CALL THE CALLERS SUBROUTINE
FNDR.3: LOAD P1,.QELNK(AP),QE.PTN ;FIND NEXT IN CASE ITS REMOVED
PUSH P,H ;MAKE US IMMUNE FROM IT
PUSHJ P,@FNDR.D ;DO SOMETHING TO THIS REQUEST
POP P,H ;RESTORE ORIGINAL HEADER
SKIPA AP,P1 ;NOW POINT TO THE NEXT
FNDR.4: LOAD AP,.QELNK(AP),QE.PTN ;FIND THE NEXT
JUMPN AP,FNDR.1 ;CHECK FOR ALL ENTRIES
MOVE S1,FNDR.E ;LOAD NUMBER OF PROT FAILURES
$RETT ;QUEUE EXHAUSTED, RETURN
;LOCAL STORAGE
FNDR.A: BLOCK 1 ; KILL = 0, MODIFY = -1
FNDR.B: BLOCK 1 ;KILL/MODIFY REQ DESC BLOCK
FNDR.C: BLOCK 1 ;RQP OF REQUESTED QUEUE
FNDR.D: BLOCK 1 ;ADDRESS OF PROCESSING ROUTINE
FNDR.E: BLOCK 1 ;# OF PROTECTION FAILURES
SUBTTL SPROTO - Build a CREATE Message Prototype
;SPROTO IS CALLED WITH T1 = THE CANONICAL SPOOL MESSAGE TO BUILD THE
; PROTOTYPE EXTERNAL QUEUE ENTRY FOR THE FIRST FILE IN DEFERRED
; MODE OR THE ONLY FILE IF IMMEDIATE MODE
;RETURN AP = THE BUILT PROTOTYPE READY FOR Q$INCL
SPROTO: PUSHJ P,M%ACQP ;GET A PAGE FOR THE PROTOTYPE
MOVE AP,S1 ;COPY FOR CALLER
PG2ADR AP ;TO AN ADDRESS
MOVX T2,<INSVL.(EQHSIZ,MS.CNT)!.QIFNC> ;GET SIZE AND INTERNAL CREATE
STORE T2,.MSTYP(AP) ;AS THE MESSAGE HEADER
MOVX T2,<%%.QSR,,EQHSIZ> ;VERSION,,HEADER SIZE
STORE T2,.EQLEN(AP) ;AS EXTERNAL QUEUE LENGTHS
MOVSI T2,CSM.RO(T1) ;POINT TO CSM'S ROB
HRRI T2,.EQROB(AP) ;AND THE EQ'S ROB
BLT T2,.EQROB+ROBSIZ-1(AP) ;AND MOVE IT
MOVE T2,G$SPRT## ;GET SYSTEM PROTECTION OF SPOOLED FILES
STORE T2,.EQSPC(AP),EQ.PRO ;AS THE REQUEST PROTECTION
MOVE S1,[POINT 7,G$ACTS##] ;GET THE ACCOUNT STRING BYTE POINTER
MOVE S2,[POINT 7,.EQACT(AP)] ;GET THE DESTINATION BYTE POINTER
SPRO.1: ILDB T2,S1 ;GET A BYTE
IDPB T2,S2 ;SAVE IT
JUMPN T2,SPRO.1 ;CONTINUE TILL ASCIZ
LOAD T2,CSM.AF(T1) ;GET THE AFTER PARAMETER
STORE T2,.EQAFT(AP) ;STORE IT
LOAD T2,CSM.FM(T1) ;GET THE FORMS PARAMETER
STOLIM T2,.EQLIM(AP),FORM ;STORE IT
DMOVE T2,CSM.NT(T1) ;GET THE NOTE WORDS
STOLIM T2,.EQLIM(AP),NOT1 ;SAVE FIRST HALF
STOLIM T3,.EQLIM(AP),NOT2 ;AND SECOND HALF
LOAD T2,CSM.LM(T1) ;GET SPOOL LIMIT
STOLIM T2,.EQLIM(AP),OLIM ;AND STORE IT IN THE EQ
MOVE S1,T1 ;POINT S1 TO CSM
PJRST I$SMEQ## ;AND MOVE SYSTEM DEPENDENT
; STUFF AN RETURN
SUBTTL MAJMOD - Perform MODIFY on Major Queue Items
;CALLED BY Q$MODIFY WITH
; AP = THE ENTRY BEING MODIFIED (.EQxxx FORM)
; S1 = GROUP 0 MODIFY BLOCK
MAJMOD: PUSHJ P,.SAVE3 ;SAVE A FEW REGS FIRST
LOAD P1,MOD.GN(S1),MODGLN ;NUMBER OF GROUP 0 ELEMENTS
SOJLE P1,.RETT ;0 IS ACCEPTABLE, ADJUST FOR THE LOOP
CAILE P1,NMAJPM ;MORE THAN CURRENTLY IMPLEMENTED
MOVEI P1,NMAJPM ;YES, USE ONLY THE KNOWN VALUES
MOVNS P1 ;NEGATE IT
HRLZS P1 ;P1 = AOBJN POINTER
MOVEI P2,MOD.GE(S1) ;POINT TO FIRST GROUP ELEMENT
MAJM.1: MOVE P3,0(P2) ;GET AN ELEMENT
CAME P3,[-1] ;DID IT CHANGE
XCT MAJMTB(P1) ;YES, STORE NEW VALUE
INCR P2 ;TO NEXT ELEMENT
AOBJN P1,MAJM.1 ;GET THEM ALL
$RETT ;RETURN TO Q$MODIFY FOR NEXT GROUP
MAJMTB: STORE P3,.EQAFT(AP) ; 0 = /AFTER
PUSHJ P,MODPRI ; 1 = /PRIORITY
JFCL ; 2 = *SPARE*
STORE P3,.EQSPC(AP),EQ.PRO ; 3 = /PROTECTION
PUSHJ P,MODATR ; 4 = /UNIT: or /LOWER or /UPPER
$CALL MODNOD ; [32]5 = /DESTINATION-NODE:
STORE P3,.EQROB+.ROBUA(AP) ; 6 = CUSTOMER DEFINED ATTRIBUTES
NMAJPM==<.-MAJMTB> ;NUMBER CURRENTLY IMPLEMENTED
MODPRI: PUSHJ P,A$WHEEL## ;IS USER A WHEEL?
JUMPT MODP.1 ;YES, LET HIM DO WHAT HE WANTS
CAILE P3,MXUPRI ;NO, DID HE SPECIFY MORE THAN MAX
MOVX P3,MXUPRI ;YES, LOAD THE MAX
MODP.1: STORE P3,.EQSEQ(AP),EQ.PRI ;STORE IT
$RETT ;AND RETURN
MODATR: TLNN P3,-1 ;ANYTHING SET?
HRLI P3,%GENRC ;NO,,THEN GET GENERIC
TXZE P3,RO.PHY ;PHYSICAL?
HRLI P3,%PHYCL ;YES,,GET PROPER VALUE
TXZE P3,OBDLLC ;LOWER?
HRLI P3,%LOWER ;YES,,GET PROPER VALUE
TXZE P3,OBDLUC ;UPPER?
HRLI P3,%UPPER ;YES,,GET PROPER VALUE
STORE P3,.EQROB+.ROBAT(AP)
$RETT
MODNOD: STORE P3,.EQROB+.ROBND(AP) ;[32]STORE THE NEW NODE NAME
MOVX S1,EQ.NND ;[32]PICK UP DEFAULT NODE NAME BIT
ANDCAM S1,.EQSEQ(AP) ;[32]TURN OFF
$RET ;[32]RETURN TO THE CALLER
SUBTTL BLDKMS - Routine to build KILL/MODIFY/DEFER acknowledgement string
;BLDKMS IS CALLED WITH T1 POINTING TO AN ARGUMENT BLOCK CONTAINING:
; +0 = NUMBER OF "THINGS" DONE (KILLED, MODIFIED, DEFERRED)
; +1 = NUMBER OF FILES (MODIFY, DEFER)
; +2 = NUMBER OF CANCEL MESSAGES SENT (KILL ONLY)
; +3 = NUMBER OF PROTECTION FAILURES
; AND T2 = "THING" STRING ADDRESS (ASCIZ FORMAT)
;ASSEMBLES THE CORRECT MESSAGE (USES TYPPLR TO PLURALIZE THE PARTS) AND CALLS G$MSND
BLDKMS: MOVE S1,0(T1) ;GET "THINGS" DONE
SKIPN G$ACK## ;CALLER WANT THIS MESSAGE
$RETT ;OH,THATS DIFFERENT,... NEVER MIND
MOVEI S1,"[" ;START MESSAGE
PUSHJ P,G$CCHR## ;WITH A BRACKET
MOVE S1,0(T1) ;GET "THINGS" DONE
PUSHJ P,TYPPLJ ;TYPE CORRECT "JOB(S)"
SKIPL T3,1(T1) ;DON'T TYPE FILES
SKIPN 0(T1) ;YES, BUT WERE THERE ANY JOBS
JRST BLDK.1 ;DONT BOTHER
MOVEI S1,[ASCIZ/ (/] ;ALIGN THE OUTPUT
SKIPN T3 ;ANY FILES
MOVEI S1,[ASCIZ/ (But /] ;NO, POINT THAT OUT
$TEXT(G$CCHR##,<^T/0(S1)/^A>) ;INCLUDE PROPER STRING
MOVE S1,T3 ;GET NUMBER OF FILES
MOVEI S2,[ASCIZ/ file/] ;SAY FILE(S) INSTEAD OF JOB(S)
PUSHJ P,TYPPLR ;OUTPUT CORRECT ENGLISH
$TEXT(G$CCHR##,<)^A>) ;CLOSE UP THE MESSAGE
BLDK.1: $TEXT(G$CCHR,<^T/0(T2)/^A>) ;NOW FOR THE "THING" STRING
SKIPN T2,2(T1) ;ANY JOBS CANCELLED
JRST BLDK.2 ;NO, AVOID THE OUTPUT
MOVEI T3,[ASCIZ / were/]
CAIN T2,1 ;JUST ONE?
MOVEI T3,[ASCIZ / was/] ;YES
$TEXT(G$CCHR##,< (^D/T2/^T/0(T3)/ in progress)^A>)
BLDK.2: SKIPN T3,3(T1) ;ANY PROTECTION FAILURES
JRST BLDK.3 ;NO, AVOID THAT TOO
$TEXT(G$CCHR##,<, ^A>) ;PUNCTUATION
MOVE S1,T3 ;GET THE COUNT OF PROTECTION FAILURES
MOVEI S2,[ASCIZ/ protection failure/]
PUSHJ P,TYPPLR ;TYPE NUMBER AND PLURALIZE THE MESSAGE
BLDK.3: MOVEI S1,"]" ;GET BRACKET
PUSHJ P,G$CCHR## ;TERMINATE TEXT
MOVEI S1,.CHNUL ;GET A <NUL>
PUSHJ P,G$CCHR## ;MAKE ASCIZ
SKIPE G$REMN## ;[33]AN IN BEHALF OF REQUEST?
MOVX S1,MF.NEB ;[33]YES, INDICATE SO
PJRST G$MSND## ;SEND "ACK" AND RETURN
SUBTTL TYPPLR - Routine to pluralize a message
;TYPPLR IS CALLED WITH S1 CONTAINING A NUMBER "N" AND S2 CONTAINING
; THE ADDRESS OF AN ASCIZ STRING "FOO". IF N IS 0, TYPPLR
; WILL SEND TO THE CURRENT TEXT MESSAGE "NO FOOS". IF N IS 1,
; "1 FOO" WILL BE SENT, OTHERWISE, "N FOOS" WILL BE SENT.
;
;ENTER AT "TYPPLJ" IF THE STRING IS "JOB".
TYPPLJ: MOVEI S2,[ASCIZ \ Job\] ;LOAD DEFAULT STRING
TYPPLR: JUMPN S1,TYPP.1 ;ANY THINGS?
$TEXT(G$CCHR##,<No^T/0(S2)/^A>) ;NO, SO SAY "NO THING"
SKIPA ;AND DONT GIVE THE NUMBER
TYPP.1: $TEXT(G$CCHR##,<^D/S1/^T/0(S2)/^A>) ;SAY "N THING"
CAIE S1,1 ;UNLESS ITS EXACTLY 1 THING
$TEXT(G$CCHR##,<s^A>) ;ADD THE PLURALIZING "S"
$RETT ;RETURN TO CALLER
SUBTTL NOTIFY - ROUTINE TO NOTIFY THE USER HIS JOB IS DONE
;CALL: AP/ QE Address
; S1/ The Notify Type Code
;
;RET: TRUE ALWAYS
NOTIFY: $SAVE <P1,P2,P3> ;[40]SAVE THESE AC
LOAD P2,.QESEQ(AP),QE.RLT ;[27]PICK UP THE REMOTE ORIGINS BIT
JUMPN P2,NOTI8 ;[40]IF REMOTE, DO DIFFERENTLY
MOVE S2,G$OPR## ;GET ORION'S PID
CAXN S1,%NOTJB ;UNLESS WE WANT TO NOTIFY A JOB,
MOVE S2,.QENID(AP) ; THEN GET THE JOBS PID
MOVEM S2,G$SAB##+SAB.PD ;SAVE AS RECIEVERS PID
PUSHJ P,M%ACQP ;GO GET A PAGE FOR IPCF
PG2ADR S1 ;CONVERT TO A PAGE NUMBER
MOVEM S1,G$SAB##+SAB.MS ;SAVE THE MESSAGE ADDRESS
MOVE P1,S1 ;SAVE IT IN P1 ALSO
MOVX S1,PAGSIZ ;GET THE PAGE LENGTH
MOVEM S1,G$SAB##+SAB.LN ;SAVE IT IN THE SAB
MOVX S1,.OMNFY ;GET THE MESSAGE TYPE
STORE S1,.MSTYP(P1),MS.TYP ;SAVE IT
MOVEI S1,^D75 ;[40]GET THE MESSAGE LENGTH
STORE S1,.MSTYP(P1),MS.CNT ;SAVE IT
MOVEI S1,3 ;GET THE BLOCK COUNT
STORE S1,.OARGC(P1) ;SAVE IT
MOVEI P1,.OHDRS(P1) ;POINT TO THE FIRST BLOCK
MOVE S1,[JBI.SZ,,.JOBID] ;GET THE JOB ID BLOCK HEADER
MOVEM S1,ARG.HD(P1) ;SAVE IT
LOAD S1,.QEJBN(AP),QE.UJN ;GET THE USERS JOB NUMBER
STORE S1,JBI.JB(P1) ;SAVE IT
MOVE S1,.QENID(AP) ;GET THE NOTIFY ID
STORE S1,JBI.LI(P1) ;SAVE IT
MOVEI P1,JBI.SZ(P1) ;POINT TO THE NEXT BLOCK
MOVE S1,[^D65,,.CMTXT] ;[40]GET THE TEXT BLOCK HEADER
MOVEM S1,ARG.HD(P1) ;SAVE IT
MOVE S2,G$OBJA## ;[35]PICK UP THE OBJECT ADDRESS
MOVE S1,OBJTYP(S2) ;[35]PICK UP THE OBJECT TYPE
TXNN S1,.CLLPT!.DQLPT!.LALPT ;[35]IS THIS A REMOTE LPT?
JRST NOTI6 ;[40]NO, PLACE TEXT IN MESSAGE
TXNN S1,.LALPT ;[35]A LAT LPT?
JRST NOTI2 ;[35]NO, CHECK FOR DQS OR CLUSTER
LOAD S1,OBJNAM(S2),AR.TYP ;[35]YES, PICK UP THE LAT TYPE
CAIE S1,.KYPOR ;[35]IS IT A PORT?
JRST NOTI1 ;[35]NO, MUST BE A SERVICE
$TEXT (<-1,,ARG.DA+^D32(P1)>,<^M^J[From SYSTEM: Job ^W/.QEJOB(AP)/ request #^D/.QERID(AP)/ finished printing on LAT port ^T/OBJNAM+1(S2)/ on server ^N/OBJNOD(S2)/ at ^C/[-1]/]^T/BELLS/>)
JRST NOTI4 ;[40]POINT TO THE NEXT BLOCK
NOTI1: $TEXT (<-1,,ARG.DA+^D32(P1)>,<^M^J[From SYSTEM: Job ^W/.QEJOB(AP)/ request #^D/.QERID(AP)/ finished printing on LAT service ^T/OBJNAM+1(S2)/ on server ^N/OBJNOD(S2)/ at ^C/[-1]/]^T/BELLS/>)
JRST NOTI4 ;[40]GO POINT TO THE NEXT BLOCK
NOTI2: TXNN S1,.DQLPT ;[35]A DQS LPT?
JRST NOTI3 ;[35]NO, MUST BE A CLUSTER LPT
$TEXT (<-1,,ARG.DA+^D32(P1)>,<^M^J[From SYSTEM: Job ^W/.QEJOB(AP)/ request #^D/.QERID(AP)/ spooled to DQS printer ^T/OBJNAM+1(S2)/ on node ^N/OBJNOD(S2)/ at ^C/[-1]/]^T/BELLS/>)
JRST NOTI4 ;[40]GO POINT TO THE NEXT BLOCK
NOTI3: $TEXT (<-1,,ARG.DA+^D32(P1)>,<^M^J[From SYSTEM: Job ^W/.QEJOB(AP)/ request #^D/.QERID(AP)/ spooled to cluster node ^N/OBJNOD(S2)/ at ^C/[-1]/]^T/BELLS/>)
NOTI4: HRLI S1,<ARG.DA+^D32>(P1) ;[40]SOURCE ADDRESS
HRRI S1,ARG.DA(P1) ;[40]SOURCE,,DESTINATION ADDRESSES
MOVEI S2,<ARG.DA+^D15>(P1) ;[40]END DESTINATION ADDRESS
BLT S1,0(S2) ;[40]MOVE THE FIRST 80 CHARACTERS
SKIPN <ARG.DA+^D32+^D15+1>(P1);[40]STRING LENGTH OF OVER 80?
JRST NOTI7 ;[40]GO GET JOBNAME BLOCK HEADER
MOVEI S1,<ARG.DA+^D15+1>(P1) ;[40]STARTING ADDRESS OF TARGET
HRLI S1,(POINT 7,) ;[40]MAKE INTO A POINTER
MOVEI S2,<ARG.DA+^D32+^D15+1>(P1) ;[40]STARTING ADR OF SOURCE
HRLI S2,(POINT 7,) ;[40]MAKE INTO A POINTER
;[40]THE FOLLOWING IS NEEDED SINCE THE FIRST TWO CHARACTERS OF THE SOURCE
;[40]STRING ARE CR-LF, SO ALTHOUGH THE TARGET STRING HAS 80 CHARACTERS, ONLY
;[40]78 OF THEM ARE PRINTABLE.
ILDB P3,S2 ;[40]PICK UP THE 1ST REMAINING CHARAC
IDPB P3,S1 ;[40]PLACE IN THE TARGET
ILDB P3,S2 ;[40]PICK UP THE 2ND REMAINING CHARAC
IDPB P3,S1 ;[40]PLACE IN THE TARGET
SKIPN P3 ;[40]LAST CHARACTER A NULL?
JRST NOTI7 ;[40]YES, GET THE JOBNAME BLD HDR
CAIN P3,"]" ;[40]END OF PRINTABLE TEXT?
JRST NOTI5 ;[40]YES, DON'T ADD ANOTHER CR-LF
CAIN P3,.CHBEL ;[40]A BELL?
JRST NOTI5 ;[40]YES, DON'T ADD ANOTHER CR-LF
CAIN P3,.CHCRT ;[40]A CARRIAGE RETURN?
JRST NOTI5 ;[40]YES, DON'T ADD ANOTHER CR-LF
CAIN P3,.CHLFD ;[40]A LINE FEED?
JRST NOTI5 ;[40]YES, DON'T ADD ANOTHER CR-LF
MOVEI P3,.CHCRT ;[40]PICK UP A CARRIAGE RETURN
IDPB P3,S1 ;[40]PLACE IN THE TARGET STRING
MOVEI P3,.CHLFD ;[40]PICK UP A LINE FEED
IDPB P3,S1 ;[40]PLACE IN THE TARGET STRING
NOTI5: ILDB P3,S2 ;[40]PICK UP THE NEXT SOURCE CHARACTER
JUMPE P3,NOTI7 ;[40]PICK UP JOBNAME BLOCK HEADER
IDPB P3,S1 ;[40]PLACE IN THE TARGET STRING
JRST NOTI5 ;[40]GO PICK UP THE NEXT SOURCE CHAR
SKIPA ;[40]GO POINT TO THE NEXT BLOCK
NOTI6: $TEXT (<-1,,ARG.DA(P1)>,<^M^J[From SYSTEM: Job ^W/.QEJOB(AP)/ request #^D/.QERID(AP)/ finished ^T/@STATS(S1)/ at ^C/[-1]/]^T/BELLS/>)
NOTI7: MOVEI P1,^D65(P1) ;[40]POINT TO THE NEXT BLOCK
MOVE S1,[2,,.QCJBN] ;GET JOBNAME BLOCK HEADER
MOVEM S1,ARG.HD(P1) ;SAVE IT
MOVE S1,.QEJOB(AP) ;GET THE JOB NAME
MOVEM S1,ARG.DA(P1) ;SAVE IT
PUSHJ P,C$SEND## ;SEND THE MESSAGE
$RETT ;AND RETURN
NOTI8: LOAD S1,.QEROB+.ROBTY(AP),AR.TYP ;[40]GET THE OBJECT TYPE
$TEXT (<-1,,G$MSG>,<[From SYSTEM ^N/G$LNAM##/: Job ^W/.QEJOB(AP)/ request #^D/.QERID(AP)/ finished ^T/@STATS(S1)/ at ^C/[-1]/^T/BELLS/]^M^J^0>)
MOVEI S1,G$MSG ;[27]PICK UP THE MESSAGE ADDRESS
$CALL Q$RACK ;[27]NOTIFY THE REMOTE USER
$RETT ;[27]AND RETURN
BELLS:: BYTE(7) .CHBEL,.CHBEL,0,0,0 ;NOISE
SUBTTL Q$RACK - ACK A REMOTE USER
;Q$RACK is called to send an ACK or NOTIFY message to the user on a remote
;node that made a print request to Cluster LPTSPL that is printed on the
;local node.
;
;Call is: S1/Address of the ASCIZ text to be sent to the remote user
;Returns true: The message was successfully sent
;Returns false: The message was not sent
Q$RACK: $SAVE <P1> ;[27]SAVE THIS AC
MOVE P1,S1 ;[27]SAVE THE MESSAGE ADDRESS
HRRE S1,.QESTN(AP) ;[27]PICK UP THE CLUSTER NODE NUMBER
SKIPG S1 ;[27]IS THERE ONE?
$RETF ;[27]NO, RETURN NOW
MOVEM S1,INFBLK+.INCID ;[27]SAVE IN THE INFO% BLOCK
MOVE S1,[.INGJI,,.INMAX] ;[27]PICK UP THE FUNCTION WORD
MOVEM S1,INFBLK+.INFUN ;[27]PLACE IN THE INFO% BLOCK
MOVE S1,.QEJBN(AP) ;[27]PICK UP THE REMOTE JOB NUMBER
MOVEM S1,INFBLK+.INAC1 ;[27]PLACE IN THE INFO% BLOCK
MOVE S1,[-3,,GETBLK] ;[27]PICK UP GETJI% ARGUMENT BLOCK
MOVEM S1,INFBLK+.INAC2 ;[27]PLACE IN THE INFOR% BLOCK
SETZM INFBLK+.INAC3 ;[27]RETURN INFO STARTING FROM FIRST WORD
MOVEI S1,INFBLK ;[27]PICK UP THE INFO% BLOCK ADDRESS
INFO% ;[27]DO THE REMOTE GETJI%
ERJMP .RETF ;[27]QUIT ON AN ERROR
TXNE S1,IN%RER ;[27]DID A REMOTE ERROR OCCUR?
$RETF ;[27]YES, QUIT NOW
SKIPG GETBLK+.JITNO ;[27]REMOTE JOB DETACHED?
$RETF ;[27]YES, QUIT NOW
MOVE S1,.QEOID(AP) ;[27]PICK UP USER NUMBER
CAME S1,GETBLK+.JIUNO ;[27]STILL THE SAME?
$RETF ;[27]NO, QUIT NOW
HRLZ S1,.QESTN(AP) ;[27]PICK UP THE CLUSTER NODE NUMBER
HRR S1,GETBLK+.JITNO ;[27]PICK UP THE TERMINAL NUMBER
TXO S1,.TTDES!TT%REM ;[27]INDICATE REMOTE
HRROI S2,0(P1) ;[27]POINT TO THE MESSAGE
TTMSG% ;[27]SEND THE ACK
ERJMP .RETF ;[27]INDICATE AN ERROR
$RETT ;[27]INDICATE SUCCESS
END