Search Options

Results per page
Sort
Preferred Languages
Advance

Results 441 - 450 of 1,339 for contextos (0.06 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. scripts/deploy_docs_status.py

                description="No Docs Changes",
                context="deploy-docs",
                target_url=run_url,
            )
            logging.info("No docs changes found")
            return
        if not settings.deploy_url:
            current_commit.create_status(
                state="pending",
                description="Deploying Docs",
                context="deploy-docs",
                target_url=run_url,
            )
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Fri Aug 09 15:52:41 UTC 2024
    - 3.1K bytes
    - Viewed (0)
  10. 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)
Back to top