Search Options

Results per page
Sort
Preferred Languages
Advance

Results 151 - 160 of 376 for cbuf (0.1 sec)

  1. 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)
  2. 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)
  3. fess-crawler/src/main/java/org/codelibs/fess/crawler/helper/SitemapsHelper.java

                } else if (LOC_ELEMENT.equals(qName)) {
                    if (buf != null) {
                        sitemapUrl.setLoc(buf.toString().trim());
                        buf = null;
                    }
                } else if (LASTMOD_ELEMENT.equals(qName)) {
                    if (buf != null) {
                        sitemapUrl.setLastmod(buf.toString().trim());
                        buf = null;
                    }
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Sat Oct 12 01:40:57 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  4. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/fs/FileSystemClient.java

                            buf.append(c);
                        } else {
                            buf.append(URLEncoder.encode(str, charset));
                        }
                    }
                }
            } catch (final UnsupportedEncodingException e) {
                return filePath;
            }
            return buf.toString();
        }
    
        protected String geCharSet(final File file) {
            return charset;
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:47:32 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  5. src/test/java/org/codelibs/fess/helper/CrawlingInfoHelperTest.java

    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 8.5K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top