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

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

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

OptionSet.setBlock1介绍

[英]Sets the Block1 option based on its components. Returns the current OptionSet object for a fluent API.
[中]根据其组件设置Block1选项。返回fluent API的当前OptionSet对象。

代码示例

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

public void set(Message message) {
    message.getOptions().setBlock1(BlockOption.size2Szx(size), m, num);
  }
});

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

block.getOptions().setBlock1(block1);
if (block1 != null) response.getOptions().setBlock1(block1);
exchange.setCurrentResponse(response);

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

block.getOptions().setBlock1(block1);
response.getOptions().setBlock1(block1);

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

private static Request newBlockwiseRequest(final int bodySize, final int blockSize) {
    Request request = Request.newPut();
    request.getOptions().setBlock1(BlockOption.size2Szx(blockSize), true, 0).setSize1(bodySize);
    request.setPayload(generateRandomPayload(blockSize));
    return request;
  }
}

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

private static Request getNextRequestBlock(final Request request, final BlockwiseStatus status) {
  int num = status.getCurrentNum();
  int szx = status.getCurrentSzx();
  Request block = new Request(request.getCode());
  // do not enforce CON, since NON could make sense over SMS or similar transports
  block.setType(request.getType());
  block.setDestination(request.getDestination());
  block.setDestinationPort(request.getDestinationPort());
  // copy options
  block.setOptions(new OptionSet(request.getOptions()));
  // copy message observers so that a failing blockwise request also notifies observers registered with
  // the original request
  block.addMessageObservers(request.getMessageObservers());
  int currentSize = 1 << (4 + szx);
  int from = num * currentSize;
  int to = Math.min((num + 1) * currentSize, request.getPayloadSize());
  int length = to - from;
  byte[] blockPayload = new byte[length];
  System.arraycopy(request.getPayload(), from, blockPayload, 0, length);
  block.setPayload(blockPayload);
  boolean m = (to < request.getPayloadSize());
  block.getOptions().setBlock1(szx, m, num);
  status.setComplete(!m);
  return block;
}

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

private static Request getNextRequestBlock(final Request request, final BlockwiseStatus status) {
  int num = status.getCurrentNum();
  int szx = status.getCurrentSzx();
  Request block = new Request(request.getCode());
  // do not enforce CON, since NON could make sense over SMS or similar transports
  block.setType(request.getType());
  block.setDestination(request.getDestination());
  block.setDestinationPort(request.getDestinationPort());
  // copy options
  block.setOptions(new OptionSet(request.getOptions()));
  // copy message observers so that a failing blockwise request also notifies observers registered with
  // the original request
  block.addMessageObservers(request.getMessageObservers());
  int currentSize = 1 << (4 + szx);
  int from = num * currentSize;
  int to = Math.min((num + 1) * currentSize, request.getPayloadSize());
  int length = to - from;
  byte[] blockPayload = new byte[length];
  System.arraycopy(request.getPayload(), from, blockPayload, 0, length);
  block.setPayload(blockPayload);
  boolean m = (to < request.getPayloadSize());
  block.getOptions().setBlock1(szx, m, num);
  status.setComplete(!m);
  return block;
}

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

piggybacked.getOptions().setBlock1(block1.getSzx(), true, block1.getNum());
    piggybacked.setLast(false);
  error.getOptions().setBlock1(block1.getSzx(), block1.isM(), block1.getNum());
  error.setPayload("unexpected Content-Format");
    new Object[]{status.getCurrentNum(), block1.getNum()});
Response error = Response.createResponse(request, ResponseCode.REQUEST_ENTITY_INCOMPLETE);
error.getOptions().setBlock1(block1.getSzx(), block1.isM(), block1.getNum());
error.setPayload("Wrong block number");
exchange.setCurrentResponse(error);

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

} else {
  Response error = Response.createResponse(request, ResponseCode.REQUEST_ENTITY_INCOMPLETE);
  error.getOptions().setBlock1(block1.getSzx(), block1.isM(), block1.getNum());
  error.setPayload("Changed Content-Format");
  piggybacked.getOptions().setBlock1(block1.getSzx(), true, block1.getNum());
  piggybacked.setLast(false);
error.getOptions().setBlock1(block1.getSzx(), block1.isM(), block1.getNum());
error.setPayload("Wrong block number");
exchange.setCurrentResponse(error);

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

case OptionNumberRegistry.PROXY_URI:      setProxyUri(option.getStringValue()); break;
case OptionNumberRegistry.PROXY_SCHEME:   setProxyScheme(option.getStringValue()); break;
case OptionNumberRegistry.BLOCK1:         setBlock1(option.getValue()); break;
case OptionNumberRegistry.BLOCK2:         setBlock2(option.getValue()); break;
case OptionNumberRegistry.SIZE1:          setSize1(option.getIntegerValue()); break;

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

case OptionNumberRegistry.PROXY_URI:      setProxyUri(option.getStringValue()); break;
case OptionNumberRegistry.PROXY_SCHEME:   setProxyScheme(option.getStringValue()); break;
case OptionNumberRegistry.BLOCK1:         setBlock1(option.getValue()); break;
case OptionNumberRegistry.BLOCK2:         setBlock2(option.getValue()); break;
case OptionNumberRegistry.SIZE1:          setSize1(option.getIntegerValue()); break;

相关文章

微信公众号

最新文章

更多