* specific language governing permissions and limitations
 * under the License.
 */
package org.apache.maven.settings;

import org.apache.maven.impl.SettingsUtilsV4;

/**
 * Several convenience methods to handle settings
 *
 */
public final class SettingsUtils {

    private SettingsUtils() {
        // don't allow construction.
    }

    /**
     * @param dominant
     * @param recessive

        // Act
        lookupSids = new MsrpcLookupSids(mockPolicyHandle, testSids);

        // Assert using reflection to verify superclass fields
        Field handleField = lsarpc.LsarLookupSids.class.getDeclaredField("handle");
        handleField.setAccessible(true);
        assertSame(mockPolicyHandle, handleField.get(lookupSids));

        Field countField = lsarpc.LsarLookupSids.class.getDeclaredField("count");

                }
                // Another thread changed the state, re-evaluate
                return state.get();
            }
        }

        return current;
    }

    /**
     * Handle successful call
     */
    private void onSuccess() {
        totalSuccesses.incrementAndGet();
        consecutiveFailures.set(0);

        State current = state.get();

      if (!response.isSuccessful) throw IOException("Unexpected code $response")

      println(response.body.string())
    }
  }
}

object ConsoleCallbackHandler : CallbackHandler {
  override fun handle(callbacks: Array<Callback>) {
    for (callback in callbacks) {
      if (callback is PasswordCallback) {
        val console = System.console()

        if (console != null) {

			return
		}

		atomic.AddInt32(&srv.requestCount, 1)
		defer atomic.AddInt32(&srv.requestCount, -1)

		// Handle request using passed handler.
		handler.ServeHTTP(w, r)
	})

	srv.listenerMutex.Lock()
	srv.Handler = wrappedHandler
	srv.listener = listener
	srv.listenerMutex.Unlock()

	var l net.Listener = listener
	if tlsConfig != nil {

    public static final int SMB2_LEASE_NONE           = 0x00;
    public static final int SMB2_LEASE_READ_CACHING   = 0x01;  // R - Read caching
    public static final int SMB2_LEASE_HANDLE_CACHING = 0x02;  // H - Handle caching  
    public static final int SMB2_LEASE_WRITE_CACHING  = 0x04;  // W - Write caching
    
    // Common combinations
    public static final int SMB2_LEASE_READ_HANDLE    = 0x03;  // RH

    //
    //        handle = DcerpcHandle.getHandle("ncacn_np:" +
    //                    UniAddress.getByName(dr[0].server).getHostAddress() +
    //                    "[\\PIPE\\netdfs]", auth);
    //        try {
    //            rpc = new MsrpcDfsRootEnum(domainName);
    //            handle.sendrecv(rpc);
    //            if (rpc.retval != 0)

      actions += { stream -> stream.sink.close() }
    }

  fun sleep(
    duration: Long,
    unit: TimeUnit,
  ) = apply {
    actions += { Thread.sleep(unit.toMillis(duration)) }
  }

  override fun handle(socket: Socket) {
    val task = serviceSocketTask(socket.asBufferedSocket())
    results.add(task)
    task.run()
  }

  /** Returns a task that processes both request and response from [socket]. */

        }
    }

    /**
     * Processes all thread information and sends it to the provided consumer.
     *
     * @param writer the consumer that will handle each line of thread dump output
     */
    public static void processThreadDump(final Consumer<String> writer) {
        for (final Map.Entry<Thread, StackTraceElement[]> entry : Thread.getAllStackTraces().entrySet()) {

        assertTrue(cause instanceof CIFSException);
        assertTrue(cause.getMessage().contains("Failed to create multi-channel transport"));
    }

    @Test
    @DisplayName("createChannelTransport should handle localhost addresses")
    void testCreateChannelTransportWithLocalhostAddresses() throws Exception {
        InetAddress localhost = InetAddress.getLocalHost();
        InetAddress loopback = InetAddress.getLoopbackAddress();