* Opens an input stream reading the file (read only)
     *
     * @param sharing
     *            flags indicating for which operations others may open the file (FILE_SHARING_*)
     *
     * @return input stream, needs to be closed when finished
     * @throws CIFSException if an error occurs accessing the resource
     */
    InputStream openInputStream(int sharing) throws CIFSException;

    /**

            this.throwOnCloseInternal = true;
            return this;
        }

        @Override
        protected FileEntry open() throws CIFSException {
            if (staticThrowOnOpen)
                throw new CIFSException("open fail");
            // Simulate fetching first page during open
            if (staticPages != null && !staticPages.isEmpty()) {
                pageIdx = 0;
            }

the key was too small, but at any rate it would not open any of
them.  However, on the second time round, she came upon a low
curtain she had not noticed before, and behind it was a little
door about fifteen inches high:  she tried the little golden key
in the lock, and to her great delight it fitted!

  Alice opened the door and found that it led into a small

      return "Files.asByteSource(" + file + ")";
    }
  }

  /**
   * Returns a new {@link ByteSink} for writing bytes to the given file. The given {@code modes}
   * control how the file is opened for writing. When no mode is provided, the file will be
   * truncated before writing. When the {@link FileWriteMode#APPEND APPEND} mode is provided, writes
   * will append to the end of the file without truncating it.
   *

   * - Both request discover no existing connection. They both make a connection.
   * - The first request "wins the race".
   * - The second request discovers it "lost the race" and closes the connection it just opened.
   * - The second request uses the coalesced connection from request1.
   * - The coalesced connection is violently closed after servicing the first request.

//
// This code is similar in spirit to io.Copy but it is only to be
// used with DIRECT I/O based file descriptor and it is expected that
// input writer *os.File not a generic io.Writer. Make sure to have
// the file opened for writes with syscall.O_DIRECT flag.
func CopyAligned(w io.Writer, r io.Reader, alignedBuf []byte, totalSize int64, file *os.File) (int64, error) {
	if totalSize == 0 {
		return 0, nil
	}

	var written int64

                        logger.info("Opened index: {}", docIndex);
                        coordinator.completeOperation("reload_doc_index");
                    }, e -> {
                        logger.warn("Failed to open index: {}", docIndex, e);
                        coordinator.completeOperation("reload_doc_index");
                    }));

         */
        public ProcessFileDescriptorObj() {
            // Default constructor
        }

        /** Number of currently open file descriptors. */
        public long open;
        /** Maximum number of file descriptors that can be opened. */
        public long max;
    }

    /**
     * Data transfer object representing process CPU statistics.
     */

version of Elasticsearch](https://www.elastic.co/downloads/elasticsearch) - your issue may already have been fixed. If not, search our [issues list](https://github.com/elastic/elasticsearch/issues) on GitHub in case a similar issue has already been opened.

It is very helpful if you can prepare a reproduction of the bug. In other words, provide a small test case which we can run to confirm your bug. It makes it easier to find the problem and to fix it. Test cases should be provided as `curl`...

the key was too small, but at any rate it would not open any of
them.  However, on the second time round, she came upon a low
curtain she had not noticed before, and behind it was a little
door about fifteen inches high:  she tried the little golden key
in the lock, and to her great delight it fitted!

  Alice opened the door and found that it led into a small