Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 328 for stop (0.14 sec)

  1. src/main/java/org/codelibs/fess/app/web/api/admin/scheduler/ApiAdminSchedulerAction.java

            return asJson(new ApiResponse().status(Status.OK).result());
        }
    
        // POST /api/admin/scheduler/{id}/stop
        @Execute(urlPattern = "{}/@word")
        public JsonResponse<ApiResult> post$stop(final String id) {
            scheduledJobService.getScheduledJob(id).ifPresent(entity -> {
                try {
                    entity.stop();
                } catch (final Exception e) {
                    logger.warn("Failed to process a request.", e);
    Java
    - Registered: Mon May 06 08:04:11 GMT 2024
    - Last Modified: Thu Feb 22 01:37:57 GMT 2024
    - 7.6K bytes
    - Viewed (0)
  2. cmd/os_unix.go

    	buf := *bufp
    
    	boff := 0 // starting read position in buf
    	nbuf := 0 // end valid data in buf
    
    	for {
    		if boff >= nbuf {
    			boff = 0
    			stop := globalOSMetrics.time(osMetricReadDirent)
    			nbuf, err = syscall.ReadDirent(fd, buf)
    			stop()
    			if err != nil {
    				if isSysErrNotDir(err) {
    					return nil
    				}
    				err = osErrToFileErr(err)
    				if err == errFileNotFound {
    					return nil
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 9.3K bytes
    - Viewed (0)
  3. buildscripts/minio-iam-ldap-upgrade-import-test.sh

    	mc idp ldap policy attach old-minio readwrite --group=CN=project.c,ou=groups,ou=swengg,dc=min,dc=io
    
    	mc idp ldap policy entities old-minio
    
    	mc admin cluster iam export old-minio
    	set +x
    
    	mc admin service stop old-minio
    }
    
    import_iam_content_in_new_minio() {
    	echo "Importing IAM content in new minio instance."
    	# Assume current minio binary exists.
    	MINIO_CI_CD=1 ./minio server /tmp/data/{1...4} &
    	sleep 5
    
    	set -x
    Shell Script
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 15:49:53 GMT 2024
    - 3.4K bytes
    - Viewed (0)
  4. cmd/admin-handlers.go

    // Supports following actions:
    // - restart (restarts all the MinIO instances in a setup)
    // - stop (stops all the MinIO instances in a setup)
    // - freeze (freezes all incoming S3 API calls)
    // - unfreeze (unfreezes previously frozen S3 API calls)
    //
    // This newer API now returns back status per remote peer and local regarding
    // if a "restart/stop" was successful or not. Service signal now supports
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 29 17:39:04 GMT 2024
    - 97.8K bytes
    - Viewed (2)
  5. .github/workflows/arm-ci.yml

          matrix:
            pyver: ['3.10']
        steps:
          - name: Stop old running containers (if any)
            shell: bash
            run: |
              running_containers=$(docker ps -q) && \
              if [[ $running_containers == "" ]]; then
                echo "No running containers";
              else
                echo "Running container(s) found" && \
                docker stop $running_containers;
              fi
              docker container prune -f
    Others
    - Registered: Tue May 07 12:40:20 GMT 2024
    - Last Modified: Wed Feb 07 17:41:21 GMT 2024
    - 2.2K bytes
    - Viewed (0)
  6. cmd/admin-heal-ops.go

    	// for too long.
    	unconsumedTimer := time.NewTimer(healUnconsumedTimeout)
    	defer unconsumedTimer.Stop()
    
    	var itemsLen int
    	for {
    		h.mutex.Lock()
    		itemsLen = len(h.currentStatus.Items)
    		if itemsLen == maxUnconsumedHealResultItems {
    			// wait for a second, or quit if an external
    			// stop signal is received or the
    			// unconsumedTimer fires.
    			select {
    			// Check after a second
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 25.1K bytes
    - Viewed (1)
  7. maven-core/src/main/java/org/apache/maven/bridge/MavenRepositorySystem.java

                        result = true;
                        // don't stop processing in case a future segment explicitly excludes this repo
                    }
                    // check for external:http:*
                    else if (EXTERNAL_HTTP_WILDCARD.equals(repo) && isExternalHttpRepo(originalRepository)) {
                        result = true;
                        // don't stop processing in case a future segment explicitly excludes this repo
    Java
    - Registered: Sun May 05 03:35:11 GMT 2024
    - Last Modified: Sat Feb 17 18:40:11 GMT 2024
    - 32.6K bytes
    - Viewed (0)
  8. cni/pkg/log/uds.go

    		Handler: mux,
    	}
    	l.loggingServer = loggingServer
    	return l
    }
    
    // StartUDSLogServer starts up a UDS server which receives log reported from CNI network plugin.
    func (l *UDSLogger) StartUDSLogServer(sockAddress string, stop <-chan struct{}) error {
    	if sockAddress == "" {
    		return nil
    	}
    	log.Info("Start a UDS server for CNI plugin logs")
    	unixListener, err := uds.NewListener(sockAddress)
    	if err != nil {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed Nov 29 01:05:12 GMT 2023
    - 3.3K bytes
    - Viewed (0)
  9. .github/workflows/arm-ci-extended-cpp.yml

          matrix:
            pyver: ['3.10']
        steps:
          - name: Stop old running containers (if any)
            shell: bash
            run: |
              running_containers=$(docker ps -q) && \
              if [[ $running_containers == "" ]]; then
                echo "No running containers";
              else
                echo "Running container(s) found" && \
                docker stop $running_containers;
              fi
              docker container prune -f
    Others
    - Registered: Tue May 07 12:40:20 GMT 2024
    - Last Modified: Wed Feb 07 17:41:21 GMT 2024
    - 2.5K bytes
    - Viewed (0)
  10. internal/store/store.go

    	keyCh := make(chan Key)
    
    	go func() {
    		defer xioutil.SafeClose(keyCh)
    
    		retryTicker := time.NewTicker(retryInterval)
    		defer retryTicker.Stop()
    
    		for {
    			names, err := store.List()
    			if err != nil {
    				log(context.Background(), fmt.Errorf("store.List() failed with: %w", err), id)
    			} else {
    				keyCount := len(names)
    				for i, name := range names {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Mar 25 16:44:20 GMT 2024
    - 3.5K bytes
    - Viewed (0)
Back to top