- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 84 for flushed (0.14 sec)
-
test/fixedbugs/issue7995.go
// run // Copyright 2014 The Go Authors. All rights reserved. // Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. // Issue 7995: globals not flushed quickly enough. package main import "fmt" var ( p = 1 q = &p ) func main() { p = 50 *q = 100 s := fmt.Sprintln(p, *q) if s != "100 100\n" { println("BUG:", s) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 02 13:43:18 UTC 2016 - 379 bytes - Viewed (0) -
src/net/http/httptest/recorder_test.go
} return nil } } hasFlush := func(want bool) checkFunc { return func(rec *ResponseRecorder) error { if rec.Flushed != want { return fmt.Errorf("Flushed = %v; want %v", rec.Flushed, want) } return nil } } hasOldHeader := func(key, want string) checkFunc { return func(rec *ResponseRecorder) error { if got := rec.HeaderMap.Get(key); got != want {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 11 23:17:38 UTC 2022 - 9.7K bytes - Viewed (0) -
src/main/java/jcifs/FileNotifyInformation.java
* The operating system detects a change in file size only when the file is written to the disk. For operating * systems that use extensive caching, detection occurs only when the cache is sufficiently flushed.s */ public static final int FILE_NOTIFY_CHANGE_SIZE = 0x00000008; /** * Any change to the last write-time of files in the watched directory or subtree causes a change notification wait
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Sun Jul 01 13:12:10 UTC 2018 - 4.9K bytes - Viewed (0) -
src/runtime/tracecpu.go
} // Write out a trace event. w := unsafeTraceWriter(gen, trace.cpuBuf[gen%2]) // Ensure we have a place to write to. var flushed bool w, flushed = w.ensure(2 + 5*traceBytesPerNumber /* traceEvCPUSamples + traceEvCPUSample + timestamp + g + m + p + stack ID */) if flushed { // Annotate the batch as containing strings. w.byte(byte(traceEvCPUSamples)) } // Add the stack to the table.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 15 17:03:35 UTC 2024 - 8.7K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/streams/ValueStore.java
/** * Writes the given value and returns an address for the written block. * The current thread performs the encoding. The implementation may perform some buffering and this may not necessarily be * flushed to the filesystem on completion of this method. */ BlockAddress write(T value); /** * Reads the contents of the given block. * The current thread performs the decoding. */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:08:47 UTC 2023 - 1.4K bytes - Viewed (0) -
platforms/software/security/src/main/java/org/gradle/plugins/signing/signatory/Signatory.java
*/ @Internal String getName(); /** * Exhausts {@code toSign}, and writes the signature to {@code signatureDestination}. The caller is responsible for closing the streams, though the output WILL be flushed. * * @param toSign The source of the data to be signed * @param destination Where the signature will be written to */ void sign(InputStream toSign, OutputStream destination); /**
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Oct 11 12:16:09 UTC 2023 - 1.9K bytes - Viewed (0) -
pkg/proxy/conntrack/conntrack.go
err := ct.exec(parameters...) if err != nil && !strings.Contains(err.Error(), noConnectionToDelete) { // TODO: Better handling for deletion failure. When failure occur, stale udp connection may not get flushed. // These stale udp connection will keep black hole traffic. Making this a best effort operation for now, since it // is expensive to baby-sit all udp connections to kubernetes services.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jan 15 18:09:05 UTC 2024 - 5.5K bytes - Viewed (0) -
pkg/ledger/trie_cache.go
// limitations under the License. package ledger import ( "sync" "time" "istio.io/istio/pkg/cache" ) type cacheDB struct { // updatedNodes that have will be flushed to disk updatedNodes byteCache // updatedMux is a lock for updatedNodes updatedMux sync.RWMutex } // byteCache implements a modified ExpiringCache interface, returning byte arrays
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 2K bytes - Viewed (0) -
maven-model-builder/src/main/java/org/apache/maven/model/building/ModelSource2.java
* <p> * ModelSource2 instances are cached in {@link ModelBuildingRequest#getModelCache()}. Implementations must guarantee * that the connection to the backing store remains active until request's {@link ModelCache} is discarded or flushed. */ public interface ModelSource2 extends ModelSource { /** * Returns model source identified by a path relative to this model source POM. Implementation <strong>MUST</strong>
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Tue Nov 22 13:26:01 UTC 2022 - 2.3K bytes - Viewed (0) -
platforms/core-runtime/logging/src/test/groovy/org/gradle/internal/logging/console/ThrottlingOutputEventListenerTest.groovy
10_000 * listener.onOutput(_) } def "background flush does nothing when events already flushed"() { def event1 = event('1') def event2 = event('2') def flush = new FlushOutputEvent() given: renderer.onOutput(event1) renderer.onOutput(event2) renderer.onOutput(flush) when: executor.runFixedScheduledActionsNow()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:05:18 UTC 2023 - 4.6K bytes - Viewed (0)