- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 263 for Flush (0.2 sec)
-
cmd/erasure-server-pool-decom_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 BenchmarkDecodePoolDecommissionInfo(b *testing.B) { v := PoolDecommissionInfo{} 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: Wed Jan 12 02:48:43 GMT 2022 - 11K bytes - Viewed (0) -
internal/grid/msg_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 BenchmarkDecodeconnectReq(b *testing.B) { v := connectReq{} var buf bytes.Buffer msgp.Encode(&buf, &v) b.SetBytes(int64(buf.Len())) rd := msgp.NewEndlessReader(buf.Bytes(), b)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 10.8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/score/ScoreBooster.java
.setScript(new Script(ScriptType.INLINE, scriptLang, scriptCode, params))); } if (bulkRequestBuilder.numberOfActions() > requestCacheSize) { flush(); } return (long) ids.length; }; public abstract long process(); protected void enable() { final ScoreUpdater scoreUpdater = ComponentUtil.getComponent("scoreUpdater");
Java - Registered: Mon Apr 29 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 5K bytes - Viewed (0) -
istioctl/pkg/writer/compare/sds/writer.go
if includeConfigType { s.Name = fmt.Sprintf("secret/%s", s.Name) } fmt.Fprintf(tw, "%s\t%s\t%s\t%t\t%s\t%s\t%s\n", s.Name, s.Type, s.State, s.Valid, s.SerialNumber, s.NotAfter, s.NotBefore) } return tw.Flush() } // printSecretItemsJSON prints secret in JSON format, and dumps the raw certificate data with the output func (w *sdsWriter) printSecretItemsJSON(secrets []SecretItem) error {
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Apr 21 14:17:23 GMT 2023 - 4.1K bytes - Viewed (0) -
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) -
okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt
assertThat(connection.writer.maxDataLength()).isEqualTo(newMaxFrameSize) } /** * Webservers may set the initial window size to zero, which is a special case because it means * that we have to flush headers immediately before any request body can be sent. * https://github.com/square/okhttp/issues/2543 */ @Test fun peerSetsZeroFlowControl() { peer.setClient(true) // Write the mocking script.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 75.4K bytes - Viewed (0) -
misc/go_android_exec/main.go
n := len(data) f.buf.Write(data) // Flush to w until a potential match of exitRe b := f.buf.Bytes() match := f.exitRe.FindIndex(b) if match == nil { // Flush all of the buffer. _, err := f.w.Write(b) f.buf.Reset() if err != nil { return n, err } } else { // Flush up to the beginning of the (potential) match. _, err := f.w.Write(b[:match[0]])
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Mon Aug 21 17:46:57 GMT 2023 - 15.3K 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) -
cmd/tier-journal_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 BenchmarkDecodejentry(b *testing.B) { v := jentry{} var buf bytes.Buffer msgp.Encode(&buf, &v) b.SetBytes(int64(buf.Len())) rd := msgp.NewEndlessReader(buf.Bytes(), b)
Go - Registered: Sun Feb 25 19:28:16 GMT 2024 - Last Modified: Thu Jun 03 21:26:51 GMT 2021 - 4.3K bytes - Viewed (0) -
internal/dsync/lock-args_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 BenchmarkDecodeLockArgs(b *testing.B) { v := LockArgs{} var buf bytes.Buffer msgp.Encode(&buf, &v) b.SetBytes(int64(buf.Len())) rd := msgp.NewEndlessReader(buf.Bytes(), b)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 4.4K bytes - Viewed (0)