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

XByteBuffer.createDataPackage介绍

[英]Creates a complete data package
[中]创建一个完整的数据包

代码示例

代码示例来源：origin: org.apache.catalina.springsource/com.springsource.org.apache.catalina.tribes.springsource

public static byte[] createDataPackage(byte[] data) {
  int length = getDataPackageLength(data.length);
  byte[] result = new byte[length];
  return createDataPackage(data,0,data.length,result,0);
}

代码示例来源：origin: codefollower/Tomcat-Research

public static byte[] createDataPackage(byte[] data) {
  int length = getDataPackageLength(data.length);
  byte[] result = new byte[length];
  return createDataPackage(data,0,data.length,result,0);
}

代码示例来源：origin: org.apache.tomcat/tomcat-tribes

public static byte[] createDataPackage(byte[] data) {
  int length = getDataPackageLength(data.length);
  byte[] result = new byte[length];
  return createDataPackage(data,0,data.length,result,0);
}

代码示例来源：origin: org.apache.geronimo.ext.tomcat/tribes

public static byte[] createDataPackage(byte[] data) {
  int length = getDataPackageLength(data.length);
  byte[] result = new byte[length];
  return createDataPackage(data,0,data.length,result,0);
}

代码示例来源：origin: codefollower/Tomcat-Research

@Override
public void broadcast(ChannelMessage message) throws ChannelException {
  if (impl==null || (impl.startLevel & Channel.MBR_TX_SEQ)!=Channel.MBR_TX_SEQ )
    throw new ChannelException("Multicast send is not started or enabled.");
  byte[] data = XByteBuffer.createDataPackage((ChannelData)message);
  if (data.length>McastServiceImpl.MAX_PACKET_SIZE) {
    throw new ChannelException("Packet length["+data.length+"] exceeds max packet size of "+McastServiceImpl.MAX_PACKET_SIZE+" bytes.");
  }
  DatagramPacket packet = new DatagramPacket(data,0,data.length);
  try {
    impl.send(false, packet);
  } catch (Exception x) {
    throw new ChannelException(x);
  }
}

代码示例来源：origin: org.apache.geronimo.ext.tomcat/tribes

@Override
public void broadcast(ChannelMessage message) throws ChannelException {
  if (impl==null || (impl.startLevel & Channel.MBR_TX_SEQ)!=Channel.MBR_TX_SEQ )
    throw new ChannelException("Multicast send is not started or enabled.");
  
  byte[] data = XByteBuffer.createDataPackage((ChannelData)message);
  if (data.length>McastServiceImpl.MAX_PACKET_SIZE) {
    throw new ChannelException("Packet length["+data.length+"] exceeds max packet size of "+McastServiceImpl.MAX_PACKET_SIZE+" bytes.");
  }
  DatagramPacket packet = new DatagramPacket(data,0,data.length);
  try {
    impl.send(false, packet);
  } catch (Exception x) {
    throw new ChannelException(x);
  }
}

代码示例来源：origin: org.apache.tomcat/tomcat-tribes

@Override
public void broadcast(ChannelMessage message) throws ChannelException {
  if (impl==null || (impl.startLevel & Channel.MBR_TX_SEQ)!=Channel.MBR_TX_SEQ )
    throw new ChannelException(sm.getString("mcastService.noStart"));
  byte[] data = XByteBuffer.createDataPackage((ChannelData)message);
  if (data.length>McastServiceImpl.MAX_PACKET_SIZE) {
    throw new ChannelException(sm.getString("mcastService.exceed.maxPacketSize",
        Integer.toString(data.length) ,
        Integer.toString(McastServiceImpl.MAX_PACKET_SIZE)));
  }
  DatagramPacket packet = new DatagramPacket(data,0,data.length);
  try {
    impl.send(false, packet);
  } catch (Exception x) {
    throw new ChannelException(x);
  }
}

代码示例来源：origin: org.apache.geronimo.ext.tomcat/tribes

