Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 441 - 450 of 2,661 for same (0.02 seconds)

  1. internal/logger/target/http/http.go

    	currentCap := 0
    	name := newTgt.Name()
    
    	currentBuff, ok := logChBuffers[name]
    	if !ok {
    		logChBuffers[name] = make(chan any, requiredCap)
    		currentCap = requiredCap
    	} else {
    		currentCap = cap(currentBuff)
    		requiredCap += len(currentBuff)
    	}
    
    	if requiredCap > currentCap {
    		logChBuffers[name] = make(chan any, requiredCap)
    
    		if len(currentBuff) > 0 {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 15.6K bytes
    - Click Count (0)
  2. tensorflow/c/c_api_function_test.cc

      std::vector<IOSpec> v;
      for (const string& name : names) {
        v.push_back(IOSpec(name, DT_INVALID));
      }
      return v;
    }
    
    // Specification for an expected edge.
    // src is either:
    // - input name (as it appears in FunctionDef)
    // - name of output tensor (in nested "add:z:0" format)
    // dst is either:
    // - output name (as it appears in FunctionDef)
    Created: Tue Dec 30 12:39:10 GMT 2025
    - Last Modified: Mon Nov 17 00:00:38 GMT 2025
    - 63.6K bytes
    - Click Count (1)
  3. cmd/xl-storage-disk-id-check.go

    }
    
    // DeleteVersions deletes slice of versions, it can be same object
    // or multiple objects.
    func (p *xlStorageDiskIDCheck) DeleteVersions(ctx context.Context, volume string, versions []FileInfoVersions, opts DeleteOptions) (errs []error) {
    	// Merely for tracing storage
    	path := ""
    	if len(versions) > 0 {
    		path = versions[0].Name
    	}
    	errs = make([]error, len(versions))
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Apr 25 05:41:04 GMT 2025
    - 34.5K bytes
    - Click Count (0)
  4. internal/ringbuffer/ring_buffer.go

    // If some data is available but not len(p) bytes, Read conventionally returns what is available instead of waiting for more.
    // When Read encounters an error or end-of-file condition after successfully reading n > 0 bytes, it returns the number of bytes read.
    // It may return the (non-nil) error from the same call or return the error (and n == 0) from a subsequent call.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 13.3K bytes
    - Click Count (0)
  5. cmd/admin-handlers-config-kv.go

    	if verr := validateConfig(ctx, result.Cfg, result.SubSys); verr != nil {
    		err = badConfigErr{Err: verr}
    		return result, err
    	}
    
    	// Check if subnet proxy being set and if so set the same value to proxy of subnet
    	// target of logger webhook configuration
    	result.LoggerWebhookCfgUpdated = setLoggerWebhookSubnetProxy(result.SubSys, result.Cfg)
    
    	// Update the actual server config on disk.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 15.8K bytes
    - Click Count (1)
  6. internal/config/storageclass/storage-class.go

    			return -1
    		}
    		return sCfg.Standard.Parity
    	}
    }
    
    // ShouldInline returns true if the shardSize is worthy of inline
    // if versioned is true then we chosen 1/8th inline block size
    // to satisfy the same constraints.
    func (sCfg *Config) ShouldInline(shardSize int64, versioned bool) bool {
    	if shardSize < 0 {
    		return false
    	}
    
    	ConfigLock.RLock()
    	inlineBlock := int64(128 * humanize.KiByte)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 12.3K bytes
    - Click Count (0)
  7. compat/maven-artifact/src/test/java/org/apache/maven/artifact/versioning/ComparableVersionTest.java

            assertEquals(0, c1.compareTo(c2), "expected " + v1 + " == " + v2);
            assertEquals(0, c2.compareTo(c1), "expected " + v2 + " == " + v1);
            assertEquals(c1.hashCode(), c2.hashCode(), "expected same hashcode for " + v1 + " and " + v2);
            assertEquals(c1, c2, "expected " + v1 + ".equals( " + v2 + " )");
            assertEquals(c2, c1, "expected " + v2 + ".equals( " + v1 + " )");
        }
    
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Fri Mar 21 04:56:21 GMT 2025
    - 17.8K bytes
    - Click Count (0)
  8. misc/cgo/gmp/gmp.go

    	x.doinit()
    	y.doinit()
    	z.doinit()
    	C.mpz_tdiv_q(&z.i[0], &x.i[0], &y.i[0])
    	return z
    }
    
    // Mod sets z = x % y and returns z.
    // Like the result of the Go % operator, z has the same sign as x.
    func (z *Int) Mod(x, y *Int) *Int {
    	x.doinit()
    	y.doinit()
    	z.doinit()
    	C.mpz_tdiv_r(&z.i[0], &x.i[0], &y.i[0])
    	return z
    }
    
    // Lsh sets z = x << s and returns z.
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Mon Apr 11 16:34:30 GMT 2022
    - 9.5K bytes
    - Click Count (0)
  9. LICENSE

          comment syntax for the file format. We also recommend that a
          file or class name and description of purpose be included on the
          same "printed page" as the copyright notice for easier
          identification within third-party archives.
    
       Copyright [yyyy] [name of copyright owner]
    
       Licensed under the Apache License, Version 2.0 (the "License");
    Created: Tue Dec 30 12:39:10 GMT 2025
    - Last Modified: Mon Nov 29 17:31:56 GMT 2021
    - 13.3K bytes
    - Click Count (0)
  10. cmd/erasure-metadata.go

    	}
    
    	dataBlocks := len(partsMetaData) - parityBlocks
    
    	writeQuorum := dataBlocks
    	if dataBlocks == parityBlocks {
    		writeQuorum++
    	}
    
    	// Since all the valid erasure code meta updated at the same time are equivalent, pass dataBlocks
    	// from latestFileInfo to get the quorum
    	return dataBlocks, writeQuorum, nil
    }
    
    const (
    	tierFVID     = "tier-free-versionID"
    	tierFVMarker = "tier-free-marker"
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 21.3K bytes
    - Click Count (0)
Back to Top