- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 89 for flush (0.14 sec)
-
android/guava/src/com/google/common/io/FileBackedOutputStream.java
out.write(b, off, len); } @Override public synchronized void close() throws IOException { out.close(); } @Override public synchronized void flush() throws IOException { out.flush(); } /** * Checks if writing {@code len} bytes would go over threshold, and switches to file buffering if * so. */ @GuardedBy("this")
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 22 17:40:56 GMT 2024 - 8.2K bytes - Viewed (0) -
cmd/admin-bucket-handlers.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 32.5K bytes - Viewed (0) -
tensorflow/c/experimental/filesystem/plugins/posix/posix_filesystem.cc
// For historical reasons, this does the same as `Flush` at the moment. // TODO(b/144055243): This should use `fsync`/`sync`. Flush(file, status); } static void Close(const TF_WritableFile* file, TF_Status* status) { auto posix_file = static_cast<PosixFile*>(file->plugin_file); if (fclose(posix_file->handle) != 0) TF_SetStatusFromIOError(status, errno, posix_file->filename); else
C++ - Registered: Tue Apr 23 12:39:09 GMT 2024 - Last Modified: Sun Mar 24 20:08:23 GMT 2024 - 15.8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/api/admin/backup/ApiAdminBackupAction.java
throw new IORuntimeException(e); } return true; }); writer.flush(); } }); } final String name = id.substring(0, id.length() - NDJSON_EXTENTION.length()); if ("search_log".equals(name)) {
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 6.1K bytes - Viewed (0) -
cni/pkg/ipset/nldeps_linux.go
if err != nil { return fmt.Errorf("failed to delete IP %s with and proto %d from ipset %s: %w", ip, ipProto, name, err) } return nil } func (m *realDeps) flush(name string) error { err := netlink.IpsetFlush(name) if err != nil { return fmt.Errorf("failed to flush ipset %s: %w", name, err) } return nil } // Alpine and some distros struggles with this - ipset CLI utilities support this, but
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 3.9K bytes - Viewed (0) -
internal/bucket/bandwidth/monitor_gen_test.go
var buf bytes.Buffer msgp.Encode(&buf, &v) b.SetBytes(int64(buf.Len())) en := msgp.NewWriter(msgp.Nowhere) b.ReportAllocs() b.ResetTimer() for i := 0; i < b.N; i++ { v.EncodeMsg(en) } en.Flush() } func BenchmarkDecodeBucketBandwidthReport(b *testing.B) { v := BucketBandwidthReport{} var buf bytes.Buffer msgp.Encode(&buf, &v) b.SetBytes(int64(buf.Len()))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Feb 19 22:54:46 GMT 2024 - 4.5K bytes - Viewed (0) -
cni/pkg/ipset/nldeps_mock.go
return args.Error(0) } func (m *MockedIpsetDeps) deleteIP(name string, ip netip.Addr, ipProto uint8) error { args := m.Called(name, ip, ipProto) return args.Error(0) } func (m *MockedIpsetDeps) flush(name string) error { args := m.Called(name) return args.Error(0) } func (m *MockedIpsetDeps) clearEntriesWithComment(name, comment string) error { args := m.Called(name, comment) return args.Error(0) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 1.8K bytes - Viewed (0) -
src/archive/zip/writer.go
if w.cw.count != 0 { panic("zip: SetOffset called after data was written") } w.cw.count = n } // Flush flushes any buffered data to the underlying writer. // Calling Flush is not normally necessary; calling Close is sufficient. func (w *Writer) Flush() error { return w.cw.w.(*bufio.Writer).Flush() } // SetComment sets the end-of-central-directory comment field. // It can only be called before [Writer.Close].
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Thu Apr 04 14:28:57 GMT 2024 - 19.3K bytes - Viewed (0) -
cmd/admin-handlers.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 29 17:39:04 GMT 2024 - 97.8K bytes - Viewed (2) -
cni/pkg/nodeagent/server.go
// // We will unconditionally flush our set before use here, so it shouldn't matter. func createHostsideProbeIpset(isV6 bool) (ipset.IPSet, error) { linDeps := ipset.RealNlDeps() probeSet, err := ipset.NewIPSet(iptables.ProbeIPSet, isV6, linDeps) if err != nil { return probeSet, err } probeSet.Flush() return probeSet, nil } func (s *Server) Start() {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 7.2K bytes - Viewed (0)