Commit graph

830 commits

Author SHA1 Message Date
Viktor Klang
465c29107d Migrating tests to use the new config for dispatchers 2012-01-30 16:34:25 +01:00
Viktor Klang
8bc6513911 Merge branch 'master' into wip-1728-fjpool-√ 2012-01-30 16:08:04 +01:00
Roland
9d388f2de6 Merge branch 'wip-1685-remote-cleaup-∂π' 2012-01-30 15:44:32 +01:00
Viktor Klang
c1dd4463b9 Restructuring how executors are configured and making sure people can plug in their own 2012-01-30 13:44:56 +01:00
Roland
2bebf29c1c implement ActorPath.fromString, see #1697 2012-01-27 15:39:29 +01:00
Viktor Klang
b045383a72 Changing signature of the createThreadPool in MDC to return the MD 2012-01-27 15:30:24 +01:00
Roland
c5fc153a10 rework system initialization, remove remote address from LocalActorRef
- move all creation of ActorRefs into the ActorRefProvider (deadLetters,
  locker)
- rootPath does not contain remote transport address any longer in order
  to start the LocalActorRefProvider before the RemoteTransport; the
  transport address is inserted during serialization only, which enables
  us later to have more than one transport available for one actor
  system (maybe even needed for clustering)
- fix inheritance between DeadLetterActorRef and EmptyLocalActorRef
- document some start-up dependencies by reordering constructor code
- fix remote tests which used self.path for identifying remote actors
  (since that no longer includes the remote transport address)
2012-01-27 12:14:28 +01:00
Patrik Nordwall
60fd3c2964 Removed the need for passing in 'this' as log source to LoggingReceive. See #1720 2012-01-26 13:24:48 +01:00
Patrik Nordwall
52aa4f2a64 LoggingReceive with implicit ActorContext instead of ActorSystem. See #1720 2012-01-26 10:58:35 +01:00
Roland
9d18b620a9 tighten static type of Duration factories
- return FiniteDuration whenever possible to allow statically guarding
  against infinities
- add Ordering[Duration] and Ordering[FiniteDuration] instances
- avoid use of structural types in multiplication enrichments
- had to fix type inference problem due to too precise type in
  DurationSpec (view bounds vs. local type inference vs. operator
  precedence)
2012-01-24 21:23:07 +01:00
Roland Kuhn
1399b048e1 Merge pull request #251 from jboner/wip-1719-ExtendedActorSystem-∂π
add ExtendedActorSystem to shield ActorSystemImpl
2012-01-24 06:36:05 -08:00
Roland
d5c23bcb76 add ExtendedActorSystem to shield ActorSystemImpl
- add provider, guardian, systemGuardian and deathWatch to it
- make ActorSystemImpl extend ExtendedActorSystem
- use ExtendedActorSystem for creating extensions, thereby limiting the
  access extensions get to just those four published methods.
2012-01-24 11:33:40 +01:00
Patrik Nordwall
2a6b7f9b03 Moved decider to separate parameter list, and implicit conversion from Seq[Throwable]. See #1714 2012-01-24 10:35:09 +01:00
Patrik Nordwall
abc072ef0a Improved API of OneForOneStrategy and AllForOneStrategy. See #1714
* withinTimeRange: Duration
* Removed need for Options in API
2012-01-24 08:46:27 +01:00
Derek Williams
4bbae37ee7 Use random port in remaining IO tests 2012-01-23 23:44:28 -07:00
Derek Williams
0137c81374 Merge branch 'master' of github.com:jboner/akka
Conflicts:
	akka-actor-tests/src/test/scala/akka/actor/IOActor.scala
2012-01-23 10:41:22 -07:00
Derek Williams
6d348b6e0e IO: Support random port 2012-01-23 10:40:05 -07:00
Roland
2a0c4ca145 Merge branch 'wip-1581-patterns-ask' 2012-01-23 18:35:30 +01:00
patriknw
d21d03207f Merge pull request #247 from jboner/wip-1711-supervisorStrategy-patriknw
FaultHandler as method in Actor instead of in Props. See #1711
2012-01-23 08:40:59 -08:00
Patrik Nordwall
9e15d2062b Renamed more things to SupervisorStrategy. Updated more docs. See #1711 2012-01-23 17:18:49 +01:00
Derek Williams
83ca0cee65 Make IO tests a bit less abusive 2012-01-23 09:11:18 -07:00
Roland
3a30f915c3 remove use of akka.actor.timeout property for ask 2012-01-23 15:59:18 +01:00
Patrik Nordwall
66e0a7cf0b Moved definition of fault handler from Props to overridable method supervisorStrategy in Actor. See #1711
* New trait SupervisorStrategy for TypedActors
* Adjustments of docs
* Updated tests
2012-01-23 13:49:19 +01:00
Viktor Klang
f8186e53d7 Merging in master 2012-01-23 11:30:36 +01:00
Roland
34a0f005b1 Merge branch 'master' into wip-1581-patterns-ask 2012-01-20 19:29:17 +01:00
Viktor Klang
a4e2b5a511 Merge branch 'master' into wip-1705-awaitTermination-patriknw 2012-01-20 18:39:40 +01:00
Viktor Klang
301b14e0ac Switching to a bit more robust approach 2012-01-20 18:38:48 +01:00
Roland
020c6b61da move all Ask stuff to akka.pattern
- remove ?(msg, timeout), should always use ?(msg)(timeout) because of
  Scala’s only Martin-acknowledged design flaw of being able to pass
  tuples into single-arg methods without adding another pair of parens
