Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 304 for striped (0.1 sec)

  1. platforms/ide/tooling-api/src/main/java/org/gradle/tooling/internal/consumer/async/ServiceLifecycle.java

                    case STOPPING:
                        throw new IllegalStateException(String.format("Cannot use %s as it is currently stopping.", displayName));
                    case STOPPED:
                        throw new IllegalStateException(String.format("Cannot use %s as it has been stopped.", displayName));
                }
                Integer depth = usages.get(Thread.currentThread());
                if (depth == null) {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Apr 11 19:07:55 UTC 2024
    - 4K bytes
    - Viewed (0)
  2. platforms/core-runtime/messaging/src/main/java/org/gradle/internal/dispatch/AsyncDispatch.java

                if (interrupted) {
                    Thread.currentThread().interrupt();
                }
                if (state == State.Stopped) {
                    throw new IllegalStateException("Cannot dispatch message, as this message dispatch has been stopped. Message: " + message);
                }
                queue.add(message);
                condition.signalAll();
            } finally {
                lock.unlock();
            }
        }
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon Dec 11 13:37:56 UTC 2023
    - 6.7K bytes
    - Viewed (0)
  3. platforms/core-runtime/messaging/src/main/java/org/gradle/internal/actor/internal/DefaultActorFactory.java

                synchronized (lock) {
                    stopped = true;
                }
                stopped(this);
            }
    
            @Override
            public void dispatch(MethodInvocation message) {
                synchronized (lock) {
                    if (stopped) {
                        throw new IllegalStateException("This actor has been stopped.");
                    }
                    dispatch.dispatch(message);
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue May 28 13:09:37 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  4. src/runtime/lockrank_on.go

    //
    //go:nosplit
    func worldStarted() {
    	if stopped := worldIsStopped.Add(-1); stopped != 0 {
    		systemstack(func() {
    			print("world stop count=", stopped, "\n")
    			throw("released non-stopped world stop")
    		})
    	}
    }
    
    // nosplit to ensure it can be called in as many contexts as possible.
    //
    //go:nosplit
    func checkWorldStopped() bool {
    	stopped := worldIsStopped.Load()
    	if stopped > 1 {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Apr 22 14:29:04 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  5. platforms/ide/ide-native/src/integTest/groovy/org/gradle/ide/visualstudio/AbstractVisualStudioProjectIntegrationTest.groovy

        List<String> getExpectedBaseIncludePaths() {
            return ["src/main/headers"]
        }
    
        protected String stripped(String configurationName) {
            if (toolChain.visualCpp) {
                return ""
            } else {
                return configurationName.startsWith("release") ? "stripped/" : ""
            }
        }
    
        protected String getCurrentHostOperatingSystemFamilyDsl() {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Sep 26 14:49:12 UTC 2023
    - 14.7K bytes
    - Viewed (0)
  6. platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/DaemonStopState.java

    package org.gradle.launcher.daemon.server;
    
    /**
     * Indicates the state of the daemon when it stops doing work.
     */
    public enum DaemonStopState {
        /**
         * Daemon was stopped cleanly and all work stopped.
         */
        Clean,
        /**
         * Daemon could not be stopped cleanly and some work may still be running.
         */
        Forced
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Sun May 05 22:45:11 UTC 2024
    - 953 bytes
    - Viewed (0)
  7. platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/exec/DaemonConnectionBackedEventConsumer.java

            }
    
            private boolean moreMessagesToSend() {
                return ableToSend && !(stopped && queue.isEmpty());
            }
    
            private Object getNextEvent() {
                try {
                    return queue.poll(10, TimeUnit.MILLISECONDS);
                } catch (InterruptedException e) {
                    stopped = true;
                    return null;
                }
            }
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Sep 22 09:29:13 UTC 2023
    - 2.9K bytes
    - Viewed (0)
  8. platforms/core-execution/execution/src/main/java/org/gradle/internal/execution/timeout/impl/DefaultTimeoutHandler.java

                }
            }
    
            private void onAfterTimeoutCheck() {
                synchronized (lock) {
                    if (!stopped) {
                        slowStop = true;
                        doAsPartOfBuildOperation(() -> {
                            LOGGER.warn("Timed out {} has not yet stopped.", workUnitDescription.getDisplayName());
    
                            if (logStacktraceTimer.hasExpired()) {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Sep 22 09:46:15 UTC 2023
    - 7.3K bytes
    - Viewed (0)
  9. platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/locklistener/FileLockCommunicator.java

                    socket.send(packet);
                } catch (IOException e) {
                    if (!stopped) {
                        LOGGER.debug("Failed to confirm lock release to Gradle process at port {} for lock with id {}.", packet.getPort(), lockId);
                    }
                }
            }
        }
    
        public void stop() {
            stopped = true;
            socket.close();
        }
    
        public int getPort() {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Apr 16 15:49:49 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  10. platforms/ide/ide-native/src/integTest/groovy/org/gradle/ide/visualstudio/VisualStudioSingleProjectIntegrationTest.groovy

            return [":${exeName}VisualStudioProject", ":${exeName}VisualStudioFilters"]
        }
    
        private String stripped(String configurationName) {
            if (toolChain.visualCpp) {
                return ""
            } else {
                return configurationName.startsWith("release") ? "stripped/" : ""
            }
        }
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Sep 26 14:49:12 UTC 2023
    - 13.1K bytes
    - Viewed (0)
Back to top