Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 35 of 35 for Future (0.14 sec)

  1. cmd/notification.go

    	// doing below. However the changes that are needed here are a bit involved,
    	// further discussion advised. Remove this comment and remove the worker model
    	// for this function in future.
    	maxWorkers := runtime.GOMAXPROCS(0) / 2
    	if maxWorkers > len(sys.peerClients) {
    		maxWorkers = len(sys.peerClients)
    	}
    
    	ng := WithNPeersThrottled(len(sys.peerClients), maxWorkers)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 12 18:13:36 GMT 2024
    - 44.5K bytes
    - Viewed (0)
  2. internal/logger/target/http/http.go

    	h.storeCtxCancel()
    
    	// Wait for messages to be sent...
    	h.wg.Wait()
    
    	// Set logch to nil and close it.
    	// This will block all Send operations,
    	// and finish the existing ones.
    	// All future ones will be discarded.
    	h.logChMu.Lock()
    	xioutil.SafeClose(h.logCh)
    	h.logCh = nil
    	h.logChMu.Unlock()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Mar 25 16:44:20 GMT 2024
    - 14.9K bytes
    - Viewed (0)
  3. src/cmd/cgo/ast.go

    	sel := (*n).(*ast.SelectorExpr)
    	// For now, assume that the only instance of capital C is when
    	// used as the imported package identifier.
    	// The parser should take care of scoping in the future, so
    	// that we will be able to distinguish a "top-level C" from a
    	// local C.
    	if l, ok := sel.X.(*ast.Ident); !ok || l.Name != "C" {
    		return
    	}
    	if context == ctxAssign2 {
    		context = ctxExpr
    	}
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Wed Jun 07 16:54:27 GMT 2023
    - 14.3K bytes
    - Viewed (0)
  4. cmd/admin-handlers-users.go

    	if err != nil {
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    		return
    	}
    
    	// Add ldap users which have mapped policies if in LDAP mode
    	// FIXME(vadmeste): move this to policy info in the future
    	ldapUsers, err := globalIAMSys.ListLDAPUsers(ctx)
    	if err != nil && err != errIAMActionNotAllowed {
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    		return
    	}
    	for k, v := range ldapUsers {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 12:41:13 GMT 2024
    - 77.5K bytes
    - Viewed (0)
  5. cmd/xl-storage-format-v2.go

    		case ObjectType:
    			return x.setIdx(i, ventry)
    		case DeleteType:
    			// Allowing delete marker to replaced with proper
    			// object data type as well, this is not S3 complaint
    			// behavior but kept here for future flexibility.
    			return x.setIdx(i, ventry)
    		}
    	}
    
    	// We did not find it, add it.
    	return x.addVersion(ventry)
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 05:07:37 GMT 2024
    - 63.6K bytes
    - Viewed (1)
Back to top