Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 480 for pollable (0.49 sec)

  1. src/internal/poll/fd_unix.go

    // The net argument is a network name from the net package (e.g., "tcp"),
    // or "file".
    // Set pollable to true if fd should be managed by runtime netpoll.
    func (fd *FD) Init(net string, pollable bool) error {
    	fd.SysFile.init()
    
    	// We don't actually care about the various network types.
    	if net == "file" {
    		fd.isFile = true
    	}
    	if !pollable {
    		fd.isBlocking = 1
    		return nil
    	}
    	err := fd.pd.init(fd)
    	if err != nil {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 31 04:09:44 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  2. src/os/file_unix.go

    				pollable = false
    			}
    
    			// In addition to the behavior described above for regular files,
    			// on Darwin, kqueue does not work properly with fifos:
    			// closing the last writer does not cause a kqueue event
    			// for any readers. See issue #24164.
    			if (runtime.GOOS == "darwin" || runtime.GOOS == "ios") && typ == syscall.S_IFIFO {
    				pollable = false
    			}
    		}
    	}
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 13:52:34 UTC 2024
    - 14.9K bytes
    - Viewed (0)
  3. src/cmd/vendor/golang.org/x/sys/unix/zerrors_zos_s390x.go

    	num  Signal
    	name string
    	desc string
    }{
    	{1, "SIGHUP", "hangup"},
    	{2, "SIGINT", "interrupt"},
    	{3, "SIGABT", "aborted"},
    	{4, "SIGILL", "illegal instruction"},
    	{5, "SIGPOLL", "pollable event"},
    	{6, "SIGURG", "urgent I/O condition"},
    	{7, "SIGSTOP", "stop process"},
    	{8, "SIGFPE", "floating point exception"},
    	{9, "SIGKILL", "killed"},
    	{10, "SIGBUS", "bus error"},
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 08 16:12:58 UTC 2024
    - 39.4K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java

        final SettableFuture<@Nullable Void> settableFuture = SettableFuture.create();
        ArrayList<ListenableFuture<@Nullable Void>> results = new ArrayList<>(50_001);
        results.add(
            serializer.submitAsync(
                new AsyncCallable<@Nullable Void>() {
                  @Override
                  public ListenableFuture<@Nullable Void> call() {
                    return settableFuture;
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Feb 13 14:28:25 UTC 2024
    - 16.8K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java

        final SettableFuture<@Nullable Void> settableFuture = SettableFuture.create();
        ArrayList<ListenableFuture<@Nullable Void>> results = new ArrayList<>(50_001);
        results.add(
            serializer.submitAsync(
                new AsyncCallable<@Nullable Void>() {
                  @Override
                  public ListenableFuture<@Nullable Void> call() {
                    return settableFuture;
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Feb 13 14:28:25 UTC 2024
    - 16.8K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

        Callable<@Nullable Void> cancelRunnable =
            new Callable<@Nullable Void>() {
              @Override
              public @Nullable Void call() {
                cancellationSuccess.set(currentFuture.get().cancel(true));
                awaitUnchecked(barrier);
                return null;
              }
            };
        Callable<@Nullable Void> setFutureCompleteSuccessfullyRunnable =
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Jun 11 16:13:05 UTC 2024
    - 46.7K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

        Callable<@Nullable Void> cancelRunnable =
            new Callable<@Nullable Void>() {
              @Override
              public @Nullable Void call() {
                cancellationSuccess.set(currentFuture.get().cancel(true));
                awaitUnchecked(barrier);
                return null;
              }
            };
        Callable<@Nullable Void> setFutureCompleteSuccessfullyRunnable =
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Jun 11 16:13:05 UTC 2024
    - 46.7K bytes
    - Viewed (0)
  8. platforms/software/signing/src/main/java/org/gradle/plugins/signing/Signature.java

        /**
         * The date of the signature artifact.
         *
         * @see #getDate()
         */
        private Date date;
    
        private Callable<File> toSignGenerator;
    
        private Callable<String> classifierGenerator;
    
        @Nullable
        private Callable<String> nameGenerator;
    
        /**
         * Creates a signature artifact for the given public artifact.
         *
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Apr 11 12:20:43 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  9. platforms/core-configuration/model-core/src/main/java/org/gradle/api/internal/tasks/DefaultTaskDependency.java

        }
    
        public DefaultTaskDependency(
            @Nullable TaskResolver resolver,
            @Nullable TaskDependencyUsageTracker taskDependencyUsageTracker
        ) {
            this(resolver, ImmutableSet.of(), taskDependencyUsageTracker);
        }
    
        public DefaultTaskDependency(
            @Nullable TaskResolver resolver,
            ImmutableSet<Object> immutableValues,
            @Nullable TaskDependencyUsageTracker taskDependencyUsageTracker
        ) {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Apr 11 12:20:43 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  10. platforms/core-runtime/logging/src/main/java/org/gradle/util/GUtil.java

        }
    
        /**
         * Calls the given callable converting any thrown exception to an unchecked exception via {@link UncheckedException#throwAsUncheckedException(Throwable)}
         *
         * @param callable The callable to call
         * @param <T> Callable's return type
         * @return The value returned by {@link Callable#call()}
         */
        @Nullable
        public static <T> T uncheckedCall(Callable<T> callable) {
            try {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue May 28 13:09:37 UTC 2024
    - 21.3K bytes
    - Viewed (0)
Back to top