Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for react (0.17 sec)

  1. cmd/service.go

    // For each call, unfreezeServices must be called once.
    func unfreezeServices() {
    	// We need a lock since we need the 2 atomic values to remain in sync.
    	globalServiceFreezeMu.Lock()
    	// Close when we reach 0
    	globalServiceFreezeCnt--
    	if globalServiceFreezeCnt <= 0 {
    		// Set to a nil channel.
    		var _ch chan struct{}
    		if val := globalServiceFreeze.Swap(_ch); val != nil {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Wed Feb 28 07:02:14 GMT 2024
    - 3.8K bytes
    - Viewed (0)
  2. cmd/bucket-notification-handlers.go

    					config.QueueList = append(config.QueueList[:i],
    						config.QueueList[i+1:]...)
    				}
    				// This is a one time activity we shall do this
    				// here and allow stale ARN to be removed. We shall
    				// never reach a stage where we will have stale
    				// notification configs.
    			}
    		} else {
    			writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    			return
    		}
    	}
    
    	configData, err := xml.Marshal(config)
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Sep 04 19:57:37 GMT 2023
    - 5.1K bytes
    - Viewed (0)
  3. istioctl/pkg/writer/ztunnel/configdump/workload.go

    		return svc.Name
    	}
    
    	return "NA" // Shouldn't normally reach here
    }
    
    func serviceWaypointName(svc *ZtunnelService, services map[string]*ZtunnelService) string {
    	if svc.Waypoint == nil {
    		return "None"
    	}
    
    	if svc, ok := services[svc.Waypoint.Destination]; ok {
    		return svc.Name
    	}
    
    	return "NA" // Shouldn't normally reach here
    Go
    - Registered: Wed Apr 24 22:53:08 GMT 2024
    - Last Modified: Tue Apr 23 21:30:30 GMT 2024
    - 4K bytes
    - Viewed (0)
  4. cmd/http-tracer.go

    	xhttp "github.com/minio/minio/internal/http"
    	"github.com/minio/minio/internal/mcontext"
    )
    
    var ldapPwdRegex = regexp.MustCompile("(^.*?)LDAPPassword=([^&]*?)(&(.*?))?$")
    
    // redact LDAP password if part of string
    func redactLDAPPwd(s string) string {
    	parts := ldapPwdRegex.FindStringSubmatch(s)
    	if len(parts) > 3 {
    		return parts[1] + "LDAPPassword=*REDACTED*" + parts[3]
    	}
    	return s
    }
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Nov 21 01:09:35 GMT 2023
    - 5.9K bytes
    - Viewed (0)
  5. internal/lock/lock.go

    func (r *RLockedFile) IncLockRef() {
    	r.mutex.Lock()
    	r.refs++
    	r.mutex.Unlock()
    }
    
    // Close - this closer implements a special closer
    // closes the underlying fd only when the refs
    // reach zero.
    func (r *RLockedFile) Close() (err error) {
    	r.mutex.Lock()
    	defer r.mutex.Unlock()
    
    	if r.refs == 0 {
    		return os.ErrInvalid
    	}
    
    	r.refs--
    	if r.refs == 0 {
    		err = r.File.Close()
    	}
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Sun Jan 02 17:15:06 GMT 2022
    - 2.5K bytes
    - Viewed (0)
  6. internal/s3select/sql/jsonpath.go

    				if arr, ok := rval.([]interface{}); ok {
    					result = append(result, arr...)
    					continue
    				}
    			}
    			result = append(result, rval)
    		}
    		return result, true, nil
    	}
    	panic("cannot reach here")
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 3.4K bytes
    - Viewed (0)
Back to top