TAO/utils/logWalker/Invocation.h

   1 // -*- C++ -*-
   2
   3 //
   4
   5 #ifndef LOG_WALKER_INVOCATION_H
   6 #define LOG_WALKER_INVOCATION_H
   7
   8 #include "ace/SString.h"
   9 #include "ace/CDR_Stream.h"
  10 #include "ace/Unbounded_Queue.h"
  11
  12 class PeerProcess;
  13 class PeerObject;
  14 class Thread;
  15 class GIOP_Buffer;
  16
  17 typedef ACE_Unbounded_Queue<ACE_CString> NotifyIncidents;
  18
  19 // Invocation holds the buffer contents for a request/response pair.
  20 // This could be originating in this process, or in the peer process.
  21 //
  22 // The trigger for finding a new outgoing invocation is "Muxed_TMS[%d]"
  23 // following that the process/thread will perform a dump_msg.
  24 //
  25 // The trigger for finding a new incoming invocation is
  26 // "Transport[%d]::process_parsed_messages, entering (missing data == 0)"
  27 // which could indicate a new request or reply, depending on the context
  28 // in which the peer connection is made.
  29 //
  30 // It is possible that two or more threads may call dump_msg
  31 // concurrently and thus have the preamble and body printed out of
  32 // order. The HEXDUMP always reports a buffer size including the 12
  33 // byte GIOP header. Also, the first line of the text contains header
  34 // data which can be compared to the expected request ID.
  35
  36 class Invocation
  37 {
  38 public:
  39   enum Dump_Mode {
  40     Dump_Proc,
  41     Dump_Thread,
  42     Dump_Both
  43   };
  44
  45   // initialize a new instance, with the initial request text line and offeset
  46   Invocation (PeerProcess *peer, Thread *thr, size_t req_id = 0);
  47   bool init ( const char * text, size_t offset, Thread *thr);
  48   ~Invocation ();
  49
  50   // return true if the invocation was a oneway
  51   bool is_oneway() const;
  52
  53   // return true if the request is a oneway and has all its octets, or
  54   // if it also has all its reply octets. The side-effect of this call
  55   // is to obtain the target reference from the request buffer and associate
  56   // it with the peer process.
  57   bool message_complete ();
  58
  59   size_t request_id () const;
  60
  61   // returns true if this request was sent by the host process.
  62   bool sent_request () const;
  63
  64   // returns the size parsed from either the request or reply preamble
  65   // which can be used to match a HEXDUMP b
  66   size_t expected_size () const;
  67
  68   size_t request_bytes () const;
  69
  70   void set_target (const char *oid, size_t oid_len);
  71
  72   void set_octets (bool request, GIOP_Buffer *octets);
  73   GIOP_Buffer *octets (bool request);
  74   GIOP_Buffer *give_octets (bool request);
  75
  76   bool contains (size_t line);
  77   size_t req_line ();
  78   size_t repl_line ();
  79
  80   void add_notify_incident (const ACE_CString &text, size_t offset);
  81   Thread *waiter () const;
  82   long handle () const;
  83
  84   void new_line (ostream &strm, size_t indent, int offset,  bool add_nl, bool show_indent);
  85   void dump_detail (ostream &strm, size_t indent, Dump_Mode mode, bool show_handle);
  86   void dump_rel_time (ostream &strm, const ACE_Time_Value& tv, const ACE_Time_Value& start);
  87   void dump_start_line (ostream &strm, size_t indent, const ACE_Time_Value& start);
  88   void dump_finish_line (ostream &strm, size_t indent, const ACE_Time_Value& start);
  89   void dump_special_details (ostream &strm, size_t indent, const char *opname);
  90
  91 private:
  92   GIOP_Buffer *req_octets_;
  93   GIOP_Buffer *repl_octets_;
  94
  95   Thread *waiter_;
  96   NotifyIncidents notify_incidents_;
  97   PeerProcess *peer_;
  98   size_t req_id_;
  99   PeerObject *target_;
 100   long handle_;
 101   bool finish_reported_;
 102   size_t req_level_;
 103   size_t repl_level_;
 104 };
 105
 106 #endif // LOG_WALKER_INVOCATION_H