Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 21 - 30 of 407 for stopfn (0.04 seconds)

  1. android/guava/src/com/google/common/base/Stopwatch.java

        startTick = ticker.read();
        return this;
      }
    
      /**
       * Stops the stopwatch. Future reads will return the fixed duration that had elapsed up to this
       * point.
       *
       * @return this {@code Stopwatch} instance
       * @throws IllegalStateException if the stopwatch is already stopped.
       */
      @CanIgnoreReturnValue
      public Stopwatch stop() {
        long tick = ticker.read();
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Oct 08 18:55:33 GMT 2025
    - 9.5K bytes
    - Click Count (0)
  2. internal/event/target/elasticsearch.go

    }
    
    // Close - does nothing and available for interface compatibility.
    func (target *ElasticsearchTarget) Close() error {
    	close(target.quitCh)
    	if target.client != nil {
    		// Stops the background processes that the client is running.
    		target.client.stop()
    	}
    	return nil
    }
    
    func (target *ElasticsearchTarget) checkAndInitClient(ctx context.Context) error {
    	if target.client != nil {
    		return nil
    	}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 15K bytes
    - Click Count (0)
  3. src/main/java/jcifs/internal/witness/WitnessClient.java

                }
            }, scheduler);
    
            asyncNotifyTasks.put(registrationId, asyncTask);
            log.debug("Started async notification monitoring for {}", registrationId);
        }
    
        /**
         * Stops asynchronous notification monitoring for a registration.
         *
         * @param registrationId the registration ID
         */
        private void stopAsyncNotificationMonitoring(String registrationId) {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 20.8K bytes
    - Click Count (0)
  4. src/main/java/org/codelibs/fess/helper/DataIndexHelper.java

                return finished;
            }
    
            /**
             * Stops the crawling operation gracefully.
             * If a data store is currently active, this method calls
             * its stop method to halt the crawling process.
             */
            public void stopCrawling() {
                if (dataStore != null) {
                    dataStore.stop();
                }
            }
    
            /**
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Nov 28 16:29:12 GMT 2025
    - 19K bytes
    - Click Count (0)
  5. src/main/java/org/codelibs/fess/indexer/IndexUpdater.java

            }
        }
    
        /**
         * Forces all crawlers to stop immediately.
         * Sets the force stop flag and stops all active crawler instances.
         */
        private void forceStop() {
            systemHelper.setForceStop(true);
            if (crawlerList != null) {
                for (final Crawler crawler : crawlerList) {
                    crawler.stop();
                }
            }
        }
    
        /**
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Nov 28 16:29:12 GMT 2025
    - 32.9K bytes
    - Click Count (0)
  6. src/main/java/org/codelibs/fess/app/web/admin/scheduler/AdminSchedulerAction.java

            });
            return redirect(getClass());
        }
    
        /**
         * Stops a running scheduled job.
         *
         * @param form the edit form containing the ID of the job to stop
         * @return HTML response redirecting to the list page after stopping
         */
        @Execute
        @Secured({ ROLE })
        public HtmlResponse stop(final EditForm form) {
            verifyCrudMode(form.crudMode, CrudMode.DETAILS, this::asListHtml);
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Nov 20 13:56:35 GMT 2025
    - 21.8K bytes
    - Click Count (0)
  7. src/builtin/builtin.go

    //
    //	x, ok := <-c
    //
    // will also set ok to false for a closed and empty channel.
    func close(c chan<- Type)
    
    // The panic built-in function stops normal execution of the current
    // goroutine. When a function F calls panic, normal execution of F stops
    // immediately. Any functions whose execution was deferred by F are run in
    // the usual way, and then F returns to its caller. To the caller G, the
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Thu Feb 26 17:14:40 GMT 2026
    - 13.2K bytes
    - Click Count (0)
  8. cmd/admin-heal-ops.go

    	defer h.mutex.RUnlock()
    	// background heal never ends
    	if h.clientToken == bgHealingUUID {
    		return false
    	}
    	return !h.endTime.IsZero()
    }
    
    // stops the heal sequence - safe to call multiple times.
    func (h *healSequence) stop() {
    	h.cancelCtx()
    }
    
    // pushHealResultItem - pushes a heal result item for consumption in
    // the heal-status API. It blocks if there are
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 25.4K bytes
    - Click Count (0)
  9. cmd/erasure-server-pool-rebalance_gen.go

    			return
    		}
    		switch msgp.UnsafeString(field) {
    		case "startTs":
    			z.StartTime, err = dc.ReadTime()
    			if err != nil {
    				err = msgp.WrapError(err, "StartTime")
    				return
    			}
    		case "stopTs":
    			z.EndTime, err = dc.ReadTime()
    			if err != nil {
    				err = msgp.WrapError(err, "EndTime")
    				return
    			}
    		case "status":
    			{
    				var zb0002 uint8
    				zb0002, err = dc.ReadUint8()
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 26.8K bytes
    - Click Count (0)
  10. docs/en/docs/deployment/docker.md

    But it's not possible to have a running container without **at least one running process**. If the main process stops, the container stops.
    
    ## Build a Docker Image for FastAPI { #build-a-docker-image-for-fastapi }
    
    Okay, let's build something now! 🚀
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 05 18:13:19 GMT 2026
    - 28.3K bytes
    - Click Count (1)
Back to Top