- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 188 for 5090 (0.04 sec)
-
guava/src/com/google/common/util/concurrent/RateLimiter.java
* second. This could be accomplished by requiring a permit per byte, and specifying a rate of 5000 * permits per second: * * <pre>{@code * final RateLimiter rateLimiter = RateLimiter.create(5000.0); // rate = 5000 permits per second * void submitPacket(byte[] packet) { * rateLimiter.acquire(packet.length); * networkService.send(packet); * } * }</pre> *
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 19 00:51:36 UTC 2024 - 21.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Call.kt
* * Note that transport-layer success (receiving a HTTP response code, headers and body) does not * necessarily indicate application-layer success: `response` may still indicate an unhappy HTTP * response code like 404 or 500. * * @throws IOException if the request could not be executed due to cancellation, a connectivity * problem or timeout. Because networks can fail during an exchange, it is possible that the
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Wed Dec 20 23:27:07 UTC 2023 - 3.6K bytes - Viewed (0) -
fess-crawler/src/test/resources/extractor/eml/sample2.eml
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Sat Jan 16 07:50:35 UTC 2016 - 91.6K bytes - Viewed (0) -
build-logic-commons/build-platform/build.gradle.kts
api("org.codenarc:CodeNarc:$codenarcVersion") api("org.eclipse.jgit:org.eclipse.jgit:5.13.3.202401111512-r") api("org.javassist:javassist:3.27.0-GA") api("org.jetbrains.kotlinx:kotlinx-metadata-jvm:0.9.0") api("org.jsoup:jsoup:1.15.3") api("org.junit.jupiter:junit-jupiter:5.8.2") api("org.junit.vintage:junit-vintage-engine:5.8.2") api("org.openmbee.junit:junit-xml-parser:1.0.0")
Registered: Wed Nov 06 11:36:14 UTC 2024 - Last Modified: Tue Oct 29 21:53:00 UTC 2024 - 4.8K bytes - Viewed (0) -
samples/tlssurvey/src/main/kotlin/okhttp3/survey/RunSurvey.kt
.build() val sslLabsClients = SslLabsClient(client).clients() val ianaSuitesNew = fetchIanaSuites(client) val android5 = sslLabsClients.first { it.userAgent == "Android" && it.version == "5.0.0" } val android9 = sslLabsClients.first { it.userAgent == "Android" && it.version == "9.0" } val chrome33 = sslLabsClients.first { it.userAgent == "Chrome" && it.version == "33" }
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Wed Apr 10 19:46:48 UTC 2024 - 3.5K bytes - Viewed (0) -
src/main/webapp/WEB-INF/web.xml
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Mon Jul 29 02:54:01 UTC 2024 - 7.1K bytes - Viewed (0) -
cmd/metrics-v3-types.go
} } // MetricsLoaderFn - represents a function to load metrics from the // metricsCache. // // Note that returning an error here will cause the Metrics handler to return a // 500 Internal Server Error. type MetricsLoaderFn func(context.Context, MetricValues, *metricsCache) error // JoinLoaders - joins multiple loaders into a single loader. The returned
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Jul 30 22:28:46 UTC 2024 - 15.6K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/configdump/route.go
for _, d := range domains { if !strings.Contains(d, ":") { withoutPort = append(withoutPort, d) // if the domain contains IPv6, such as [fd00:10:96::7fc7] and [fd00:10:96::7fc7]:8090 } else if strings.Count(d, ":") > 2 { // if the domain is only a IPv6 address, such as [fd00:10:96::7fc7], append it if strings.HasSuffix(d, "]") { withoutPort = append(withoutPort, d) } } }
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Thu Aug 08 20:44:50 UTC 2024 - 7.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/job/CrawlJob.java
it.start(); final Process currentProcess = jobProcess.getProcess(); currentProcess.waitFor(); it.join(5000); final int exitValue = currentProcess.exitValue(); if (logger.isInfoEnabled()) { logger.info("Crawler: Exit Code={} - Process Output:\n{}", exitValue, it.getOutput());
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Sun Jun 23 04:13:47 UTC 2024 - 15.1K bytes - Viewed (0) -
cmd/metacache-manager.go
} type metacacheManager struct { mu sync.RWMutex init sync.Once buckets map[string]*bucketMetacache trash map[string]metacache // Recently deleted lists. } const metacacheMaxEntries = 5000 // initManager will start async saving the cache. func (m *metacacheManager) initManager() { // Add a transient bucket. // Start saver when object layer is ready. go func() { objAPI := newObjectLayerFn()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Oct 25 00:44:15 UTC 2022 - 5.2K bytes - Viewed (0)