- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 408 for Chan (0.37 sec)
-
cni/pkg/nodeagent/ztunnelserver_test.go
if sent == nil { panic("expected snapshot sent") } sendAck(ztunClient) // now remove the pod ztunnelServer := fixture.ztunServer errChan := make(chan error) go func() { errChan <- ztunnelServer.PodDeleted(ctx, uid) }() // read the msg to delete from ztunnel m, fds = readRequest(t, ztunClient) assert.Equal(t, len(fds), 0)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 8.6K 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) -
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 May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 26 15:00:38 GMT 2024 - 2K bytes - Viewed (0) -
guava-gwt/src-super/com/google/common/collect/super/com/google/common/collect/RegularImmutableSortedSet.java
import java.util.Comparator; import java.util.SortedSet; import org.checkerframework.checker.nullness.qual.Nullable; /** * GWT emulation of {@link RegularImmutableSortedSet}. * * @author Hayward Chan */ @ElementTypesAreNonnullByDefault final class RegularImmutableSortedSet<E> extends ImmutableSortedSet<E> { /** true if this set is a subset of another immutable sorted set. */ final boolean isSubset;
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Jan 23 18:43:40 GMT 2024 - 1.4K bytes - Viewed (0) -
guava-gwt/src-super/com/google/common/collect/super/com/google/common/collect/SingletonImmutableBiMap.java
import java.util.Collections; import org.checkerframework.checker.nullness.qual.Nullable; /** * GWT emulation of {@link SingletonImmutableBiMap}. * * @author Hayward Chan */ @ElementTypesAreNonnullByDefault final class SingletonImmutableBiMap<K, V> extends ImmutableBiMap<K, V> { // These references are used both by the custom field serializer, and by the
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Jan 23 18:43:40 GMT 2024 - 2.1K bytes - Viewed (0) -
internal/event/target/redis.go
initOnce once.Init id event.TargetID args RedisArgs pool *redis.Pool store store.Store[event.Event] firstPing bool loggerOnce logger.LogOnce quitCh chan struct{} } // ID - returns target ID. func (target *RedisTarget) ID() event.TargetID { return target.id } // Name - returns the Name of the target. func (target *RedisTarget) Name() string {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 19 04:37:54 GMT 2024 - 9.1K bytes - Viewed (0) -
guava-gwt/test-super/com/google/common/collect/testing/super/com/google/common/collect/testing/testers/Platform.java
* limitations under the License. */ package com.google.common.collect.testing.testers; import com.google.common.annotations.GwtCompatible; /** * The emulation source used in GWT. * * @author Hayward Chan */ @GwtCompatible(emulated = true) final class Platform { // Use fewer steps in the ListIteratorTester in ListListIteratorTester because it's slow in prod // mode.
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Oct 04 15:31:40 GMT 2023 - 2.3K bytes - Viewed (0) -
internal/event/target/mqtt.go
} // MQTTTarget - MQTT target. type MQTTTarget struct { initOnce once.Init id event.TargetID args MQTTArgs client mqtt.Client store store.Store[event.Event] quitCh chan struct{} loggerOnce logger.LogOnce } // ID - returns target ID. func (target *MQTTTarget) ID() event.TargetID { return target.id } // Name - returns the Name of the target.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Oct 07 15:07:38 GMT 2023 - 8.2K 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 May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.2K bytes - Viewed (0) -
internal/s3select/json/reader.go
"github.com/minio/minio/internal/s3select/sql" "github.com/bcicen/jstream" ) // Reader - JSON record reader for S3Select. type Reader struct { args *ReaderArgs decoder *jstream.Decoder valueCh chan *jstream.MetaValue readCloser io.ReadCloser } // Read - reads single record. func (r *Reader) Read(dst sql.Record) (sql.Record, error) { v, ok := <-r.valueCh if !ok { if err := r.decoder.Err(); err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 24 03:58:53 GMT 2022 - 3K bytes - Viewed (0)