Commit graph

23826 commits

Author SHA1 Message Date
Patrik Nordwall
ebb71dc7ed Add akka-protobuf-v3 to version check 2019-08-23 08:55:21 +02:00
Johannes Rudolph
682a76e928 streams: move lastCancellationCause helper variable to GraphStageLogic (#27531)
It seems in the previous `_lastCancellationCause = cause` caused a trait
forwarder method to be called.

Refs #27529
2019-08-21 12:43:40 +02:00
Patrik Nordwall
0d8c4c4d8f update latestPatchOf25 (master) (#27535) 2019-08-21 10:50:44 +02:00
Johan Andrén
2c9f0c9ff0
Give the large source test some more time #27497 (#27524) 2019-08-20 12:48:14 +02:00
Patrik Nordwall
e61ac07f7e
Merge pull request #27527 from akka/wip-singleton-leaving-master-patriknw
Fix singleton issue when leaving several nodes, #27487
2019-08-19 18:45:12 +02:00
Patrik Nordwall
ddb085255d Fix singleton issue when leaving several nodes, #27487 (#27488)
* Fix singleton issue when leaving several nodes, #27487

* When leaving several nodes at about the same time the new singleton
  could be started before previous had been completely stopped.
* Found two possible ways this could happen.
  * Acting on MemberRemoved that is emitted when the self
    cluster node is shutting down.
  * The HandOverDone confirmation when in Younger state,
    but that node is also Leaving so could be seen as Exiting
    from a third node that is the next singleton.

* keep track of all previous oldest, not only the latest

* Option => List
* Otherwise in BecomingOldest it could transition to Oldest
  when the previous oldest was removed even though the previous-previous wasn't removed yet

* fix failure in ClusterSingletonRestart2Spec

* OldestChanged was not emitted when Exiting member was removed
* The initial membersByAge must also contain Leaving, Exiting members

(cherry picked from commit ee188565b9f3cf2257ebda218cec6af5a4777439)
2019-08-19 15:11:49 +02:00
Arnout Engelen
c97e966f8b
Update some SBT plugins (#27502)
Including akka-paradox, to get the new banner
2019-08-19 12:29:09 +02:00
Helena Edelson
3dd8c7e7e2
Upgrade sbt-paradox-akka 0.18 -> 0.23 (#27473) 2019-08-17 09:40:12 -07:00
Arnout Engelen
34f9faf5fa
Convert 'Blocking needs Careful Management' from classic (#27498)
* Convert 'Blocking needs Careful Management' from classic

* Move triggering blocking calls to separate methods

* Remove classic examples of dispatching
2019-08-16 17:35:52 +02:00
Marcos Pereira
9caae087a2 Add configuration for all Jackson Features (#27409)
* Support configuration for Jackson MapperFeatures in Jackson Serializer

* Add JsonParser.Feature configuration support

* Add JsonGenerator.Feature configuration support

* Fix formatting issues

* Add examples for each feature configuration

* Test coverage of the override methods
2019-08-16 11:33:47 +02:00
Patrik Nordwall
16f4971f64 update to reactive-streams-tck 1.0.3-RC1 (#27513) 2019-08-16 11:07:10 +02:00
Patrik Nordwall
c4a87431be
Merge pull request #27485 from akka/removeHowToCommonPatterns
Remove 'How To' section of the docs
2019-08-16 10:56:04 +02:00
Patrik Nordwall
3dac8b9072
Merge pull request #27512 from akka/wip-jackson-2.9.9.3-patriknw
Update to jackson-databind 2.9.9.3
2019-08-16 10:55:24 +02:00
Johannes Rudolph
16033eaf5e Propagate stream cancellation causes (#27266)
* base functionality
* fix-restart-flow
* Fix subSource / subSink cancellation handling
* GraphStage-fix
* Fix ambiguity between complete and cancellation (for isAvailable / grab)
* rename lastCancellationCause
* add mima
* fix cancellation cause propagation in OutputBoundary
* Fix cancellation cause propagation in SubSink
* Add cancellation cause logging to Flow.log
* add more comments about GraphStage portState internals
* Add some assertions in onDownstreamFinish to prevent wrong usage
* Also deprecate onDownstreamFinish() so that no one calls the wrong one
accidentally
* add SubSinkInlet.cancel(cause)
* Propagate causes in two other places
* Suggest to use `cancel(in, cause)` but don't deprecate old one
2019-08-16 10:53:14 +02:00
Arnout Engelen
836d020e78
Remove 'How To' section of the docs (#27223) 2019-08-16 09:28:25 +02:00
Patrik Nordwall
911f6ab6c5 Update to jackson-databind 2.9.9.3
* a few more gadget types added to blacklist
* https://github.com/FasterXML/jackson/wiki/Jackson-Release-2.9#micro-patches
2019-08-16 08:31:45 +02:00
Christopher Batey
6c13949aec Use protobuf3 for internal serialization (#27366)
* Only load akka protobuf serializer if protobuf on the classpath
2019-08-15 17:43:19 +02:00
James Roper
bbff92ade6 RebalanceWorker should watch shard regions (#27261)
* RebalanceWorker should watch shard regions

Fixes #27259.

The RebalanceWorker actor needs to watch the shard regions that it's
expecting a BeginHandOffAck message from, in case the ShardRegion shuts
down before it can receive the BeginHandOff message, preventing hand
off.  This can be a problem when two nodes are shut down at about the
same time.
2019-08-15 16:36:02 +02:00
Patrik Nordwall
c1eb0719da
Merge pull request #27504 from akka/wip-deprecate-persistent-fsm-patriknw
Deprecate PersistentFSM (for validation)
2019-08-15 14:14:19 +02:00
Christopher Batey
e3164916ad Deprecate PersistentFSM
Refs #26490
2019-08-15 11:17:40 +02:00
Johannes Rudolph
a19bd1597a Fix assertion in dns tests wrt changed docker json API #27489 2019-08-14 16:24:11 +02:00
Patrik Nordwall
251fdff519
Merge pull request #27484 from akka/collapseProjectAndAdditionalInformation
Collapse 'project information' and 'additional information'
2019-08-14 15:35:29 +02:00
Patrik Nordwall
f808dd0f30
Merge pull request #27494 from akka/dispatchersDoc
Move generic dispatcher docs from Classic
2019-08-14 15:19:31 +02:00
Patrik Nordwall
a821c9cb67 follow up on style guide changes for private vs public (#27495) 2019-08-14 09:21:51 +02:00
Arnout Engelen
230905c85a
Move generic dispatcher docs from Classic (#27223)
'Blocking Needs Careful Management' and 'CallingThreadDispatcher'
still need to be done, but those also need example changes, so
leaving that for another PR
2019-08-13 15:01:44 +02:00
Arnout Engelen
a87edc601d
Update to 2.12.9 for travis as well (#27476) 2019-08-12 16:39:06 +02:00
Arnout Engelen
d75720ab33
Collapse 'project information' and 'additional information' #27223 2019-08-12 15:39:40 +02:00
Tim Moore
22fa8eb827 Update links to the Lightbend Platform docs (#27477) 2019-08-12 13:07:27 +02:00
Johan Andrén
6b29bc6fe8
2.5.24 (#27479) 2019-08-12 13:06:55 +02:00
Patrik Nordwall
fb31045896
Merge pull request #27207 from akka/releaseDrafter
Initial release drafter template
2019-08-12 10:42:29 +02:00
Helena Edelson
2933de522b
Upgraded plugin to 2.0.3, nightly to RC8 (bug fixes) (#27468) 2019-08-09 09:40:52 -07:00
Helena Edelson
fb910a2b64 Upgraded silencer plugin. (#27470) 2019-08-09 15:27:42 +02:00
Helena Edelson
b2a5abf866 Upgraded upgrade-sbt-updates. (#27469) 2019-08-09 10:23:03 +02:00
Arnout Engelen
c140fb182f Update to Scala 2.12.9 (#27384) 2019-08-08 09:46:39 -07:00
Helena Edelson
94e6706efa
Update sbt-jmh plugin (#27467) 2019-08-08 09:44:34 -07:00
Arnout Engelen
70a0af1036
Hook in akka-persistence-typed (#27464) 2019-08-08 10:25:05 +02:00
Arnout Engelen
38cda5147f Fix race conditions in Artery TCP binding to 0 (#27456) 2019-08-06 06:21:28 -07:00
Arnout Engelen
dd7dad1b7b Typo alowing -> allowing (#27458) 2019-08-06 11:40:32 +02:00
Arnout Engelen
a7e8ad2918 Update paradox (#27457)
Which adds checks for dead references and pages that are unexpectedly not
in any table of contents
2019-08-06 06:41:53 +02:00
Christopher Batey
d41622296e Clean up of persistence and cluster docs (#27451)
* Moves generic sections to main index rather than classic
* A few renames from persistence to event sourced actors
Refs #27223
2019-08-04 07:30:56 -07:00
Helena Edelson
473d4f71d7
Fixed warnings in akka-bench-jmh-typed (#27435) 2019-08-02 14:02:51 -07:00
Helena Edelson
d12bc13fcb Fix akka-bench-jmh warnings. (#27438) 2019-08-02 10:44:27 +02:00
Christopher Batey
a2ecd915cb
Remove extensions to protobuf config checker messages (#27400)
* Remove extensions to protobuf config checker messages

AFAICT these are never serialized/deserialized. Removing as they use a
deprecated feature of protobuf (required fields in extensions)
* Remove extensions from protobuf
2019-08-02 09:16:57 +01:00
Arnout Engelen
75de45d9ef
Log changes to the ShardCoordinator ddata state (#27444)
The number of shards is configurable, in the order of magnitude of the number
of nodes in the cluster. Logging the ActorRef for each allocated shard is
useful to see on which node the shard is allocated.
2019-08-01 15:19:45 +02:00
Johannes Rudolph
1fe2659203
actor: ignore more messages while TcpConnection is shutting do… (#27439)
actor: ignore more messages while TcpConnection is shutting down
2019-08-01 09:53:37 +02:00
Johannes Rudolph
21adbcfa34
actor: ignore more messages while TcpConnection is shutting down
Otherwise, there will be noisy warnings in the log for messages that
carry `DeadLetterSupression` like all the `CloseCommands`.
2019-07-31 13:36:58 +02:00
Christopher Batey
e55ac350c3
Fix race in AkkaProtocolSpec (#27431)
The heartbeat happens after the send associate in
AkkaProtocolTransport so test can't assume the heartbeat
has happened.

Fixes #26974
2019-07-31 09:05:58 +01:00
Helena Edelson
914466c8c2
Fixed akka-stream-tests-tck warnings (#27436) 2019-07-30 08:33:48 -07:00
Helena Edelson
01f5698677
Added GPG and release script prerequisite setup steps explicitly to release doc (#27417) 2019-07-30 07:55:33 -07:00
Helena Edelson
737fedcb91
Review suggestions tested and added, stepped on the merge gas with two approvals but suggestions lingering #27424 (#27433) 2019-07-30 06:30:57 -07:00