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
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
|
// -*- C++ -*-
//
#ifndef LOG_WALKER_HOST_PROCESS_H
#define LOG_WALKER_HOST_PROCESS_H
#include "ace/SString.h"
#include "ace/Synch.h"
#include "ace/Containers.h"
#include "ace/Hash_Map_Manager.h"
#include "ace/RB_Tree.h"
#include "ace/Functor.h"
#include "Invocation.h"
#include "PeerProcess.h"
class Session;
class Thread;
/*
* Peer node is an element of the connection list which associates peer
* processes to the host process by handle. The peer node does not own
* the reference to the peer process, and the specific peer process may
* change over time.
*/
struct PeerNode
{
PeerNode (long h, PeerProcess *p);
long handle_;
PeerProcess *peer_;
};
typedef ACE_DLList<Thread> ThreadList;
typedef ACE_DLList<PeerNode> PeerArray;
typedef ACE_DLList<Endpoint> AddrList;
typedef ACE_RB_Tree<Endpoint, PeerProcess *, ACE_Less_Than<Endpoint>, ACE_Null_Mutex> PeerProcs;
/*
* HostProcess encapsulates the state related a specific process instance
* described by a log file. There may be more than one HostProcess in a
* log file.
*/
class HostProcess
{
public:
HostProcess (const ACE_CString &src, long pid);
~HostProcess (void);
// set/get the name of the process. This is only provided by
// an alias supplied to the logWalker command line or manifest file.
void proc_name (const ACE_CString &name);
const ACE_CString &proc_name (void) const;
// Returns a thread instance based on thread id. Will create an instance
// as needed.
Thread * find_thread (long tid, size_t offset);
// Returns a thread that has a pending peer with the supplied address
Thread * find_thread_for_peer (const ACE_CString& addr);
// Returns a thread that had previously worked with handle h. May return
// a null pointer.
Thread * find_thread_for_handle (long h);
// Returns the process id.
long pid (void) const;
const ACE_Time_Value &start_time (void) const;
void start_time (const ACE_Time_Value &);
// Return true if the supplied endpoint has been visited before. This
// may be either a listen endpoint or a client endpoint used to connect
// to another peer.
bool has_endpoint (const Endpoint& addr, bool listen);
// adds a new endpoint to the list of listen endpoints. Client endpoints
// are added as part of the process to add a new peer process
void add_client_endpoint (const Endpoint& addr);
// adds a new endpoint to the list of listen endpoints. Client endpoints
// are added as part of the process to add a new peer process
void add_listen_endpoint (const Endpoint& addr);
// add a peer to the connection list. If the peer is not in the
// by_addr_ table, it will be added there too.
void add_peer (long handle, PeerProcess *peer);
// locate a peer process by handle or address
PeerProcess *find_peer (const ACE_CString& addr);
PeerProcess *find_peer (long handle);
void remove_peer (long handle);
// remove a peer by handle, noting the line.
void close_peer (long handle, size_t offset);
// various output methods
void dump_ident (ostream &strm, const char *extra);
void dump_summary (ostream &strm);
void dump_thread_summary (ostream &strm);
void split_thread_invocations (Session *session, const ACE_Time_Value& start);
void dump_thread_invocations (ostream &strm, const ACE_Time_Value& start);
void dump_peer_summary (ostream &strm);
void dump_object_detail (ostream &strm);
void split_peer_invocations (Session *session);
void dump_invocation_detail (ostream &strm);
// reconcile_peers gives an opportunity to resolve peer process names
// by matching the peer processes to other host processes in the session.
void reconcile_peers (Session *session);
private:
void iterate_peers (int group,
int operation,
ostream *strm = 0,
Session * session = 0);
long pid_;
ACE_CString logfile_name_;
ACE_CString proc_name_;
AddrList client_endpoints_;
AddrList listen_endpoints_;
ThreadList threads_;
PeerProcs by_addr_;
PeerArray by_handle_;
ACE_Time_Value start_time_;
};
#endif // LOG_WALKER_HOST_PROCESS_H
|
