Search Options

Results per page
Sort
Preferred Languages
Advance

Results 801 - 810 of 1,191 for makeAs (0.16 sec)

  1. ci/official/utilities/setup.sh

    # See the License for the specific language governing permissions and
    # limitations under the License.
    # ==============================================================================
    #
    # Common setup for all TF scripts.
    #
    # Make as FEW changes to this file as possible. It should not contain utility
    # functions (except for tfrun); use dedicated scripts instead and reference them
    # specifically. Use your best judgment to keep the scripts in this directory
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Wed Aug 07 23:01:25 UTC 2024
    - 6K bytes
    - Viewed (0)
  2. cmd/bucket-policy-handlers_test.go

    func testCreateBucket(obj ObjectLayer, instanceType, bucketName string, apiRouter http.Handler,
    	credentials auth.Credentials, t *testing.T,
    ) {
    	bucketName1 := fmt.Sprintf("%s-1", bucketName)
    
    	const n = 100
    	start := make(chan struct{})
    	var ok, errs int
    	var wg sync.WaitGroup
    	var mu sync.Mutex
    	wg.Add(n)
    	for i := 0; i < n; i++ {
    		go func() {
    			defer wg.Done()
    			// Sync start.
    			<-start
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:50:49 UTC 2024
    - 32.9K bytes
    - Viewed (0)
  3. compat/maven-model-builder/src/test/java/org/apache/maven/model/interpolation/AbstractModelInterpolatorTest.java

            Calendar cal = Calendar.getInstance();
            cal.setTimeZone(MavenBuildTimestamp.DEFAULT_BUILD_TIME_ZONE);
            cal.set(Calendar.HOUR, 12);
            cal.set(Calendar.AM_PM, Calendar.AM);
    
            // just to make sure all the bases are covered...
            cal.set(Calendar.HOUR_OF_DAY, 0);
            cal.set(Calendar.MINUTE, 16);
            cal.set(Calendar.SECOND, 0);
            cal.set(Calendar.YEAR, 1976);
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 22.2K bytes
    - Viewed (0)
  4. cmd/data-usage_test.go

    			t.Fatal(err)
    		}
    		err = os.WriteFile(filepath.Join(base, bucket, f.name), make([]byte, f.size), os.ModePerm)
    		if err != nil {
    			t.Fatal(err)
    		}
    	}
    }
    
    // generateUsageTestFiles create nFolders * nFiles files of size bytes each.
    func generateUsageTestFiles(t *testing.T, base, bucket string, nFolders, nFiles, size int) {
    	pl := make([]byte, size)
    	for i := 0; i < nFolders; i++ {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 22:23:33 UTC 2024
    - 14.7K bytes
    - Viewed (0)
  5. internal/event/target/elasticsearch.go

    		}
    	}
    
    	target := &ElasticsearchTarget{
    		id:         event.TargetID{ID: id, Name: "elasticsearch"},
    		args:       args,
    		store:      queueStore,
    		loggerOnce: loggerOnce,
    		quitCh:     make(chan struct{}),
    	}
    
    	if target.store != nil {
    		store.StreamItems(target.store, target, target.quitCh, target.loggerOnce)
    	}
    
    	return target, nil
    }
    
    // ES Client definitions and methods
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 15K bytes
    - Viewed (0)
  6. cmd/bucket-metadata-sys.go

    }
    
    // concurrently load bucket metadata to speed up loading bucket metadata.
    func (sys *BucketMetadataSys) concurrentLoad(ctx context.Context, buckets []string) {
    	g := errgroup.WithNErrs(len(buckets))
    	bucketMetas := make([]BucketMetadata, len(buckets))
    	for index := range buckets {
    		index := index
    		g.Go(func() error {
    			// Sleep and stagger to avoid blocked CPU and thundering
    			// herd upon start up sequence.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 28 15:32:18 UTC 2024
    - 20.4K bytes
    - Viewed (0)
  7. tensorflow/c/eager/c_api.h

    //
    // Very similar to TF_OperationDescription with some differences:
    // (1) TF_Output or TFE_TensorHandle* as arguments to TF_AddInput,
    //     TF_AddInputList
    // (2) TF_ColocateWith, TF_AddControlInput etc. do not make sense.
    // (3) Implementation detail: Avoid use of NodeBuilder/NodeDefBuilder since
    //     the additional sanity checks there seem unnecessary;
    typedef struct TFE_Op TFE_Op;
    
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Thu Apr 27 21:07:00 UTC 2023
    - 22.8K bytes
    - Viewed (0)
  8. cmd/leak-detect_test.go

    	relevantRoutines map[string]bool
    }
    
    // NewLeakDetect - Initialize a LeakDetector with the snapshot of relevant Go routines.
    func NewLeakDetect() LeakDetect {
    	snapshot := LeakDetect{
    		relevantRoutines: make(map[string]bool),
    	}
    	for _, g := range pickRelevantGoroutines() {
    		snapshot.relevantRoutines[g] = true
    	}
    	return snapshot
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  9. internal/etag/reader.go

    	Expected ETag
    	Computed ETag
    }
    
    func (v VerifyError) Error() string {
    	return fmt.Sprintf("etag: expected ETag %q does not match computed ETag %q", v.Expected, v.Computed)
    }
    
    // UUIDHash - use uuid to make md5sum
    type UUIDHash struct {
    	uuid []byte
    }
    
    // Write -  implement hash.Hash Write
    func (u UUIDHash) Write(p []byte) (n int, err error) {
    	return len(p), nil
    }
    
    // Sum -  implement md5.Sum
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 4.8K bytes
    - Viewed (0)
  10. internal/event/targetlist_test.go

    	return target.send(eventData)
    }
    
    // Store - Returns a nil store.
    func (target ExampleTarget) Store() TargetStore {
    	return nil
    }
    
    func (target ExampleTarget) send(eventData Event) error {
    	b := make([]byte, 1)
    	if _, err := rand.Read(b); err != nil {
    		panic(err)
    	}
    
    	time.Sleep(time.Duration(b[0]) * time.Millisecond)
    
    	if target.sendErr {
    		return errors.New("send error")
    	}
    
    	return nil
    }
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Dec 05 10:16:33 UTC 2023
    - 6.1K bytes
    - Viewed (0)
Back to top