Search Options

Results per page
Sort
Preferred Languages
Advance

Results 171 - 180 of 1,088 for closer (0.06 sec)

  1. docs/metrics/prometheus/grafana/replication/minio-replication-cluster.json

          "5m",
          "15m",
          "1h",
          "6h",
          "12h",
          "24h",
          "2d",
          "7d",
          "30d"
        ]
      },
      "timezone": "",
      "title": "MinIO Cluster Replication Dashboard",
      "uid": "TgmJnnqnk3",
      "version": 1,
      "weekStart": ""
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Mar 28 17:15:39 UTC 2024
    - 71.1K bytes
    - Viewed (0)
  2. cmd/metrics-v3-cluster-config.go

    		"Reduced redundancy storage class parity")
    	configStandardParityMD = NewGaugeMD(configStandardParity,
    		"Standard storage class parity")
    )
    
    // loadClusterConfigMetrics - `MetricsLoaderFn` for cluster config
    // such as standard and RRS parity.
    func loadClusterConfigMetrics(ctx context.Context, m MetricValues, c *metricsCache) error {
    	clusterDriveMetrics, err := c.clusterDriveMetrics.Get()
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 12:50:46 UTC 2024
    - 1.5K bytes
    - Viewed (0)
  3. okhttp/src/test/java/okhttp3/internal/cache/DiskLruCacheTest.kt

        while (!toClose.isEmpty()) {
          toClose.pop().close()
        }
        taskFaker.close()
    
        (filesystem.delegate as? FakeFileSystem)?.checkNoOpenFiles()
      }
    
      @ParameterizedTest
      @ArgumentsSource(FileSystemParamProvider::class)
      fun emptyCache(parameters: Pair<FileSystem, Boolean>) {
        setUp(parameters.first, parameters.second)
        cache.close()
        assertJournalEquals()
      }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 15 14:55:09 UTC 2024
    - 75.8K bytes
    - Viewed (0)
  4. src/main/java/jcifs/SmbTransportPool.java

         * 
         * @param trans
         */
        void removeTransport ( SmbTransport trans );
    
    
        /**
         * Closes the pool and all connections in it
         * 
         * @return whether any transport was still in use
         * 
         * @throws CIFSException
         * 
         */
        boolean close () throws CIFSException;
    
    
        /**
         * Authenticate arbitrary credentials represented by the
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun May 17 09:02:44 UTC 2020
    - 6.3K bytes
    - Viewed (0)
  5. internal/config/dns/operator_dns.go

    // No Op for Operator because operator deals on with bucket entries
    func (c *OperatorDNS) DeleteRecord(record SrvRecord) error {
    	return ErrNotImplemented
    }
    
    // Close closes the internal http client
    func (c *OperatorDNS) Close() error {
    	return nil
    }
    
    // List - Retrieves list of DNS entries for the domain.
    // This is a No Op for Operator because, there is no intent to enforce global
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Mar 06 16:56:10 UTC 2023
    - 6.6K bytes
    - Viewed (0)
  6. src/main/java/jcifs/smb/SmbPipeInputStream.java

                return resp.getAvailable();
            }
            catch ( SmbException se ) {
                throw seToIoe(se);
            }
        }
    
    
        @Override
        public void close () {
            // ignore, the shared file descriptor is closed by the pipe handle
        }
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Aug 05 07:12:23 UTC 2018
    - 3.5K bytes
    - Viewed (0)
  7. api/maven-api-cli/src/main/java/org/apache/maven/api/cli/Invoker.java

         * @throws InvokerException if an error occurs during the invocation process
         */
        int invoke(@Nonnull R invokerRequest) throws InvokerException;
    
        /**
         * Closes and disposes of this {@link Invoker} instance, releasing any resources it may hold.
         * This method is called automatically when using try-with-resources statements.
         *
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Thu Oct 03 16:03:55 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  8. internal/event/target/nats.go

    	return target.store.Del(key)
    }
    
    // Close - closes underneath connections to NATS server.
    func (target *NATSTarget) Close() (err error) {
    	close(target.quitCh)
    	if target.stanConn != nil {
    		// closing the streaming connection does not close the provided NATS connection.
    		if target.stanConn.NatsConn() != nil {
    			target.stanConn.NatsConn().Close()
    		}
    		return target.stanConn.Close()
    	}
    
    	if target.natsConn != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 12.9K bytes
    - Viewed (0)
  9. src/archive/zip/reader.go

    	dcomp := r.decompressors[method]
    	if dcomp == nil {
    		dcomp = decompressor(method)
    	}
    	return dcomp
    }
    
    // Close closes the Zip file, rendering it unusable for I/O.
    func (rc *ReadCloser) Close() error {
    	return rc.f.Close()
    }
    
    // DataOffset returns the offset of the file's possibly-compressed
    // data, relative to the beginning of the zip file.
    //
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Sat Aug 03 01:05:29 UTC 2024
    - 28.1K bytes
    - Viewed (0)
  10. okhttp/src/test/java/okhttp3/internal/http/ThreadInterruptTest.kt

                    for (i in 0..9) {
                      sink.writeByte(0)
                      sink.flush()
                      sleep(100)
                    }
                    fail("Expected connection to be closed")
                  }
                },
              )
              .build(),
          )
        interruptLater(500)
        assertFailsWith<IOException> {
          call.execute()
        }
      }
    
      @Test
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 4.6K bytes
    - Viewed (0)
Back to top