Search Options

Results per page
Sort
Preferred Languages
Advance

Results 281 - 290 of 453 for ctx_ (0.06 sec)

  1. cmd/bootstrap-messages.go

    		traceInfo = append(traceInfo, i)
    	}
    	bs.mu.RUnlock()
    
    	return traceInfo
    }
    
    func (bs *bootstrapTracer) Publish(ctx context.Context, trace *pubsub.PubSub[madmin.TraceInfo, madmin.TraceType]) {
    	for _, bsEvent := range bs.Events() {
    		if bsEvent.Message != "" {
    			select {
    			case <-ctx.Done():
    			default:
    				trace.Publish(bsEvent)
    			}
    		}
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 23 10:07:06 UTC 2023
    - 1.7K bytes
    - Viewed (0)
  2. internal/http/check_port_others.go

    func CheckPortAvailability(host, port string, opts TCPOptions) (err error) {
    	lc := &net.ListenConfig{}
    
    	ctx, cancel := context.WithTimeout(context.Background(), time.Second)
    	defer cancel()
    
    	l, err := lc.Listen(ctx, "tcp", net.JoinHostPort(host, port))
    	if err != nil {
    		return err
    	}
    
    	// As we are able to listen on this network, the port is not in use.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 03 21:12:25 UTC 2023
    - 1.5K bytes
    - Viewed (0)
  3. internal/config/dns/operator_dns.go

    // Put - Adds DNS entries into operator webhook server
    func (c *OperatorDNS) Put(bucket string) error {
    	ctx, cancel := context.WithTimeout(context.Background(), defaultOperatorContextTimeout)
    	defer cancel()
    	e, err := c.endpoint(bucket, false)
    	if err != nil {
    		return newError(bucket, err)
    	}
    	req, err := http.NewRequestWithContext(ctx, http.MethodPost, e, nil)
    	if err != nil {
    		return newError(bucket, err)
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Mar 06 16:56:10 UTC 2023
    - 6.6K bytes
    - Viewed (0)
  4. cmd/test-utils_test.go

    }
    
    func prepareErasureSets32(ctx context.Context) (ObjectLayer, []string, error) {
    	return prepareErasure(ctx, 32)
    }
    
    func prepareErasure(ctx context.Context, nDisks int) (ObjectLayer, []string, error) {
    	fsDirs, err := getRandomDisks(nDisks)
    	if err != nil {
    		return nil, nil, err
    	}
    	obj, _, err := initObjectLayer(ctx, mustGetPoolEndpoints(0, fsDirs...))
    	if err != nil {
    		removeRoots(fsDirs)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 77K bytes
    - Viewed (0)
  5. cmd/handler-utils.go

    }
    
    // extractMetadataFromReq extracts metadata from HTTP header and HTTP queryString.
    func extractMetadataFromReq(ctx context.Context, r *http.Request) (metadata map[string]string, err error) {
    	return extractMetadata(ctx, textproto.MIMEHeader(r.Form), textproto.MIMEHeader(r.Header))
    }
    
    func extractMetadata(ctx context.Context, mimesHeader ...textproto.MIMEHeader) (metadata map[string]string, err error) {
    	metadata = make(map[string]string)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 15.5K bytes
    - Viewed (0)
  6. logger/logger.go

    	newlogger.LogLevel = level
    	return &newlogger
    }
    
    // Info print info
    func (l *logger) Info(ctx context.Context, msg string, data ...interface{}) {
    	if l.LogLevel >= Info {
    		l.Printf(l.infoStr+msg, append([]interface{}{utils.FileWithLineNum()}, data...)...)
    	}
    }
    
    // Warn print warn messages
    func (l *logger) Warn(ctx context.Context, msg string, data ...interface{}) {
    	if l.LogLevel >= Warn {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Tue Nov 07 02:19:41 UTC 2023
    - 5.8K bytes
    - Viewed (0)
  7. istioctl/pkg/authz/authz.go

    				if err != nil {
    					return fmt.Errorf("failed to get config dump from file %s: %s", configDumpFile, err)
    				}
    			} else if len(args) == 1 {
    				podName, podNamespace, err := ctx.InferPodInfoFromTypedResource(args[0], ctx.Namespace())
    				if err != nil {
    					return err
    				}
    				configDump, err = getConfigDumpFromPod(kubeClient, podName, podNamespace)
    				if err != nil {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Sat Apr 13 05:23:38 UTC 2024
    - 5K bytes
    - Viewed (0)
  8. internal/logger/target/testlogger/testlogger.go

    	return types.TargetStats{}
    }
    
    func (t *testLogger) Init(ctx context.Context) error {
    	return nil
    }
    
    func (t *testLogger) IsOnline(ctx context.Context) bool {
    	return t.current.Load() != nil
    }
    
    func (t *testLogger) Cancel() {
    	t.current.Store(nil)
    }
    
    func (t *testLogger) Send(ctx context.Context, entry interface{}) error {
    	tb := t.current.Load()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4K bytes
    - Viewed (0)
  9. src/main/java/jcifs/smb/SmbResourceLocatorImpl.java

        private Address[] addresses;
        private int addressIndex;
        private int type;
    
        private CIFSContext ctx;
    
    
        /**
         * 
         * @param ctx
         * @param u
         */
        public SmbResourceLocatorImpl ( CIFSContext ctx, URL u ) {
            this.ctx = ctx;
            this.url = u;
        }
    
    
        /**
         * {@inheritDoc}
         *
         * @see java.lang.Object#clone()
         */
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sat Jul 20 08:24:53 UTC 2019
    - 23.9K bytes
    - Viewed (0)
  10. cmd/event-notification.go

    }
    
    // NewEventNotifier - creates new event notification object.
    func NewEventNotifier(ctx context.Context) *EventNotifier {
    	// targetList/bucketRulesMap/bucketRemoteTargetRulesMap are populated by NotificationSys.InitBucketTargets()
    	return &EventNotifier{
    		targetList:     event.NewTargetList(ctx),
    		bucketRulesMap: make(map[string]event.RulesMap),
    	}
    }
    
    // GetARNList - returns available ARNs.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 21 22:22:24 UTC 2024
    - 7.7K bytes
    - Viewed (0)
Back to top