Search Options

Results per page
Sort
Preferred Languages
Advance

Results 261 - 270 of 462 for slop (0.05 sec)

  1. doc/godebug.md

    pre-Go 1.24 behavior.
    
    ### Go 1.23
    
    Go 1.23 changed the channels created by package time to be unbuffered
    (synchronous), which makes correct use of the [`Timer.Stop`](/pkg/time/#Timer.Stop)
    and [`Timer.Reset`](/pkg/time/#Timer.Reset) method results much easier.
    The [`asynctimerchan` setting](/pkg/time/#NewTimer) disables this change.
    There are no runtime metrics for this change,
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Oct 28 14:46:33 UTC 2024
    - 17.2K bytes
    - Viewed (0)
  2. istioctl/pkg/dashboard/dashboard.go

    		// Wait for stop
    		fw.WaitForStop()
    
    		return nil
    	}
    
    	return fmt.Errorf("failure running port forward process: %v", err)
    }
    
    func ClosePortForwarderOnInterrupt(fw kube.PortForwarder) {
    	go func() {
    		signals := make(chan os.Signal, 1)
    		signal.Notify(signals, os.Interrupt)
    		defer signal.Stop(signals)
    		<-signals
    		fw.Close()
    	}()
    }
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Apr 15 01:29:35 UTC 2024
    - 20.5K bytes
    - Viewed (0)
  3. cmd/xl-storage-disk-id-check.go

    // Once the disk has been deemed ok, it will return to online status.
    func (p *xlStorageDiskIDCheck) monitorDiskStatus(spent time.Duration, fn string) {
    	t := time.NewTicker(5 * time.Second)
    	defer t.Stop()
    
    	for range t.C {
    		if contextCanceled(p.diskCtx) {
    			return
    		}
    
    		err := p.storage.WriteAll(context.Background(), minioMetaTmpBucket, fn, toWrite)
    		if err != nil {
    			continue
    		}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:56:26 UTC 2024
    - 34.5K bytes
    - Viewed (0)
  4. cmd/erasure-sets.go

    	time.Sleep(time.Duration(r.Float64() * float64(time.Second)))
    
    	// Pre-emptively connect the disks if possible.
    	s.connectDisks(false)
    
    	monitor := time.NewTimer(monitorInterval)
    	defer monitor.Stop()
    
    	for {
    		select {
    		case <-ctx.Done():
    			return
    		case <-monitor.C:
    			if serverDebugLog {
    				console.Debugln("running drive monitoring")
    			}
    
    			s.connectDisks(true)
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 27 10:41:37 UTC 2024
    - 37K bytes
    - Viewed (1)
  5. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Writer.kt

            flags = if (ack) FLAG_ACK else FLAG_NONE,
          )
          sink.writeInt(payload1)
          sink.writeInt(payload2)
          sink.flush()
        }
      }
    
      /**
       * Tell the peer to stop creating streams and that we last processed `lastGoodStreamId`, or zero
       * if no streams were processed.
       *
       * @param lastGoodStreamId the last stream ID processed, or zero if no streams were processed.
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 11.3K bytes
    - Viewed (0)
  6. cni/pkg/install/install_test.go

    				t.Fatal(err)
    			}
    
    			// Listen for isReady to be set to true
    			ticker := time.NewTicker(500 * time.Millisecond)
    			defer ticker.Stop()
    			readyChan := make(chan bool)
    			go func(ctx context.Context, tick <-chan time.Time) {
    				for {
    					select {
    					case <-ctx.Done():
    						return
    					case <-tick:
    						if isReady.Load().(bool) {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jan 26 20:34:28 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  7. cni/pkg/nodeagent/net.go

    		netnsRunner:        NetnsDo,
    	}
    }
    
    func (s *NetServer) Start(ctx context.Context) {
    	log.Debug("starting ztunnel server")
    	go s.ztunnelServer.Run(ctx)
    }
    
    func (s *NetServer) Stop() {
    	log.Debug("stopping ztunnel server")
    	s.ztunnelServer.Close()
    }
    
    func (s *NetServer) rescanPod(pod *corev1.Pod) error {
    	// this can happen if the pod was dynamically added to the mesh after it was created.
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Oct 21 16:48:55 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  8. fess-crawler/src/test/java/org/codelibs/fess/crawler/client/storage/StorageClientTest.java

                    SetObjectTagsArgs.builder().bucket(bucketName).object("dir3/file4.txt").tags(Map.of("label", "label4")).build());
        }
    
        @Override
        protected void tearDown() throws Exception {
            minioServer.stop();
            super.tearDown();
        }
    
        public void test_doGet() throws Exception {
            try (final ResponseData responseData = storageClient.doGet("storage://fess/file1.txt")) {
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:36:27 UTC 2024
    - 13.5K bytes
    - Viewed (0)
  9. compat/maven-embedder/src/main/java/org/apache/maven/cli/props/MavenProperties.java

         * is that in JavaScript, a single quote must be escaped.</p>
         *
         * <p>Example:</p>
         * <pre>
         * input string: He didn't say, "Stop!"
         * output string: He didn't say, \"Stop!\"
         * </pre>
         *
         *
         * @param str  String to escape values in, may be null
         * @return String with escaped values, <code>null</code> if null string input
         */
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 38.2K bytes
    - Viewed (0)
  10. okhttp/src/main/kotlin/okhttp3/internal/connection/RealRoutePlanner.kt

       * this address.
       *
       * If [planToReplace] is non-null, this will swap it for a pooled connection if that pooled
       * connection uses HTTP/2. That results in fewer sockets overall and thus fewer TCP slow starts.
       */
      internal fun planReusePooledConnection(
        planToReplace: ConnectPlan? = null,
        routes: List<Route>? = null,
      ): ReusePlan? {
        val result =
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 12K bytes
    - Viewed (0)
Back to top