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
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
|
// **********************************************************************
//
// Copyright (c) 2003-2014 ZeroC, Inc. All rights reserved.
//
// This copy of Ice is licensed to you under the terms described in the
// ICE_LICENSE file included in this distribution.
//
// **********************************************************************
package IceInternal;
abstract public class EndpointI implements Ice.Endpoint, java.lang.Comparable<EndpointI>
{
public EndpointI(String connectionId)
{
_connectionId = connectionId;
}
public EndpointI()
{
}
public String
toString()
{
return _toString();
}
//
// Marshal the endpoint.
//
public abstract void streamWrite(BasicStream s);
//
// Return the endpoint type.
//
public abstract short type();
//
// Return the protocol name.
//
public abstract String protocol();
//
// Return the timeout for the endpoint in milliseconds. 0 means
// non-blocking, -1 means no timeout.
//
public abstract int timeout();
//
// Return a new endpoint with a different timeout value, provided
// that timeouts are supported by the endpoint. Otherwise the same
// endpoint is returned.
//
public abstract EndpointI timeout(int t);
//
// Return a new endpoint with a different connection id.
//
public abstract EndpointI connectionId(String connectionId);
//
// Return true if the endpoints support bzip2 compress, or false
// otherwise.
//
public abstract boolean compress();
//
// Return a new endpoint with a different compression value,
// provided that compression is supported by the
// endpoint. Otherwise the same endpoint is returned.
//
public abstract EndpointI compress(boolean co);
//
// Return true if the endpoint is datagram-based.
//
public abstract boolean datagram();
//
// Return true if the endpoint is secure.
//
public abstract boolean secure();
//
// Return the connection ID
//
public String connectionId()
{
return _connectionId;
}
//
// Return a server side transceiver for this endpoint, or null if a
// transceiver can only be created by an acceptor. In case a
// transceiver is created, this operation also returns a new
// "effective" endpoint, which might differ from this endpoint,
// for example, if a dynamic port number is assigned.
//
public abstract Transceiver transceiver(EndpointIHolder endpoint);
//
// Return connectors for this endpoint, or empty list if no connector
// is available.
//
public abstract java.util.List<Connector> connectors(Ice.EndpointSelectionType selType);
public abstract void connectors_async(Ice.EndpointSelectionType selType, EndpointI_connectors callback);
//
// Return an acceptor for this endpoint, or null if no acceptors
// is available. In case an acceptor is created, this operation
// also returns a new "effective" endpoint, which might differ
// from this endpoint, for example, if a dynamic port number is
// assigned.
//
public abstract Acceptor acceptor(EndpointIHolder endpoint, String adapterName);
//
// Expand endpoint out in to separate endpoints for each local
// host if listening on INADDR_ANY.
//
public abstract java.util.List<EndpointI> expand();
//
// Check whether the endpoint is equivalent to another one.
//
public abstract boolean equivalent(EndpointI endpoint);
public java.util.List<Connector>
connectors(java.util.List<java.net.InetSocketAddress> addresses, NetworkProxy proxy)
{
//
// This method must be extended by endpoints which use the EndpointHostResolver to create
// connectors from IP addresses.
//
assert(false);
return null;
}
//
// Compare endpoints for sorting purposes.
//
public boolean equals(java.lang.Object obj)
{
if(!(obj instanceof EndpointI))
{
return false;
}
return compareTo((EndpointI)obj) == 0;
}
public int compareTo(EndpointI p) // From java.lang.Comparable.
{
if(!_connectionId.equals(p._connectionId))
{
return _connectionId.compareTo(p._connectionId);
}
return 0;
}
protected String _connectionId = "";
}
|
