Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 4,303 for starts (0.37 sec)

  1. pilot/cmd/pilot-agent/status/testserver/server.go

    	for k, v := range handlers {
    		mux.HandleFunc(k, http.HandlerFunc(v))
    	}
    
    	// Start a local HTTP server
    	server := httptest.NewUnstartedServer(mux)
    
    	l, err := net.Listen("tcp", ":0")
    	if err != nil {
    		panic("Could not create listener for test: " + err.Error())
    	}
    	server.Listener = l
    	server.Start()
    	return server
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jan 26 17:53:14 UTC 2022
    - 1.7K bytes
    - Viewed (0)
  2. src/net/http/httptest/server.go

    	// NewUnstartedServer and calling Server.StartTLS.
    	EnableHTTP2 bool
    
    	// TLS is the optional TLS configuration, populated with a new config
    	// after TLS is started. If set on an unstarted server before StartTLS
    	// is called, existing fields are copied into the new config.
    	TLS *tls.Config
    
    	// Config may be changed after calling NewUnstartedServer and
    	// before Start or StartTLS.
    	Config *http.Server
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 10 17:26:10 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  3. platforms/core-runtime/process-services/src/main/java/org/gradle/process/internal/StreamsHandler.java

        /**
         * Collects whatever state is required the given process. Should not start work.
         */
        void connectStreams(Process process, String processName, Executor executor);
    
        /**
         * Starts reading/writing/whatever the process' streams. May block until the streams reach some particular state, e.g. indicate that the process has started successfully.
         */
        void start();
    
        /**
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Sep 22 09:10:02 UTC 2023
    - 1.6K bytes
    - Viewed (0)
  4. src/cmd/go/internal/trace/trace.go

    // other packages.
    type traceKey struct{}
    
    type traceContext struct {
    	t   *tracer
    	tid uint64
    }
    
    // Start starts a trace which writes to the given file.
    func Start(ctx context.Context, file string) (context.Context, func() error, error) {
    	traceStarted.Store(true)
    	if file == "" {
    		return nil, nil, errors.New("no trace file supplied")
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Nov 21 20:45:06 UTC 2023
    - 4.7K bytes
    - Viewed (0)
  5. platforms/core-runtime/base-services/src/main/java/org/gradle/internal/work/WorkerThreadRegistry.java

         */
        void runAsUnmanagedWorkerThread(Runnable action);
    
        /**
         * Starts a new lease for the current thread. Marks the reservation of a lease. Blocks until a lease is available.
         *
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Mar 12 02:21:10 UTC 2024
    - 3.6K bytes
    - Viewed (0)
  6. cmd/service.go

    var GlobalContext, cancelGlobalContext = context.WithCancel(context.Background())
    
    // restartProcess starts a new process passing it the active fd's. It
    // doesn't fork, but starts a new process using the same environment and
    // arguments as when it was originally started. This allows for a newly
    // deployed binary to be started. It returns the pid of the newly started
    // process when successful.
    func restartProcess() error {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Wed Feb 28 07:02:14 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apimachinery/pkg/util/wait/backoff.go

    // factor, with sliding = false (meaning the timer for period starts at the same
    // time as the function starts).
    func NonSlidingUntil(f func(), period time.Duration, stopCh <-chan struct{}) {
    	JitterUntil(f, period, 0.0, false, stopCh)
    }
    
    // NonSlidingUntilWithContext loops until context is done, running f every
    // period.
    //
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 14 19:14:11 UTC 2023
    - 16.5K bytes
    - Viewed (0)
  8. platforms/core-execution/execution/src/main/java/org/gradle/internal/execution/timeout/TimeoutHandler.java

        /**
         * Starts a timeout for the given thread. The thread is interrupted if the given timeout is exceeded.
         * The returned {@link Timeout} object must be used to stop the timeout once the thread has completed
         * the work that this timeout was supposed to limit, otherwise it may be interrupted doing
         * some other work later.
         */
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Sep 22 09:46:15 UTC 2023
    - 1.6K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/base/Stopwatch.java

        return new Stopwatch(ticker);
      }
    
      /**
       * Creates (and starts) a new stopwatch using {@link System#nanoTime} as its time source.
       *
       * @since 15.0
       */
      public static Stopwatch createStarted() {
        return new Stopwatch().start();
      }
    
      /**
       * Creates (and starts) a new stopwatch, using the specified time source.
       *
       * @since 15.0
       */
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Nov 15 21:38:09 UTC 2022
    - 8.5K bytes
    - Viewed (0)
  10. dbflute_fess/dfprop/commonColumnMap.dfprop

    #     ; beforeUpdateMap = map:{
    #         ; UPDATE_DATETIME   = $$AccessContext$$.getAccessLocalDateTimeOnThread()
    #         ; UPDATE_USER       = $$AccessContext$$.getAccessUserOnThread()
    #     }
    # }
    #
    # *The line that starts with '#' means comment-out.
    #
    map:{
        #; commonColumnMap = map:{
        #    ; REGISTER_DATETIME=TIMESTAMP ; REGISTER_USER=VARCHAR
        #    ; UPDATE_DATETIME=TIMESTAMP   ; UPDATE_USER=VARCHAR
        #}
    Registered: Wed Jun 12 13:08:18 UTC 2024
    - Last Modified: Sat Jul 04 22:46:31 UTC 2015
    - 1.9K bytes
    - Viewed (0)
Back to top