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

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

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

Util.streamableFromByteBuffer介绍

暂无

代码示例

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

  1. public static <T extends Streamable> T streamableFromByteBuffer(Supplier<T> factory, byte[] buffer) throws Exception {
  2.   return streamableFromByteBuffer(factory, buffer, 0, buffer.length);
  3. }

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

  1. public static <T extends Streamable> T streamableFromByteBuffer(Class<? extends Streamable> cl,byte[] buffer) throws Exception {
  2.   return streamableFromByteBuffer(cl,buffer,0,buffer.length);
  3. }

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

  1. protected static PingData deserialize(final byte[] data) throws Exception {
  2.   return Util.streamableFromByteBuffer(PingData::new, data);
  3. }

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

  1. DrawCommand comm=Util.streamableFromByteBuffer(DrawCommand::new, buf, offset, length);
  2. switch(comm.mode) {
  3.   case DrawCommand.DRAW:

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

  1. public void receive(Message msg) {
  2.   byte[] buf=msg.getRawBuffer();
  3.   if(buf == null) {
  4.     System.err.printf("%s: received null buffer from %s, headers: %s\n", channel.getAddress(), msg.src(), msg.printHeaders());
  5.     return;
  6.   }
  7.   try {
  8.     DrawCommand comm=Util.streamableFromByteBuffer(DrawCommand::new, buf, msg.getOffset(), msg.getLength());
  9.     switch(comm.mode) {
  10.       case DrawCommand.DRAW:
  11.         if(panel != null)
  12.           panel.drawPoint(comm);
  13.         break;
  14.       case DrawCommand.CLEAR:
  15.         clearPanel();
  16.         break;
  17.       default:
  18.         System.err.println("***** received invalid draw command " + comm.mode);
  19.         break;
  20.     }
  21.   }
  22.   catch(Exception e) {
  23.     e.printStackTrace();
  24.   }
  25. }

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

  1. case VIEW:
  2.   try {
  3.     ViewData data=Util.streamableFromByteBuffer(ViewData::new, msg.getRawBuffer(),
  4.                           msg.getOffset(), msg.getLength());

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

  1. protected Object installView(byte[] buf, int offset, int length) {
  2.   try {
  3.     ViewData data=Util.streamableFromByteBuffer(ViewData::new, buf, offset, length);
  4.     if(data.uuids != null)
  5.       NameCache.add(data.uuids);
  6.     remote_view=data.remote_view;
  7.     if(global_view == null || (data.global_view != null &&!global_view.equals(data.global_view))) {
  8.       global_view=data.global_view;
  9.       synchronized(this) {
  10.         if(data.global_view.getViewId().getId() > global_view_id)
  11.           global_view_id=data.global_view.getViewId().getId();
  12.       }
  13.       if(present_global_views)
  14.         return up_prot.up(new Event(Event.VIEW_CHANGE, global_view));
  15.     }
  16.   }
  17.   catch(Exception e) {
  18.     log.error(Util.getMessage("FailedInstallingView"), e);
  19.   }
  20.   return null;
  21. }

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

  1. protected void sendOnLocalCluster(byte[] buf, int offset, int length) {
  2.   try {
  3.     Message msg=Util.streamableFromByteBuffer(Message::new, buf, offset, length);
  4.     Address sender=msg.getSrc();
  5.     Address dest=msg.getDest();
  6.     if(!isLocal(dest)) {
  7.       if(log.isWarnEnabled())
  8.         log.warn("[" + local_addr + "] dest=" + dest + " is not local (site=" + this.site + "); discarding it");
  9.       return;
  10.     }
  11.     // set myself to be the sender
  12.     msg.setSrc(local_addr);
  13.     // later, in RELAY, we'll take the original sender from the header and make it the sender
  14.     msg.putHeader(id, RelayHeader.createDisseminateHeader(sender));
  15.     if(log.isTraceEnabled())
  16.       log.trace("received msg from " + sender + ", passing down the stack with dest=" +
  17.             msg.getDest() + " and src=" + msg.getSrc());
  18.     down_prot.down(msg);
  19.   }
  20.   catch(Exception e) {
  21.     log.error(Util.getMessage("FailedSendingOnLocalCluster"), e);
  22.   }
  23. }

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

  1. public static <T extends Streamable> T streamableFromByteBuffer(Supplier<T> factory, byte[] buffer) throws Exception {
  2.   return streamableFromByteBuffer(factory, buffer, 0, buffer.length);
  3. }

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

  1. public static <T extends Streamable> T streamableFromByteBuffer(Class<? extends Streamable> cl,byte[] buffer) throws Exception {
  2.   return streamableFromByteBuffer(cl,buffer,0,buffer.length);
  3. }

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

  1. protected static PingData deserialize(final byte[] data) throws Exception {
  2.   return Util.streamableFromByteBuffer(PingData::new, data);
  3. }

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

  1. DrawCommand comm=Util.streamableFromByteBuffer(DrawCommand::new, buf, offset, length);
  2. switch(comm.mode) {
  3.   case DrawCommand.DRAW:

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

  1. public void receive(Message msg) {
  2.   byte[] buf=msg.getRawBuffer();
  3.   DrawCommand comm=null;
  4.   try {
  5.     comm=(DrawCommand)Util.streamableFromByteBuffer(DrawCommand.class, buf, msg.getOffset(), msg.getLength());
  6.     switch(comm.mode) {
  7.       case DrawCommand.DRAW:
  8.         if(panel != null)
  9.           panel.drawPoint(comm);
  10.         break;
  11.       case DrawCommand.CLEAR:
  12.         clearPanel();
  13.         break;
  14.       default:
  15.         System.err.println("***** Draw2Channels.run(): received invalid draw command " + comm.mode);
  16.         break;
  17.     }
  18.   }
  19.   catch(Exception ex) {
  20.     ex.printStackTrace();
  21.   }
  22. }

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

  1. public void receive(Message msg) {
  2.   byte[] buf=msg.getRawBuffer();
  3.   if(buf == null) {
  4.     System.err.println("received null buffer from " + msg.getSrc() + ", headers: " + msg.printHeaders());
  5.     return;
  6.   }
  7.   try {
  8.     DrawCommand comm=(DrawCommand)Util.streamableFromByteBuffer(DrawCommand.class, buf, msg.getOffset(), msg.getLength());
  9.     switch(comm.mode) {
  10.       case DrawCommand.DRAW:
  11.         if(panel != null)
  12.           panel.drawPoint(comm);
  13.         break;
  14.       case DrawCommand.CLEAR:
  15.         clearPanel();
  16.         break;
  17.       default:
  18.         System.err.println("***** received invalid draw command " + comm.mode);
  19.         break;
  20.     }
  21.   }
  22.   catch(Exception e) {
  23.     e.printStackTrace();
  24.   }
  25. }

代码示例来源：origin: org.integratedmodelling/klab-common

  1. public void receive(Message msg) {
  2.   byte[] buf=msg.getRawBuffer();
  3.   if(buf == null) {
  4.     System.err.println("[" + channel.getAddress() + "] received null buffer from " + msg.getSrc() +
  5.         ", headers: " + msg.printHeaders());
  6.     return;
  7.   }
  8.   try {
  9.     DrawCommand comm=(DrawCommand)Util.streamableFromByteBuffer(DrawCommand.class, buf, msg.getOffset(), msg.getLength());
  10.     switch(comm.mode) {
  11.       case DrawCommand.DRAW:
  12.         if(panel != null)
  13.           panel.drawPoint(comm);
  14.         break;
  15.       case DrawCommand.CLEAR:
  16.         clearPanel();
  17.         break;
  18.       default:
  19.         System.err.println("***** received invalid draw command " + comm.mode);
  20.         break;
  21.     }
  22.   }
  23.   catch(Exception e) {
  24.     e.printStackTrace();
  25.   }
  26. }

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

  1. public void receive(Message msg) {
  2.   byte[] buf=msg.getRawBuffer();
  3.   if(buf == null) {
  4.     System.err.printf("%s: received null buffer from %s, headers: %s\n", channel.getAddress(), msg.src(), msg.printHeaders());
  5.     return;
  6.   }
  7.   try {
  8.     DrawCommand comm=Util.streamableFromByteBuffer(DrawCommand::new, buf, msg.getOffset(), msg.getLength());
  9.     switch(comm.mode) {
  10.       case DrawCommand.DRAW:
  11.         if(panel != null)
  12.           panel.drawPoint(comm);
  13.         break;
  14.       case DrawCommand.CLEAR:
  15.         clearPanel();
  16.         break;
  17.       default:
  18.         System.err.println("***** received invalid draw command " + comm.mode);
  19.         break;
  20.     }
  21.   }
  22.   catch(Exception e) {
  23.     e.printStackTrace();
  24.   }
  25. }

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

  1. private static Message _decrypt(Cipher cipher, Message msg, boolean decrypt_entire_msg) throws Exception {
  2.   if(!decrypt_entire_msg) {
  3.     msg.setBuffer(cipher.doFinal(msg.getRawBuffer(), msg.getOffset(), msg.getLength()));
  4.     return msg;
  5.   }
  6.   byte[] decrypted_msg=cipher.doFinal(msg.getRawBuffer(), msg.getOffset(), msg.getLength());
  7.   Message ret=(Message)Util.streamableFromByteBuffer(Message.class, decrypted_msg);
  8.   if(ret.getDest() == null)
  9.     ret.setDest(msg.getDest());
  10.   if(ret.getSrc() == null)
  11.     ret.setSrc(msg.getSrc());
  12.   return ret;
  13. }

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

  1. protected Object installView(byte[] buf, int offset, int length) {
  2.   try {
  3.     ViewData data=Util.streamableFromByteBuffer(ViewData::new, buf, offset, length);
  4.     if(data.uuids != null)
  5.       NameCache.add(data.uuids);
  6.     remote_view=data.remote_view;
  7.     if(global_view == null || (data.global_view != null &&!global_view.equals(data.global_view))) {
  8.       global_view=data.global_view;
  9.       synchronized(this) {
  10.         if(data.global_view.getViewId().getId() > global_view_id)
  11.           global_view_id=data.global_view.getViewId().getId();
  12.       }
  13.       if(present_global_views)
  14.         return up_prot.up(new Event(Event.VIEW_CHANGE, global_view));
  15.     }
  16.   }
  17.   catch(Exception e) {
  18.     log.error(Util.getMessage("FailedInstallingView"), e);
  19.   }
  20.   return null;
  21. }

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

  1. case VIEW:
  2.   try {
  3.     ViewData data=Util.streamableFromByteBuffer(ViewData::new, msg.getRawBuffer(),
  4.                           msg.getOffset(), msg.getLength());

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

  1. protected void sendOnLocalCluster(byte[] buf, int offset, int length) {
  2.   try {
  3.     Message msg=Util.streamableFromByteBuffer(Message::new, buf, offset, length);
  4.     Address sender=msg.getSrc();
  5.     Address dest=msg.getDest();
  6.     if(!isLocal(dest)) {
  7.       if(log.isWarnEnabled())
  8.         log.warn("[" + local_addr + "] dest=" + dest + " is not local (site=" + this.site + "); discarding it");
  9.       return;
  10.     }
  11.     // set myself to be the sender
  12.     msg.setSrc(local_addr);
  13.     // later, in RELAY, we'll take the original sender from the header and make it the sender
  14.     msg.putHeader(id, RelayHeader.createDisseminateHeader(sender));
  15.     if(log.isTraceEnabled())
  16.       log.trace("received msg from " + sender + ", passing down the stack with dest=" +
  17.             msg.getDest() + " and src=" + msg.getSrc());
  18.     down_prot.down(msg);
  19.   }
  20.   catch(Exception e) {
  21.     log.error(Util.getMessage("FailedSendingOnLocalCluster"), e);
  22.   }
  23. }

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

Util

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    Util类方法

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