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

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

本文整理了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

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

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

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

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

  1. @Override
  2. public void write(DataOutput output, Address address) throws IOException {
  3. // Awkward exception handling due to JGRP-2242
  4. try {
  5. org.jgroups.util.Util.writeAddress(address, output);
  6. } catch (IOException e) {
  7. throw e;
  8. } catch (Exception e) {
  9. throw new IOException(e);
  10. }
  11. }

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

  1. public void writeTo(DataOutput outstream) throws Exception {
  2. Util.writeAddress(sender, outstream);
  3. outstream.writeByte(flags);
  4. Bits.writeString(logical_name,outstream);
  5. Util.writeAddress(physical_addr,outstream);
  6. Util.writeAddresses(mbrs, outstream);
  7. }

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

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

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

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

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

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

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

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

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

  1. public static void writeMessageListHeader(Address dest, Address src, byte[] cluster_name, int numMsgs, DataOutput dos, boolean multicast) throws Exception {
  2. dos.writeShort(Version.version);
  3. byte flags=LIST;
  4. if(multicast)
  5. flags+=MULTICAST;
  6. dos.writeByte(flags);
  7. Util.writeAddress(dest, dos);
  8. Util.writeAddress(src, dos);
  9. dos.writeShort(cluster_name != null? cluster_name.length : -1);
  10. if(cluster_name != null)
  11. dos.write(cluster_name);
  12. dos.writeInt(numMsgs);
  13. }

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

  1. public void writeTo(DataOutput out) throws Exception {
  2. out.writeByte(type);
  3. Util.writeAddress(mbr, out);
  4. Util.writeStreamable(sock_addr, out);
  5. int size=mbrs != null? mbrs.size() : 0;
  6. out.writeInt(size);
  7. if(size > 0)
  8. for(Address address: mbrs)
  9. Util.writeAddress(address, out);
  10. }

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

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

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

  1. public void writeTo(DataOutput out) throws Exception {
  2. out.writeByte(type.ordinal());
  3. switch(type) {
  4. case DISSEMINATE:
  5. Util.writeAddress(original_sender, out);
  6. break;
  7. case FORWARD:
  8. case VIEW:
  9. case BROADCAST_VIEW:
  10. break;
  11. }
  12. }

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

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

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

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

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

  1. public void writeTo(DataOutput out) throws Exception {
  2. out.writeByte(type);
  3. switch(type) {
  4. case MSG:
  5. case XMIT_RSP:
  6. case HIGHEST_SEQNO:
  7. Bits.writeLong(seqno, out);
  8. break;
  9. case XMIT_REQ:
  10. Util.writeAddress(sender, out);
  11. break;
  12. }
  13. }

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

  1. public void writeTo(DataOutput out) throws Exception {
  2. Util.writeView(remote_view, out);
  3. Util.writeView(global_view, out);
  4. out.writeInt(uuids.size());
  5. for(Map.Entry<Address,String> entry: uuids.entrySet()) {
  6. Util.writeAddress(entry.getKey(), out);
  7. out.writeUTF(entry.getValue());
  8. }
  9. }

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

  1. public void writeTo(DataOutput out) throws Exception {
  2. out.writeByte(type);
  3. short flags=determineFlags();
  4. out.writeShort(flags);
  5. Util.writeAddress(mbr, out);
  6. if(merge_id != null)
  7. merge_id.writeTo(out);
  8. }

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

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

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

  1. public void writeTo(DataOutput out) throws Exception {
  2. out.writeByte(type.ordinal());
  3. Bits.writeString(lock_name,out);
  4. out.writeInt(lock_id);
  5. Util.writeStreamable(owner, out);
  6. out.writeLong(timeout);
  7. out.writeBoolean(is_trylock);
  8. Util.writeStreamable(info_rsp, out);
  9. Util.writeAddress(sender, out);
  10. }

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

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

相关文章

Util类方法