- Sort Score
- Result 10 results
- Languages All
Results 441 - 450 of 1,339 for contextos (0.06 sec)
-
cmd/metrics-v3-cluster-iam.go
) // loadClusterIAMMetrics - `MetricsLoaderFn` for cluster IAM metrics. func loadClusterIAMMetrics(_ context.Context, m MetricValues, _ *metricsCache) error { m.Set(lastSyncDurationMillis, float64(atomic.LoadUint64(&globalIAMSys.LastRefreshDurationMilliseconds))) pluginAuthNMetrics := globalAuthNPlugin.Metrics()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu May 02 08:20:42 UTC 2024 - 4.5K bytes - Viewed (0) -
cmd/erasure-utils.go
size += len(block) } return size } // Writes all the data blocks from encoded blocks until requested // outSize length. Provides a way to skip bytes until the offset. func writeDataBlocks(ctx context.Context, dst io.Writer, enBlocks [][]byte, dataBlocks int, offset int64, length int64) (int64, error) { // Offset and out size cannot be negative. if offset < 0 || length < 0 { return 0, errUnexpected }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Jan 31 02:11:45 UTC 2024 - 3.1K bytes - Viewed (0) -
compat/maven-model-builder/src/main/java/org/apache/maven/model/profile/activation/FileProfileActivator.java
this.profileActivationFilePathInterpolator = profileActivationFilePathInterpolator; } @Override public boolean isActive(Profile profile, ProfileActivationContext context, ModelProblemCollector problems) { Activation activation = profile.getActivation(); if (activation == null) { return false; } ActivationFile file = activation.getFile();
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 4.2K bytes - Viewed (0) -
api/maven-api-core/src/main/java/org/apache/maven/api/services/Source.java
*/ @Nullable Path getPath(); /** * Creates a new byte stream to the source contents. * Closing the returned stream is the responsibility of the caller. * * @return a byte stream to the source contents, never {@code null} * @throws IOException in case of IO issue */ @Nonnull InputStream openStream() throws IOException; /**
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Apr 12 10:50:18 UTC 2024 - 3.5K bytes - Viewed (0) -
cmd/metacache-set.go
// Cache will be bypassed. // Context cancellation will be respected but may take a while to effectuate. func listPathRaw(ctx context.Context, opts listPathRawOptions) (err error) { disks := opts.disks if len(disks) == 0 { return fmt.Errorf("listPathRaw: 0 drives provided") } // Cancel upstream if we finish before we expect. ctx, cancel := context.WithCancel(ctx) defer cancel()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jul 12 16:23:16 UTC 2024 - 30.7K bytes - Viewed (0) -
cmd/sftp-server.go
switch tag { case xsftp.AcceptNetworkError: sftpLogOnceIf(context.Background(), err, "accept-limit-sftp") case xsftp.AcceptChannelError: sftpLogOnceIf(context.Background(), err, "accept-channel-sftp") case xsftp.SSHKeyExchangeError: sftpLogOnceIf(context.Background(), err, "key-exchange-sftp") default: sftpLogOnceIf(context.Background(), err, "unknown-error-sftp") } }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Aug 20 20:00:29 UTC 2024 - 16K bytes - Viewed (0) -
internal/rest/client.go
return } // ErrClientClosed returned when *Client is closed. var ErrClientClosed = errors.New("rest client is closed") // CallWithHTTPMethod - make a REST call with context, using a custom HTTP method. func (c *Client) CallWithHTTPMethod(ctx context.Context, httpMethod, rpcMethod string, values url.Values, body io.Reader, length int64) (reply io.ReadCloser, err error) { switch atomic.LoadInt32(&c.connected) { case closed:
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jul 26 12:55:01 UTC 2024 - 14.7K bytes - Viewed (0) -
src/main/java/jcifs/context/BaseContext.java
private final SmbTransportPool transportPool; private final CredentialsInternal defaultCredentials; /** * Construct a context * * @param config * configuration for the context * */ public BaseContext ( Configuration config ) { this.config = config; this.dfs = new DfsImpl(this);
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Sun Nov 27 18:25:00 UTC 2022 - 5.3K bytes - Viewed (0) -
scripts/deploy_docs_status.py
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Fri Aug 09 15:52:41 UTC 2024 - 3.1K bytes - Viewed (0) -
internal/hash/reader.go
// does not send more content than specified size. func NewReader(ctx context.Context, src io.Reader, size int64, md5Hex, sha256Hex string, actualSize int64) (*Reader, error) { return newReader(ctx, src, size, md5Hex, sha256Hex, actualSize, false, nil) } func newReader(ctx context.Context, src io.Reader, size int64, md5Hex, sha256Hex string, actualSize int64, disableMD5 bool, forceMD5 []byte) (*Reader, error) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Sep 19 12:59:07 UTC 2024 - 10.9K bytes - Viewed (0)