Commit graph

1436 commits

Author SHA1 Message Date
Arnout Engelen
814cfa286c Scala 2.13.0 rc2 (#26967) 2019-05-24 08:11:50 +02:00
Patrik Nordwall
a6f717c9b0 fix a race condition in ClusterReadView #24710 (#26922)
* remove lazy initialization for _cachedSelf
* don't update _state and friends after close()
2019-05-23 14:08:25 +02:00
Patrik Nordwall
a2658cc8a0
Merge pull request #26933 from akka/wip-ClusterSingletonProxySpec-patriknw
more classic remoting leftovers
2019-05-17 11:07:29 +02:00
Patrik Nordwall
35e7e07488
Some more internal-dispatcher usages, #26915
* tried to investigate the (small) increase in LatencySpec that occured
  when the internal-dispatcher was introduced
* couldn't see significant difference when running locally
* found a few more places where the internal-dispatcher should be used
* my thinking is that the additional latency could have been caused by
  hopping between dispatchers, but I'm not sure if any of these
  changes will have an effect (we'll see in Jenkins job)
* more clear router props
2019-05-15 19:35:57 +02:00
Patrik Nordwall
71e9bdc262 more classic remoting leftovers
* fix several tests that were using akka.remote.netty.tcp config
* replace akka.tcp with akka in more places
* some doc cross references to remoting.md
2019-05-15 19:34:50 +02:00
Patrik Nordwall
0c8d46121a Disable LargeMessageClusterSpec for classic remoting, #26889 2019-05-13 15:43:59 +02:00
Patrik Nordwall
3b538dc84c internal-dispatcher in akka.cluster.StartupWithOneThreadSpec (#26862) 2019-05-06 10:08:11 +02:00
Christopher Batey
25648bdf36
Be more explicit that a node is shutting down as it was marked as DOWN (#26861) 2019-05-03 14:15:22 +01:00
Patrik Nordwall
2bbf13f707
Run CoordinatedShutdown from ActorSystem.terminate #25213 (#26830) 2019-05-03 10:47:47 +02:00
Johan Andrén
81b1e2ef9b Internal dispatcher to protect against starvation (#26816)
* Allow for dispatcher aliases and define a internal dispatcher
* Test checking dispatcher name
* MiMa for Dispatchers
* Migration guide entry
* No need to have custom dispatcher lookup logic in streams anymore
* Default dispatcher size and migration note about that
* Test checking exact config values...
* Typed receptionist on internal dispatcher
* All internal usages of system.dispatcher gone through
2019-05-02 22:35:25 +02:00
Patrik Nordwall
82c761f026
remove Future from StreamRefs mat val, #24372 (#26847) 2019-05-02 16:54:37 +02:00
Patrik Nordwall
cf0329681e
Merge pull request #26835 from akka/wip-26832-assertInvariants-patriknw
Handle CoordinatedShutdown exiting-completed when not joined, #26832
2019-05-02 08:24:43 +02:00
Christopher Batey
efc3adc08d
Make artery the default remoting (#26772) 2019-05-01 08:12:09 +01:00
Patrik Nordwall
a77db34f8f Handle CoordinatedShutdown exiting-completed when not joined, #26832
* assertion failed: Nodes not part of cluster have marked the Gossip as seen
* trying to mark the Gossip as seen before it has joined, which may happen
  if CoordinatedShutdown is running before the node has joined
2019-04-30 14:47:53 +02:00
Arnout Engelen
f17941d614 Move 'Remoting' under 'Clustering' in the docs (#26774)
* Move 'Remoting' under 'Clustering' in the docs #26491

* As it is typically not used directly, but as an implementation detail of
Clustering.

* Warn when remoting is used directly #26491
2019-04-29 13:18:03 +02:00
Martynas Mickevičius
2184a617a3 Drop MiMa filters for 2.4.x (#26781) 2019-04-23 09:24:29 +02:00
Johannes Rudolph
4c9783a2dc
Merge pull request #26762 from chbatey/fix-cluster-round-robin-spec
Fix regression in ClusterRoundRobinSpec
2019-04-17 11:41:02 +02:00
Christopher Batey
d75d44de4a Fix regression in MultiDcHeartbeatTakingOverSpec introduced by removing compiler warnings (#26761) 2019-04-17 11:25:59 +02:00
Christopher Batey
aca530d93b Fix regression in ClusterRoundRobinSpec 2019-04-17 08:34:47 +01:00
Christopher Batey
8dd6f790bd Remove warnings in akka-cluster (#26739)
Also undeprecate isTerminated but mark it internal
2019-04-16 19:10:31 +02:00
Patrik Nordwall
caa1752206 Support disable of join compat config check, #26719 2019-04-15 17:23:05 +02:00
Christopher Batey
65ccada280 Lease API + use in cluster singleton and sharding, #26480 (#26629)
* lease api
* Cluster singleton manager with lease
* Refactor OldestData to use option for actor reference
* Sharding with lease
* Docs for singleton and sharding lease + config for sharding lease
* Have ddata shard wait until lease is acquired before getting state
2019-03-28 13:31:56 +01:00
Ignasi Marimon-Clos
c097e8144a Extends collection of shutdown Reasons (e.g. ClusterJoinUnsuccessfulReason) (#26570)
* Adds JoiningSeedNodesUnsuccessfulReason

* Promotes IncompatibleConfigurationDetectedReason to public API

* Rename class after PR comments

* Use a custom exit code on joinUnsuccesful shuhtdown

* Mima

* Scalafmt
2019-03-26 14:52:50 +01:00
Arnout Engelen
d390fcf183 Introduce warning silencer plugin (#26588)
So now we can compile akka-distributed-data with
-Xfatal-warnings - though I'm not yet sure about
enabling the (other) undisciplineScalacOptions

* Fix multi-node silencing
* Fix scaladoc warnings
* Introduce annotation to declare ccompat use
* Add explicit toString
* Fix deprecation on 2.13
* Move 'immutable' ccompat helpers to shared ccompat package
* Add MiMa for internal scala 2.13 compatibility class
* Internal API markers
* Fix scaladoc generation
Got bitten by https://github.com/scala/bug/issues/11021
2019-03-26 14:41:29 +01:00
Arnout Engelen
d7f12d3568 akka-distributed-data compiler warnings #26088 2019-03-19 08:12:51 +01:00
Auto Format
75579bed17 format source with scalafmt, #26511 2019-03-15 10:23:46 +01:00
Auto Format
ce404e4f53 format source with scalafmt 2019-03-11 16:58:55 +01:00
Patrik Nordwall
5c96a5f556 replace unicode arrows
* ⇒, →, ←
* because we don't want to show them in documentation snippets and
  then it's complicated to avoid that when snippets are
  located in src/test/scala in individual modules
* dont replace object `→` in FSM.scala and PersistentFSM.scala
2019-03-11 16:58:51 +01:00
Patrik Nordwall
e0a3fb28c9
Merge pull request #26346 from akka/wip-26326-FunctionRef-deadlock-patriknw
Fix deadlock in FunctionRef, #26326
2019-02-12 15:56:28 +01:00
Patrik Nordwall
ddada9a8e1
Stop singleton and shards when self MemberDowned, #26336 (#26339)
* Stop singleton when self MemberDowned, #26336
  * It's safer to stop singleton instance early in case of downing.
  * Instead of waiting for MemberRemoved and trying to hand over.
* Stop ShardRegion when self MemberDowned, #26336
* Upper bound when waiting for seen in shutdownSelfWhenDown, #26336
2019-02-12 15:05:33 +01:00
Arnaud Burlet
93ce2b8696 Test to ensure a coordinated shutdown is successful when a stream involving StreamRefs is running 2019-02-12 15:03:49 +01:00
Patrik Nordwall
f0b976d557 fix wrong log level of cluster debug logging (#26351) 2019-02-11 16:24:08 +00:00
Patrik Nordwall
0c2ad78042 fix format of verbose logging of cluster events (#26363) 2019-02-11 14:37:39 +01:00
Christopher Batey
5e0bc91e34 Make cluster logging even more standard
A few cases the dc logging was inconsistent. The logger has changed in
some cases but only in cluster actors of which there are a single
instance
2019-02-05 16:29:30 +00:00
Patrik Nordwall
18daa47781
Merge pull request #25963 from akka/wip-25950-allObservers-patriknw
Reachability.allObservers wrong after filterRecords, #25950
2019-01-18 12:31:11 +01:00
Patrik Nordwall
96692b2c04
Terminate StreamRef on node failure, #25960
* manage AddressTerminated subscription in FunctionRef
* implementation can be compared with akka/actor/dungeon/DeathWatch.scala
* use synchronized access to the watch state and AddressTerminatedTopic
* use OptionVal for _watchedBy
2019-01-17 16:53:17 +01:00
Patrik Nordwall
7777cba0a6 Reachability.allObservers wrong after filterRecords, #25950 2019-01-14 20:42:08 +01:00
Patrik Nordwall
312dbad1b9 Suppress no seed-nodes configured logging when Bootstrap is used, #25680
* link to docs
2019-01-14 19:51:31 +01:00
Patrik Nordwall
19c9fbc355 cleanup Cluster logging
* include Cluster Node prefix in same way for all logging
2019-01-14 19:47:43 +01:00
Helena Edelson
00b235d9c5
Support rolling update for new JoinConfigCompatChecker #26194 (#26229)
Support rolling update for new JoinConfigCompatChecker #26194
2019-01-14 09:15:22 -08:00
Helena Edelson
5514afbe54
Fix compiler warnings in akka-cluster* #26087 (#26241)
* Fix compiler warnings in akka-cluster* #26087
* Added new mima filters for 2.5.19 bin compat.
2019-01-14 05:50:59 -08:00
hepin1989
998c5a9285 Formatting java codes with sbt-java-formatter. 2019-01-12 04:00:53 +08:00
Arnout Engelen
d274e039f9
Various scala-2.13.0-M5 fixes
fix akka-actor-tests compile errors

some tests still fail though

Fix test failures in akka-actor-test

Manually work arround missing implicit Factory[Nothing, Seq[Nothing]]

see https://github.com/scala/scala-collection-compat/issues/137

akka-remote scalafix changes

Fix shutdownAll compile error

test:akka-remote scalafix changes

akka-multi-node-testkit scalafix

Fix akka-remote-tests multi-jvm compile errors

akka-stream-tests/test:scalafix

Fix test:akka-stream-tests

Crude implementation of ByteString.map

scalafix akka-actor-typed, akka-actor-typed-tests

akka-actor-typed-tests compile and succeed

scalafix akka-camel

scalafix akka-cluster

akka-cluster compile & test

scalafix akka-cluster-metrics

Fix akka-cluster-metrics

scalafix akka-cluster-tools

akka-cluster-tools compile and test

scalafix akka-distributed-data

akka-distributed-data fixes

scalafix akka-persistence

scalafix akka-cluster-sharding

fix akka-cluster-sharding

scalafix akka-contrib

Fix akka-cluster-sharding-typed test

scalafix akka-docs

Use scala-stm 0.9 (released for M5)

akka-docs

Remove dependency on collections-compat

Cherry-pick the relevant constructs to our own
private utils

Shorten 'scala.collections.immutable' by importing it

Duplicate 'immutable' imports

Use 'foreach' on futures

Replace MapLike with regular Map

Internal API markers

Simplify ccompat by moving PackageShared into object

Since we don't currently need to differentiate between 2.11 and

Avoid relying on 'union' (and ++) being left-biased

Fix akka-actor/doc by removing -Ywarn-unused

Make more things more private

Copyright headers

Use 'unsorted' to go from SortedSet to Set

Duplicate import

Use onComplete rather than failed.foreach

Clarify why we partly duplicate scala-collection-compat
2019-01-11 12:27:18 +01:00
Arnout Engelen
0cc8e20a2e
Various scala-2.13.0-M5 fixes
Clearer imports in TcpDnsClient

Accept SVG's when checking if diagrams were generated

Fix akka-actor MiMa issues

akka-testkit scalafix changes

Update scalatest to 2.13-released snapshot

akka-stream scalafix changes

Update ssl-config

To version that's released with -M5

Take elements directly out of buffer

Manually fix immutable.Seq / Doc link

Make sure the right Concat, Sink is imported

akka-stream binary compat

akka-stream-testkit scalafix

akka-actor-tests scalafix

Eta-expensions
2019-01-11 11:44:35 +01:00
Seth Tisue
67300e4122
isFinite has zero parameter lists now 2019-01-11 11:43:31 +01:00
kerr
bdc90052aa Update headers from 2018 to 2019 once for all. (#26165)
* Add CopyrightHeader support for sbt-boilerplate plugin.
* Add CopyrightHeader support for `*.proto` files.
* Add regex match for both `–` and `-` for CopyrightHeader.
* Add CopyrightHeader support for sbt build files.
* Update copyright from 2018 to 2019.
2019-01-02 11:55:26 +01:00
Patrik Nordwall
229db51eb4 Cleanup validNodeForGossip (#25965)
The intended behavior is:
* don't gossip to node marked as unreachable by self (heartbeat
  messages are not getting through so no point in trying to gossip).
* gossip is allowed to nodes marked as unreachable by others

This doesn't change anything from how it worked before, but I think the
original intention before the multi-dc changes was to not gossip to
unreachable at all no matter who marked them.
2018-12-10 17:18:53 +01:00
kerr
e9fb3a020a Make use of scalafix to remove unused import. (#26019)
* =build Add scalafix to remote unused import.

* +build Add file ignore plugin for scalafix which support ignore files.
2018-12-05 08:30:21 +00:00
Christopher Batey
c8013d54f3 Include configuration name in log when cluster not actor provider 2018-11-16 15:58:59 +00:00
Helena Edelson
f872115512 Cluster event listener that logs all events #25832 (#25918) 2018-11-15 17:31:58 +01:00