/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...] |