Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 22 for ends (0.13 sec)

  1. cmd/erasure-object.go

    		// considered as Delete marker true to avoid listing such objects by
    		// regular ListObjects() calls. However for delete replication this
    		// ends up being a problem because "upon" a successful delete this
    		// ends up creating a new delete marker that is spurious and unnecessary.
    		//
    		// Regression introduced by #14555 was reintroduced in #15564
    		if versionFound {
    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)
  2. cmd/api-errors.go

    			apiErr = APIError{
    				Code:           "XGCSInternalError",
    				Description:    e.Message,
    				HTTPStatusCode: e.Code,
    			}
    			// GCS may send multiple errors, just pick the first one
    			// since S3 only sends one Error XML response.
    			if len(e.Errors) >= 1 {
    				apiErr.Code = e.Errors[0].Reason
    			}
    		case azblob.StorageError:
    			apiErr = APIError{
    				Code:           string(e.ServiceCode()),
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 91.4K bytes
    - Viewed (7)
  3. cmd/erasure-server-pool.go

    				return true
    			}
    		}
    		return false
    	}
    	if hadoop && matches() && delimiter == SlashSeparator && maxKeys == 2 && marker == "" {
    		// Optimization for Spark/Hadoop workload where spark sends a garbage
    		// request of this kind
    		//
    		// GET /testbucket/?list-type=2&delimiter=%2F&max-keys=2&prefix=parquet%2F_SUCCESS%2F&fetch-owner=false
    		//
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 80.5K bytes
    - Viewed (0)
  4. cmd/object-handlers.go

    		return
    	}
    
    	objectRSC := s3select.NewObjectReadSeekCloser(
    		func(offset int64) (io.ReadCloser, error) {
    			rs := &HTTPRangeSpec{
    				IsSuffixLength: false,
    				Start:          offset,
    				End:            -1,
    			}
    			opts.NoLock = true
    			return getObjectNInfo(ctx, bucket, object, rs, r.Header, opts)
    		},
    		actualSize,
    	)
    	defer objectRSC.Close()
    	s3Select, err := s3select.NewS3Select(r.Body)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu May 02 20:15:54 GMT 2024
    - 125.2K bytes
    - Viewed (0)
  5. cmd/config-current.go

    				key, subSys)
    		}
    		h = config.HelpKVS{value}
    	}
    
    	help := config.HelpKVS{}
    
    	// Only for multiple targets, make sure
    	// to list the ENV, for regular k/v EnableKey is
    	// implicit, for ENVs we cannot make it implicit.
    	if subSysHelp.MultipleTargets {
    		key := madmin.EnableKey
    		if envOnly {
    			key = config.EnvPrefix + strings.ToTitle(subSys) + config.EnvWordDelimiter + strings.ToTitle(madmin.EnableKey)
    		}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 30.8K bytes
    - Viewed (0)
  6. docs/ftp/README.md

    aes128-cbc
    3des-cbc
    ```
    
    `--sftp=mac-algos=...` specifies a default set of MAC algorithms in preference order.
    This is based on RFC 4253, section 6.4, but with hmac-md5 variants removed because they have 
    reached the end of their useful life.
    
    Valid values: 
    
    ```
    ******@****.***
    ******@****.***
    hmac-sha2-256
    hmac-sha2-512
    hmac-sha1
    hmac-sha1-96
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 30 15:15:45 GMT 2024
    - 7.1K bytes
    - Viewed (0)
  7. internal/grid/grid_test.go

    		select {
    		case <-cc:
    			return
    		case <-c:
    			buf := make([]byte, 1<<20)
    			stacklen := runtime.Stack(buf, true)
    			fmt.Printf("=== Timeout, assuming deadlock ===\n*** goroutine dump...\n%s\n*** end\n", string(buf[:stacklen]))
    			os.Exit(2)
    		}
    	}()
    	return func() {
    		close(cc)
    	}
    }
    
    func assertNoActive(t *testing.T, c *Connection) {
    	t.Helper()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 30 15:03:35 GMT 2024
    - 30.1K bytes
    - Viewed (0)
  8. cmd/test-utils_test.go

    	registerBucketLevelFunc(bucketRouter, api, apiFunctions...)
    }
    
    // Takes in Erasure object layer, and the list of API end points to be tested/required, registers the API end points and returns the HTTP handler.
    // Need isolated registration of API end points while writing unit tests for end points.
    // All the API end points are registered only for the default case.
    func initTestAPIEndPoints(objLayer ObjectLayer, apiFunctions []string) http.Handler {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 17:26:51 GMT 2024
    - 76.2K bytes
    - Viewed (0)
  9. cmd/sftp-server.go

    }
    
    // supportedMACs specifies a default set of MAC algorithms in preference order.
    // This is based on RFC 4253, section 6.4, but with hmac-md5 variants removed
    // because they have reached the end of their useful life.
    // https://cs.opensource.google/go/x/crypto/+/refs/tags/v0.22.0:ssh/common.go;l=85
    var supportedMACs = []string{
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 11:07:40 GMT 2024
    - 10.4K bytes
    - Viewed (0)
  10. cmd/bucket-replication.go

    			if err := p.queueMRFHeal(); err != nil && !osIsNotExist(err) {
    				replLogIf(p.ctx, err)
    			}
    			pTimer.Reset(mrfQueueInterval)
    		case <-p.ctx.Done():
    			return
    		}
    	}
    }
    
    // process sends error logs to the heal channel for an attempt to heal replication.
    func (p *ReplicationPool) queueMRFHeal() error {
    	p.mrfMU.Lock()
    	defer p.mrfMU.Unlock()
    
    	if !p.initialized() {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 112.2K bytes
    - Viewed (1)
Back to top