org.jgroups.Message.src()方法的使用及代码示例

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

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

Message.src介绍

暂无

代码示例

代码示例来源：origin: wildfly/wildfly

  1. public Object up(Message msg) {
  2.   try {
  3.     Message ret=deserialize(msg);
  4.     return up_prot.up(ret);
  5.   }
  6.   catch(Exception e) {
  7.     throw new RuntimeException(String.format("failed deserialize message from %s", msg.src()), e);
  8.   }
  9. }

代码示例来源：origin: wildfly/wildfly

  1. protected static void dump(String type, Message msg) {
  2.   StringBuilder sb=new StringBuilder();
  3.   sb.append(String.format("\n%s from %s (%d bytes):\nhdrs: %s\n", type, msg.src(), msg.getLength(), msg.printHeaders()));
  4.   if(msg.getLength() > 0) {
  5.     sb.append("payload: ");
  6.     printPayload(msg, sb);
  7.     sb.append("\n");
  8.   }
  9.   System.out.println(sb.toString());
  10. }

代码示例来源：origin: wildfly/wildfly

  1. public static String dump(byte[] buf, int offset, int length) {
  2.   StringBuilder sb=new StringBuilder();
  3.   List<Message> msgs=parse(new ByteArrayInputStream(buf, offset, length));
  4.   if(msgs != null)
  5.     for(Message msg: msgs)
  6.       sb.append(String.format("dst=%s src=%s (%d bytes): hdrs= %s\n", msg.dest(), msg.src(), msg.getLength(), msg.printHeaders()));
  7.   return sb.toString();
  8. }

代码示例来源：origin: wildfly/wildfly

  1. protected Object handleMessage(Message msg, Header hdr) {
  2.   switch(hdr.type) {
  3.     case CACHE_REQ:
  4.       handleCacheRequest(msg.src());
  5.       break;
  6.     case CACHE_RSP:
  7.       handleCacheResponse(msg);
  8.       break;
  9.   }
  10.   return null;
  11. }

代码示例来源：origin: wildfly/wildfly

  1. public Object down(Message msg) {
  2.    System.out.println("------------------- TRACE (sent) -----------------------");
  3.    System.out.printf("msg from %s to %s (%d bytes): hdrs=%s\n", msg.src(), msg.dest(), msg.length(), msg.printHeaders());
  4.    System.out.println("--------------------------------------------------------");
  5.    return down_prot.down(msg);
  6.  }

代码示例来源：origin: wildfly/wildfly

  1. public Object up(Message msg) {
  2.   if(print_up)
  3.     System.out.printf("-- [s] from %s (%d bytes): %s\n", msg.src(), msg.getLength(), msg.printHeaders());
  4.   return up_prot.up(msg); // Pass up to the layer above us
  5. }

代码示例来源：origin: wildfly/wildfly

  1. protected static void dump(GossipData data) {
  2.   System.out.println("");
  3.   List<Message> messages=Util.parse(data.buffer, data.offset, data.length);
  4.   if(messages != null)
  5.     for(Message msg : messages)
  6.       System.out.printf("dst=%s src=%s (%d bytes): hdrs= %s\n", msg.dest(), msg.src(), msg.getLength(), msg.printHeaders());
  7. }

代码示例来源：origin: wildfly/wildfly

  1. public void up(MessageBatch batch) {
  2.   if(print_up) {
  3.     for(Message msg : batch)
  4.       System.out.printf("-- [b] from %s (%d bytes): %s\n", msg.src(), msg.getLength(), msg.printHeaders());
  5.   }
  6.   if(!batch.isEmpty())
  7.     up_prot.up(batch);
  8. }

代码示例来源：origin: wildfly/wildfly

  1. public Object up(Message msg) {
  2.   DhHeader hdr=msg.getHeader(id);
  3.   if(hdr != null) {
  4.     handle(hdr, msg.src());
  5.     return null;
  6.   }
  7.   return up_prot.up(msg);
  8. }

代码示例来源：origin: wildfly/wildfly

  1. protected Object handleEncryptedMessage(Message msg, byte[] version) throws Exception {
  2.   if(!Arrays.equals(sym_version, version)) { // only check if msg needs to be queued if versions differ
  3.     versionMismatch(msg);
  4.     return null;
  5.   }
  6.   // try and decrypt the message - we need to copy msg as we modify its
  7.   // buffer (http://jira.jboss.com/jira/browse/JGRP-538)
  8.   Message tmpMsg=decryptMessage(null, msg.copy()); // need to copy for possible xmits
  9.   if(tmpMsg != null)
  10.     return up_prot.up(tmpMsg);
  11.   log.warn("%s: unrecognized cipher; discarding message from %s", local_addr, msg.src());
  12.   return null;
  13. }

代码示例来源：origin: wildfly/wildfly

  1. protected void handleCacheResponse(Message msg) {
  2.   Header hdr=msg.getHeader(id);
  3.   if(hdr != null && hdr.addr != null && hdr.name != null) {
  4.     if(log.isTraceEnabled())
  5.       log.trace("%s: received %s from %s", local_addr, hdr, msg.src());
  6.     NameCache.add(hdr.addr, hdr.name);
  7.   }
  8. }

