org.jgroups.util.Util.match()方法的使用及代码示例

x33g5p2x  于2022-02-01 转载在 其他  
字(6.1k)|赞(0)|评价(0)|浏览(219)

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

Util.match介绍

暂无

代码示例

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

  1. public static <T> boolean different(T one,T two) {
  2.   return !match(one,two);
  3. }

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

  1. public synchronized boolean matchMergeId(MergeId id)   {return Util.match(this.merge_id, id);}

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

  1. public void setAddress(String address) {
  2.   boolean changed=false;
  3.   if(!Util.match(this.address, address))
  4.     changed=true;
  5.   super.setAddress(address);
  6.   if(changed)
  7.     renameThreads();
  8. }

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

  1. public void setClusterName(String cluster_name) {
  2.   boolean changed=false;
  3.   if(!Util.match(this.clusterName, cluster_name))
  4.     changed=true;
  5.   super.setClusterName(cluster_name);
  6.   if(changed)
  7.     renameThreads();
  8. }

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

  1. if(asym_encrypt != null) {
  2.   String sym_alg=asym_encrypt.symAlgorithm();
  3.   if(!Util.match(sym_alg, secret_key_algorithm)) {
  4.     log.warn("overriding %s=%s to %s from %s", "secret_key_algorithm", secret_key_algorithm,
  5.          sym_alg, ASYM_ENCRYPT.class.getSimpleName());

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

  1. public void init() throws Exception {
  2.   super.init();
  3.   if(secret_key_length % 8 != 0)
  4.     throw new IllegalStateException(String.format("secret_key_length (%d) must be a multiple of 8", secret_key_length));
  5.   ASYM_ENCRYPT asym_encrypt=findProtocolAbove(ASYM_ENCRYPT.class);
  6.   if(asym_encrypt != null) {
  7.     String sym_alg=asym_encrypt.symAlgorithm();
  8.     int sym_keylen=asym_encrypt.symKeylength();
  9.     if(Util.match(sym_alg, secret_key_algorithm)) {
  10.       log.warn("overriding %s=%s to %s from %s", "secret_key_algorithm", secret_key_algorithm,
  11.            sym_alg, ASYM_ENCRYPT.class.getSimpleName());
  12.       secret_key_algorithm=sym_alg;
  13.     }
  14.     if(sym_keylen != secret_key_length) {
  15.       log.warn("overriding %s=%d to %d from %s", "secret_key_length", secret_key_length,
  16.            sym_keylen, ASYM_ENCRYPT.class.getSimpleName());
  17.       secret_key_length=sym_keylen;
  18.     }
  19.   }
  20.   key_agreement=KeyAgreement.getInstance("DH");
  21. }

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

  1. public void run() {
  2.   while(running) {
  3.     Message msg=null;
  4.     try {
  5.       if((msg=queue.take()) == null) // block until first message is available
  6.         continue;
  7.       long size=msg.size();
  8.       if(count + size >= transport.getMaxBundleSize()) {
  9.         num_sends_because_full_queue++;
  10.         fill_count.add(count);
  11.         _sendBundledMessages();
  12.       }
  13.       for(;;) {
  14.         Address dest=msg.dest();
  15.         if(!Util.match(dest, target_dest) || count + size >= transport.getMaxBundleSize())
  16.           _sendBundledMessages();
  17.         _addMessage(msg, size);
  18.         msg=queue.poll();
  19.         if(msg == null)
  20.           break;
  21.         size=msg.size();
  22.       }
  23.       _sendBundledMessages();
  24.     }
  25.     catch(Throwable t) {
  26.     }
  27.   }
  28. }

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

  1. public synchronized boolean setMergeId(MergeId expected, MergeId new_value) {
  2.   boolean match=Util.match(this.merge_id, expected);
  3.   if(match) {
  4.     if(new_value != null && merge_id_history.contains(new_value))
  5.       return false;
  6.     else
  7.       merge_id_history.add(new_value);
  8.     this.merge_id=new_value;
  9.     if(this.merge_id != null) {
  10.       // Clears the view handler queue and discards all JOIN/LEAVE/MERGE requests until after the MERGE
  11.       gms.getViewHandler().suspend();
  12.       gms.getDownProtocol().down(new Event(Event.SUSPEND_STABLE, 20000));
  13.       startMergeKiller();
  14.     }
  15.   }
  16.   return match;
  17. }

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

  1. public static <T> boolean different(T one,T two) {
  2.   return !match(one,two);
  3. }

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

  1. public synchronized boolean matchMergeId(MergeId id)   {return Util.match(this.merge_id, id);}

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

  1. public void setClusterName(String cluster_name) {
  2.   boolean changed=false;
  3.   if(!Util.match(this.clusterName, cluster_name))
  4.     changed=true;
  5.   super.setClusterName(cluster_name);
  6.   if(changed)
  7.     renameThreads();
  8. }

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

  1. public void setAddress(String address) {
  2.   boolean changed=false;
  3.   if(!Util.match(this.address, address))
  4.     changed=true;
  5.   super.setAddress(address);
  6.   if(changed)
  7.     renameThreads();
  8. }

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

  1. if(asym_encrypt != null) {
  2.   String sym_alg=asym_encrypt.symAlgorithm();
  3.   if(!Util.match(sym_alg, secret_key_algorithm)) {
  4.     log.warn("overriding %s=%s to %s from %s", "secret_key_algorithm", secret_key_algorithm,
  5.          sym_alg, ASYM_ENCRYPT.class.getSimpleName());

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

  1. public void init() throws Exception {
  2.   super.init();
  3.   if(secret_key_length % 8 != 0)
  4.     throw new IllegalStateException(String.format("secret_key_length (%d) must be a multiple of 8", secret_key_length));
  5.   ASYM_ENCRYPT asym_encrypt=findProtocolAbove(ASYM_ENCRYPT.class);
  6.   if(asym_encrypt != null) {
  7.     String sym_alg=asym_encrypt.symAlgorithm();
  8.     int sym_keylen=asym_encrypt.symKeylength();
  9.     if(Util.match(sym_alg, secret_key_algorithm)) {
  10.       log.warn("overriding %s=%s to %s from %s", "secret_key_algorithm", secret_key_algorithm,
  11.            sym_alg, ASYM_ENCRYPT.class.getSimpleName());
  12.       secret_key_algorithm=sym_alg;
  13.     }
  14.     if(sym_keylen != secret_key_length) {
  15.       log.warn("overriding %s=%d to %d from %s", "secret_key_length", secret_key_length,
  16.            sym_keylen, ASYM_ENCRYPT.class.getSimpleName());
  17.       secret_key_length=sym_keylen;
  18.     }
  19.   }
  20.   key_agreement=KeyAgreement.getInstance("DH");
  21. }

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

  1. public void run() {
  2.   while(running) {
  3.     Message msg=null;
  4.     try {
  5.       if((msg=queue.take()) == null) // block until first message is available
  6.         continue;
  7.       long size=msg.size();
  8.       if(count + size >= transport.getMaxBundleSize()) {
  9.         num_sends_because_full_queue++;
  10.         fill_count.add(count);
  11.         _sendBundledMessages();
  12.       }
  13.       for(;;) {
  14.         Address dest=msg.dest();
  15.         if(!Util.match(dest, target_dest) || count + size >= transport.getMaxBundleSize())
  16.           _sendBundledMessages();
  17.         _addMessage(msg, size);
  18.         msg=queue.poll();
  19.         if(msg == null)
  20.           break;
  21.         size=msg.size();
  22.       }
  23.       _sendBundledMessages();
  24.     }
  25.     catch(Throwable t) {
  26.     }
  27.   }
  28. }

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

  1. public synchronized boolean setMergeId(MergeId expected, MergeId new_value) {
  2.   boolean match=Util.match(this.merge_id, expected);
  3.   if(match) {
  4.     if(new_value != null && merge_id_history.contains(new_value))
  5.       return false;
  6.     else
  7.       merge_id_history.add(new_value);
  8.     this.merge_id=new_value;
  9.     if(this.merge_id != null) {
  10.       // Clears the view handler queue and discards all JOIN/LEAVE/MERGE requests until after the MERGE
  11.       gms.getViewHandler().suspend();
  12.       gms.getDownProtocol().down(new Event(Event.SUSPEND_STABLE, 20000));
  13.       startMergeKiller();
  14.     }
  15.   }
  16.   return match;
  17. }

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

Util

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    Util类方法

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