Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 221 - 230 of 324 for mbuf (0.02 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. internal/store/queuestore_test.go

    	for i := range 10 {
    		items = append(items, TestItem{
    			Name:     fmt.Sprintf("test-item-%d", i),
    			Property: "property",
    		})
    	}
    
    	buf := bytebufferpool.Get()
    	defer bytebufferpool.Put(buf)
    
    	enc := jsoniter.ConfigCompatibleWithStandardLibrary.NewEncoder(buf)
    	for i := range items {
    		if err = enc.Encode(items[i]); err != nil {
    			t.Fatal(err)
    		}
    	}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 10.2K bytes
    - Click Count (0)
  2. 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)
  3. 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)
  4. 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)
  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/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)
  7. 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)
  8. 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)
  9. internal/s3select/csv/reader.go

    	if skip > 0 {
    		n, err := io.ReadFull(r.buf, dst)
    		if err != nil && err != io.ErrUnexpectedEOF {
    			// If an EOF happens after reading some but not all the bytes,
    			// ReadFull returns ErrUnexpectedEOF.
    			return dst[:n], err
    		}
    		dst = dst[:n]
    		if err == io.ErrUnexpectedEOF {
    			return dst, io.EOF
    		}
    	}
    	// Read until next line.
    	in, err := r.buf.ReadBytes('\n')
    	dst = append(dst, in...)
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue May 27 15:19:03 GMT 2025
    - 8.8K bytes
    - Click Count (0)
  10. src/main/java/jcifs/smb1/smb1/TestLocking.java

        long ltime = 0L;
    
        @Override
        public void run() {
            try {
                final SmbFile f = new SmbFile(url);
                final SmbFile d = new SmbFile(f.getParent());
                final byte[] buf = new byte[1024];
    
                for (int ii = 0; ii < numIter; ii++) {
    
                    synchronized (this) {
                        ltime = System.currentTimeMillis();
                        wait();
                    }
    
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 4.2K bytes
    - Click Count (0)
Back to Top