-
- Downloads
[SPARK-11079] Post-hoc review Netty-based RPC - round 1
I'm going through the implementation right now for post-doc review. Adding more comments and renaming things as I go through them. I also want to write higher level documentation about how the whole thing works -- but those will come in other pull requests. Author: Reynold Xin <rxin@databricks.com> Closes #9091 from rxin/rpc-review.
Showing
- core/src/main/scala/org/apache/spark/MapOutputTracker.scala 1 addition, 1 deletioncore/src/main/scala/org/apache/spark/MapOutputTracker.scala
- core/src/main/scala/org/apache/spark/rpc/RpcAddress.scala 50 additions, 0 deletionscore/src/main/scala/org/apache/spark/rpc/RpcAddress.scala
- core/src/main/scala/org/apache/spark/rpc/RpcEndpoint.scala 1 addition, 2 deletionscore/src/main/scala/org/apache/spark/rpc/RpcEndpoint.scala
- core/src/main/scala/org/apache/spark/rpc/RpcEnv.scala 3 additions, 150 deletionscore/src/main/scala/org/apache/spark/rpc/RpcEnv.scala
- core/src/main/scala/org/apache/spark/rpc/RpcTimeout.scala 131 additions, 0 deletionscore/src/main/scala/org/apache/spark/rpc/RpcTimeout.scala
- core/src/main/scala/org/apache/spark/rpc/akka/AkkaRpcEnv.scala 0 additions, 4 deletions...src/main/scala/org/apache/spark/rpc/akka/AkkaRpcEnv.scala
- core/src/main/scala/org/apache/spark/rpc/netty/Dispatcher.scala 62 additions, 46 deletions...rc/main/scala/org/apache/spark/rpc/netty/Dispatcher.scala
- core/src/main/scala/org/apache/spark/rpc/netty/IDVerifier.scala 2 additions, 2 deletions...rc/main/scala/org/apache/spark/rpc/netty/IDVerifier.scala
- core/src/main/scala/org/apache/spark/rpc/netty/Inbox.scala 53 additions, 66 deletionscore/src/main/scala/org/apache/spark/rpc/netty/Inbox.scala
- core/src/main/scala/org/apache/spark/rpc/netty/NettyRpcCallContext.scala 7 additions, 4 deletions...cala/org/apache/spark/rpc/netty/NettyRpcCallContext.scala
- core/src/main/scala/org/apache/spark/rpc/netty/NettyRpcEnv.scala 18 additions, 20 deletions...c/main/scala/org/apache/spark/rpc/netty/NettyRpcEnv.scala
- core/src/main/scala/org/apache/spark/util/ThreadUtils.scala 0 additions, 1 deletioncore/src/main/scala/org/apache/spark/util/ThreadUtils.scala
- core/src/main/scala/org/apache/spark/util/Utils.scala 1 addition, 0 deletionscore/src/main/scala/org/apache/spark/util/Utils.scala
- core/src/test/scala/org/apache/spark/rpc/netty/InboxSuite.scala 3 additions, 3 deletions...rc/test/scala/org/apache/spark/rpc/netty/InboxSuite.scala
- core/src/test/scala/org/apache/spark/rpc/netty/NettyRpcHandlerSuite.scala 4 additions, 3 deletions...ala/org/apache/spark/rpc/netty/NettyRpcHandlerSuite.scala
Loading
Please register or sign in to comment