raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10
21965 commits 1 branch 31 tags 268 MiB
Commit graph

21965 commits

This branch
This branch
All branches
Author SHA1 Message Date
Johan Andrén
9e459f0c04 Supervise also deferred initialization, #24052 
* Initial test coverage

* Working except for the restart with exponential backoff

* All lights green

* Update after latest discussion

* Just an extra testcase to cover something I had a gut feeling could be wrong

* Some review and rebase fixes

* Alias and class name conflict

* Stopper implementing init()

* Some final minor fixes

* Rebased, and all exception logs silenced/checked for
 2018-02-01 19:41:40 +01:00
Johannes Rudolph
2c71122b7b
=typ #24456 in ActorAdapter catch exceptions from ask/message adapters 
Log those and stop the actor manually.
 2018-02-01 17:43:17 +01:00
Johannes Rudolph
1a717c02ca
=typ fix race condition in AskSpec 2018-02-01 17:42:30 +01:00
Johan Andrén
3b54f238ea
Ability to disable coordinated shutdown phases #24477 2018-02-01 17:32:10 +01:00
Johannes Rudolph
e4397db44a
Merge pull request #24406 from jrudolph/jr/review-24302 
Introduce special starting state in ActorAdapter for guardian actor #24279
 2018-02-01 17:20:02 +01:00
Patrik Nordwall
1054b5bd81
Merge pull request #24461 from akka/wip-behaviour-typo-patriknw 
change spelling of behaviour to behavior, #24457
 2018-02-01 17:13:31 +01:00
Johannes Rudolph
3e2e348cdb
=typ allow creation of ActorSystemAdapters only after ActorSystem is fully initialized 
This will allow to uncover initialization order bugs easier.
 2018-02-01 16:06:21 +01:00
Johannes Rudolph
79a111d64b
=typ #24279 introduce special startup state for typed guardian actor 
This allows the untyped actorsystem to be initialized completely before starting up
the typed guardian code.
 2018-02-01 16:06:21 +01:00
