- Sort Score
- Result 10 results
- Languages All
Results 331 - 340 of 1,122 for contextos (0.12 sec)
-
cmd/mrf.go
// // You should have received a copy of the GNU Affero General Public License // along with this program. If not, see <http://www.gnu.org/licenses/>. //go:generate msgp -file=$GOFILE package cmd import ( "context" "encoding/binary" "errors" "fmt" "io" "sync" "sync/atomic" "time" "github.com/google/uuid" "github.com/minio/madmin-go/v3" "github.com/minio/pkg/v3/wildcard"
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Aug 13 22:26:05 UTC 2024 - 6.5K bytes - Viewed (0) -
build-logic/binary-compatibility/src/main/groovy/gradlebuild/binarycompatibility/upgrades/UpgradedProperties.java
*/ public static boolean shouldAcceptForUpgradedProperty(JApiMethod jApiMethod, Violation violation, ViolationCheckContext context) { Map<AccessorKey, UpgradedProperty> currentAccessors = context.getUserData(CURRENT_ACCESSORS_OF_UPGRADED_PROPERTIES); Map<AccessorKey, ReplacedAccessor> oldRemovedAccessors = context.getUserData(OLD_REMOVED_ACCESSORS_OF_UPGRADED_PROPERTIES);
Registered: Wed Nov 06 11:36:14 UTC 2024 - Last Modified: Wed Oct 02 14:20:08 UTC 2024 - 9.1K bytes - Viewed (0) -
guava/src/com/google/common/base/Objects.java
* Arrays#hashCode(Object[])}. Note that array arguments to this method, with the exception of a * single Object array, do not get any special handling; their hash codes are based on identity * and not contents. * * <p>This is useful for implementing {@link Object#hashCode()}. For example, in an object that * has three properties, {@code x}, {@code y}, and {@code z}, one could write: * * <pre>{@code
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Jul 22 19:03:12 UTC 2024 - 3K bytes - Viewed (0) -
build-logic-commons/module-identity/src/main/kotlin/gradlebuild.module-identity.gradle.kts
ReleasedVersionsDetails( moduleIdentity.version.get().baseVersion, releasedVersionsFile() ) } return versionNumber } /** * Returns the trimmed contents of the file at the given [path] after * marking the file as a build logic input. */ fun Project.trimmedContentsOfFile(path: String): String = providers.fileContents(repoRoot().file(path)).asText.get().trim()
Registered: Wed Nov 06 11:36:14 UTC 2024 - Last Modified: Sat Sep 30 16:17:28 UTC 2023 - 4.9K bytes - Viewed (0) -
cmd/sftp-server_test.go
if err == nil || !errors.Is(err, errNoSuchUser) { c.Fatalf("expected err(%s) but got (%s)", errNoSuchUser, err) } } func (s *TestSuiteIAM) SFTPInvalidServiceAccountPassword(c *check) { ctx, cancel := context.WithTimeout(context.Background(), testDefaultTimeout) defer cancel() accessKey, secretKey := mustGenerateCredentials(c) err := s.adm.SetUser(ctx, accessKey, secretKey, madmin.AccountEnabled) if err != nil {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jun 28 09:06:25 UTC 2024 - 8.3K bytes - Viewed (0) -
cmd/bootstrap-peer-server.go
} // client to talk to bootstrap NEndpoints. type bootstrapRESTClient struct { gridConn *grid.Connection } // Verify function verifies the server config. func (client *bootstrapRESTClient) Verify(ctx context.Context, srcCfg *ServerSystemConfig) (err error) { if newObjectLayerFn() != nil { return nil } recvCfg, err := serverVerifyHandler.Call(ctx, client.gridConn, grid.NewMSS()) if err != nil { return err
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Oct 01 22:13:18 UTC 2024 - 8.4K bytes - Viewed (0) -
internal/http/listener_test.go
} nextTest: for i, testCase := range testCases { listener, errs := newHTTPListener(context.Background(), testCase.serverAddrs, TCPOptions{}, ) for _, err := range errs { if err != nil { if strings.Contains(err.Error(), "The requested address is not valid in its context") { // Ignore if IP is unbindable. continue nextTest }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jun 10 17:41:02 UTC 2024 - 11.8K bytes - Viewed (0) -
cmd/metrics-v3-ilm.go
) // loadILMMetrics - `MetricsLoaderFn` for ILM metrics. func loadILMMetrics(_ context.Context, m MetricValues, _ *metricsCache) error { if globalExpiryState != nil { m.Set(expiryPendingTasks, float64(globalExpiryState.PendingTasks())) } if globalTransitionState != nil {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Jun 06 09:36:25 UTC 2024 - 2.3K bytes - Viewed (0) -
cmd/bootstrap-messages.go
bs.mu.RLock() for _, i := range bs.info { traceInfo = append(traceInfo, i) } bs.mu.RUnlock() return traceInfo } func (bs *bootstrapTracer) Publish(ctx context.Context, trace *pubsub.PubSub[madmin.TraceInfo, madmin.TraceType]) { for _, bsEvent := range bs.Events() { if bsEvent.Message != "" { select { case <-ctx.Done(): default: trace.Publish(bsEvent) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Aug 23 10:07:06 UTC 2023 - 1.7K bytes - Viewed (0) -
internal/http/check_port_others.go
func CheckPortAvailability(host, port string, opts TCPOptions) (err error) { lc := &net.ListenConfig{} ctx, cancel := context.WithTimeout(context.Background(), time.Second) defer cancel() l, err := lc.Listen(ctx, "tcp", net.JoinHostPort(host, port)) if err != nil { return err } // As we are able to listen on this network, the port is not in use. // Close the listener and continue check other networks.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed May 03 21:12:25 UTC 2023 - 1.5K bytes - Viewed (0)