- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 420 for replay (0.2 sec)
-
internal/logger/target/kafka/kafka.go
// Reading logCh must hold read lock on logChMu (to avoid read race) // Sending a value on logCh must hold read lock on logChMu (to avoid closing) logCh chan interface{} logChMu sync.RWMutex // store to persist and replay the logs to the target // to avoid missing events when the target is down. store store.Store[interface{}] storeCtxCancel context.CancelFunc initKafkaOnce once.Init initQueueStoreOnce once.Init
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 10.1K bytes - Viewed (1) -
internal/logger/target/http/http.go
// support reading multiple events on a stream for example // like : Splunk HTTP Event collector, if you are unsure // set this to '1'. batchSize int payloadType string // store to persist and replay the logs to the target // to avoid missing events when the target is down. store store.Store[interface{}] storeCtxCancel context.CancelFunc initQueueOnce once.Init config Config
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 25 16:44:20 GMT 2024 - 14.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Reader.kt
* Read a connection-level ping from the peer. `ack` indicates this is a reply. The data * in `payload1` and `payload2` opaque binary, and there are no rules on the content. */ fun ping( ack: Boolean, payload1: Int, payload2: Int, ) /** * The peer tells us to stop creating streams. It is safe to replay streams with
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 19.9K bytes - Viewed (0) -
cmd/erasure-healing.go
// notFoundPartsErrs is ignored since // - delete marker does not have any parts dataBlocks := (len(errs) + 1) / 2 return validMeta, notFoundMetaErrs > dataBlocks } // TODO: It is possible to replay the object via just single // xl.meta file, considering quorum number of data-dirs are still // present on other drives. // // However this requires a bit of a rewrite, leave this up for // future work.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 06:32:14 GMT 2024 - 33.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/cache2/Relay.kt
file!!.channel.force(false) // This file is complete. synchronized(this@Relay) { complete = true } upstream?.closeQuietly() upstream = null } fun metadata(): ByteString = metadata /** * Returns a new source that returns the same bytes as upstream. Returns null if this relay has * been closed and no further sources are possible. In that case callers should retry after
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 11.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/cache2/RelayTest.kt
upstream.writeUtf8("abcde") val relay = edit(file, upstream, metadata, 1024) val source1 = relay.newSource() val source2 = relay.newSource() source1!!.close() source1.close() // Unnecessary. Shouldn't decrement the reference count. assertThat(relay.isClosed).isFalse() source2!!.close() assertThat(relay.isClosed).isTrue() assertFile(Relay.PREFIX_DIRTY, -1L, -1, null, null) }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 8.1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/URLConnectionTest.kt
assertContent("A", getResponse(newRequest("/a"))) // Give the server time to disconnect. Thread.sleep(500) // If the request body is larger than OkHttp's replay buffer, the failure may still occur. val requestBodyChars = CharArray(requestSize) Arrays.fill(requestBodyChars, 'x') val requestBody = String(requestBodyChars) for (j in 0..1) { try {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 131.7K bytes - Viewed (0) -
.github/workflows/deploy-docs.yml
- name: Comment Deploy if: steps.deploy.outputs.url != '' uses: ./.github/actions/comment-docs-preview-in-pr with: token: ${{ secrets.FASTAPI_PREVIEW_DOCS_COMMENT_DEPLOY }}
Others - Registered: Sun May 05 07:19:11 GMT 2024 - Last Modified: Tue Mar 19 01:33:28 GMT 2024 - 1.6K bytes - Viewed (0) -
maven-api-impl/src/test/remote-repo/org/apache/maven/plugins/maven-deploy-plugin/0.1/maven-deploy-plugin-0.1.jar
META-INF/MANIFEST.MF Manifest-Version: 1.0 Archiver-Version: Plexus Archiver Created-By: Apache Maven Built-By: BEBE Build-Jdk: 1.6.0_07 META-INF/maven/plugin.xml A test plugin to assist testing of Maven core. org.apache.maven.plugins maven-deploy-plugin 0.1 deploy false true deploy Does nothing. false true false false false true org.apache.maven.plugin.coreit.ItMojo java per-lookup once-per-session org.apache.maven maven-plugin-api jar 2.0 org/apache/maven/plugin/coreit/ItMojo.class package org.apache.maven.plugin.coreit;...
Archive - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Thu May 02 15:10:38 GMT 2024 - 6.6K bytes - Viewed (0) -
maven-api-impl/src/test/remote-repo/org/apache/maven/plugins/maven-deploy-plugin/0.1/maven-deploy-plugin-0.1.pom
<modelVersion>4.0.0</modelVersion> <groupId>org.apache.maven.plugins</groupId> <artifactId>maven-deploy-plugin</artifactId> <version>0.1</version> <packaging>maven-plugin</packaging> <name>Maven Integration Test Plugin</name> <description> A test plugin to assist testing of Maven core. </description>
Plain Text - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Thu May 02 15:10:38 GMT 2024 - 2.1K bytes - Viewed (0)