}

            private String getFromCache(final String propertyKey) {
                try {
                    return cache.get(propertyKey,
                            () -> System.getProperty(Constants.FESS_CONFIG_PREFIX + propertyKey, super.get(propertyKey)));
                } catch (final ExecutionException e) {
                    return super.get(propertyKey);
                }
            }

        .build();

    Call call = client.newCall(new Request.Builder()
        .url(server.url("/"))
        .build());
    Response response = call.execute();
    System.out.println(response.handshake().tlsVersion());
  }

  public static void main(String... args) throws Exception {
    new HttpsServer().run();
  }

) : EventListener(),
  EventListener.Factory {
  private var startNs: Long? = null

  override fun create(call: Call): EventListener = this

  override fun callStart(call: Call) {
    startNs = System.nanoTime()

    logWithTime("callStart: ${call.request()}")

    delegate.callStart(call)
  }

  override fun proxySelectStart(
    call: Call,
    url: HttpUrl,
  ) {

        final int length = readUShort(src, index);
        final int offset = readULong(src, index + 4);
        final byte[] buffer = new byte[length];
        System.arraycopy(src, offset, buffer, 0, length);
        return buffer;
    }

    static void writeULong(final byte[] dest, final int offset, final int ulong) {
        dest[offset] = (byte) (ulong & 0xff);

    public static final int WITNESS_RESOURCE_STATE_UNAVAILABLE = 0x000000FF;

    /**
     * Creates a new empty witness notification.
     */
    public WitnessNotification() {
        this.timestamp = System.currentTimeMillis();
        this.newIPAddresses = new ArrayList<>();
        this.oldIPAddresses = new ArrayList<>();
        this.flags = WITNESS_RESOURCE_STATE_UNKNOWN;
    }

    /**

            System.arraycopy(password, 0, dst, dstIndex, passwordLength);
            dstIndex += passwordLength;
        } else {
            // no password in tree connect
            dst[dstIndex++] = (byte) 0x00;
        }
        dstIndex += writeString(path, dst, dstIndex);
        try {
            System.arraycopy(service.getBytes("ASCII"), 0, dst, dstIndex, service.length());

    public void init() throws IOException {
        /*
         * TODO if (initialized) { return; }
         *
         * if (tokenizerFactory == null) { final String path = System.getProperty(SuggestConstants.USER_DICT_PATH);
         * final String encoding = System.getProperty(SuggestConstants.USER_DICT_ENCODING); final Map<String, String>
         * args = new HashMap<>(); args.put("mode", "normal"); args.put("discardPunctuation", "false"); if

            byte[] buffer = new byte[256];
            int offset = 100;
            byte[] responseData = createValidCopyChunkResponse(10, 131072, 1310720);
            System.arraycopy(responseData, 0, buffer, offset, responseData.length);

            int bytesDecoded = response.decode(buffer, offset, responseData.length);

            assertEquals(12, bytesDecoded);

         */
        public LeaseEntry(Smb2LeaseKey key, String path, int state) {
            this.leaseKey = key;
            this.path = path;
            this.leaseState = state;
            this.createTime = System.currentTimeMillis();
            this.lastAccessTime = createTime;
            this.epoch = 1;
            this.breaking = false;
        }

        /**
         * Update the lease state
         *

 * governing permissions and limitations under the License.
 */
package org.codelibs.fess.job;

/**
 * Abstract base class for job executors that handle script execution within the job system.
 * This class provides a framework for executing scripts and managing shutdown operations.
 */
public abstract class JobExecutor {
    /** Listener to handle shutdown events */