Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 361 for Buf (0.01 sec)

  1. 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)
  2. 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)
  3. 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)
  4. src/main/java/jcifs/smb1/smb1/BufferCache.java

            synchronized( cache ) {
                byte[] buf;
    
                if (freeBuffers > 0) {
                    for (int i = 0; i < MAX_BUFFERS; i++) {
                        if( cache[i] != null ) {
                            buf = (byte[])cache[i];
                            cache[i] = null;
                            freeBuffers--;
                            return buf;
                        }
                    }
                }
    
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 21:10:40 UTC 2019
    - 2.2K bytes
    - Viewed (0)
  5. 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)
  6. 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)
  7. 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)
  8. fess-crawler-lasta/src/test/java/org/codelibs/fess/crawler/util/CrawlerWebServer.java

                buf.append("-");
                buf.append(i);
                buf.append(".html\">File ");
                buf.append(count);
                buf.append("-");
                buf.append(i);
                buf.append("</a><br>");
                buf.append("<a href=\"dir");
                buf.append(count);
                buf.append("-");
                buf.append(i);
                buf.append("/index.html\">Dir ");
                buf.append(count);
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:36:27 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  9. 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)
  10. 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)
Back to top