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

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

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

Request.setType介绍

暂无

代码示例

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

  1. private Request applyRequestType(Request request) {
  2.   request.setType(this.type);
  3.   return request;
  4. }

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

  1. private static boolean ping(String address) {
  2.   try {
  3.     Request request = new Request(null);
  4.     request.setType(Type.CON);
  5.     request.setToken(new byte[0]);
  6.     request.setURI(address);
  7.     System.out.println("++++++ Sending Ping ++++++");
  8.     request.send().waitForResponse(5000);
  9.     return request.isRejected();
  10.   } catch (Exception e) {
  11.     e.printStackTrace();
  12.     return false;
  13.   }
  14. }

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

  1. /**
  2.  * Schedules a retransmission for confirmable messages. 
  3.  */
  4. @Override
  5. public void sendRequest(final Exchange exchange, final Request request) {
  6.   LOGGER.log(Level.FINER, "Send request, failed transmissions: {0}", exchange.getFailedTransmissionCount());
  7.   if (request.getType() == null) {
  8.     request.setType(Type.CON);
  9.   }
  10.   if (request.getType() == Type.CON) {
  11.     prepareRetransmission(exchange, new RetransmissionTask(exchange, request) {
  12.       public void retransmit() {
  13.         sendRequest(exchange, request);
  14.       }
  15.     });
  16.   }
  17.   super.sendRequest(exchange, request);
  18. }

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

  1. /**
  2.  * Schedules a retransmission for confirmable messages.
  3.  */
  4. @Override
  5. public void sendRequest(final Exchange exchange, final Request request) {
  6.   LOGGER.log(Level.FINER, "Send request, failed transmissions: {0}", exchange.getFailedTransmissionCount());
  7.   if (request.getType() == null) {
  8.     request.setType(Type.CON);
  9.   }
  10.   if (request.getType() == Type.CON) {
  11.     prepareRetransmission(exchange, new RetransmissionTask(exchange, request) {
  12.       public void retransmit() {
  13.         sendRequest(exchange, request);
  14.       }
  15.     });
  16.   }
  17.   lower().sendRequest(exchange, request);
  18. }

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

  1. /**
  2.  * Sends the specified request over the specified endpoint.
  3.  * 
  4.  * @param request the request
  5.  * @param outEndpoint the endpoint
  6.  * @return the request
  7.  */
  8. protected Request send(Request request, Endpoint outEndpoint) {
  9.   // use the specified message type
  10.   request.setType(this.type);
  11.   if (blockwise!=0) {
  12.     request.getOptions().setBlock2(new BlockOption(BlockOption.size2Szx(this.blockwise), false, 0));
  13.   }
  14.   
  15.   outEndpoint.sendRequest(request);
  16.   return request;
  17. }

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

  1. /**
  2.  * Verifies that the server cleans up all exchanges after serving a NON GET.
  3.  * 
  4.  * @throws Exception if the test fails.
  5.  */
  6. @Test
  7. public void testSimpleNONGet() throws Exception {
  8.   String uri = uriOf(URI);
  9.   LOGGER.log(Level.FINE, "Test simple NON GET to {0}", uri);
  10.   String currentResponseText = "simple NON GET";
  11.   resource.setResponse(currentResponseText, Mode.PIGGY_BACKED_RESPONSE);
  12.   Request request = Request.newGet();
  13.   request.setURI(uri);
  14.   request.setType(Type.NON);
  15.   Response response = request.send(clientEndpoint).waitForResponse(ACK_TIMEOUT);
  16.   assertThat("Client did not receive response to NON request in time", response, is(notNullValue()));
  17.   LOGGER.log(Level.FINE, "Client received response [{0}] with msg type [{1}]", new Object[]{response.getPayloadString(), response.getType()});
  18.   assertThat(response.getPayloadString(), is(currentResponseText));
  19.   assertThat(response.getType(), is(Type.NON));
  20. }

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

  1. exchange.getCurrentRequest().setType(Type.CON);
  2. } else if (exchange.getCurrentResponse() != null) {
  3.   exchange.getCurrentResponse().setType(Type.CON);

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

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

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

  1. exchange.getCurrentRequest().setType(Type.CON);
  2. } else if (exchange.getCurrentResponse() != null) {
  3.   exchange.getCurrentResponse().setType(Type.CON);

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

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

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

  1. block.setType(request.getType());
  2. block.setDestination(request.getDestination());
  3. block.setDestinationPort(request.getDestinationPort());

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

  1. block.setType(request.getType());
  2. block.setDestination(request.getDestination());
  3. block.setDestinationPort(request.getDestinationPort());

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

  1. @Test public void testRequestParsing() {
  2.     Request request = new Request(Code.POST);
  3.     request.setType(Type.NON);
  4.     request.setMID(expectedMid);
  5.     request.setToken(new byte[] { 11, 82, -91, 77, 3 });
  6.     request.getOptions().addIfMatch(new byte[] { 34, -17 }).addIfMatch(new byte[] { 88, 12, -2, -99, 5 })
  7.         .setContentFormat(40).setAccept(40);
  9.     RawData rawData = serializer.serializeRequest(request);
  10. //        MessageHeader header = parser.parseHeader(rawData);
  11. //        assertTrue(CoAP.isRequest(header.getCode()));
  12. //
  13. //        Request result = parser.parseRequest(rawData);
  14.     Request result = (Request) parser.parseMessage(rawData);
  15.     assertEquals(request.getMID(), result.getMID());
  16.     assertArrayEquals(request.getToken(), result.getToken());
  17.     assertEquals(request.getOptions().asSortedList(), result.getOptions().asSortedList());
  18.   }

内容来源于网络，如有侵权，请联系作者删除！

request

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    Request类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com