Search Options

Results per page
Sort
Preferred Languages
Advance

Results 111 - 120 of 1,059 for rval (0.03 sec)

  1. settings.gradle.kts

    include(":samples:unixdomainsockets")
    include(":container-tests")
    
    project(":okhttp-logging-interceptor").name = "logging-interceptor"
    
    val androidHome = System.getenv("ANDROID_HOME")
    val localProperties = Properties().apply {
      val file = File("local.properties")
      if (file.exists()) {
        load(file.inputStream())
      }
    }
    val sdkDir = localProperties.getProperty("sdk.dir")
    if ((androidHome != null || sdkDir != null) && !isKnownBrokenIntelliJ()) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Apr 14 14:24:05 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  2. okhttp/src/test/java/okhttp3/UrlComponentEncodingTesterJvm.kt

        encoding: UrlComponentEncodingTester.Encoding,
        component: Component,
      ) {
        if (codePoint == '%'.code) return
        val encoded = encoding.encode(codePoint)
        val httpUrl = component.urlString(encoded).toHttpUrl()
        val uri = httpUrl.toUri()
        val toAndFromUri = uri.toHttpUrlOrNull()
        val uriStripped = uriStrippedCodePoints.indexOf(codePointString) != -1
        if (uriStripped) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/internal/cache/CacheStrategy.kt

      /** The request to send on the network, or null if this call doesn't use the network. */
      val networkRequest: Request?,
      /** The cached response to return or validate; or null if this call doesn't use a cache. */
      val cacheResponse: Response?,
    ) {
      class Factory(
        private val nowMillis: Long,
        internal val request: Request,
        private val cacheResponse: Response?,
      ) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 15 13:24:48 UTC 2024
    - 12K bytes
    - Viewed (0)
  4. internal/s3select/parquet/reader.go

    		// - fix this later.
    		value = string(val[:])
    	case int32:
    		value = int64(val)
    		if logicalType := se.GetLogicalType(); logicalType != nil {
    			if logicalType.IsSetDATE() {
    				value = sql.FormatSQLTimestamp(time.Unix(60*60*24*int64(val), 0).UTC())
    			}
    		} else if se.GetConvertedType() == parquettypes.ConvertedType_DATE {
    			value = sql.FormatSQLTimestamp(time.Unix(60*60*24*int64(val), 0).UTC())
    		}
    	case int64:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 4.5K bytes
    - Viewed (0)
  5. build-logic-commons/basics/src/main/kotlin/gradlebuild/basics/transforms/Minify.kt

        fun minify(artifact: File, keepClasses: Set<String>, jarFile: File): File {
            val tempDirectory = java.nio.file.Files.createTempDirectory(jarFile.name).toFile()
            val classesDir = tempDirectory.resolve("classes")
            val manifestFile = tempDirectory.resolve("MANIFEST.MF")
            val buildReceiptFile = tempDirectory.resolve("build-receipt.properties")
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Sat Sep 30 16:17:28 UTC 2023
    - 4.4K bytes
    - Viewed (0)
  6. mockwebserver/src/test/java/mockwebserver3/internal/http2/Http2Server.kt

    class Http2Server(
      private val baseDirectory: File,
      private val sslSocketFactory: SSLSocketFactory,
    ) : Http2Connection.Listener() {
      private fun run() {
        val serverSocket = ServerSocket(8888)
        serverSocket.reuseAddress = true
        while (true) {
          var socket: Socket? = null
          try {
            socket = serverSocket.accept()
            val sslSocket = doSsl(socket)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  7. okhttp/src/main/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt

      }
    
      companion object {
        private const val NO_CHUNK_YET = -1L
    
        private const val STATE_IDLE = 0 // Idle connections are ready to write request headers.
        private const val STATE_OPEN_REQUEST_BODY = 1
        private const val STATE_WRITING_REQUEST_BODY = 2
        private const val STATE_READ_RESPONSE_HEADERS = 3
        private const val STATE_OPEN_RESPONSE_BODY = 4
        private const val STATE_READING_RESPONSE_BODY = 5
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  8. okhttp/src/test/java/okhttp3/internal/HostnamesTest.kt

        val addressD = decodeIpv6("abcd:ef01:2345:6789:abcd:ef01:2345:6789")!!
        assertThat(canonicalizeInetAddress(addressD)).isEqualTo(addressD)
    
        val addressE = decodeIpv6("2001:db8::1:0:0:1")!!
        assertThat(canonicalizeInetAddress(addressE)).isEqualTo(addressE)
    
        val addressF = decodeIpv6("0:0:0:0:0:ffff:7f00:1")!!
        assertThat(canonicalizeInetAddress(addressF)).isEqualTo(addressB)
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Tue Jan 30 06:23:33 UTC 2024
    - 5.1K bytes
    - Viewed (0)
  9. okhttp/src/main/kotlin/okhttp3/Cookie.kt

          var pos = cookiePairEnd + 1
          val limit = setCookie.length
          while (pos < limit) {
            val attributePairEnd = setCookie.delimiterOffset(';', pos, limit)
    
            val attributeEqualsSign = setCookie.delimiterOffset('=', pos, attributePairEnd)
            val attributeName = setCookie.trimSubstring(pos, attributeEqualsSign)
            val attributeValue =
              if (attributeEqualsSign < attributePairEnd) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 06 04:12:05 UTC 2024
    - 23.1K bytes
    - Viewed (0)
  10. cni/pkg/plugin/cnieventclient_test.go

    		Interface: &fakeIDX,
    		Address: net.IPNet{
    			IP: fakeIP,
    		},
    		Gateway: fakeGW,
    	}
    )
    
    func TestPushCNIAddEventSucceed(t *testing.T) {
    	// Fake out a test HTTP server and use that instead of a real HTTP server over gRPC to validate  req/resp flows
    	testServer := httptest.NewServer(http.HandlerFunc(func(res http.ResponseWriter, req *http.Request) {
    		res.WriteHeader(http.StatusOK)
    		res.Write([]byte("server happy"))
    	}))
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Jul 02 18:48:50 UTC 2024
    - 4.2K bytes
    - Viewed (0)
Back to top