org.eclipse.californium.core.coap.Response.isCanceled()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(3.1k)|赞(0)|评价(0)|浏览(100)

本文整理了Java中org.eclipse.californium.core.coap.Response.isCanceled方法的一些代码示例,展示了Response.isCanceled的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Response.isCanceled方法的具体详情如下:
包路径:org.eclipse.californium.core.coap.Response
类名称:Response
方法名:isCanceled

Response.isCanceled介绍

暂无

代码示例

代码示例来源:origin: org.eclipse.californium/californium-core

@Override
public void sendResponse(Exchange exchange, Response response) {
  
  if (response.getDestination() == null)
    throw new NullPointerException("Response has no destination address");
  if (response.getDestinationPort() == 0)
    throw new NullPointerException("Response has no destination port");
  
  matcher.sendResponse(exchange, response);
  
  /* 
   * Logging here causes significant performance loss.
   * If necessary, add an interceptor that logs the messages,
   * e.g., the MessageTracer.
   */
  
  for (MessageInterceptor interceptor:interceptors)
    interceptor.sendResponse(response);
  // MessageInterceptor might have canceled
  if (response.isCanceled()) {
    if (null != exchange) {
      exchange.setComplete();
    }
  }
  else {
    connector.send(serializer.serialize(response));
  }
}

代码示例来源:origin: eclipse/californium

private void receiveResponse(final Response response, final RawData raw) {
  /* 
   * Logging here causes significant performance loss.
   * If necessary, add an interceptor that logs the messages,
   * e.g., the MessageTracer.
   */
  for (MessageInterceptor interceptor:interceptors) {
    interceptor.receiveResponse(response);
  }
  // MessageInterceptor might have canceled
  if (!response.isCanceled()) {
    Exchange exchange = matcher.receiveResponse(response, raw.getCorrelationContext());
    if (exchange != null) {
      exchange.setEndpoint(CoapEndpoint.this);
      response.setRTT(System.currentTimeMillis() - exchange.getTimestamp());
      coapstack.receiveResponse(exchange, response);
    } else if (response.getType() != Type.ACK) {
      LOGGER.log(Level.FINE, "Rejecting unmatchable response from {0}", raw.getInetSocketAddress());
      reject(response);
    }
  }
}

代码示例来源:origin: eclipse/californium

@Override
public void sendResponse(Exchange exchange, Response response) {
  assertMessageHasDestinationAddress(response);
  matcher.sendResponse(exchange, response);
  /* 
   * Logging here causes significant performance loss.
   * If necessary, add an interceptor that logs the messages,
   * e.g., the MessageTracer.
   */
  for (MessageInterceptor interceptor:interceptors) {
    interceptor.sendResponse(response);
  }
  // MessageInterceptor might have canceled
  if (response.isCanceled()) {
    if (null != exchange) {
      exchange.setComplete();
    }
  }
  else {
    connector.send(serializer.serializeResponse(response));
  }
}

代码示例来源:origin: eclipse/californium

protected final void appendResponseDetails(final Response response) {
  if (response.isCanceled()) {
    buffer.append("CANCELED ");
  }
  buffer.append(response.getType()).append(" [MID=").append(response.getMID())
    .append(", T=").append(response.getTokenString()).append("], ")
    .append(response.getCode());
  appendBlockOption(1, response.getOptions().getBlock1());
  appendBlockOption(2, response.getOptions().getBlock2());
  appendObserveOption(response.getOptions());
  appendSize1(response.getOptions());
  appendSize2(response.getOptions());
  appendEtags(response.getOptions());
}

代码示例来源:origin: org.eclipse.californium/californium-core

if (!response.isCanceled()) {
  Exchange exchange = matcher.receiveResponse(response);
  if (exchange != null) {

相关文章