Examples of ch.ethz.inf.vs.californium.network.CoAPEndpoint

Package ch.ethz.inf.vs.californium.network

Examples of ch.ethz.inf.vs.californium.network.CoAPEndpoint

ch.ethz.inf.vs.californium.network.CoAPEndpoint
Endpoint encapsulates the stack that executes the CoAP protocol. Endpoint forwards incoming messages to a {@link MessageDeliverer}. The deliverer will deliver requests to its destination resource. The resource sends the response back over the same endpoint. The endpoint sends outgoing messages over a connector. The connector encapsulates the transport protocol.
The CoAP Draft 18 describes an endpoint as: "A CoAP Endpoint is is identified by transport layer multiplexing information that can include a UDP port number and a security association." (draft-ietf-core-coap-14: 1.2)
The following diagram describes the structure of an endpoint. The endpoint implements CoAP in layers. Incoming and outgoing messages always travel from layer to layer. An {@link Exchange} represents the known state about theexchange between a request and one or more corresponding responses. The matcher remembers outgoing messages and matches incoming responses, acks and rsts to them. MessageInterceptors receive every incoming and outgoing message. By default, only one interceptor is used to log messages.
```
 +-----------------------+ |    {@link MessageDeliverer}    +--> (Resource Tree)+-------------A---------+ | * A             +-Endpoint--+-A---------+ |           v A         |   |           v A         |   | +---------v-+-------+ |   | | Stack Top         | |   | +-------------------+ |   | |  {@link TokenLayer}        | || +-------------------+ |   | |  {@link ObserveLayer}      | || +-------------------+ |   | |  {@link BlockwiseLayer}    | || +-------------------+ |   | |  {@link ReliabilityLayer}  | || +-------------------+ |   | | Stack Bottom      | |   | +--------+-+--------+ |   |          v A          |   |          v A          |   |         {@link Matcher}        ||          v A          |   |    {@link MessageInterceptor}  |  |          v A          |   |          v A          |   | +--------v-+--------+ |   +-|      {@link Connector}     |-++--------+-A--------+     v A              v A              (Network) 
```
The endpoint and its layers use an {@link ScheduledExecutorService} toexecute tasks, e.g., when a request arrives.

    request.setURI(uri);
    request.setPayload(payload);
    request.getOptions().setContentFormat(MediaTypeRegistry.TEXT_PLAIN);
    
    if (request.getScheme().equals(CoAP.COAP_SECURE_URI_SCHEME)) {
      dtlsEndpoint = new CoAPEndpoint(new DTLSConnector(new InetSocketAddress(0)), NetworkConfig.getStandard());
      dtlsEndpoint.setMessageDeliverer(new ClientMessageDeliverer());
      dtlsEndpoint.start();
      EndpointManager.getEndpointManager().setDefaultSecureEndpoint(dtlsEndpoint);
    }

View Full Code Here

   * Binds the server to a ephemeral port on the specified address.
   *
   * @param address the address
   */
  private void bind(InetSocketAddress address) {
    Endpoint endpoint = new CoAPEndpoint(address, this.config);
    addEndpoint(endpoint);
  }

View Full Code Here

  }
  
  @Override
  public final Endpoint getEndpoint(NetworkConfig config, InetSocketAddress address) {
    
    CoAPEndpoint endpoint = new CoAPEndpoint(address, config);
    return endpoint;
  }

View Full Code Here

  @Override
  public final Endpoint getSecureEndpoint(NetworkConfig config, InetSocketAddress address) {


    Endpoint endpoint = null;
    if (secureConnectorFactory != null) {
      endpoint = new CoAPEndpoint(
          secureConnectorFactory.newConnector(address),
          config);
    } else {
      log.fine("A secure ConnectorFactory is required to create secure Endpoints.");
    }

View Full Code Here

      
    server.add(new BenchmarkResource("benchmark"));
    server.add(new FibonacciResource("fibonacci"));
    server.add(new ShutDownResource("shutdown"));
    
    server.addEndpoint(new CoAPEndpoint(sockAddr));
    server.start();


    System.out.println("Benchmark server listening on " + sockAddr);
  }

View Full Code Here

        // ETSI Plugtest environment
//    server.addEndpoint(new CoAPEndpoint(new DTLSConnector(new InetSocketAddress("::1", DTLS_PORT)), NetworkConfig.getStandard()));
//    server.addEndpoint(new CoAPEndpoint(new DTLSConnector(new InetSocketAddress("127.0.0.1", DTLS_PORT)), NetworkConfig.getStandard()));
//    server.addEndpoint(new CoAPEndpoint(new DTLSConnector(new InetSocketAddress("2a01:c911:0:2010::10", DTLS_PORT)), NetworkConfig.getStandard()));
//    server.addEndpoint(new CoAPEndpoint(new DTLSConnector(new InetSocketAddress("10.200.1.2", DTLS_PORT)), NetworkConfig.getStandard()));
    server.addEndpoint(new CoAPEndpoint(new DTLSConnector(new InetSocketAddress(DTLS_PORT)), NetworkConfig.getStandard()));
    server.start();


        // add special interceptor for message traces
        for (Endpoint ep:server.getEndpoints()) {
          ep.addInterceptor(new MessageTracer());

View Full Code Here

TOP

Related Classes of ch.ethz.inf.vs.californium.network.CoAPEndpoint

ch.ethz.inf.vs.californium.benchmark.BenchmarkServer

ch.ethz.inf.vs.californium.coap.EmptyMessage

ch.ethz.inf.vs.californium.coap.Request

ch.ethz.inf.vs.californium.coap.Response

ch.ethz.inf.vs.californium.examples.ExampleClient

ch.ethz.inf.vs.californium.examples.SecureServer

ch.ethz.inf.vs.californium.network.serialization.DataParser

ch.ethz.inf.vs.californium.network.serialization.Serializer

ch.ethz.inf.vs.californium.network.stack.CoapStack

ch.ethz.inf.vs.californium.osgi.SimpleServerEndpointFactory

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.