Search Options

Results per page
Sort
Preferred Languages
Advance

Results 131 - 140 of 313 for bufB (0.03 sec)

  1. cmd/tier_gen_test.go

    	v := TierConfigMgr{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    
    	m := v.Msgsize()
    	if buf.Len() > m {
    		t.Log("WARNING: TestEncodeDecodeTierConfigMgr Msgsize() is inaccurate")
    	}
    
    	vn := TierConfigMgr{}
    	err := msgp.Decode(&buf, &vn)
    	if err != nil {
    		t.Error(err)
    	}
    
    	buf.Reset()
    	msgp.Encode(&buf, &v)
    	err = msgp.NewReader(&buf).Skip()
    	if err != nil {
    		t.Error(err)
    	}
    }
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 2.3K bytes
    - Viewed (0)
  2. internal/grid/grid.go

    	return d
    }
    
    type writerWrapper struct {
    	ch  chan<- []byte
    	ctx context.Context
    }
    
    func (w *writerWrapper) Write(p []byte) (n int, err error) {
    	buf := GetByteBufferCap(len(p))
    	buf = buf[:len(p)]
    	copy(buf, p)
    	select {
    	case w.ch <- buf:
    		return len(p), nil
    	case <-w.ctx.Done():
    		return 0, context.Cause(w.ctx)
    	}
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 7K bytes
    - Viewed (0)
  3. cmd/utils.go

    			runtime.GC()
    			var buf bytes.Buffer
    			err := pprof.Lookup("heap").WriteTo(&buf, 0)
    			return buf.Bytes(), err
    		}
    	case madmin.ProfilerBlock:
    		runtime.SetBlockProfileRate(100)
    		prof.stopFn = func() ([]byte, error) {
    			var buf bytes.Buffer
    			err := pprof.Lookup("block").WriteTo(&buf, 0)
    			runtime.SetBlockProfileRate(0)
    			return buf.Bytes(), err
    		}
    	case madmin.ProfilerMutex:
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 33K bytes
    - Viewed (0)
  4. src/test/java/jcifs/smb/SmbFileInputStreamTest.java

                byte[] buf = new byte[16];
    
                // Skip advances internal file pointer; next read should use this offset
                in.skip(2);
    
                // Act
                int n = in.readDirect(buf, 0, 5);
    
                // Assert
                assertEquals(3, n, "Should report bytes read from SMB2 response");
    
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 07:14:38 UTC 2025
    - 12.8K bytes
    - Viewed (0)
  5. src/test/java/jcifs/smb1/dcerpc/ndr/NdrShortTest.java

            buf.reset();
            ns.encode(buf); // should not throw
    
            // After encoding, check how many bytes were used
            int bytesUsed = buf.getIndex();
            // Should be 2 bytes for the short value (alignment may add padding)
            assertTrue(bytesUsed >= 2, "Should use at least 2 bytes for short");
    
            // Reset index to read back
            buf.reset();
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 5.1K 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 Dec 30 11:13:12 UTC 2025
    - Last Modified: Thu Feb 20 03:25:33 UTC 2025
    - 31.4K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/timer/MonitorTarget.java

                tempBuf.append("null");
            }
            buf.append(tempBuf.toString());
            return buf;
        }
    
        /**
         * Appends a timestamp to the buffer.
         *
         * @param buf the string buffer to append to
         * @return the updated buffer
         */
        protected StringBuilder appendTimestamp(final StringBuilder buf) {
            final SystemHelper systemHelper = ComponentUtil.getSystemHelper();
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 3.8K bytes
    - Viewed (0)
  8. fess-crawler/src/main/java/org/codelibs/fess/crawler/container/CrawlerContainer.java

            final StringBuilder buf = new StringBuilder(100);
            final String value = System.getProperty("java.protocol.handler.pkgs");
            if (StringUtil.isEmpty(value)) {
                buf.append("org.codelibs.fess.net.protocol");
            } else if (!value.contains("org.codelibs.fess.net.protocol")) {
                buf.append("|org.codelibs.fess.net.protocol");
            }
            if (buf.length() > 0) {
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Sat Mar 15 06:52:00 UTC 2025
    - 2.6K bytes
    - Viewed (0)
  9. api/go1.2.txt

    pkg syscall (freebsd-386-cgo), type BpfVersion struct, Minor uint16
    pkg syscall (freebsd-386-cgo), type BpfZbuf struct
    pkg syscall (freebsd-386-cgo), type BpfZbuf struct, Bufa *uint8
    pkg syscall (freebsd-386-cgo), type BpfZbuf struct, Bufb *uint8
    pkg syscall (freebsd-386-cgo), type BpfZbuf struct, Buflen uint32
    pkg syscall (freebsd-386-cgo), type BpfZbufHeader struct
    Registered: Tue Dec 30 11:13:12 UTC 2025
    - Last Modified: Fri Oct 18 04:36:59 UTC 2013
    - 1.9M bytes
    - Viewed (1)
  10. src/main/java/org/codelibs/core/text/JsonUtil.java

                case '\r' -> "\\r";
                default -> c < ' ' ? "\\u" + "0".repeat(4 - Integer.toHexString(c).length()) + Integer.toHexString(c) : String.valueOf(c);
                };
                buf.append(escaped);
            }
            return buf.toString();
        }
    
    Registered: Sat Dec 20 08:55:33 UTC 2025
    - Last Modified: Thu Jul 24 01:52:43 UTC 2025
    - 1.7K bytes
    - Viewed (0)
Back to top