Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 321 - 330 of 504 for runnable (0.05 seconds)

  1. build-tools-internal/src/main/java/org/elasticsearch/gradle/internal/precommit/FilePermissionsTask.java

                    || permissions.contains(PosixFilePermission.OWNER_EXECUTE)
                    || permissions.contains(PosixFilePermission.GROUP_EXECUTE);
            } catch (IOException e) {
                throw new IllegalStateException("unable to read the file " + file + " attributes", e);
            }
        }
    
        /**
         * Returns the files this task will check
         */
        @InputFiles
        @SkipWhenEmpty
        public FileCollection getFiles() {
    Created: Wed Apr 08 16:19:15 GMT 2026
    - Last Modified: Tue Jun 01 09:19:30 GMT 2021
    - 3.9K bytes
    - Click Count (0)
  2. cmd/callhome.go

    				auditOptions := AuditLogOptions{Event: "callhome:diagnostics"}
    				// Received all data. Send to SUBNET and return
    				err := sendHealthInfo(ctx, healthInfo)
    				if err != nil {
    					internalLogIf(ctx, fmt.Errorf("Unable to perform callhome: %w", err))
    					auditOptions.Error = err.Error()
    				}
    				auditLogInternal(ctx, auditOptions)
    				return
    			}
    			healthInfo = hi
    		case <-healthCtx.Done():
    			return
    		}
    	}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 5.3K bytes
    - Click Count (0)
  3. internal/logger/target/http/http.go

    	queueStore := store.NewQueueStore[any](
    		filepath.Join(h.config.QueueDir, h.Name()),
    		uint64(h.config.QueueSize),
    		httpLoggerExtension,
    	)
    
    	if err := queueStore.Open(); err != nil {
    		return fmt.Errorf("unable to initialize the queue store of %s webhook: %w", h.Name(), err)
    	}
    
    	h.store = queueStore
    	store.StreamItems(h.store, h, ctx.Done(), h.config.LogOnceIf)
    
    	return nil
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 15.6K bytes
    - Click Count (0)
  4. okhttp/src/androidMain/kotlin/okhttp3/internal/platform/android/StandardAndroidSocketAdapter.kt

          } catch (e: Exception) {
            AndroidLog.androidLog(
              loggerName = OkHttpClient::class.java.name,
              logLevel = Platform.WARN,
              message = "unable to load android socket classes",
              t = e,
            )
            null
          }
      }
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sat Jan 10 09:36:53 GMT 2026
    - 2.8K bytes
    - Click Count (0)
  5. compat/maven-compat/src/main/java/org/apache/maven/repository/legacy/resolver/transform/LatestArtifactTransformation.java

                try {
                    String version = resolveVersion(artifact, request);
                    if (Artifact.LATEST_VERSION.equals(version)) {
                        throw new ArtifactNotFoundException("Unable to determine the latest version", artifact);
                    }
    
                    artifact.setBaseVersion(version);
                    artifact.updateVersion(version, request.getLocalRepository());
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Fri Jun 06 14:28:57 GMT 2025
    - 2.9K bytes
    - Click Count (0)
  6. okhttp/src/androidMain/kotlin/okhttp3/internal/platform/Android10Platform.kt

        }
    
      override fun logCloseableLeak(
        message: String,
        stackTrace: Any?,
      ) {
        if (Build.VERSION.SDK_INT >= 30) {
          (stackTrace as CloseGuard).warnIfOpen()
        } else {
          // Unable to report via CloseGuard. As a last-ditch effort, send it to the logger.
          super.logCloseableLeak(message, stackTrace)
        }
      }
    
      @SuppressLint("NewApi")
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Jul 20 11:25:50 GMT 2025
    - 4.5K bytes
    - Click Count (0)
  7. cmd/utils.go

    		}
    	case madmin.ProfilerCPUIO:
    		// at 10k or more goroutines fgprof is likely to become
    		// unable to maintain its sampling rate and to significantly
    		// degrade the performance of your application
    		// https://github.com/felixge/fgprof#fgprof
    		if n := runtime.NumGoroutine(); n > 10000 && !globalIsCICD {
    			return nil, fmt.Errorf("unable to perform CPU IO profile with %d goroutines", n)
    		}
    		dirPath, err := os.MkdirTemp("", "profile")
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 33K bytes
    - Click Count (0)
  8. guava-tests/test/com/google/common/io/IoTestCase.java

        if (testDir != null) {
          return testDir;
        }
    
        URL testFileUrl = IoTestCase.class.getResource("testdata/i18n.txt");
        if (testFileUrl == null) {
          throw new RuntimeException("unable to locate testdata directory");
        }
    
        if (testFileUrl.getProtocol().equals("file")) {
          try {
            File testFile = new File(testFileUrl.toURI());
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 5.6K bytes
    - Click Count (0)
  9. impl/maven-core/src/main/java/org/apache/maven/execution/DefaultBuildResumptionDataRepository.java

                return properties;
            }
    
            try (Reader reader = Files.newBufferedReader(path)) {
                properties.load(reader);
            } catch (IOException e) {
                LOGGER.warn("Unable to read {}. The --resume / -r feature will not work.", path);
            }
    
            return properties;
        }
    
        // This method is made package-private for testing purposes
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Tue Feb 11 16:38:19 GMT 2025
    - 4.9K bytes
    - Click Count (0)
  10. docs/sts/assume-role.go

    	stsOpts.AccessKey = minioUsername
    	stsOpts.SecretKey = minioPassword
    
    	if sessionPolicyFile != "" {
    		var policy string
    		if f, err := os.Open(sessionPolicyFile); err != nil {
    			log.Fatalf("Unable to open session policy file: %v", err)
    		} else {
    			defer f.Close()
    			bs, err := io.ReadAll(f)
    			if err != nil {
    				log.Fatalf("Error reading session policy file: %v", err)
    			}
    			policy = string(bs)
    		}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sat Aug 17 01:24:54 GMT 2024
    - 4.4K bytes
    - Click Count (1)
Back to Top