- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 578 for Chan (0.14 sec)
-
src/builtin/builtin.go
// constant. See the Go language specification's "Length and capacity" section for // details. func cap(v Type) int // The make built-in function allocates and initializes an object of type // slice, map, or chan (only). Like new, the first argument is a type, not a // value. Unlike new, make's return type is the same as the type of its // argument, not a pointer to it. The specification of the result depends on // the type: //
Go - Registered: Tue Apr 23 11:13:09 GMT 2024 - Last Modified: Thu Apr 11 20:22:45 GMT 2024 - 12.7K bytes - Viewed (0) -
cmd/bucket-replication-utils.go
} type replicationResyncer struct { // map of bucket to their resync status statusMap map[string]BucketReplicationResyncStatus workerSize int resyncCancelCh chan struct{} workerCh chan struct{} sync.RWMutex } const ( replicationDir = ".replication" resyncFileName = "resync.bin" resyncMetaFormat = 1 resyncMetaVersionV1 = 1
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 26.2K bytes - Viewed (0) -
istioctl/pkg/admin/istiodconfig.go
return fmt.Errorf("cannot update resource %s, got status %s", scope.Name, resp.Status) } return nil } func (c *ControlzClient) PutScopes(scopes []*ScopeInfo) error { ch := make(chan struct { err error scopeName string }, len(scopes)) var wg sync.WaitGroup for _, scope := range scopes { wg.Add(1) go func(si *ScopeInfo) { defer wg.Done() err := c.PutScope(si)
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 13.5K bytes - Viewed (0) -
cmd/metacache-entries.go
// The entry not chosen will be discarded. // If the context is canceled the function will return the error, // otherwise the function will return nil. func mergeEntryChannels(ctx context.Context, in []chan metaCacheEntry, out chan<- metaCacheEntry, readQuorum int) error { defer xioutil.SafeClose(out) top := make([]*metaCacheEntry, len(in)) nDone := 0 ctxDone := ctx.Done() // Use simpler forwarder. if len(in) == 1 {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Apr 19 16:43:43 GMT 2024 - 23.2K bytes - Viewed (0) -
cmd/sftp-server-driver.go
defer cancel() if prefix == "" { // if all objects are not deleted yet this call may fail. return clnt.RemoveBucket(cctx, bucket) } objectsCh := make(chan minio.ObjectInfo) // Send object names that are needed to be removed to objectsCh go func() { defer xioutil.SafeClose(objectsCh) opts := minio.ListObjectsOptions{ Prefix: prefix,
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Apr 19 12:23:42 GMT 2024 - 12.9K bytes - Viewed (0) -
misc/ios/go_ios_exec.go
} // startDebugBridge ensures that the idevicedebugserverproxy runs on // port 3222. func startDebugBridge() (func(), error) { errChan := make(chan error, 1) cmd := idevCmd(exec.Command("idevicedebugserverproxy", "3222")) var stderr bytes.Buffer cmd.Stderr = &stderr if err := cmd.Start(); err != nil { return nil, fmt.Errorf("idevicedebugserverproxy: %v", err)
Go - Registered: Tue Apr 23 11:13:09 GMT 2024 - Last Modified: Mon Apr 11 16:34:30 GMT 2022 - 23.4K bytes - Viewed (0) -
internal/kms/kes.go
// to authenticate to KMS via mTLS. Certificate *certs.Certificate // ReloadCertEvents is an event channel that receives // the reloaded client certificate. ReloadCertEvents <-chan tls.Certificate // RootCAs is a set of root CA certificates // to verify the KMS server TLS certificate. RootCAs *x509.CertPool } // NewWithConfig returns a new KMS using the given // configuration.
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Apr 16 15:43:39 GMT 2024 - 14.9K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/ForwardingMapTest.java
import junit.framework.TestCase; import junit.framework.TestSuite; import org.checkerframework.checker.nullness.qual.Nullable; /** * Unit test for {@link ForwardingMap}. * * @author Hayward Chan * @author Louis Wasserman */ public class ForwardingMapTest extends TestCase { static class StandardImplForwardingMap<K, V> extends ForwardingMap<K, V> { private final Map<K, V> backingMap;
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Apr 19 19:24:36 GMT 2023 - 12.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/ForwardingMapTest.java
import junit.framework.TestCase; import junit.framework.TestSuite; import org.checkerframework.checker.nullness.qual.Nullable; /** * Unit test for {@link ForwardingMap}. * * @author Hayward Chan * @author Louis Wasserman */ public class ForwardingMapTest extends TestCase { static class StandardImplForwardingMap<K, V> extends ForwardingMap<K, V> { private final Map<K, V> backingMap;
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Apr 19 19:24:36 GMT 2023 - 12.7K bytes - Viewed (0) -
cni/pkg/repair/repaircontroller.go
controllers.WithReconciler(c.Reconcile), controllers.WithMaxAttempts(5)) c.pods.AddEventHandler(controllers.ObjectHandler(c.queue.AddObject)) return c, nil } func (c *Controller) Run(stop <-chan struct{}) { kube.WaitForCacheSync("repair controller", stop, c.pods.HasSynced) c.queue.Run(stop) c.pods.ShutdownHandlers() } func (c *Controller) Reconcile(key types.NamespacedName) error {
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Sat Feb 10 00:31:55 GMT 2024 - 10.4K bytes - Viewed (0)