Current - Code Search

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)

github.com/square/okhttp

okhttp/src/main/kotlin/okhttp3/internal/cache/CacheStrategy.kt

        val delta = servedMillis - lastModified!!.time
        return if (delta > 0L) delta / 10 else 0L
      }

      return 0L
    }

    /**
     * Returns the current age of the response, in milliseconds. The calculation is specified by RFC
     * 7234, 4.2.3 Calculating Age.
     */
    private fun cacheResponseAge(): Long {
      val servedDate = this.servedDate

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

- Last Modified: Mon Apr 15 13:24:48 UTC 2024

- 12K bytes

- Viewed (0)

github.com/square/okhttp

okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt

      tasksExecutor.execute {
        taskRunner.assertThreadDoesntHoldLock()
        require(currentTask == this)
        try {
          runnable.run()
          require(currentTask == this) { "unexpected current task: $currentTask" }
        } finally {
          taskRunner.lock.withLock {
            activeThreads--
            startNextTask()
          }
        }
      }
    }
  }

  /**

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

- Last Modified: Mon Apr 29 00:33:04 UTC 2024

- 12.6K bytes

- Viewed (0)

github.com/google/guava

android/guava/src/com/google/common/util/concurrent/SequentialExecutor.java

            if (task == null) {
              workerRunningState = IDLE;
              return;
            }
          }
          // Remove the interrupt bit before each task. The interrupt is for the "current task" when
          // it is sent, so subsequent tasks in the queue should not be caused to be interrupted
          // by a previous one in the queue being interrupted.
          interruptedDuringTask |= Thread.interrupted();

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

- Last Modified: Thu Feb 01 21:46:34 UTC 2024

- 10.6K bytes

- Viewed (0)

github.com/google/guava

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

            if (task == null) {
              workerRunningState = IDLE;
              return;
            }
          }
          // Remove the interrupt bit before each task. The interrupt is for the "current task" when
          // it is sent, so subsequent tasks in the queue should not be caused to be interrupted
          // by a previous one in the queue being interrupted.
          interruptedDuringTask |= Thread.interrupted();

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

- Last Modified: Thu Feb 01 21:46:34 UTC 2024

- 10.6K bytes

- Viewed (0)

github.com/google/guava

guava/src/com/google/common/hash/LittleEndianByteArray.java

      if (theUnsafe.arrayIndexScale(byte[].class) != 1) {
        throw new AssertionError();
      }
    }
  }

  /** Fallback implementation for when Unsafe is not available in our current environment. */
  private enum JavaLittleEndianBytes implements LittleEndianBytes {
    INSTANCE {
      @Override
      public long getLongLittleEndian(byte[] source, int offset) {
        return Longs.fromBytes(

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

- Last Modified: Sat Oct 19 00:26:48 UTC 2024

- 9.8K bytes

- Viewed (0)

github.com/minio/minio

docs/debugging/README.md

```bash
go install github.com/minio/minio/docs/debugging/xl-meta@latest
```

### Using xl-meta

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

- Last Modified: Fri Feb 25 01:17:53 UTC 2022

- 8.7K bytes

- Viewed (0)

Search Options