Search Options

Results per page
Sort
Preferred Languages
Advance

Results 2631 - 2640 of 3,237 for get2 (0.02 sec)

  1. guava-tests/test/com/google/common/base/AbstractIteratorTest.java

        assertTrue(iter.hasNext());
        assertTrue(iter.hasNext());
        assertTrue(iter.hasNext());
        assertEquals(1, (int) iter.next());
    
        assertFalse(iter.hasNext());
    
        // Make sure computeNext() doesn't get invoked again
        assertFalse(iter.hasNext());
    
        assertThrows(NoSuchElementException.class, iter::next);
      }
    
      public void testSneakyThrow() throws Exception {
        Iterator<Integer> iter =
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Sep 17 18:14:12 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  2. src/main/java/jcifs/smb1/http/Handler.java

                throws IOException {
            synchronized (PROTOCOL_HANDLERS) {
                URLStreamHandler handler = (URLStreamHandler)
                        PROTOCOL_HANDLERS.get(protocol);
                if (handler != null) return handler;
                if (factory != null) {
                    handler = factory.createURLStreamHandler(protocol);
                }
                if (handler == null) {
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 20:39:42 UTC 2019
    - 6.1K bytes
    - Viewed (0)
  3. cmd/jwt.go

    		// Check if the access key is part of users credentials.
    		u, ok := globalIAMSys.GetUser(req.Context(), claims.AccessKey)
    		if !ok {
    			return nil, nil, false, errInvalidAccessKeyID
    		}
    		ucred := u.Credentials
    		// get embedded claims
    		eclaims, s3Err := checkClaimsFromToken(req, ucred)
    		if s3Err != ErrNone {
    			return nil, nil, false, errAuthentication
    		}
    
    		for k, v := range eclaims {
    			claims.MapClaims[k] = v
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 22 07:04:48 UTC 2024
    - 4.5K bytes
    - Viewed (0)
  4. cmd/background-heal-ops.go

    					bgSeq.countFailed(res.Type)
    				}
    			}
    		case <-ctx.Done():
    			return
    		}
    	}
    }
    
    func newHealRoutine() *healRoutine {
    	workers := runtime.GOMAXPROCS(0) / 2
    
    	if envHealWorkers := env.Get("_MINIO_HEAL_WORKERS", ""); envHealWorkers != "" {
    		if numHealers, err := strconv.Atoi(envHealWorkers); err != nil {
    			bugLogIf(context.Background(), fmt.Errorf("invalid _MINIO_HEAL_WORKERS value: %w", err))
    		} else {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  5. compat/maven-compat/src/main/java/org/apache/maven/repository/legacy/resolver/transform/SnapshotTransformation.java

                // TODO Should this be changed for MNG-6754 too?
                snapshot.setTimestamp(getDeploymentTimestamp());
    
                // we update the build number anyway so that it doesn't get lost. It requires the timestamp to take effect
                try {
                    int buildNumber = resolveLatestSnapshotBuildNumber(artifact, localRepository, remoteRepository);
    
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 6.4K bytes
    - Viewed (0)
  6. internal/logger/reqinfo.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package logger
    
    import (
    	"context"
    	"fmt"
    	"sync"
    
    	"github.com/minio/minio/internal/auth"
    )
    
    // Key used for Get/SetReqInfo
    type contextKeyType string
    
    const contextLogKey = contextKeyType("miniolog")
    
    // KeyVal - appended to ReqInfo.Tags
    type KeyVal struct {
    	Key string
    	Val string
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:22:04 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  7. build-logic/documentation/src/main/groovy/gradlebuild/docs/dsl/source/model/TypeMetaData.java

                    for (int i = 0; i < typeArgs.size(); i++) {
                        if (i > 0) {
                            visitor.visitText(", ");
                        }
                        TypeMetaData typeArg = typeArgs.get(i);
                        typeArg.visitSignature(visitor);
                    }
                    visitor.visitText(">");
                }
                String suffix = getArraySuffix();
                if (suffix.length() > 0) {
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Wed Dec 09 08:14:05 UTC 2020
    - 6.1K bytes
    - Viewed (0)
  8. helm-releases/minio-3.6.2.tgz

    mc client: 1. Download the MinIO mc client - https://docs.minio.io/docs/minio-client-quickstart-guide 2. export MC_HOST_{{ template "minio.fullname" . }}-local=http://$(kubectl get secret --namespace {{ .Release.Namespace }} {{ template "minio.secretName" . }} -o jsonpath="{.data.rootUser}" | base64 --decode):$(kubectl get secret --namespace {{ .Release.Namespace }} {{ template "minio.secretName" . }} -o jsonpath="{.data.rootPassword}" | base64 --decode)@localhost:{{ .Values.service.port }} 3. mc...
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Mar 17 18:30:55 UTC 2022
    - 17.9K bytes
    - Viewed (0)
  9. native-image-tests/src/main/kotlin/okhttp3/RunTests.kt

     */
    fun treeListener(): TestExecutionListener {
      val colorPalette =
        Class.forName("org.junit.platform.console.tasks.ColorPalette").getField("DEFAULT").apply {
          isAccessible = true
        }.get(null)
      return Class.forName(
        "org.junit.platform.console.tasks.TreePrintingListener",
      ).declaredConstructors.first()
        .apply {
          isAccessible = true
        }
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 5.3K bytes
    - Viewed (0)
  10. okhttp/src/test/java/okhttp3/FakeRoutePlanner.kt

            idleAtNanos = defaultConnectionIdleAtNanos,
          )
        var retry: FakePlan? = null
        var retryTaken = false
        var yieldBeforePlanReturns = false
    
        override val isReady: Boolean
          get() = connectState == ConnectState.TLS_CONNECTED
    
        var tcpConnectDelayNanos = 0L
        var tcpConnectThrowable: Throwable? = null
        var yieldBeforeTcpConnectReturns = false
        var connectTcpNextPlan: FakePlan? = null
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Apr 24 04:40:49 UTC 2024
    - 6.2K bytes
    - Viewed (0)
Back to top