Janitor - Code Search

android/guava/src/com/google/common/util/concurrent/Monitor.java

    @Weak final Monitor monitor;
    final Condition condition;

    @GuardedBy("monitor.lock")
    int waiterCount = 0;

    /** The next active guard */
    @GuardedBy("monitor.lock")
    @CheckForNull
    Guard next;

    protected Guard(Monitor monitor) {
      this.monitor = checkNotNull(monitor, "monitor");
      this.condition = monitor.lock.newCondition();
    }

    /**

Java

- Registered: Fri Apr 26 12:43:10 GMT 2024

- Last Modified: Mon Dec 04 18:22:01 GMT 2023

- 38.6K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/java/org/codelibs/fess/app/web/api/admin/stats/ApiAdminStatsAction.java

import org.opensearch.monitor.jvm.JvmStats;
import org.opensearch.monitor.jvm.JvmStats.BufferPool;
import org.opensearch.monitor.jvm.JvmStats.Classes;
import org.opensearch.monitor.jvm.JvmStats.GarbageCollectors;
import org.opensearch.monitor.jvm.JvmStats.Mem;
import org.opensearch.monitor.jvm.JvmStats.Threads;
import org.opensearch.monitor.os.OsProbe;
import org.opensearch.monitor.os.OsStats;

Java

- Registered: Mon May 06 08:04:11 GMT 2024

- Last Modified: Thu Feb 22 01:37:57 GMT 2024

- 12.1K bytes

- Viewed (0)

github.com/google/guava

android/guava/src/com/google/common/util/concurrent/ServiceManager.java

  private static final class ServiceManagerState {
    final Monitor monitor = new Monitor();

    @GuardedBy("monitor")
    final SetMultimap<State, Service> servicesByState =
        MultimapBuilder.enumKeys(State.class).linkedHashSetValues().build();

    @GuardedBy("monitor")
    final Multiset<State> states = servicesByState.keys();

    @GuardedBy("monitor")

Java

- Registered: Fri Apr 26 12:43:10 GMT 2024

- Last Modified: Wed Dec 13 19:45:20 GMT 2023

- 30.5K bytes

- Viewed (0)

github.com/gradle/gradle

build-logic/cleanup/src/main/java/gradlebuild/cleanup/services/KillLeakingJavaProcesses.java

    private static final String PLAY_SERVER_PATTERN_STR = "(play\\.core\\.server\\.NettyServer)";
    private static final String JAVA_PROCESS_STACK_TRACES_MONITOR_PATTERN_STR = "(JavaProcessStackTracesMonitor\\.java)";
    private static ExecutionMode executionMode;

    static String generateAllGradleProcessPattern() {
        return "(?i)[/\\\\]" + JAVA_EXECUTABLE_PATTERN_STR + ".+("

Java

- Registered: Wed May 01 11:36:15 GMT 2024

- Last Modified: Fri Apr 26 09:46:00 GMT 2024

- 11.3K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/java/org/codelibs/fess/exec/SuggestCreator.java

import org.lastaflute.di.core.external.GenericExternalContextComponentDefRegister;
import org.lastaflute.di.core.factory.SingletonLaContainerFactory;
import org.opensearch.monitor.jvm.JvmInfo;
import org.opensearch.monitor.os.OsProbe;
import org.opensearch.monitor.process.ProcessProbe;

public class SuggestCreator {

    private static final Logger logger = LogManager.getLogger(SuggestCreator.class);

    @Resource

Java

- Registered: Mon May 06 08:04:11 GMT 2024

- Last Modified: Thu Feb 22 01:37:57 GMT 2024

- 10K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/java/org/codelibs/fess/exec/Crawler.java

import org.lastaflute.di.core.external.GenericExternalContextComponentDefRegister;
import org.lastaflute.di.core.factory.SingletonLaContainerFactory;
import org.opensearch.monitor.jvm.JvmInfo;
import org.opensearch.monitor.os.OsProbe;
import org.opensearch.monitor.process.ProcessProbe;

public class Crawler {

    private static final Logger logger = LogManager.getLogger(Crawler.class);

Java

- Registered: Mon May 06 08:04:11 GMT 2024

- Last Modified: Thu Feb 22 01:37:57 GMT 2024

- 24.1K bytes

- Viewed (2)

github.com/minio/minio

cmd/erasure-sets.go

	s.connectDisks()

	monitor := time.NewTimer(monitorInterval)
	defer monitor.Stop()

	for {
		select {
		case <-ctx.Done():
			return
		case <-monitor.C:
			if serverDebugLog {
				console.Debugln("running drive monitoring")
			}

			s.connectDisks()

			// Reset the timer for next interval
			monitor.Reset(monitorInterval)
		}
	}
}

Go

- Registered: Sun May 05 19:28:20 GMT 2024

- Last Modified: Fri May 03 20:08:20 GMT 2024

- 37.7K bytes

- Viewed (5)

github.com/apache/maven

maven-core/src/main/resources/META-INF/maven/extension.xml

    <exportedPackage>org.apache.maven.graph</exportedPackage>
    <exportedPackage>org.apache.maven.lifecycle</exportedPackage>
    <exportedPackage>org.apache.maven.model</exportedPackage>
    <exportedPackage>org.apache.maven.monitor</exportedPackage>
    <exportedPackage>org.apache.maven.plugin</exportedPackage>
    <exportedPackage>org.apache.maven.profiles</exportedPackage>
    <exportedPackage>org.apache.maven.project</exportedPackage>

XML

- Registered: Sun Apr 28 03:35:10 GMT 2024

- Last Modified: Mon Jan 08 10:37:09 GMT 2024

- 12.2K bytes

- Viewed (0)

github.com/google/guava

android/guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

          // because the service does not monitor the state of the future so if the exception is not
          // caught and forwarded to the service the task would stop executing but the service would
          // have no idea.
          // TODO(lukes): consider building everything in terms of ListenableScheduledFuture then
          // the AbstractService could monitor the future directly. Rescheduling is still hard...

Java

- Registered: Fri Apr 26 12:43:10 GMT 2024

- Last Modified: Wed Dec 13 19:45:20 GMT 2023

- 25.8K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/resources/fess_config.properties

crawler.data.env.param.key.pattern=^FESS_ENV_.*
crawler.ignore.robots.txt=false
crawler.ignore.robots.tags=false
crawler.ignore.content.exception=true
crawler.failure.url.status.codes=404
crawler.system.monitor.interval=60
crawler.hotthread.ignore_idle_threads=true
crawler.hotthread.interval=500ms
crawler.hotthread.snapshots=10
crawler.hotthread.threads=3
crawler.hotthread.timeout=30s
crawler.hotthread.type=cpu

Properties

- Registered: Mon May 06 08:04:11 GMT 2024

- Last Modified: Thu Apr 11 02:34:53 GMT 2024

- 30.6K bytes

- Viewed (1)

Search Options