Home   Package List   Routine Alphabetical List   Global Alphabetical List   FileMan Files List   FileMan Sub-Files List   Package Component Lists   Package-Namespace Mapping  
Routine: INHVTMT4

INHVTMT4.m

Go to the documentation of this file. 
  1. INHVTMT4 ; KAC ; 06 Aug 1999 16:51; Multi-threaded TCP/IP socket utilities
  1.  ;;3.01;BHL IHS Interfaces with GIS;;JUL 01, 2001
  1.  ;COPYRIGHT 1991-2000 SAIC
  1.  Q
  1.  ;
  1. PENDSYNC(INPEND) ; Function - Sync INPEND variable with the reality of 
  1.  ; what is on pending reponse queue.  Provides ability to continue 
  1.  ; where left off in the case of a FORCEX.  Called at start of 
  1.  ; transceiver.
  1.  ;
  1.  ; Called by: INHVTMT
  1.  ;
  1.  ; Returns:
  1.  ;   1 - pending que contained entries on startup
  1.  ;   0 - pending que was empty on startup
  1.  ;
  1.  N X
  1.  S X=0
  1.  F INPEND=0:1 S X=$O(^INLHDEST(INDSTR,"PEND",INBPN,X)) Q:(X="")
  1.  Q $S(INPEND:1,1:0)
  1.  ;
  1. PUTPEND(INDEST,INUIF,INSEQNUM,INPEND) ; Function - Put UIF on "pending 
  1.  ; response" queue.  Used for multi-threaded transceivers. Assumes 
  1.  ; caller locked the node being moved from ^INLHDEST to "pending 
  1.  ; response" queue.
  1.  ;
  1.  ; Called by: NEXT^INHUVUT3
  1.  ;
  1.  ; Input:
  1.  ;  INDEST   - (req) Destination IEN (INDSTR)
  1.  ;  INUIF    - (req) Universal Interface IEN
  1.  ;
  1.  ; Output:  Flag - 1=success, 0=failure
  1.  ;  INSEQNUM - (pbr) Sequence # for this UIF, "" if not found
  1.  ;  INPEND   - (pbr) # of msgs in "pending response" que
  1.  ;
  1.  N INERRMSG
  1.  S INSEQNUM=$P(^INTHU(INUIF,0),U,17)
  1.  I INSEQNUM="" D  Q 0
  1.  . S INERRMSG="Putpend: Missing sequence number in INTHU for entry "_INUIF_": Cannot que msg"
  1.  . D ENT^INHE(INUIF,INDEST,INERRMSG,INBPN)
  1.  . D:$G(INDEBUG) LOG^INHVCRA1(INERRMSG,4)
  1.  . K ^INLHDEST(INDEST,INPRI,INHOR,INUIF) ; avoid re-processing
  1.  D:$G(INDEBUG) LOG^INHVCRA1("Putting UIF="_INUIF_" on pend que",9)
  1.  S ^INLHDEST(INDEST,"PEND",INBPN,INSEQNUM,INUIF)=""
  1.  K ^INLHDEST(INDEST,INPRI,INHOR,INUIF)
  1.  S INPEND=INPEND+1
  1.  Q 1
  1.  ;
  1. GETPEND(INDEST,INSEQNUM,INUIF,INPEND) ; Function - Get UIF from "pending 
  1.  ; response" queue and restore entry on destination queue.  Used 
  1.  ; for multi-threaded transceivers.  If no entry existed on que
  1.  ; entry is still restored to dest que and INPEND will not be updated.
  1.  ;
  1.  ; Called by: INHVTMT, EVAL^INHVTMT3, REROUTE^INHVTMT4
  1.  ;
  1.  ; Input:
  1.  ;  INDEST   - (req) Destination IEN (INDSTR)
  1.  ;  INSEQNUM - (req) Sequence # for this UIF
  1.  ;
  1.  ; Output:  Flag - 1=success, 0=failure
  1.  ;  INUIF    - (pbr) UIF for this sequence #, "" if not found
  1.  ;  INPEND   - (pbr) # of msgs in "pending response" que
  1.  ;
  1.  N INERR,INPRI,INHOR
  1.  Q:'$D(^INLHDEST(INDEST,"PEND",INBPN,INSEQNUM))  ; no que entry
  1.  S INUIF=$O(^INLHDEST(INDEST,"PEND",INBPN,INSEQNUM,""))
  1.  I INUIF="" D  Q 0
  1.  . S INERR="Getpend: Missing UIF IEN in pending queue entry with sequence #: "_INSEQNUM_": Cannot reroute msg"
  1.  . D ENT^INHE(INUIF,INDEST,INERR,INBPN)
  1.  . D:$G(INDEBUG) LOG^INHVCRA1(INERR,4)
  1.  . K ^INLHDEST(INDEST,"PEND",INBPN,INSEQNUM)
  1.  S INPRI=$P(^INTHU(INUIF,0),U,16) ; priority
  1.  S INHOR=$P(^INTHU(INUIF,0),U,19) ; time to process
  1.  I (INPRI="")!(INHOR="") D  Q 0
  1.  . S INERR="Getpend: Missing priority/time in UIF entry "_INUIF_": Cannot reroute msg"
  1.  . D ENT^INHE(INUIF,INDEST,INERR,INBPN)
  1.  . D:$G(INDEBUG) LOG^INHVCRA1(INERR,4)
  1.  . D PQKILL(INDEST,INSEQNUM,INUIF,.INPEND) ; avoid hanging entry
  1.  S ^INLHDEST(INDEST,INPRI,INHOR,INUIF)=""
  1.  ; update INPEND only if que entry exists
  1.  D:$G(INDEBUG) LOG^INHVCRA1("Restoring UIF="_INUIF_" to dest que",9)
  1.  D PQKILL(INDEST,INSEQNUM,INUIF,.INPEND)
  1.  Q 1
  1.  ;
  1. REROUTE(INDEST,INPEND) ; Move ALL entries on "pending response" queue to 
  1.  ; destination queue, effectively rerouting UIF entries to 
  1.  ; another transceiver.
  1.  ;
  1.  ; Called by: INHVTMT, SHUTDWN^INHVTMT5, ERR^INHVTMT5
  1.  ;
  1.  N INSEQNUM,INUIF,X
  1.  D:$G(INDEBUG) LOG^INHVCRA1("Rerouting entire pending que to dest que",9)
  1.  S INSEQNUM=""
  1.  F  S INSEQNUM=$O(^INLHDEST(INDEST,"PEND",INBPN,INSEQNUM))  Q:(INSEQNUM="")  D
  1.  . S X=$$GETPEND(INDEST,INSEQNUM,.INUIF,.INPEND)
  1.  Q
  1.  ;
  1. RESEND(INDEST,INUIF,INSEQNUM) ; Resend INUIF.  If no 'pending que' entry
  1.  ; for INUIF, create a queue entry and update INPEND.
  1.  ;
  1.  ; Called by: INHVTMT, EVAL^INHVTMT3
  1.  ;
  1.  N INATTMPT
  1.  S INATTMPT=$P($G(^INLHDEST(INDSTR,"PEND",INBPN,INSEQNUM,INUIF)),U,2)+1
  1.  ; Start transaction audit
  1.  D:$D(XUAUDIT) TTSTRT^XUSAUD(INUIF,"",INBPNM,"","RESEND")
  1.  D:$G(INDEBUG) LOG^INHVCRA1("Resending outgoing UIF="_INUIF_" on "_INBPNM_". Attempt "_INATTMPT_".",7)
  1.  S INRUNMT=$$INRHB^INHUVUT1(INBPN,"Resending "_INUIF_",Attempt "_INATTMPT) Q:'INRUNMT
  1.  F  S INERRMT=$$SEND^INHVTMT1(INUIF,INCHNL,.INIP) Q:'INERRMT!'$D(^INRHB("RUN",INBPN))
  1.  ; Post-send activities
  1.  D ULOG^INHU(INUIF,"S") ; log activity in UIF - sent
  1.  S:INATTMPT=1 INPEND=INPEND+1 ; pending que entry did not exist upon call
  1.  S ^INLHDEST(INDEST,"PEND",INBPN,INSEQNUM,INUIF)=$H_U_INATTMPT
  1.  D:$D(XUAUDIT) TTSTP^XUSAUD(0)  ;stop transaction audit
  1.  Q
  1.  ;
  1. PQKILL(INDEST,INSEQNUM,INUIF,INPEND) ; Kill entry on "pending response" queue
  1.  ; Used when multiple transceivers are sending msgs to the same 
  1.  ; destination.
  1.  ;
  1.  ; Called by: INHVTMT, EVAL^INHVTMT3
  1.  ;
  1.  Q:'$D(^INLHDEST(INDEST,"PEND",INBPN,INSEQNUM))  ; no que entry
  1.  ; Update INPEND only if que entry exists
  1.  S INPEND=INPEND-1
  1.  K ^INLHDEST(INDEST,"PEND",INBPN,INSEQNUM,INUIF)
  1.  Q
  1.  ;
  1.  ;