body - Code Search

src/archive/tar/tar_test.go

		}
		if (formats == FormatUnknown) && (err == nil) {
			t.Errorf("test %d, got nil-error, want non-nil error", i)
		}
	}
}

func Benchmark(b *testing.B) {
	type file struct {
		hdr  *Header
		body []byte
	}

	vectors := []struct {
		label string
		files []file
	}{{
		"USTAR",
		[]file{{
			&Header{Name: "bar", Mode: 0640, Size: int64(3)},
			[]byte("foo"),
		}, {

Registered: Tue Nov 05 11:13:11 UTC 2024

- Last Modified: Thu Jul 25 00:25:45 UTC 2024

- 23.9K bytes

- Viewed (0)

github.com/minio/minio

cmd/batch-expire.go

func (r BatchJobExpire) Notify(ctx context.Context, body io.Reader) error {
	if r.NotificationCfg.Endpoint == "" {
		return nil
	}

	ctx, cancel := context.WithTimeout(ctx, 10*time.Second)
	defer cancel()

	req, err := http.NewRequestWithContext(ctx, http.MethodPost, r.NotificationCfg.Endpoint, body)
	if err != nil {
		return err
	}

	if r.NotificationCfg.Token != "" {

Registered: Sun Nov 03 19:28:11 UTC 2024

- Last Modified: Wed Sep 18 17:59:03 UTC 2024

- 21.9K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/main/java/jcifs/smb1/http/NetworkExplorer.java

            out.println( "    a:hover {" );
            out.println( "        background: #a2ff01;" );
            out.println( "    }" );
        }

        out.println( "</STYLE>" );
        out.println( "</head><body>" );

        out.print( "<a class=\"sort\" style=\"width: " + maxLen + ";\" href=\"?fmt=detail&sort=name\">Name</a>" );
        out.println( "<a class=\"sort\" href=\"?fmt=detail&sort=size\">Size</a>" );

Registered: Sun Nov 03 00:10:13 UTC 2024

- Last Modified: Wed Jan 22 03:57:31 UTC 2020

- 19.7K bytes

- Viewed (0)

github.com/minio/minio

cmd/warm-backend-azure.go

		Range: blob.HTTPRange{Offset: opts.startOffset, Count: opts.length},
	})
	if err != nil {
		return nil, azureToObjectError(err, az.Bucket, az.getDest(object))
	}

	return resp.Body, nil
}

func (az *warmBackendAzure) Remove(ctx context.Context, object string, rv remoteVersionID) error {
	_, err := az.clnt.DeleteBlob(ctx, az.Bucket, az.getDest(object), &azblob.DeleteBlobOptions{})

Registered: Sun Nov 03 19:28:11 UTC 2024

- Last Modified: Thu Oct 31 22:10:24 UTC 2024

- 7K bytes

- Viewed (0)

github.com/go-gorm/gorm

tests/customize_field_test.go

func TestCustomColumnAndIgnoredFieldClash(t *testing.T) {
	// Make sure an ignored field does not interfere with another field's custom
	// column name that matches the ignored field.
	type CustomColumnAndIgnoredFieldClash struct {
		Body    string `gorm:"-"`
		RawBody string `gorm:"column:body"`
	}

	DB.Migrator().DropTable(&CustomColumnAndIgnoredFieldClash{})

	if err := DB.AutoMigrate(&CustomColumnAndIgnoredFieldClash{}); err != nil {

Registered: Sun Nov 03 09:35:10 UTC 2024

- Last Modified: Fri Sep 11 09:33:31 UTC 2020

- 6.9K bytes

- Viewed (0)

github.com/minio/minio

cmd/bitrot-streaming.go

	shardSize  int64
	hashBytes  []byte
}

func (b *streamingBitrotReader) Close() error {
	if b.rc == nil {
		return nil
	}
	if closer, ok := b.rc.(io.Closer); ok {
		// drain the body for connection reuse at network layer.
		xhttp.DrainBody(io.NopCloser(b.rc))
		return closer.Close()
	}
	return nil
}

func (b *streamingBitrotReader) ReadAt(buf []byte, offset int64) (int, error) {

Registered: Sun Nov 03 19:28:11 UTC 2024

- Last Modified: Wed Aug 21 12:20:54 UTC 2024

- 6K bytes

- Viewed (0)

github.com/minio/minio

cmd/bucket-lifecycle-handlers.go

	rcfg, err := globalBucketObjectLockSys.Get(bucket)
	if err != nil {
		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
		return
	}

	bucketLifecycle, err := lifecycle.ParseLifecycleConfigWithID(io.LimitReader(r.Body, r.ContentLength))
	if err != nil {
		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
		return
	}

	// Validate the received bucket policy document
	if err = bucketLifecycle.Validate(rcfg); err != nil {

Registered: Sun Nov 03 19:28:11 UTC 2024

- Last Modified: Fri May 24 23:05:23 UTC 2024

- 7K bytes

- Viewed (0)

github.com/minio/minio

internal/config/lambda/target/webhook.go

	}

	resp, err := target.httpClient.Do(req)
	if err != nil {
		if xnet.IsNetworkOrHostDown(err, true) {
			return false, errNotConnected
		}
		return false, err
	}
	xhttp.DrainBody(resp.Body)
	// No network failure i.e response from the target means its up
	return true, nil
}

// Stat - returns lambda webhook target statistics such as
// current calls in progress, successfully completed functions

Registered: Sun Nov 03 19:28:11 UTC 2024

- Last Modified: Mon Jul 08 21:39:49 UTC 2024

- 6.7K bytes

- Viewed (0)

github.com/tensorflow/tensorflow

CODE_OF_CONDUCT.md

In the interest of fostering an open and welcoming environment, we as
contributors and maintainers pledge to make participation in our project and our
community a harassment-free experience for everyone, regardless of age, body
size, disability, ethnicity, gender identity and expression, level of
experience, nationality, personal appearance, race, religion, or sexual identity
and orientation.

## Our Standards

Registered: Tue Nov 05 12:39:12 UTC 2024

- Last Modified: Fri Feb 05 18:43:16 UTC 2021

- 5.2K bytes

- Viewed (0)

github.com/minio/minio

cmd/prepare-storage.go

		return err
	}
	// Indicate that the liveness check for a peer call
	req.Header.Set(xhttp.MinIOPeerCall, "true")

	resp, err := httpClient.Do(req)
	if err != nil {
		return err
	}
	xhttp.DrainBody(resp.Body)

	return nil
}

// connect to list of endpoints and load all Erasure disk formats, validate the formats are correct
// and are in quorum, if no formats are found attempt to initialize all of them for the first

Registered: Sun Nov 03 19:28:11 UTC 2024

- Last Modified: Fri Jul 12 20:51:54 UTC 2024

- 11.1K bytes

- Viewed (1)

Search Options