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

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

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

Message.getBuffer介绍

[英]Returns a copy of the buffer if offset and length are used, otherwise a reference.
[中]如果使用了偏移量和长度，则返回缓冲区的副本，否则返回引用。

代码示例

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

  1. public byte[]  buffer()                  {return getBuffer();}
  2. public Buffer  buffer2()                 {return getBuffer2();}

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

  1. @Override
  2. public void receive(org.jgroups.Message msg) {
  3.  if (logger.isTraceEnabled())
  4.    logger.trace("sending message " + msg);
  5.  dequeue.add(msg.getBuffer());
  6. }

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

  1. private void doReceive(final Message msg)
  2. {
  3.   final NodeInfo nodeInfo = nodeMap.get(msg.getSrc());
  4.   if (nodeInfo == null)
  5.   {
  6.     logger.warn("Received message from invalid address {}", msg.getSrc());
  7.     messageListener.receive(new NodeAddressImpl(new java.util.UUID(((UUID) msg.getSrc()).getMostSignificantBits(), ((UUID) msg.getSrc()).getLeastSignificantBits())), msg.getBuffer());
  8.   }
  9.   else
  10.   {
  11.     messageListener.receive(nodeInfo.nodeAddress, msg.getBuffer());
  12.   }
  13. }

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

  1. @Override
  2. public void receive(Message msg) {
  3.  byte[] msgBytes = msg.getBuffer();
  4.  if (pingPonger.isPingMessage(msgBytes)) {
  5.   try {
  6.    pingPonger.sendPongMessage(channel, myAddress, msg.getSrc());
  7.   } catch (Exception e) {
  8.    logger.debug("Failed sending Pong message to " + msg.getSrc());
  9.   }
  10.  } else if (pingPonger.isPongMessage(msgBytes)) {
  11.   pongReceived(msg.getSrc());
  12.  }
  13. }

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

  1. private void filter(Message msg, int direction) {
  2.   if (direction == INCOMING) {
  3.    Header h = msg.getHeader(frag2HeaderId);
  4.    boolean copyBuffer = false;
  5.    if (h != null && h instanceof FragHeader) {
  6.     copyBuffer = true;
  7.    } else {
  8.     h = msg.getHeader(unicastHeaderId);
  9.     if (h instanceof UNICAST3.Header) {
  10.      copyBuffer = true;
  11.     } else {
  12.      h = msg.getHeader(nakackHeaderId);
  13.      if (h instanceof NakAckHeader2) {
  14.       copyBuffer = true;
  15.      }
  16.     }
  17.    }
  18.    if (copyBuffer) {
  19.     // JGroups doesn't copy its message buffer when thread pools are
  20.     // disabled. This causes Frag2 fragments to become corrupted
  21.     msg.setBuffer(msg.getBuffer(), 0, msg.getLength());
  22.    }
  23.   }
  24.  }
  25. }

