Search Options

Results per page
Sort
Preferred Languages
Advance

Results 121 - 130 of 467 for Uint64 (0.27 sec)

  1. tensorflow/c/eager/c_api_test_util.cc

    }
    
    TFE_Op* SendOp(TFE_Context* ctx, TFE_TensorHandle* in,
                   const std::string& op_name, const std::string& send_device,
                   const std::string& recv_device,
                   tensorflow::uint64 send_device_incarnation) {
      TF_Status* status = TF_NewStatus();
      TFE_Op* op = TFE_NewOp(ctx, op_name.c_str(), status);
      CHECK_EQ(TF_OK, TF_GetCode(status)) << TF_Message(status);
      TFE_OpAddInput(op, in, status);
    Registered: Tue Oct 29 12:39:09 UTC 2024
    - Last Modified: Wed Feb 21 22:37:46 UTC 2024
    - 23.5K bytes
    - Viewed (0)
  2. internal/grid/stream.go

    	// If the request context is canceled, the stream will no longer process requests.
    	// Requests sent cannot be used any further by the called.
    	Requests chan<- []byte
    
    	muxID uint64
    	ctx   context.Context
    }
    
    // Send a payload to the remote server.
    func (s *Stream) Send(b []byte) error {
    	if s.Requests == nil {
    		return errors.New("stream does not accept requests")
    	}
    	select {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 3.1K bytes
    - Viewed (0)
  3. internal/bpool/bpool.go

    type BytePoolCap struct {
    	c    chan []byte
    	w    int
    	wcap int
    }
    
    // NewBytePoolCap creates a new BytePool bounded to the given maxSize, with new
    // byte arrays sized based on width.
    func NewBytePoolCap(maxSize uint64, width int, capwidth int) (bp *BytePoolCap) {
    	if capwidth <= 0 {
    		panic("total buffer capacity must be provided")
    	}
    	if capwidth < 64 {
    		panic("buffer capped with smaller than 64 bytes is not supported")
    	}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Aug 29 01:40:52 UTC 2024
    - 3K bytes
    - Viewed (0)
  4. internal/config/identity/openid/jwt_test.go

    		expectedFailure bool
    	}{
    		{"", "", true},
    		{"-1", "0", true},
    		{"-1", "900", true},
    		{"1574812326", "900", false},
    		{1574812326, "900", false},
    		{int64(1574812326), "900", false},
    		{int(1574812326), "900", false},
    		{uint(1574812326), "900", false},
    		{uint64(1574812326), "900", false},
    		{json.Number("1574812326"), "900", false},
    		{1574812326.000, "900", false},
    		{time.Duration(3) * time.Minute, "900", false},
    	}
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 8.3K bytes
    - Viewed (0)
  5. cmd/metrics-realtime.go

    			continue
    		}
    
    		var dm madmin.DiskMetric
    		dm.NDisks = 1
    		if d.Healing {
    			dm.Healing++
    		}
    		if d.Metrics != nil {
    			dm.LifeTimeOps = make(map[string]uint64, len(d.Metrics.APICalls))
    			for k, v := range d.Metrics.APICalls {
    				if v != 0 {
    					dm.LifeTimeOps[k] = v
    				}
    			}
    			dm.LastMinute.Operations = make(map[string]madmin.TimedAction, len(d.Metrics.APICalls))
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sat Jun 01 05:16:24 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  6. internal/event/target/nsq.go

    	Topic       string    `json:"topic"`
    	TLS         struct {
    		Enable     bool `json:"enable"`
    		SkipVerify bool `json:"skipVerify"`
    	} `json:"tls"`
    	QueueDir   string `json:"queueDir"`
    	QueueLimit uint64 `json:"queueLimit"`
    }
    
    // Validate NSQArgs fields
    func (n NSQArgs) Validate() error {
    	if !n.Enable {
    		return nil
    	}
    
    	if n.NSQDAddress.IsEmpty() {
    		return errors.New("empty nsqdAddress")
    	}
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  7. cmd/batch-job-common-types.go

    // - sz < sf.UpperBound, when sf.UpperBound alone is specified
    // - sf.LowerBound < sz < sf.UpperBound when both are specified,
    func (sf BatchJobSizeFilter) InRange(sz int64) bool {
    	if sf.UpperBound > 0 && sz > int64(sf.UpperBound) {
    		return false
    	}
    
    	if sf.LowerBound > 0 && sz < int64(sf.LowerBound) {
    		return false
    	}
    	return true
    }
    
    // Validate checks if sf is a valid batch-job size filter
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Jun 11 03:13:30 UTC 2024
    - 7.9K bytes
    - Viewed (0)
  8. cmd/streaming-signature-v4.go

    func parseChunkSignature(chunk []byte) []byte {
    	chunkSplits := bytes.SplitN(chunk, []byte(s3ChunkSignatureStr), 2)
    	return chunkSplits[1]
    }
    
    // parse hex to uint64.
    func parseHexUint(v []byte) (n uint64, err error) {
    	for i, b := range v {
    		switch {
    		case '0' <= b && b <= '9':
    			b -= '0'
    		case 'a' <= b && b <= 'f':
    			b = b - 'a' + 10
    		case 'A' <= b && b <= 'F':
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu May 16 23:13:47 UTC 2024
    - 18.2K bytes
    - Viewed (0)
  9. internal/grid/grid_test.go

    		runtime.Gosched()
    		stats := c.Stats()
    		if stats.IncomingStreams != 0 {
    			if i > 0 {
    				time.Sleep(100 * time.Millisecond)
    				continue
    			}
    			var found []uint64
    			c.inStream.Range(func(key uint64, value *muxServer) bool {
    				found = append(found, key)
    				return true
    			})
    			t.Errorf("expected no active streams, got %d incoming: %v", stats.IncomingStreams, found)
    		}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 36.4K bytes
    - Viewed (0)
  10. internal/kms/config.go

    			conn: &kmsConn{
    				enclave:    env.Get(EnvKMSEnclave, ""),
    				defaultKey: env.Get(EnvKMSDefaultKey, ""),
    				client:     client,
    			},
    			latencyBuckets: defaultLatencyBuckets,
    			latency:        make([]atomic.Uint64, len(defaultLatencyBuckets)),
    		}, nil
    	case lookup(EnvKESEndpoint):
    		rawEndpoint := env.Get(EnvKESEndpoint, "")
    		if rawEndpoint == "" {
    			return nil, errors.New("kms: no KES server endpoint provided")
    		}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Aug 15 11:46:39 UTC 2024
    - 14.2K bytes
    - Viewed (0)
Back to top