Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1241 - 1250 of 2,237 for setI (0.03 sec)

  1. samples/crawler/build.gradle.kts

    plugins {
      kotlin("jvm")
      application
    }
    
    application {
      mainClass.set("okhttp3.sample.Crawler")
    }
    
    dependencies {
      implementation(projects.okhttp)
      implementation(libs.jsoup)
    }
    
    tasks.compileJava {
      options.isWarnings = false
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Tue Feb 15 23:38:32 UTC 2022
    - 234 bytes
    - Viewed (0)
  2. okhttp/src/main/kotlin/okhttp3/internal/connection/RouteDatabase.kt

     * a specific IP address or proxy server, that failure is remembered and alternate routes are
     * preferred.
     */
    class RouteDatabase {
      private val _failedRoutes = mutableSetOf<Route>()
    
      val failedRoutes: Set<Route>
        @Synchronized get() = _failedRoutes.toSet()
    
      /** Records a failure connecting to [failedRoute]. */
      @Synchronized fun failed(failedRoute: Route) {
        _failedRoutes.add(failedRoute)
      }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 15 14:55:09 UTC 2024
    - 1.5K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/internal/tls/BasicTrustRootIndex.kt

    /** A simple index that of trusted root certificates that have been loaded into memory. */
    class BasicTrustRootIndex(vararg caCerts: X509Certificate) : TrustRootIndex {
      private val subjectToCaCerts: Map<X500Principal, Set<X509Certificate>>
    
      init {
        val map = mutableMapOf<X500Principal, MutableSet<X509Certificate>>()
        for (caCert in caCerts) {
          map.getOrPut(caCert.subjectX500Principal) { mutableSetOf() }.add(caCert)
        }
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 1.8K bytes
    - Viewed (0)
  4. internal/bucket/replication/datatypes.go

    	Replica StatusType = "REPLICA"
    )
    
    // String returns string representation of status
    func (s StatusType) String() string {
    	return string(s)
    }
    
    // Empty returns true if this status is not set
    func (s StatusType) Empty() bool {
    	return string(s) == ""
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Mar 08 19:08:18 UTC 2024
    - 1.5K bytes
    - Viewed (0)
  5. internal/config/scanner/help.go

    			Optional:    true,
    			Type:        "int",
    		},
    		config.HelpKV{
    			Key:         ExcessFolders,
    			Description: `alert beyond this many sub-folders per folder in an erasure set` + defaultHelpPostfix(ExcessFolders),
    			Optional:    true,
    			Type:        "int",
    		},
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Feb 12 07:41:53 UTC 2024
    - 1.6K bytes
    - Viewed (0)
  6. cni/pkg/monitoring/monitoring.go

    		log.Errorf("unable to listen on socket: %v", err)
    		return
    	}
    	exporter, err := monitoring.RegisterPrometheusExporter(nil, nil)
    	if err != nil {
    		log.Errorf("could not set up prometheus exporter: %v", err)
    		return
    	}
    	mux.Handle(path, exporter)
    	monitoringServer := &http.Server{
    		Handler: mux,
    	}
    	go func() {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jun 09 07:54:01 UTC 2023
    - 1.5K bytes
    - Viewed (0)
  7. build-logic/binary-compatibility/src/test/groovy/gradlebuild/binarycompatibility/rules/AbstractContextAwareRuleSpecification.groovy

    abstract class AbstractContextAwareRuleSpecification extends Specification {
        @TempDir
        File testDir
    
        ViolationCheckContext context = new ViolationCheckContext() {
            Map userData = [seenApiChanges: [] as Set]
    
            String getClassName() { return null }
    
            Map<String, ?> getUserData() { return userData }
    
            Object getUserData(String key) {
                return userData[key]
            }
    
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Thu Oct 06 19:15:15 UTC 2022
    - 2K bytes
    - Viewed (0)
  8. src/main/java/jcifs/util/transport/Transport.java

    
    import java.io.IOException;
    import java.io.InputStream;
    import java.net.SocketTimeoutException;
    import java.util.Iterator;
    import java.util.Map;
    import java.util.Map.Entry;
    import java.util.Set;
    import java.util.concurrent.ConcurrentHashMap;
    import java.util.concurrent.atomic.AtomicLong;
    
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    
    import jcifs.RuntimeCIFSException;
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Nov 01 18:12:21 UTC 2020
    - 24.1K bytes
    - Viewed (0)
  9. okhttp/src/test/java/okhttp3/HeadersJvmTest.kt

        assertThat(headers.getInstant("Test-Instant")).isEqualTo(expected)
      }
    
      @Test fun setDate() {
        val expected = Date(1000)
        val headers =
          Headers.Builder()
            .add("testDate", Date(0L))
            .set("testDate", expected)
            .build()
        assertThat(headers["testDate"]).isEqualTo("Thu, 01 Jan 1970 00:00:01 GMT")
        assertThat(headers.getDate("testDate")).isEqualTo(expected)
      }
    
      @Test fun setInstant() {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  10. src/main/java/jcifs/dcerpc/DcerpcMessage.java

        /**
         * 
         * @param flag
         * @return whether flag is set
         */
        public boolean isFlagSet ( int flag ) {
            return ( this.flags & flag ) == flag;
        }
    
    
        /**
         * Remove flag
         * 
         * @param flag
         */
        public void unsetFlag ( int flag ) {
            this.flags &= ~flag;
        }
    
    
        /**
         * Set flag
         * 
         * @param flag
         */
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 5K bytes
    - Viewed (0)
Back to top