Search Options

Results per page
Sort
Preferred Languages
Advance

Results 201 - 210 of 276 for buf1 (0.03 sec)

  1. lib/wasm/wasm_exec.js

    			writeSync(fd, buf) {
    				outputBuf += decoder.decode(buf);
    				const nl = outputBuf.lastIndexOf("\n");
    				if (nl != -1) {
    					console.log(outputBuf.substring(0, nl));
    					outputBuf = outputBuf.substring(nl + 1);
    				}
    				return buf.length;
    			},
    			write(fd, buf, offset, length, position, callback) {
    				if (offset !== 0 || length !== buf.length || position !== null) {
    					callback(enosys());
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Aug 30 19:15:21 UTC 2024
    - 16.5K bytes
    - Viewed (0)
  2. cmd/erasure-decode_test.go

    		}
    		_, err = erasure.Decode(context.Background(), buf, bitrotReaders, offset, readLen, length, nil)
    		closeBitrotReaders(bitrotReaders)
    		if err != nil {
    			t.Fatal(err, offset, readLen)
    		}
    		got := buf.Bytes()
    		if !bytes.Equal(expected, got) {
    			t.Fatalf("read data is different from what was expected, offset=%d length=%d", offset, readLen)
    		}
    		buf.Reset()
    	}
    }
    
    // Benchmarks
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jan 30 20:43:25 UTC 2024
    - 21.1K bytes
    - Viewed (0)
  3. src/main/java/jcifs/smb1/smb1/TestLocking.java

        int numComplete = 0;
        long ltime = 0L;
    
        public void run()
        {
            try {
                SmbFile f = new SmbFile(url);
                SmbFile d = new SmbFile(f.getParent());
                byte[] buf = new byte[1024];
    
                for (int ii = 0; ii < numIter; ii++) {
    
                    synchronized (this) {
                        ltime = System.currentTimeMillis();
                        wait();
                    }
    
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 21:10:40 UTC 2019
    - 3.4K bytes
    - Viewed (0)
  4. cmd/peer-rest-server.go

    	// We have however a dynamic downstream buffer (ch).
    	buf := bytes.NewBuffer(grid.GetByteBuffer())
    	enc := json.NewEncoder(buf)
    	tmpEvt := struct{ Records []event.Event }{[]event.Event{{}}}
    	for {
    		select {
    		case <-ctx.Done():
    			grid.PutByteBuffer(buf.Bytes())
    			return nil
    		case ev := <-ch:
    			buf.Reset()
    			tmpEvt.Records[0] = ev
    			if err := enc.Encode(tmpEvt); err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 53.2K bytes
    - Viewed (0)
  5. cmd/data-usage_test.go

    	if err != nil {
    		t.Fatal(err)
    	}
    	e := want.find("abucket/dir2")
    	want.replace("abucket/dir2", "", *e)
    	var buf bytes.Buffer
    	err = want.serializeTo(&buf)
    	if err != nil {
    		t.Fatal(err)
    	}
    	t.Log("serialized size:", buf.Len(), "bytes")
    	var got dataUsageCache
    	err = got.deserialize(&buf)
    	if err != nil {
    		t.Fatal(err)
    	}
    	if got.Info.LastUpdate.IsZero() {
    		t.Error("lastupdate not set")
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 22:23:33 UTC 2024
    - 14.7K bytes
    - Viewed (0)
  6. src/main/java/jcifs/smb1/util/HMACT64.java

            md5.update(opad);
            return md5.digest(digest);
        }
    
        protected int engineDigest(byte[] buf, int offset, int len) {
            byte[] digest = md5.digest();
            md5.update(opad);
            md5.update(digest);
            try {
                return md5.digest(buf, offset, len);
            } catch (Exception ex) {
                throw new IllegalStateException();
            }
        }
    
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 20:39:42 UTC 2019
    - 3.4K bytes
    - Viewed (0)
  7. src/main/java/jcifs/util/HMACT64.java

            return this.md5.digest(digest);
        }
    
    
        @Override
        protected int engineDigest ( byte[] buf, int offset, int len ) {
            byte[] digest = this.md5.digest();
            this.md5.update(this.opad);
            this.md5.update(digest);
            try {
                return this.md5.digest(buf, offset, len);
            }
            catch ( Exception ex ) {
                throw new IllegalStateException();
            }
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 3.5K bytes
    - Viewed (0)
  8. 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
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Aug 12 08:38:15 UTC 2024
    - 5.2K bytes
    - Viewed (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...)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Feb 22 06:26:06 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/auth/chain/CommandChain.java

                    }
                }
            }
    
            public String getOutput() {
                final StringBuilder buf = new StringBuilder(100);
                for (final String value : list) {
                    buf.append(value).append("\n");
                }
                return buf.toString();
            }
    
        }
    
        public void setWorkingDirectory(final File workingDirectory) {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 9.3K bytes
    - Viewed (0)
Back to top