Skip to content

Commit f0c4d24

Browse files
committed
#5060: Upgrade to Akka 2.6.11
- fixed the scalafmt in tests
1 parent 33dbc08 commit f0c4d24

File tree

4 files changed

+13
-646
lines changed

4 files changed

+13
-646
lines changed

core/controller/src/main/scala/org/apache/openwhisk/core/controller/Controller.scala

Lines changed: 3 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -88,6 +88,7 @@ class Controller(val instance: ControllerInstanceId,
8888
* A Route in Akka is technically a function taking a RequestContext as a parameter.
8989
*
9090
* The "~" Akka DSL operator composes two independent Routes, building a routing tree structure.
91+
*
9192
* @see http://doc.akka.io/docs/akka-http/current/scala/http/routing-dsl/routes.html#composing-routes
9293
*/
9394
override def routes(implicit transid: TransactionId): Route = {
@@ -273,18 +274,12 @@ object Controller {
273274

274275
ExecManifest.initialize(config) match {
275276
case Success(_) =>
276-
val controller = new Controller(
277-
instance,
278-
ExecManifest.runtimesManifest,
279-
config,
280-
actorSystem,
281-
logger)
277+
val controller = new Controller(instance, ExecManifest.runtimesManifest, config, actorSystem, logger)
282278

283279
val httpsConfig =
284280
if (Controller.protocol == "https") Some(loadConfigOrThrow[HttpsConfig]("whisk.controller.https")) else None
285281

286-
BasicHttpService.startHttpService(controller.route, port, httpsConfig, interface)(
287-
actorSystem)
282+
BasicHttpService.startHttpService(controller.route, port, httpsConfig, interface)(actorSystem)
288283

289284
case Failure(t) =>
290285
abort(s"Invalid runtimes manifest: $t")

core/controller/src/main/scala/org/apache/openwhisk/core/loadBalancer/CommonLoadBalancer.scala

Lines changed: 7 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -41,15 +41,13 @@ import scala.util.{Failure, Success}
4141
/**
4242
* Abstract class which provides common logic for all LoadBalancer implementations.
4343
*/
44-
abstract class CommonLoadBalancer(
45-
config: WhiskConfig,
46-
feedFactory: FeedFactory,
47-
controllerInstance: ControllerInstanceId
48-
)(implicit
49-
val actorSystem: ActorSystem,
50-
logging: Logging,
51-
messagingProvider: MessagingProvider)
52-
extends LoadBalancer {
44+
abstract class CommonLoadBalancer(config: WhiskConfig,
45+
feedFactory: FeedFactory,
46+
controllerInstance: ControllerInstanceId)(implicit
47+
val actorSystem: ActorSystem,
48+
logging: Logging,
49+
messagingProvider: MessagingProvider)
50+
extends LoadBalancer {
5351

5452
protected implicit val executionContext: ExecutionContext = actorSystem.dispatcher
5553

core/controller/src/main/scala/org/apache/openwhisk/core/loadBalancer/LeanBalancer.scala

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -87,9 +87,8 @@ class LeanBalancer(config: WhiskConfig,
8787

8888
object LeanBalancer extends LoadBalancerProvider {
8989

90-
override def instance(whiskConfig: WhiskConfig, instance: ControllerInstanceId)(
91-
implicit actorSystem: ActorSystem,
92-
logging: Logging): LoadBalancer = {
90+
override def instance(whiskConfig: WhiskConfig, instance: ControllerInstanceId)(implicit actorSystem: ActorSystem,
91+
logging: Logging): LoadBalancer = {
9392

9493
new LeanBalancer(whiskConfig, createFeedFactory(whiskConfig, instance), instance)
9594
}

0 commit comments

Comments
 (0)