Context - Code Search

fastapi/concurrency.py

@asynccontextmanager
async def contextmanager_in_threadpool(
    cm: AbstractContextManager[_T],
) -> AsyncGenerator[_T, None]:
    # blocking __exit__ from running waiting on a free thread
    # can create race conditions/deadlocks if the context manager itself
    # has its own internal pool (e.g. a database connection pool)
    # to avoid this we let __exit__ run without a capacity limit
    # since we're creating a new limiter for each call, any non-zero limit

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

- Last Modified: Wed Dec 17 21:25:59 UTC 2025

- 1.5K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/test/java/jcifs/spnego/NegTokenInitTest.java

        NegTokenInit parsed = new NegTokenInit(token);
        assertNull(parsed.getMechanismListMIC(), "Non-Octet MIC in tag [3] should be ignored");
    }

    @Test
    @DisplayName("Context flags encode as DER BIT STRING and parse back")
    void testContextFlagsRoundTripViaAsn1() throws Exception {
        int flags = NegTokenInit.ANONYMITY | NegTokenInit.CONFIDENTIALITY | NegTokenInit.SEQUENCE_CHECKING;

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

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

- 21K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/test/java/jcifs/internal/witness/WitnessClientTest.java

     */
    private static class TestWitnessClient extends WitnessClient {

        public TestWitnessClient(InetAddress witnessServer, CIFSContext context, WitnessRpcClient rpcClient) {
            super(witnessServer, context, rpcClient);
        }

        // TestWitnessClient can use the parent implementation now since we inject the mock RPC client
    }

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

- Last Modified: Sat Aug 23 09:06:40 UTC 2025

- 9.8K bytes

- Viewed (0)

github.com/minio/minio

internal/config/identity/openid/jwt_test.go

		},
		ProviderCfgs: map[string]*providerCfg{
			"1": &provider,
		},
		closeRespFn: func(rc io.ReadCloser) {
			rc.Close()
		},
	}

	var claims jwtgo.MapClaims
	if err = cfg.Validate(t.Context(), DummyRoleARN, token, "", "", claims); err != nil {
		t.Fatal(err)
	}
}

func TestJWT(t *testing.T) {
	const jsonkey = `{"keys":
       [
         {"kty":"RSA",

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

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

- 8.2K bytes

- Viewed (0)

github.com/minio/minio

internal/event/target/redis.go

	if pingErr != nil {
		if !xnet.IsConnRefusedErr(pingErr) && !xnet.IsConnResetErr(pingErr) {
			target.loggerOnce(context.Background(), pingErr, target.ID().String())
		}
		return pingErr
	}

	if err := target.args.validateFormat(conn); err != nil {
		target.loggerOnce(context.Background(), err, target.ID().String())
		return err
	}

	target.firstPing = true

	yes, err := target.isActive()

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

- Last Modified: Sun Mar 30 00:56:02 UTC 2025

- 9.1K bytes

- Viewed (0)

github.com/minio/minio

internal/event/target/postgresql.go

	}

	err = target.db.Ping()
	if err != nil {
		if !xnet.IsConnRefusedErr(err) && !xnet.IsConnResetErr(err) {
			target.loggerOnce(context.Background(), err, target.ID().String())
		}
	} else {
		if err = target.executeStmts(); err != nil {
			target.loggerOnce(context.Background(), err, target.ID().String())
		} else {
			target.firstPing = true
		}
	}

	if err != nil {
		target.db.Close()

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

- Last Modified: Sun Mar 30 00:56:02 UTC 2025

- 13.3K bytes

- Viewed (0)

github.com/tiangolo/fastapi

.github/workflows/notify-translations.yml

        required: false
        default: 'false'

env:
  UV_SYSTEM_PYTHON: 1

jobs:
  job:
    runs-on: ubuntu-latest
    permissions:
      discussions: write
    steps:
      - name: Dump GitHub context
        env:
          GITHUB_CONTEXT: ${{ toJson(github) }}
        run: echo "$GITHUB_CONTEXT"
      - uses: actions/checkout@v6
      - name: Set up Python
        uses: actions/setup-python@v6
        with:

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

- Last Modified: Fri Nov 21 13:03:21 UTC 2025

- 1.7K bytes

- Viewed (0)

github.com/square/okhttp

okhttp-testing-support/src/main/kotlin/okhttp3/SimpleProvider.kt

import org.junit.jupiter.params.provider.Arguments
import org.junit.jupiter.params.provider.ArgumentsProvider

abstract class SimpleProvider : ArgumentsProvider {
  override fun provideArguments(context: ExtensionContext) = arguments().map { Arguments.of(it) }.stream()

  @Throws(Exception::class)
  abstract fun arguments(): List<Any>

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

- Last Modified: Mon Jan 08 01:13:22 UTC 2024

- 1K bytes

- Viewed (0)

github.com/codelibs/fess-crawler

fess-crawler/src/test/resources/extractor/eml/sample2.eml

<html>
<head>
<meta http-equiv="Content-Type" content="text/html; charset=utf-8" />
<meta name="viewport" content="width=device-width, minimum-scale=1.0, maximum-scale=1.0, user-scalable=0" />
<meta name="apple-mobile-web-app-capable" content="yes" />
<style type="text/css">

@media only screen and (max-width: 420px) {
a[class="article-headline"] {

Registered: Sat Dec 20 11:21:39 UTC 2025

- Last Modified: Sat Jan 16 07:50:35 UTC 2016

- 91.6K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/test/java/jcifs/http/NtlmHttpFilterTest.java

        Properties props = new Properties();
        props.setProperty("jcifs.smb.client.domain", "TEST_DOMAIN");
        CIFSContext context = new BaseContext(new PropertyConfiguration(props));
        NtlmPasswordAuthentication auth = new NtlmPasswordAuthentication(context, "TEST_DOMAIN", "user", "pass");

        when(httpSession.getAttribute("NtlmHttpAuth")).thenReturn(auth);

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

- Last Modified: Thu Aug 21 04:51:33 UTC 2025

- 12.8K bytes

- Viewed (0)

Search Options