代码示例来源：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. protected void handleSecretKeyResponse(final Message msg, final byte[] key_version) {
  2.   if(!inView(msg.src(), "ignoring secret key sent by %s which is not in current view %s"))
  3.     return;
  4.   if(Arrays.equals(sym_version, key_version)) {
  5.     log.debug("%s: secret key (version %s) already installed, ignoring key response from %s",
  6.          local_addr, Util.byteArrayToHexString(key_version), msg.src());
  7.     return;
  8.   }
  9.   try {
  10.     SecretKey tmp=decodeKey(msg.getBuffer());
  11.     if(tmp == null)
  12.       sendKeyRequest(key_server_addr);      // unable to understand response, let's try again
  13.     else
  14.       setKeys(msg.src(), tmp, key_version); // otherwise set the received key as the shared key
  15.   }
  16.   catch(Exception e) {
  17.     log.warn("%s: unable to process key received from %s: %s", local_addr, msg.src(), e);
  18.   }
  19. }

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

  1. applyNewConfig(msg.getBuffer());
  2. break;

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

  1. byte[] contents = jgmsg.getBuffer();
  2. if (contents == null) {
  3.  return;

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

  1. byte[] buf=frag_table.add(hdr.id, hdr.frag_id, hdr.num_frags, msg.getBuffer());
  2. if(buf == null)
  3.   return null;

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

  1. public Object up(Message msg) {
  2.   StateHeader hdr=msg.getHeader(this.id);
  3.   if(hdr == null)
  4.     return up_prot.up(msg);
  5.   switch(hdr.type) {
  6.     case StateHeader.STATE_REQ:
  7.       state_requesters.add(msg.getSrc());
  8.       break;
  9.     case StateHeader.STATE_RSP:
  10.       handleStateRsp(hdr.getDigest(), msg.getSrc(), msg.getBuffer());
  11.       break;
  12.     case StateHeader.STATE_EX:
  13.       closeHoleFor(msg.getSrc());
  14.       try {
  15.         handleException(Util.exceptionFromBuffer(msg.getRawBuffer(), msg.getOffset(), msg.getLength()));
  16.       }
  17.       catch(Throwable t) {
  18.         log.error("failed deserializaing state exception", t);
  19.       }
  20.       break;
  21.     default:
  22.       log.error("%s: type %s not known in StateHeader", local_addr, hdr.type);
  23.       break;
  24.   }
  25.   return null;
  26. }

代码示例来源：origin: org.hornetq/hornetq-core-client

  1. @Override
  2. public void receive(org.jgroups.Message msg)
  3. {
  4.  dequeue.add(msg.getBuffer());
  5. }

代码示例来源：origin: org.apache.activemq/artemis-core-client

  1. @Override
  2. public void receive(org.jgroups.Message msg) {
  3.  if (logger.isTraceEnabled())
  4.    logger.trace("sending message " + msg);
  5.  dequeue.add(msg.getBuffer());
  6. }

代码示例来源：origin: apache/activemq-artemis

  1. @Override
  2. public void receive(org.jgroups.Message msg) {
  3.  if (logger.isTraceEnabled())
  4.    logger.trace("sending message " + msg);
  5.  dequeue.add(msg.getBuffer());
  6. }

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

  1. @Override
  2. public void receive(org.jgroups.Message msg) {
  3.  if (logger.isTraceEnabled())
  4.    logger.trace("sending message " + msg);
  5.  dequeue.add(msg.getBuffer());
  6. }

代码示例来源：origin: fenix-framework/fenix-framework

  1. @Override
  2. public void receive(Message msg) {
  3.   super.receive(msg);
  4.   String barrierName = new String(msg.getBuffer());
  5.   getOrAdd(barrierName).addMember(msg.getSrc());
  6. }

代码示例来源：origin: org.codehaus.fabric3/fabric3-federation-jgroups

  1. public void receive(Message message) {
  2.   if (message.getSrc() != channel.getAddress()) {
  3.     try {
  4.       Object payload = helper.deserialize(message.getBuffer());
  5.       delegate.onMessage(payload);
  6.     } catch (MessageException e) {
  7.       monitor.error("Error deserializing message payload", e);
  8.     }
  9.   }
  10. }

代码示例来源：origin: org.codehaus.fabric3/fabric3-federation-jgroups

  1. public void receive(Message msg) {
  2.   try {
  3.     String runtimeName = org.jgroups.util.UUID.get(msg.getSrc());
  4.     monitor.receiveMessage(runtimeName);
  5.     Command command = (Command) helper.deserialize(msg.getBuffer());
  6.     executorRegistry.execute(command);
  7.   } catch (MessageException e) {
  8.     monitor.error("Error receiving message from: " + runtimeName, e);
  9.   } catch (ExecutionException e) {
  10.     monitor.error("Error receiving message from: " + runtimeName, e);
  11.   }
  12. }

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

  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: org.ow2.cmi/cmi-ha

  1. public void sendMessage(final HaMessageData messageData) {
  2.   Message message = new Message(null, null, messageData);
  3.   // Compute statistics
  4.   messagesNumber++;
  5.   messagesSize += message.size();
  6.   RspList rspList = dispatcher.castMessage(null, message, GroupRequest.GET_FIRST, 0);
  7.   if (logger.isDebugEnabled()) {
  8.     Address localAddress = dispatcher.getChannel().getLocalAddress();
  9.     logger.debug("Message sended. Length: " + message.getBuffer().length + " From: " + localAddress);
  10.     logger.debug("Response: " + rspList.toString());
  11.   }
  12. }

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

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