From 1acf6575925b07129ec874f95e7d00a0367e3feb Mon Sep 17 00:00:00 2001
From: Maxime MORGE <maxime.morge@univ-lille.fr>
Date: Mon, 19 Jun 2023 15:11:43 +0200
Subject: [PATCH] PSSI: XP from 16
---
build.sbt | 4 ++--
.../smastaplus/utils/MASTAPlusConsumer.scala | 18 +++++++++---------
2 files changed, 11 insertions(+), 11 deletions(-)
diff --git a/build.sbt b/build.sbt
index 8ee8a465..01c7a21b 100644
--- a/build.sbt
+++ b/build.sbt
@@ -7,8 +7,8 @@ scalacOptions += "-feature" // Emit warning and location for usages of features
scalacOptions += "-unchecked" // Enable additional warnings where generated code depends on assumptions.
scalacOptions += "-Xlint" // Enable recommended warnings
-run / javaOptions += "-Xms4G"//400G on a blade
-run / javaOptions += "-Xmx4G"//400G on a blade
+run / javaOptions += "-Xms400G"//400G on a blade
+run / javaOptions += "-Xmx400G"//400G on a blade
run / javaOptions += "-Dfile.encoding=UTF-8"
/**
diff --git a/src/main/scala/org/smastaplus/utils/MASTAPlusConsumer.scala b/src/main/scala/org/smastaplus/utils/MASTAPlusConsumer.scala
index 1f5aacfa..bcb33a1c 100644
--- a/src/main/scala/org/smastaplus/utils/MASTAPlusConsumer.scala
+++ b/src/main/scala/org/smastaplus/utils/MASTAPlusConsumer.scala
@@ -13,7 +13,6 @@ import akka.actor.ActorSystem
import akka.dispatch.MessageDispatcher
import com.typesafe.config.{Config, ConfigFactory}
import org.joda.time.LocalDateTime
-import org.smastaplus.balancer.{PSIBalancer, SSIBalancer}
/**
* Consume and negotiate a random allocation for a random STAP instance using :
@@ -23,23 +22,24 @@ import org.smastaplus.balancer.{PSIBalancer, SSIBalancer}
* - or java -jar smastaplus-assembly-X.Y.jar org.smastaplus.utils.MASTAPlusConsumer -v -m
*/
object MASTAPlusConsumer extends App {
- val debug = true
- val decentralizedDispatcherId = "akka.actor.default-dispatcher"
- val decentralizedSystem: ActorSystem = ActorSystem("DecentralizedSystem1")
- val decentralizedSystem2: ActorSystem = ActorSystem("DecentralizedSystem2")
- val decentralizedSystem3: ActorSystem = ActorSystem("DecentralizedSystem3")
- val decentralizedSystem4: ActorSystem = ActorSystem("DecentralizedSystem4")
+ private val debug = true
+ private val decentralizedDispatcherId = "akka.actor.default-dispatcher"
+ private val decentralizedSystem: ActorSystem = ActorSystem("DecentralizedSystem1")
+ private val decentralizedSystem2: ActorSystem = ActorSystem("DecentralizedSystem2")
+ private val decentralizedSystem3: ActorSystem = ActorSystem("DecentralizedSystem3")
+ private val decentralizedSystem4: ActorSystem = ActorSystem("DecentralizedSystem4")
+
implicit val decentralizedContext: MessageDispatcher = decentralizedSystem.dispatchers.lookup(decentralizedDispatcherId)
val config: Config = ConfigFactory.load()
val monitoringDirectoryName: String = config.getString("path.smastaplus") + "/" +
config.getString("path.monitoringDirectory")
+ // Manag e
var verbose: Boolean = false
var monitor: Boolean = true
var argList: List[String] = List[String]()
- // drop class name in the java command line
- if (!args.isEmpty) {
+ if (!args.isEmpty) { // drop class name in the java command line
argList = if (args.head == "org.smastaplus.utils.MASTAPlusConsumer") args.toList.drop(1) else args.toList
parseCommandLine()
}
--
GitLab