- Sort Score
- Num 10 results
- Language All
Results 301 - 310 of 396 for chain (0.03 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
guava-gwt/test-super/com/google/common/collect/testing/super/com/google/common/collect/testing/Platform.java
import java.util.Arrays; /** * Minimal GWT emulation of {@code com.google.common.collect.testing.Platform}. * * <p><strong>This .java file should never be consumed by javac.</strong> * * @author Hayward Chan */ final class Platform { // Class.cast is not supported in GWT. static void checkCast(Class<?> clazz, Object obj) {} static <T> T[] clone(T[] array) {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Dec 04 17:37:03 GMT 2017 - 2.1K bytes - Click Count (0) -
internal/event/target/mysql.go
args MySQLArgs updateStmt *sql.Stmt deleteStmt *sql.Stmt insertStmt *sql.Stmt db *sql.DB store store.Store[event.Event] firstPing bool loggerOnce logger.LogOnce quitCh chan struct{} } // ID - returns target ID. func (target *MySQLTarget) ID() event.TargetID { return target.id } // Name - returns the Name of the target. func (target *MySQLTarget) Name() string {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Mar 30 00:56:02 GMT 2025 - 11.6K bytes - Click Count (0) -
src/bufio/net_test.go
} // Start a goroutine for the server to accept one connection // and read all the data sent on the connection, // reporting the number of bytes read on ch. ch := make(chan int, 1) var wg sync.WaitGroup wg.Add(1) go func() { defer wg.Done() tot := 0 defer func() { ch <- tot }() serverConn, err := server.Accept() if err != nil { t.Error(err)
Created: Tue Apr 07 11:13:11 GMT 2026 - Last Modified: Fri Feb 07 19:37:07 GMT 2025 - 1.9K bytes - Click Count (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
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 9.2K bytes - Click Count (0) -
android/guava-testlib/src/com/google/common/collect/testing/google/SortedMapGenerators.java
import org.jspecify.annotations.NullMarked; /** * Generators of sorted maps and derived collections. * * @author Kevin Bourrillion * @author Jesse Wilson * @author Jared Levy * @author Hayward Chan * @author Chris Povirk * @author Louis Wasserman */ @GwtCompatible @NullMarked public class SortedMapGenerators { public static class ImmutableSortedMapGenerator extends TestStringSortedMapGenerator {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sun Aug 10 19:54:19 GMT 2025 - 4.8K bytes - Click Count (0) -
cmd/globals.go
globalIsTLS bool globalTLSCerts *certs.Manager globalHTTPServer *xhttp.Server globalTCPOptions xhttp.TCPOptions globalHTTPServerErrorCh = make(chan error) globalOSSignalCh = make(chan os.Signal, 1) // global Trace system to send HTTP request/response // and Storage/OS calls info to registered listeners. globalTrace = pubsub.New[madmin.TraceInfo, madmin.TraceType](8)
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Sep 03 18:23:41 GMT 2024 - 16.2K bytes - Click Count (1) -
guava-tests/test/com/google/common/collect/ForwardingCollectionTest.java
import junit.framework.TestCase; import junit.framework.TestSuite; import org.jspecify.annotations.NullUnmarked; /** * Tests for {@link ForwardingCollection}. * * @author Robert Konigsberg * @author Hayward Chan * @author Louis Wasserman */ @NullUnmarked public class ForwardingCollectionTest extends TestCase { static final class StandardImplForwardingCollection<T> extends ForwardingCollection<T> {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Jul 16 20:34:52 GMT 2025 - 4.8K bytes - Click Count (0) -
cmd/callhome.go
internalLogIf(ctx, errors.New("Callhome: object layer not ready")) return } healthCtx, healthCancel := context.WithTimeout(ctx, deadline) defer healthCancel() healthInfoCh := make(chan madmin.HealthInfo) query := url.Values{} for _, k := range madmin.HealthDataTypesList { query.Set(string(k), "true") } healthInfo := madmin.HealthInfo{ TimeStamp: time.Now().UTC(),
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 5.3K bytes - Click Count (0) -
internal/event/target/nats.go
id event.TargetID args NATSArgs natsConn *nats.Conn stanConn stan.Conn jstream nats.JetStream store store.Store[event.Event] loggerOnce logger.LogOnce quitCh chan struct{} } // ID - returns target ID. func (target *NATSTarget) ID() event.TargetID { return target.id } // Name - returns the Name of the target. func (target *NATSTarget) Name() string {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Apr 27 04:30:57 GMT 2025 - 13.5K bytes - Click Count (0) -
schema/schema.go
BeforeCreate, AfterCreate bool BeforeUpdate, AfterUpdate bool BeforeDelete, AfterDelete bool BeforeSave, AfterSave bool AfterFind bool err error initialized chan struct{} namer Namer cacheStore *sync.Map } func (schema *Schema) String() string { if schema.ModelType.Name() == "" { return fmt.Sprintf("%s(%s)", schema.Name, schema.Table)Created: Sun Apr 05 09:35:12 GMT 2026 - Last Modified: Sat Mar 21 11:35:55 GMT 2026 - 13.3K bytes - Click Count (0)