currently - Code Search

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

      // and when it is done will run the listeners.
      if (hasListeners.compareAndSet(false, true)) {
        if (delegate.isDone()) {
          // If the delegate is already done, run the execution list immediately on the current
          // thread.
          executionList.execute();
          return;
        }

        // TODO(lukes): handle RejectedExecutionException
        adapterExecutor.execute(
            () -> {

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

- Last Modified: Thu Dec 14 20:35:03 UTC 2023

- 7.5K bytes

- Viewed (0)

github.com/tensorflow/tensorflow

ci/official/containers/linux_arm64/builder.devtoolset/build_devtoolset.sh

  echo "Use 'devtoolset-9' to build a manylinux2014 compatible toolchain"
  exit 1
  ;;
esac

mkdir -p "${TARGET}"

mkdir -p ${TARGET}/usr/include

# Put the current kernel headers from ubuntu in place.
ln -s "/usr/include/linux" "${TARGET}/usr/include/linux"
ln -s "/usr/include/asm-generic" "${TARGET}/usr/include/asm-generic"
ln -s "/usr/include/aarch64-linux-gnu/asm" "${TARGET}/usr/include/asm"

Registered: Tue Nov 05 12:39:12 UTC 2024

- Last Modified: Fri Sep 29 00:26:34 UTC 2023

- 6.1K bytes

- Viewed (0)

github.com/square/okhttp

okhttp/src/main/kotlin/okhttp3/Cache.kt

    val snapshot = (cached.body as CacheResponseBody).snapshot
    var editor: DiskLruCache.Editor? = null
    try {
      editor = snapshot.edit() ?: return // edit() returns null if snapshot is not current.
      entry.writeTo(editor)
      editor.commit()
    } catch (_: IOException) {
      abortQuietly(editor)
    }
  }

  private fun abortQuietly(editor: DiskLruCache.Editor?) {

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

- Last Modified: Wed Apr 10 19:46:48 UTC 2024

- 26.8K bytes

- Viewed (0)

github.com/codelibs/jcifs

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

        )

        already_notified_comment: Union[Comment, None] = None
        already_done_comment: Union[Comment, None] = None

        logging.info(
            f"Checking current comments in discussion: #{discussion.number} to see if already notified about this PR: #{pr.number}"
        )
        comments = get_graphql_translation_discussion_comments(

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

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)

Search Options