Search Options

Results per page
Sort
Preferred Languages
Advance

Results 111 - 120 of 141 for goroutine (0.09 sec)

  1. CHANGELOG/CHANGELOG-1.11.md

    * MAC Address filter has been fixed in vSphere Cloud Provider, it no longer ignores `00:1c:14` and `00:05:69` prefixes ([#73721](https://github.com/kubernetes/kubernetes/pull/73721), [@frapposelli](https://github.com/frapposelli))
    * add goroutine to move unschedulable pods to activeq if they are not retried for more than 1 minute ([#72558](https://github.com/kubernetes/kubernetes/pull/72558), [@denkensk](https://github.com/denkensk))
    Registered: Fri Nov 01 09:05:11 UTC 2024
    - Last Modified: Thu Feb 06 06:04:15 UTC 2020
    - 328.4K bytes
    - Viewed (0)
  2. fastapi/routing.py

    import email.message
    import inspect
    import json
    from contextlib import AsyncExitStack, asynccontextmanager
    from enum import Enum, IntEnum
    from typing import (
        Any,
        AsyncIterator,
        Callable,
        Coroutine,
        Dict,
        List,
        Mapping,
        Optional,
        Sequence,
        Set,
        Tuple,
        Type,
        Union,
    )
    
    from fastapi import params
    from fastapi._compat import (
        ModelField,
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sat Oct 12 09:44:57 UTC 2024
    - 172.1K bytes
    - Viewed (0)
  3. internal/logger/logger.go

    	sendLog(ctx, entry)
    }
    
    // ErrCritical is the value panic'd whenever CriticalIf is called.
    var ErrCritical struct{}
    
    // CriticalIf logs the provided error on the console. It fails the
    // current go-routine by causing a `panic(ErrCritical)`.
    func CriticalIf(ctx context.Context, err error, errKind ...interface{}) {
    	if err != nil {
    		LogIf(ctx, "", err, errKind...)
    		panic(ErrCritical)
    	}
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 22 09:43:48 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  4. cmd/common-main.go

    // Cancellation/timeouts are removed, so parent cancellations/timeout will
    // not propagate from parent.
    // Context values are preserved.
    // This can be used for goroutines that live beyond the parent context.
    func bgContext(parent context.Context) context.Context {
    	return bgCtx{parent: parent}
    }
    
    type bgCtx struct {
    	parent context.Context
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 21:50:11 UTC 2024
    - 31.7K bytes
    - Viewed (0)
  5. CHANGELOG/CHANGELOG-1.23.md

    ### Bug or Regression
    
    - Bump sigs.k8s.io/apiserver-network-proxy/konnectivity-client to v0.0.30, fixing goroutine leaks in kube-apiserver. ([#108438](https://github.com/kubernetes/kubernetes/pull/108438), [@andrewsykim](https://github.com/andrewsykim)) [SIG API Machinery, Auth and Cloud Provider]
    Registered: Fri Nov 01 09:05:11 UTC 2024
    - Last Modified: Tue Feb 28 21:06:52 UTC 2023
    - 424.5K bytes
    - Viewed (0)
  6. src/main/java/jcifs/smb1/netbios/NameServiceClient.java

                throw new UnknownHostException( name.name );
            }
    
            /* If a target address to query was not specified explicitly
             * with the addr parameter we fall into this resolveOrder routine.
             */
    
            for( int i = 0; i < resolveOrder.length; i++ ) {
                try {
                    switch( resolveOrder[i] ) {
                        case RESOLVER_LMHOSTS:
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 20:39:42 UTC 2019
    - 17.4K bytes
    - Viewed (0)
  7. cmd/erasure-sets.go

    				nsMutex:            mutex,
    			}
    		}(i)
    	}
    
    	wg.Wait()
    
    	// start cleanup stale uploads go-routine.
    	go s.cleanupStaleUploads(ctx)
    
    	// start cleanup of deleted objects.
    	go s.cleanupDeletedObjects(ctx)
    
    	// Start the disk monitoring and connect routine.
    	if !globalIsTesting {
    		go s.monitorAndConnectEndpoints(ctx, defaultMonitorConnectEndpointInterval)
    	}
    
    	return s, nil
    }
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 27 10:41:37 UTC 2024
    - 37K bytes
    - Viewed (1)
  8. CHANGELOG/CHANGELOG-1.22.md

    ### Bug or Regression
    
    - Bump sigs.k8s.io/apiserver-network-proxy/konnectivity-client to v0.0.30, fixing goroutine leaks in kube-apiserver. ([#108439](https://github.com/kubernetes/kubernetes/pull/108439), [@andrewsykim](https://github.com/andrewsykim)) [SIG API Machinery, Auth and Cloud Provider]
    Registered: Fri Nov 01 09:05:11 UTC 2024
    - Last Modified: Tue Dec 13 12:43:45 UTC 2022
    - 454.1K bytes
    - Viewed (0)
  9. cmd/iam-etcd-store.go

    		err = errNoSuchGroup
    	}
    	return err
    }
    
    func (ies *IAMEtcdStore) watch(ctx context.Context, keyPath string) <-chan iamWatchEvent {
    	ch := make(chan iamWatchEvent)
    
    	// go routine to read events from the etcd watch channel and send them
    	// down `ch`
    	go func() {
    		for {
    		outerLoop:
    			watchCh := ies.client.Watch(ctx,
    				keyPath, etcd.WithPrefix(), etcd.WithKeysOnly())
    
    			for {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 01:29:20 UTC 2024
    - 14K bytes
    - Viewed (0)
  10. src/main/java/jcifs/netbios/NameServiceClientImpl.java

                throw new UnknownHostException(name.name);
            }
    
            /*
             * If a target address to query was not specified explicitly
             * with the addr parameter we fall into this resolveOrder routine.
             */
    
            for ( ResolverType resolverType : this.resolveOrder ) {
                try {
                    switch ( resolverType ) {
                    case RESOLVER_LMHOSTS:
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Aug 14 14:26:22 UTC 2022
    - 38.2K bytes
    - Viewed (0)
Back to top