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

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

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

Util.printBytes介绍

[英]MByte nowadays doesn't mean 1024 * 1024 bytes, but 1 million bytes, see http://en.wikipedia.org/wiki/Megabyte
[中]MByte现在并不意味着1024*1024字节，而是100万字节，参见http://en.wikipedia.org/wiki/Megabyte

代码示例

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

  1. protected static String computeStats(long time, long msgs, int size) {
  2.   double msgs_sec, throughput=0;
  3.   msgs_sec=msgs / (time/1000.0);
  4.   throughput=(msgs * size) / (time / 1000.0);
  5.   return String.format("%,d msgs, %s received, time=%,d ms, msgs/sec=%,.2f, throughput=%s",
  6.              msgs, Util.printBytes(msgs * size), time, msgs_sec, Util.printBytes(throughput));
  7. }

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

  1. public String toString() {
  2.   if(buffer != null)
  3.     return Util.printBytes(buffer.length);
  4.   else if(exception != null)
  5.     return exception.toString();
  6.   return "OK";
  7. }

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

  1. protected static String computeStats(long time, long msgs, int size) {
  2.   StringBuilder sb=new StringBuilder();
  3.   double msgs_sec, throughput=0;
  4.   msgs_sec=msgs / (time/1000.0);
  5.   throughput=(msgs * size) / (time / 1000.0);
  6.   sb.append(msgs).append(" msgs, ");
  7.   sb.append(Util.printBytes(msgs * size)).append(" received");
  8.   sb.append(", time=").append(format.format(time)).append("ms");
  9.   sb.append(", rpcs/sec=").append(format.format(msgs_sec));
  10.   sb.append(", throughput=").append(Util.printBytes(throughput));
  11.   return sb.toString();
  12. }

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

  1. protected void handleData() {
  2.   if(last_interval == 0)
  3.     last_interval=System.currentTimeMillis();
  4.   total_received_msgs.increment();
  5.   long received_so_far=total_received_msgs.sum();
  6.   if(received_so_far % receive_log_interval == 0) {
  7.     long curr_time=System.currentTimeMillis();
  8.     long diff=curr_time - last_interval;
  9.     double msgs_sec=receive_log_interval / (diff / 1000.0);
  10.     double throughput=msgs_sec * msg_size;
  11.     last_interval=curr_time;
  12.     System.out.println(String.format("-- received %d msgs %d ms, %.2f msgs/sec, %s / sec)",
  13.                      received_so_far, diff, msgs_sec, Util.printBytes(throughput)));
  14.   }
  15. }

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

  1. public String toString() {
  2.   boolean is_file=Util.isFlagSet(flags, FILE);
  3.   StringBuilder sb=new StringBuilder();
  4.   sb.append(getType());
  5.   if(is_file)
  6.     sb.append(", len=" + Util.printBytes(length) + ", chunk_size=" + chunk_size);
  7.   sb.append(", mod_time=" + new Date(modification_time));
  8.   return sb.toString();
  9. }

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

  1. public void setState(InputStream istream) throws Exception {
  2.   total_received=0;
  3.   int received=0;
  4.   while(true) {
  5.     byte[] buf=new byte[10000];
  6.     received=istream.read(buf);
  7.     if(received < 0)
  8.       break;
  9.     if(delay > 0)
  10.       Util.sleep(delay);
  11.     total_received+=received;
  12.     if(requester_fails)
  13.       throw new Exception("booom - requester failed");
  14.   }
  15.   stop=System.currentTimeMillis();
  16.   System.out.println("<-- received " + Util.printBytes(total_received) + " in " + (stop-start) + "ms");
  17. }

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

  1. public void receiveData(long value, byte[] buffer) {
  2.   long diff=System.currentTimeMillis() - value;
  3.   total_req_time+=diff;
  4.   num_reqs++;
  5.   long new_val=current_value.incrementAndGet();
  6.   total_bytes.addAndGet(buffer.length);
  7.   if(print > 0 && new_val % print == 0)
  8.     System.out.println("received " + current_value);
  9.   if(new_val >= num_values) {
  10.     stop=System.currentTimeMillis();
  11.     long total_time=stop - start;
  12.     long msgs_per_sec=(long)(num_values / (total_time / 1000.0));
  13.     double throughput=total_bytes.get() / (total_time / 1000.0);
  14.     System.out.println("\n-- received " + num_values + " messages in " + total_time +
  15.         " ms (" + msgs_per_sec + " messages/sec, " + Util.printBytes(throughput) + " / sec)");
  16.     double time_per_req=(double)total_req_time / num_reqs;
  17.     System.out.println("received " + num_reqs + " requests in " + total_req_time + " ms, " + time_per_req +
  18.         " ms / req (only requests)\n");
  19.     started=false;
  20.     if(exit_on_end)
  21.       System.exit(0);
  22.   }
  23. }

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

  1. public void getState(OutputStream ostream) throws Exception {
  2.   int frag_size=size / 10;
  3.   long bytes=0;
  4.   for(int i=0; i < 10; i++) {
  5.     byte[] buf=new byte[frag_size];
  6.     ostream.write(buf);
  7.     bytes+=buf.length;
  8.     if(provider_fails)
  9.       throw new Exception("booom - provider failed");
  10.     if(delay > 0)
  11.       Util.sleep(delay);
  12.   }
  13.   int remaining=size - (10 * frag_size);
  14.   if(remaining > 0) {
  15.     byte[] buf=new byte[remaining];
  16.     ostream.write(buf);
  17.     bytes+=buf.length;
  18.   }
  19.   System.out.println("--> wrote " + Util.printBytes(bytes));
  20. }

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

  1. protected void handleData(Address src, long seqno, boolean check_order) {
  2.   Stats result=received_msgs.get(src);
  3.   if(result == null) {
  4.     result=new Stats();
  5.     Stats tmp=received_msgs.putIfAbsent(src,result);
  6.     if(tmp != null)
  7.       result=tmp;
  8.   }
  9.   result.addMessage(seqno, check_order);
  10.   if(last_interval == 0)
  11.     last_interval=System.currentTimeMillis();
  12.   long received_so_far=total_received_msgs.incrementAndGet();
  13.   if(received_so_far % receive_log_interval == 0) {
  14.     long curr_time=System.currentTimeMillis();
  15.     long diff=curr_time - last_interval;
  16.     double msgs_sec=receive_log_interval / (diff / 1000.0);
  17.     double throughput=msgs_sec * msg_size;
  18.     last_interval=curr_time;
  19.     System.out.printf("-- received %,d msgs (%,d ms, %,.2f msgs/sec, %s /sec)\n",
  20.              received_so_far, diff, msgs_sec, Util.printBytes(throughput));
  21.   }
  22. }

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

  1. private static String print(File file, boolean details, int indent) {
  2.   StringBuilder sb=new StringBuilder();
  3.   if(file.isDirectory()) {
  4.     if(details)
  5.       sb.append(indent(indent));
  6.     sb.append(file.getName()).append("/");
  7.   }
  8.   else {
  9.     if(details)
  10.       sb.append(indent(indent));
  11.     sb.append(file.getName());
  12.     if(details) {
  13.       sb.append(" " + Util.printBytes(file.length()));
  14.       if(file instanceof GridFile)
  15.         sb.append(", chunk_sise=" + ((GridFile)file).getChunkSize());
  16.     }
  17.   }
  18.   sb.append(details? '\n' : ' ');
  19.   return sb.toString();
  20. }

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

  1. public void handleData(Address src, byte[] payload, long seqno, boolean check_order) { // 0
  2.   int length=payload.length;
  3.   if(length == 0)
  4.     return;
  5.   Stats tmp_result=received_msgs.get(src);
  6.   if(tmp_result == null) {
  7.     tmp_result=new Stats();
  8.     Stats tmp=received_msgs.putIfAbsent(src,tmp_result);
  9.     if(tmp != null)
  10.       tmp_result=tmp;
  11.   }
  12.   tmp_result.addMessage(seqno,check_order);
  13.   if(last_interval == 0)
  14.     last_interval=System.currentTimeMillis();
  15.   long received_so_far=total_received_msgs.incrementAndGet();
  16.   if(received_so_far % receive_log_interval == 0) {
  17.     long curr_time=System.currentTimeMillis();
  18.     long diff=curr_time - last_interval;
  19.     double msgs_sec=receive_log_interval / (diff / 1000.0);
  20.     double throughput=msgs_sec * msg_size;
  21.     last_interval=curr_time;
  22.     System.out.println("-- received " + received_so_far + " rpcs " + "(" + diff + " ms, " +
  23.                format.format(msgs_sec) + " rpcs/sec, " + Util.printBytes(throughput) + "/sec)");
  24.   }
  25. }

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

  1. public Object up(Message msg) {
  2.   if(log.isTraceEnabled()) {
  3.     long size=raw_buffer? msg.getLength() : msg.size();
  4.     if(size >= min_size) {
  5.       StringBuilder sb=new StringBuilder(local_addr + ".up(): size of message buffer=");
  6.       sb.append(Util.printBytes(size)).append(", " + numHeaders(msg) + " headers");
  7.       if(print_msg)
  8.         sb.append(", headers=" + msg.printHeaders());
  9.       log.trace(sb);
  10.     }
  11.   }
  12.   return up_prot.up(msg);
  13. }

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

  1. public Object down(Message msg) {
  2.   if(log.isTraceEnabled()) {
  3.     long size=raw_buffer? msg.getLength() : msg.size();
  4.     if(size >= min_size) {
  5.       StringBuilder sb=new StringBuilder(local_addr + ".down(): size of message buffer=");
  6.       sb.append(Util.printBytes(size)).append(", " + numHeaders(msg) + " headers");
  7.       if(print_msg)
  8.         sb.append(", headers=" + msg.printHeaders());
  9.       log.trace(sb);
  10.     }
  11.   }
  12.   return down_prot.down(msg);
  13. }

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

  1. public void up(MessageBatch batch) {
  2.   if(log.isTraceEnabled()) {
  3.     long size=raw_buffer? batch.length() : batch.totalSize();
  4.     if(size >= min_size) {
  5.       StringBuilder sb=new StringBuilder(local_addr + ".up(): size of message batch=");
  6.       sb.append(Util.printBytes(size)).append(", " + batch.size() + " messages, " + numHeaders(batch) + " headers");
  7.       log.trace(sb);
  8.     }
  9.   }
  10.   up_prot.up(batch);
  11. }

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

  1. public String toString() {
  2.   return String.format("%s bytes left (queuing: %b, msg-queue size: %d, bytes: %s, enqueued: %d)",
  3.              super.toString(), isQueuing(), getQueuedMessages(), Util.printBytes(getQueuedMessageSize()), num_queued.intValue());
  4. }

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

  1. protected void setBufferSize(DatagramSocket sock, int send_buf_size, int recv_buf_size) {
  2.   try {
  3.     sock.setSendBufferSize(send_buf_size);
  4.     int actual_size=sock.getSendBufferSize();
  5.     if(actual_size < send_buf_size && log.isWarnEnabled()) {
  6.       log.warn(Util.getMessage("IncorrectBufferSize"), "send", sock.getClass().getSimpleName(),
  7.                    Util.printBytes(send_buf_size), Util.printBytes(actual_size), "send", "net.core.wmem_max");
  8.     }
  9.   }
  10.   catch(Throwable ex) {
  11.     log.warn(Util.getMessage("BufferSizeFailed"), "send", send_buf_size, sock, ex);
  12.   }
  13.   try {
  14.     sock.setReceiveBufferSize(recv_buf_size);
  15.     int actual_size=sock.getReceiveBufferSize();
  16.     if(actual_size < recv_buf_size && log.isWarnEnabled()) {
  17.       log.warn(Util.getMessage("IncorrectBufferSize"), "receive", sock.getClass().getSimpleName(),
  18.                    Util.printBytes(recv_buf_size), Util.printBytes(actual_size), "receive", "net.core.rmem_max");
  19.     }
  20.   }
  21.   catch(Throwable ex) {
  22.     log.warn(Util.getMessage("BufferSizeFailed"), "receive", recv_buf_size, sock, ex);
  23.   }
  24. }

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

  1. public String toString() {
  2.   return String.format("%s bytes left (queuing: %b, msg-queue size: %d, bytes: %s, enqueued: %d)",
  3.              super.toString(), isQueuing(), getQueuedMessages(), Util.printBytes(getQueuedMessageSize()), num_queued.intValue());
  4. }

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

  1. protected void handleStateChunk(Address sender, byte[] buffer, int offset, int length) {
  2.   if(buffer == null || input_stream == null)
  3.     return;
  4.   try {
  5.     if(log.isTraceEnabled())
  6.       log.trace("%s: received chunk of %s from %s",local_addr,Util.printBytes(length),sender);
  7.     input_stream.write(buffer, offset, length);
  8.   }
  9.   catch(IOException e) {
  10.     handleException(e);
  11.   }
  12. }

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

  1. protected void sendMessage(byte[] b, int off, int len) throws IOException {
  2.   Message m=new Message(stateRequester).putHeader(id, new StateHeader(StateHeader.STATE_PART));
  3.   // we're copying the buffer passed from the state provider here: if a BufferedOutputStream is used, the
  4.   // buffer (b) will always be the same and can be modified after it has been set in the message !
  5.   // Fix for https://issues.jboss.org/browse/JGRP-1598
  6.   byte[] data=new byte[len];
  7.   System.arraycopy(b, off, data, 0, len);
  8.   // m.setBuffer(b, off, len);
  9.   m.setBuffer(data);
  10.   bytesWrittenCounter+=len;
  11.   if(Thread.interrupted())
  12.     throw interrupted((int)bytesWrittenCounter);
  13.   down_prot.down(m);
  14.   if(log.isTraceEnabled())
  15.     log.trace("%s: sent chunk of %s to %s",local_addr,Util.printBytes(len),stateRequester);
  16. }

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

  1. protected void getStateFromApplication(Address requester, Digest digest) {
  2.   StateTransferInfo rsp=(StateTransferInfo)up_prot.up(new Event(Event.GET_APPLSTATE));
  3.   byte[] state=rsp.state;
  4.   if(stats) {
  5.     num_state_reqs.increment();
  6.     if(state != null)
  7.       num_bytes_sent.add(state.length);
  8.     avg_state_size=num_bytes_sent.doubleValue() / num_state_reqs.doubleValue();
  9.   }
  10.   Message state_rsp=new Message(requester, state).putHeader(this.id, new StateHeader(StateHeader.STATE_RSP, digest));
  11.   log.trace("%s: sending state to %s (size=%s)", local_addr, state_rsp.getDest(), Util.printBytes(state != null? state.length : 0));
  12.   down_prot.down(state_rsp);
  13. }

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

Util

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    Util类方法

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