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

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

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

Message.getSrc介绍

暂无

代码示例

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

  1. protected void queueMessage(Message msg, long seqno) {
  2.   if(become_server_queue != null) {
  3.     become_server_queue.add(msg);
  4.     log.trace("%s: message %s::%d was added to queue (not yet server)", local_addr, msg.getSrc(), seqno);
  5.   }
  6.   else
  7.     log.trace("%s: message %s::%d was discarded (not yet server)", local_addr, msg.getSrc(), seqno);
  8. }

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

  1. public Object up(Message msg) {
  2.   if(shouldDropUpMessage(msg, msg.getSrc()))
  3.     return null;
  4.   return up_prot.up(msg);
  5. }

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

  1. public Object up(Message msg) {
  2.   Frag3Header hdr=msg.getHeader(this.id);
  3.   if(hdr != null) { // needs to be defragmented
  4.     Message assembled_msg=unfragment(msg, hdr);
  5.     if(assembled_msg != null) {
  6.       assembled_msg.setSrc(msg.getSrc()); // needed ? YES, because fragments have a null src !!
  7.       up_prot.up(assembled_msg);
  8.       avg_size_up.add(assembled_msg.length());
  9.     }
  10.     return null;
  11.   }
  12.   return up_prot.up(msg);
  13. }

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

  1. public Object up(Message msg) {
  2.   if(msg.getDest() == null || msg.isFlagSet(Message.Flag.NO_RELIABILITY))  // only handle unicast messages
  3.     return up_prot.up(msg);  // pass up
  4.   UnicastHeader3 hdr=msg.getHeader(this.id);
  5.   if(hdr == null)
  6.     return up_prot.up(msg);
  7.   Address sender=msg.getSrc();
  8.   switch(hdr.type) {
  9.     case UnicastHeader3.DATA:      // received regular message
  10.       if(is_trace)
  11.         log.trace("%s <-- DATA(%s: #%d, conn_id=%d%s)", local_addr, sender, hdr.seqno, hdr.conn_id, hdr.first? ", first" : "");
  12.       if(Objects.equals(local_addr, sender))
  13.         handleDataReceivedFromSelf(sender, hdr.seqno, msg);
  14.       else
  15.         handleDataReceived(sender, hdr.seqno, hdr.conn_id, hdr.first, msg);
  16.       break; // we pass the deliverable message up in handleDataReceived()
  17.     default:
  18.       handleUpEvent(sender, msg, hdr);
  19.       break;
  20.   }
  21.   return null;
  22. }

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

  1. public void passMessageUp(Message msg, byte[] cluster_name, boolean perform_cluster_name_matching,
  2.              boolean multicast, boolean discard_own_mcast) {
  3.   if(is_trace)
  4.     log.trace("%s: received %s, headers are %s", local_addr, msg, msg.printHeaders());
  5.   if(up_prot == null)
  6.     return;
  7.   if(multicast && discard_own_mcast && local_addr != null && local_addr.equals(msg.getSrc()))
  8.     return;
  9.   // Discard if message's cluster name is not the same as our cluster name
  10.   if(perform_cluster_name_matching && this.cluster_name != null && !this.cluster_name.equals(cluster_name)) {
  11.     if(log_discard_msgs && log.isWarnEnabled()) {
  12.       Address sender=msg.getSrc();
  13.       if(suppress_log_different_cluster != null)
  14.         suppress_log_different_cluster.log(SuppressLog.Level.warn, sender,
  15.                           suppress_time_different_cluster_warnings,
  16.                           new AsciiString(cluster_name),this.cluster_name, sender);
  17.       else
  18.         log.warn(Util.getMessage("MsgDroppedDiffCluster"), new AsciiString(cluster_name),this.cluster_name, sender);
  19.     }
  20.     return;
  21.   }
  22.   up_prot.up(msg);
  23. }

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

  1. /**
  2.  * Sends a message msg to the requester. We have to wrap the original message into a retransmit message, as we need
  3.  * to preserve the original message's properties, such as src, headers etc.
  4.  * @param dest
  5.  * @param msg
  6.  */
  7. protected void sendXmitRsp(Address dest, Message msg) {
  8.   if(msg == null)
  9.     return;
  10.   if(stats)
  11.     xmit_rsps_sent.increment();
  12.   if(msg.getSrc() == null)
  13.     msg.setSrc(local_addr);
  14.   if(use_mcast_xmit) { // we simply send the original multicast message
  15.     down_prot.down(msg);
  16.     return;
  17.   }
  18.   Message xmit_msg=msg.copy(true, true).dest(dest); // copy payload and headers
  19.   NakAckHeader2 hdr=xmit_msg.getHeader(id);
  20.   NakAckHeader2 newhdr=hdr.copy();
  21.   newhdr.type=NakAckHeader2.XMIT_RSP; // change the type in the copy from MSG --> XMIT_RSP
  22.   xmit_msg.putHeader(id, newhdr);
  23.   down_prot.down(xmit_msg);
  24. }

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

  1. public boolean handleUpMessage(Message msg) {
  2.   ChallengeResponseHeader hdr=msg.getHeader(ID);
  3.   if(hdr == null)
  4.     return true;
  5.   switch(hdr.type) {
  6.     case ChallengeResponseHeader.CHALLENGE:
  7.       long hash=hash(encrypt(hdr.payload));
  8.       Message response=new Message(msg.getSrc()).setFlag(Message.Flag.OOB)
  9.        .putHeader(ID, new ChallengeResponseHeader(hash));
  10.       log.trace("%s: received CHALLENGE from %s; sending RESPONSE (hash=%d)", auth.getAddress(), msg.src(), hash);
  11.       auth.getDownProtocol().down(response);
  12.       break;
  13.     case ChallengeResponseHeader.RESPONSE:
  14.       log.trace("%s: received RESPONSE from %s", auth.getAddress(), msg.getSrc());
  15.       Entry entry=pending_requests.get(msg.getSrc());
  16.       if(entry != null)
  17.         entry.setResponse(hdr.hash);
  18.       break;
  19.   }
  20.   return false; // don't pass up
  21. }

