blob: fcc503e26850fa46cc9ebcca3e4fd4374638b1c9 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
|
// -*- C++ -*-
// $Id$
//
#ifndef LOG_WALKER_GIOP_BUFFER_H
#define LOG_WALKER_GIOP_BUFFER_H
#include "ace/SString.h"
#include "ace/CDR_Stream.h"
class Invocation;
class Thread;
// Invocation holds the buffer contents for a request/response pair.
// This could be originating in this process, or in the peer process.
//
// The trigger for finding a new outgoing invocation is "Muxed_TMS[%d]"
// following that the process/thread will perform a dump_msg.
//
// The trigger for finding a new incoming invocation is
// "Transport[%d]::process_parsed_messages, entering (missing data == 0)"
// which could indicate a new request or reply, depending on the context
// in which the peer connection is made.
//
// It is possible that two or more threads may call dump_msg
// concurrently and thus have the preamble and body printed out of
// order. The HEXDUMP always reports a buffer size including the 12
// byte GIOP header. Also, the first line of the text contains header
// data which can be compared to the expected request ID.
class GIOP_Buffer
{
public:
static const char *size_leadin;
static size_t leadin_len;
static const size_t giop_header_len;
static void init_leadin (int version);
GIOP_Buffer (const char *text, size_t offset, Thread *thread, Invocation *owner = 0);
GIOP_Buffer (void);
~GIOP_Buffer (void);
void owner (Invocation *);
Invocation *owner (void);
void init_buf (const char *text, size_t offset);
int add_octets(const char *text, size_t offset);
char type (void) const;
char expected_type (void) const;
bool sending (void) const;
char minor_version (void) const;
char reply_status (void) const;
size_t num_contexts (void) const;
bool is_oneway (void);
bool is_full (void) const;
size_t log_posn (void) const;
Thread *thread (void);
time_t time (void) const;
const ACE_CString &preamble(void) const;
size_t expected_req_id(void) const;
size_t actual_req_id(void);
size_t expected_size (void) const;
size_t buf_size (void) const;
size_t cur_size(void) const;
size_t msg_size (void);
const char * target_oid (size_t &len);
const char * operation (void);
ACE_InputCDR &payload (void);
bool has_octets (void) const;
bool validate (void);
bool matches (GIOP_Buffer *other) const;
void reset (void);
void transfer_from (GIOP_Buffer *other);
void swap (GIOP_Buffer *other);
private:
bool parse_svc_contexts (void);
bool parse_header (void);
ACE_InputCDR *cdr_;
ACE_CString preamble_;
size_t log_offset_;
Thread *thr_;
time_t time_;
size_t expected_req_id_;
size_t expected_size_;
char expected_type_;
size_t buffer_size_;
char * wr_pos_;
char * octets_;
Invocation *owner_;
bool buffer_lost_;
bool sending_;
char * oid_;
size_t oid_len_;
char * opname_;
size_t req_id_;
char resp_exp_;
size_t reply_status_;
char ver_minor_;
size_t msg_size_;
size_t num_contexts_;
bool header_parsed_;
char * payload_start_;
};
#endif // LOG_WALKER_GIOP_BUFFER_H
|
