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
|
/* -*- C++ -*- */
// $Id$
// Defines the ClassiX IPC address family address format.
#define ACE_BUILD_DLL
#include "ace/CLASSIX/CLASSIX_Port.h"
#if !defined (__ACE_INLINE__)
#include "ace/CLASSIX/CLASSIX_Port.i"
#endif /* __ACE_INLINE__ */
ACE_ALLOC_HOOK_DEFINE(ACE_CLASSIX_Port)
ACE_CLASSIX_Port::ACE_CLASSIX_Port(void* thePort, int theLen)
: ACE_CLASSIX_Addr (sizeof (ACE_CLASSIX_Port_Core::Addr))
{
if (thePort && theLen == this->get_size())
{
ACE_CLASSIX_Port_Core::Addr *port =
(ACE_CLASSIX_Port_Core::Addr*) thePort;
this->addr_.handle = port->handle;
this->addr_.id = port->id;
}
else
{
this->clear();
}
}
ACE_CLASSIX_Port::ACE_CLASSIX_Port(ACE_Addr const& theAddr)
: ACE_CLASSIX_Addr (sizeof (ACE_CLASSIX_Port_Core::Addr))
{
if (theAddr.get_size() == this->get_size() &&
theAddr.get_type() == this->get_type())
this->set_(theAddr);
else
this->clear();
}
void
ACE_CLASSIX_Port::clear(void)
{
this->addr_.handle = ACE_CLASSIX_ADDR_UNKNOWN;
this->addr_.id.uiHead = this->addr_.id.uiTail = 0;
}
int
ACE_CLASSIX_Port::set_(const ACE_Addr& theAddr)
{
ACE_CLASSIX_Port_Core::Addr *src =
((ACE_CLASSIX_Port_Core::Addr*) theAddr.get_addr());
this->addr_.id = src->id;
this->addr_.handle = src->handle;
return 0;
}
int
ACE_CLASSIX_Port::set(const KnUniqueId& thePort)
{
int no = ::portLi((KnUniqueId*) &thePort);
// update the port no only if the no is valid
if (no < 0)
// Assume this is a remote port
no = ACE_INVALID_HANDLE;
this->addr_.handle = no;
this->addr_.id = thePort;
return 0;
}
int
ACE_CLASSIX_Port::set_handle(ACE_HANDLE thePort)
{
if (thePort == ACE_INVALID_HANDLE &&
::portUi(&this->addr_.id, thePort) < 0)
return -1;
this->addr_.handle = thePort;
return 0;
}
void
ACE_CLASSIX_Port::set_addr(void* theSrc, int theLen)
{
// Remove self owned first and Make sure no memory overflow
if (theSrc && theLen > this->get_size())
return;
ACE_OS::memcpy ((void *) &this->addr_,
(void *) theSrc, theLen);
}
ACE_CLASSIX_Port const&
ACE_CLASSIX_Port::operator =(ACE_Addr const& theAddr)
{
if (theAddr.get_size() == this->get_size() &&
theAddr.get_type() == this->get_type())
{
this->set_(theAddr);
}
return *this;
}
int
ACE_CLASSIX_Port::addr_to_string (ASYS_TCHAR s[], size_t) const
{
ACE_OS::sprintf (s, ASYS_TEXT ("%d:%d"),
ASYS_WIDE_STRING (::agetId()),
this->get_port_number ());
}
void
ACE_CLASSIX_Port::dump (void) const
{
ACE_DEBUG ((LM_DEBUG, "ACE_CLASSIX_Port...\n"));
ACE_Addr::dump();
char s[100];
ACE_OS::sprintf (s, "handle = %d;\tid head = %x, id tail = %x\n",
this->get_handle(),
this->get_id().uiHead, this->get_id().uiTail);
ACE_DEBUG ((LM_DEBUG, "%s", s));
ACE_DEBUG ((LM_DEBUG, ACE_END_DUMP));
}
|