代码示例来源：origin: apache/geode

  1. pingPonger.sendPongMessage(myChannel, jgAddress, jgmsg.getSrc());
  2. } catch (Exception e) {
  3.  logger.info("Failed sending Pong response to " + jgmsg.getSrc());
  4. NakAckHeader2 header = (NakAckHeader2) jgmsg.getHeader(nackack2HeaderId);
  5. if (header != null && !jgmsg.isFlagSet(Flag.OOB)) {
  6.  recordScheduledSeqno(msg.getSender(), header.getSeqno());

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

  1. public Object up(Message msg) {
  2.   FdHeader hdr=msg.getHeader(this.id);
  3.   if(hdr == null) {
  4.     if(msg_counts_as_heartbeat)
  5.       updateTimestamp(msg.getSrc());
  6.     return up_prot.up(msg);  // message did not originate from FD layer, just pass up
  7.       Address hb_sender=msg.getSrc();
  8.       log.trace("%s: received are-you-alive from %s, sending response", local_addr, hb_sender);
  9.       sendHeartbeatResponse(hb_sender);
  10.       break;                                     // don't pass up !
  11.       if(hdr.mbrs == null)
  12.         return null;
  13.       log.trace("%s: received suspect message: %s", local_addr, hdr);
  14.           log.warn("%s: I was suspected by %s; ignoring the SUSPECT message and sending back a HEARTBEAT_ACK",
  15.                local_addr, msg.src());
  16.           sendHeartbeatResponse(msg.getSrc());
  17.           continue;
  18.       if(!suspects.isEmpty()) {
  19.         log.debug("%s: suspecting %s", local_addr, suspects);
  20.         up_prot.up(new Event(Event.SUSPECT, suspects));
  21.         down_prot.down(new Event(Event.SUSPECT, suspects));

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

  1. public Object up(Message msg) {
  2.   FragHeader hdr=msg.getHeader(this.id);
  3.   if(hdr != null) { // needs to be defragmented
  4.     Message assembled_msg=unfragment(msg, hdr);
  5.     if(assembled_msg != null) {
  6.       assembled_msg.setSrc(msg.getSrc()); // needed ? YES, because fragments have a null src !!
  7.       up_prot.up(assembled_msg);
  8.       avg_size_up.add(assembled_msg.length());
  9.     }
  10.     return null;
  11.   }
  12.   return up_prot.up(msg);
  13. }

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

  1. public boolean authenticate(AuthToken token, Message msg) {
  2.   Address sender=msg.getSrc();
  3.   if(match_ip_address) {
  4.     PhysicalAddress src=sender != null? (PhysicalAddress)auth.down(new Event(Event.GET_PHYSICAL_ADDRESS, sender)) : null;
  5.     String ip_addr=src != null? src.toString() : null;
  6.     if(ip_addr != null) {
  7.       Matcher matcher=pattern.matcher(ip_addr);
  8.       boolean result=matcher.matches();
  9.       if(log.isTraceEnabled())
  10.         log.trace("matching ip_address: pattern= " + pattern + ", input= " + ip_addr + ", result= " + result);
  11.       if(result)
  12.         return true;
  13.     }
  14.   }
  15.   if(match_logical_name) {
  16.     String logical_name=sender != null? NameCache.get(sender) : null;
  17.     if(logical_name != null) {
  18.       Matcher matcher=pattern.matcher(logical_name);
  19.       boolean result=matcher.matches();
  20.       if(log.isTraceEnabled())
  21.         log.trace("matching logical_name: pattern= " + pattern + ", input= " + logical_name + ", result= " + result);
  22.       if(result)
  23.         return true;
  24.     }
  25.   }
  26.   return false;
  27. }

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

  1. public void receive(long id, Message msg) {
  2.   Address sender=msg.getSrc();
  3.   if(sender == null) {
  4.     if(log.isErrorEnabled())
  5.       log.error(local_addr + ": sender is null, cannot deliver message " + "::" + id);
  6.     return;
  7.   }
  8.   if(!canDeliver(sender, id)) {
  9.     if(log.isWarnEnabled())
  10.       log.warn(local_addr + ": dropped duplicate message " + sender + "::" + id);
  11.     return;
  12.   }
  13.   if(log.isTraceEnabled())
  14.     log.trace(local_addr + ": delivering " + sender + "::" + id);
  15.   up_prot.up(msg);
  16. }

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

  1. public void receive(Message msg) {
  2.   MPerfHeader hdr=msg.getHeader(ID);
  3.   switch(hdr.type) {
  4.     case MPerfHeader.DATA:
  5.       handleData(msg.getSrc(), hdr.seqno, num_threads == 1 && !oob);
  6.       break;
  7.       result_collector=msg.getSrc();
  8.       sendMessages();
  9.       break;
  10.       Address sender=msg.getSrc();
  11.       Stats tmp=received_msgs.get(sender);
  12.       if(tmp != null)
  13.       results.add(msg.getSrc(), res);
  14.       if(initiator && results.hasAllResponses()) {
  15.         initiator=false;
  16.         send(msg.getSrc(), null, MPerfHeader.ACK, Message.Flag.OOB);
  17.         handleConfigRequest(msg.getSrc());
  18.       ack_collector.ack(msg.getSrc());
  19.       break;

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

  1. public void up(MessageBatch batch) {
  2.   for(Iterator<Message> it=batch.iterator(); it.hasNext();) {
  3.     Message msg=it.next();
  4.     if(msg != null && shouldDropUpMessage(msg, msg.getSrc()))
  5.       it.remove();
  6.   }
  7.   if(!batch.isEmpty())
  8.     up_prot.up(batch);
  9. }

代码示例来源：origin: org.jboss.eap/wildfly-client-all

  1. public boolean handleUpMessage(Message msg) {
  2.   ChallengeResponseHeader hdr=msg.getHeader(ID);
  3.   if(hdr == null)
  4.     return true;
  5.   switch(hdr.type) {
  6.     case ChallengeResponseHeader.CHALLENGE:
  7.       long hash=hash(encrypt(hdr.payload));
  8.       Message response=new Message(msg.getSrc()).setFlag(Message.Flag.OOB)
  9.        .putHeader(ID, new ChallengeResponseHeader(hash));
  10.       log.trace("%s: received CHALLENGE from %s; sending RESPONSE (hash=%d)", auth.getAddress(), msg.src(), hash);
  11.       auth.getDownProtocol().down(response);
  12.       break;
  13.     case ChallengeResponseHeader.RESPONSE:
  14.       log.trace("%s: received RESPONSE from %s", auth.getAddress(), msg.getSrc());
  15.       Entry entry=pending_requests.get(msg.getSrc());
  16.       if(entry != null)
  17.         entry.setResponse(hdr.hash);
  18.       break;
  19.   }
  20.   return false; // don't pass up
  21. }

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

  1. public Object up(Message msg) {
  2.   CounterHeader hdr=msg.getHeader(id);
  3.   if(hdr == null)
  4.     return up_prot.up(msg);
  5.   try {
  6.     Object obj=streamableFromBuffer(msg.getRawBuffer(), msg.getOffset(), msg.getLength());
  7.     if(log.isTraceEnabled())
  8.       log.trace("[" + local_addr + "] <-- [" + msg.getSrc() + "] " + obj);
  9.     if(obj instanceof Request) {
  10.       handleRequest((Request)obj, msg.getSrc());
  11.     }
  12.     else if(obj instanceof Response) {
  13.       handleResponse((Response)obj, msg.getSrc());
  14.     }
  15.     else {
  16.       log.error(Util.getMessage("ReceivedObjectIsNeitherARequestNorAResponse") + obj);
  17.     }
  18.   }
  19.   catch(Exception ex) {
  20.     log.error(Util.getMessage("FailedHandlingMessage"), ex);
  21.   }
  22.   return null;
  23. }

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

  1. public Object up(Message msg) {
  2.   Address sender=msg.getSrc();
  3.   Header hdr=msg.getHeader(this.id);
  4.   if(hdr != null) {
  5.     update(sender); // updates the heartbeat entry for 'sender'
  6.     num_heartbeats_received++;
  7.     unsuspect(sender);
  8.     return null; // consume heartbeat message, do not pass to the layer above
  9.   }
  10.   else if(msg_counts_as_heartbeat) {
  11.     // message did not originate from FD_ALL layer, but still count as heartbeat
  12.     update(sender); // update when data is received too ? maybe a bit costly
  13.     if(has_suspected_mbrs)
  14.       unsuspect(sender);
  15.   }
  16.   return up_prot.up(msg); // pass up to the layer above us
  17. }

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

  1. Address   sender=msg.getSrc();
  2. Message   assembled_msg=null;
  3.   frag_table.remove(hdr.id);
  4.   if(log.isTraceEnabled())
  5.     log.trace("%s: unfragmented message from %s (size=%d) from %d fragments",
  6.          local_addr, sender, assembled_msg.getLength(), entry.num_frags);

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

  1. boolean multicast=dest == null;
  2. if(msg.getSrc() == null)
  3.   msg.setSrc(localAddress());
  4.     if(dest == null) {
  5.       up_prot.up(msg);
  6.       return null;
  7.   if(r < down) {
  8.     if(excludeItself && dest != null && dest.equals(localAddress())) {
  9.       if(log.isTraceEnabled()) log.trace("excluding itself");
  10.       log.trace("dropping message");
  11.       num_down++;
  12.       return null;

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

  1. public void receive(Message msg) {
  2.   Address sender=msg.getSrc();
  3.   if(bridge.getAddress().equals(sender)) // discard my own messages
  4.     return;
  5.   RelayHeader hdr=msg.getHeader(id);
  6.   switch(hdr.type) {
  7.     case DISSEMINATE: // should not occur here, but we'll ignore it anyway

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

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