return (int) (this.fp - start);
        } catch (final CIFSException e) {
            throw SmbException.wrap(e);
        }
    }

    @Override
    public final void readFully(final byte b[]) throws SmbException {
        readFully(b, 0, b.length);
    }

    @Override
    public final void readFully(final byte b[], final int off, final int len) throws SmbException {
        int n = 0, count;

    protected String replaceHighlightQueries(final String cache, final String[] queries) {
        final StringBuffer buf = new StringBuffer(cache.length() + 100);
        final StringBuffer segBuf = new StringBuffer(1000);
        final Pattern p = Pattern.compile("<[^>]+>");
        final Matcher m = p.matcher(cache);
        final String[] regexQueries = new String[queries.length];
        final String[] hlQueries = new String[queries.length];

        return getHeaderFields0();
    }

    @Override
    public int getHeaderFieldInt(final String header, final int def) {
        handshake();
        return this.connection.getHeaderFieldInt(header, def);
    }

    @Override
    public long getHeaderFieldDate(final String header, final long def) {
        handshake();
        return this.connection.getHeaderFieldDate(header, def);
    }

        }
    }

    @Test
    void testPerformProfileActivation() throws ParseException {
        final CommandLineParser parser = new DefaultParser();

        final Options options = new Options();
        options.addOption(Option.builder(Character.toString(CLIManager.ACTIVATE_PROFILES))
                .hasArg()
                .build());

     */
    public ChatResult chat(final String sessionId, final String userMessage, final String userId, final Map<String, String[]> fields,
            final String[] extraQueries) {
        final Map<String, String[]> safeFields = fields != null ? fields : Collections.emptyMap();
        final String[] safeExtraQueries = extraQueries != null ? extraQueries : new String[0];
        final long startTime = System.currentTimeMillis();

            // any circumstances
            assertEquals(3, MoreFiles.listFiles(symlinkTarget).size());

            Thread.yield();
          }
        } finally {
          executor.shutdownNow();
        }

        switcher.get(); // to check for (extremely unlikely) exceptions
      }
    }
  }

          if (e == null) {
            break; // we already waited enough, and there are no more elements in sight
          }
          buffer.add(e);
          added++;
        }
      }
    } finally {
      if (interrupted) {
        Thread.currentThread().interrupt();
      }
    }
    return added;
  }

  /**

        }

        return ":" + firstFailedProject.getArtifactId();
    }

    protected static final Pattern NEXT_LINE = Pattern.compile("\r?\n");

    protected static final Pattern LAST_ANSI_SEQUENCE = Pattern.compile("(\u001B\\[[;\\d]*[ -/]*[@-~])[^\u001B]*$");

    protected static final String ANSI_RESET = "\u001B\u005Bm";

    protected void logSummary(

    }

    private void setupMockComponents(final List<Map<String, Object>> documents) {
        final SearchEngineClient searchEngineClient = new SearchEngineClient() {
            @Override
            public long scrollSearch(final String index, final SearchCondition<org.opensearch.action.search.SearchRequestBuilder> condition,
                    final BooleanFunction<Map<String, Object>> cursor) {
                long count = 0;

            final T response, final RequestParam... params) throws CIFSException {
        return send(loc, request, response,
                params.length == 0 ? EnumSet.noneOf(RequestParam.class) : EnumSet.copyOf(Arrays.asList(params)));
    }