- put a provider into all actor refs, because they all are created by
  and associated with one
- treat all terminated refs equally: tell(msg) and return broken promise
2012-01-20 15:45:53 +01:00
Patrik Nordwall
0bf87613d2 Timeout in test 2012-01-20 14:24:20 +01:00
Patrik Nordwall
e6cee135f0 Run callbacks in defined order, and ActorSystem.awaitTermination. See #1704, #1705 2012-01-20 14:17:27 +01:00
Viktor Klang
8dfe619140 #1703 & #1693 - moving daemonicity to one place, and in doing so creating a thread factory in ActorSystem 2012-01-20 12:30:19 +01:00
Viktor Klang
03bc15feb1 #1692 - Adding config option for making the Scheduler daemonic 2012-01-19 20:55:27 +01:00
Viktor Klang
c4b4302266 Damn you ConfigSpec 2012-01-19 19:48:57 +01:00
Viktor Klang
d888ca5bff Removing 'name' from dispatchers, just use id, much better 2012-01-19 19:08:51 +01:00
Viktor Klang
2e40cdcf0e Merge branch 'master' of github.com:jboner/akka 2012-01-19 18:21:25 +01:00
Viktor Klang
149fbea5a7 Updating Copyright as per #1660 2012-01-19 18:21:06 +01:00
Viktor Klang
44c7f49f92 Removed FState, switched to isCompleted checks instead of value.isDefined, added zip etc 2012-01-19 13:50:02 +01:00
Patrik Nordwall
5647f69727 Fixed failing test, due to pool-size. 2012-01-18 18:04:41 +01:00
Roland
1daaee98aa Merge remote-tracking branch 'origin/master' into wip-1581-patterns-ask 2012-01-18 14:20:13 +01:00
Roland
00ec3f89dc move ask machinery from ActorRefProvider to pattern.AskSupport
- now everything is assembled in one spot
- also moved PromiseActorRef and AskTimeoutException from akka.actor
- plus a little boy-scouting
2012-01-18 11:53:45 +01:00
patriknw
b5c8d7db56 Merge pull request #221 from jboner/wip-less-aggressive-poolsize-for-tests
Limit default-dispatcher pool size, see #1654
2012-01-18 02:25:25 -08:00
Roland
2bed2cb954 move everything into package akka.pattern 2012-01-18 10:18:51 +01:00
Derek Williams
cac7c8cdda Proper fault tolerance in IO test Actors and less blocking in tests 2012-01-17 23:45:37 -07:00
Roland
9c762dec20 polish “ask” pattern, see #1581
- move package objects into their respective package.scala file in the
  right directories
- make implicit conversion as well as explicit facility available under
  the same name akka.patterns.ask for easy import
- revert the logic to produce the Promise for the PromiseActorRef within
  the ActorRefProvider; supporting wrapping of external Promises does
  not seem to justify doing needless extra allocations in case of
  failure
- add scaladocs
- factor out “def provider” into trait ActorRefWithProvider, as it
  didn’t feel right attaching this information “by exception” to
  MinimalActorRef
2012-01-17 17:35:33 +01:00
Patrik Nordwall
517fceae34 Adjust pool size of default-dispatcher. See #1654
* Changed reference.conf
  core-pool-size-min = 6
  core-pool-size-factor = 3.0
  core-pool-size-max = 64
  max-pool-size-min = 6
  max-pool-size-factor  = 3.0
  max-pool-size-max = 64
* Limited to smaller pool size in AkkaSpec
* Adjusted some tests that needed more threads
2012-01-17 17:28:57 +01:00
patriknw
2e6061b411 Merge pull request #220 from jboner/wip-1606-remote-routers-patriknw
Handle remote routers transparently
2012-01-17 06:56:42 -08:00
viktorklang
c71514bc73 Merge pull request #219 from jboner/wip-1650-Future-or-√
Fixing ticket #1650
2012-01-17 06:56:31 -08:00
Viktor Klang
3f0b1772c8 Simplified the test cases for Future.or 2012-01-17 15:54:56 +01:00
Viktor Klang
a019c9e8a6 Adding tests for the chaining 2012-01-17 15:36:24 +01:00
Patrik Nordwall
74382c156a Merge branch 'master' into wip-1606-remote-routers-patriknw
Conflicts:
	akka-remote/src/main/scala/akka/routing/RemoteRouters.scala
2012-01-17 14:55:10 +01:00