- Sort Score
- Result 10 results
- Languages All
Results 151 - 160 of 376 for cbuf (0.1 sec)
-
src/main/java/org/codelibs/core/exception/SAXRuntimeException.java
*/ protected static String createMessage(final SAXException cause) { final StringBuilder buf = new StringBuilder(100); buf.append(cause); if (cause instanceof SAXParseException) { final SAXParseException e = (SAXParseException) cause; if (e.getSystemId() != null) { buf.append(" at ").append(e.getSystemId()); } final int lineNumber = e.getLineNumber();
Registered: Fri Nov 01 20:58:10 UTC 2024 - Last Modified: Thu Mar 07 01:59:08 UTC 2024 - 2.1K bytes - Viewed (0) -
internal/store/queuestore.go
} // multiWrite - writes an item to the directory. func (store *QueueStore[I]) multiWrite(key Key, items []I) (err error) { buf := bytebufferpool.Get() defer bytebufferpool.Put(buf) enc := jsoniter.ConfigCompatibleWithStandardLibrary.NewEncoder(buf) for i := range items { if err = enc.Encode(items[i]); err != nil { return err } }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 8.6K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/helper/SitemapsHelper.java
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Sat Oct 12 01:40:57 UTC 2024 - 11.8K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/client/fs/FileSystemClient.java
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Feb 22 01:47:32 UTC 2024 - 11.8K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/helper/CrawlingInfoHelperTest.java
} StringBuilder buf = new StringBuilder(); for (int i = 0; i < 550; i++) { buf.append('a'); } assertEquals( "c11e9ec4fa5ccd0c37c78e7e43555c7061a4dfe8d250a66cad3abaf190e4519cae5b0dce520fb94667cb37e5bbd29b226638cc6172169706a8ae36b000a6900c", crawlingInfoHelper.generateId(buf.substring(0, 500))); assertEquals(
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 8.5K bytes - Viewed (0) -
src/cmd/api/main_test.go
case "rune": s = "int32" } } buf.WriteString(s) case *types.Array: fmt.Fprintf(buf, "[%d]", typ.Len()) w.writeType(buf, typ.Elem()) case *types.Slice: buf.WriteString("[]") w.writeType(buf, typ.Elem()) case *types.Struct: buf.WriteString("struct") case *types.Pointer: buf.WriteByte('*') w.writeType(buf, typ.Elem()) case *types.Tuple:
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Wed Sep 04 18:16:59 UTC 2024 - 31.4K bytes - Viewed (0) -
cmd/bitrot-streaming.go
_, err = io.ReadFull(b.rc, b.hashBytes) if err != nil { return 0, err } _, err = io.ReadFull(b.rc, buf) if err != nil { return 0, err } b.h.Write(buf) if !bytes.Equal(b.h.Sum(nil), b.hashBytes) { return 0, errFileCorrupt } b.currOffset += int64(len(buf)) return len(buf), nil } // Returns streaming bitrot reader implementation.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Aug 21 12:20:54 UTC 2024 - 6K bytes - Viewed (0) -
src/bytes/bytes_test.go
return func(b *testing.B, n int) { buf := bmbuf[0:n] o := copy(buf, uchars) for o < len(buf) { o += copy(buf[o:], uchars) } // Make space for the needle rune at the end of buf. m := utf8.RuneLen(needle) for o := m; o > 0; { _, sz := utf8.DecodeLastRune(buf) copy(buf[len(buf)-sz:], "\x00\x00\x00\x00") buf = buf[:len(buf)-sz] o -= sz }
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Mon Aug 19 19:09:04 UTC 2024 - 61.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/io/IoTestCase.java
InputStream in = url.openStream(); try { OutputStream out = new FileOutputStream(file); try { byte[] buf = new byte[4096]; for (int read = in.read(buf); read != -1; read = in.read(buf)) { out.write(buf, 0, read); } } finally { out.close(); } } finally { in.close(); } }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri May 31 12:36:13 UTC 2024 - 5.6K bytes - Viewed (0) -
istioctl/pkg/authz/listener.go
addPolicy(action, nameOfPolicy, indexOfRule) } if len(rbacTCP.GetRules().GetPolicies()) == 0 { addPolicy(action, anonymousName, "0") } } } } buf := strings.Builder{} buf.WriteString("ACTION\tAuthorizationPolicy\tRULES\n") for _, action := range []rbacpb.RBAC_Action{rbacpb.RBAC_DENY, rbacpb.RBAC_ALLOW, rbacpb.RBAC_LOG} { if names, ok := actionToPolicy[action]; ok {
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Mon Sep 11 15:29:30 UTC 2023 - 6K bytes - Viewed (0)