- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 361 for Buf (0.01 sec)
-
cmd/xl-storage-format-utils.go
var fi FileInfo var err error var inData xlMetaInlineData if buf, data, e := isIndexedMetaV2(xlMetaBuf); e != nil { return FileInfo{}, e } else if buf != nil { inData = data fi, err = buf.ToFileInfo(volume, path, versionID, true) if len(buf) != 0 && errors.Is(err, errFileNotFound) { // This special case is needed to handle len(xlMeta.versions) == 0 return FileInfo{
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 08 15:29:58 UTC 2024 - 5.5K bytes - Viewed (0) -
src/main/java/jcifs/smb1/dcerpc/DcerpcPipeHandle.java
off = in.read(buf, 0, 1024); } else { off = in.readDirect(buf, 0, buf.length); } if (buf[0] != 5 && buf[1] != 0) throw new IOException("Unexpected DCERPC PDU header"); flags = buf[3] & 0xFF; // next read is start of new frag isStart = (flags & DCERPC_LAST_FRAG) == DCERPC_LAST_FRAG;
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Fri Mar 22 21:10:40 UTC 2019 - 3.7K bytes - Viewed (0) -
src/main/java/jcifs/smb1/dcerpc/DcerpcMessage.java
} void encode_header(NdrBuffer buf) { buf.enc_ndr_small(5); /* RPC version */ buf.enc_ndr_small(0); /* minor version */ buf.enc_ndr_small(ptype); buf.enc_ndr_small(flags); buf.enc_ndr_long(0x00000010); /* Little-endian / ASCII / IEEE */ buf.enc_ndr_short(length); buf.enc_ndr_short(0); /* length of auth_value */ buf.enc_ndr_long(call_id); }
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Fri Mar 22 20:39:42 UTC 2019 - 4.2K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/BufferCache.java
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Fri Mar 22 21:10:40 UTC 2019 - 2.2K bytes - Viewed (0) -
cmd/bitrot-whole.go
buf []byte // Holds bit-rot verified data } func (b *wholeBitrotReader) ReadAt(buf []byte, offset int64) (n int, err error) { if b.buf == nil { b.buf = make([]byte, b.tillOffset-offset) if _, err := b.disk.ReadFile(context.TODO(), b.volume, b.filePath, offset, b.buf, b.verifier); err != nil { return 0, err } } if len(b.buf) < len(buf) { return 0, errLessData }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Jan 31 02:11:45 UTC 2024 - 2.7K bytes - Viewed (0) -
cmd/config-common.go
} return nil, ObjectInfo{}, err } defer r.Close() buf, err := io.ReadAll(r) if err != nil { return nil, ObjectInfo{}, err } if len(buf) == 0 { return nil, ObjectInfo{}, errConfigNotFound } return buf, r.ObjInfo, nil } func readConfig(ctx context.Context, store objectIO, configFile string) ([]byte, error) { buf, _, err := readConfigWithMetadata(ctx, store, configFile, ObjectOptions{})
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 18 17:00:54 UTC 2023 - 3.1K bytes - Viewed (0) -
src/main/java/org/codelibs/core/xml/DomUtil.java
final String tag = element.getTagName(); buf.append('<'); buf.append(tag); appendAttrs(element.getAttributes(), buf); buf.append('>'); appendChildren(element.getChildNodes(), buf); buf.append("</"); buf.append(tag); buf.append('>'); } /** * {@link NodeList}の文字列表現を追加します。 * * @param children
Registered: Fri Nov 01 20:58:10 UTC 2024 - Last Modified: Thu Mar 07 01:59:08 UTC 2024 - 10.5K bytes - Viewed (0) -
fess-crawler-lasta/src/test/java/org/codelibs/fess/crawler/util/CrawlerWebServer.java
Registered: Sun Nov 10 03:50:12 UTC 2024 - Last Modified: Thu Feb 22 01:36:27 UTC 2024 - 6.3K bytes - Viewed (0) -
cmd/streaming-v4-unsigned.go
// the incoming AWS Signature V4 streaming signature. func (cr *s3UnsignedChunkedReader) Read(buf []byte) (n int, err error) { // First, if there is any unread data, copy it to the client // provided buffer. if cr.offset > 0 { n = copy(buf, cr.buffer[cr.offset:]) if n == len(buf) { cr.offset += n return n, nil } cr.offset = 0 buf = buf[n:] } // mustRead reads from input and compares against provided slice.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat May 06 02:53:12 UTC 2023 - 6.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/hash/HashingOutputStreamTest.java
byte[] buf = new byte[] {'y', 'a', 'm', 's'}; HashingOutputStream out = new HashingOutputStream(hashFunction, buffer); out.write(buf); verify(hashFunction).newHasher(); verify(hasher).putBytes(buf, 0, buf.length); verifyNoMoreInteractions(hashFunction, hasher); } public void testWrite_putByteArrayAtPos() throws Exception { byte[] buf = new byte[] {'y', 'a', 'm', 's'};
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 11 22:00:03 UTC 2024 - 3.1K bytes - Viewed (0)