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

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

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

Util.writeAddress介绍

[英]Writes a list of Addresses. Can contain 65K addresses at most
[中]写一个地址列表。最多可包含65K个地址

代码示例

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

public void writeTo(DataOutput out) throws Exception {
  out.writeByte(type);
  Util.writeAddress(final_dest, out);
  Util.writeAddress(original_sender, out);
}

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

public void writeTo(DataOutput out) throws Exception {
  out.writeByte(type);
  Util.writeAddresses(mbrs, out);
  Util.writeAddress(from, out);
}

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

@Override
public void write(DataOutput output, Address address) throws IOException {
  // Awkward exception handling due to JGRP-2242
  try {
    org.jgroups.util.Util.writeAddress(address, output);
  } catch (IOException e) {
    throw e;
  } catch (Exception e) {
    throw new IOException(e);
  }
}

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

public void writeTo(DataOutput outstream) throws Exception {
  Util.writeAddress(sender, outstream);
  outstream.writeByte(flags);
  Bits.writeString(logical_name,outstream);
  Util.writeAddress(physical_addr,outstream);
  Util.writeAddresses(mbrs, outstream);
}

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

public void writeTo(DataOutput out) throws Exception {
  out.writeShort(type);
  Util.writeAddress(from, out);
}

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

public void writeTo(DataOutput out) throws Exception {
  Util.writeAddress(initiator, out);
  out.writeInt(id);
}

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

public static void writeAddresses(final Address[] addrs,DataOutput out) throws Exception {
  if(addrs == null) {
    out.writeShort(-1);
    return;
  }
  out.writeShort(addrs.length);
  for(Address addr : addrs)
    Util.writeAddress(addr,out);
}

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

public void writeTo(DataOutput out) throws Exception {
  Util.writeAddress(logical_addr, out);
  Util.writeAddress(physical_addr, out);
  Bits.writeString(logical_name,out);
}

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

public static void writeMessageListHeader(Address dest, Address src, byte[] cluster_name, int numMsgs, DataOutput dos, boolean multicast) throws Exception {
  dos.writeShort(Version.version);
  byte flags=LIST;
  if(multicast)
    flags+=MULTICAST;
  dos.writeByte(flags);
  Util.writeAddress(dest, dos);
  Util.writeAddress(src, dos);
  dos.writeShort(cluster_name != null? cluster_name.length : -1);
  if(cluster_name != null)
    dos.write(cluster_name);
  dos.writeInt(numMsgs);
}

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

public void writeTo(DataOutput out) throws Exception {
  out.writeByte(type);
  Util.writeAddress(mbr, out);
  Util.writeStreamable(sock_addr, out);
  int size=mbrs != null? mbrs.size() : 0;
  out.writeInt(size);
  if(size > 0)
    for(Address address: mbrs)
      Util.writeAddress(address, out);
}

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

@Override
public void writeTo(DataOutput out) throws Exception {
  Util.writeAddress(address, out);
  Bits.writeLong(id, out);
}

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

public void writeTo(DataOutput out) throws Exception {
  out.writeByte(type.ordinal());
  switch(type) {
    case DISSEMINATE:
      Util.writeAddress(original_sender, out);
      break;
    case FORWARD:
    case VIEW:
    case BROADCAST_VIEW:
      break;
  }
}

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

public void writeTo(DataOutput out) throws Exception {
  Util.writeAddress(creator, out);
  Bits.writeLong(id,out);
}

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

public void writeTo(DataOutput out) throws Exception {
  Util.writeAddress(address, out);
  Bits.writeLong(thread_id, out);
}

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

public void writeTo(DataOutput out) throws Exception {
  out.writeByte(type);
  switch(type) {
    case MSG:
    case XMIT_RSP:
    case HIGHEST_SEQNO:
      Bits.writeLong(seqno, out);
      break;
    case XMIT_REQ:
      Util.writeAddress(sender, out);
      break;
  }
}

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

public void writeTo(DataOutput out) throws Exception {
  Util.writeView(remote_view, out);
  Util.writeView(global_view, out);
  out.writeInt(uuids.size());
  for(Map.Entry<Address,String> entry: uuids.entrySet()) {
    Util.writeAddress(entry.getKey(), out);
    out.writeUTF(entry.getValue());
  }
}

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

public void writeTo(DataOutput out) throws Exception {
  out.writeByte(type);
  short flags=determineFlags();
  out.writeShort(flags);
  Util.writeAddress(mbr, out);
  if(merge_id != null)
    merge_id.writeTo(out);
}

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

public void writeTo(DataOutput out) throws Exception {
  out.writeShort(type.ordinal());
  Util.writeAddress(addr, out);
  Bits.writeString(name, out);
}

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

public void writeTo(DataOutput out) throws Exception {
  out.writeByte(type.ordinal());
  Bits.writeString(lock_name,out);
  out.writeInt(lock_id);
  Util.writeStreamable(owner, out);
  out.writeLong(timeout);
  out.writeBoolean(is_trylock);
  Util.writeStreamable(info_rsp, out);
  Util.writeAddress(sender, out);
}

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

public void writeTo(DataOutput outstream) throws Exception {
  outstream.writeByte(type.ordinal()); // a byte if ok as we only have 3 types anyway
  Util.writeViewId(view_id,outstream);
  Bits.writeString(logical_name,outstream);
  Util.writeAddress(physical_addr, outstream);
}

相关文章

Util类方法