Johan Andrén
c6965edc21
=typ #24279 Add tests for ActorSystem startup / shutdown scenarios 2018-02-01 16:05:45 +01:00
Patrik Nordwall
23fa8b0810 change spelling of behaviour to behavior, #24457 2018-02-01 15:10:46 +01:00
Christopher Batey
4af523a012 Make typed test probe names consistent (#24469) 
We have expectMsg but expectNoMessage

We have lots of pixels these days so went with the full word
 2018-02-01 22:43:29 +09:00
Patrik Nordwall
742749f3d5
Merge pull request #24460 from akka/wip-24298-streams-materialize-under-system-typed-patriknw 
=str #24298 ActorMaterializer now starts actors under /system
 2018-01-31 21:34:40 +01:00
Arnout Engelen
e33db45139
Add dependency snippets to relevant doc sections (#24418) 
* Add dependency snippets to relevant doc sections

* Add 'Dependency' headings

Tried to consistently add them to each section introducing a module, after
the introduction but before the first code sample.

* Make Dependency sections more consistent
 2018-01-31 17:19:19 +01:00
Patrik Nordwall
36372bb2a5
Merge pull request #24458 from akka/wip-24289-typed-streams-patriknw 
Typed stream adapters, #23604
 2018-01-31 16:49:55 +01:00
Konrad Malawski
dd62071ff8 =str #24298 ActorMaterializer now starts actors under /system unless 
inside ActorContext, in which case it still is child actors as usual

This makes sense as they're "internal", so more like system actors
anyway, but the major reason for the change is Akka Typed, in which we
do not control the user guardian, and as such can not attach things
from the side into it
 2018-01-31 15:35:42 +01:00
Martynas Mickevičius
cbe0215c41 Typed stream adapters, #23604 
* Change more general factories to private
* Typed Streams docs
* Remove BoxedUnit from Java Api
* Use JavaPartialFunction in Java examples
* Doc wording improvements, formatting fixes, no verification diagrams
 2018-01-31 15:33:48 +01:00
Konrad `ktoso` Malawski
171bb6c231 WIP initial typed streams adapters 
Adapt ref source and sink for typed

 * do not use the typed teskit temporarily
 2018-01-31 15:10:46 +01:00
Patrik Nordwall
84b8f3ac29
Merge pull request #24407 from akka/wip-stashing2-patriknw 
document and cleanup stashing, #22275
 2018-01-31 15:08:00 +01:00
Arnout Engelen
fe5a42586c Scheduler that manually advances time (##24150) 
* Don't apply dilation to scheduler parameter
* Clarify ExecutionContext usage
* Clarify comment on timePasses
* Make ExplicitlyTriggeredScheduler internals private
* List currently scheduled tasks in one log message
* Execute immediately if (initialDelay <= Duration.Zero)
* Don't reschedule if scheduled task fails
* Be more efficient about logging
* Widen `timePasses` delay for now
https://github.com/akka/akka/pull/24243#discussion_r160985493 for some
discussion on what to do instead
* Remove mechanism for mixing in config from a test trait
 2018-01-31 14:48:05 +01:00
Patrik Nordwall
8b38789d9d document and cleanup stashing, #22275 
* remove ImmutableStashBuffer
* minor doc edits
* java example
* some more tests, and some more scaladoc details
* rename head/tail to first/last
 2018-01-31 14:05:18 +01:00
Johan Andrén
978d927133
Document thread safety of ActorContext #24410 2018-01-31 12:52:47 +01:00
Johannes Rudolph
c6250eddb3
Merge pull request #24399 from jrudolph/jr/don-t-initialize-serialization-in-RemoteActorRef 
=act don't initialize Serializer extension in `RemoteActorRefProvider`
 2018-01-31 11:41:53 +01:00
Johan Andrén
570e080a19
Make sure it is obvious ctx.stop(non-child) does not work #18524 2018-01-31 10:47:26 +01:00
Johan Andrén
ac64a7bb98
Logging for typed #23326 2018-01-31 10:43:56 +01:00
Viktor Klang (√)
08b0d34a4c Introduces eager cancellation for divertTo 
* and updates Partition to support this behavior
* not adding Partition.apply overload due to type inference issues, use constructor instead
 2018-01-30 19:59:53 +01:00
Christopher Batey
5b2a4edd2c
Increase timeout for system termination in BasicClusterConfigSpec (#24446) 
Refs #24444
 2018-01-30 15:23:49 +00:00
Konrad `ktoso` Malawski
c023d51367
=doc #24435 copy mutable maps before sharing them as messages in java (#24447) 
* =doc #24435 copy mutable maps before sharing them as messages in java

* fix rename

* Update DeviceGroup.java

* Update DeviceGroup.java
 2018-01-30 23:20:15 +09:00
Patrik Nordwall
cdecd8b6fe add missing returnRecoveryPermit (#24439) 
* missing for some error cases
* in the states recoveryStarted and recovering it has got the permit and
  it must returned if the actor is stopped due to some error in those
  states
* it would have been a lot easier to do such in postStop but we can't
  introduce new things in the trait Eventsourced due to BC
 2018-01-30 21:46:38 +09:00
Christopher Batey
aa911bcf14 Handle TCP connection timeout while resolving #24437 2018-01-30 12:54:21 +01:00
Patrik Nordwall
40018809f1
Merge pull request #24441 from nachinius/wip-24421-add-restartflow-with-backoff-only-on-failures 
Adds RestartFlow to restart only on failures #24421
 2018-01-30 11:02:54 +01:00
Konrad `ktoso` Malawski
c7f842942d
=clut #24311 timer event may arrive after we already identified successfuly (#24442) 
* =clut #24311 timer event may arrive after we already identified successfuly

* mark as NoSerializationVerificationNeeded
 2018-01-30 18:17:01 +09:00
Christopher Batey
5658d6e77a MultiDcSplitBain: only subscribe to unreachable after split 
Test would fail picking up the reachable from the previous unsplit
as it is a new probe.

Also change barrierCounter to split/unsplit so easier to see
where the failure is on a barrier fail
 2018-01-30 09:01:15 +00:00
Johan Andrén
78b5045165 More details in the coordinated shutdown docs (#24436) 
* More details in the coordinated shutdown docs

* Update reference.conf
 2018-01-30 12:07:09 +09:00
Ignacio (nachinius) Peixoto
e73434796c Adds RestartFlow to restart only on failures #24421 2018-01-29 13:58:31 -03:00
Johannes Rudolph
2fd4063d72
Merge pull request #24385 from jrudolph/jr/23697-start-receptionist-eagerly 
=typ #23697 start typed receptionist eagerly
 2018-01-29 16:29:51 +01:00
Konrad `ktoso` Malawski
800923522a
=str #24413 make sure to check if available to push (#24434) 
* =str #24413 make sure to check if available to push

* address review

* Update SourceRefBenchmark.scala
 2018-01-30 00:27:40 +09:00
Johannes Rudolph
3ba4b27889
=typ #23697 start typed receptionist eagerly 
Fixes #23697
 2018-01-29 15:58:43 +01:00
Patrik Nordwall
81c5b1d571
Merge pull request #24422 from akka/wip-24100-DistributedPubSubRestart-patriknw 
harden DistributedPubSubRestart, #24100
 2018-01-29 14:22:39 +01:00
pwliwanow
7ba40b238a Fix in BackoffSupervisor.calculateDelay #24419 2018-01-29 12:05:27 +01:00
Arnout Engelen
c05dd26700 Use getWhenTerminated in Java examples (#24428) 
* Use getWhenTerminated in Java examples

Introduced in #24330

* Fix compilation error
 2018-01-29 18:05:11 +09:00
Song Kun
0e2d001cce =doc Some improvements on overview of Akka modules (#24429) 2018-01-29 13:34:25 +09:00
Arnout Engelen
a0ef1f7272
Shorter heading for scalaFiddle example (#24416) 
The long h4 header looked a bit strange in the index:
https://doc.akka.io/docs/akka/current/stream/index.html
 2018-01-26 10:51:46 +01:00
Patrik Nordwall
da565edbc6 harden DistributedPubSubRestart, #24100 2018-01-26 07:13:34 +01:00
Julien Broi
d47c703b6d Adding streams to the list of capabilities (#24417) 2018-01-26 00:40:45 +09:00
Arnout Engelen
c1e0522970
Suppress 'match is not exhaustive!' warning (#24408) 
* Suppress 'match is not exhaustive!' warning

Not super clean, but gets rid of the compiler warning shown every time this
file is compiled.

* Using a NotImplementedError rather than a MatchError
 2018-01-25 15:22:11 +01:00
Song Kun
22b10dbef0 fix typo (#24415) 2018-01-25 13:58:08 +01:00
Sebastian Harko
4ed492d90f make NonBlockingBoundedMailbox the default example (#24401) 2018-01-25 20:27:50 +09:00
Arron Norwell
b4f24f44fa Remove explicit fsync from FileSink (#24314) 2018-01-25 11:46:15 +01:00
Johannes Rudolph
a1d8a5554b
Merge pull request #24354 from anilgursel/24353-groupBy-drops-new-group-anilgursel 
groupBy pulls upstream when a substream materialization is waiting #2…
 2018-01-25 11:41:18 +01:00
Johannes Rudolph
176bec52ae
=act don't initialize Serializer extension in RemoteActorRefProvider 
Instead, load it as a library-extension.
 2018-01-25 11:21:07 +01:00