- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for addWorker (0.28 sec)
-
platforms/ide/base-ide-plugins/src/main/java/org/gradle/plugins/ide/internal/IdePlugin.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Aug 01 11:07:39 UTC 2023 - 8.2K bytes - Viewed (0) -
cmd/background-heal-ops.go
// Run the background healer for i := 0; i < globalBackgroundHealRoutine.workers; i++ { go globalBackgroundHealRoutine.AddWorker(ctx, objAPI, bgSeq) } globalBackgroundHealState.LaunchNewHealSequence(bgSeq, objAPI) } // Wait for heal requests and process them func (h *healRoutine) AddWorker(ctx context.Context, objAPI ObjectLayer, bgSeq *healSequence) { for { select { case task, ok := <-h.tasks: if !ok {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 4.6K bytes - Viewed (0) -
platforms/ide/base-ide-plugins/src/test/groovy/org/gradle/plugins/ide/internal/IdePluginTest.groovy
@Override protected String getLifecycleTaskName() { return 'testIde' } @Override protected void onApply(Project target) { def worker = target.task('generateXml') addWorker(target.getTasks().named(worker.getName()), worker.getName()); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Aug 01 11:07:39 UTC 2023 - 1.9K bytes - Viewed (0) -
platforms/ide/ide-plugins/src/test/groovy/org/gradle/plugins/ide/internal/TestIdePlugin.groovy
@Override protected String getLifecycleTaskName() { return 'testIde' } @Override protected void onApply(Project target) { def worker = target.task('generateXml') addWorker(target.getTasks().named(worker.getName()), worker.getName()); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Aug 01 11:07:39 UTC 2023 - 1008 bytes - Viewed (0) -
internal/event/target/mqtt.go
SetUsername(args.User). SetPassword(args.Password). SetMaxReconnectInterval(args.MaxReconnectInterval). SetKeepAlive(args.KeepAlive). SetTLSConfig(&tls.Config{RootCAs: args.RootCAs}). AddBroker(args.Broker.String()) target.client = mqtt.NewClient(options) token := target.client.Connect() ok := token.WaitTimeout(reconnectInterval) if !ok { return store.ErrNotConnected }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 8.2K bytes - Viewed (0)