Class BatchBundler.Buffer

  • Enclosing class:
    BatchBundler

    protected class BatchBundler.Buffer
    extends java.lang.Object
    • Field Detail

      • msgs

        private final Message[] msgs
      • index

        private int index
      • closed

        private boolean closed
      • total_bytes

        private long total_bytes
    • Constructor Detail

      • Buffer

        protected Buffer​(Address address)
    • Method Detail

      • addMessage

        protected boolean addMessage​(Message msg)
      • sendBatch

        protected void sendBatch​(boolean due_to_timeout)
      • sendMessageList

        protected void sendMessageList​(Address dest,
                                       Address src,
                                       Message[] list,
                                       int length)
      • close

        protected void close()