- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 610 for Chan (0.18 sec)
-
cmd/erasure-common.go
func readMultipleFiles(ctx context.Context, disks []StorageAPI, req ReadMultipleReq, readQuorum int) ([]ReadMultipleResp, error) { resps := make([]chan ReadMultipleResp, len(disks)) for i := range resps { resps[i] = make(chan ReadMultipleResp, len(req.Files)) } g := errgroup.WithNErrs(len(disks)) // Read files in parallel across disks. for index := range disks { index := index
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 4.6K bytes - Viewed (0) -
guava-gwt/src-super/com/google/common/collect/super/com/google/common/collect/RegularImmutableBiMap.java
* limitations under the License. */ package com.google.common.collect; import java.util.HashMap; /** * GWT emulation of {@link RegularImmutableBiMap}. * * @author Jared Levy * @author Hayward Chan */ @ElementTypesAreNonnullByDefault @SuppressWarnings("serial") class RegularImmutableBiMap<K, V> extends ImmutableBiMap<K, V> { static final RegularImmutableBiMap<Object, Object> EMPTY =
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Feb 27 19:19:19 GMT 2024 - 2K bytes - Viewed (0) -
guava-testlib/src/com/google/common/collect/testing/google/BiMapGenerators.java
import java.util.Arrays; import java.util.Map; import java.util.Map.Entry; /** * Generators of various {@link com.google.common.collect.BiMap}s and derived collections. * * @author Jared Levy * @author Hayward Chan */ @GwtCompatible @ElementTypesAreNonnullByDefault public class BiMapGenerators { public static class ImmutableBiMapGenerator extends TestStringBiMapGenerator { @Override
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Feb 21 16:49:06 GMT 2024 - 2.2K bytes - Viewed (0) -
src/cmd/api/main_test.go
buf.WriteString("map[") w.writeType(buf, typ.Key()) buf.WriteByte(']') w.writeType(buf, typ.Elem()) case *types.Chan: var s string switch typ.Dir() { case types.SendOnly: s = "chan<- " case types.RecvOnly: s = "<-chan " case types.SendRecv: s = "chan " default: panic("unreachable") } buf.WriteString(s) w.writeType(buf, typ.Elem()) case *types.Alias:
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Tue Apr 09 20:48:51 GMT 2024 - 31.4K bytes - Viewed (0) -
cmd/metrics-resource.go
func (c *minioResourceCollector) Describe(ch chan<- *prometheus.Desc) { ch <- c.desc } // Collect is called by the Prometheus registry when collecting metrics. func (c *minioResourceCollector) Collect(out chan<- prometheus.Metric) { var wg sync.WaitGroup publish := func(in <-chan MetricV2) { defer wg.Done() for metric := range in {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Apr 23 23:56:12 GMT 2024 - 17.4K bytes - Viewed (0) -
cmd/grid.go
) // globalGrid is the global grid manager. var globalGrid atomic.Pointer[grid.Manager] // globalGridStart is a channel that will block startup of grid connections until closed. var globalGridStart = make(chan struct{}) func initGlobalGrid(ctx context.Context, eps EndpointServerPools) error { hosts, local := eps.GridHosts() g, err := grid.NewManager(ctx, grid.ManagerOptions{
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Mar 26 15:00:38 GMT 2024 - 2K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/collect/testing/google/BiMapGenerators.java
import java.util.Arrays; import java.util.Map; import java.util.Map.Entry; /** * Generators of various {@link com.google.common.collect.BiMap}s and derived collections. * * @author Jared Levy * @author Hayward Chan */ @GwtCompatible @ElementTypesAreNonnullByDefault public class BiMapGenerators { public static class ImmutableBiMapGenerator extends TestStringBiMapGenerator { @Override
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Feb 21 16:49:06 GMT 2024 - 2.2K bytes - Viewed (0) -
doc/go_mem.html
may be implemented as a write of each individual sub-value, in any order. </p> <p> A read <i>r</i> of a memory location <i>x</i> holding a value that is not larger than a machine word must observe some write <i>w</i> such that <i>r</i> does not happen before <i>w</i> and there is no write <i>w'</i> such that <i>w</i> happens before <i>w'</i> and <i>w'</i> happens before <i>r</i>.
HTML - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Mon Mar 04 15:54:42 GMT 2024 - 26.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/ForwardingMultimapTest.java
import com.google.common.testing.EqualsTester; import com.google.common.testing.ForwardingWrapperTester; import junit.framework.TestCase; /** * Unit test for {@link ForwardingMultimap}. * * @author Hayward Chan */ public class ForwardingMultimapTest extends TestCase { @SuppressWarnings("rawtypes") public void testForwarding() { new ForwardingWrapperTester() .testForwarding( Multimap.class,
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Feb 22 20:09:59 GMT 2024 - 1.8K bytes - Viewed (0) -
internal/event/targetlist.go
currentSendCalls atomic.Int64 totalEvents atomic.Int64 eventsSkipped atomic.Int64 eventsErrorsTotal atomic.Int64 sync.RWMutex targets map[TargetID]Target queue chan asyncEvent ctx context.Context statLock sync.RWMutex targetStats map[TargetID]targetStat } type targetStat struct { // The number of concurrent async Send calls per targets currentSendCalls int64
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.2K bytes - Viewed (0)