Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 281 - 290 of 397 for mbuf (0.04 seconds)

  1. src/main/java/org/codelibs/core/io/CopyUtil.java

         */
        protected static int copyInternal(final InputStream in, final OutputStream out) {
            try {
                final byte[] buf = new byte[DEFAULT_BUF_SIZE];
                int len;
                int amount = 0;
                while ((len = in.read(buf)) != -1) {
                    out.write(buf, 0, len);
                    amount += len;
                }
                out.flush();
                return amount;
    Created: Fri Apr 03 20:58:12 GMT 2026
    - Last Modified: Thu Jul 31 08:16:49 GMT 2025
    - 45.2K bytes
    - Click Count (0)
  2. cmd/xl-storage-format-v2_test.go

    			continue
    		}
    		in, err := file.Open()
    		if err != nil {
    			t.Fatal(err)
    		}
    		defer in.Close()
    		buf, err := io.ReadAll(in)
    		if err != nil {
    			t.Fatal(err)
    		}
    		buf = xlMetaV2TrimData(buf)
    
    		vers = append(vers, metaCacheEntry{
    			name:     "a",
    			metadata: buf,
    		})
    	}
    
    	// Shuffle...
    	for i := range 100 {
    		rng := rand.New(rand.NewSource(int64(i)))
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 37.8K bytes
    - Click Count (0)
  3. cmd/storage-interface.go

    	ListDir(ctx context.Context, origvolume, volume, dirPath string, count int) ([]string, error)
    	ReadFile(ctx context.Context, volume string, path string, offset int64, buf []byte, verifier *BitrotVerifier) (n int64, err error)
    	AppendFile(ctx context.Context, volume string, path string, buf []byte) (err error)
    	CreateFile(ctx context.Context, origvolume, olume, path string, size int64, reader io.Reader) error
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Apr 25 05:41:04 GMT 2025
    - 5.3K bytes
    - Click Count (0)
  4. src/main/java/org/codelibs/fess/suggest/index/operations/ContentIndexingOperations.java

            final long start = System.currentTimeMillis();
            final StringBuilder buf = new StringBuilder(searchWord.length());
            char prev = 0;
            for (final char c : searchWord.toCharArray()) {
                if (!Character.isWhitespace(c)) {
                    buf.append(c);
                } else if (!Character.isWhitespace(prev)) {
                    buf.append(' ');
                }
                prev = c;
            }
    Created: Fri Apr 17 09:08:13 GMT 2026
    - Last Modified: Sat Mar 14 02:35:38 GMT 2026
    - 21.7K bytes
    - Click Count (0)
  5. src/main/java/jcifs/http/NetworkExplorer.java

                }
    
                try {
                    try (InputStream is = getClass().getClassLoader().getResourceAsStream("jcifs/http/ne.css");) {
                        while ((n = is.read(buf)) != -1) {
                            sb.append(new String(buf, 0, n, "ISO8859_1"));
                        }
                        this.style = sb.toString();
                    }
                } catch (final IOException ioe) {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 23.4K bytes
    - Click Count (0)
  6. src/main/java/org/codelibs/fess/exec/Crawler.java

                final StringBuilder buf = new StringBuilder(500);
                for (final Map.Entry<String, String> entry : infoMap.entrySet()) {
                    if (buf.length() != 0) {
                        buf.append(',');
                    }
                    buf.append(entry.getKey()).append('=').append(entry.getValue());
                }
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Mar 26 02:24:08 GMT 2026
    - 32.4K bytes
    - Click Count (0)
  7. src/main/java/org/codelibs/fess/app/web/admin/maintenance/AdminMaintenanceAction.java

                    if (buf.length() > 0) {
                        buf.append(" : ");
                    }
                    buf.append(ip);
                }
            } catch (final Exception e) {
                // ignore
            }
            return buf.toString();
        }
    
        /**
         * Checks if the given filename is a log file based on its extension.
         *
         * @param name the filename to check
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Mar 28 06:59:19 GMT 2026
    - 23K bytes
    - Click Count (0)
  8. src/main/java/jcifs/util/HMACT64.java

            return this.md5.digest(digest);
        }
    
        @Override
        protected int engineDigest(final byte[] buf, final int offset, final int len) {
            final byte[] digest = this.md5.digest();
            this.md5.update(this.opad);
            this.md5.update(digest);
            try {
                return this.md5.digest(buf, offset, len);
            } catch (final Exception ex) {
                throw new IllegalStateException();
            }
        }
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 07:14:38 GMT 2025
    - 3.6K bytes
    - Click Count (0)
  9. src/main/java/jcifs/smb1/util/HMACT64.java

            md5.update(opad);
            return md5.digest(digest);
        }
    
        @Override
        protected int engineDigest(final byte[] buf, final int offset, final int len) {
            final byte[] digest = md5.digest();
            md5.update(opad);
            md5.update(digest);
            try {
                return md5.digest(buf, offset, len);
            } catch (final Exception ex) {
                throw new IllegalStateException();
            }
        }
    
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 07:14:38 GMT 2025
    - 3.6K bytes
    - Click Count (0)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/ResponseBody.kt

        private val charset: Charset,
      ) : Reader() {
        private var closed: Boolean = false
        private var delegate: Reader? = null
    
        @Throws(IOException::class)
        override fun read(
          cbuf: CharArray,
          off: Int,
          len: Int,
        ): Int {
          if (closed) throw IOException("Stream closed")
    
          val finalDelegate =
            delegate ?: InputStreamReader(
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue May 27 14:51:25 GMT 2025
    - 11.6K bytes
    - Click Count (0)
Back to Top