代码示例来源：origin: wildfly/wildfly

  1. public void up(MessageBatch batch) {
  2.   for(Message msg: batch) {
  3.     DhHeader hdr=msg.getHeader(id);
  4.     if(hdr != null) {
  5.       batch.remove(msg);
  6.       handle(hdr, msg.src());
  7.     }
  8.   }
  9.   if(!batch.isEmpty())
  10.     up_prot.up(batch);
  11. }

代码示例来源：origin: wildfly/wildfly

  1. public void receive(Message msg) {
  2.   if(receiver == null)
  3.     return;
  4.   try {
  5.     receiver.receive(msg.src(), msg.getRawBuffer(), msg.getOffset(), msg.getLength());
  6.   }
  7.   catch(Throwable t) {
  8.     log.error("failed delivering message", t);
  9.   }
  10. }

代码示例来源：origin: wildfly/wildfly

  1. protected Message createMessage(Address target, Address final_destination, Address original_sender, final Message msg) {
  2.     Message copy=relay.copy(msg).dest(target).src(null);
  3.     RELAY2.Relay2Header hdr=new RELAY2.Relay2Header(RELAY2.Relay2Header.DATA, final_destination, original_sender);
  4.     copy.putHeader(relay.getId(), hdr);
  5.     return copy;
  6.   }
  7. }

代码示例来源：origin: wildfly/wildfly

  1. public void receive(MessageBatch batch) {
  2.   if(receiver == null)
  3.     return;
  4.   for(Message msg: batch) {
  5.     try {
  6.       receiver.receive(msg.src(), msg.getRawBuffer(), msg.getOffset(), msg.getLength());
  7.     }
  8.     catch(Throwable t) {
  9.       log.error("failed delivering message from batch", t);
  10.     }
  11.   }
  12. }

代码示例来源：origin: wildfly/wildfly

  1. protected Object handleUpMessage(Message msg) throws Exception {
  2.   EncryptHeader hdr=msg.getHeader(this.id);
  3.   if(hdr == null) {
  4.     log.error("%s: received message without encrypt header from %s; dropping it", local_addr, msg.src());
  5.     return null;
  6.   }
  7.   switch(hdr.type()) {
  8.     case EncryptHeader.ENCRYPT:
  9.       return handleEncryptedMessage(msg, hdr.version);
  10.     default:
  11.       return handleUpEvent(msg,hdr);
  12.   }
  13. }

代码示例来源：origin: wildfly/wildfly

  1. private void rejectFlush(Collection<? extends Address> participants, long viewId) {
  2.   if(participants == null)
  3.     return;
  4.   for (Address flushMember : participants) {
  5.     if(flushMember == null)
  6.       continue;
  7.     Message reject = new Message(flushMember).src(localAddress).setFlag(Message.Flag.OOB, Message.Flag.INTERNAL)
  8.      .putHeader(this.id, new FlushHeader(FlushHeader.ABORT_FLUSH, viewId))
  9.      .setBuffer(marshal(participants, null));
  10.     down_prot.down(reject);
  11.   }
  12. }

代码示例来源：origin: wildfly/wildfly

  1. protected void sendSecretKey(Key secret_key, PublicKey public_key, Address source) throws Exception {
  2.   byte[] encryptedKey=encryptSecretKey(secret_key, public_key);
  3.   Message newMsg=new Message(source, encryptedKey).src(local_addr)
  4.    .putHeader(this.id, new EncryptHeader(EncryptHeader.SECRET_KEY_RSP, symVersion()));
  5.   log.debug("%s: sending secret key response to %s (version: %s)", local_addr, source, Util.byteArrayToHexString(sym_version));
  6.   down_prot.down(newMsg);
  7. }

代码示例来源：origin: wildfly/wildfly

  1. protected void handleSecretKeyRequest(final Message msg) {
  2.   if(!inView(msg.src(), "key requester %s is not in current view %s; ignoring key request"))
  3.     return;
  4.   log.debug("%s: received secret key request from %s", local_addr, msg.getSrc());
  5.   try {
  6.     PublicKey tmpKey=generatePubKey(msg.getBuffer());
  7.     sendSecretKey(secret_key, tmpKey, msg.getSrc());
  8.   }
  9.   catch(Exception e) {
  10.     log.warn("%s: unable to reconstitute peer's public key", local_addr);
  11.   }
  12. }

代码示例来源：origin: wildfly/wildfly

  1. /**
  2.  * Sends a SITE-UNREACHABLE message to the sender of the message. Because the sender is always local (we're the
  3.  * relayer), no routing needs to be done
  4.  * @param dest
  5.  * @param target_site
  6.  */
  7. protected void sendSiteUnreachableTo(Address dest, String target_site) {
  8.   Message msg=new Message(dest).setFlag(Message.Flag.OOB, Message.Flag.INTERNAL)
  9.    .src(new SiteUUID((UUID)local_addr, NameCache.get(local_addr), site))
  10.    .putHeader(id,new Relay2Header(Relay2Header.SITE_UNREACHABLE,new SiteMaster(target_site),null));
  11.   down_prot.down(msg);
  12. }

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

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