transfer - Code Search

platforms/software/publish/src/main/java/org/gradle/api/publish/internal/PublicationInternal.java

     *
     * <p>Derived artifacts are not mandatory, i.e. when the supplied file does not exist when this
     * publication is about to be published, they will simply be omitted from the file transfer.
     *
     * <p>Currently, the only known use case for derived artifacts is adding signature files
     * created by the signing plugin.
     *

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

- Last Modified: Thu Oct 12 14:02:46 UTC 2023

- 3K bytes

- Viewed (0)

github.com/minio/minio

cmd/site-replication-metrics.go

	ReplicatedCount int64 `json:"replicationCount"`
	// Replication latency information
	Latency ReplicationLatency `json:"replicationLatency"`
	// transfer rate for large uploads
	XferRateLrg *XferStats `json:"largeTransferRate" msg:"lt"`
	// transfer rate for small uploads
	XferRateSml *XferStats `json:"smallTransferRate" msg:"st"`
	// Endpoint is the replication target endpoint
	Endpoint string `json:"-"`

Registered: Sun Jun 16 00:44:34 UTC 2024

- Last Modified: Tue Feb 06 06:00:45 UTC 2024

- 8.2K bytes

- Viewed (0)

github.com/golang/go

src/net/http/httptest/recorder.go

	if rw.wroteHeader {
		return
	}
	if len(str) > 512 {
		str = str[:512]
	}

	m := rw.Header()

	_, hasType := m["Content-Type"]
	hasTE := m.Get("Transfer-Encoding") != ""
	if !hasType && !hasTE {
		if b == nil {
			b = []byte(str)
		}
		m.Set("Content-Type", http.DetectContentType(b))
	}

	rw.WriteHeader(200)
}

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

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

- 7K bytes

- Viewed (0)

github.com/gradle/gradle

platforms/software/resources/src/main/java/org/gradle/internal/resource/transfer/UrlExternalResource.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.UncheckedException;
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

- 4.2K bytes

- Viewed (0)

github.com/apache/maven

maven-core/src/test/java/org/apache/maven/internal/transformation/AbstractRepositoryTestCase.java

import org.eclipse.aether.internal.impl.DefaultUpdatePolicyAnalyzer;
import org.eclipse.aether.repository.LocalRepository;
import org.eclipse.aether.repository.RemoteRepository;
import org.eclipse.aether.transfer.TransferListener;
import org.junit.jupiter.api.BeforeEach;
import org.mockito.Mockito;

import static org.codehaus.plexus.testing.PlexusExtension.getTestFile;

@PlexusTest

Registered: Wed Jun 12 09:55:16 UTC 2024

- Last Modified: Thu May 02 15:10:38 UTC 2024

- 4K bytes

- Viewed (0)

github.com/gradle/gradle

platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/repositories/resolver/ExternalRepositoryResourceAccessor.java

import org.gradle.internal.resource.ExternalResourceName;
import org.gradle.internal.resource.local.FileStore;
import org.gradle.internal.resource.local.LocallyAvailableExternalResource;
import org.gradle.internal.resource.transfer.CacheAwareExternalResourceAccessor;

import javax.annotation.Nullable;
import java.io.InputStream;
import java.net.URI;

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

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

- 4.3K bytes

- Viewed (0)

github.com/golang/go

src/internal/poll/splice_linux.go

	// which is determined by /proc/sys/fs/pipe-max-size.
	maxSpliceSize = 1 << 20
)

// Splice transfers at most remain bytes of data from src to dst, using the
// splice system call to minimize copies of data from and to userspace.
//
// Splice gets a pipe buffer from the pool or creates a new one if needed, to serve as a buffer for the data transfer.
// src and dst must both be stream-oriented sockets.

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

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

- 7.6K bytes

- Viewed (0)

github.com/minio/minio

cmd/batch-job-common-types.go

			col:  r.col,
			msg:  "Invalid arguments specified",
		}
	}

	return nil
}

//   # snowball based archive transfer is by default enabled when source
//   # is local and target is remote which is also minio.
//   snowball:
//     disable: false # optionally turn-off snowball archive transfer
//     batch: 100 # upto this many objects per archive

Registered: Sun Jun 16 00:44:34 UTC 2024

- Last Modified: Tue Jun 11 03:13:30 UTC 2024

- 7.9K 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/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)

Search Options