referred - Code Search

cmd/erasure-decode.go

	}
}

// preferReaders can mark readers as preferred.
// These will be chosen before others.
func (p *parallelReader) preferReaders(prefer []bool) {
	if len(prefer) != len(p.orgReaders) {
		return
	}
	// Copy so we don't change our input.
	tmp := make([]io.ReaderAt, len(p.orgReaders))
	copy(tmp, p.orgReaders)
	p.readers = tmp
	// next is the next non-preferred index.
	next := 0
	for i, ok := range prefer {

Registered: Sun Sep 07 19:28:11 UTC 2025

- Last Modified: Thu Aug 29 01:40:52 UTC 2024

- 9.5K bytes

- Viewed (0)

github.com/square/okhttp

okhttp/src/jvmTest/kotlin/okhttp3/SocksProxy.kt

    if (version != VERSION_5) throw ProtocolException("unexpected version: $version")

    val command = fromSource.readByte() and 0xff

    val reserved = fromSource.readByte() and 0xff
    if (reserved != 0) throw ProtocolException("unexpected reserved: $reserved")

    val addressType = fromSource.readByte() and 0xff
    val toAddress =
      when (addressType) {
        ADDRESS_TYPE_IPV4 -> {

Registered: Fri Sep 05 11:42:10 UTC 2025

- Last Modified: Mon May 05 16:01:00 UTC 2025

- 7.6K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/test/java/jcifs/smb1/dcerpc/msrpc/samrTest.java

    @Mock
    private rpc.unicode_string mockUnicodeString;

    @Mock
    private lsarpc.LsarSidArray mockLsarSidArray;

    @BeforeEach
    void setUp() {
        // Directly set the deferred field on the mock
        mockNdrBuffer.deferred = mockDeferredBuffer;

        // Configure mocks for NdrBuffer interactions
        lenient().when(mockDeferredBuffer.derive(anyInt())).thenReturn(mockDeferredBuffer);

Registered: Sun Sep 07 00:10:21 UTC 2025

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

- 33.6K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/test/java/jcifs/internal/smb2/tree/Smb2TreeDisconnectResponseTest.java

        SMBUtil.writeInt2(4, buffer, 0);
        // Write reserved field (any value is acceptable)
        buffer[2] = (byte) byte2;
        buffer[3] = (byte) byte3;

        // When
        int bytesRead = response.readBytesWireFormat(buffer, 0);

        // Then - should still read 4 bytes regardless of reserved field value
        assertEquals(4, bytesRead);
    }

    @Test

Registered: Sun Sep 07 00:10:21 UTC 2025

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

- 14.1K bytes

- Viewed (0)

github.com/tiangolo/fastapi

docs/en/data/sponsors.yml

  - url: https://www.stainlessapi.com/?utm_source=fastapi&utm_medium=referral
    title: Stainless | Generate best-in-class SDKs
    img: https://fastapi.tiangolo.com/img/sponsors/stainless.png
  - url: https://www.permit.io/blog/implement-authorization-in-fastapi?utm_source=github&utm_medium=referral&utm_campaign=fastapi
    title: Fine-Grained Authorization for FastAPI

Registered: Sun Sep 07 07:19:17 UTC 2025

- Last Modified: Sun Aug 31 15:19:49 UTC 2025

- 3.8K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/main/java/jcifs/smb1/smb1/SmbComReadAndXResponse.java

        final int start = bufferIndex;

        bufferIndex += 2; // reserved
        dataCompactionMode = readInt2(buffer, bufferIndex);
        bufferIndex += 4; // 2 reserved
        dataLength = readInt2(buffer, bufferIndex);
        bufferIndex += 2;
        dataOffset = readInt2(buffer, bufferIndex);
        bufferIndex += 12; // 10 reserved

        return bufferIndex - start;
    }

    @Override

Registered: Sun Sep 07 00:10:21 UTC 2025

- Last Modified: Thu Aug 14 07:14:38 UTC 2025

- 2.3K bytes

- Viewed (0)

github.com/square/okhttp

okhttp/src/jvmTest/kotlin/okhttp3/FastFallbackTest.kt

    }.also { expected ->
      assertThat(expected).hasMessage("timeout")
    }
  }

  /**
   * This test reproduces a crash where OkHttp attempted to use a deferred connection when the call
   * already had a healthy connection. It sets up a deferred connection by stalling the IPv6
   * connect, and it sets up a same-connection retry with [ErrorCode.REFUSED_STREAM].
   *
   * https://github.com/square/okhttp/pull/7190
   */

Registered: Fri Sep 05 11:42:10 UTC 2025

- Last Modified: Fri Jun 20 11:46:46 UTC 2025

- 10.4K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/main/java/jcifs/smb1/smb1/SmbComNtTransaction.java

            dst[dstIndex++] = maxSetupCount;
        } else {
            dst[dstIndex++] = (byte) 0x00; // Reserved
        }
        dst[dstIndex] = (byte) 0x00; // Reserved
        dstIndex++;
        dst[dstIndex++] = (byte) 0x00; // Reserved
        writeInt4(totalParameterCount, dst, dstIndex);
        dstIndex += 4;
        writeInt4(totalDataCount, dst, dstIndex);
        dstIndex += 4;

Registered: Sun Sep 07 00:10:21 UTC 2025

- Last Modified: Thu Aug 14 07:14:38 UTC 2025

- 3K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/test/java/jcifs/dcerpc/msrpc/samrTest.java

    @Mock
    private rpc.unicode_string mockUnicodeString;

    @Mock
    private lsarpc.LsarSidArray mockLsarSidArray;

    @BeforeEach
    void setUp() {
        // Directly set the deferred field on the mock
        mockNdrBuffer.deferred = mockDeferredBuffer;

        // Configure mocks for NdrBuffer interactions
        lenient().when(mockDeferredBuffer.derive(anyInt())).thenReturn(mockDeferredBuffer);

Registered: Sun Sep 07 00:10:21 UTC 2025

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

- 33.7K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/webapp/WEB-INF/orig/view/search.jsp

${fe:html(true)}
<head profile="http://a9.com/-/spec/opensearch/1.1/">
<meta charset="utf-8">
<meta name="viewport" content="width=device-width, initial-scale=1">
<meta http-equiv="X-UA-Compatible" content="IE=edge">
<meta name="referrer" content="no-referrer">
<title>${f:h(displayQuery)}-<la:message
		key="labels.search_title" /></title>
<c:if test="${osddLink}">
	<link rel="search" type="application/opensearchdescription+xml"
		href="${fe:url('/osdd')}"

Registered: Thu Sep 04 12:52:25 UTC 2025

- Last Modified: Sat Jan 18 11:38:54 UTC 2025

- 6.8K bytes

- Viewed (0)

Search Options