Commit graph

21751 commits

Author SHA1 Message Date
Patrik Nordwall
6cb326e171 add label 'good first issue' (#24296) 2018-01-16 09:42:22 +00:00
Johan Andrén
df40ef7bc0
Actually check the shutdown status before materializing anything (#24307) 2018-01-16 09:10:21 +01:00
Catalin Ursachi
0529f1814b Remove redundant Futures tests (#24095) (#24130)
* Remove redundant Futures tests (#24095)

* Cleaned up tests

* Removed FutureSpec.scala
2018-01-16 08:45:01 +01:00
Martynas Mickevičius
6cb3cc5e02
Update whitesource plugin to the latest (#24313) 2018-01-16 09:39:38 +07:00
Patrik Nordwall
fb72274b71 fix compilation error (expectNoMsg) (#24312) 2018-01-15 17:15:45 +01:00
Arnout Engelen
ed9ece49c4 Use expectNoMessage in typed testkit (#24250)
* Use expectNoMessage in typed testkit

Interestingly most calls to expectNoMsg did not appear to expect the parameter
to be dilated

Might be nice to allow configuring a variant that uses a (configurable) default
delay (other than the single-expect-default)

* Add a probe.expectNoMessage with no parameters

If you want to 'just wait a while' and not care too much about how long
exactly, will be dilated.
2018-01-15 15:08:18 +01:00
Patrik Nordwall
d66f6e07dc
Merge pull request #24290 from akka/whitesourceUpdate
Update whitesource
2018-01-15 15:04:04 +01:00
Patrik Nordwall
876eb83ae4
Merge pull request #24292 from akka/updateLeveldb
Update LevelDB
2018-01-15 15:02:43 +01:00
Martynas Mickevičius
930d2e9133
#23695 Remove onSignal from typed persistent actor (#24253) 2018-01-12 19:50:49 +07:00
Arnout Engelen
ab624c08c0 Update LevelDB (#23907)
The latest version can work with jdk9, previous versions
touched jdk.internal.ref.Cleaner which is no longer allowed
on jdk9.
2018-01-11 17:35:35 +01:00
Arnout Engelen
bfbfe5d817 Update whitesource (#23757)
0.1.8 uses a whitesource release that works under jdk9
2018-01-11 16:37:04 +01:00
Martynas Mickevičius
a3ae494325 #24104 Give a bit of time for consumers to register 2018-01-11 20:02:05 +09:00
Denys Zadorozhnyi
f1de21950d Adds stacktrace to the logged warning in onPersistRejected() (#24263)
Fixes #24133: Switch to log.error from log.warning and add a stacktrace in onPersistRejected()
2018-01-11 11:52:38 +01:00
Johan Andrén
7ce494b262 A bit more text about the clustered receptionist 2018-01-11 18:17:15 +09:00
Johan Andrén
f7b4a08308 Review updates and making the Receptionist API work from Java plus workaround for guardian start race 2018-01-11 18:17:15 +09:00
Johan Andrén
3a9facfe32 Review updates and making the Receptionist API work from Java 2018-01-11 18:17:15 +09:00
Christopher Batey
45c7303d3f Cluster typed examples in scala and java 2018-01-11 18:17:15 +09:00
Christopher Batey
f17dc5c7f7 Receptionist docs and examples 2018-01-11 18:17:15 +09:00
Konrad `ktoso` Malawski
cf455f3c11 Fix MiMa for Untangle settings from attributes in materializer #24063 2018-01-11 14:14:38 +09:00
Johan Andrén
4dde0742d0 Untangle settings from attributes in materializer #24063
Instead of renaming - deprecating and documenting

Renaming defaultInitialAttributes to defaultAttributes and adding docs

Tests passing

More work on using attributes for the attribute settings in ActorMaterializerSettings

Mark some attributes as mandatory and provide a smoother access w/o allocation for those

Another warning notice

MiMa filters

Part of the review adressed

Incorrect rebase fixed + formatting

Review feedback adressed

Formatting ...
2018-01-11 14:14:38 +09:00
Patrik Nordwall
4402c73a53
Merge pull request #24281 from akka/raboof-patch-1
Update sbt-paradox-akka
2018-01-10 17:01:05 +01:00
Arnout Engelen
f441d2e82a
Update sbt-paradox-akka
To the version with the fiddle encoding fix (and more)
2018-01-10 16:26:32 +01:00
Patrik Nordwall
ca945e2746
Merge pull request #24278 from akka/wip-24277-ClusterClientSpec-patriknw
harden ClusterClientSpec, #24277
2018-01-10 12:21:01 +01:00
Konrad `ktoso` Malawski
59a48c728b
+rem #24265 protobuf serializer for Address and UniqueAddress in akka… (#24267)
* +rem #24265 protobuf serializer for Address and UniqueAddress in akka-remote

* remove the duplication, by using previously existing type

* fixed doc link

* make it easier to enable the additional no-java-serialization bindings

* fixed akka-actor failure due to changes

* cleanup

* Update reference.conf

* Update serialization.md

* Update reference.conf
2018-01-10 19:28:51 +09:00
Patrik Nordwall
115f9b2a33 harden ClusterClientSpec, #24277 2018-01-10 10:48:55 +01:00
Konrad `ktoso` Malawski
eba7473199
=doc,per Include link to nice article about Events as First-Class Citizens (#24262)
* =doc,per Include link to nice article about Events as First-Class Citizens

* Move link up
2018-01-10 11:12:56 +09:00
Arnout Engelen
1f898ea491 Fix Java logging code example (#24275) 2018-01-10 11:09:54 +09:00
Patrik Nordwall
a1b61f15cb
Merge pull request #24209 from akka/wip-24191-sharding-opt2-patriknw
Reply to GetShardHome requests after rebalance, #24191
2018-01-09 20:53:30 +01:00
Patrik Nordwall
d30464c452 Reply to GetShardHome requests after rebalance, #24191
* Some GetShardHome requests were ignored (by design) during
  rebalance and they would be retried later.
* This optimization keeps tracks of such requests and reply
  to them immediately after rebalance has been completed and
  thereby the buffered messages in the region don't have to
  wait for next retry tick.
* use regionTerminationInProgress also during the update since
  all GetShardHome requests are not stashed
2018-01-09 20:12:45 +01:00
Johan Andrén
fc2413f29b
Version checking utility #24030 2018-01-09 20:11:14 +01:00
Patrik Nordwall
0eedd714e8 reply to known shard locations immediately when waitingForUpdate, #24064 2018-01-09 13:51:35 +01:00
Konrad `ktoso` Malawski
be7c05cad2
=tes #24270 expectNoMessage should pull the unexpected msg (#24271)
* =tes #24270 expectNoMessage should pull the unexpected msg from the queue

* Update TestKit.scala
2018-01-09 20:35:43 +09:00
fredfp
0bd408977b cluster client handover when receptionist's node leaves the cluster (#24167)
* Always add sender of GetContacts to client interactions

* Handover clients when receptionist leaves the cluster

* Revision based on code review

* Cluster receptionist only tracks connected clients
2018-01-09 10:41:33 +01:00
Nafer Sanabria
804dc4b6ba add flag crdt constants (#24208)
* add flag crdt constants

* add scaladoc
2018-01-09 10:39:06 +01:00
Rebecca Grenier
7c94bc7df4 Update tutorial_5.md (#24268)
plural noun doesn't need an apostrophe
2018-01-09 12:20:09 +09:00
Josep Prat
0796607aa4 =doc Fix dangling @@@ in howto docs #23516 (#24261)
Refs: #23516
Last Java pattern was shown for both Java and Scala.
2018-01-08 02:54:11 +01:00
kerr
dc20fc2f1e ! project upgrade to SBT 1.1.0 (#24257) 2018-01-06 09:44:38 +01:00
Heiko Seeberger
032f712301 Remove superfluous final modifier #19493 2018-01-05 09:58:07 +01:00
Christopher Batey
0380cc517a Cluster singleton manager: don't send member events to FSM during shutdown (#24236)
There exists a race where a cluter node that is being downed seens its
self as the oldest node (as it has had the other nodes removed) and it
takes over the singleton manager sending the real oldest node to go into
the End state meaning that cluster singletons never work again.

This fix simply prevents Member events being given to the Cluster
Manager FSM during a shut down, instread relying on SelfExiting.

This also hardens the test by not downing the node that the current
sharding coordinator is running on as well as fixing a bug in the
probes.
2018-01-05 09:47:43 +01:00
Philippus Baalman
1d14c387a0 Extend copyright into 2018 (#24246) 2018-01-05 09:25:34 +01:00
Christopher Batey
009214ae07
Update copyright to 2018 (#24241) 2018-01-04 17:26:29 +00:00
Christopher Batey
bd2a3de88a
Typed async testkit (#24203)
* Typed async testkit
* Pull out useful parts from internal TypedSpec into a public TestKit
* Port internal tests to use the external testkit
2018-01-04 15:09:38 +00:00
Christopher Batey
c7cbebb534 Fix record overflow race condition in flight recorder #21992
The flag used to show a record is dirty/commited was overwritten by the
last 4 bytes of the previous metadata. Most of the time this isn't
caught as the record is written fixed width and typically the last bytes
are 0s which is the same as the Commited flag. However under
concurrency this can overwrite the Dirty flag that is preventing
corruption.
2018-01-04 13:37:16 +01:00
Pritam Kadam
37f0da17b7 Allow member to leave a cluster via CoordinatedShutdown.run when MemberStatus is Joining/WeaklyUp/Up. (#24152) 2018-01-04 07:43:25 +00:00
Nafer Sanabria
1dffa344c4 Fail fast on empty string persistenceId in PersistentActor (#24239) 2018-01-03 22:22:44 +01:00
kerr
5a66976683 update java and scala doc to use the terminate method (#24233) 2018-01-03 14:18:06 +01:00
kerr
7943bd5f96 fix up AbstractActor's Java doc. (#24212) 2018-01-03 12:51:54 +01:00
Łukasz Drygała
0c0bf91661 rewrite FlatSpec tests using WordSpec #24186 2018-01-03 12:51:27 +01:00
Ayush Mishra
6d6e96179d Adding new book reference for Akka HTTP (#24218) 2018-01-03 12:47:11 +01:00
kerr
7edf3bfecf + actor #15446 add external predicate to ReceiveBuilder (#24221) 2018-01-03 10:23:31 +01:00