- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 100 for 1024x1024 (0.18 sec)
-
mockwebserver-deprecated/src/test/java/okhttp3/mockwebserver/MockWebServerTest.kt
connection.setDoOutput(true) connection.setFixedLengthStreamingMode(1024 * 1024 * 1024) // 1 GB connection.connect() val out = connection.outputStream val data = ByteArray(1024 * 1024) var i = 0 while (i < 1024) { try { out.write(data) out.flush() if (i == 513) { // pause slightly after halfway to make result more predictable
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 21.9K bytes - Viewed (0) -
mockwebserver/src/test/java/mockwebserver3/MockWebServerTest.kt
connection.doOutput = true connection.setFixedLengthStreamingMode(1024 * 1024 * 1024) // 1 GB connection.connect() val out = connection.outputStream val data = ByteArray(1024 * 1024) var i = 0 while (i < 1024) { try { out!!.write(data) out.flush() if (i == 513) { // pause slightly after half way to make result more predictable
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 23.5K bytes - Viewed (0) -
pkg/kubelet/cm/helpers_linux_test.go
t.Errorf("Input %v and %v, expected quota %v, but got quota %v", testCase.input, testCase.period, testCase.quota, quota) } } } func TestHugePageLimits(t *testing.T) { Mi := int64(1024 * 1024) type inputStruct struct { key string input string } testCases := []struct { name string inputs []inputStruct expected map[int64]int64 }{ {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 27.8K bytes - Viewed (0) -
pkg/proxy/ipvs/README.md
If kube-proxy starts with `--cluster-cidr=<cidr>`, IPVS proxier will masquerade off-cluster traffic accessing service Cluster IP, which behaves the same as what IPTABLES proxier. Suppose kube-proxy is provided with the cluster cidr `10.244.16.0/24`, then the IPTABLES installed by IPVS proxier should be like what is shown below. ```shell # iptables -t nat -nL Chain PREROUTING (policy ACCEPT) target prot opt source destination
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Oct 20 02:32:29 UTC 2021 - 18.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketHttpTest.kt
) val webSocket: WebSocket = newWebSocket() clientListener.assertOpen() // Send messages until the client's outgoing buffer overflows! val message: ByteString = ByteString.of(*ByteArray(1024 * 1024)) var messageCount: Long = 0 while (true) { val success = webSocket.send(message) if (!success) break messageCount++ val queueSize = webSocket.queueSize()
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sun Mar 31 17:16:15 UTC 2024 - 35.2K bytes - Viewed (0) -
cmd/erasure-healing-common_test.go
defer obj.Shutdown(context.Background()) defer removeRoots(disks) bucket := "bucket" object := "object" // make data with more than one part partCount := 3 data := bytes.Repeat([]byte("a"), 6*1024*1024*partCount) z := obj.(*erasureServerPools) s := z.serverPools[0].sets[0] erasureDisks := s.getDisks() err = obj.MakeBucket(ctx, "bucket", MakeBucketOptions{}) if err != nil {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 23K bytes - Viewed (0) -
pkg/kube/util.go
// We allow an additional 2x buffer, as it is still fairly cheap (6mb) const MaxRequestBodyBytes = int64(6 * 1024 * 1024) // HTTPConfigReader is reads an HTTP request, imposing size restrictions aligned with Kubernetes limits func HTTPConfigReader(req *http.Request) ([]byte, error) { defer req.Body.Close() lr := &io.LimitedReader{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 05:10:23 UTC 2024 - 18.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/proxy/streamtunnel_test.go
// Create a SPDY client stream, which will queue a SPDY server stream // on the stream creation channel. Send random data on the client stream // reading off the SPDY server stream, and validating it was tunneled. randomSize := 1024 * 1024 randomData := make([]byte, randomSize) _, err = rand.Read(randomData) require.NoError(t, err) var actual []byte go func() { clientStream, err := spdyClient.CreateStream(http.Header{})
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 02:21:50 UTC 2024 - 22.7K bytes - Viewed (0) -
cluster/gce/config-default.sh
export MASTER_TAG="${INSTANCE_PREFIX}-master" export NODE_TAG="${INSTANCE_PREFIX}-minion" CLUSTER_IP_RANGE="${CLUSTER_IP_RANGE:-$(get-cluster-ip-range)}" MASTER_IP_RANGE="${MASTER_IP_RANGE:-10.246.0.0/24}" # NODE_IP_RANGE is used when ENABLE_IP_ALIASES=true or CREATE_CUSTOM_NETWORK=true. # It is the primary range in the subnet and is the range used for node instance IPs. NODE_IP_RANGE="$(get-node-ip-range)"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 16 20:16:32 UTC 2024 - 26.9K bytes - Viewed (0) -
cluster/gce/config-test.sh
export MASTER_TAG="${INSTANCE_PREFIX}-master" export NODE_TAG="${INSTANCE_PREFIX}-minion" CLUSTER_IP_RANGE=${CLUSTER_IP_RANGE:-$(get-cluster-ip-range)} MASTER_IP_RANGE=${MASTER_IP_RANGE:-10.246.0.0/24} # NODE_IP_RANGE is used when ENABLE_IP_ALIASES=true or CREATE_CUSTOM_NETWORK=true. # It is the primary range in the subnet and is the range used for node instance IPs. NODE_IP_RANGE=$(get-node-ip-range)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 17:20:24 UTC 2024 - 29.8K bytes - Viewed (0)