Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 141 for Coroutine (0.36 sec)

  1. doc/go_spec.html

    <p>
    The function value and parameters are
    <a href="#Calls">evaluated as usual</a>
    in the calling goroutine, but
    unlike with a regular call, program execution does not wait
    for the invoked function to complete.
    Instead, the function begins executing independently
    in a new goroutine.
    When the function terminates, its goroutine also terminates.
    If the function has any return values, they are discarded when the
    function completes.
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Oct 02 00:58:01 UTC 2024
    - 282.5K bytes
    - Viewed (0)
  2. misc/go_android_exec/main.go

    	// passed on, the hanging adb subprocess will hold them open and
    	// go test will hang forever.
    	//
    	// Avoid that by wrapping stderr, breaking the short circuit and
    	// forcing cmd.Run to use another pipe and goroutine to pass
    	// along stderr from adb.
    	cmd.Stderr = struct{ io.Writer }{os.Stderr}
    	err := cmd.Run()
    
    	// Before we process err, flush any further output and get the exit code.
    	exitCode, err2 := filter.Finish()
    
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Aug 21 17:46:57 UTC 2023
    - 15.3K bytes
    - Viewed (0)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. internal/logger/target/http/http.go

    			retryIntvl = 3 * time.Second
    		}
    
    		maxRetries := h.config.MaxRetry
    
    	retry:
    		// If the channel reaches above half capacity
    		// we spawn more workers. The workers spawned
    		// from this main worker routine will exit
    		// once the channel drops below half capacity
    		// and when it's been at least 30 seconds since
    		// we launched a new worker.
    		if mainWorker && len(h.logCh) > cap(h.logCh)/2 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 11 22:20:42 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  9. src/main/java/jcifs/util/transport/Transport.java

                    this.state = 6;
                    ioe = ioe0;
                }
            case 4: /* failed to connect - reset the transport */
                // thread is cleaned up by connect routine, joining it here causes a deadlock
                this.thread = null;
                this.state = 6;
                break;
            default:
                log.error("Invalid state: " + this.state);
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Nov 01 18:12:21 UTC 2020
    - 24.1K bytes
    - Viewed (0)
  10. src/main/java/jcifs/smb/SmbResourceLocatorImpl.java

            char[] in = this.url.getPath().toCharArray();
            char[] out = new char[in.length];
            int length = in.length, prefixLen = 0, state = 0;
    
            /*
             * The canonicalization routine
             */
            for ( int i = 0; i < length; i++ ) {
                switch ( state ) {
                case 0:
                    if ( in[ i ] != '/' ) {
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sat Jul 20 08:24:53 UTC 2019
    - 23.9K bytes
    - Viewed (0)
Back to top