- Sort Score
- Result 10 results
- Languages All
Results 141 - 150 of 1,339 for contextos (0.19 sec)
-
android/guava/src/com/google/common/collect/ImmutableSortedSet.java
Comparable<?>[] contents = new Comparable<?>[6 + remaining.length]; contents[0] = e1; contents[1] = e2; contents[2] = e3; contents[3] = e4; contents[4] = e5; contents[5] = e6; arraycopy(remaining, 0, contents, 6, remaining.length); return construct(Ordering.natural(), contents.length, (E[]) contents); }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Oct 30 16:15:19 UTC 2024 - 36.9K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver_test.go
) var ztunnelTestCounter atomic.Uint32 func TestZtunnelSendsPodSnapshot(t *testing.T) { ztunnelKeepAliveCheckInterval = time.Second / 10 mt := monitortest.New(t) setupLogging() ctx, cancel := context.WithCancel(context.Background()) defer cancel() fixture := connect(ctx) ztunClient := fixture.ztunClient uid := fixture.uid m, fds := readRequest(t, ztunClient)
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Fri Apr 12 21:47:31 UTC 2024 - 8.6K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver.go
) var ztunnelConnected = monitoring.NewGauge("ztunnel_connected", "number of connections to ztunnel") type ZtunnelServer interface { Run(ctx context.Context) PodDeleted(ctx context.Context, uid string) error PodAdded(ctx context.Context, pod *v1.Pod, netns Netns) error Close() error } /* To clean up stale ztunnels we may need to ztunnel to send its (uid, bootid / boot time) to us
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Mon Jul 29 16:08:35 UTC 2024 - 13.2K bytes - Viewed (0) -
cmd/erasure-healing_test.go
} }) } } // Tests both object and bucket healing. func TestHealing(t *testing.T) { ctx, cancel := context.WithCancel(context.Background()) defer cancel() obj, fsDirs, err := prepareErasure16(ctx) if err != nil { t.Fatal(err) } defer obj.Shutdown(context.Background()) // initialize the server and obtain the credentials and root. // credentials are necessary to sign the HTTP request.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 49K bytes - Viewed (0) -
cmd/shared-lock.go
go func() { select { case <-ctx1.Done(): case <-ctx2.Done(): // The lock acquirer decides to cancel, exit this goroutine case <-ctx.Done(): } cancel() }() return ctx, cancel } func (ld sharedLock) GetLock(ctx context.Context) (context.Context, context.CancelFunc) { l := <-ld.lockContext return mergeContext(l.Context(), ctx) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Feb 13 09:26:38 UTC 2023 - 2.3K bytes - Viewed (0) -
cmd/warm-backend-azure.go
vid = *resp.VersionID } return remoteVersionID(vid), nil } func (az *warmBackendAzure) Put(ctx context.Context, object string, r io.Reader, length int64) (remoteVersionID, error) { return az.PutWithMeta(ctx, object, r, length, map[string]string{}) } func (az *warmBackendAzure) Get(ctx context.Context, object string, rv remoteVersionID, opts WarmBackendGetOpts) (r io.ReadCloser, err error) { if opts.startOffset < 0 {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Oct 31 22:10:24 UTC 2024 - 7K bytes - Viewed (0) -
cmd/xl-storage_windows_test.go
t.Fatal(err) } // Create volume to use in conjunction with other StorageAPI's file API(s) err = fs.MakeVol(context.Background(), "voldir") if err != nil { t.Fatal(err) } for i, test := range testCases { t.Run(fmt.Sprint(i), func(t *testing.T) { err = fs.AppendFile(context.Background(), "voldir", test.objName, []byte("hello")) if err != nil && test.pass { t.Error(err)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Nov 29 06:35:16 UTC 2023 - 2.8K bytes - Viewed (0) -
tests/tracer_test.go
} func (S Tracer) Warn(ctx context.Context, s string, i ...interface{}) { S.Logger.Warn(ctx, s, i...) } func (S Tracer) Error(ctx context.Context, s string, i ...interface{}) { S.Logger.Error(ctx, s, i...) } func (S Tracer) Trace(ctx context.Context, begin time.Time, fc func() (sql string, rowsAffected int64), err error) { S.Logger.Trace(ctx, begin, fc, err) S.Test(ctx, begin, fc, err)
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Tue Oct 18 09:28:06 UTC 2022 - 830 bytes - Viewed (0) -
cmd/erasure-metadata-utils.go
errorCounts := make(map[error]int) for _, err := range errs { if IsErrIgnored(err, ignoredErrs...) { continue } // Errors due to context cancellation may be wrapped - group them by context.Canceled. if errors.Is(err, context.Canceled) { errorCounts[context.Canceled]++ continue } errorCounts[err]++ } max := 0 for err, count := range errorCounts { switch { case max < count:
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 11.7K bytes - Viewed (0) -
impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvn/DefaultMavenParser.java
return new DefaultMavenInvokerRequest<>( context.parserRequest, context.cwd, context.installationDirectory, context.userHomeDirectory, context.userProperties, context.systemProperties, context.topDirectory, context.rootDirectory,
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 2.5K bytes - Viewed (0)