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

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

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

Message.putHeader介绍

[英]Puts a header given a key into the hashmap. Overwrites potential existing entry.
[中]将给定键的标题放入hashmap。覆盖潜在的现有条目。

代码示例

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

  1. public void run() {
  2.   Message heartbeat=new Message().setFlag(Message.Flag.INTERNAL).putHeader(id, new HeartbeatHeader());
  3.   down_prot.down(heartbeat);
  4.   num_heartbeats_sent++;
  5.   log.trace("Sent heartbeat");
  6. }

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

  1. protected void send(Address target, Object payload, byte header, Message.Flag ... flags) throws Exception {
  2.   Message msg=new Message(target, payload);
  3.   if(flags != null)
  4.     for(Message.Flag flag: flags)
  5.       msg.setFlag(flag);
  6.   if(header > 0)
  7.     msg.putHeader(ID, new MPerfHeader(header));
  8.   channel.send(msg);
  9. }

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

  1. protected void broadcast(final Message msg, long seqno) {
  2.   msg.putHeader(this.id, new SequencerHeader(SequencerHeader.BCAST, seqno));
  3.   if(log.isTraceEnabled())
  4.     log.trace(local_addr + ": broadcasting ::" + seqno);
  5.   down_prot.down(msg);
  6.   bcasts_sent++;
  7. }

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

  1. protected void sendEof(Address requester) {
  2.   try {
  3.     Message eof_msg=new Message(requester).putHeader(getId(), new StateHeader(StateHeader.STATE_EOF));
  4.     log.trace("%s --> EOF --> %s", local_addr, requester);
  5.     down(eof_msg);
  6.   }
  7.   catch(Throwable t) {
  8.     log.error("%s: failed sending EOF to %s", local_addr, requester);
  9.   }
  10. }

