| /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.
|
| /frameworks/av/media/libaah_rtp/ |
| aah_tx_sender.h | 61 struct Endpoint {
62 Endpoint();
63 Endpoint(uint32_t a, uint16_t p);
64 bool operator<(const Endpoint& other) const;
70 uint16_t registerEndpoint(const Endpoint& endpoint);
71 void unregisterEndpoint(const Endpoint& endpoint);
96 // state maintained on a per-endpoint basis
110 const Endpoint& endpoint)
[all...] |
| aah_tx_sender.cpp | 130 // Return the next epoch number usable for a newly instantiated endpoint.
144 // Notify the sender that a player has started sending to this endpoint.
146 uint16_t AAH_TXSender::registerEndpoint(const Endpoint& endpoint) {
149 EndpointState* eps = mEndpointMap.valueFor(endpoint);
154 mEndpointMap.add(endpoint, eps);
157 // if this is the first registered endpoint, then send a message to start
173 // Notify the sender that a player has ceased sending to this endpoint.
174 // An endpoint's state can not be deleted until all of the endpoint'
[all...] |
| aah_tx_player.h | 67 const struct sockaddr_in* endpoint);
165 AAH_TXSender::Endpoint mEndpoint;
|
| /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/bluetooth/bluez/test/ |
| simple-endpoint | 42 class Endpoint(dbus.service.Object):
91 path = "/test/endpoint"
92 endpoint = Endpoint(bus, path) variable
110 endpoint.default_configuration(MP3_CONFIGURATION)
115 endpoint.default_configuration(MP3_CONFIGURATION)
120 endpoint.default_configuration(dbus.Array([]))
|
