Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 13 for fork (0.16 sec)

  1. cmd/iam.go

    	}
    
    	// 2. Query LDAP server for groups of the LDAP users collected.
    	updatedGroups, err := sys.LDAPConfig.LookupGroupMemberships(parentUsers, parentUserToLDAPUsernameMap)
    	if err != nil {
    		// Log and return on error - perhaps it'll work the next time.
    		iamLogIf(GlobalContext, err)
    		return
    	}
    
    	// 3. Update creds for those users whose groups are changed
    	for _, parentUser := range parentUsers {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 21:28:16 GMT 2024
    - 71.1K bytes
    - Viewed (1)
  2. cmd/api-errors.go

    		HTTPStatusCode: http.StatusBadRequest,
    	},
    
    	// Generic Invalid-Request error. Should be used for response errors only for unlikely
    	// corner case errors for which introducing new APIErrorCode is not worth it. LogIf()
    	// should be used to log the error at the source of the error for debugging purposes.
    	ErrInvalidRequest: {
    		Code:           "InvalidRequest",
    		Description:    "Invalid Request",
    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/peer-rest-server.go

    		s.writeErrorResponse(w, errServerNotInitialized)
    		return
    	}
    
    	sizeStr := r.Form.Get(peerRESTSize)
    	durationStr := r.Form.Get(peerRESTDuration)
    	concurrentStr := r.Form.Get(peerRESTConcurrent)
    	storageClass := r.Form.Get(peerRESTStorageClass)
    	bucketName := r.Form.Get(peerRESTBucket)
    	enableSha256 := r.Form.Get(peerRESTEnableSha256) == "true"
    
    	size, err := strconv.Atoi(sizeStr)
    	if err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 51.8K bytes
    - Viewed (0)
  4. cmd/test-utils_test.go

    	if err != nil {
    		removeRoots(fsDirs)
    		return nil, nil, err
    	}
    
    	// Wait up to 10 seconds for disks to come online.
    	pools := obj.(*erasureServerPools)
    	t := time.Now()
    	for _, pool := range pools.serverPools {
    		for _, sets := range pool.erasureDisks {
    			for _, s := range sets {
    				if !s.IsLocal() {
    					for {
    						if s.IsOnline() {
    							break
    						}
    						time.Sleep(100 * time.Millisecond)
    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)
  5. cmd/batch-handlers.go

    				}
    				tagMap = t.ToMap()
    			}
    			for _, kv := range r.Flags.Filter.Tags {
    				for t, v := range tagMap {
    					if kv.Match(BatchJobKV{Key: t, Value: v}) {
    						return true
    					}
    				}
    			}
    
    			// None of the provided tags filter match skip the object
    			return false
    		}
    
    		for _, kv := range r.Flags.Filter.Metadata {
    			for k, v := range oi.UserDefined {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 55.2K bytes
    - Viewed (0)
  6. cmd/object-api-datatypes_gen.go

    	for za0001 := range z.Uploads {
    		s += z.Uploads[za0001].Msgsize()
    	}
    	s += 7 + msgp.StringPrefixSize + len(z.Prefix) + 10 + msgp.StringPrefixSize + len(z.Delimiter) + 15 + msgp.ArrayHeaderSize
    	for za0002 := range z.CommonPrefixes {
    		s += msgp.StringPrefixSize + len(z.CommonPrefixes[za0002])
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Mar 08 19:08:18 GMT 2024
    - 69.8K bytes
    - Viewed (0)
  7. cmd/bucket-replication-utils_gen.go

    				return
    			}
    			if z.TargetsMap == nil {
    				z.TargetsMap = make(map[string]TargetReplicationResyncStatus, zb0002)
    			} else if len(z.TargetsMap) > 0 {
    				for key := range z.TargetsMap {
    					delete(z.TargetsMap, key)
    				}
    			}
    			for zb0002 > 0 {
    				zb0002--
    				var za0001 string
    				var za0002 TargetReplicationResyncStatus
    				za0001, err = dc.ReadString()
    				if err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Mar 21 17:21:35 GMT 2024
    - 61.1K bytes
    - Viewed (0)
  8. cmd/bucket-handlers.go

    	}
    
    	var wg sync.WaitGroup
    	// Remove buckets that are in DNS for this server, but aren't local
    	for bucket, records := range dnsBuckets {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 16:27:27 GMT 2024
    - 61.6K bytes
    - Viewed (0)
  9. docs/bucket/notifications/README.md

    auto_deleted   (on|off)    auto delete queue when set to 'on', when there are no consumers
    delivery_mode  (number)    set to '1' for non-persistent or '2' for persistent queue
    queue_dir      (path)      staging dir for undelivered messages e.g. '/home/events'
    queue_limit    (number)    maximum limit for undelivered messages, defaults to '100000'
    comment        (sentence)  optionally add a comment to this setting
    ```
    
    Or environment variables
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 84K bytes
    - Viewed (2)
  10. cmd/xl-storage_test.go

    		t.Error("expected false for non-existent directory, got true")
    	}
    
    	// Should give false for not-a-directory.
    	dir2 := slashpath.Join(tmp, "file")
    	err := os.WriteFile(dir2, []byte("hello"), 0o777)
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	if isDirEmpty(dir2, true) {
    		t.Error("expected false for a file, got true")
    	}
    
    	// Should give true for a real empty directory.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 11 17:45:28 GMT 2024
    - 66.7K bytes
    - Viewed (0)
Back to top