assertEquals(baseUrl + "none", responseData.getUrl());
        }

        try {
            smbClient.doGet("");
            fail();
        } catch (final CrawlerSystemException e) {
            // nothing
        }
    }

    public void test_doHead() throws Exception {
        try (final ResponseData responseData = smbClient.doHead(baseUrl + "file1.txt")) {
            assertEquals(0, responseData.getStatus());

public class SuggestJob extends ExecJob {

    private static final Logger logger = LogManager.getLogger(SuggestJob.class);

    /**
     * Constructs a new suggest job.
     */
    public SuggestJob() {
        // do nothing
    }

    @Override
    public String execute() {
        final StringBuilder resultBuf = new StringBuilder();

        if (sessionId == null) { // create session id

        SmbFileHandleImpl result = stream.ensureOpen();
        assertSame(fd, result);
        verify(handle, times(1)).ensureOpen();
    }

    @Test
    @DisplayName("close() does nothing (no delegate interactions)")
    void close_isNoop() throws Exception {
        // Verify close() is a no-op and does not call handle/tree/fd
        SmbPipeInputStream stream = newStreamWithInit(true);

        String[] args = {"apply", "--plugins"};
        CommonsCliUpgradeOptions options = CommonsCliUpgradeOptions.parse(args);

        // Test that interpolation works (even though there's nothing to interpolate here)
        UpgradeOptions interpolated = (CommonsCliUpgradeOptions) options.interpolate(s -> s);

        assertTrue(interpolated.plugins().isPresent(), "Interpolated options should preserve --plugins");

      by You to the Licensor shall be under the terms and conditions of
      this License, without any additional terms or conditions.
      Notwithstanding the above, nothing herein shall supersede or modify
      the terms of any separate license agreement you may have executed
      with Licensor regarding such Contributions.

// inspection to understand the root cause. E.g, this could be due to
// backend filesystem corruption.

// listOnlineDisks - returns
// - a slice of disks where disk having 'older' xl.meta (or nothing)
// are set to nil.
// - latest (in time) of the maximally occurring modTime(s), which has at least quorum occurrences.

    }

    /**
     * Cleans up resources when the filter is destroyed.
     * Currently performs no cleanup operations.
     */
    @Override
    public void destroy() {
        // nothing
    }

        @Override
        public int getMaxReadingNum() {
            return 5;
        }

        @Override
        public void init() throws IOException {
            // Do nothing
        }

        @Override
        public List<String> convert(String text, String field, String... langs) throws IOException {
            if (text == null || text.isEmpty()) {

we are unable to deliver its IOException to the application. We would have told the application layer that the write succeeded, but it didn't!

The application-layer can also do blocking reads. If the application asks to read and there's nothing available, we need to hold that thread until either the bytes arrive, the stream is closed, or a timeout elapses. If we get bytes but there's nobody asking for them, we buffer them. We don't consider bytes as delivered for flow control until they're...

    Adapters.sequence(
      "AttributeTypeAndValue",
      Adapters.OBJECT_IDENTIFIER,
      Adapters.any(
        String::class to Adapters.UTF8_STRING,
        Nothing::class to Adapters.PRINTABLE_STRING,
        AnyValue::class to Adapters.ANY_VALUE,
      ),
      decompose = {
        listOf(
          it.type,
          it.value,
        )
      },