- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 71 for flushed (0.77 sec)
-
operator/pkg/cache/cache.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Dec 06 13:12:49 UTC 2023 - 2.4K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/SynchronizedDispatchConnection.java
import org.slf4j.Logger; import org.slf4j.LoggerFactory; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock; /** * Connection decorator that synchronizes dispatching and always flushes after each message. * * The plan is to replace this with a Connection implementation that queues outgoing messages and dispatches them from a worker thread. */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jan 26 14:58:23 UTC 2024 - 3K bytes - Viewed (0) -
pkg/hbone/server.go
t0 := time.Now() log.WithLabels("host", r.Host, "source", r.RemoteAddr).Info("Received CONNECT") // Send headers back immediately so we can start getting the body w.(http.Flusher).Flush() ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second) defer cancel() dst, err := (&net.Dialer{}).DialContext(ctx, "tcp", r.Host) if err != nil { w.WriteHeader(http.StatusServiceUnavailable)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Nov 10 02:05:07 UTC 2022 - 2.4K bytes - Viewed (0) -
pkg/proxy/ipvs/ipset/testing/fake.go
} } // GetVersion is part of interface. func (f *FakeIPSet) GetVersion() (string, error) { return f.Version, nil } // FlushSet is part of interface. It deletes all entries from a named set but keeps the set itself. func (f *FakeIPSet) FlushSet(set string) error { if f.Entries == nil { return fmt.Errorf("entries map can't be nil") } // delete all entry elements for true {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Dec 19 01:20:51 UTC 2023 - 3.6K bytes - Viewed (0) -
pkg/util/coverage/coverage.go
flag.CommandLine.Parse([]string{"-test.coverprofile", tempCoveragePath()}) // Begin periodic logging go wait.Forever(FlushCoverage, flushInterval) } // FlushCoverage flushes collected coverage information to disk. // The destination file is configured at startup and cannot be changed. // Calling this function also sends a line like "coverage: 5% of statements" to stdout. func FlushCoverage() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 05 21:00:21 UTC 2022 - 3.2K bytes - Viewed (0) -
platforms/core-configuration/configuration-cache/src/main/kotlin/org/gradle/internal/cc/impl/BuildTreeConfigurationCache.kt
*/ fun loadOrCreateProjectMetadata(identityPath: Path, creator: () -> LocalComponentGraphResolveState): LocalComponentGraphResolveState /** * Flushes any remaining state to the cache and closes any resources */ fun finalizeCacheEntry() // This is a temporary property to allow migration from a root build scoped cache to a build tree scoped cache
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:25 UTC 2024 - 3.5K bytes - Viewed (0) -
.github/workflows/sigbuild-docker-presubmit.yml
- name: Add a comment with the pushed containers uses: mshick/add-pr-comment@a65df5f64fc741e91c59b8359a4bc56e57aaf5b1 # v2 if: contains(github.event.pull_request.labels.*.name, 'build and push to gcr.io for staging') with: repo-token: ${{ secrets.GITHUB_TOKEN }} message: | I pushed these containers:
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Mon Oct 23 18:43:43 UTC 2023 - 4K bytes - Viewed (0) -
maven-core/src/test/resources/apiv4-repo/org/codehaus/plexus/plexus-components/1.1.6/plexus-components-1.1.6.pom
<groupId>org.codehaus.plexus</groupId> <artifactId>plexus-components</artifactId> <packaging>pom</packaging> <version>1.1.6</version> <name>Plexus Components Parent Project</name> <!-- TODO: should this be pushed down to all the dependencies? - a more stable API JAR may be useful, for the interfaces and classes such as AbstractLogEnabled --> <dependencies> <dependency> <groupId>org.codehaus.plexus</groupId>
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Sun Oct 02 08:41:25 UTC 2022 - 1.8K bytes - Viewed (0) -
internal/http/response-recorder.go
lrw.writeHeaders(&lrw.headers, code, lrw.ResponseWriter.Header()) lrw.headersLogged = true lrw.ResponseWriter.WriteHeader(code) } } // Flush - Calls the underlying Flush. func (lrw *ResponseRecorder) Flush() { lrw.ResponseWriter.(http.Flusher).Flush() } // Size - returns the number of bytes written func (lrw *ResponseRecorder) Size() int { return lrw.bytesWritten }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat Dec 02 00:13:19 UTC 2023 - 4.9K bytes - Viewed (0) -
.teamcity/src/main/kotlin/common/VersionedSettingsBranch.kt
/** * Whether the <a href="https://www.jetbrains.com/help/teamcity/configuring-vcs-triggers.html">VCS trigger</a> * should be enabled, i.e. when new commits are pushed to this branch, should a ReadyForNightly job * be triggered automatically? * * Currently, we only enable VCS trigger for `master`/`release`/`releaseNx` branches. */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Dec 05 00:08:14 UTC 2023 - 3.4K bytes - Viewed (0)