Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 47 of 47 for goroutines (0.13 sec)

  1. src/crypto/tls/handshake_client_test.go

    				<-stdout.handshakeComplete
    			}
    
    			// OpenSSL will try to interleave application data and
    			// a renegotiation if we send both concurrently.
    			// Therefore: ask OpensSSL to start a renegotiation, run
    			// a goroutine to call client.Read and thus process the
    			// renegotiation request, watch for OpenSSL's stdout to
    			// indicate that the handshake is complete and,
    			// finally, have OpenSSL write something to cause
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 03:10:12 UTC 2024
    - 88.7K bytes
    - Viewed (0)
  2. pkg/controller/job/job_controller.go

    	jm.updateStatusHandler = jm.updateJobStatus
    	jm.patchJobHandler = jm.patchJob
    	jm.syncHandler = jm.syncJob
    
    	metrics.Register()
    
    	return jm, nil
    }
    
    // Run the main goroutine responsible for watching and syncing jobs.
    func (jm *Controller) Run(ctx context.Context, workers int) {
    	defer utilruntime.HandleCrash()
    	logger := klog.FromContext(ctx)
    
    	// Start events processing pipeline.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jun 10 23:56:37 UTC 2024
    - 77.6K bytes
    - Viewed (0)
  3. cmd/iam-store.go

    	}
    	c.updatedAt = time.Now()
    	return nil
    }
    
    // IAMStorageAPI defines an interface for the IAM persistence layer
    type IAMStorageAPI interface {
    	// The role of the read-write lock is to prevent go routines from
    	// concurrently reading and writing the IAM storage. The (r)lock()
    	// functions return the iamCache. The cache can be safely written to
    	// only when returned by `lock()`.
    	lock() *iamCache
    	unlock()
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Jun 13 22:26:38 UTC 2024
    - 75.8K bytes
    - Viewed (0)
  4. cmd/erasure-object.go

    			if onlineDisks[index] == nil {
    				return errDiskNotFound
    			}
    			return onlineDisks[index].UpdateMetadata(ctx, bucket, object, fi, opts)
    		}, index)
    	}
    
    	// Wait for all the routines.
    	mErrs := g.Wait()
    
    	return reduceWriteQuorumErrs(ctx, mErrs, objectOpIgnoredErrs, fi.WriteQuorum(er.defaultWQuorum()))
    }
    
    // updateObjectMeta will update the metadata of a file.
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 78.6K bytes
    - Viewed (0)
  5. src/cmd/link/internal/loader/loader.go

    // has a linkname (push).
    // If a name is in this map, it is allowed only in listed packages,
    // even if it has a linknamed definition.
    var blockedLinknames = map[string][]string{
    	// coroutines
    	"runtime.coroswitch": {"iter"},
    	"runtime.newcoro":    {"iter"},
    	// weak references
    	"internal/weak.runtime_registerWeakPointer": {"internal/weak"},
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 24 20:26:10 UTC 2024
    - 81.5K bytes
    - Viewed (0)
  6. src/cmd/link/internal/ld/lib.go

    					ctxt.loader.SymName(froms[0]), froms[0])
    			}
    		}
    	}
    	// If needed, create the __CTOR_LIST__ and __DTOR_LIST__
    	// symbols (referenced by some of the mingw support library
    	// routines). Creation of these symbols is normally done by the
    	// linker if not already present.
    	want := []string{"__CTOR_LIST__", "__DTOR_LIST__"}
    	isunresolved := symbolsAreUnresolved(ctxt, want)
    	for k, w := range want {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue May 21 18:45:27 UTC 2024
    - 88.6K bytes
    - Viewed (0)
  7. src/cmd/vendor/github.com/ianlancetaylor/demangle/demangle.go

    	}
    }
    
    // The doDemangle function is the entry point into the demangler proper.
    func doDemangle(name string, options ...Option) (ret AST, err error) {
    	// When the demangling routines encounter an error, they panic
    	// with a value of type demangleErr.
    	defer func() {
    		if r := recover(); r != nil {
    			if de, ok := r.(demangleErr); ok {
    				ret = nil
    				err = de
    				return
    			}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 31 19:48:28 UTC 2024
    - 94.1K bytes
    - Viewed (0)
Back to top