Search Options

Results per page
Sort
Preferred Languages
Advance

Results 231 - 240 of 304 for buf1 (0.04 sec)

  1. 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)
  2. tensorflow/c/eager/c_api_experimental.h

    // Serialize `attrs` as a tensorflow::NameAttrList protocol buffer (into `buf`),
    // containing the op name and a map of its attributes.
    TF_CAPI_EXPORT extern void TFE_OpAttrsSerialize(const TFE_OpAttrs* attrs,
                                                    TF_Buffer* buf,
                                                    TF_Status* status);
    
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Wed Feb 21 22:37:46 UTC 2024
    - 39.5K bytes
    - Viewed (0)
  3. 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)
  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. 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)
  7. android/guava-tests/test/com/google/common/io/LittleEndianDataInputStreamTest.java

        assertThrows(EOFException.class, () -> in.readUnsignedByte());
      }
    
      public void testReadUnsignedShort_eof() throws IOException {
        byte[] buf = {23};
        DataInput in = new LittleEndianDataInputStream(new ByteArrayInputStream(buf));
        assertThrows(EOFException.class, () -> in.readUnsignedShort());
      }
    
      @SuppressWarnings("DoNotCall")
      public void testReadLine() throws IOException {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 4.8K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/io/LittleEndianDataInputStreamTest.java

        assertThrows(EOFException.class, () -> in.readUnsignedByte());
      }
    
      public void testReadUnsignedShort_eof() throws IOException {
        byte[] buf = {23};
        DataInput in = new LittleEndianDataInputStream(new ByteArrayInputStream(buf));
        assertThrows(EOFException.class, () -> in.readUnsignedShort());
      }
    
      @SuppressWarnings("DoNotCall")
      public void testReadLine() throws IOException {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 4.8K 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