- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 56 for flushed (0.36 sec)
-
cni/pkg/nodeagent/net.go
} if err := s.ztunnelServer.PodDeleted(ctx, string(pod.UID)); err != nil { return err } return nil } // syncHostIPSets is called after the host node ipset has been created (or found + flushed) // during initial snapshot creation, it will insert every snapshotted pod's IP into the set. // // The set does not allow dupes (obviously, that would be undefined) - but in the real world due to misconfigured
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 05:10:23 UTC 2024 - 13.4K bytes - Viewed (0) -
internal/logger/target/http/http.go
atomic.AddInt64(&h.totalMessages, 1) atomic.AddInt64(&h.failedMessages, 1) return errors.New("log buffer full") } return nil } // Cancel - cancels the target. // All queued messages are flushed and the function returns afterwards. // All messages sent to the target after this function has been called will be dropped. func (h *Target) Cancel() { atomic.StoreInt32(&h.status, statusClosed) h.storeCtxCancel()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sun Jun 02 03:03:39 UTC 2024 - 14.9K bytes - Viewed (0) -
src/compress/flate/deflate.go
// If the underlying writer returns an error, Flush returns that error. // // In the terminology of the zlib library, Flush is equivalent to Z_SYNC_FLUSH. func (w *Writer) Flush() error { // For more about flushing: // https://www.bolet.org/~pornin/deflate-flush.html return w.d.syncFlush() } // Close flushes and closes the writer. func (w *Writer) Close() error { return w.d.close() }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 26 13:32:40 UTC 2024 - 20.3K bytes - Viewed (0) -
src/internal/coverage/cfile/emit.go
return fmt.Errorf("writing %s: %v\n", s.mftmp, err) } if err := s.mf.Close(); err != nil { return fmt.Errorf("closing meta data temp file: %v", err) } // Temp file has now been flushed and closed. Rename the temp to the // final desired path. if err := os.Rename(s.mftmp, s.mfname); err != nil { return fmt.Errorf("writing %s: rename from %s failed: %v\n", s.mfname, s.mftmp, err) } return nil
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 09:57:47 UTC 2024 - 18.9K bytes - Viewed (0) -
src/runtime/mfinal.go
// associated operating system file descriptor when a program discards // an os.File without calling Close, but it would be a mistake // to depend on a finalizer to flush an in-memory I/O buffer such as a // [bufio.Writer], because the buffer would not be flushed at program exit. // // It is not guaranteed that a finalizer will run if the size of *obj is // zero bytes, because it may share same address with other zero-size
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 01:56:56 UTC 2024 - 19K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
* `HttpURLConnection` who flushes more bytes to the output stream than the connection's write * window will block. * * Zero [byteCount] writes are not subject to flow control and will not block. The only use case * for zero [byteCount] is closing a flushed output stream. */ @Throws(IOException::class) fun writeData( streamId: Int,
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 32.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/admin/upgrade/AdminUpgradeAction.java
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Sun May 26 05:52:29 UTC 2024 - 48.6K bytes - Viewed (0) -
tensorflow/c/eager/c_api_experimental.h
// have been executed. Note that "execution" here refers to kernel execution / // scheduling of copies, etc. Similar to sync execution, it doesn't guarantee // that lower level device queues (like GPU streams) have been flushed. // // This call may not block for execution of ops enqueued concurrently with this // call. TF_CAPI_EXPORT extern void TFE_ExecutorWaitForAllPendingNodes( TFE_Executor*, TF_Status* status);
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Feb 21 22:37:46 UTC 2024 - 39.5K bytes - Viewed (0) -
src/runtime/stack.go
// thisg.m.p == 0 can happen in the guts of exitsyscall // or procresize. Just get a stack from the global pool. // Also don't touch stackcache during gc // as it's flushed concurrently. lock(&stackpool[order].item.mu) x = stackpoolalloc(order) unlock(&stackpool[order].item.mu) } else { c := thisg.m.p.ptr().mcache x = c.stackcache[order].list
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 22:31:00 UTC 2024 - 41.1K bytes - Viewed (0) -
src/runtime/runtime2.go
statsSeq atomic.Uint32 // Timer heap. timers timers // maxStackScanDelta accumulates the amount of stack space held by // live goroutines (i.e. those eligible for stack scanning). // Flushed to gcController.maxStackScan once maxStackScanSlack // or -maxStackScanSlack is reached. maxStackScanDelta int64 // gc-time statistics about current goroutines
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:57:37 UTC 2024 - 47.9K bytes - Viewed (0)