rels - Code Search

tests/test_stream_cancellation.py

    Returns `True` if the cancellation was delivered (i.e. it did not hang).
    """
    chunks: list[bytes] = []

    async def receive():  # type: ignore[no-untyped-def]
        # Simulate a client that never disconnects, rely on cancellation
        await anyio.sleep(float("inf"))
        return {"type": "http.disconnect"}  # pragma: no cover

    async def send(message: dict) -> None:  # type: ignore[type-arg]

Created: Sun Apr 05 07:19:11 GMT 2026

- Last Modified: Fri Feb 27 18:56:47 GMT 2026

- 2.7K bytes

- Click Count (0)

github.com/codelibs/fess

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

<c:if test="${osddLink}">
	<link rel="search" type="application/opensearchdescription+xml" href="${fe:url('/osdd')}"
		title="<la:message key="labels.index_osdd_title" />"
	/>
</c:if>
<link href="${fe:url('/css/bootstrap.min.css')}" rel="stylesheet" type="text/css" />
<link href="${fe:url('/css/style.css')}" rel="stylesheet" type="text/css" />
<link href="${fe:url('/css/font-awesome.min.css')}" rel="stylesheet" type="text/css" />
</head>

Created: Tue Mar 31 13:07:34 GMT 2026

- Last Modified: Mon Feb 23 08:03:44 GMT 2026

- 14.2K bytes

- Click Count (0)

github.com/gradle/gradle

build-logic/documentation/src/main/groovy/gradlebuild/docs/ReleaseNotesTransformer.java

                append("<meta name='viewport' content='width=device-width, initial-scale=1'>").
                append("<title>Gradle @version@ Release Notes</title>").
                append("<link rel='stylesheet' type='text/css' href='https://assets.gradle.com/lato/css/lato-font.css'/>");
        addCssToHead(document);
        addJavascriptToHead(document);
        addHighlightJsToHead(document);

Created: Wed Apr 01 11:36:16 GMT 2026

- Last Modified: Tue Mar 03 01:59:51 GMT 2026

- 11.3K bytes

- Click Count (0)

github.com/minio/minio

cmd/data-scanner-metric.go

		}
		obj, ok := value.(*currentPathTracker)
		if !ok {
			return true
		}
		strptr := (*string)(atomic.LoadPointer(obj.name))
		if strptr != nil {
			res = append(res, pathJoin(prefix, name, *strptr))
		}
		return true
	})
	return res
}

// activeDrives returns the number of currently active disks.
// (since this is concurrent it may not be 100% reliable)
func (p *scannerMetrics) activeDrives() int {

Created: Sun Apr 05 19:28:12 GMT 2026

- Last Modified: Wed Oct 01 06:06:01 GMT 2025

- 9.4K bytes

- Click Count (0)

github.com/minio/minio

cmd/generic-handlers_test.go

	}
	return header
}

func TestIsHTTPHeaderSizeTooLarge(t *testing.T) {
	for i, test := range isHTTPHeaderSizeTooLargeTests {
		if res := isHTTPHeaderSizeTooLarge(test.header); res != test.shouldFail {
			t.Errorf("Test %d: Expected %v got %v", i, res, test.shouldFail)
		}
	}
}

var containsReservedMetadataTests = []struct {
	header     http.Header
	shouldFail bool
}{
	{

Created: Sun Apr 05 19:28:12 GMT 2026

- Last Modified: Fri Aug 29 02:39:48 GMT 2025

- 6.2K bytes

- Click Count (0)

github.com/tiangolo/fastapi

docs_src/templates/templates/item.html

<html>
<head>
    <title>Item Details</title>
    <link href="{{ url_for('static', path='/styles.css') }}" rel="stylesheet">
</head>
<body>
    <h1><a href="{{ url_for('read_item', id=id) }}">Item ID: {{ id }}</a></h1>
</body>

Created: Sun Apr 05 07:19:11 GMT 2026

- Last Modified: Thu Jan 11 22:25:37 GMT 2024

- 235 bytes

- Click Count (0)

github.com/google/guava

guava-tests/test/com/google/common/util/concurrent/ListenableFutureTaskTest.java

    task.cancel(false);
    assertTrue(task.isDone());
    assertTrue(task.isCancelled());
    assertEquals(1, runLatch.getCount());

    // Wait for the listeners to be called, don't rely on the same-thread exec.
    listenerLatch.await(5, SECONDS);
    assertTrue(task.isDone());
    assertTrue(task.isCancelled());

    // Make sure we didn't run anything.
    assertEquals(1, runLatch.getCount());

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Mon Mar 16 22:45:21 GMT 2026

- 4.7K bytes

- Click Count (0)

github.com/tensorflow/tensorflow

ci/official/requirements_updater/README.md

## Managing hermetic Python

To make sure that TensorFlow's build is reproducible, behaves uniformly across
supported platforms (Linux, Windows, MacOS) and is properly isolated from
specifics of a local system, we rely on hermetic Python (see
[rules_python](https://github.com/bazelbuild/rules_python)) for all build
and test commands executed via Bazel. This means that your system Python
installation will be ignored during the build and Python interpreter itself

Created: Tue Apr 07 12:39:13 GMT 2026

- Last Modified: Sat Jun 29 00:19:18 GMT 2024

- 3K bytes

- Click Count (0)

github.com/codelibs/jcifs

src/main/java/jcifs/internal/smb2/rdma/RdmaBufferManager.java

    }

    /**
     * Release a temporary buffer
     *
     * For direct buffers, we rely on GC. A more sophisticated
     * implementation could maintain a buffer pool here as well.
     *
     * @param buffer buffer to release
     */
    public void releaseBuffer(ByteBuffer buffer) {
        // For direct buffers, we rely on GC
        // Could implement a more sophisticated buffer pool here
    }

    /**

Created: Sun Apr 05 00:10:12 GMT 2026

- Last Modified: Sat Aug 23 05:11:12 GMT 2025

- 8.7K bytes

- Click Count (0)

github.com/codelibs/fess

src/test/java/org/codelibs/fess/it/admin/FileAuthTests.java

    String getFileConfigId() {
        final Map<String, Object> searchBody = new HashMap<>();
        searchBody.put("name", "test_fileconfig");
        String res = checkMethodBase(searchBody).get("/api/admin/fileconfig/settings").asString();
        List<String> fileConfigList = JsonPath.from(res).getList("response.settings.findAll {it.name.startsWith(\"test_fileconfig\")}.id");
        return fileConfigList.get(0);
    }

    @AfterEach

Created: Tue Mar 31 13:07:34 GMT 2026

- Last Modified: Thu Aug 07 03:06:29 GMT 2025

- 3.9K bytes

- Click Count (0)

Search Options