else options = (options & (~Channel.SEND_OPTIONS_USE_ACK));
data.setOptions(options);
byte[] message = XByteBuffer.createDataPackage(data);
socket.getOutputStream().write(message);
if ( readTest ) {

代码示例来源：origin: codefollower/Tomcat-Research

else options = (options & (~Channel.SEND_OPTIONS_USE_ACK));
data.setOptions(options);
byte[] message = XByteBuffer.createDataPackage(data);
socket.getOutputStream().write(message);
if ( readTest ) {

代码示例来源：origin: org.apache.catalina.springsource/com.springsource.org.apache.catalina.tribes.springsource

else options = (options & (~Channel.SEND_OPTIONS_USE_ACK));
data.setOptions(options);
byte[] message = XByteBuffer.createDataPackage(data);
socket.getOutputStream().write(message);
if ( readTest ) {

代码示例来源：origin: org.apache.tomcat/tomcat-tribes

else options = (options & (~Channel.SEND_OPTIONS_USE_ACK));
data.setOptions(options);
byte[] message = XByteBuffer.createDataPackage(data);
socket.getOutputStream().write(message);
if ( readTest ) {

代码示例来源：origin: org.apache.geronimo.ext.tomcat/tribes

@Override
public synchronized void sendMessage(Member[] destination, ChannelMessage msg) throws ChannelException {
  byte[] data = XByteBuffer.createDataPackage((ChannelData)msg);
  BioSender[] senders = setupForSend(destination);
  ChannelException cx = null;
  for ( int i=0; i<senders.length; i++ ) {
    try {
      senders[i].sendMessage(data,(msg.getOptions()&Channel.SEND_OPTIONS_USE_ACK)==Channel.SEND_OPTIONS_USE_ACK);
    } catch (Exception x) {
      if (cx == null) cx = new ChannelException(x);
      cx.addFaultyMember(destination[i],x);
    }
  }
  if (cx!=null ) throw cx;
}

代码示例来源：origin: org.apache.catalina.springsource/com.springsource.org.apache.catalina.tribes.springsource

public synchronized void sendMessage(Member[] destination, ChannelMessage msg) throws ChannelException {
  byte[] data = XByteBuffer.createDataPackage((ChannelData)msg);
  BioSender[] senders = setupForSend(destination);
  ChannelException cx = null;
  for ( int i=0; i<senders.length; i++ ) {
    try {
      senders[i].sendMessage(data,(msg.getOptions()&Channel.SEND_OPTIONS_USE_ACK)==Channel.SEND_OPTIONS_USE_ACK);
    } catch (Exception x) {
      if (cx == null) cx = new ChannelException(x);
      cx.addFaultyMember(destination[i],x);
    }
  }
  if (cx!=null ) throw cx;
}

代码示例来源：origin: codefollower/Tomcat-Research

@Override
public synchronized void sendMessage(Member[] destination, ChannelMessage msg) throws ChannelException {
  byte[] data = XByteBuffer.createDataPackage((ChannelData)msg);
  BioSender[] senders = setupForSend(destination);
  ChannelException cx = null;
  for ( int i=0; i<senders.length; i++ ) {
    try {
      senders[i].sendMessage(data,(msg.getOptions()&Channel.SEND_OPTIONS_USE_ACK)==Channel.SEND_OPTIONS_USE_ACK);
    } catch (Exception x) {
      if (cx == null) cx = new ChannelException(x);
      cx.addFaultyMember(destination[i],x);
    }
  }
  if (cx!=null ) throw cx;
}

代码示例来源：origin: org.apache.tomcat/tomcat-tribes

@Override
public synchronized void sendMessage(Member[] destination, ChannelMessage msg) throws ChannelException {
  byte[] data = XByteBuffer.createDataPackage((ChannelData)msg);
  BioSender[] senders = setupForSend(destination);
  ChannelException cx = null;
  for ( int i=0; i<senders.length; i++ ) {
    try {
      senders[i].sendMessage(data,(msg.getOptions()&Channel.SEND_OPTIONS_USE_ACK)==Channel.SEND_OPTIONS_USE_ACK);
    } catch (Exception x) {
      if (cx == null) cx = new ChannelException(x);
      cx.addFaultyMember(destination[i],x);
    }
  }
  if (cx!=null ) throw cx;
}

代码示例来源：origin: org.apache.tomcat/tomcat-tribes

long start = System.currentTimeMillis();
this.setUdpBased((msg.getOptions()&Channel.SEND_OPTIONS_UDP) == Channel.SEND_OPTIONS_UDP);
byte[] data = XByteBuffer.createDataPackage((ChannelData)msg);
NioSender[] senders = setupForSend(destination);
connect(senders);

代码示例来源：origin: org.apache.catalina.springsource/com.springsource.org.apache.catalina.tribes.springsource

public synchronized void sendMessage(Member[] destination, ChannelMessage msg) throws ChannelException {
  long start = System.currentTimeMillis();
  byte[] data = XByteBuffer.createDataPackage((ChannelData)msg);
  NioSender[] senders = setupForSend(destination);
  connect(senders);

代码示例来源：origin: org.apache.geronimo.ext.tomcat/tribes

long start = System.currentTimeMillis();
this.setUdpBased((msg.getOptions()&Channel.SEND_OPTIONS_UDP) == Channel.SEND_OPTIONS_UDP);
byte[] data = XByteBuffer.createDataPackage((ChannelData)msg);
NioSender[] senders = setupForSend(destination);
connect(senders);

代码示例来源：origin: codefollower/Tomcat-Research

long start = System.currentTimeMillis();
this.setUdpBased((msg.getOptions()&Channel.SEND_OPTIONS_UDP) == Channel.SEND_OPTIONS_UDP);
byte[] data = XByteBuffer.createDataPackage((ChannelData)msg);
NioSender[] senders = setupForSend(destination);
connect(senders);