chan - Code Search

internal/config/certs.go

	var data []byte
	if data, err = os.ReadFile(certFile); err != nil {
		return nil, err
	}

	// Trimming leading and tailing white spaces.
	data = bytes.TrimSpace(data)

	// Parse all certs in the chain.
	current := data
	for len(current) > 0 {
		var pemBlock *pem.Block
		if pemBlock, current = pem.Decode(current); pemBlock == nil {

Registered: Sun Dec 28 19:28:13 UTC 2025

- Last Modified: Wed Aug 14 17:11:51 UTC 2024

- 3.8K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/test/java/jcifs/internal/smb2/ServerMessageBlock2RequestTest.java

            assertEquals(mid, smb2Cancel.getMid());
            assertEquals(asyncId, smb2Cancel.getAsyncId());
        }
    }

    @Nested
    @DisplayName("Chain Operation Tests")
    class ChainOperationTests {

        @Test
        @DisplayName("allowChain should check configuration for both requests")
        void testAllowChain() {

Registered: Sat Dec 20 13:44:44 UTC 2025

- Last Modified: Thu Aug 14 05:31:44 UTC 2025

- 15.7K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/main/java/jcifs/smb1/dcerpc/DcerpcHandle.java

    protected static DcerpcBinding parseBinding(final String str) throws DcerpcException {
        int state, mark, si;
        final char[] arr = str.toCharArray();
        String proto = null, key = null;
        DcerpcBinding binding = null;

        state = mark = si = 0;
        do {
            final char ch = arr[si];

            switch (state) {
            case 0:
                if (ch == ':') {

Registered: Sat Dec 20 13:44:44 UTC 2025

- Last Modified: Sat Aug 16 01:32:48 UTC 2025

- 11.7K bytes

- Viewed (0)

github.com/square/okhttp

okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/ConnectInterceptor.kt

 * be used for the returned response, or to validate a cached response with a conditional GET.
 */
object ConnectInterceptor : Interceptor {
  @Throws(IOException::class)
  override fun intercept(chain: Interceptor.Chain): Response {
    val realChain = chain as RealInterceptorChain
    val exchange = realChain.call.initExchange(realChain)
    val connectedChain = realChain.copy(exchange = exchange)
    return connectedChain.proceed(realChain.request)
  }

Registered: Fri Dec 26 11:42:13 UTC 2025

- Last Modified: Fri Dec 27 13:39:56 UTC 2024

- 1.5K bytes

- Viewed (0)

github.com/google/guava

guava/src/com/google/common/util/concurrent/CycleDetectingLockFactory.java

 * Thread2: acquire(LockB) --X acquire(LockA)
 * </pre>
 *
 * <p>Neither thread will progress because each is waiting for the other. In more complex
 * applications, cycles can arise from interactions among more than 2 locks:
 *
 * <pre>
 * Thread1: acquire(LockA) --X acquire(LockB)
 * Thread2: acquire(LockB) --X acquire(LockC)
 * ...
 * ThreadN: acquire(LockN) --X acquire(LockA)
 * </pre>
 *

Registered: Fri Dec 26 12:43:10 UTC 2025

- Last Modified: Thu Sep 11 17:06:34 UTC 2025

- 35.9K bytes

- Viewed (0)

github.com/tiangolo/fastapi

docs_src/websockets/tutorial003_py39.py

from fastapi import FastAPI, WebSocket, WebSocketDisconnect
from fastapi.responses import HTMLResponse

app = FastAPI()

html = """
<!DOCTYPE html>
<html>
    <head>
        <title>Chat</title>
    </head>
    <body>
        <h1>WebSocket Chat</h1>
        <h2>Your ID: <span id="ws-id"></span></h2>
        <form action="" onsubmit="sendMessage(event)">
            <input type="text" id="messageText" autocomplete="off"/>

Registered: Sun Dec 28 07:19:09 UTC 2025

- Last Modified: Sat Mar 18 12:29:59 UTC 2023

- 2.5K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/java/org/codelibs/fess/app/web/admin/wizard/AdminWizardAction.java

        }

        // normalize
        final StringBuilder buf = new StringBuilder(1000);
        for (int i = 0; i < configPath.length(); i++) {
            final char c = configPath.charAt(i);
            if (c == '\\') {
                buf.append('/');
            } else if (c == ' ') {
                buf.append("%20");
            } else if (CharUtil.isUrlChar(c)) {

Registered: Sat Dec 20 09:19:18 UTC 2025

- Last Modified: Thu Dec 11 09:47:03 UTC 2025

- 16.3K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/java/org/codelibs/fess/app/web/base/FessBaseAction.java

    }

    /**
     * Builds a comprehensive error message from a throwable and its causes.
     * This method traverses the cause chain and concatenates all error messages.
     *
     * @param t the throwable to build message from
     * @return a string containing all error messages in the cause chain
     */
    protected String buildThrowableMessage(final Throwable t) {
        final StringBuilder buf = new StringBuilder(100);

Registered: Sat Dec 20 09:19:18 UTC 2025

- Last Modified: Fri Nov 28 16:29:12 UTC 2025

- 15K bytes

- Viewed (0)

github.com/apache/maven

impl/maven-cli/src/main/java/org/apache/maven/cling/event/ExecutionEventLogger.java

        this.messageBuilderFactory = messageBuilderFactory;
        this.terminalWidth = terminalWidth;
    }

    private static String chars(char c, int count) {
        return String.valueOf(c).repeat(Math.max(0, count));
    }

    private void infoLine(char c) {
        infoMain(chars(c, lineLength));
    }

    private void infoMain(String msg) {
        logger.info(builder().strong(msg).toString());
    }

Registered: Sun Dec 28 03:35:09 UTC 2025

- Last Modified: Fri Dec 13 15:40:45 UTC 2024

- 17.5K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/main/java/jcifs/smb/NtlmContext.java

            passwordString = this.transportContext.getConfig().getGuestPassword();
        } else {
            char[] passwordChars = this.auth.getPasswordAsCharArray();
            if (passwordChars != null) {
                passwordString = new String(passwordChars);
                // Securely wipe the char array immediately after use
                java.util.Arrays.fill(passwordChars, '\0');
            }
        }

Registered: Sat Dec 20 13:44:44 UTC 2025

- Last Modified: Sat Aug 30 05:58:03 UTC 2025

- 17.3K bytes

- Viewed (1)

Search Options