org.xbill.DNS.Message.setHeader()方法的使用及代码示例

x33g5p2x  于2022-01-25 转载在 其他  
字(5.6k)|赞(0)|评价(0)|浏览(273)

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

Message.setHeader介绍

暂无

代码示例

代码示例来源:origin: undera/jmeter-plugins

  1. protected byte[] getMessageBytes(String data) {
  2. Message msg = new Message();
  3. String recs[] = data.split(NL);
  4. for (String rec : recs) {
  5. if (rec.length() <= 3) {
  6. Header head = msg.getHeader();
  7. int val = Integer.parseInt(rec.trim());
  8. if (val < 0) {
  9. head.unsetFlag(-val);
  10. } else {
  11. head.setFlag(val);
  12. }
  13. msg.setHeader(head);
  14. } else {
  15. msg.addRecord(getRecord(rec.trim()), Section.QUESTION);
  16. }
  17. }
  18. return msg.toWire();
  19. }

代码示例来源:origin: kg.apc/jmeter-plugins-extras-libs

  1. protected byte[] getMessageBytes(String data) {
  2. Message msg = new Message();
  3. String recs[] = data.split(NL);
  4. for (String rec : recs) {
  5. if (rec.length() <= 3) {
  6. Header head = msg.getHeader();
  7. int val = Integer.parseInt(rec.trim());
  8. if (val < 0) {
  9. head.unsetFlag(-val);
  10. } else {
  11. head.setFlag(val);
  12. }
  13. msg.setHeader(head);
  14. } else {
  15. msg.addRecord(getRecord(rec.trim()), Section.QUESTION);
  16. }
  17. }
  18. return msg.toWire();
  19. }

代码示例来源:origin: OpenNMS/opennms

  1. byte[] buildErrorMessage(final Header header, final int rcode, final Record question) {
  2. final Message response = new Message();
  3. response.setHeader(header);
  4. for (int i = 0; i < 4; i++)
  5. response.removeAllRecords(i);
  6. if (rcode == Rcode.SERVFAIL)
  7. response.addRecord(question, Section.QUESTION);
  8. header.setRcode(rcode);
  9. return response.toWire();
  10. }

代码示例来源:origin: org.echocat.jomon.net/common

  1. byte[] buildErrorMessage(Header header, int rcode, Record question) {
  2. final Message response = new Message();
  3. response.setHeader(header);
  4. for (int i = 0; i < 4; i++) {
  5. response.removeAllRecords(i);
  6. }
  7. if (rcode == Rcode.SERVFAIL) {
  8. response.addRecord(question, Section.QUESTION);
  9. }
  10. header.setRcode(rcode);
  11. return response.toWire();
  12. }

代码示例来源:origin: dnsjava/dnsjava

  1. byte []
  2. buildErrorMessage(Header header, int rcode, Record question) {
  3. Message response = new Message();
  4. response.setHeader(header);
  5. for (int i = 0; i < 4; i++)
  6. response.removeAllRecords(i);
  7. if (rcode == Rcode.SERVFAIL)
  8. response.addRecord(question, Section.QUESTION);
  9. header.setRcode(rcode);
  10. return response.toWire();
  11. }

代码示例来源:origin: org.jboss.resteasy/resteasy-eagledns-fork

  1. private byte[] buildErrorMessage(Header header, int rcode, Record question) {
  2. Message response = new Message();
  3. response.setHeader(header);
  4. for (int i = 0; i < 4; i++) {
  5. response.removeAllRecords(i);
  6. }
  7. if (rcode == Rcode.SERVFAIL) {
  8. response.addRecord(question, Section.QUESTION);
  9. }
  10. header.setRcode(rcode);
  11. return response.toWire();
  12. }

代码示例来源:origin: org.apache.hadoop/hadoop-yarn-registry

  1. /**
  2. * Create an error message.
  3. *
  4. * @param header the response header.
  5. * @param rcode the response code.
  6. * @param question the question record.
  7. * @return the error message.
  8. */
  9. byte[] buildErrorMessage(Header header, int rcode, Record question) {
  10. Message response = new Message();
  11. response.setHeader(header);
  12. for (int i = 0; i < 4; i++) {
  13. response.removeAllRecords(i);
  14. }
  15. response.addRecord(question, Section.QUESTION);
  16. header.setRcode(rcode);
  17. return response.toWire();
  18. }

