transfer - Code Search

src/os/readfrom_linux_test.go

		}
	}); err != nil {
		t.Fatalf("server Conn Control error: %v", err)
	}

	// Check that the offsets after the transfer make sense, that the size
	// of the transfer was reported correctly, and that the destination
	// file contains exactly the bytes we expect it to contain.
	dstoff, err := dst.Seek(0, io.SeekCurrent)
	if err != nil {
		t.Fatal(err)
	}

Registered: Wed Jun 12 16:32:35 UTC 2024

- Last Modified: Tue Apr 02 21:49:26 UTC 2024

- 20.3K bytes

- Viewed (0)

github.com/istio/istio

pilot/pkg/security/authn/utils/utils.go

	if protocol == networking.ListenerProtocolTCP && features.MetadataExchange {
		// For TCP with mTLS, we advertise "istio-peer-exchange" from client and
		// expect the same from server. This  is so that secure metadata exchange
		// transfer can take place between sidecars for TCP with mTLS.
		if features.DisableMxALPN {
			ctx.CommonTlsContext.AlpnProtocols = util.ALPNDownstream
		} else {
			ctx.CommonTlsContext.AlpnProtocols = util.ALPNDownstreamWithMxc
		}

Registered: Fri Jun 14 15:00:06 UTC 2024

- Last Modified: Fri Feb 23 00:16:21 UTC 2024

- 3.8K bytes

- Viewed (0)

github.com/square/okhttp

mockwebserver/src/main/kotlin/mockwebserver3/MockResponse.kt

    /** Sets the status and returns this. */
    fun status(status: String) =
      apply {
        this.status = status
      }

    /**
     * Removes all HTTP headers including any "Content-Length" and "Transfer-encoding" headers that
     * were added by default.
     */
    fun clearHeaders() =
      apply {
        headers = Headers.Builder()
      }

    /**

Registered: Sun Jun 16 04:42:17 UTC 2024

- Last Modified: Tue Jan 23 14:31:42 UTC 2024

- 13.3K bytes

- Viewed (0)

github.com/golang/go

src/net/http/httptest/recorder_test.go

				io.WriteString(w, "<html>")
			},
			check(hasHeader("Content-Type", "text/html; charset=utf-8")),
		},
		{
			"no Content-Type detection with Transfer-Encoding",
			func(w http.ResponseWriter, r *http.Request) {
				w.Header().Set("Transfer-Encoding", "some encoding")
				io.WriteString(w, "<html>")
			},
			check(hasHeader("Content-Type", "")), // no header
		},
		{

Registered: Wed Jun 12 16:32:35 UTC 2024

- Last Modified: Mon Apr 11 23:17:38 UTC 2022

- 9.7K bytes

- Viewed (0)

github.com/golang/go

src/net/http/internal/chunked.go

// Copyright 2009 The Go Authors. All rights reserved.
// Use of this source code is governed by a BSD-style
// license that can be found in the LICENSE file.

// The wire protocol for HTTP's "chunked" Transfer-Encoding.

// Package internal contains HTTP internals shared by net/http and
// net/http/httputil.
package internal

import (
	"bufio"
	"bytes"
	"errors"
	"fmt"
	"io"
)

Registered: Wed Jun 12 16:32:35 UTC 2024

- Last Modified: Wed Jan 10 03:29:50 UTC 2024

- 7.8K bytes

- Viewed (0)

github.com/golang/go

src/net/mptcpsock_linux_test.go

		}
	}

	c, err := d.Dial("tcp", addr)
	if err != nil {
		t.Fatal(err)
	}
	defer c.Close()

	tcp, ok := c.(*TCPConn)
	if !ok {
		t.Fatal("struct is not a TCPConn")
	}

	// Transfer a bit of data to make sure everything is still OK
	snt := []byte("MPTCP TEST")
	if _, err := c.Write(snt); err != nil {
		t.Fatal(err)
	}
	b := make([]byte, len(snt))
	if _, err := c.Read(b); err != nil {

Registered: Wed Jun 12 16:32:35 UTC 2024

- Last Modified: Tue Jul 11 00:36:57 UTC 2023

- 4.1K bytes

- Viewed (0)

github.com/gradle/gradle

platforms/software/resources/src/main/java/org/gradle/internal/resource/transfer/ExternalResourceAccessor.java

 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

package org.gradle.internal.resource.transfer;

import org.gradle.api.resources.ResourceException;
import org.gradle.internal.resource.ExternalResource;
import org.gradle.internal.resource.ExternalResourceName;

Registered: Wed Jun 12 18:38:38 UTC 2024

- Last Modified: Thu Oct 12 19:38:08 UTC 2023

- 3.8K bytes

- Viewed (0)

github.com/gradle/gradle

platforms/software/dependency-management/src/main/java/org/gradle/internal/resource/transfer/ProgressLoggingExternalResourceAccessor.java

 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

package org.gradle.internal.resource.transfer;

import org.gradle.api.resources.ResourceException;
import org.gradle.internal.operations.BuildOperationContext;
import org.gradle.internal.operations.BuildOperationDescriptor;

Registered: Wed Jun 12 18:38:38 UTC 2024

- Last Modified: Fri Mar 08 12:31:19 UTC 2024

- 6.8K bytes

- Viewed (0)

github.com/gradle/gradle

platforms/software/dependency-management/src/test/groovy/org/gradle/api/internal/artifacts/repositories/resolver/ExternalResourceResolverTest.groovy

import org.gradle.internal.resource.local.FileStore
import org.gradle.internal.resource.local.LocallyAvailableExternalResource
import org.gradle.internal.resource.local.LocallyAvailableResourceFinder
import org.gradle.internal.resource.transfer.CacheAwareExternalResourceAccessor
import spock.lang.Specification

class ExternalResourceResolverTest extends Specification {
    String name = "TestResolver"
    ExternalResourceRepository repository = Mock()

Registered: Wed Jun 12 18:38:38 UTC 2024

- Last Modified: Tue Oct 10 21:10:11 UTC 2023

- 6.6K bytes

- Viewed (0)

github.com/square/okhttp

docs/features/calls.md

at a high-level: _“fetch me this URL with these headers.”_ For correctness and efficiency, OkHttp rewrites your request before transmitting it.

OkHttp may add headers that are absent from the original request, including `Content-Length`, `Transfer-Encoding`, `User-Agent`, `Host`, `Connection`, and `Content-Type`. It will add an `Accept-Encoding` header for transparent response compression unless the header is already present. If you’ve got cookies, OkHttp will add a `Cookie` header with them....

Registered: Sun Jun 16 04:42:17 UTC 2024

- Last Modified: Sun Feb 06 02:19:09 UTC 2022

- 3.9K bytes

- Viewed (0)

Search Options