Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 39 for eof (0.14 sec)

  1. cmd/xl-storage-disk-id-check.go

    // that is not io.EOF.
    func diskHealthCheckOK(ctx context.Context, err error) bool {
    	// Check if context has a disk health check.
    	tracker, ok := ctx.Value(healthDiskCtxKey{}).(*healthDiskCtxValue)
    	if !ok {
    		// No tracker, return
    		return err == nil || errors.Is(err, io.EOF)
    	}
    	if err == nil || errors.Is(err, io.EOF) {
    		tracker.logSuccess()
    		return true
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 33K bytes
    - Viewed (0)
  2. cmd/kms-handlers.go

    		return
    	}
    
    	pattern := r.Form.Get("pattern")
    	if !strings.Contains(pattern, "*") {
    		pattern += "*"
    	}
    
    	var values []kes.KeyInfo
    	for name, err := keys.SeekTo(ctx, pattern); err != io.EOF; name, err = keys.Next(ctx) {
    		if err != nil {
    			writeCustomErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrInternalError), err.Error(), r.URL)
    			return
    		}
    		values = append(values, kes.KeyInfo{
    			Name: name,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Mar 01 21:09:42 GMT 2024
    - 20.7K bytes
    - Viewed (0)
  3. cmd/metacache-server-pool.go

    		// Marker not common with prefix is not implemented. Send an empty response
    		if !HasPrefix(o.Marker, o.Prefix) {
    			return entries, io.EOF
    		}
    	}
    
    	// With max keys of zero we have reached eof, return right here.
    	if o.Limit == 0 {
    		return entries, io.EOF
    	}
    
    	// For delimiter and prefix as '/' we do not list anything at all
    	// along // with the prefix. On a flat namespace with 'prefix'
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 12.8K bytes
    - Viewed (0)
  4. cmd/erasure-common.go

    	}
    
    	ignoredErrs := []error{
    		errFileNotFound,
    		errVolumeNotFound,
    		errFileVersionNotFound,
    		io.ErrUnexpectedEOF, // some times we would read without locks, ignore these errors
    		io.EOF,              // some times we would read without locks, ignore these errors
    		context.DeadlineExceeded,
    		context.Canceled,
    	}
    	ignoredErrs = append(ignoredErrs, objectOpIgnoredErrs...)
    
    	errs := g.Wait()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 4.6K bytes
    - Viewed (0)
  5. internal/disk/stat_linux.go

    	file, err := os.Open(fileName)
    	if err != nil {
    		return nil, err
    	}
    	defer file.Close()
    
    	s, err := bufio.NewReader(file).ReadString('\n')
    	if err != nil && !errors.Is(err, io.EOF) {
    		return nil, err
    	}
    	statLine := strings.TrimSpace(s)
    	for _, token := range strings.Fields(statLine) {
    		ui64, err := strconv.ParseUint(token, 10, 64)
    		if err != nil {
    			return nil, err
    		}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Feb 26 19:34:50 GMT 2024
    - 4.8K bytes
    - Viewed (0)
  6. .github/workflows/go-fips.yml

              echo Detected go version $GO_VERSION
              cat > Dockerfile.fips.test <<EOF
              FROM golang:${GO_VERSION}
              COPY . /minio
              WORKDIR /minio
              ENV GOEXPERIMENT=boringcrypto
              RUN make
              EOF
    
          - name: Build
            uses: docker/build-push-action@v3
            with:
              context: .
    Others
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Mar 28 23:44:49 GMT 2024
    - 1.5K bytes
    - Viewed (0)
  7. cmd/untar.go

    			err := asyncErr
    			asyncErrMu.Unlock()
    			if err != nil {
    				return err
    			}
    		}
    
    		header, err := tarReader.Next()
    		switch {
    
    		// if no more files are found return
    		case err == io.EOF:
    			wg.Wait()
    			return asyncErr
    
    		// return any other error
    		case err != nil:
    			wg.Wait()
    			extra := ""
    			if n > 0 {
    				extra = fmt.Sprintf(" after %d successful object(s)", n)
    			}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 6K bytes
    - Viewed (0)
  8. internal/grid/muxclient.go

    			}
    			m.addErrorNonBlockingClose(internalResp, context.Cause(m.ctx))
    			errState = true
    			continue
    		case req, ok := <-requests:
    			if !ok {
    				// Done send EOF
    				if debugPrint {
    					fmt.Println("Client done, sending EOF to mux", m.MuxID)
    				}
    				msg := message{
    					Op:    OpMuxClientMsg,
    					MuxID: m.MuxID,
    					Seq:   1,
    					Flags: FlagEOF,
    				}
    				msg.setZeroPayloadFlag()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 14.2K bytes
    - Viewed (0)
  9. cmd/storage-rest-client.go

    		return errAuthentication
    	case errRPCAPIVersionUnsupported.Error():
    		return errRPCAPIVersionUnsupported
    	case errServerTimeMismatch.Error():
    		return errServerTimeMismatch
    	case io.EOF.Error():
    		return io.EOF
    	case io.ErrUnexpectedEOF.Error():
    		return io.ErrUnexpectedEOF
    	case errDiskStale.Error():
    		return errDiskNotFound
    	case errDiskNotFound.Error():
    		return errDiskNotFound
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 26.1K bytes
    - Viewed (0)
  10. cmd/erasure-object.go

    	// Fetch buffer for I/O, returns from the pool if not allocates a new one and returns.
    	var buffer []byte
    	switch size := data.Size(); {
    	case size == 0:
    		buffer = make([]byte, 1) // Allocate at least a byte to reach EOF
    	case size >= fi.Erasure.BlockSize:
    		buffer = globalBytePoolCap.Load().Get()
    		defer globalBytePoolCap.Load().Put(buffer)
    	case size < fi.Erasure.BlockSize:
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 77.2K bytes
    - Viewed (2)
Back to top