| /external/jmonkeyengine/engine/src/networking/com/jme3/network/kernel/ |
| Envelope.java | 44 private Endpoint source;
53 public Envelope( Endpoint source, byte[] data, boolean reliable )
60 public Endpoint getSource()
|
| EndpointEvent.java | 48 private Endpoint endpoint; field in class:EndpointEvent
51 public EndpointEvent( Kernel source, Endpoint p, Type type )
54 this.endpoint = p;
58 public static EndpointEvent createAdd( Kernel source, Endpoint p )
63 public static EndpointEvent createRemove( Kernel source, Endpoint p )
73 public Endpoint getEndpoint()
75 return endpoint;
85 return "EndpointEvent[" + type + ", " + endpoint + "]";
|
| Endpoint.java | 38 * An abstract endpoint in a Kernel that can be used for
44 public interface Endpoint
47 * Returns an ID that is unique for this endpoint within its
53 * Returns the transport specific remote address of this endpoint
54 * as a string. This may or may not be unique per endpoint depending
60 * Returns the kernel to which this endpoint belongs.
65 * Returns true if this endpoint is currently connected.
71 * by this endpoint.
76 * Closes this endpoint without flushing any of its
82 * Closes this endpoint, optionally flushing any queue
[all...] |
| Kernel.java | 50 * more easily process the envelopes and endpoint events.
68 * kernel that match the specified endpoint filter..
75 public void broadcast( Filter<? super Endpoint> filter, ByteBuffer data, boolean reliable,
90 * Removes and returnsn one endpoint event from the event queue or
91 * null if there are no endpoint events.
|
| /external/chromium_org/third_party/libjingle/source/talk/examples/android/src/org/appspot/apprtc/ |
| VideoStreamsView.java | 59 public static enum Endpoint { LOCAL, REMOTE };
62 private EnumMap<Endpoint, Rect> rects =
63 new EnumMap<Endpoint, Rect>(Endpoint.class);
72 private EnumMap<Endpoint, I420Frame> framesToRender =
73 new EnumMap<Endpoint, I420Frame>(Endpoint.class);
84 public void queueFrame(final Endpoint stream, I420Frame frame) {
113 localFrame = framesToRender.remove(Endpoint.LOCAL);
114 remoteFrame = framesToRender.remove(Endpoint.REMOTE)
[all...] |
| AppRTCDemoActivity.java | 225 vsv, VideoStreamsView.Endpoint.LOCAL)));
333 new VideoCallbacks(vsv, VideoStreamsView.Endpoint.REMOTE)));
496 private final VideoStreamsView.Endpoint stream;
499 VideoStreamsView view, VideoStreamsView.Endpoint stream) {
|
| /external/jmonkeyengine/engine/src/networking/com/jme3/network/base/ |
| KernelAdapter.java | 39 import com.jme3.network.kernel.Endpoint;
53 * to the supplied message dispatcher and new endpoint
77 private Map<Endpoint, MessageProtocol> messageBuffers = new ConcurrentHashMap<Endpoint,MessageProtocol>();
104 public void broadcast( Filter<? super Endpoint> filter, ByteBuffer data, boolean reliable,
118 protected void reportError( Endpoint p, Object context, Exception e )
122 log.log( Level.SEVERE, "Unhandled error, endpoint:" + p + ", context:" + context, e );
124 // In lieu of other options, at least close the endpoint
128 protected HostedConnection getConnection( Endpoint p )
133 protected void connectionClosed( Endpoint p
[all...] |
| DefaultServer.java | 36 import com.jme3.network.kernel.Endpoint;
78 private Map<Endpoint,HostedConnection> endpointConnections
79 = new ConcurrentHashMap<Endpoint,HostedConnection>();
307 protected void registerClient( KernelAdapter ka, Endpoint p, ClientRegistrationMessage m )
322 log.log( Level.FINE, "Registering client for endpoint, pass 1:{0}.", p );
324 log.log( Level.FINE, "Refining client registration for endpoint:{0}.", p );
360 for( Endpoint cp : c.channels ) {
393 protected HostedConnection getConnection( Endpoint endpoint )
395 return endpointConnections.get(endpoint);
[all...] |
| /external/jmonkeyengine/engine/src/networking/com/jme3/network/kernel/udp/ |
| UdpEndpoint.java | 35 import com.jme3.network.kernel.Endpoint;
46 * Endpoint implementation that encapsulates the
53 public class UdpEndpoint implements Endpoint
94 throw new KernelException( "Error closing endpoint for socket:" + socket, e );
118 throw new KernelException( "Endpoint is not connected:" + this );
|
| UdpKernel.java | 123 public void broadcast( Filter<? super Endpoint> filter, ByteBuffer data, boolean reliable,
147 protected Endpoint getEndpoint( SocketAddress address, boolean create )
169 log.log( Level.INFO, "Closing endpoint:{0}.", p );
187 // So the tricky part here is figuring out the endpoint and
192 Endpoint p = getEndpoint( packet.getSocketAddress(), true );
202 protected void enqueueWrite( Endpoint endpoint, DatagramPacket packet )
204 writer.execute( new MessageWriter(endpoint, packet) );
209 private Endpoint endpoint; field in class:UdpKernel.MessageWriter
[all...] |
| /external/jmonkeyengine/engine/src/networking/com/jme3/network/kernel/tcp/ |
| NioEndpoint.java | 35 import com.jme3.network.kernel.Endpoint;
45 * Endpoint implementation that encapsulates the
52 public class NioEndpoint implements Endpoint
97 throw new KernelException( "Error closing endpoint for socket:" + socket, e );
123 // We create a ByteBuffer per endpoint since we
124 // use it to track the data sent to each endpoint
172 throw new KernelException( "Endpoint has been closed:" + socket );
|
| SelectorKernel.java | 115 public void broadcast( Filter<? super Endpoint> filter, ByteBuffer data, boolean reliable,
134 // Give it the data... but let each endpoint track their
147 // Note: we purposely do NOT put the key in the endpoint.
154 // Enqueue an endpoint event for the listeners
165 // Enqueue an endpoint event for the listeners
184 //log.log( Level.INFO, "Closing endpoint:{0}.", p );
231 * the endpoint -> key mapping internally.
318 // And now create a new endpoint
328 //log.log( Level.INFO, "Endpoint already closed:{0}.", p );
331 log.log( Level.FINE, "Endpoint keys size:{0}", endpointKeys.size() )
[all...] |
| /external/chromium_org/third_party/libjingle/source/talk/p2p/base/ |
| p2ptransportchannel_unittest.cc | 153 NAT_SYMMETRIC, // NAT, endpoint-dependent bindings
200 struct Endpoint {
201 Endpoint() : signaling_delay_(0), role_(cricket::ICEROLE_UNKNOWN),
277 // In BUNDLE each endpoint must share common ICE credentials.
297 int endpoint,
304 "test content name", component, NULL, GetAllocator(endpoint));
313 channel->SetIceProtocolType(GetEndpoint(endpoint)->protocol_type());
320 channel->SetIceRole(GetEndpoint(endpoint)->ice_role());
321 channel->SetIceTiebreaker(GetEndpoint(endpoint)->GetIceTiebreaker());
358 Endpoint* GetEndpoint(int endpoint)
[all...] |
