Search Options

Results per page
Sort
Preferred Languages
Advance

Results 371 - 380 of 1,122 for contextos (0.12 sec)

  1. android/guava/src/com/google/common/io/ByteSource.java

        copyTo(Funnels.asOutputStream(hasher));
        return hasher.hash();
      }
    
      /**
       * Checks that the contents of this byte source are equal to the contents of the given byte
       * source.
       *
       * @throws IOException if an I/O error occurs while reading from this source or {@code other}
       */
      public boolean contentEquals(ByteSource other) throws IOException {
        checkNotNull(other);
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:26:48 UTC 2024
    - 26.2K bytes
    - Viewed (0)
  2. compat/maven-model-builder/src/main/java/org/apache/maven/model/management/DefaultDependencyManagementInjector.java

                    Map<Object, Object> context) {
                // optional flag is not managed
            }
    
            @Override
            protected void mergeDependency_Exclusions(
                    Dependency.Builder builder,
                    Dependency target,
                    Dependency source,
                    boolean sourceDominant,
                    Map<Object, Object> context) {
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  3. cmd/metrics-v3-system-network.go

    		"Total number of bytes received from other peer nodes")
    )
    
    // loadNetworkInternodeMetrics - reads internode network metrics.
    //
    // This is a `MetricsLoaderFn`.
    func loadNetworkInternodeMetrics(ctx context.Context, m MetricValues, _ *metricsCache) error {
    	connStats := globalConnStats.toServerConnStats()
    	rpcStats := rest.GetRPCStats()
    	if globalIsDistErasure {
    		m.Set(internodeErrorsTotal, float64(rpcStats.Errs))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Mar 10 09:15:15 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  4. cmd/metrics-v3-cluster-notification.go

    )
    
    // loadClusterNotificationMetrics - `MetricsLoaderFn` for cluster notification metrics.
    func loadClusterNotificationMetrics(_ context.Context, m MetricValues, _ *metricsCache) error {
    	if globalEventNotifier == nil {
    		return nil
    	}
    
    	nstats := globalEventNotifier.targetList.Stats()
    	m.Set(notificationCurrentSendInProgress, float64(nstats.CurrentSendCalls))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Apr 24 04:10:35 UTC 2024
    - 2.2K bytes
    - Viewed (0)
  5. cmd/metrics-v3-logger-webhook.go

    		allWebhookLabels...)
    )
    
    // loadLoggerWebhookMetrics - `MetricsLoaderFn` for logger webhook
    // such as failed messages and total messages.
    func loadLoggerWebhookMetrics(ctx context.Context, m MetricValues, c *metricsCache) error {
    	tgts := append(logger.SystemTargets(), logger.AuditTargets()...)
    	for _, t := range tgts {
    		labels := []string{nameL, t.String(), endpointL, t.Endpoint()}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue May 14 07:27:33 UTC 2024
    - 2K bytes
    - Viewed (0)
  6. cmd/data-scanner_test.go

    	objAPI, disks, err := prepareErasure(context.Background(), 8)
    	if err != nil {
    		t.Fatalf("Failed to initialize object layer: %v", err)
    	}
    	defer removeRoots(disks)
    	setObjectLayer(objAPI)
    	globalBucketMetadataSys = NewBucketMetadataSys()
    	globalBucketObjectLockSys = &BucketObjectLockSys{}
    	globalBucketVersioningSys = &BucketVersioningSys{}
    	es := newExpiryState(context.Background(), objAPI, 0)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 03 11:18:58 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  7. src/test/java/jcifs/tests/BaseCIFSTest.java

    import jcifs.config.PropertyConfiguration;
    import jcifs.context.BaseContext;
    import jcifs.context.CIFSContextWrapper;
    import jcifs.smb.NtlmPasswordAuthenticator;
    import jcifs.smb.SmbFile;
    
    
    /**
     * @author mbechler
     *
     */
    @SuppressWarnings ( "javadoc" )
    public abstract class BaseCIFSTest {
    
        private Map<String, String> properties;
        private CIFSContext context;
        private Random rand = new Random();
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 8.1K bytes
    - Viewed (0)
  8. cmd/service.go

    )
    
    // Global service signal channel.
    var globalServiceSignalCh = make(chan serviceSignal)
    
    // GlobalContext context that is canceled when server is requested to shut down.
    // cancelGlobalContext can be used to indicate server shutdown.
    var GlobalContext, cancelGlobalContext = context.WithCancel(context.Background())
    
    // restartProcess starts a new process passing it the active fd's. It
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Feb 28 07:02:14 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  9. 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)
  10. 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)
Back to top