- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 204 for Counter (0.19 sec)
-
cmd/background-heal-ops.go
} else { res, err = objAPI.HealObject(ctx, task.bucket, task.object, task.versionID, task.opts) } } if bgSeq != nil { // We increment relevant counter based on the heal result for prometheus reporting. if err != nil { bgSeq.countFailed(res) } else { bgSeq.countHeals(res.Type, false) } } if task.respCh != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 4.6K bytes - Viewed (0) -
tensorflow/c/experimental/filesystem/plugins/gcs/BUILD
"//tensorflow/c:tf_status_internal", "//tensorflow/core:lib", "//tensorflow/core:test", "//tensorflow/core:test_main", "//tensorflow/core/platform:blocking_counter", "//tensorflow/core/platform/cloud:now_seconds_env", ], ) tf_cc_test( name = "gcs_filesystem_test", srcs = [ "gcs_filesystem_test.cc", ], tags = [
Plain Text - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Wed Mar 27 18:00:18 GMT 2024 - 3.4K bytes - Viewed (0) -
internal/http/server.go
listener *httpListener // HTTP listener for all 'Addrs' field. inShutdown uint32 // indicates whether the server is in shutdown or not requestCount int32 // counter holds no. of request in progress. } // GetRequestCount - returns number of request in progress. func (srv *Server) GetRequestCount() int { return int(atomic.LoadInt32(&srv.requestCount)) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Feb 09 21:25:16 GMT 2024 - 7.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketProtocol.kt
val buffer = cursor.data var i = cursor.start val end = cursor.end if (buffer != null) { while (i < end) { keyIndex %= keyLength // Reassign to prevent overflow breaking counter. // Byte xor is experimental in Kotlin so we coerce bytes to int, xor them // and convert back to byte. val bufferInt: Int = buffer[i].toInt()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 4.8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/ldap/LdapManager.java
private final DirContext context; private int counter = 1; protected DirContextHolder(final DirContext context) { this.context = context; } public DirContext get() { return context; } public void inc() { counter++; } @Override public void close() {
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 65.9K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AggregateFutureState.java
/** * A helper which does some thread-safe operations for aggregate futures, which must be implemented * differently in GWT. Namely: * * <ul> * <li>Lazily initializes a set of seen exceptions * <li>Decrements a counter atomically * </ul> */ @GwtCompatible(emulated = true) @ReflectionSupport(value = ReflectionSupport.Level.FULL) @ElementTypesAreNonnullByDefault abstract class AggregateFutureState<OutputT extends @Nullable Object>
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Dec 14 20:35:03 GMT 2023 - 8.5K bytes - Viewed (0) -
okhttp-logging-interceptor/src/test/java/okhttp3/logging/HttpLoggingInterceptorTest.kt
.build(), ) val asyncRequestBody: RequestBody = object : RequestBody() { var counter = 0 override fun contentType() = null override fun writeTo(sink: BufferedSink) { counter++ assertThat(counter).isLessThanOrEqualTo(1) sink.writeUtf8("Hello request!") sink.close() }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 06 09:14:38 GMT 2024 - 37.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Futures.java
* Future}. * * <p>Usage example: * * <pre>{@code * ListenableFuture<Integer> fetchCounterFuture = ...; * * // Falling back to a zero counter in case an exception happens when * // processing the RPC to fetch counters. * ListenableFuture<Integer> faultTolerantFuture = Futures.catching( * fetchCounterFuture, FetchException.class, x -> 0, directExecutor()); * }</pre> *
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 01 16:15:01 GMT 2024 - 59.6K bytes - Viewed (0) -
maven-core/src/site/apt/offline-mode.apt
Offline Mode Design * UPDATE: 18-April-2005 We cannot take the approach outlined below of detecting which remote repositories are "really" offline, since offline mode is more of a behavior, and this will lead to counter-intuitive results. A different feature may exist unimplemented, which is to detect when the network is down and provide better feedback for that case. However, when offline mode is declared, nothing
Plain Text - Registered: Sun Apr 28 03:35:10 GMT 2024 - Last Modified: Mon Mar 18 00:24:53 GMT 2024 - 10.6K bytes - Viewed (0) -
doc/godebug.md
Some, such as `http2client` and `http2server`, will be maintained much longer, even indefinitely. When possible, each GODEBUG setting has an associated [runtime/metrics](/pkg/runtime/metrics/) counter named `/godebug/non-default-behavior/<name>:events` that counts the number of times a particular program's behavior has changed based on a non-default value for that setting. For example, when `GODEBUG=http2client=0` is set,
Plain Text - Registered: Tue May 07 11:14:38 GMT 2024 - Last Modified: Tue Apr 16 17:29:58 GMT 2024 - 13.5K bytes - Viewed (0)