|
|
|
@ -69,6 +69,7 @@ public class CoapTransportResource extends AbstractCoapTransportResource { |
|
|
|
|
|
|
|
private final ConcurrentMap<InetSocketAddress, TbCoapDtlsSessionInfo> dtlsSessionsMap; |
|
|
|
private final long timeout; |
|
|
|
private final long piggybackTimeout; |
|
|
|
private final CoapClientContext clients; |
|
|
|
|
|
|
|
public CoapTransportResource(CoapTransportContext ctx, CoapServerService coapServerService, String name) { |
|
|
|
@ -77,6 +78,7 @@ public class CoapTransportResource extends AbstractCoapTransportResource { |
|
|
|
this.addObserver(new CoapResourceObserver()); |
|
|
|
this.dtlsSessionsMap = coapServerService.getDtlsSessionsMap(); |
|
|
|
this.timeout = coapServerService.getTimeout(); |
|
|
|
this.piggybackTimeout = coapServerService.getPiggybackTimeout(); |
|
|
|
this.clients = ctx.getClientContext(); |
|
|
|
long sessionReportTimeout = ctx.getSessionReportTimeout(); |
|
|
|
ctx.getScheduler().scheduleAtFixedRate(clients::reportActivity, new Random().nextInt((int) sessionReportTimeout), sessionReportTimeout, TimeUnit.MILLISECONDS); |
|
|
|
@ -169,7 +171,7 @@ public class CoapTransportResource extends AbstractCoapTransportResource { |
|
|
|
} |
|
|
|
|
|
|
|
private void processProvision(CoapExchange exchange) { |
|
|
|
exchange.accept(); |
|
|
|
deferAccept(exchange); |
|
|
|
try { |
|
|
|
UUID sessionId = UUID.randomUUID(); |
|
|
|
log.trace("[{}] Processing provision publish msg [{}]!", sessionId, exchange.advanced().getRequest()); |
|
|
|
@ -195,7 +197,7 @@ public class CoapTransportResource extends AbstractCoapTransportResource { |
|
|
|
|
|
|
|
private void processRequest(CoapExchange exchange, SessionMsgType type) { |
|
|
|
log.trace("Processing {}", exchange.advanced().getRequest()); |
|
|
|
exchange.accept(); |
|
|
|
deferAccept(exchange); |
|
|
|
Exchange advanced = exchange.advanced(); |
|
|
|
Request request = advanced.getRequest(); |
|
|
|
|
|
|
|
@ -346,6 +348,20 @@ public class CoapTransportResource extends AbstractCoapTransportResource { |
|
|
|
new CoapNoOpCallback(exchange)); |
|
|
|
} |
|
|
|
|
|
|
|
/** |
|
|
|
* Send an empty ACK if we are unable to send the full response within the timeout. |
|
|
|
* If the full response is transmitted before the timeout this will not do anything. |
|
|
|
* If this is triggered the full response will be sent in a separate CON/NON message. |
|
|
|
* Essentially this allows the use of piggybacked responses. |
|
|
|
*/ |
|
|
|
private void deferAccept(CoapExchange exchange) { |
|
|
|
if (piggybackTimeout > 0) { |
|
|
|
transportContext.getScheduler().schedule(exchange::accept, piggybackTimeout, TimeUnit.MILLISECONDS); |
|
|
|
} else { |
|
|
|
exchange.accept(); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
private UUID toSessionId(TransportProtos.SessionInfoProto sessionInfoProto) { |
|
|
|
return new UUID(sessionInfoProto.getSessionIdMSB(), sessionInfoProto.getSessionIdLSB()); |
|
|
|
} |
|
|
|
|
Igor Kulikov
4 years ago