代码示例来源:origin: posicks/mdnsjava

  1. header.setCount(2, 0);
  2. header.setCount(3, 0);
  3. m.setHeader(header);
  4. m.addRecord(records[index], section);
  5. } else

代码示例来源:origin: org.nhind/dns

  1. /**
  2. * Processes a DNS error condition and creates an appropriate DNS response.
  3. * @param request The original DNS request.
  4. * @param error The error condition that occured.
  5. * @return A response to the DNS request.
  6. */
  7. protected Message processError(Message request, DNSError<?> error)
  8. {
  9. Message errorResponse = null;
  10. try
  11. {
  12. Header respHeader = new Header(request.toWire());
  13. Message response = new Message();
  14. response.setHeader(respHeader);
  15. for (int i = 0; i < 4; i++)
  16. response.removeAllRecords(i);
  17. response.addRecord(request.getQuestion(), Section.QUESTION);
  18. response.getHeader().setFlag(Flags.QR);
  19. if (request.getHeader().getFlag(Flags.RD))
  20. response.getHeader().setFlag(Flags.RD);
  21. respHeader.setRcode(Integer.parseInt(error.getError().toString()));
  22. return response;
  23. }
  24. catch (IOException e) {}
  25. return errorResponse;
  26. }

代码示例来源:origin: github/elasticsearch-srv-discovery

  1. @Override
  2. public Message send(Message query) throws IOException {
  3. final String HOSTNAME = "localhost.";
  4. if (query.getQuestion().getName().toString().equals(Constants.TEST_QUERY)) {
  5. Record question = Record.newRecord(query.getQuestion().getName(), Type.SRV, DClass.IN);
  6. Message queryMessage = Message.newQuery(question);
  7. Message result = new Message();
  8. result.setHeader(queryMessage.getHeader());
  9. result.addRecord(question, Section.QUESTION);
  10. result.addRecord(new SRVRecord(query.getQuestion().getName(), DClass.IN, 1, 1, 1, Constants.NODE_0_TRANSPORT_TCP_PORT, Name.fromString(HOSTNAME)), Section.ANSWER);
  11. result.addRecord(new SRVRecord(query.getQuestion().getName(), DClass.IN, 1, 1, 1, Constants.NODE_1_TRANSPORT_TCP_PORT, Name.fromString(HOSTNAME)), Section.ANSWER);
  12. result.addRecord(new SRVRecord(query.getQuestion().getName(), DClass.IN, 1, 1, 1, Constants.NODE_2_TRANSPORT_TCP_PORT, Name.fromString(HOSTNAME)), Section.ANSWER);
  13. result.addRecord(new SRVRecord(query.getQuestion().getName(), DClass.IN, 1, 1, 1, Constants.NODE_3_TRANSPORT_TCP_PORT, Name.fromString(HOSTNAME)), Section.ANSWER);
  14. result.addRecord(new SRVRecord(query.getQuestion().getName(), DClass.IN, 1, 1, 1, Constants.NODE_4_TRANSPORT_TCP_PORT, Name.fromString(HOSTNAME)), Section.ANSWER);
  15. return result;
  16. }
  17. if (query.getQuestion().getName().toString().equals(HOSTNAME)) {
  18. Record question = Record.newRecord(query.getQuestion().getName(), Type.A, DClass.IN);
  19. Message queryMessage = Message.newQuery(question);
  20. Message result = new Message();
  21. result.setHeader(queryMessage.getHeader());
  22. result.addRecord(question, Section.QUESTION);
  23. result.addRecord(new ARecord(query.getQuestion().getName(), DClass.IN, 1, InetAddress.getLoopbackAddress()), Section.ANSWER);
  24. return result;
  25. }
  26. throw new IllegalArgumentException("Unknown test query: " + query.getQuestion().getName().toString());
  27. }
  28. };

相关文章