Search Options

Results per page
Sort
Preferred Languages
Advance

Results 221 - 230 of 276 for buf1 (0.03 sec)

  1. guava-tests/test/com/google/common/io/CharSourceTest.java

        assertTrue(source.wasStreamOpened());
        assertFalse(source.wasStreamClosed());
    
        StringWriter writer = new StringWriter();
        char[] buf = new char[64];
        int read;
        while ((read = reader.read(buf)) != -1) {
          writer.write(buf, 0, read);
        }
        reader.close();
        writer.close();
    
        assertTrue(source.wasStreamClosed());
        assertEquals(STRING, writer.toString());
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue May 07 15:26:58 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  2. internal/logger/target/http/http.go

    					currentGlobalBuffer <- v
    				default:
    					break drain
    				}
    			}
    		}
    	}()
    
    	lastBatchProcess := time.Now()
    
    	buf := bytebufferpool.Get()
    	enc := jsoniter.ConfigCompatibleWithStandardLibrary.NewEncoder(buf)
    	defer bytebufferpool.Put(buf)
    
    	isDirQueue := h.config.QueueDir != ""
    
    	// globalBuffer is always created or adjusted
    	// before this method is launched.
    	logChLock.Lock()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 11 22:20:42 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  3. cmd/test-utils_test.go

    	// Get canonical headers.
    	var buf bytes.Buffer
    	for _, k := range headers {
    		buf.WriteString(k)
    		buf.WriteByte(':')
    		switch {
    		case k == "host":
    			buf.WriteString(req.URL.Host)
    			fallthrough
    		default:
    			for idx, v := range headerMap[k] {
    				if idx > 0 {
    					buf.WriteByte(',')
    				}
    				buf.WriteString(v)
    			}
    			buf.WriteByte('\n')
    		}
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 77K bytes
    - Viewed (0)
  4. cmd/storage-datatypes_gen.go

    			if dc.IsNil() {
    				err = dc.ReadNil()
    				if err != nil {
    					err = msgp.WrapError(err, "Buf")
    					return
    				}
    				z.Buf = nil
    			} else {
    				z.Buf, err = dc.ReadBytes(z.Buf)
    				if err != nil {
    					err = msgp.WrapError(err, "Buf")
    					return
    				}
    				if z.Buf == nil {
    					z.Buf = make([]byte, 0)
    				}
    			}
    		default:
    			err = dc.Skip()
    			if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 150.2K bytes
    - Viewed (0)
  5. cmd/data-scanner.go

    	// Load current bloom cycle
    	var cycleInfo currentScannerCycle
    
    	buf, _ := readConfig(ctx, objAPI, dataUsageBloomNamePath)
    	if len(buf) == 8 {
    		cycleInfo.next = binary.LittleEndian.Uint64(buf)
    	} else if len(buf) > 8 {
    		cycleInfo.next = binary.LittleEndian.Uint64(buf[:8])
    		buf = buf[8:]
    		_, err := cycleInfo.UnmarshalMsg(buf)
    		bugLogIf(ctx, err)
    	}
    
    	scannerTimer := time.NewTimer(scannerCycle.Load())
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 21:10:34 UTC 2024
    - 48.4K bytes
    - Viewed (0)
  6. cmd/xl-storage_test.go

    				if err == io.ErrUnexpectedEOF {
    					if !bytes.Equal(testCase.expectedBuf, buf[:n]) {
    						t.Errorf("Case: %d %#v, expected: \"%s\", got: \"%s\"", i+1, testCase, string(testCase.expectedBuf), string(buf[:n]))
    					}
    					if n > int64(len(buf)) {
    						t.Errorf("Case: %d %#v, expected: %d, got: %d", i+1, testCase, testCase.bufSize, n)
    					}
    				}
    			}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 66.7K bytes
    - Viewed (0)
  7. cmd/xl-storage-disk-id-check.go

    		return p.storage.ReadFile(ctx, volume, path, offset, buf, verifier)
    	})
    }
    
    // Legacy API - does not have any deadlines
    func (p *xlStorageDiskIDCheck) AppendFile(ctx context.Context, volume string, path string, buf []byte) (err error) {
    	ctx, done, err := p.TrackDiskHealth(ctx, storageMetricAppendFile, volume, path)
    	if err != nil {
    		return err
    	}
    	defer done(int64(len(buf)), &err)
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:56:26 UTC 2024
    - 34.5K bytes
    - Viewed (0)
  8. cmd/handler-api.go

    	cgroupV2MemLimitFile = "/sys/fs/cgroup/memory.max"
    )
    
    func cgroupMemLimit() (limit uint64) {
    	buf, err := os.ReadFile(cgroupV2MemLimitFile)
    	if err != nil {
    		buf, err = os.ReadFile(cgroupV1MemLimitFile)
    	}
    	if err != nil {
    		return 0
    	}
    	limit, err = strconv.ParseUint(strings.TrimSpace(string(buf)), 10, 64)
    	if err != nil {
    		// The kernel can return valid but non integer values
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 26 17:07:10 UTC 2024
    - 10.4K bytes
    - Viewed (0)
  9. cmd/streaming-signature-v4_test.go

    		}
    	}
    }
    
    // Test parsing s3 chunk extension.
    func TestParseS3ChunkExtension(t *testing.T) {
    	type testCase struct {
    		buf       []byte
    		chunkSize []byte
    		chunkSign []byte
    	}
    
    	tests := []testCase{
    		// Test - 1 valid case.
    		{
    			[]byte("10000;chunk-signature=ad80c730a21e5b8d04586a2213dd63b9a0e99e0e2307b0ade35a65485a288648"),
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Apr 23 18:58:53 UTC 2021
    - 5.7K bytes
    - Viewed (0)
  10. tensorflow/c/eager/c_api_experimental_test.cc

      auto* cell2 = TFE_MonitoringGetCellStringGauge2(gauge2, "foo", "bar");
      TFE_MonitoringStringGaugeCellSet(cell2, "str");
      auto* buf = new TF_Buffer;
      TFE_MonitoringStringGaugeCellValue(cell2, buf);
      string data(static_cast<const char*>(buf->data), buf->length);
      TF_DeleteBuffer(buf);
      EXPECT_EQ(data, "str");
      TFE_MonitoringDeleteStringGauge2(gauge2);
      TF_DeleteStatus(status);
    }
    
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Thu Aug 03 03:14:26 UTC 2023
    - 31.5K bytes
    - Viewed (0)
Back to top