socket.close()
      openClientSockets.remove(socket.javaNetSocket)
    }

    /**
     * Respond to `CONNECT` requests until a non-tunnel response is peeked. Returns true if further
     * calls should be attempted on the socket.
     */
    @Throws(IOException::class, InterruptedException::class)
    private fun processTunnelRequests(): Boolean {
      if (!dispatcher.peek().inTunnel) return true // No tunnel requests.

    return Synchronized.multimap(multimap, null);
  }

  /**
   * Returns an unmodifiable view of the specified multimap. Query operations on the returned
   * multimap "read through" to the specified multimap, and attempts to modify the returned
   * multimap, either directly or through the multimap's views, result in an {@code
   * UnsupportedOperationException}.
   *

  }

  private fun runWriter() {
    assertLockHeld()

    val writerTask = writerTask
    if (writerTask != null) {
      taskQueue.schedule(writerTask)
    }
  }

  /**
   * Attempts to remove a single frame from a queue and send it. This prefers to write urgent pongs
   * before less urgent messages and close frames. For example, it's possible that a caller will

                        return toRead;
                    });
                })) {

            lmhosts.populate(new StringReader(content), mockContext);

            // Verify include was attempted
            assertTrue(mockedConstruction.constructed().size() > 0);

            // Access the internal table to verify main entry was added
            Field tableField = Lmhosts.class.getDeclaredField("table");

If synchronous replication is configured above, replication is attempted right away prior to returning the PUT object response. In the event that the replication target is down, the `X-Amz-Replication-Status` is marked as `FAILED` and resynced with target when the scanner runs again.

- Sometimes, the scheduler incorrectly placed a pod in the "unschedulable" queue instead of the "backoff" queue. This happened when some plugin previously declared the pod as "unschedulable" and then in a later attempt encounters some other error. Scheduling of that pod then got delayed by up to five minutes, after which periodic flushing moved the pod back into the "active" queue. ([#120334](https://github.com/kubernetes/kubernetes/pull/120334), [@pohly](https...

   *
   * <p>The returned {@code BiMap} iterates over entries in the same order as the {@code entrySet}
   * of the original map.
   *
   * <p>Despite the method name, this method attempts to avoid actually copying the data when it is
   * safe to do so. The exact circumstances under which a copy will or will not be performed are
   * undocumented and subject to change.
   *

)

const (
	// TransitionComplete marks completed transition
	TransitionComplete = "complete"
	// TransitionPending - transition is yet to be attempted
	TransitionPending = "pending"
)

// Action represents a delete action or other transition
// actions that will be implemented later.
type Action int

//go:generate stringer -type Action $GOFILE

const (

            assertThrows(Exception.class, () -> {
                unicodeString.encode(mockNdrBuffer);
            }, "Should encounter issue with deferred buffer access");

            // Verify that basic encoding was attempted
            verify(mockNdrBuffer).align(4);
            verify(mockNdrBuffer).enc_ndr_short((short) 6);
            verify(mockNdrBuffer).enc_ndr_short((short) 10);

     */
    long getDurableHandleTimeout();

    /**
     * Property {@code jcifs.smb.client.handleReconnectRetries}, defaults to 3
     *
     * @return maximum number of retry attempts for handle reconnection
     */
    int getHandleReconnectRetries();

    /**
     * Enable SMB3 Multi-Channel support
     *
     * Property {@code jcifs.smb.client.useMultiChannel} (boolean, default true)