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

x33g5p2x  于2022-01-26 转载在 其他  
字(5.0k)|赞(0)|评价(0)|浏览(98)

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

OptionSet.getObserve介绍

[英]Returns the uint value of the Observe option.
[中]返回“观察”选项的uint值。

代码示例

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

@Override
public void sendRequest(final Exchange exchange, final Request request) {
  if (CANCEL.equals(request.getOptions().getObserve())) {
    /* TODO: don't send, if connection is not available */
  }
  lower().sendRequest(exchange, request);
}

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

/**
 * Checks for Observe option.
 * 
 * @param response
 *            the response
 * @return true, if successful
 */
protected boolean hasObserve(Response response, boolean invert) {
  // boolean success =
  // response.hasOption(OptionNumberRegistry.OBSERVE);
  boolean success = response.getOptions().hasObserve();
  // invert to check for not having the option
  success ^= invert;
  if (!success) {
    System.out.println("FAIL: Response without Observe");
  } else if (!invert) {
    System.out.printf("PASS: Observe (%d)\n",
    // response.getFirstOption(OptionNumberRegistry.OBSERVE).getIntValue());
        response.getOptions().getObserve().intValue());
  } else {
    System.out.println("PASS: No Observe");
  }
  return success;
}

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

protected final void appendObserveOption(final OptionSet options) {
  if (options != null && options.hasObserve()) {
    buffer.append(", observe(").append(options.getObserve()).append(")");
  }
}

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

/**
 * Checks if this request is used to establish an observe relation.
 * 
 * @return {@code true} if this request's <em>observe</em> option is set to 0.
 */
public final boolean isObserve() {
  return getOptions().hasObserve() && getOptions().getObserve() == 0;
}

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

long T2 = System.currentTimeMillis();
int V1 = getCurrent();
int V2 = response.getOptions().getObserve();
if (V1 < V2 && V2 - V1 < 1<<23
    || V1 > V2 && V1 - V2 > 1<<23

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

long T2 = System.currentTimeMillis();
int V1 = getCurrent();
int V2 = response.getOptions().getObserve();
if (V1 < V2 && V2 - V1 < 1<<23
    || V1 > V2 && V1 - V2 > 1<<23

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

public void check(Response response) {
    assertTrue("Has no observe option", response.getOptions().hasObserve());
    storage.put(key, response.getOptions().getObserve());
  }
});

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

public void check(Response response) {
    assertTrue("Has no observe option", response.getOptions().hasObserve());
    Object value = storage.get(key);
    if (value == null) {
      throw new IllegalArgumentException("Key " + key + " not found");
    }
    int V1 = (Integer) value;
    int V2 = response.getOptions().getObserve();
    boolean fresh = V1 < V2 && V2 - V1 < 1 << 23 || V1 > V2 && V1 - V2 > 1 << 23;
    assertTrue("Was not a fresh notification. Last obs=" + V1 + ", new=" + V2, fresh);
  }
});

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

options.add(new Option(OptionNumberRegistry.OBSERVE, getObserve()));

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

options.add(new Option(OptionNumberRegistry.OBSERVE, getObserve()));

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

public void check(Response response) {
    assertTrue("No observe option:", response.getOptions().hasObserve());
    int expected = (Integer) storage.get(key);
    int actual = response.getOptions().getObserve();
    assertEquals("Wrong observe sequence number:", expected, actual);
    print("Correct observe sequence number: " + expected);
  }
});

代码示例来源:origin: org.github.leshan/leshan-client

if (request.getOptions().getObserve() == 0) {
} else if (request.getOptions().getObserve() == 1) {
  final ObserveRelation relation = observeManager.getRelation(source, request.getToken());
  if (relation != null) {

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

if (request.getOptions().getObserve()==0) {
} else if (request.getOptions().getObserve() == 1) {

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

if (request.getOptions().getObserve()==0) {
} else if (request.getOptions().getObserve() == 1) {

代码示例来源:origin: org.eclipse.leshan/leshan-client

if (request.getOptions().getObserve() == 0) {
} else if (request.getOptions().getObserve() == 1) {
  final ObserveRelation relation = observeManager.getRelation(source, request.getToken());
  if (relation != null) {

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

if (request.getOptions().getObserve() == 0) {
} else if (request.getOptions().getObserve() == 1) {

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

public void check(Message message) {
  assertTrue("No observe option:", message.getOptions().hasObserve());
  int actual = message.getOptions().getObserve();
  assertEquals("Wrong observe sequence number:", observe, actual);
  print("Correct observe sequence number: " + observe);
}

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

if (response.getOptions().getObserve() > responseStatus.getObserve()) {
  responseStatus.setObserve(response.getOptions().getObserve());

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

if (response.getOptions().getObserve()>status.getObserve()) {
  status.setObserve(response.getOptions().getObserve());

相关文章

微信公众号

最新文章

更多