99 lines
3.7 KiB
Mathematica
99 lines
3.7 KiB
Mathematica
XMKPLQ ;ISC-SF/GMB-Post local msgs to correct queues ;07/28/2000 14:34
|
|
;;8.0;MailMan;;Jun 28, 2002
|
|
; Replaces ^XMADJF0, ZTSK^XMADGO (ISC-WASH/CAP)
|
|
GO ;
|
|
; Variables provided through TASKMAN: XMHANG
|
|
N XMACTIVE,XMUID,XMQLIST,XMTSTAMP,XMGROUP,XMCNT,XMQUEUE,XMREC
|
|
I $D(ZTQUEUED) S ZTREQ="@"
|
|
L +^XMBPOST("POST_Mover"):1 E Q
|
|
I $D(ZTQUEUED) S %=$$PSET^%ZTLOAD(ZTSK)
|
|
S XMACTIVE=$$TSTAMP^XMXUTIL1
|
|
F D Q:$P($G(^XMB(1,1,0)),U,16)
|
|
. D GETQ(.XMQLIST) ; Get new parameters for grouping
|
|
. S XMTSTAMP=""
|
|
. F S XMTSTAMP=$O(^XMBPOST("BOX",XMTSTAMP)) Q:XMTSTAMP="" D Q:$$TSTAMP^XMXUTIL1-XMACTIVE>30
|
|
. . S XMGROUP=""
|
|
. . F S XMGROUP=$O(^XMBPOST("BOX",XMTSTAMP,XMGROUP)) Q:XMGROUP="" D
|
|
. . . S XMUID=0
|
|
. . . F S XMUID=$O(^XMBPOST("BOX",XMTSTAMP,XMGROUP,XMUID)) Q:XMUID="" S XMREC=^(XMUID) D
|
|
. . . . S XMCNT=+XMREC
|
|
. . . . S XMQUEUE=$$WHICHQ(XMQLIST(XMGROUP),XMCNT)
|
|
. . . . I XMGROUP="M" D
|
|
. . . . . D MQUEUE(XMTSTAMP,XMUID,XMQUEUE,XMREC)
|
|
. . . . E D
|
|
. . . . . D RQUEUE(XMTSTAMP,XMUID,XMQUEUE,XMREC)
|
|
. . . . D STATS(XMGROUP,XMQUEUE,XMCNT)
|
|
. . . . K ^XMBPOST("BOX",XMTSTAMP,XMGROUP,XMUID)
|
|
. I $$TSTAMP^XMXUTIL1-XMACTIVE>30 D Q
|
|
. . D ZTSK
|
|
. . S XMACTIVE=$$TSTAMP^XMXUTIL1
|
|
. H XMHANG
|
|
L -^XMBPOST("POST_Mover")
|
|
I $D(ZTQUEUED) D PCLEAR^%ZTLOAD(ZTSK)
|
|
Q
|
|
GETQ(XMQLIST) ;
|
|
N X
|
|
S X=$G(^XMB(1,1,6))
|
|
S XMQLIST("M")=$P(X,U),XMQLIST("R")=$P(X,U,2)
|
|
Q
|
|
WHICHQ(XMQLIST,XMCNT) ;
|
|
N XMQUEUE,XMQLEN
|
|
I XMQLIST'["," Q 1
|
|
S XMQLEN=$L(XMQLIST,",")
|
|
F XMQUEUE=1:1:$L(XMQLIST,",") Q:XMCNT<$P(XMQLIST,",",XMQUEUE)
|
|
Q $S(XMCNT<$P(XMQLIST,",",XMQUEUE):XMQUEUE,1:XMQUEUE+1)
|
|
RQUEUE(XMTSTAMP,XMUID,XMQUEUE,XMREC) ; Put replies into queue
|
|
N XMZ,XMTSQ
|
|
;If the response is already in the queue, find out its Timestamp
|
|
;and file the new response right next to it.
|
|
S XMZ=$P(XMUID,U,1)
|
|
S XMTSQ=$O(^XMBPOST("R",XMQUEUE,"B",XMZ,0))
|
|
I XMTSQ S XMTSTAMP=XMTSQ
|
|
E S ^XMBPOST("R",XMQUEUE,"B",XMZ,XMTSTAMP)=""
|
|
S ^XMBPOST("R",XMQUEUE,XMTSTAMP,XMZ,$P(XMUID,U,2))=XMREC
|
|
Q
|
|
MQUEUE(XMTSTAMP,XMUID,XMQUEUE,XMREC) ; Put new & forwarded messages into queue
|
|
S ^XMBPOST("M",XMQUEUE,XMTSTAMP,XMUID)=XMREC
|
|
Q
|
|
STATS(XMGROUP,XMQUEUE,XMCNT) ;
|
|
N XMSTATS
|
|
L +^XMBPOST("QSTATS",XMGROUP,XMQUEUE)
|
|
S XMSTATS=$G(^XMBPOST(XMGROUP,XMQUEUE)),^(XMQUEUE)=($P(XMSTATS,U,1)+1)_U_($P(XMSTATS,U,2)+XMCNT)
|
|
L -^XMBPOST("QSTATS",XMGROUP,XMQUEUE)
|
|
Q
|
|
ZTSK ; START Delivery Background Processes
|
|
Q:$P(^XMB(1,1,0),U,16) ;Quit if Background Filer Stop Flag
|
|
N XMGROUP,XMQUEUE,ZTRTN,ZTSAVE,ZTDESC
|
|
F XMGROUP="M","R" D ; Check each queue for messages
|
|
. S XMQUEUE=""
|
|
. F S XMQUEUE=$O(^XMBPOST(XMGROUP,XMQUEUE)) Q:XMQUEUE'>0 D
|
|
. . Q:$D(^XMBPOST(XMGROUP,XMQUEUE))<10 ; Quit if nothing in queue
|
|
. . L +^XMBPOST(XMGROUP,XMQUEUE):1 E Q ; If node locked, there is already one running
|
|
. . S (ZTSAVE("XMGROUP"),ZTSAVE("XMQUEUE"),ZTSAVE("XMHANG"))=""
|
|
. . S ZTDESC=$$EZBLD^DIALOG($S(XMGROUP="M":36230,1:36231),XMQUEUE) ; MailMan: Message/Response Delivery Queue |1|
|
|
. . S ZTRTN="GO^XMTDL"
|
|
. . D TASKIT(ZTRTN,ZTDESC,.ZTSAVE) H 0 ; Start a job, Give TaskMan a chance to start it (hang)
|
|
. . L -^XMBPOST(XMGROUP,XMQUEUE)
|
|
Q
|
|
TASKIT(ZTRTN,ZTDESC,ZTSAVE) ;
|
|
N X,ZTSK,ZTQUEUED,ZTCPU,ZTDTH,ZTIO
|
|
I '$D(ZTCPU),$D(^XMB(1,1,0)) S X=$P(^(0),U,12) I X'="" S ZTCPU=$P(X,",",2)
|
|
S ZTIO="",ZTDTH=$H
|
|
D ^%ZTLOAD
|
|
Q
|
|
JOB ;Start background filer when TaskMan can't
|
|
JOBGO S IO="",IO(0)="" D DT^DICRW G GO^XMTDL
|
|
Q
|
|
CHKQ ; Input transform for file 4.3, fields 241 and 242
|
|
K:$L(X)>120!($L(X)<1) X Q:'$D(X)
|
|
K:X'?1.N.9(1","1.N) X Q:'$D(X)
|
|
N I
|
|
F I=1:1:$L(X,",")-1 I $P(X,",",I)'<$P(X,",",I+1) K X Q
|
|
Q
|
|
HELPQ ; Executable help for file 4.3, fields 241 and 242
|
|
;You determine the number of delivery queues (10 max.) ...
|
|
N XMTEXT
|
|
D BLD^DIALOG(36232,"","","XMTEXT","F")
|
|
D MSG^DIALOG("WM","",79,"","XMTEXT")
|
|
Q
|