- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 104 for wc (0.12 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/etcd3/watcher.go
resultChanWG.Wait() close(wc.resultChan) } func (wc *watchChan) Stop() { wc.cancel() } func (wc *watchChan) ResultChan() <-chan watch.Event { return wc.resultChan } func (wc *watchChan) RequestWatchProgress() error { return wc.watcher.client.RequestProgress(wc.ctx) } // sync tries to retrieve existing data and send them to process.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Sep 25 10:26:38 UTC 2023 - 18.9K bytes - Viewed (0) -
docs/distributed/decom-encrypted-sse-s3.sh
./mc mirror internal myminio/versioned/ --quiet >/dev/null expected_checksum=$(./mc cat internal/dsync/drwmutex.go | md5sum) user_count=$(./mc admin user list myminio/ | wc -l) policy_count=$(./mc admin policy list myminio/ | wc -l) kill $pid (minio server http://localhost:9000/tmp/xl/{1...10}/disk{0...1} http://localhost:9001/tmp/xl/{11...30}/disk{0...3} 2>&1 >/tmp/expanded_1.log) & pid_1=$!
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon May 27 19:17:46 UTC 2024 - 4.5K bytes - Viewed (0) -
docs/distributed/decom-compressed-sse-s3.sh
./mc mirror internal myminio/versioned/ --quiet >/dev/null expected_checksum=$(./mc cat internal/dsync/drwmutex.go | md5sum) user_count=$(./mc admin user list myminio/ | wc -l) policy_count=$(./mc admin policy list myminio/ | wc -l) kill $pid (minio server http://localhost:9000/tmp/xl/{1...10}/disk{0...1} http://localhost:9001/tmp/xl/{11...30}/disk{0...3} 2>&1 >/tmp/expanded_1.log) & pid_1=$!
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon May 27 19:17:46 UTC 2024 - 4.3K bytes - Viewed (0) -
src/internal/fuzz/worker.go
// and closes it after the worker process closes the other end. func (wc *workerClient) Close() error { wc.mu.Lock() defer wc.mu.Unlock() // Close fuzzIn. This signals to the server that there are no more calls, // and it should exit. if err := wc.fuzzIn.Close(); err != nil { wc.fuzzOut.Close() return err }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 26 19:58:28 UTC 2024 - 37.7K bytes - Viewed (0) -
.github/workflows/multipart/migrate.sh
failed_count_site1=$(./s3-check-md5 -versions -access-key minioadmin -secret-key minioadmin -endpoint http://site1-nginx:9001 -bucket testbucket 2>&1 | grep FAILED | wc -l) failed_count_site2=$(./s3-check-md5 -versions -access-key minioadmin -secret-key minioadmin -endpoint http://site2-nginx:9002 -bucket testbucket 2>&1 | grep FAILED | wc -l) if [ $failed_count_site1 -ne 0 ]; then echo "failed with multipart on site1 uploads" exit 1 fi
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon May 27 19:17:46 UTC 2024 - 4.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_cache_interval_test.go
t.Run(c.name, func(t *testing.T) { wc := newTestWatchCache(capacity, &cache.Indexers{}) defer wc.Stop() for i := 0; i < c.eventsAddedToWatchcache; i++ { wc.Add(makeTestPod(fmt.Sprintf("pod%d", i), uint64(i))) } indexerFunc := func(i int) *watchCacheEvent { return wc.cache[i%wc.capacity] } wci := newCacheInterval( c.intervalStartIndex, wc.endIndex, indexerFunc,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 09:20:10 UTC 2024 - 11.6K bytes - Viewed (0) -
docs/site-replication/run-ssec-object-replication.sh
count1=$(./mc ls minio1/test-bucket/plainfile --insecure | wc -l) if [ "${count1}" -ne 1 ]; then echo "BUG: object minio1/test-bucket/plainfile not found" exit_1 fi count2=$(./mc ls minio1/test-bucket/encrypted --insecure | wc -l) if [ "${count2}" -ne 1 ]; then echo "BUG: object minio1/test-bucket/encrypted not found" exit_1 fi count3=$(./mc ls minio1/test-bucket/defpartsize --insecure | wc -l) if [ "${count3}" -ne 1 ]; then
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat May 18 18:19:01 UTC 2024 - 9.8K bytes - Viewed (0) -
src/net/smtp/example_test.go
log.Fatal(err) } if err := c.Rcpt("******@****.***"); err != nil { log.Fatal(err) } // Send the email body. wc, err := c.Data() if err != nil { log.Fatal(err) } _, err = fmt.Fprintf(wc, "This is the email body") if err != nil { log.Fatal(err) } err = wc.Close() if err != nil { log.Fatal(err) } // Send the QUIT command and close the connection. err = c.Quit()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sat Feb 07 22:23:10 UTC 2015 - 1.9K bytes - Viewed (0) -
docs/distributed/decom-encrypted.sh
./mc mirror internal myminio/versioned/ --quiet >/dev/null expected_checksum=$(./mc cat internal/dsync/drwmutex.go | md5sum) user_count=$(./mc admin user list myminio/ | wc -l) policy_count=$(./mc admin policy list myminio/ | wc -l) kill $pid (minio server http://localhost:9000/tmp/xl/{1...10}/disk{0...1} http://localhost:9001/tmp/xl/{11...30}/disk{0...3} 2>&1 >/tmp/expanded_1.log) & pid_1=$!
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon May 27 19:17:46 UTC 2024 - 4.1K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_container_windows.go
wc := &runtimeapi.WindowsContainerConfig{ Resources: m.generateWindowsContainerResources(pod, container), SecurityContext: &runtimeapi.WindowsContainerSecurityContext{}, } // setup security context effectiveSc := securitycontext.DetermineEffectiveSecurityContext(pod, container) if username != "" { wc.SecurityContext.RunAsUsername = username }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 22:40:29 UTC 2024 - 8K bytes - Viewed (0)