Search Options

Results per page
Sort
Preferred Languages
Advance

Results 561 - 570 of 777 for callee (0.05 sec)

  1. okhttp-testing-support/src/main/kotlin/okhttp3/CallEvent.kt

      ) : CallEvent()
    
      data class SecureConnectEnd(
        override val timestampNs: Long,
        override val call: Call,
        val handshake: Handshake?,
      ) : CallEvent() {
        override fun closes(event: CallEvent): Boolean = event is SecureConnectStart && call == event.call
      }
    
      data class ConnectionAcquired(
        override val timestampNs: Long,
        override val call: Call,
        val connection: Connection,
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  2. internal/http/listener.go

    	RecvBufSize int              // SO_RECVBUF size for the socket connection, NOTE: this sets server and client connection
    	NoDelay     bool             // Indicates callers to enable TCP_NODELAY on the net.Conn
    	Interface   string           // This is a VRF device passed via `--interface` flag
    	Trace       func(msg string) // Trace when starting.
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 23 10:53:03 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  3. cmd/erasure-object.go

    					break
    				}
    			}
    		}
    		if found {
    			offline++
    		}
    	}
    	if offline > 0 {
    		tags["offline"] = strconv.Itoa(offline)
    	}
    
    	_, file, line, cok := runtime.Caller(1)
    	if cok {
    		tags["caller"] = fmt.Sprintf("%s:%d", file, line)
    	}
    
    	defer auditDanglingObjectDeletion(ctx, bucket, object, m.VersionID, tags)
    
    	fi := FileInfo{
    		VersionID: m.VersionID,
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 78.8K bytes
    - Viewed (0)
  4. okhttp/src/test/java/okhttp3/ServerTruncatesRequestTest.kt

        // makeSimpleCall() because it uses the MockResponse enqueued above.
        val callB = client.newCall(Request(server.url("/")))
        callB.execute().use { response ->
          assertThat(response.body.string()).isEqualTo("abc")
        }
      }
    
      private fun makeSimpleCall() {
        server.enqueue(MockResponse(body = "healthy"))
        val callB = client.newCall(Request(server.url("/")))
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  5. guava-testlib/src/com/google/common/collect/testing/google/AbstractMultisetSetCountTester.java

            size,
            getMultiset().size());
      }
    
      /** Call the {@code setCount()} method under test, and check its return value. */
      abstract void setCountCheckReturnValue(E element, int count);
    
      /**
       * Call the {@code setCount()} method under test, but do not check its return value. Callers
       * should use this method over {@link #setCountCheckReturnValue(Object, int)} when they expect
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:05:46 UTC 2024
    - 13K bytes
    - Viewed (0)
  6. cmd/erasure.go

    					return nil
    				})
    			})
    		}(disk)
    	}
    	wg.Wait()
    }
    
    // nsScanner will start scanning buckets and send updated totals as they are traversed.
    // Updates are sent on a regular basis and the caller *must* consume them.
    func (er erasureObjects) nsScanner(ctx context.Context, buckets []BucketInfo, wantCycle uint32, updates chan<- dataUsageCache, healScanMode madmin.HealScanMode) error {
    	if len(buckets) == 0 {
    		return nil
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 22:23:33 UTC 2024
    - 16.1K bytes
    - Viewed (0)
  7. internal/config/identity/openid/openid.go

    func Enabled(kvs config.KVS) bool {
    	return kvs.Get(ConfigURL) != ""
    }
    
    // GetSettings - fetches OIDC settings for site-replication related validation.
    // NOTE that region must be populated by caller as this package does not know.
    func (r *Config) GetSettings() madmin.OpenIDSettings {
    	res := madmin.OpenIDSettings{}
    	if !r.Enabled {
    		return res
    	}
    	h := sha256.New()
    	hashedSecret := ""
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 10 20:16:44 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  8. build-logic-commons/basics/src/main/kotlin/gradlebuild/basics/BuildParams.kt

        @JvmName("shouldRunBrokenForConfigurationCacheDocsTests") get() = gradleProperty(RUN_BROKEN_CONFIGURATION_CACHE_DOCS_TESTS).orNull.toBoolean()
    
    
    /**
     * Is a promotion build task called?
     */
    val Project.isPromotionBuild: Boolean
        get() {
            val taskNames = gradle.startParameter.taskNames
            return taskNames.contains("promotionBuild") ||
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Wed Oct 09 08:19:42 UTC 2024
    - 16.9K bytes
    - Viewed (0)
  9. guava-gwt/src-super/com/google/common/collect/super/com/google/common/collect/ImmutableList.java

        }
      }
    
      /**
       * Views the array as an immutable list. The array must have only {@code E} elements.
       *
       * <p>The array must be internally created.
       */
      @SuppressWarnings("unchecked") // caller is reponsible for getting this right
      static <E> ImmutableList<E> asImmutableList(Object[] elements) {
        return unsafeDelegateList((List) Arrays.asList(elements));
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Jun 14 22:14:46 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  10. okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnection.kt

       * `allocations.size() < allocationLimit` then new streams can be created on this connection.
       */
      internal var allocationLimit = 1
        private set
    
      /** Current calls carried by this connection. */
      val calls = mutableListOf<Reference<RealCall>>()
    
      /** Timestamp when `allocations.size()` reached zero. Also assigned upon initial connection. */
      var idleAtNs = Long.MAX_VALUE
    
      /**
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 15.4K bytes
    - Viewed (0)
Back to top