source: FOIAVistA/trunk/r/HEALTH_LEVEL_SEVEN-HL/HLCSQUE1.m@ 1427

Last change on this file since 1427 was 628, checked in by George Lilly, 15 years ago

initial load of FOIAVistA 6/30/08 version

File size: 1.8 KB
Line 
1HLCSQUE1 ;ALB/MFK HL7 UTILITY FUNCTIONS - 10/4/94 11AM ;05/08/2000 11:22
2 ;;1.6;HEALTH LEVEL SEVEN;**14,59,100**;Oct 13, 1995
3 ;
4 ;Utilities used by HLCSQUE
5 ;
6DELMSG(IEN,HLDIR,MSG) ;DELETE A SINGLE MESSAGE FROM A QUEUE
7 ;INPUT: IEN - Internal Entry Number for queue
8 ; HLDIR - Direction of queue
9 ; MSG - Message number to remove
10 ;OUTPUT: 0 - Success
11 ; -1 - Error
12 N DIK,DA
13 ; Check for required variables
14 S IEN=$G(IEN)
15 Q:(IEN="") "-1^Internal Entry Number missing"
16 I +IEN<1 S IEN=$O(^HLCS(870,"B",IEN,""))
17 Q:(IEN="") "-1^Invalid IEN"
18 S HLDIR=$G(HLDIR)
19 S HLDIR=$S(HLDIR="IN":1,HLDIR="OUT":2,HLDIR=2:2,HLDIR=1:1,1:"")
20 Q:(HLDIR="") "-1^Invalid direction"
21 S MSG=$G(MSG)
22 Q:(MSG="") "-1^No message number"
23 L +^HLCS(870,IEN,HLDIR,MSG):1
24 ;If lock fails, another process is doing the work.
25 I '$T Q 1
26 S DIK="^HLCS(870,"_IEN_","_HLDIR_",",DA(1)=IEN,DA=MSG
27 D ^DIK
28 L -^HLCS(870,IEN,HLDIR,MSG)
29 K IEN,HLDIR,MSG
30 Q 0
31DELETE(IEN,HLDIR,FRONT) ; Delete messages outside the 'queue size' window
32 N MSG,TMP,QSIZE,STOP,HLX
33 ; Make sure required variables exist
34 S IEN=$G(IEN) Q:(IEN="")
35 S HLDIR=$G(HLDIR) Q:(HLDIR="")
36 S FRONT=$G(FRONT) Q:(FRONT="")
37 S TMP=^HLCS(870,IEN,0)
38 S QSIZE=$P(TMP,"^",21)
39 I FRONT'>0 Q
40 I QSIZE'>0 S QSIZE=10
41 S MSG=0,STOP=0
42 ; For each message from the beginning of the queue to the front
43 ; of the queue-queue size, delete that message if it's done
44 F S MSG=$O(^HLCS(870,IEN,HLDIR,MSG)) Q:(MSG>(FRONT-QSIZE))!(STOP'=0)!(MSG'>0) D
45 .I $P($G(^HLCS(870,IEN,HLDIR,MSG,0)),"^",2)'="D" D QUIT:STOP ;->
46 ..I $D(^HLCS(870,IEN,HLDIR,MSG)) D QUIT:STOP ;->
47 ...S HLX=$O(^HLCS(870,IEN,HLDIR,MSG)) QUIT:HLX>0 ;->
48 ...S STOP=1
49 ..S HLX=+$G(HLX)
50 ..I '$D(^HLCS(870,IEN,HLDIR,+HLX,0)) S STOP=1 QUIT ;->
51 ..Q:$P($G(^HLCS(870,IEN,HLDIR,+HLX,0)),U,2)="D" ;-> All OK...
52 ..S STOP=1
53 .S STOP=$$DELMSG(IEN,HLDIR,MSG)
54 K IEN,HLDIR,FRONT
55 Q
Note: See TracBrowser for help on using the repository browser.