Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 43 for exit1 (0.55 sec)

  1. platforms/software/dependency-management/src/test/groovy/org/gradle/api/internal/artifacts/configurations/DefaultConfigurationSpec.groovy

            configuration.description = "descript"
            configuration.exclude([group: "value"])
            configuration.exclude([group: "value2"])
            configuration.artifacts.add(artifact("name1", "ext1", "type1", "classifier1"))
            configuration.artifacts.add(artifact("name2", "ext2", "type2", "classifier2"))
    
            if (configuration.roleAtCreation.declarable) {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu May 23 17:30:13 UTC 2024
    - 64.8K bytes
    - Viewed (0)
  2. configure.py

      bazel_executable = which('bazel')
      if bazel_executable is None:
        bazel_executable = which('bazelisk')
        if bazel_executable is None:
          print('Cannot find bazel. Please install bazel/bazelisk.')
          sys.exit(1)
    
      stderr = open(os.devnull, 'wb')
      curr_version = run_shell([bazel_executable, '--version'],
                               allow_non_zero=True,
                               stderr=stderr)
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Mon Jun 10 04:32:44 UTC 2024
    - 53.8K bytes
    - Viewed (1)
  3. cmd/peer-rest-server.go

    	if traceOpts.TraceTypes().Contains(madmin.TraceBootstrap) {
    		go globalBootstrapTracer.Publish(ctx, globalTrace)
    	}
    
    	// Wait for remote to cancel and SubscribeJSON to exit.
    	wg.Wait()
    	return nil
    }
    
    func (s *peerRESTServer) BackgroundHealStatusHandler(_ *grid.MSS) (*grid.JSON[madmin.BgHealState], *grid.RemoteErr) {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 52.1K bytes
    - Viewed (0)
  4. src/net/http/transport.go

    			}
    			if b, ok := req.Body.(*readTrackingBody); ok && !b.didClose {
    				// Issue 49621: Close the request body if pconn.roundTrip
    				// didn't do so already. This can happen if the pconn
    				// write loop exits without reading the write request.
    				req.closeBody()
    			}
    			return nil, err
    		}
    		testHookRoundTripRetried()
    
    		// Rewind the body if we're able to.
    		req, err = rewindBody(req)
    		if err != nil {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Jun 06 21:59:21 UTC 2024
    - 91K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go

    	// We start with usable (write) locked. The below OnReplace function will
    	// unlock it after a successful list. The below defer will then re-lock
    	// it when this function exits (always due to disconnection), only if
    	// we actually got a successful list. This cycle will repeat as needed.
    	successfulList := false
    	c.watchCache.SetOnReplace(func() {
    		successfulList = true
    		c.ready.set(true)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 51.8K bytes
    - Viewed (0)
  6. src/cmd/link/internal/loader/loader.go

    //
    // After each error, the error actions function will be invoked; this
    // will either terminate the link immediately (if -h option given)
    // or it will keep a count and exit if more than 20 errors have been printed.
    //
    // Logging an error means that on exit cmd/link will delete any
    // output file and return a non-zero error code.
    func (reporter *ErrorReporter) Errorf(s Sym, format string, args ...interface{}) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 24 20:26:10 UTC 2024
    - 81.5K bytes
    - Viewed (0)
  7. pkg/kubelet/kuberuntime/kuberuntime_container.go

    		gracePeriod = gracePeriod - m.executePreStopHook(ctx, pod, containerID, containerSpec, gracePeriod)
    	}
    
    	// if we care about termination ordering, then wait for this container's turn to exit if there is
    	// time remaining
    	if ordering != nil && gracePeriod > 0 {
    		// grace period is only in seconds, so the time we've waited gets truncated downward
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 54.7K bytes
    - Viewed (0)
  8. src/cmd/dist/test.go

    // bgCommand returns a go test Cmd and a post-Run flush function. The result
    // will write its output to stdout and stderr. If stdout==stderr, bgCommand
    // ensures Writes are serialized. The caller should call flush() after Cmd exits.
    func (opts *goTest) bgCommand(t *tester, stdout, stderr io.Writer) (cmd *exec.Cmd, flush func()) {
    	build, run, pkgs, testFlags, setupCmd := opts.buildArgs(t)
    
    	// Combine the flags.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon May 20 16:01:35 UTC 2024
    - 50K bytes
    - Viewed (0)
  9. pkg/kubelet/cm/devicemanager/manager_test.go

    					// Such as: `throw("Concurrent map iteration and map writing")`.
    					// When this test ends quietly, no data race error occurs.
    					// Otherwise, the test process exits automatically and prints all goroutine call stacks.
    					test.testfunc(mimpl)
    				}
    			}()
    			wg.Wait()
    		})
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 65K bytes
    - Viewed (0)
  10. src/go/types/api_test.go

    	}
    }
    
    func TestIssue8518(t *testing.T) {
    	fset := token.NewFileSet()
    	imports := make(testImporter)
    	conf := Config{
    		Error:    func(err error) { t.Log(err) }, // don't exit after first error
    		Importer: imports,
    	}
    	makePkg := func(path, src string) {
    		imports[path], _ = conf.Check(path, fset, []*ast.File{mustParse(fset, src)}, nil) // errors logged via conf.Error
    	}
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 94.2K bytes
    - Viewed (0)
Back to top