Search Options

Results per page
Sort
Preferred Languages
Advance

Results 191 - 200 of 988 for readOp (0.09 sec)

  1. cmd/erasure-multipart.go

    	if !opts.NoAuditLog {
    		auditObjectErasureSet(ctx, "PutObjectPart", object, &er)
    	}
    
    	data := r.Reader
    	// Validate input data size and it can never be less than zero.
    	if data.Size() < -1 {
    		bugLogIf(ctx, errInvalidArgument, logger.ErrorKind)
    		return pi, toObjectErr(errInvalidArgument)
    	}
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 44.7K bytes
    - Viewed (0)
  2. doc/go_mem.html

        or a <i>synchronizing operation</i> such as an atomic data access,
    	a mutex operation, or a channel operation,</li>
    	<li>its location in the program,</li>
    	<li>the memory location or variable being accessed, and</li>
    	<li>the values read or written by the operation.</li>
    </ul>
    <p>
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Mon Mar 04 15:54:42 UTC 2024
    - 26.6K bytes
    - Viewed (0)
  3. internal/lsync/lrwmutex_test.go

    		panic("Failed to acquire read lock")
    	}
    	// fmt.Println("1st read lock acquired, waiting...")
    
    	if !lrwm.GetRLock(ctx, "", "object1", time.Second) {
    		panic("Failed to acquire read lock")
    	}
    	// fmt.Println("2nd read lock acquired, waiting...")
    
    	go func() {
    		time.Sleep(2 * time.Second)
    		lrwm.RUnlock()
    		// fmt.Println("1st read lock released, waiting...")
    	}()
    
    	go func() {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sun Mar 05 04:57:35 UTC 2023
    - 7.9K bytes
    - Viewed (0)
  4. .github/workflows/sigbuild-docker-branch.yml

      push:
        paths:
          - '.github/workflows/sigbuild-docker-branch.yml'
          - 'tensorflow/tools/tf_sig_build_dockerfiles/**'
          - '!tensorflow/tools/tf_sig_build_dockerfiles/README.md'
        branches:
          - "r[1-9].[0-9]+"
    
    permissions:
      contents: read
    
    jobs:
      docker:
        if: github.repository == 'tensorflow/tensorflow' # Don't do this in forks
        runs-on: ubuntu-latest
        strategy:
          matrix:
    Registered: Tue Oct 29 12:39:09 UTC 2024
    - Last Modified: Tue Oct 01 08:13:39 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  5. cmd/data-usage-cache_gen.go

    package cmd
    
    // Code generated by github.com/tinylib/msgp DO NOT EDIT.
    
    import (
    	"time"
    
    	"github.com/tinylib/msgp/msgp"
    )
    
    // DecodeMsg implements msgp.Decodable
    func (z *allTierStats) DecodeMsg(dc *msgp.Reader) (err error) {
    	var field []byte
    	_ = field
    	var zb0001 uint32
    	zb0001, err = dc.ReadMapHeader()
    	if err != nil {
    		err = msgp.WrapError(err)
    		return
    	}
    	for zb0001 > 0 {
    		zb0001--
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 75K bytes
    - Viewed (0)
  6. CONTRIBUTING.md

    This will build the whole documentation locally in [platforms/documentation](./platforms/documentation).
    For more commands and examples, including local development,
    see [this guide](./platforms/documentation/docs/README.md).
    
    ### Creating commits and writing commit messages
    
    The commit messages that accompany your code changes are an important piece of documentation. Please follow these guidelines when creating commits:
    
    Registered: Wed Oct 30 11:36:09 UTC 2024
    - Last Modified: Tue Jun 18 08:01:25 UTC 2024
    - 15.8K bytes
    - Viewed (0)
  7. cmd/healthcheck-router.go

    import (
    	"net/http"
    
    	"github.com/minio/mux"
    )
    
    const (
    	healthCheckPath            = "/health"
    	healthCheckLivenessPath    = "/live"
    	healthCheckReadinessPath   = "/ready"
    	healthCheckClusterPath     = "/cluster"
    	healthCheckClusterReadPath = "/cluster/read"
    	healthCheckPathPrefix      = minioReservedBucketPath + healthCheckPath
    )
    
    // registerHealthCheckRouter - add handler functions for liveness and readiness routes.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jan 23 11:12:47 UTC 2023
    - 2.3K bytes
    - Viewed (0)
  8. internal/rest/client.go

    				r := bytes.NewReader(buf)
    				return io.NopCloser(r), nil
    			}
    		case *bytes.Reader:
    			req.ContentLength = int64(v.Len())
    			snapshot := *v
    			req.GetBody = func() (io.ReadCloser, error) {
    				r := snapshot
    				return io.NopCloser(&r), nil
    			}
    		case *strings.Reader:
    			req.ContentLength = int64(v.Len())
    			snapshot := *v
    			req.GetBody = func() (io.ReadCloser, error) {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Jul 26 12:55:01 UTC 2024
    - 14.7K bytes
    - Viewed (0)
  9. cmd/object-handlers.go

    		compressMetadata[ReservedMetadataPrefix+"actual-size"] = strconv.FormatInt(actualSize, 10)
    
    		reader = etag.NewReader(ctx, reader, nil, nil)
    		wantEncryption := crypto.Requested(r.Header)
    		s2c, cb := newS2CompressReader(reader, actualSize, wantEncryption)
    		dstOpts.IndexCB = cb
    		defer s2c.Close()
    		reader = etag.Wrap(s2c, reader)
    		length = -1
    	} else {
    		delete(srcInfo.UserDefined, ReservedMetadataPrefix+"compression")
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sat Oct 05 05:16:15 UTC 2024
    - 117.4K bytes
    - Viewed (0)
  10. cmd/object_api_suite_test.go

    // Return pointer to testOneByteReadNoEOF{}
    func newTestReaderNoEOF(data []byte) io.Reader {
    	return &testOneByteReadNoEOF{false, data}
    }
    
    // testOneByteReadNoEOF - implements io.Reader which returns 1 byte and nil error, but
    // returns io.EOF on the next Read().
    type testOneByteReadNoEOF struct {
    	eof  bool
    	data []byte
    }
    
    func (r *testOneByteReadNoEOF) Read(p []byte) (n int, err error) {
    	if r.eof {
    		return 0, io.EOF
    	}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Jul 02 15:13:05 UTC 2024
    - 33.3K bytes
    - Viewed (0)
Back to top