代码示例来源：origin: org.jgroups/com.springsource.org.jgroups

  1. private void forwardTo(Address destination, Message msg) {
  2.   HTotalHeader hdr=(HTotalHeader)msg.getHeader(getName());
  3.   if(hdr == null) {
  4.     hdr=new HTotalHeader(msg.getDest(), msg.getSrc());
  5.     msg.putHeader(getName(), hdr);
  6.   }
  7.   msg.setDest(destination);
  8.   if(log.isTraceEnabled())
  9.     log.trace("forwarding message to " + destination + ", hdr=" + hdr);
  10.   down_prot.down(new Event(Event.MSG, msg));
  11. }

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

  1. public void sendClose(Address dest, short conn_id) {
  2.   Message msg=new Message(dest).setFlag(Message.Flag.INTERNAL).putHeader(id, UnicastHeader3.createCloseHeader(conn_id));
  3.   log.trace("%s --> CLOSE(%s, conn-id=%d)", local_addr, dest, conn_id);
  4.   down_prot.down(msg);
  5. }

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

  1. protected void sendResponse(Message rsp, long req_id, boolean is_exception) {
  2.   Header rsp_hdr=new Header(is_exception? Header.EXC_RSP : Header.RSP, req_id, corr_id);
  3.   rsp.putHeader(corr_id, rsp_hdr);
  4.   if(log.isTraceEnabled())
  5.     log.trace("sending rsp for %d to %s", req_id, rsp.getDest());
  6.   transport.down(rsp);
  7. }

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

  1. public void run() {
  2.   Message heartbeat=new Message().setFlag(Message.Flag.INTERNAL).putHeader(id, new HeartbeatHeader());
  3.   down_prot.down(heartbeat);
  4.   num_heartbeats_sent++;
  5.   log.trace("Sent heartbeat");
  6. }

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

  1. public Object down(Message msg) {
  2.   if(msg.getDest() != null)
  3.     return down_prot.down(msg); // only process multicast messages
  4.   if(next == null) // view hasn'<></> been received yet, use the normal transport
  5.     return down_prot.down(msg);
  6.   // we need to copy the message, as we cannot do a msg.setSrc(next): the next retransmission
  7.   // would use 'next' as destination  !
  8.   Message copy=msg.copy(true);
  9.   short hdr_ttl=(short)(loopback? view_size -1 : view_size);
  10.   DaisyHeader hdr=new DaisyHeader(hdr_ttl);
  11.   copy.setDest(next);
  12.   copy.putHeader(getId(), hdr);
  13.   msgs_sent++;
  14.   if(loopback) {
  15.     if(log.isTraceEnabled()) log.trace(new StringBuilder("looping back message ").append(msg));
  16.     if(msg.getSrc() == null)
  17.       msg.setSrc(local_addr);
  18.     default_pool.execute(() -> up_prot.up(msg));
  19.   }
  20.   return down_prot.down(copy);
  21. }

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

  1. protected void sendViewAck(Address dest) {
  2.   Message view_ack=new Message(dest).setFlag(OOB, INTERNAL)
  3.    .putHeader(this.id, new GmsHeader(GmsHeader.VIEW_ACK));
  4.   down_prot.down(view_ack);
  5. }

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

  1. protected void sendHeartbeatResponse(Address dest) {
  2.   Message hb_ack=new Message(dest).setFlag(Message.Flag.INTERNAL);
  3.   FdHeader tmp_hdr=new FdHeader(FdHeader.HEARTBEAT_ACK);
  4.   tmp_hdr.from=local_addr;
  5.   hb_ack.putHeader(this.id, tmp_hdr);
  6.   down_prot.down(hb_ack);
  7. }

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

  1. protected synchronized boolean handleMessage(Address sender, byte msg_bit) {
  2.   boolean retval=false;
  3.   if(this.bit == msg_bit) {
  4.     this.bit^=1;
  5.     retval=true;
  6.   }
  7.   byte ack_bit=(byte)(this.bit ^ 1);
  8.   Message ack=new Message(sender).putHeader(id, new ABPHeader(Type.ack, ack_bit));
  9.   log.trace("%s: --> %s.ack(%d)", local_addr, sender, ack_bit);
  10.   down_prot.down(ack);
  11.   return retval;
  12. }

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

  1. protected void sendRequestForFirstSeqno(Address dest) {
  2.   if(last_sync_sent.addIfAbsentOrExpired(dest)) {
  3.     Message msg=new Message(dest).setFlag(Message.Flag.OOB)
  4.      .putHeader(this.id, UnicastHeader3.createSendFirstSeqnoHeader(timestamper.incrementAndGet()));
  5.     log.trace("%s --> SEND_FIRST_SEQNO(%s)", local_addr, dest);
  6.     down_prot.down(msg);
  7.   }
  8. }

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

  1. protected void sendLockInfoRequestTo(Buffer buf, Address[] mbrs, Address exclude) {
  2.   Stream.of(mbrs).filter(m -> m != null && !Objects.equals(m, exclude)).forEach(dest -> {
  3.     Message msg=new Message(dest, buf).putHeader(id, new LockingHeader());
  4.     if(bypass_bundling)
  5.       msg.setFlag(Message.Flag.DONT_BUNDLE);
  6.     try {
  7.       down_prot.down(msg);
  8.     }
  9.     catch(Throwable t) {
  10.       log.error("%s: failed sending LOCK_INFO_REQ to %s: %s", local_addr, dest, t);
  11.     }
  12.   });
  13. }

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

  1. public void run() {
  2.   FD.FdHeader hdr;
  3.   synchronized(suspected_members) {
  4.     if(suspected_members.isEmpty()) {
  5.       stop();
  6.       return;
  7.     }
  8.     hdr=new FdHeader(FdHeader.SUSPECT);
  9.     hdr.mbrs=new ArrayList<>(suspected_members);
  10.     hdr.from=local_addr;
  11.   }
  12.   Message suspect_msg=new Message().setFlag(Message.Flag.INTERNAL).putHeader(id, hdr);
  13.   log.trace("%s: broadcasting SUSPECT message (suspects=%s)", local_addr, suspected_members);
  14.   down_prot.down(suspect_msg);
  15. }

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

  1. protected void sendJoinResponse(Buffer marshalled_rsp, Address dest) {
  2.   Message m=new Message(dest, marshalled_rsp).putHeader(this.id, new GmsHeader(GmsHeader.JOIN_RSP))
  3.    .setFlag(OOB, INTERNAL);
  4.   getDownProtocol().down(m);
  5. }

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

  1. /**
  2.  Sends or broadcasts a I_HAVE_SOCK response. If 'dst' is null, the reponse will be broadcast, otherwise
  3.  it will be unicast back to the requester
  4.  */
  5. protected void sendIHaveSockMessage(Address dst, Address mbr, IpAddress addr) {
  6.   Message msg=new Message(dst).setFlag(Message.Flag.INTERNAL).setTransientFlag(Message.TransientFlag.DONT_LOOPBACK);
  7.   FdHeader hdr=new FdHeader(FdHeader.I_HAVE_SOCK, mbr);
  8.   hdr.sock_addr=addr;
  9.   msg.putHeader(this.id, hdr);
  10.   down_prot.down(msg);
  11. }

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

  1. protected void sendSeqnoResponse(Address original_sender,long seqno, int num_seqnos) {
  2.   SequencerHeader hdr = new SequencerHeader(SequencerHeader.RESPONSE, seqno, num_seqnos);
  3.   Message ucast_msg = new Message(original_sender).putHeader(this.id, hdr);
  4.   
  5.   if (log.isTraceEnabled())
  6.     log.trace(local_addr + ": sending seqno response to " + original_sender + ":: new_seqno=" + seqno + ", num_seqnos=" + num_seqnos);
  7.   down_prot.down(ucast_msg);
  8.   sent_responses++;
  9. }

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

  1. public void run() {
  2.   log.trace("%s: broadcasting SUSPECT message (suspected_mbrs=%s)", local_addr, suspects);
  3.   FdHeader hdr;
  4.   synchronized(suspects) {
  5.     if(suspects.isEmpty()) {
  6.       stopTask();
  7.       return;
  8.     }
  9.     hdr=new FdHeader(FdHeader.SUSPECT).mbrs(new HashSet<>(suspects));
  10.   }
  11.   Message suspect_msg=new Message().setFlag(Message.Flag.INTERNAL).putHeader(id, hdr); // mcast SUSPECT to all members
  12.   down_prot.down(suspect_msg);
  13. }

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

  1. protected void sendCredit(Address dest, long credits) {
  2.   if(log.isTraceEnabled())
  3.     log.trace("sending %d credits to %s", credits, dest);
  4.   Message msg=new Message(dest, longToBuffer(credits))
  5.    .setFlag(Message.Flag.OOB, Message.Flag.INTERNAL, Message.Flag.DONT_BUNDLE)
  6.    .putHeader(this.id,getReplenishHeader());
  7.   down_prot.down(msg);
  8.   num_credit_responses_sent++;
  9. }

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

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