Clovertech

David Paterson

Forum Replies Created

Viewing 1 replies (of 1 total)
  • Author
    Replies
  • April 1, 2011 at 4:36 am in reply to: Non-persistent TCP/IP #69463
    David Paterson
    Participant

      I am trying to get this to work for an outbound thread to a receiving system over tcp/ip. I am running cloverelaf 5.6 on unix.

      I can successfully get the thread to close after sending the first message but I don’t appear to be receiving the ACK and the thread will not go up when more messages are waiting to be sent. Using TPS inbound reply to do this.

      proc stop_thread_ACK { args } {

                 keylget args MODE mode

      echo “XXXXXXXXargs=$args”

      switch -exact — $mode {

             start {

                 # Perform special init functions

         # N.B.: there may or may not be a MSGID key in args

         echo “START MODE”

             }

             run {

          keylget args MSGID mh

        set closeMh [msgcreate]

        set dctl “”

        keylset dctl CLOSE 1            ;# causes PDL driver to close cxn

        keylset dctl TCP/IP.CLOSE 1 ;# causes non-PDL tcp/ip driver to close cxn

        msgmetaset $closeMh DRIVERCTL $dctl

        lappend dispList “PROTO $closeMh”

        lappend dispList “KILLREPLY $mh”

           }

        }

      }

      Below is the output from the log file. It is saying that Message sucessfully sent, not awaiting replies. If I disable the TPS inbound reply all messages go through, ACKs are received but threads remain up.

      [msg :Msg :DBUG/0:       conn_1:04/01/2011 15:01:57] [0.0.1032151] msgFree 0x30001628

      [pti :even:DBUG/0:       conn_1:04/01/2011 15:01:57] Unregistering TIMER () event 0x20ecd148 for tid 3

      [pti :even:DBUG/0:       conn_1:04/01/2011 15:01:57] evUnregister TIMER event 0x20ECD148 for tid 3

      [diag:leak:DBUG/0:       conn_1:04/01/2011 15:01:57] diag dqe free  0x20dcba18

      [diag:leak:DBUG/0:       conn_1:04/01/2011 15:01:57] diag ev free  0x20ecd148

      [tps :tps :INFO/2:       conn_1:04/01/2011 15:01:57] [midNULL] Unbind message1 from TPS Interp

      [msg :Mid :DBUG/0:       conn_1:04/01/2011 15:01:57] mid free [0.0.1032156] 0x20dcf9b8

      [msg :Mid :DBUG/0:       conn_1:04/01/2011 15:01:57] mid free [0.0.1032156] 0x20dcf768

      [pd  :thrd:INFO/0:       conn_1:04/01/2011 15:01:57] [0.0.1032158] Placing msg on OB post-SMS DATA queue

      [pd  :pdtd:INFO/3:       conn_1:04/01/2011 15:01:57] [0.0.1032158] OB post-SMS message details

      msg: 0x30002728

         msgType           : DATA

         msgClass          : PROTOCOL

         msgState          : Unknown: 0 (0)

         msgPriority       : 8193

         msgRecoveryDbState: 1

         msgFlags          : 0x2

         msgMid            : [0.0.1032158]

         msgSrcMid         : midNULL

         msgSrcMidGroup    : midNULL

         msgOrigSrcThread  : conn_1

         msgOrigDestThread :

         msgSrcThread      : conn_1

         msgDestThread     :

         msgXlateThread    :

         msgSkipXlate      : 0

         msgSepChars       :

         msgNumRetries     : 0

         msgGroupId        : 0

         msgDriverControl  : {CLOSE 1} {TCP/IP {{CLOSE 1}}}

         msgRecordFormat   :

         msgRoutes         :

         msgUserData       :

         msgStaticIsDirty  : 1

         msgVariableIsDirty: 1

         msgTimeStartIb    : 1301632317.210

         msgTimeStartOb    : 1301632317.210

         msgTimeCurQueStart: 0.000

         msgTimeTotalQue   : 0.000

         msgTimeRecovery   : 1301632317.210

         msgEoConfig       : 0x0

         msgData (BO)      : 0x300027d4

         message           : ”

      [pd  :thrd:INFO/1:       conn_1:04/01/2011 15:01:57] OB-Data queue has 2 msgs

      [pd  :thrd:INFO/1:       conn_1:04/01/2011 15:01:57] OB-Data queue has SOME work

      [pd  :thrd:INFO/0:       conn_1:04/01/2011 15:01:57] Processing OB-Data message queue

      [pd  :pdtd:INFO/0:       conn_1:04/01/2011 15:01:57] [0.0.1032158] Writing message to Protocol Driver tcpip

      [tcp :wrte:INFO/0:       conn_1:04/01/2011 15:01:57] [0.0.1032158] Write msg, length 0

      [tcp :wrte:DBUG/2:       conn_1:04/01/2011 15:01:57] pdtFlagsCur( pdt ) = 0x3

      [tcp :clse:DBUG/1:       conn_1:04/01/2011 15:01:57] pdTcpipHandleClose

      [pd  :pdtd:INFO/1:       conn_1:04/01/2011 15:01:57] Set driver status to PD_STATUS_CLOSING

      [tcp :clse:INFO/1:       conn_1:04/01/2011 15:01:57] Closing client connection

      [diag:leak:DBUG/0:       conn_1:04/01/2011 15:01:57] diag fd close  25

      [pti :even:DBUG/0:       conn_1:04/01/2011 15:01:57] Unregistering SOCKET (TCP Client Read) event 0x2167f458 for tid 3

      [pti :even:DBUG/0:       conn_1:04/01/2011 15:01:57] evUnregister SOCKET event 0x2167F458 for tid 3

      [diag:leak:DBUG/0:       conn_1:04/01/2011 15:01:57] diag ev free  0x2167f458

      [pd  :pdtd:INFO/1:       conn_1:04/01/2011 15:01:57] Set driver status to PD_STATUS_DOWN

      [tcp :clse:DBUG/1:       conn_1:04/01/2011 15:01:57] pdTcpipHandleClose done

      [pd  :pdtd:INFO/1:       conn_1:04/01/2011 15:01:57] [0.0.1032158] Writing message succeeded

      [pd  :pdtd:INFO/1:       conn_1:04/01/2011 15:01:57] [0.0.1032158] Latencies: Outbound 0.006, Que 0.000, Total 0.006 secs

      [pd  :pdtd:INFO/2:       conn_1:04/01/2011 15:01:57] [0.0.1032158] Writing msg to outbound save file conn_1_out

      [pd  :thrd:INFO/0:       conn_1:04/01/2011 15:01:57] [0.0.1032158] Invoking SENDOK

      [pd  :thrd:DBUG/0:       conn_1:04/01/2011 15:01:57] [0.0.1032158] Message successfully sent, not awaiting replies.  Removing msg from db.

      [dbi :rlog:DBUG/0:       conn_1:04/01/2011 15:01:57] [0.0.1032158] Msg not removed from rdb; state=1

      [msg :Msg :DBUG/0:       conn_1:04/01/2011 15:01:57] [0.0.1032158] msgFree 0x30002728

      [pti :sche:INFO/1:       conn_1:04/01/2011 15:01:57] Thread has 0 ready events left.

      [pd  :thrd:INFO/1:       conn_1:04/01/2011 15:01:57] OB-Data queue has 1 msgs

      [pd  :thrd:INFO/1:       conn_1:04/01/2011 15:01:57] OB-Data queue has NO work

      [pd  :thrd:INFO/1:       conn_1:04/01/2011 15:01:57] OB-Data queue has 1 msgs

      [pd  :thrd:INFO/1:       conn_1:04/01/2011 15:01:57] OB-Data queue has NO work

      [tcp :read:ERR /0:       conn_2:04/01/2011 15:01:57] Read 0 bytes — peer disconnected?

      [tcp :read:ERR /0:       conn_2:04/01/2011 15:01:57] Unable to read msg length

      [pd  :thrd:INFO/1:       conn_1:04/01/2011 15:01:57] OB-Data queue has 1 msgs

      [pd  :thrd:INFO/1:       conn_1:04/01/2011 15:01:57] OB-Data queue has NO work

      [pti :sche:INFO/2:       conn_1:04/01/2011 15:01:57] Performing apply callback for thread 3

      [msi :msi :DBUG/1:       conn_1:04/01/2011 15:01:57] msiExportStats: export for thread: conn_1

      [pd  :thrd:INFO/1:       conn_1:04/01/2011 15:01:57] OB-Data queue has 1 msgs

      [pd  :thrd:INFO/1:       conn_1:04/01/2011 15:01:57] OB-Data queue has NO work

      [pti :sche:INFO/2:       conn_1:04/01/2011 15:01:57] Performing apply callback for thread 3

      [msi :msi :DBUG/1:       conn_1:04/01/2011 15:01:57] msiExportStats: export for thread: conn_1

      [pd  :thrd:INFO/1:       conn_1:04/01/2011 15:01:58] OB-Data queue has 1 msgs

      [pd  :thrd:INFO/1:       conn_1:04/01/2011 15:01:58] OB-Data queue has NO work

      [pti :sche:INFO/2:       conn_1:04/01/2011 15:01:58] Performing apply callback for thread 3

      [msi :msi :DBUG/1:       conn_1:04/01/2011 15:01:58] msiExportStats: export for thread: conn_1

      [cmd :cmd :INFO/0:healthtrack_req_cmd:04/01/2011 15:01:58] Receiving a command

      [pd  :thrd:INFO/1:       conn_1:04/01/2011 15:01:58] OB-Data queue has 1 msgs

      [pd  :thrd:INFO/1:       conn_1:04/01/2011 15:01:58] OB-Data queue has NO work

      [pti :sche:INFO/2:       conn_1:04/01/2011 15:01:58] Performing apply callback for thread 3

      [msi :msi :DBUG/1:       conn_1:04/01/2011 15:01:58] msiExportStats: export for thread: conn_1

      [cmd :cmd :INFO/0:healthtrack_req_cmd:04/01/2011 15:01:58] Receiving a command

      [cmd :cmd :INFO/0:healthtrack_req_cmd:04/01/2011 15:01:58] Received command: ‘healthtrack_req_xlate xrel_post’

      [cmd :cmd :INFO/0:healthtrack_req_xlate:04/01/2011 15:01:58] Doing ‘xrel_post’ command with args ”

      [pd  :thrd:INFO/1:       conn_1:04/01/2011 15:01:58] OB-Data queue has 1 msgs

      [pd  :thrd:INFO/1:       conn_1:04/01/2011 15:01:58] OB-Data queue has NO work

      [pti :sche:INFO/2:       conn_1:04/01/2011 15:01:58] Performing apply callback for thread 3

      [msi :msi :DBUG/1:       conn_1:04/01/2011 15:01:58] msiExportStats: export for thread: conn_1

      [cmd :cmd :INFO/0:healthtrack_req_cmd:04/01/2011 15:01:58] Receiving a command

      [cmd :cmd :INFO/0:healthtrack_req_cmd:04/01/2011 15:01:58] Command client went away.  Closing connection.

      [pd  :thrd:INFO/1:       conn_1:04/01/2011 15:01:58] OB-Data queue has 1 msgs

      [pd  :thrd:INFO/1:       conn_1:04/01/2011 15:01:58] OB-Data queue has NO work

      [pti :sche:INFO/2:       conn_1:04/01/2011 15:01:58] Performing apply callback for thread 3

      [msi :msi :DBUG/1:       conn_1:04/01/2011 15:01:58] msiExportStats: export for thread: conn_1

      [pd  :thrd:INFO/1:       conn_1:04/01/2011 15:01:58] OB-Data queue has 1 msgs

      [pd  :thrd:INFO/1:       conn_1:04/01/2011 15:01:58] OB-Data queue has NO work

      [pti :sche:INFO/2:       conn_1:04/01/2011 15:01:58] Performing apply callback for thread 3

      [msi :msi :DBUG/1:       conn_1:04/01/2011 15:01:58] msiExportStats: export for thread: conn_1

      [cmd :cmd :INFO/0:healthtrack_req_cmd:04/01/2011 15:01:58] Receiving a command

      [pd  :thrd:INFO/1:       conn_1:04/01/2011 15:01:58] OB-Data queue has 1 msgs

      [pd  :thrd:INFO/1:       conn_1:04/01/2011 15:01:58] OB-Data queue has NO work

      [pti :sche:INFO/2:       conn_1:04/01/2011 15:01:58] Performing apply callback for thread 3

      [msi :msi :DBUG/1:       conn_1:04/01/2011 15:01:58] msiExportStats: export for thread: conn_1

      [cmd :cmd :INFO/0:healthtrack_req_cmd:04/01/2011 15:01:59] Receiving a command

      [cmd :cmd :INFO/0:healthtrack_req_cmd:04/01/2011 15:01:59] Received command: ”healthtrack_req_xlate’

      [cmd :cmd :INFO/0:healthtrack_req_cmd:04/01/2011 15:01:59] Cmd null in ”healthtrack_req_xlate’

      [pd  :thrd:INFO/1:       conn_1:04/01/2011 15:01:59] OB-Data queue has 1 msgs

      [pd  :thrd:INFO/1:       conn_1:04/01/2011 15:01:59] OB-Data queue has NO work

      [pti :sche:INFO/2:       conn_1:04/01/2011 15:01:59] Performing apply callback for thread 3

      [msi :msi :DBUG/1:       conn_1:04/01/2011 15:01:59] msiExportStats: export for thread: conn_1

      [cmd :cmd :INFO/0:healthtrack_req_cmd:04/01/2011 15:01:59] Receiving a command

      [cmd :cmd :INFO/0:healthtrack_req_cmd:04/01/2011 15:01:59] Command client went away.  Closing connection.

      [pd  :thrd:INFO/1:       conn_1:04/01/2011 15:01:59] OB-Data queue has 1 msgs

      [pd  :thrd:INFO/1:       conn_1:04/01/2011 15:01:59] OB-Data queue has NO work

      [pti :sche:INFO/2:       conn_1:04/01/2011 15:01:59] Performing apply callback for thread 3

      [msi :msi :DBUG/1:       conn_1:04/01/2011 15:01:59] msiExportStats: export for thread: conn_1

    • Author
      Replies
    Viewing 1 replies (of 1 total)