furent - Code Search

src/main/java/jcifs/smb1/smb1/AndXServerMessageBlock.java

            // andx not used; return
            return dstIndex - start;
        }

        /* The message provided to batch has a batchLimit that is
         * higher than the current batchLevel so we will now encode
         * that chained message. Before doing so we must increment
         * the batchLevel of the andx message in case it itself is an

Registered: Sun Nov 03 00:10:13 UTC 2024

- Last Modified: Fri Mar 22 21:10:40 UTC 2019

- 11.3K bytes

- Viewed (0)

github.com/tiangolo/fastapi

.github/actions/notify-translations/app/main.py

import httpx
from github import Github
from pydantic import BaseModel, BaseSettings, SecretStr

awaiting_label = "awaiting-review"
lang_all_label = "lang-all"
approved_label = "approved-1"
translations_path = Path(__file__).parent / "translations.yml"

github_graphql_url = "https://api.github.com/graphql"
questions_translations_category_id = "DIC_kwDOCZduT84CT5P9"

all_discussions_query = """
query Q($category_id: ID) {

Registered: Sun Nov 03 07:19:11 UTC 2024

- Last Modified: Mon Jul 29 23:35:07 UTC 2024

- 12.4K bytes

- Viewed (0)

github.com/minio/minio

docs/multi-user/README.md

- `aws:username` - This is a string containing the friendly name of the current user, this value would point to STS temporary credential in `AssumeRole`ed requests, use `jwt:preferred_username` in case of OpenID connect and `ldap:username` in case of AD/LDAP. *aws:userid* is an alias to *aws:username* in MinIO.

Registered: Sun Nov 03 19:28:11 UTC 2024

- Last Modified: Tue Mar 21 06:38:06 UTC 2023

- 8K bytes

- Viewed (0)

github.com/minio/minio

internal/s3select/sql/aggregation.go

		return &aggVal{runningMin: FromInt(0)}
	case aggFnMax:
		return &aggVal{runningMax: FromInt(0)}
	default:
		return &aggVal{}
	}
}

// evalAggregationNode - performs partial computation using the
// current row and stores the result.
//
// On success, it returns (nil, nil).
func (e *FuncExpr) evalAggregationNode(r Record, tableAlias string) error {
	// It is assumed that this function is called only when

Registered: Sun Nov 03 19:28:11 UTC 2024

- Last Modified: Sat Dec 23 07:19:11 UTC 2023

- 7.9K bytes

- Viewed (0)

github.com/square/okhttp

samples/guide/src/main/java/okhttp3/recipes/kt/WiresharkExample.kt

          println("TLSv1.3 requires an external command run before first traffic is sent")
          println("Follow instructions at https://github.com/neykov/extract-tls-secrets for TLSv1.3")
          println("Pid: ${ProcessHandle.current().pid()}")

          Thread.sleep(10000)
        }
      }
      CommandLine -> {
        return ProcessBuilder(
          "tshark", "-l", "-V", "-o", "tls.keylog_file:$logFile", "-Y", "http2", "-O", "http2,tls",

Registered: Fri Nov 01 11:42:11 UTC 2024

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

- 10.7K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/java/org/codelibs/fess/sso/oic/OpenIdConnectAuthenticator.java

            final String fieldName = jsonParser.getCurrentName();
            if (fieldName != null) {
                jsonParser.nextToken(); // Move to the value of the current field

                if (jsonParser.getCurrentToken() == JsonToken.START_ARRAY) {
                    nestedMap.put(fieldName, parseArray(jsonParser));

Registered: Thu Oct 31 13:40:30 UTC 2024

- Last Modified: Fri Oct 11 21:20:39 UTC 2024

- 12.3K bytes

- Viewed (0)

github.com/square/okhttp

okhttp-logging-interceptor/src/main/kotlin/okhttp3/logging/HttpLoggingInterceptor.kt

       * ```
       */
      BODY,
    }

    fun interface Logger {
      fun log(message: String)

      companion object {
        /** A [Logger] defaults output appropriate for the current platform. */
        @JvmField
        val DEFAULT: Logger = DefaultLogger()

        private class DefaultLogger : Logger {
          override fun log(message: String) {
            Platform.get().log(message)

Registered: Fri Nov 01 11:42:11 UTC 2024

- Last Modified: Sat Apr 06 09:14:38 UTC 2024

- 11.2K bytes

- Viewed (0)

github.com/gradle/gradle

build-logic/buildquality/src/main/kotlin/gradlebuild/incubation/action/IncubatingApiReportWorkAction.kt

       <meta xmlns:xslthl="http://xslthl.sf.net" content="width=device-width, initial-scale=1" name="viewport">
       <link xmlns:xslthl="http://xslthl.sf.net" type="text/css" rel="stylesheet" href="https://docs.gradle.org/current/userguide/base.css">

    </head>
    <body>
       <h1>Incubating APIs for  $title</h1>
    """
            )
            val versions = versionsDates()

Registered: Wed Nov 06 11:36:14 UTC 2024

- Last Modified: Fri Jun 28 08:29:28 UTC 2024

- 12.8K bytes

- Viewed (0)

github.com/istio/istio

common-protos/k8s.io/api/rbac/v1/generated.proto

  // Subjects holds references to the objects the role applies to.
  // +optional
  repeated Subject subjects = 2;

  // RoleRef can reference a Role in the current namespace or a ClusterRole in the global namespace.
  // If the RoleRef cannot be resolved, the Authorizer must return an error.
  optional RoleRef roleRef = 3;
}

// RoleBindingList is a collection of RoleBindings

Registered: Wed Nov 06 22:53:10 UTC 2024

- Last Modified: Mon Mar 11 18:43:24 UTC 2024

- 7.6K bytes

- Viewed (0)

github.com/google/guava

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

      ExecutorService service, long terminationTimeout, TimeUnit timeUnit) {
    new Application().addDelayedShutdownHook(service, terminationTimeout, timeUnit);
  }

  /** Represents the current application to register shutdown hooks. */
  @J2ktIncompatible
  @GwtIncompatible // TODO
  @VisibleForTesting
  static class Application {

    final ExecutorService getExitingExecutorService(

Registered: Fri Nov 01 12:43:10 UTC 2024

- Last Modified: Sat Oct 19 00:51:36 UTC 2024

- 44.1K bytes

- Viewed (0)

Search Options