- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 970 for Starting (0.14 sec)
-
guava/src/com/google/common/util/concurrent/ServiceManager.java
this.state = state; } @Override public void starting() { ServiceManagerState state = this.state.get(); if (state != null) { state.transitionService(service, NEW, STARTING); if (!(service instanceof NoOpService)) { logger.get().log(Level.FINE, "Starting {0}.", service); } } } @Override public void running() {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue May 07 12:41:16 UTC 2024 - 33K bytes - Viewed (0) -
cmd/batch-expire_test.go
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 3K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/exec/LogAndCheckHealth.java
int nextBuildNum = runningStats.getBuildCount() + 1; if (nextBuildNum == 1) { return String.format("Starting build in new daemon [memory: %s]", NumberUtil.formatBytes(Runtime.getRuntime().maxMemory())); } else { return String.format("Starting %s build in daemon %s", NumberUtil.ordinal(nextBuildNum), stats.getHealthInfo()); } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 3K bytes - Viewed (0) -
pkg/controller/nodeipam/node_ipam_controller.go
serviceCIDR *net.IPNet, secondaryServiceCIDR *net.IPNet, nodeCIDRMaskSizes []int, allocatorType ipam.CIDRAllocatorType) (*Controller, error) { if kubeClient == nil { return nil, fmt.Errorf("kubeClient is nil when starting Controller") } // Cloud CIDR allocator does not rely on clusterCIDR or nodeCIDRMaskSize for allocation. if allocatorType != ipam.CloudAllocatorType { if len(clusterCIDRs) == 0 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 16:18:38 UTC 2024 - 5.4K bytes - Viewed (0) -
testing/soak/src/integTest/groovy/org/gradle/launcher/daemon/DaemonPerformanceMonitoringSoakTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 3.7K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ServiceManager.java
this.state = state; } @Override public void starting() { ServiceManagerState state = this.state.get(); if (state != null) { state.transitionService(service, NEW, STARTING); if (!(service instanceof NoOpService)) { logger.get().log(Level.FINE, "Starting {0}.", service); } } } @Override public void running() {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue May 07 12:41:16 UTC 2024 - 31.1K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/process/internal/DefaultExecHandle.java
if (currentState == ExecHandleState.STARTING) { if (hasCommandLineExceedMaxLength(command, arguments) && hasCommandLineExceedMaxLengthException(failureCause)) { return format("Process '%s' could not be started because the command line exceed operating system limits.", displayName); } return format("A problem occurred starting process '%s'", displayName); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jan 26 14:58:23 UTC 2024 - 15.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/JobHelper.java
}; findJobByUniqueOf(LaJobUnique.of(id)).ifPresent(job -> { if (!job.isUnscheduled()) { if (StringUtil.isNotBlank(scheduledJob.getCronExpression())) { logger.info("Starting Job {}:{}", id, scheduledJob.getName()); final String cronExpression = scheduledJob.getCronExpression(); job.reschedule(cronExpression, op -> op.changeNoticeLogToDebug().params(paramsOp));
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 8.1K bytes - Viewed (0) -
platforms/core-configuration/file-collections/src/main/java/org/gradle/api/internal/file/FileCollectionStructureVisitor.java
} /** * Called when starting to visit a file collection. Can return true to continue with visiting or false to skip this collection and its contents. * * <p>When a file collection represents a container of file collections, the children of the file collection are visited in order. Visiting a child works in the
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Sep 28 09:51:04 UTC 2023 - 3.3K bytes - Viewed (0) -
security/pkg/nodeagent/sds/server.go
s.workloadSds.register(s.grpcWorkloadServer) var err error s.grpcWorkloadListener, err = uds.NewListener(security.WorkloadIdentitySocketPath) go func() { sdsServiceLog.Info("Starting SDS grpc server") waitTime := time.Second started := false for i := 0; i < maxRetryTimes; i++ { if s.stopped.Load() { return } serverOk := true setUpUdsOK := true
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 07 17:44:41 UTC 2024 - 3.3K bytes - Viewed (0)