You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@reef.apache.org by we...@apache.org on 2015/02/05 22:06:12 UTC
[51/51] [partial] incubator-reef git commit: [REEF-131] Towards the
new .Net project structure This is to change .Net project structure for Tang,
Wake, REEF utilities, Common and Driver:
[REEF-131] Towards the new .Net project structure
This is to change .Net project structure for Tang, Wake,
REEF utilities, Common and Driver:
* Move projects folders under cs
* Rename projects to follow name convention
* Update csproj file for the references
* Update Tang.Tests name space
* Update Tang internal namesapces for subfolders
JIRA:
[REEF-131] https://issues.apache.org/jira/browse/REEF-131
Pull Request:
This closes #68
Project: http://git-wip-us.apache.org/repos/asf/incubator-reef/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-reef/commit/c1b5200f
Tree: http://git-wip-us.apache.org/repos/asf/incubator-reef/tree/c1b5200f
Diff: http://git-wip-us.apache.org/repos/asf/incubator-reef/diff/c1b5200f
Branch: refs/heads/master
Commit: c1b5200f6008855ffb2bb420e916257c4b5092a4
Parents: fa77cc6
Author: Julia Wang <jw...@yahoo.com>
Authored: Tue Feb 3 17:38:27 2015 -0800
Committer: Markus Weimer <we...@apache.org>
Committed: Thu Feb 5 12:55:46 2015 -0800
----------------------------------------------------------------------
.../JavaClrBridge/ActiveContextClr2Java.cpp | 2 +-
.../AllocatedEvaluatorClr2Java.cpp | 2 +-
.../JavaClrBridge/ClosedContextClr2Java.cpp | 2 +-
.../Cpp/CppBridge/JavaClrBridge/Clr2JavaImpl.h | 8 +-
.../CppBridge/JavaClrBridge/CommonUtilities.cpp | 2 +-
.../CompletedEvaluatorClr2Java.cpp | 2 +-
.../JavaClrBridge/CompletedTaskClr2Java.cpp | 2 +-
.../JavaClrBridge/ContextMessageClr2Java.cpp | 2 +-
.../EvaluatorRequestorClr2Java.cpp | 2 +-
.../JavaClrBridge/FailedContextClr2Java.cpp | 2 +-
.../JavaClrBridge/FailedEvaluatorClr2Java.cpp | 2 +-
.../JavaClrBridge/FailedTaskClr2Java.cpp | 2 +-
.../JavaClrBridge/HttpServerClr2Java.cpp | 2 +-
.../CppBridge/JavaClrBridge/JavaClrBridge.cpp | 2 +-
.../JavaClrBridge/RunningTaskClr2Java.cpp | 2 +-
.../JavaClrBridge/SuspendedTaskClr2Java.cpp | 2 +-
.../JavaClrBridge/TaskMessageClr2Java.cpp | 2 +-
.../ClientJobStatusHandler.cs | 142 +++
lang/cs/Org.Apache.REEF.Common/Constants.cs | 38 +
.../EvaluatorHeartBeatSanityChecker.cs | 55 +
lang/cs/Org.Apache.REEF.Common/FailedRuntime.cs | 49 +
.../IContextAndTaskSubmittable.cs | 55 +
.../IContextSubmittable.cs | 42 +
.../IJobMessageObserver.cs | 30 +
.../Org.Apache.REEF.Common/ITaskSubmittable.cs | 35 +
.../Org.Apache.REEF.Common.csproj | 233 ++++
.../Properties/AssemblyInfo.cs | 55 +
.../api/AbstractFailure.cs | 142 +++
.../api/IAbstractFailure.cs | 25 +
lang/cs/Org.Apache.REEF.Common/api/IFailure.cs | 57 +
.../api/IResourceLaunchHandler.cs | 28 +
.../api/IResourceReleaseHandler.cs | 28 +
.../api/IResourceRequestHandler.cs | 28 +
.../avro/AvroDriverInfo.cs | 65 +
.../avro/AvroHttpRequest.cs | 79 ++
.../avro/AvroHttpSerializer.cs | 36 +
.../avro/AvroJsonSerializer.cs | 52 +
.../avro/AvroReefServiceInfo.cs | 55 +
.../catalog/INodeDescriptor.cs | 36 +
.../catalog/IRackDescriptor.cs | 25 +
.../catalog/IResourceCatalog.cs | 37 +
.../catalog/NodeDescriptorImpl.cs | 116 ++
.../catalog/RackDescriptorImpl.cs | 75 ++
.../catalog/ResourceCatalogImpl.cs | 95 ++
.../catalog/capabilities/CPU.cs | 60 +
.../catalog/capabilities/ICapability.cs | 25 +
.../catalog/capabilities/RAM.cs | 51 +
.../context/ContextMessage.cs | 66 +
.../context/IContextMessage.cs | 28 +
.../context/IContextMessageHandler.cs | 27 +
.../context/IContextMessageSource.cs | 28 +
.../DefaultLocalHttpDriverConnection.cs | 45 +
.../DefaultYarnClusterHttpDriverConnection.cs | 44 +
.../DefaultYarnOneBoxHttpDriverConnection.cs | 46 +
.../evaluator/DriverInformation.cs | 136 ++
.../evaluator/EvaluatorOperationState.cs | 39 +
.../evaluator/EvaluatorRuntimeState.cs | 39 +
.../evaluator/EvaluatorType.cs | 39 +
.../evaluator/IDriverConnection.cs | 26 +
.../events/IContextStart.cs | 26 +
.../events/IContextStop.cs | 26 +
.../exceptions/EvaluatorException.cs | 75 ++
.../exceptions/JobException.cs | 58 +
.../cs/Org.Apache.REEF.Common/io/INameClient.cs | 71 ++
.../Org.Apache.REEF.Common/io/NameAssignment.cs | 60 +
.../io/NamingConfiguration.cs | 45 +
.../io/NamingConfigurationOptions.cs | 36 +
lang/cs/Org.Apache.REEF.Common/packages.config | 26 +
.../protobuf/cs/ClientRuntime.pb.cs | 147 +++
.../protobuf/cs/DriverRuntime.pb.cs | 339 +++++
.../protobuf/cs/EvaluatorRunTime.pb.cs | 305 +++++
.../protobuf/cs/ReefProtocol.pb.cs | 78 ++
.../protobuf/cs/ReefService.pb.cs | 393 ++++++
.../protobuf/cs/Serializer.cs | 130 ++
.../cs/codec/EvaluatorHeartbeatProtoCodec.cs | 41 +
.../protobuf/cs/codec/REEFMessageCodec.cs | 37 +
.../protobuf/proto/client_runtime.proto | 56 +
.../protobuf/proto/driver_runtime.proto | 90 ++
.../protobuf/proto/evaluator_runtime.proto | 91 ++
.../protobuf/proto/reef_protocol.proto | 44 +
.../protobuf/proto/reef_service_protos.proto | 117 ++
.../runtime/MachineStatus.cs | 137 +++
.../runtime/evaluator/Constants.cs | 40 +
.../runtime/evaluator/EvaluatorRuntime.cs | 255 ++++
.../runtime/evaluator/EvaluatorSettings.cs | 185 +++
.../runtime/evaluator/HeartBeatManager.cs | 390 ++++++
.../evaluator/ReefMessageProtoObserver.cs | 140 +++
.../context/ContextClientCodeException.cs | 70 ++
.../evaluator/context/ContextConfiguration.cs | 140 +++
.../evaluator/context/ContextLifeCycle.cs | 105 ++
.../runtime/evaluator/context/ContextManager.cs | 362 ++++++
.../runtime/evaluator/context/ContextRuntime.cs | 478 ++++++++
.../evaluator/context/ContextStartImpl.cs | 33 +
.../evaluator/context/ContextStopImpl.cs | 33 +
.../evaluator/context/RootContextLauncher.cs | 126 ++
.../runtime/evaluator/task/CloseEventImpl.cs | 48 +
.../runtime/evaluator/task/DriverMessageImpl.cs | 52 +
.../runtime/evaluator/task/SuspendEventImpl.cs | 48 +
.../evaluator/task/TaskClientCodeException.cs | 65 +
.../runtime/evaluator/task/TaskLifeCycle.cs | 69 ++
.../runtime/evaluator/task/TaskRuntime.cs | 328 +++++
.../runtime/evaluator/task/TaskStartImpl.cs | 34 +
.../runtime/evaluator/task/TaskState.cs | 40 +
.../runtime/evaluator/task/TaskStatus.cs | 330 +++++
.../runtime/evaluator/task/TaskStopImpl.cs | 35 +
.../evaluator/utils/EvaluatorConfigurations.cs | 121 ++
.../runtime/evaluator/utils/RemoteManager.cs | 25 +
.../Org.Apache.REEF.Common/services/IService.cs | 25 +
.../services/ServiceConfiguration.cs | 83 ++
.../services/ServicesConfigurationOptions.cs | 31 +
.../tasks/IDriverMessageHandler.cs | 31 +
.../tasks/IRunningTask.cs | 53 +
lang/cs/Org.Apache.REEF.Common/tasks/ITask.cs | 28 +
.../tasks/ITaskMessageSource.cs | 31 +
.../tasks/TaskConfiguration.cs | 148 +++
.../tasks/TaskConfigurationOptions.cs | 69 ++
.../Org.Apache.REEF.Common/tasks/TaskMessage.cs | 68 +
.../defaults/DefaultDriverMessageHandler.cs | 42 +
.../tasks/defaults/DefaultTaskMessageSource.cs | 49 +
.../tasks/events/ICloseEvent.cs | 28 +
.../tasks/events/IDriverMessage.cs | 28 +
.../tasks/events/ISuspendEvent.cs | 25 +
.../tasks/events/ITaskStart.cs | 26 +
.../tasks/events/ITaskStop.cs | 26 +
lang/cs/Org.Apache.REEF.Driver/ClientManager.cs | 43 +
lang/cs/Org.Apache.REEF.Driver/Constants.cs | 114 ++
.../DriverConfigGenerator.cs | 151 +++
.../DriverConfigurationSettings.cs | 135 ++
lang/cs/Org.Apache.REEF.Driver/DriverManager.cs | 541 ++++++++
.../DriverRuntimeConfiguration.cs | 64 +
.../DriverRuntimeConfigurationOptions.cs | 42 +
.../DriverSubmissionSettings.cs | 185 +++
.../Org.Apache.REEF.Driver/EvaluatorManager.cs | 655 ++++++++++
lang/cs/Org.Apache.REEF.Driver/FailedJob.cs | 51 +
lang/cs/Org.Apache.REEF.Driver/IDriver.cs | 28 +
lang/cs/Org.Apache.REEF.Driver/IStartHandler.cs | 26 +
.../Org.Apache.REEF.Driver.csproj | 226 ++++
.../Properties/AssemblyInfo.cs | 55 +
.../bridge/BridgeLogger.cs | 65 +
.../bridge/ClrClientHelper.cs | 175 +++
.../bridge/ClrHandlerHelper.cs | 178 +++
.../bridge/ClrSystemHandler.cs | 53 +
.../bridge/ClrSystemHandlerWrapper.cs | 274 +++++
.../bridge/DriverBridge.cs | 321 +++++
.../bridge/DriverBridgeConfiguration.cs | 273 +++++
.../bridge/DriverBridgeConfigurationOptions.cs | 154 +++
.../bridge/HttpMessage.cs | 60 +
.../bridge/HttpServerHandler.cs | 165 +++
.../bridge/HttpServerPort.cs | 33 +
.../bridge/IHttpHandler.cs | 39 +
.../bridge/IHttpMessage.cs | 33 +
.../bridge/ReefHttpRequest.cs | 49 +
.../bridge/ReefHttpResponse.cs | 30 +
.../bridge/clr2java/IActiveContextClr2Java.cs | 36 +
.../clr2java/IAllocatedEvaluaotrClr2Java.cs | 42 +
.../bridge/clr2java/IClosedContextClr2Java.cs | 34 +
.../bridge/clr2java/IClr2Java.cs | 26 +
.../clr2java/ICompletedEvaluatorClr2Java.cs | 30 +
.../bridge/clr2java/ICompletedTaskClr2Java.cs | 28 +
.../bridge/clr2java/IContextMessageClr2Java.cs | 30 +
.../clr2java/IEvaluatorRequestorClr2Java.cs | 28 +
.../bridge/clr2java/IFailedContextClr2Java.cs | 36 +
.../bridge/clr2java/IFailedEvaluatorClr2Java.cs | 30 +
.../bridge/clr2java/IFailedTaskClr2Java.cs | 28 +
.../clr2java/IHttpServerBridgeClr2Java.cs | 34 +
.../bridge/clr2java/IRunningTaskClr2Java.cs | 30 +
.../bridge/clr2java/ISuspendedTaskClr2Java.cs | 42 +
.../bridge/clr2java/ITaskMessageClr2Java.cs | 26 +
.../bridge/events/ActiveContext.cs | 117 ++
.../bridge/events/AllocatedEvaluator.cs | 175 +++
.../bridge/events/ClosedContext.cs | 98 ++
.../bridge/events/CompletedEvaluator.cs | 60 +
.../bridge/events/CompletedTask.cs | 75 ++
.../bridge/events/ContextMessage.cs | 53 +
.../bridge/events/EvaluatorRequstor.cs | 95 ++
.../bridge/events/FailedContext.cs | 110 ++
.../bridge/events/FailedEvaluator.cs | 72 ++
.../bridge/events/FailedTask.cs | 140 +++
.../bridge/events/RunningTask.cs | 97 ++
.../bridge/events/SuspendedTask.cs | 81 ++
.../bridge/events/TaskMessage.cs | 64 +
.../context/ContextConfiguration.cs | 93 ++
.../context/ContextConfigurationOptions.cs | 60 +
.../context/EvaluatorContext.cs | 148 +++
.../context/IActiveContext.cs | 29 +
.../context/IClosedContext.cs | 26 +
.../Org.Apache.REEF.Driver/context/IContext.cs | 45 +
.../context/IFailedContext.cs | 28 +
.../defaults/DefaultContextMessageSource.cs | 42 +
.../defaults/DefaultContextStartHandler.cs | 48 +
.../defaults/DefaultContextStopHandler.cs | 48 +
.../contract/IBridgeContract.cs | 26 +
.../defaults/DefaultClientCloseHandler.cs | 53 +
.../DefaultClientCloseWithMessageHandler.cs | 54 +
.../defaults/DefaultClientMessageHandler.cs | 54 +
.../defaults/DefaultContextActiveHandler.cs | 56 +
.../defaults/DefaultContextClosureHandler.cs | 55 +
.../defaults/DefaultContextFailureHandler.cs | 51 +
.../defaults/DefaultContextMessageHandler.cs | 55 +
.../defaults/DefaultCustomTraceListener.cs | 45 +
.../DefaultDriverRestartContextActiveHandler.cs | 56 +
.../defaults/DefaultDriverRestartHandler.cs | 54 +
.../DefaultDriverRestartTaskRunningHandler.cs | 54 +
.../DefaultEvaluatorAllocationHandler.cs | 57 +
.../DefaultEvaluatorCompletionHandler.cs | 54 +
.../defaults/DefaultEvaluatorFailureHandler.cs | 55 +
.../DefaultEvaluatorRequestorHandler.cs | 61 +
.../defaults/DefaultHttpHandler.cs | 49 +
.../defaults/DefaultTaskCompletionHandler.cs | 60 +
.../defaults/DefaultTaskFailureHandler.cs | 53 +
.../defaults/DefaultTaskMessageHandler.cs | 55 +
.../defaults/DefaultTaskRunningHandler.cs | 54 +
.../defaults/DefaultTaskSuspensionHandler.cs | 53 +
.../evaluator/EvaluatorDescriptorImpl.cs | 218 ++++
.../evaluator/EvaluatorRequest.cs | 108 ++
.../evaluator/EvaluatorRequestBuilder.cs | 60 +
.../evaluator/IAllocatedEvaluator.cs | 55 +
.../evaluator/ICompletedEvaluator.cs | 30 +
.../evaluator/IEvaluatorDescriptor.cs | 57 +
.../evaluator/IEvaluatorRequest .cs | 42 +
.../evaluator/IEvaluatorRequestor.cs | 47 +
.../evaluator/IFailedEvaluator.cs | 41 +
lang/cs/Org.Apache.REEF.Driver/packages.config | 24 +
.../task/ICompletedTask.cs | 29 +
.../Org.Apache.REEF.Driver/task/IFailedTask.cs | 30 +
.../Org.Apache.REEF.Driver/task/IRunningTask.cs | 65 +
.../task/ISuspendedTask.cs | 29 +
.../Org.Apache.REEF.Driver/task/ITaskMessage.cs | 28 +
.../task/RunningTaskImpl.cs | 127 ++
.../AnonymousType.cs | 57 +
.../Org.Apache.REEF.Tang.Examples/CheckChild.cs | 37 +
.../DocumentedLocalNamedParameter.cs | 43 +
.../Org.Apache.REEF.Tang.Examples/FileNames.cs | 39 +
.../ForksInjectorInConstructor.cs | 60 +
.../GenericArgument.cs | 48 +
.../GenericAsArgument.cs | 44 +
.../NamedParameterConstructors.cs | 40 +
.../Org.Apache.REEF.Tang.Examples.csproj | 119 ++
.../Properties/AssemblyInfo.cs | 55 +
.../ShortNameFooAB.cs | 38 +
.../SimpleConstructors.cs | 42 +
.../TestClasses.cs | 57 +
lang/cs/Org.Apache.REEF.Tang.Examples/Timer.cs | 46 +
.../TweetExample.cs | 90 ++
.../ClassHierarchy/TestAnonymousType.cs | 64 +
.../ClassHierarchy/TestClassHierarchy.cs | 719 +++++++++++
.../TestClassHierarchyRoundTrip.cs | 70 ++
.../ClassHierarchy/TestGeneric.cs | 47 +
.../ClassHierarchy/TestMultipleInterface.cs | 104 ++
.../ClassHierarchy/TestParameterParser.cs | 325 +++++
.../ClassHierarchy/TestSerilization.cs | 236 ++++
.../Configuration/TestAvroConfiguration.cs | 69 ++
.../TestAvroSerializerRoundTrip.cs | 71 ++
.../Configuration/TestConfiguration.cs | 568 +++++++++
.../TestCsConfigurationBuilderExtension.cs | 179 +++
.../Format/TestConfigurationModule.cs | 523 ++++++++
.../Format/TestConfigurationModuleForList.cs | 146 +++
.../Format/TestTaskConfiguration.cs | 390 ++++++
.../Injection/TestAmbigousConstructors.cs | 81 ++
.../Injection/TestForkInjection.cs | 80 ++
.../Injection/TestInjection.cs | 388 ++++++
.../Injection/TestInjectionFuture.cs | 242 ++++
.../Injection/TestListInjection.cs | 566 +++++++++
.../Injection/TestMissingParameters.cs | 152 +++
.../Injection/TestMissingParamtersInNested.cs | 143 +++
.../Injection/TestMultipleConstructors.cs | 361 ++++++
.../Injection/TestNamedParameter.cs | 358 ++++++
.../Injection/TestSetInjection.cs | 740 +++++++++++
.../Org.Apache.REEF.Tang.Tests.csproj | 203 +++
.../Properties/AssemblyInfo.cs | 55 +
.../ScenarioTest/HttpHandlerConfiguration.cs | 35 +
.../ScenarioTest/HttpRuntimeConfiguration.cs | 36 +
.../ScenarioTest/HttpRuntimeStartHandler.cs | 50 +
.../ScenarioTest/HttpRuntimeStopHandler.cs | 50 +
.../ScenarioTest/HttpServer.cs | 49 +
.../ScenarioTest/IHttpHandler.cs | 27 +
.../ScenarioTest/JettyHandler.cs | 44 +
.../ScenarioTest/TestDefaultConstructor.cs | 80 ++
.../ScenarioTest/TestHttpService.cs | 195 +++
.../ScenarioTest/TestRuntimeClock.cs | 255 ++++
.../ScenarioTest/TestTrackingURIProvider.cs | 60 +
.../ScenarioTest/TrackingURIProvider.cs | 63 +
.../ScenarioTest/TrackingYRIProvider.cs | 25 +
.../SmokeTest/AnInterface.cs | 29 +
.../SmokeTest/AnInterfaceImplementation.cs | 65 +
.../SmokeTest/CyclicDependency.cs | 70 ++
.../SmokeTest/CyclicDependencyClassOne.cs | 61 +
.../SmokeTest/CyclicDependencyClassTwo.cs | 56 +
.../SmokeTest/Handler.cs | 26 +
.../SmokeTest/InjectableClass.cs | 60 +
.../SmokeTest/ListOfBaseTypes.cs | 108 ++
.../SmokeTest/ObjectTreeTest.cs | 55 +
.../SmokeTest/RootImplementation.cs | 178 +++
.../SmokeTest/RootInterface.cs | 26 +
.../SmokeTest/RoundTripTest.cs | 41 +
.../SmokeTest/SetInterface.cs | 31 +
.../SmokeTest/SetInterfaceImplOne.cs | 82 ++
.../SmokeTest/SetInterfaceImplTwo.cs | 82 ++
.../SmokeTest/SetOfBaseTypes.cs | 105 ++
.../SmokeTest/SetOfImplementations.cs | 72 ++
.../SmokeTest/TestConfigurationModuleBuilder.cs | 107 ++
.../Tang/TestDefaultImpementaion.cs | 197 +++
.../Tang/TestExternalConstructors.cs | 149 +++
.../Tang/TestLegacyConstructors.cs | 73 ++
.../Org.Apache.REEF.Tang.Tests/Tang/TestTang.cs | 1160 ++++++++++++++++++
.../Utilities/TestUtilities.cs | 294 +++++
.../Utilities/Utilities.cs | 62 +
.../Org.Apache.REEF.Tang.Tests/evaluator.conf | Bin 0 -> 2837 bytes
.../Org.Apache.REEF.Tang.Tests/packages.config | 24 +
.../simpleConstructorJavaProto.bin | Bin 0 -> 1994 bytes
.../Org.Apache.REEF.Tang.Tools.csproj | 119 ++
lang/cs/Org.Apache.REEF.Tang.Tools/Program.cs | 98 ++
.../Properties/AssemblyInfo.cs | 55 +
.../Annotations/DefaultImplementation.cs | 43 +
.../Org.Apache.REEF.Tang/Annotations/Inject.cs | 28 +
.../cs/Org.Apache.REEF.Tang/Annotations/Name.cs | 28 +
.../Annotations/NamedParameter.cs | 44 +
.../Annotations/Parameter.cs | 39 +
.../cs/Org.Apache.REEF.Tang/Annotations/Unit.cs | 29 +
.../Exceptions/BindException.cs | 36 +
.../Exceptions/ClassHierarchyException.cs | 34 +
.../Exceptions/IllegalStateException.cs | 40 +
.../Exceptions/InjectionException.cs | 35 +
.../Exceptions/NameResolutionException.cs | 37 +
.../Exceptions/ParseException.cs | 36 +
.../AvroConfiguration.cs | 47 +
.../ConfigurationEntry.cs | 44 +
.../Formats/AvroConfigurationSerializer.cs | 326 +++++
.../Formats/ConfigurationFile.cs | 373 ++++++
.../Formats/ConfigurationModule.cs | 302 +++++
.../Formats/ConfigurationModuleBuilder.cs | 520 ++++++++
.../Formats/IConfigurationSerializer.cs | 49 +
lang/cs/Org.Apache.REEF.Tang/Formats/IImpl.cs | 31 +
lang/cs/Org.Apache.REEF.Tang/Formats/IParam.cs | 31 +
.../Formats/OptionalImpl.cs | 31 +
.../Formats/OptionalParameter.cs | 31 +
.../cs/Org.Apache.REEF.Tang/Formats/Provides.cs | 31 +
.../Formats/RequiredImpl.cs | 31 +
.../Formats/RequiredParameter.cs | 31 +
.../ClassHierarchy/AbstractNode.cs | 131 ++
.../ClassHierarchy/ClassHierarchyImpl.cs | 526 ++++++++
.../ClassHierarchy/ClassNodeImpl.cs | 157 +++
.../ClassHierarchy/ConstructorArgImpl.cs | 97 ++
.../ClassHierarchy/ConstructorDefImpl.cs | 203 +++
.../ClassHierarchy/NamedParameterNodeImpl.cs | 88 ++
.../ClassHierarchy/NodeFactory.cs | 316 +++++
.../ClassHierarchy/PackageNodeImpl.cs | 49 +
.../ClassHierarchy/ParameterParser.cs | 199 +++
.../Configuration/ConfigurationBuilderImpl.cs | 366 ++++++
.../Configuration/ConfigurationImpl.cs | 122 ++
.../Configuration/Configurations.cs | 56 +
.../Configuration/CsConfigurationBuilderImpl.cs | 489 ++++++++
.../Configuration/CsConfigurationImpl.cs | 34 +
.../InjectionPlan/Constructor.cs | 217 ++++
.../Implementations/InjectionPlan/CsInstance.cs | 90 ++
.../InjectionPlan/InjectionFuture.cs | 100 ++
.../InjectionPlan/InjectionFuturePlan.cs | 73 ++
.../InjectionPlan/InjectionPlan.cs | 222 ++++
.../InjectionPlan/InjectorImpl.cs | 1092 +++++++++++++++++
.../InjectionPlan/ListInjectionPlan.cs | 117 ++
.../InjectionPlan/SetInjectionPlan.cs | 122 ++
.../Implementations/InjectionPlan/Subplan.cs | 235 ++++
.../Implementations/Tang/TangFactory.cs | 30 +
.../Implementations/Tang/TangImpl.cs | 204 +++
.../Org.Apache.REEF.Tang/Interface/IAspect.cs | 32 +
.../Interface/IClassHierarchy.cs | 30 +
.../Interface/IConfiguration.cs | 49 +
.../Interface/IConfigurationBuilder.cs | 54 +
.../Interface/ICsClassHierarchy.cs | 33 +
.../Interface/ICsConfigurationBuilder.cs | 121 ++
.../ICsInternalConfigurationBuilder.cs | 70 ++
.../Interface/IExternalConstructor.cs | 26 +
.../Org.Apache.REEF.Tang/Interface/IInjector.cs | 181 +++
lang/cs/Org.Apache.REEF.Tang/Interface/ITang.cs | 46 +
.../Org.Apache.REEF.Tang.csproj | 195 +++
.../Properties/AssemblyInfo.cs | 55 +
.../Protobuf/ProtocolBufferClassHierarchy.cs | 474 +++++++
.../Protobuf/ProtocolBufferInjectionPlan.cs | 205 ++++
.../Protobuf/class_hierarchy.cs | 274 +++++
.../Protobuf/injection_plan.cs | 132 ++
.../cs/Org.Apache.REEF.Tang/Types/IClassNode.cs | 37 +
.../Types/IConstructorArg.cs | 32 +
.../Types/IConstructorDef.cs | 34 +
.../Types/INamedParameterNode.cs | 38 +
lang/cs/Org.Apache.REEF.Tang/Types/INode.cs | 37 +
.../Org.Apache.REEF.Tang/Types/IPackageNode.cs | 24 +
.../Org.Apache.REEF.Tang/Types/ITraversable.cs | 27 +
.../Util/AbstractMonotonicMultiMap.cs | 263 ++++
.../Org.Apache.REEF.Tang/Util/AssemblyLoader.cs | 70 ++
.../cs/Org.Apache.REEF.Tang/Util/GenericType.cs | 49 +
.../Util/MonotonicHashMap.cs | 83 ++
.../Util/MonotonicHashSet.cs | 131 ++
.../Util/MonotonicMultiHashMap.cs | 30 +
.../Util/MonotonicMultiMap.cs | 30 +
.../Org.Apache.REEF.Tang/Util/MonotonicSet.cs | 106 ++
.../Util/MonotonicTreeMap.cs | 68 +
.../Util/ReflectionUtilities.cs | 594 +++++++++
.../Org.Apache.REEF.Tang/Util/SetValuedKey.cs | 62 +
lang/cs/Org.Apache.REEF.Tang/packages.config | 24 +
lang/cs/Org.Apache.REEF.Utilities/AvroUtils.cs | 61 +
.../Org.Apache.REEF.Utilities/ByteUtilities.cs | 45 +
.../Diagnostics/DiagnosticsMessages.cs | 42 +
.../Diagnostics/Exceptions.cs | 282 +++++
.../Org.Apache.REEF.Utilities/IIdentifiable.cs | 26 +
lang/cs/Org.Apache.REEF.Utilities/IMessage.cs | 33 +
.../Logging/JavaLoggingSetting.cs | 39 +
.../Org.Apache.REEF.Utilities/Logging/Level.cs | 59 +
.../Org.Apache.REEF.Utilities/Logging/Logger.cs | 227 ++++
.../Org.Apache.REEF.Utilities/NetUtilities.cs | 51 +
lang/cs/Org.Apache.REEF.Utilities/Optional.cs | 116 ++
.../Org.Apache.Reef.Utilities.csproj | 116 ++
.../Properties/AssemblyInfo.cs | 55 +
.../ValidationUtilities.cs | 42 +
.../Org.Apache.REEF.Utilities/packages.config | 23 +
lang/cs/Org.Apache.REEF.Wake.Tests/ClockTest.cs | 180 +++
.../MultiCodecTest.cs | 98 ++
.../Org.Apache.REEF.Wake.Tests.csproj | 124 ++
.../Properties/AssemblyInfo.cs | 55 +
.../PubSubSubjectTest.cs | 205 ++++
.../RemoteManagerTest.cs | 338 +++++
.../Org.Apache.REEF.Wake.Tests/TransportTest.cs | 201 +++
.../Org.Apache.REEF.Wake.Tests/packages.config | 23 +
lang/cs/Org.Apache.REEF.Wake/AbstractEStage.cs | 42 +
lang/cs/Org.Apache.REEF.Wake/IEStage.cs | 26 +
lang/cs/Org.Apache.REEF.Wake/IEventHandler.cs | 34 +
lang/cs/Org.Apache.REEF.Wake/IIdentifier.cs | 57 +
.../Org.Apache.REEF.Wake/IIdentifierFactory.cs | 35 +
.../cs/Org.Apache.REEF.Wake/IObserverFactory.cs | 32 +
lang/cs/Org.Apache.REEF.Wake/IStage.cs | 29 +
.../Impl/LoggingEventHandler.cs | 53 +
.../Impl/MissingStartHandlerHandler.cs | 49 +
.../Impl/MultiEventHandler.cs | 65 +
.../Org.Apache.REEF.Wake/Impl/PeriodicEvent.cs | 26 +
.../Impl/PubSubEventHandler.cs | 94 ++
.../Impl/SingleThreadStage.cs | 100 ++
lang/cs/Org.Apache.REEF.Wake/Impl/SyncStage.cs | 48 +
.../Impl/ThreadPoolStage.cs | 100 ++
lang/cs/Org.Apache.REEF.Wake/Impl/TimerStage.cs | 66 +
.../Org.Apache.REEF.Wake.csproj | 216 ++++
.../Properties/AssemblyInfo.cs | 55 +
.../Protobuf/RemoteProtocol.proto | 36 +
.../Protobuf/WakeRemoteProtosGen.cs | 96 ++
.../Org.Apache.REEF.Wake/RX/AbstractObserver.cs | 45 +
.../Org.Apache.REEF.Wake/RX/AbstractRxStage.cs | 54 +
lang/cs/Org.Apache.REEF.Wake/RX/IRxStage.cs | 28 +
.../RX/IStaticObservable.cs | 31 +
lang/cs/Org.Apache.REEF.Wake/RX/ISubject.cs | 31 +
.../RX/Impl/PubSubSubject.cs | 180 +++
.../Org.Apache.REEF.Wake/RX/Impl/RxSyncStage.cs | 70 ++
.../RX/Impl/RxThreadPoolStage.cs | 134 ++
.../RX/Impl/RxTimerStage.cs | 67 +
.../RX/Impl/SimpleSubject.cs | 59 +
.../RX/ObserverCompletedException.cs | 46 +
lang/cs/Org.Apache.REEF.Wake/Remote/ICodec.cs | 34 +
.../Remote/ICodecFactory.cs | 35 +
lang/cs/Org.Apache.REEF.Wake/Remote/IDecoder.cs | 38 +
lang/cs/Org.Apache.REEF.Wake/Remote/IEncoder.cs | 38 +
lang/cs/Org.Apache.REEF.Wake/Remote/ILink.cs | 73 ++
.../Org.Apache.REEF.Wake/Remote/IRemoteEvent.cs | 42 +
.../Remote/IRemoteIdentifier.cs | 28 +
.../Remote/IRemoteIdentifierFactory.cs | 26 +
.../Remote/IRemoteManager.cs | 42 +
.../Remote/IRemoteMessage.cs | 39 +
.../Remote/ISubscriptionManager.cs | 26 +
.../Remote/Impl/ByteCodec.cs | 41 +
.../Remote/Impl/ByteCodecFactory.cs | 41 +
.../Org.Apache.REEF.Wake/Remote/Impl/Channel.cs | 258 ++++
.../Remote/Impl/DefaultRemoteManager.cs | 338 +++++
.../Remote/Impl/DefaultRemoteMessage.cs | 34 +
.../Remote/Impl/IPEndpointComparer.cs | 59 +
.../Remote/Impl/IntCodec.cs | 42 +
.../cs/Org.Apache.REEF.Wake/Remote/Impl/Link.cs | 256 ++++
.../Remote/Impl/MultiCodec.cs | 89 ++
.../Remote/Impl/MultiDecoder.cs | 110 ++
.../Remote/Impl/MultiEncoder.cs | 87 ++
.../Remote/Impl/ObserverContainer.cs | 132 ++
.../Remote/Impl/RemoteEvent.cs | 59 +
.../Remote/Impl/RemoteEventCodec.cs | 43 +
.../Remote/Impl/RemoteEventDecoder.cs | 39 +
.../Remote/Impl/RemoteEventEncoder.cs | 43 +
.../Remote/Impl/RemoteEventEndpoint.cs | 42 +
.../Remote/Impl/SocketRemoteIdentifier.cs | 76 ++
.../Remote/Impl/StringCodec.cs | 46 +
.../Remote/Impl/StringIdentifier.cs | 53 +
.../Remote/Impl/StringIdentifierFactory.cs | 41 +
.../Remote/Impl/TransportClient.cs | 133 ++
.../Remote/Impl/TransportEvent.cs | 42 +
.../Remote/Impl/TransportServer.cs | 195 +++
.../Remote/Proto/WakeRemoteProtos.cs | 76 ++
.../Remote/RemoteConfiguration.cs | 57 +
.../Remote/RemoteRuntimeException.cs | 54 +
.../cs/Org.Apache.REEF.Wake/Time/Event/Alarm.cs | 41 +
.../Time/Event/StartTime.cs | 31 +
.../Org.Apache.REEF.Wake/Time/Event/StopTime.cs | 31 +
lang/cs/Org.Apache.REEF.Wake/Time/IClock.cs | 89 ++
.../Time/Runtime/Event/ClientAlarm.cs | 34 +
.../Time/Runtime/Event/IdleClock.cs | 28 +
.../Time/Runtime/Event/RuntimeAlarm.cs | 34 +
.../Time/Runtime/Event/RuntimeStart.cs | 28 +
.../Time/Runtime/Event/RuntimeStop.cs | 37 +
.../Org.Apache.REEF.Wake/Time/Runtime/ITimer.cs | 49 +
.../Time/Runtime/LogicalTimer.cs | 55 +
.../Time/Runtime/RealTimer.cs | 64 +
.../Time/Runtime/RuntimeClock.cs | 258 ++++
lang/cs/Org.Apache.REEF.Wake/Time/Time.cs | 82 ++
lang/cs/Org.Apache.REEF.Wake/Util/Actionable.cs | 42 +
lang/cs/Org.Apache.REEF.Wake/Util/Disposable.cs | 63 +
.../Util/FixedThreadPoolTaskService.cs | 105 ++
lang/cs/Org.Apache.REEF.Wake/Util/IStartable.cs | 32 +
.../Org.Apache.REEF.Wake/Util/ITaskService.cs | 34 +
.../LimitedConcurrencyLevelTaskScheduler.cs | 187 +++
.../Org.Apache.REEF.Wake/Util/NetworkUtils.cs | 66 +
.../Util/SerializationHelper.cs | 46 +
.../Org.Apache.REEF.Wake/Util/TaskExtensions.cs | 34 +
lang/cs/Org.Apache.REEF.Wake/Util/TimeHelper.cs | 49 +
.../WakeRuntimeException.cs | 54 +
lang/cs/Org.Apache.REEF.Wake/packages.config | 24 +
.../src/main/cs/Examples/P2p/IEventSource.cs | 35 +
.../src/main/cs/Examples/P2p/Pull2Push.cs | 103 ++
.../src/main/cs/PeriodicEvent.cs | 23 +
lang/cs/Org.Apache.REEF.Wake/testkey.snk | Bin 0 -> 596 bytes
lang/cs/ReefDotNet.sln | 165 +--
.../CLRBridgeClient/CLRBridgeClient.cs | 26 +-
.../CLRBridgeClient/CLRBridgeClient.csproj | 38 +-
.../reef-applications/Evaluator/Evaluator.cs | 39 +-
.../Evaluator/Evaluator.csproj | 26 +-
.../ReefCommon/ClientJobStatusHandler.cs | 142 ---
.../REEF/reef-common/ReefCommon/Constants.cs | 38 -
.../EvaluatorHeartBeatSanityChecker.cs | 55 -
.../reef-common/ReefCommon/FailedRuntime.cs | 49 -
.../ReefCommon/IContextAndTaskSubmittable.cs | 55 -
.../ReefCommon/IContextSubmittable.cs | 42 -
.../ReefCommon/IJobMessageObserver.cs | 30 -
.../reef-common/ReefCommon/ITaskSubmittable.cs | 35 -
.../ReefCommon/Properties/AssemblyInfo.cs | 55 -
.../reef-common/ReefCommon/ReefCommon.csproj | 233 ----
.../ReefCommon/api/AbstractFailure.cs | 142 ---
.../ReefCommon/api/IAbstractFailure.cs | 25 -
.../REEF/reef-common/ReefCommon/api/IFailure.cs | 57 -
.../ReefCommon/api/IResourceLaunchHandler.cs | 28 -
.../ReefCommon/api/IResourceReleaseHandler.cs | 28 -
.../ReefCommon/api/IResourceRequestHandler.cs | 28 -
.../ReefCommon/avro/AvroDriverInfo.cs | 65 -
.../ReefCommon/avro/AvroHttpRequest.cs | 79 --
.../ReefCommon/avro/AvroHttpSerializer.cs | 36 -
.../ReefCommon/avro/AvroJsonSerializer.cs | 52 -
.../ReefCommon/avro/AvroReefServiceInfo.cs | 55 -
.../ReefCommon/catalog/INodeDescriptor.cs | 36 -
.../ReefCommon/catalog/IRackDescriptor.cs | 25 -
.../ReefCommon/catalog/IResourceCatalog.cs | 37 -
.../ReefCommon/catalog/NodeDescriptorImpl.cs | 116 --
.../ReefCommon/catalog/RackDescriptorImpl.cs | 75 --
.../ReefCommon/catalog/ResourceCatalogImpl.cs | 95 --
.../ReefCommon/catalog/capabilities/CPU.cs | 60 -
.../catalog/capabilities/ICapability.cs | 25 -
.../ReefCommon/catalog/capabilities/RAM.cs | 51 -
.../ReefCommon/context/ContextMessage.cs | 66 -
.../ReefCommon/context/IContextMessage.cs | 28 -
.../context/IContextMessageHandler.cs | 27 -
.../ReefCommon/context/IContextMessageSource.cs | 28 -
.../DefaultLocalHttpDriverConnection.cs | 45 -
.../DefaultYarnClusterHttpDriverConnection.cs | 44 -
.../DefaultYarnOneBoxHttpDriverConnection.cs | 46 -
.../ReefCommon/evaluator/DriverInformation.cs | 136 --
.../evaluator/EvaluatorOperationState.cs | 39 -
.../evaluator/EvaluatorRuntimeState.cs | 39 -
.../ReefCommon/evaluator/EvaluatorType.cs | 39 -
.../ReefCommon/evaluator/IDriverConnection.cs | 26 -
.../ReefCommon/events/IContextStart.cs | 26 -
.../ReefCommon/events/IContextStop.cs | 26 -
.../ReefCommon/exceptions/EvaluatorException.cs | 75 --
.../ReefCommon/exceptions/JobException.cs | 58 -
.../reef-common/ReefCommon/io/INameClient.cs | 71 --
.../reef-common/ReefCommon/io/NameAssignment.cs | 60 -
.../ReefCommon/io/NamingConfiguration.cs | 45 -
.../ReefCommon/io/NamingConfigurationOptions.cs | 36 -
.../REEF/reef-common/ReefCommon/packages.config | 26 -
.../ReefCommon/protobuf/cs/ClientRuntime.pb.cs | 147 ---
.../ReefCommon/protobuf/cs/DriverRuntime.pb.cs | 339 -----
.../protobuf/cs/EvaluatorRunTime.pb.cs | 305 -----
.../ReefCommon/protobuf/cs/ReefProtocol.pb.cs | 78 --
.../ReefCommon/protobuf/cs/ReefService.pb.cs | 393 ------
.../ReefCommon/protobuf/cs/Serializer.cs | 130 --
.../cs/codec/EvaluatorHeartbeatProtoCodec.cs | 41 -
.../protobuf/cs/codec/REEFMessageCodec.cs | 37 -
.../protobuf/proto/client_runtime.proto | 56 -
.../protobuf/proto/driver_runtime.proto | 90 --
.../protobuf/proto/evaluator_runtime.proto | 91 --
.../protobuf/proto/reef_protocol.proto | 44 -
.../protobuf/proto/reef_service_protos.proto | 117 --
.../ReefCommon/runtime/MachineStatus.cs | 137 ---
.../ReefCommon/runtime/evaluator/Constants.cs | 40 -
.../runtime/evaluator/EvaluatorRuntime.cs | 255 ----
.../runtime/evaluator/EvaluatorSettings.cs | 185 ---
.../runtime/evaluator/HeartBeatManager.cs | 390 ------
.../evaluator/ReefMessageProtoObserver.cs | 140 ---
.../context/ContextClientCodeException.cs | 70 --
.../evaluator/context/ContextConfiguration.cs | 140 ---
.../evaluator/context/ContextLifeCycle.cs | 105 --
.../runtime/evaluator/context/ContextManager.cs | 362 ------
.../runtime/evaluator/context/ContextRuntime.cs | 478 --------
.../evaluator/context/ContextStartImpl.cs | 33 -
.../evaluator/context/ContextStopImpl.cs | 33 -
.../evaluator/context/RootContextLauncher.cs | 125 --
.../runtime/evaluator/task/CloseEventImpl.cs | 48 -
.../runtime/evaluator/task/DriverMessageImpl.cs | 52 -
.../runtime/evaluator/task/SuspendEventImpl.cs | 48 -
.../evaluator/task/TaskClientCodeException.cs | 65 -
.../runtime/evaluator/task/TaskLifeCycle.cs | 69 --
.../runtime/evaluator/task/TaskRuntime.cs | 328 -----
.../runtime/evaluator/task/TaskStartImpl.cs | 34 -
.../runtime/evaluator/task/TaskState.cs | 40 -
.../runtime/evaluator/task/TaskStatus.cs | 330 -----
.../runtime/evaluator/task/TaskStopImpl.cs | 35 -
.../evaluator/utils/EvaluatorConfigurations.cs | 121 --
.../runtime/evaluator/utils/RemoteManager.cs | 25 -
.../reef-common/ReefCommon/services/IService.cs | 25 -
.../ReefCommon/services/ServiceConfiguration.cs | 83 --
.../services/ServicesConfigurationOptions.cs | 31 -
.../ReefCommon/tasks/IDriverMessageHandler.cs | 31 -
.../ReefCommon/tasks/IRunningTask.cs | 53 -
.../REEF/reef-common/ReefCommon/tasks/ITask.cs | 28 -
.../ReefCommon/tasks/ITaskMessageSource.cs | 31 -
.../ReefCommon/tasks/TaskConfiguration.cs | 148 ---
.../tasks/TaskConfigurationOptions.cs | 69 --
.../reef-common/ReefCommon/tasks/TaskMessage.cs | 68 -
.../defaults/DefaultDriverMessageHandler.cs | 42 -
.../tasks/defaults/DefaultTaskMessageSource.cs | 49 -
.../ReefCommon/tasks/events/ICloseEvent.cs | 28 -
.../ReefCommon/tasks/events/IDriverMessage.cs | 28 -
.../ReefCommon/tasks/events/ISuspendEvent.cs | 25 -
.../ReefCommon/tasks/events/ITaskStart.cs | 26 -
.../ReefCommon/tasks/events/ITaskStop.cs | 26 -
.../reef-common/ReefDriver/ClientManager.cs | 43 -
.../REEF/reef-common/ReefDriver/Constants.cs | 114 --
.../ReefDriver/DriverConfigGenerator.cs | 151 ---
.../ReefDriver/DriverConfigurationSettings.cs | 135 --
.../reef-common/ReefDriver/DriverManager.cs | 540 --------
.../ReefDriver/DriverRuntimeConfiguration.cs | 64 -
.../DriverRuntimeConfigurationOptions.cs | 42 -
.../ReefDriver/DriverSubmissionSettings.cs | 185 ---
.../reef-common/ReefDriver/EvaluatorManager.cs | 655 ----------
.../REEF/reef-common/ReefDriver/FailedJob.cs | 51 -
.../REEF/reef-common/ReefDriver/IDriver.cs | 28 -
.../reef-common/ReefDriver/IStartHandler.cs | 26 -
.../ReefDriver/Properties/AssemblyInfo.cs | 55 -
.../reef-common/ReefDriver/ReefDriver.csproj | 226 ----
.../ReefDriver/bridge/BridgeLogger.cs | 65 -
.../ReefDriver/bridge/ClrClientHelper.cs | 175 ---
.../ReefDriver/bridge/ClrHandlerHelper.cs | 177 ---
.../ReefDriver/bridge/ClrSystemHandler.cs | 53 -
.../bridge/ClrSystemHandlerWrapper.cs | 273 -----
.../ReefDriver/bridge/DriverBridge.cs | 321 -----
.../bridge/DriverBridgeConfiguration.cs | 273 -----
.../bridge/DriverBridgeConfigurationOptions.cs | 154 ---
.../ReefDriver/bridge/HttpMessage.cs | 60 -
.../ReefDriver/bridge/HttpServerHandler.cs | 165 ---
.../ReefDriver/bridge/HttpServerPort.cs | 33 -
.../ReefDriver/bridge/IHttpHandler.cs | 39 -
.../ReefDriver/bridge/IHttpMessage.cs | 33 -
.../ReefDriver/bridge/ReefHttpRequest.cs | 49 -
.../ReefDriver/bridge/ReefHttpResponse.cs | 30 -
.../bridge/clr2java/IActiveContextClr2Java.cs | 36 -
.../clr2java/IAllocatedEvaluaotrClr2Java.cs | 42 -
.../bridge/clr2java/IClosedContextClr2Java.cs | 34 -
.../ReefDriver/bridge/clr2java/IClr2Java.cs | 26 -
.../clr2java/ICompletedEvaluatorClr2Java.cs | 30 -
.../bridge/clr2java/ICompletedTaskClr2Java.cs | 28 -
.../bridge/clr2java/IContextMessageClr2Java.cs | 30 -
.../clr2java/IEvaluatorRequestorClr2Java.cs | 28 -
.../bridge/clr2java/IFailedContextClr2Java.cs | 36 -
.../bridge/clr2java/IFailedEvaluatorClr2Java.cs | 30 -
.../bridge/clr2java/IFailedTaskClr2Java.cs | 28 -
.../clr2java/IHttpServerBridgeClr2Java.cs | 34 -
.../bridge/clr2java/IRunningTaskClr2Java.cs | 30 -
.../bridge/clr2java/ISuspendedTaskClr2Java.cs | 42 -
.../bridge/clr2java/ITaskMessageClr2Java.cs | 26 -
.../ReefDriver/bridge/events/ActiveContext.cs | 117 --
.../bridge/events/AllocatedEvaluator.cs | 175 ---
.../ReefDriver/bridge/events/ClosedContext.cs | 98 --
.../bridge/events/CompletedEvaluator.cs | 60 -
.../ReefDriver/bridge/events/CompletedTask.cs | 75 --
.../ReefDriver/bridge/events/ContextMessage.cs | 53 -
.../bridge/events/EvaluatorRequstor.cs | 95 --
.../ReefDriver/bridge/events/FailedContext.cs | 110 --
.../ReefDriver/bridge/events/FailedEvaluator.cs | 72 --
.../ReefDriver/bridge/events/FailedTask.cs | 140 ---
.../ReefDriver/bridge/events/RunningTask.cs | 97 --
.../ReefDriver/bridge/events/SuspendedTask.cs | 81 --
.../ReefDriver/bridge/events/TaskMessage.cs | 64 -
.../ReefDriver/context/ContextConfiguration.cs | 93 --
.../context/ContextConfigurationOptions.cs | 60 -
.../ReefDriver/context/EvaluatorContext.cs | 148 ---
.../ReefDriver/context/IActiveContext.cs | 29 -
.../ReefDriver/context/IClosedContext.cs | 26 -
.../reef-common/ReefDriver/context/IContext.cs | 45 -
.../ReefDriver/context/IFailedContext.cs | 28 -
.../defaults/DefaultContextMessageSource.cs | 42 -
.../defaults/DefaultContextStartHandler.cs | 48 -
.../defaults/DefaultContextStopHandler.cs | 48 -
.../ReefDriver/contract/IBridgeContract.cs | 26 -
.../defaults/DefaultClientCloseHandler.cs | 53 -
.../DefaultClientCloseWithMessageHandler.cs | 54 -
.../defaults/DefaultClientMessageHandler.cs | 54 -
.../defaults/DefaultContextActiveHandler.cs | 56 -
.../defaults/DefaultContextClosureHandler.cs | 55 -
.../defaults/DefaultContextFailureHandler.cs | 51 -
.../defaults/DefaultContextMessageHandler.cs | 55 -
.../defaults/DefaultCustomTraceListener.cs | 45 -
.../DefaultDriverRestartContextActiveHandler.cs | 56 -
.../defaults/DefaultDriverRestartHandler.cs | 54 -
.../DefaultDriverRestartTaskRunningHandler.cs | 54 -
.../DefaultEvaluatorAllocationHandler.cs | 57 -
.../DefaultEvaluatorCompletionHandler.cs | 54 -
.../defaults/DefaultEvaluatorFailureHandler.cs | 55 -
.../DefaultEvaluatorRequestorHandler.cs | 61 -
.../ReefDriver/defaults/DefaultHttpHandler.cs | 49 -
.../defaults/DefaultTaskCompletionHandler.cs | 60 -
.../defaults/DefaultTaskFailureHandler.cs | 53 -
.../defaults/DefaultTaskMessageHandler.cs | 55 -
.../defaults/DefaultTaskRunningHandler.cs | 54 -
.../defaults/DefaultTaskSuspensionHandler.cs | 53 -
.../evaluator/EvaluatorDescriptorImpl.cs | 218 ----
.../ReefDriver/evaluator/EvaluatorRequest.cs | 108 --
.../evaluator/EvaluatorRequestBuilder.cs | 60 -
.../ReefDriver/evaluator/IAllocatedEvaluator.cs | 55 -
.../ReefDriver/evaluator/ICompletedEvaluator.cs | 30 -
.../evaluator/IEvaluatorDescriptor.cs | 57 -
.../ReefDriver/evaluator/IEvaluatorRequest .cs | 42 -
.../ReefDriver/evaluator/IEvaluatorRequestor.cs | 47 -
.../ReefDriver/evaluator/IFailedEvaluator.cs | 41 -
.../REEF/reef-common/ReefDriver/packages.config | 24 -
.../ReefDriver/task/ICompletedTask.cs | 29 -
.../reef-common/ReefDriver/task/IFailedTask.cs | 30 -
.../reef-common/ReefDriver/task/IRunningTask.cs | 65 -
.../ReefDriver/task/ISuspendedTask.cs | 29 -
.../reef-common/ReefDriver/task/ITaskMessage.cs | 28 -
.../ReefDriver/task/RunningTaskImpl.cs | 127 --
.../HelloCLRBridge/HelloCLRBridge.csproj | 40 +-
.../HelloCLRBridge/HelloTraceListener.cs | 4 +-
.../AnotherHelloAllocatedEvaluatorHandler.cs | 6 +-
.../handlers/HelloActiveContextHandler.cs | 16 +-
.../handlers/HelloAllocatedEvaluatorHandler.cs | 28 +-
.../handlers/HelloCompletedEvaluatorHandler.cs | 12 +-
.../HelloDriverRestartActiveContextHandler.cs | 8 +-
.../HelloDriverRestartRunningTaskHandler.cs | 10 +-
.../handlers/HelloEvaluatorRequestorHandler.cs | 8 +-
.../handlers/HelloFailedEvaluatorHandler.cs | 8 +-
.../handlers/HelloFailedTaskHandler.cs | 8 +-
.../HelloCLRBridge/handlers/HelloHttpHandler.cs | 10 +-
.../handlers/HelloRestartHandler.cs | 6 +-
.../handlers/HelloRunningTaskHandler.cs | 10 +-
.../handlers/HelloSimpleEventHandlers.cs | 30 +-
.../handlers/HelloStartHandler.cs | 18 +-
.../handlers/HelloTaskMessageHandler.cs | 6 +-
.../RetainedEvalCLRBridge.csproj | 28 +-
.../handler/RetainedEvalActiveContextHandler.cs | 13 +-
.../RetainedEvalAllocatedEvaluatorHandler.cs | 8 +-
.../RetainedEvalEvaluatorRequestorHandler.cs | 6 +-
.../handler/RetainedEvalStartHandler.cs | 18 +-
.../Naming/Codec/NamingLookupRequestCodec.cs | 8 +-
.../Naming/Codec/NamingLookupResponseCodec.cs | 10 +-
.../Naming/Codec/NamingRegisterRequestCodec.cs | 10 +-
.../Naming/Codec/NamingRegisterResponseCodec.cs | 6 +-
.../Codec/NamingUnregisterRequestCodec.cs | 8 +-
.../Network/Naming/Events/NamingEvent.cs | 4 +-
.../Naming/Events/NamingGetAllRequest.cs | 2 +-
.../Naming/Events/NamingGetAllResponse.cs | 4 +-
.../Naming/Events/NamingLookupRequest.cs | 2 +-
.../Naming/Events/NamingLookupResponse.cs | 4 +-
.../Naming/Events/NamingRegisterRequest.cs | 4 +-
.../Naming/Events/NamingRegisterResponse.cs | 2 +-
.../Naming/Events/NamingUnregisterRequest.cs | 2 +-
.../Naming/Events/NamingUnregisterResponse.cs | 2 +-
.../REEF/reef-io/Network/Naming/INameServer.cs | 8 +-
.../REEF/reef-io/Network/Naming/NameClient.cs | 24 +-
.../reef-io/Network/Naming/NameLookupClient.cs | 8 +-
.../Network/Naming/NameRegisterClient.cs | 8 +-
.../REEF/reef-io/Network/Naming/NameServer.cs | 24 +-
.../Network/Naming/NamingConfiguration.cs | 6 +-
.../Naming/NamingConfigurationOptions.cs | 4 +-
.../Observers/NamingGetAllRequestObserver.cs | 8 +-
.../Observers/NamingLookupRequestObserver.cs | 8 +-
.../Observers/NamingRegisterRequestObserver.cs | 8 +-
.../NamingUnregisterRequestObserver.cs | 6 +-
.../Source/REEF/reef-io/Network/Network.csproj | 29 +-
.../NetworkService/Codec/ControlMessageCodec.cs | 6 +-
.../NetworkService/Codec/NsMessageCodec.cs | 6 +-
.../NetworkService/Codec/NsMessageProto.cs | 4 +-
.../Network/NetworkService/ControlMessage.cs | 2 +-
.../Network/NetworkService/IConnection.cs | 2 +-
.../Network/NetworkService/INetworkService.cs | 10 +-
.../Network/NetworkService/NetworkService.cs | 24 +-
.../NetworkServiceConfiguration.cs | 12 +-
.../NetworkService/NetworkServiceOptions.cs | 8 +-
.../Network/NetworkService/NsConnection.cs | 12 +-
.../reef-io/Network/NetworkService/NsMessage.cs | 4 +-
.../Utilities/BlockingCollectionExtensions.cs | 2 +-
.../REEF/reef-io/Network/Utilities/Utils.cs | 16 +-
.../reef-tasks/Tasks/FailedTask/FailedTask.cs | 4 +-
.../reef-tasks/Tasks/HelloTask/HelloService.cs | 6 +-
.../reef-tasks/Tasks/HelloTask/HelloTask.cs | 12 +-
.../Tasks/HelloTask/HelloTaskMessage.cs | 6 +-
.../reef-tasks/Tasks/ShellTask/ShellTask.cs | 8 +-
.../Tasks/StreamingTasks/StreamTask1.cs | 4 +-
.../Tasks/StreamingTasks/StreamTask2.cs | 4 +-
.../Source/REEF/reef-tasks/Tasks/Tasks.csproj | 18 +-
lang/cs/Source/TANG/Examples/AnonymousType.cs | 57 -
lang/cs/Source/TANG/Examples/CheckChild.cs | 37 -
.../Examples/DocumentedLocalNamedParameter.cs | 43 -
lang/cs/Source/TANG/Examples/Examples.csproj | 115 --
lang/cs/Source/TANG/Examples/FileNames.cs | 39 -
.../TANG/Examples/ForksInjectorInConstructor.cs | 59 -
lang/cs/Source/TANG/Examples/GenericArgument.cs | 48 -
.../Source/TANG/Examples/GenericAsArgument.cs | 44 -
.../TANG/Examples/NamedParameterConstructors.cs | 40 -
.../TANG/Examples/Properties/AssemblyInfo.cs | 55 -
lang/cs/Source/TANG/Examples/ShortNameFooAB.cs | 38 -
.../Source/TANG/Examples/SimpleConstructors.cs | 42 -
lang/cs/Source/TANG/Examples/TestClasses.cs | 57 -
lang/cs/Source/TANG/Examples/Timer.cs | 46 -
lang/cs/Source/TANG/Examples/TweetExample.cs | 90 --
.../Tang/Annotations/DefaultImplementation.cs | 43 -
lang/cs/Source/TANG/Tang/Annotations/Inject.cs | 28 -
lang/cs/Source/TANG/Tang/Annotations/Name.cs | 28 -
.../TANG/Tang/Annotations/NamedParameter.cs | 44 -
.../Source/TANG/Tang/Annotations/Parameter.cs | 39 -
lang/cs/Source/TANG/Tang/Annotations/Unit.cs | 29 -
.../TANG/Tang/Exceptions/BindException.cs | 36 -
.../Tang/Exceptions/ClassHierarchyException.cs | 34 -
.../Tang/Exceptions/IllegalStateException.cs | 40 -
.../TANG/Tang/Exceptions/InjectionException.cs | 35 -
.../Tang/Exceptions/NameResolutionException.cs | 37 -
.../TANG/Tang/Exceptions/ParseException.cs | 36 -
.../AvroConfiguration.cs | 47 -
.../ConfigurationEntry.cs | 44 -
.../Tang/Formats/AvroConfigurationSerializer.cs | 324 -----
.../TANG/Tang/Formats/ConfigurationFile.cs | 371 ------
.../TANG/Tang/Formats/ConfigurationModule.cs | 302 -----
.../Tang/Formats/ConfigurationModuleBuilder.cs | 519 --------
.../Tang/Formats/IConfigurationSerializer.cs | 49 -
lang/cs/Source/TANG/Tang/Formats/IImpl.cs | 31 -
lang/cs/Source/TANG/Tang/Formats/IParam.cs | 31 -
.../cs/Source/TANG/Tang/Formats/OptionalImpl.cs | 31 -
.../TANG/Tang/Formats/OptionalParameter.cs | 31 -
lang/cs/Source/TANG/Tang/Formats/Provides.cs | 31 -
.../cs/Source/TANG/Tang/Formats/RequiredImpl.cs | 31 -
.../TANG/Tang/Formats/RequiredParameter.cs | 31 -
.../ClassHierarchy/AbstractNode.cs | 131 --
.../ClassHierarchy/ClassHierarchyImpl.cs | 526 --------
.../ClassHierarchy/ClassNodeImpl.cs | 157 ---
.../ClassHierarchy/ConstructorArgImpl.cs | 97 --
.../ClassHierarchy/ConstructorDefImpl.cs | 203 ---
.../ClassHierarchy/NamedParameterNodeImpl.cs | 88 --
.../ClassHierarchy/NodeFactory.cs | 315 -----
.../ClassHierarchy/PackageNodeImpl.cs | 49 -
.../ClassHierarchy/ParameterParser.cs | 199 ---
.../Configuration/ConfigurationBuilderImpl.cs | 364 ------
.../Configuration/ConfigurationImpl.cs | 122 --
.../Configuration/Configurations.cs | 55 -
.../Configuration/CsConfigurationBuilderImpl.cs | 489 --------
.../Configuration/CsConfigurationImpl.cs | 34 -
.../InjectionPlan/Constructor.cs | 217 ----
.../Implementations/InjectionPlan/CsInstance.cs | 90 --
.../InjectionPlan/InjectionFuture.cs | 100 --
.../InjectionPlan/InjectionFuturePlan.cs | 73 --
.../InjectionPlan/InjectionPlan.cs | 222 ----
.../InjectionPlan/InjectorImpl.cs | 1091 ----------------
.../InjectionPlan/ListInjectionPlan.cs | 117 --
.../InjectionPlan/SetInjectionPlan.cs | 122 --
.../Implementations/InjectionPlan/Subplan.cs | 235 ----
.../Tang/Implementations/Tang/TangFactory.cs | 30 -
.../TANG/Tang/Implementations/Tang/TangImpl.cs | 201 ---
lang/cs/Source/TANG/Tang/Interface/IAspect.cs | 31 -
.../TANG/Tang/Interface/IClassHierarchy.cs | 30 -
.../TANG/Tang/Interface/IConfiguration.cs | 49 -
.../Tang/Interface/IConfigurationBuilder.cs | 54 -
.../TANG/Tang/Interface/ICsClassHierarchy.cs | 33 -
.../Tang/Interface/ICsConfigurationBuilder.cs | 121 --
.../ICsInternalConfigurationBuilder.cs | 70 --
.../TANG/Tang/Interface/IExternalConstructor.cs | 26 -
lang/cs/Source/TANG/Tang/Interface/IInjector.cs | 180 ---
lang/cs/Source/TANG/Tang/Interface/ITang.cs | 46 -
.../Source/TANG/Tang/Properties/AssemblyInfo.cs | 55 -
.../Protobuf/ProtocolBufferClassHierarchy.cs | 473 -------
.../Protobuf/ProtocolBufferInjectionPlan.cs | 204 ---
.../TANG/Tang/Protobuf/class_hierarchy.cs | 274 -----
.../Source/TANG/Tang/Protobuf/injection_plan.cs | 132 --
lang/cs/Source/TANG/Tang/Tang.csproj | 195 ---
lang/cs/Source/TANG/Tang/Types/IClassNode.cs | 37 -
.../Source/TANG/Tang/Types/IConstructorArg.cs | 32 -
.../Source/TANG/Tang/Types/IConstructorDef.cs | 34 -
.../TANG/Tang/Types/INamedParameterNode.cs | 38 -
lang/cs/Source/TANG/Tang/Types/INode.cs | 37 -
lang/cs/Source/TANG/Tang/Types/IPackageNode.cs | 24 -
lang/cs/Source/TANG/Tang/Types/ITraversable.cs | 27 -
.../TANG/Tang/Util/AbstractMonotonicMultiMap.cs | 263 ----
lang/cs/Source/TANG/Tang/Util/AssemblyLoader.cs | 70 --
lang/cs/Source/TANG/Tang/Util/GenericType.cs | 49 -
.../Source/TANG/Tang/Util/MonotonicHashMap.cs | 83 --
.../Source/TANG/Tang/Util/MonotonicHashSet.cs | 131 --
.../TANG/Tang/Util/MonotonicMultiHashMap.cs | 30 -
.../Source/TANG/Tang/Util/MonotonicMultiMap.cs | 30 -
lang/cs/Source/TANG/Tang/Util/MonotonicSet.cs | 106 --
.../Source/TANG/Tang/Util/MonotonicTreeMap.cs | 68 -
.../TANG/Tang/Util/ReflectionUtilities.cs | 594 ---------
lang/cs/Source/TANG/Tang/Util/SetValuedKey.cs | 62 -
lang/cs/Source/TANG/Tang/packages.config | 24 -
.../ClassHierarchyBuilder.csproj | 107 --
.../Tools/ClassHierarchyBuilder/Program.cs | 97 --
.../Properties/AssemblyInfo.cs | 55 -
lang/cs/Source/Tools/ReefAll/ReefAll.csproj | 31 +-
lang/cs/Source/Utilities/AvroUtils.cs | 61 -
lang/cs/Source/Utilities/ByteUtilities.cs | 45 -
.../Diagnostics/DiagnosticsMessages.cs | 42 -
.../Source/Utilities/Diagnostics/Exceptions.cs | 282 -----
lang/cs/Source/Utilities/IIdentifiable.cs | 26 -
lang/cs/Source/Utilities/IMessage.cs | 33 -
.../Utilities/Logging/JavaLoggingSetting.cs | 39 -
lang/cs/Source/Utilities/Logging/Level.cs | 59 -
lang/cs/Source/Utilities/Logging/Logger.cs | 227 ----
lang/cs/Source/Utilities/NetUtilities.cs | 51 -
lang/cs/Source/Utilities/Optional.cs | 116 --
.../Source/Utilities/Properties/AssemblyInfo.cs | 55 -
lang/cs/Source/Utilities/Utilities.csproj | 116 --
lang/cs/Source/Utilities/ValidationUtilities.cs | 42 -
lang/cs/Source/Utilities/packages.config | 23 -
lang/cs/Source/WAKE/Wake/AbstractEStage.cs | 42 -
lang/cs/Source/WAKE/Wake/IEStage.cs | 26 -
lang/cs/Source/WAKE/Wake/IEventHandler.cs | 34 -
lang/cs/Source/WAKE/Wake/IIdentifier.cs | 57 -
lang/cs/Source/WAKE/Wake/IIdentifierFactory.cs | 35 -
lang/cs/Source/WAKE/Wake/IObserverFactory.cs | 32 -
lang/cs/Source/WAKE/Wake/IStage.cs | 29 -
.../WAKE/Wake/Impl/LoggingEventHandler.cs | 53 -
.../Wake/Impl/MissingStartHandlerHandler.cs | 49 -
.../Source/WAKE/Wake/Impl/MultiEventHandler.cs | 65 -
lang/cs/Source/WAKE/Wake/Impl/PeriodicEvent.cs | 26 -
.../Source/WAKE/Wake/Impl/PubSubEventHandler.cs | 94 --
.../Source/WAKE/Wake/Impl/SingleThreadStage.cs | 100 --
lang/cs/Source/WAKE/Wake/Impl/SyncStage.cs | 48 -
.../cs/Source/WAKE/Wake/Impl/ThreadPoolStage.cs | 100 --
lang/cs/Source/WAKE/Wake/Impl/TimerStage.cs | 66 -
.../Source/WAKE/Wake/Properties/AssemblyInfo.cs | 55 -
.../WAKE/Wake/Protobuf/RemoteProtocol.proto | 36 -
.../WAKE/Wake/Protobuf/WakeRemoteProtosGen.cs | 96 --
lang/cs/Source/WAKE/Wake/RX/AbstractObserver.cs | 45 -
lang/cs/Source/WAKE/Wake/RX/AbstractRxStage.cs | 54 -
lang/cs/Source/WAKE/Wake/RX/IRxStage.cs | 28 -
.../cs/Source/WAKE/Wake/RX/IStaticObservable.cs | 31 -
lang/cs/Source/WAKE/Wake/RX/ISubject.cs | 31 -
.../Source/WAKE/Wake/RX/Impl/PubSubSubject.cs | 180 ---
lang/cs/Source/WAKE/Wake/RX/Impl/RxSyncStage.cs | 70 --
.../WAKE/Wake/RX/Impl/RxThreadPoolStage.cs | 134 --
.../cs/Source/WAKE/Wake/RX/Impl/RxTimerStage.cs | 67 -
.../Source/WAKE/Wake/RX/Impl/SimpleSubject.cs | 59 -
.../WAKE/Wake/RX/ObserverCompletedException.cs | 46 -
lang/cs/Source/WAKE/Wake/Remote/ICodec.cs | 34 -
.../cs/Source/WAKE/Wake/Remote/ICodecFactory.cs | 35 -
lang/cs/Source/WAKE/Wake/Remote/IDecoder.cs | 38 -
lang/cs/Source/WAKE/Wake/Remote/IEncoder.cs | 38 -
lang/cs/Source/WAKE/Wake/Remote/ILink.cs | 73 --
lang/cs/Source/WAKE/Wake/Remote/IRemoteEvent.cs | 42 -
.../WAKE/Wake/Remote/IRemoteIdentifier.cs | 28 -
.../Wake/Remote/IRemoteIdentifierFactory.cs | 26 -
.../Source/WAKE/Wake/Remote/IRemoteManager.cs | 42 -
.../Source/WAKE/Wake/Remote/IRemoteMessage.cs | 39 -
.../WAKE/Wake/Remote/ISubscriptionManager.cs | 26 -
.../Source/WAKE/Wake/Remote/Impl/ByteCodec.cs | 41 -
.../WAKE/Wake/Remote/Impl/ByteCodecFactory.cs | 41 -
lang/cs/Source/WAKE/Wake/Remote/Impl/Channel.cs | 258 ----
.../Wake/Remote/Impl/DefaultRemoteManager.cs | 338 -----
.../Wake/Remote/Impl/DefaultRemoteMessage.cs | 34 -
.../WAKE/Wake/Remote/Impl/IPEndpointComparer.cs | 59 -
.../cs/Source/WAKE/Wake/Remote/Impl/IntCodec.cs | 42 -
lang/cs/Source/WAKE/Wake/Remote/Impl/Link.cs | 256 ----
.../Source/WAKE/Wake/Remote/Impl/MultiCodec.cs | 89 --
.../WAKE/Wake/Remote/Impl/MultiDecoder.cs | 110 --
.../WAKE/Wake/Remote/Impl/MultiEncoder.cs | 87 --
.../WAKE/Wake/Remote/Impl/ObserverContainer.cs | 132 --
.../Source/WAKE/Wake/Remote/Impl/RemoteEvent.cs | 59 -
.../WAKE/Wake/Remote/Impl/RemoteEventCodec.cs | 43 -
.../WAKE/Wake/Remote/Impl/RemoteEventDecoder.cs | 39 -
.../WAKE/Wake/Remote/Impl/RemoteEventEncoder.cs | 43 -
.../Wake/Remote/Impl/RemoteEventEndpoint.cs | 42 -
.../Wake/Remote/Impl/SocketRemoteIdentifier.cs | 76 --
.../Source/WAKE/Wake/Remote/Impl/StringCodec.cs | 46 -
.../WAKE/Wake/Remote/Impl/StringIdentifier.cs | 53 -
.../Wake/Remote/Impl/StringIdentifierFactory.cs | 41 -
.../WAKE/Wake/Remote/Impl/TransportClient.cs | 133 --
.../WAKE/Wake/Remote/Impl/TransportEvent.cs | 42 -
.../WAKE/Wake/Remote/Impl/TransportServer.cs | 195 ---
.../WAKE/Wake/Remote/Proto/WakeRemoteProtos.cs | 76 --
.../WAKE/Wake/Remote/RemoteConfiguration.cs | 57 -
.../WAKE/Wake/Remote/RemoteRuntimeException.cs | 54 -
lang/cs/Source/WAKE/Wake/Time/Event/Alarm.cs | 41 -
.../cs/Source/WAKE/Wake/Time/Event/StartTime.cs | 31 -
lang/cs/Source/WAKE/Wake/Time/Event/StopTime.cs | 31 -
lang/cs/Source/WAKE/Wake/Time/IClock.cs | 89 --
.../WAKE/Wake/Time/Runtime/Event/ClientAlarm.cs | 34 -
.../WAKE/Wake/Time/Runtime/Event/IdleClock.cs | 28 -
.../Wake/Time/Runtime/Event/RuntimeAlarm.cs | 34 -
.../Wake/Time/Runtime/Event/RuntimeStart.cs | 28 -
.../WAKE/Wake/Time/Runtime/Event/RuntimeStop.cs | 37 -
lang/cs/Source/WAKE/Wake/Time/Runtime/ITimer.cs | 49 -
.../WAKE/Wake/Time/Runtime/LogicalTimer.cs | 55 -
.../Source/WAKE/Wake/Time/Runtime/RealTimer.cs | 64 -
.../WAKE/Wake/Time/Runtime/RuntimeClock.cs | 257 ----
lang/cs/Source/WAKE/Wake/Time/Time.cs | 82 --
lang/cs/Source/WAKE/Wake/Util/Actionable.cs | 42 -
lang/cs/Source/WAKE/Wake/Util/Disposable.cs | 63 -
.../Wake/Util/FixedThreadPoolTaskService.cs | 105 --
lang/cs/Source/WAKE/Wake/Util/IStartable.cs | 32 -
lang/cs/Source/WAKE/Wake/Util/ITaskService.cs | 34 -
.../LimitedConcurrencyLevelTaskScheduler.cs | 187 ---
lang/cs/Source/WAKE/Wake/Util/NetworkUtils.cs | 66 -
.../WAKE/Wake/Util/SerializationHelper.cs | 46 -
lang/cs/Source/WAKE/Wake/Util/TaskExtensions.cs | 34 -
lang/cs/Source/WAKE/Wake/Util/TimeHelper.cs | 49 -
lang/cs/Source/WAKE/Wake/Wake.csproj | 216 ----
.../cs/Source/WAKE/Wake/WakeRuntimeException.cs | 54 -
lang/cs/Source/WAKE/Wake/packages.config | 24 -
.../src/main/cs/Examples/P2p/IEventSource.cs | 35 -
.../Wake/src/main/cs/Examples/P2p/Pull2Push.cs | 103 --
.../WAKE/Wake/src/main/cs/PeriodicEvent.cs | 23 -
lang/cs/Source/WAKE/Wake/testkey.snk | Bin 596 -> 0 bytes
.../EvaluatorConfigurationsTests.cs | 4 +-
.../ReefTests/Evaluator.Tests/EvaluatorTests.cs | 17 +-
.../Functional.Tests/Bridge/TestBridgeClient.cs | 8 +-
.../Bridge/TestHelloBridgeHandlers.cs | 18 +-
.../Bridge/TestSimpleEventHandlers.cs | 24 +-
.../Driver/DriverTestStartHandler.cs | 12 +-
.../Functional.Tests/Driver/TestDriver.cs | 12 +-
.../Functional.Tests/Messaging/MessageDriver.cs | 34 +-
.../Functional.Tests/Messaging/MessageTask.cs | 16 +-
.../Messaging/TestTaskMessage.cs | 14 +-
.../Functional.Tests/ReefFunctionalTest.cs | 12 +-
.../BlockingCollectionExtensionTests.cs | 4 +-
.../Tests/ReefTests/IO.Tests/NameServerTests.cs | 19 +-
.../ReefTests/IO.Tests/NetworkServiceTests.cs | 25 +-
lang/cs/Tests/ReefTests/ReefTests.csproj | 42 +-
.../Utility.Test/TestDriverConfigGenerator.cs | 4 +-
.../ReefTests/Utility.Test/TestExceptions.cs | 6 +-
...bridge-0.11.0-incubating-SNAPSHOT-shaded.jar | Bin 13555093 -> 13555222 bytes
.../ClassHierarchy/TestAnonymousType.cs | 63 -
.../ClassHierarchy/TestClassHierarchy.cs | 717 -----------
.../TestClassHierarchyRoundTrip.cs | 69 --
.../TangTests/ClassHierarchy/TestGeneric.cs | 46 -
.../ClassHierarchy/TestMultipleInterface.cs | 103 --
.../ClassHierarchy/TestParameterParser.cs | 323 -----
.../ClassHierarchy/TestSerilization.cs | 234 ----
.../Configuration/TestAvroConfiguration.cs | 68 -
.../TestAvroSerializerRoundTrip.cs | 71 --
.../Configuration/TestConfiguration.cs | 566 ---------
.../TestCsConfigurationBuilderExtension.cs | 178 ---
.../TangTests/Format/TestConfigurationModule.cs | 522 --------
.../Format/TestConfigurationModuleForList.cs | 145 ---
.../TangTests/Format/TestTaskConfiguration.cs | 389 ------
.../Injection/TestAmbigousConstructors.cs | 80 --
.../TangTests/Injection/TestForkInjection.cs | 79 --
.../Tests/TangTests/Injection/TestInjection.cs | 386 ------
.../TangTests/Injection/TestInjectionFuture.cs | 240 ----
.../TangTests/Injection/TestListInjection.cs | 565 ---------
.../Injection/TestMissingParameters.cs | 151 ---
.../Injection/TestMissingParamtersInNested.cs | 142 ---
.../Injection/TestMultipleConstructors.cs | 360 ------
.../TangTests/Injection/TestNamedParameter.cs | 357 ------
.../TangTests/Injection/TestSetInjection.cs | 739 -----------
.../Tests/TangTests/Properties/AssemblyInfo.cs | 55 -
.../ScenarioTest/HttpHandlerConfiguration.cs | 35 -
.../ScenarioTest/HttpRuntimeConfiguration.cs | 36 -
.../ScenarioTest/HttpRuntimeStartHandler.cs | 50 -
.../ScenarioTest/HttpRuntimeStopHandler.cs | 50 -
.../Tests/TangTests/ScenarioTest/HttpServer.cs | 49 -
.../TangTests/ScenarioTest/IHttpHandler.cs | 27 -
.../TangTests/ScenarioTest/JettyHandler.cs | 44 -
.../ScenarioTest/TestDefaultConstructor.cs | 79 --
.../TangTests/ScenarioTest/TestHttpService.cs | 194 ---
.../TangTests/ScenarioTest/TestRuntimeClock.cs | 253 ----
.../ScenarioTest/TestTrackingURIProvider.cs | 59 -
.../ScenarioTest/TrackingURIProvider.cs | 63 -
.../ScenarioTest/TrackingYRIProvider.cs | 25 -
.../cs/Tests/TangTests/SmokeTest/AnInterface.cs | 29 -
.../SmokeTest/AnInterfaceImplementation.cs | 65 -
.../TangTests/SmokeTest/CyclicDependency.cs | 70 --
.../SmokeTest/CyclicDependencyClassOne.cs | 61 -
.../SmokeTest/CyclicDependencyClassTwo.cs | 55 -
lang/cs/Tests/TangTests/SmokeTest/Handler.cs | 26 -
.../TangTests/SmokeTest/InjectableClass.cs | 60 -
.../TangTests/SmokeTest/ListOfBaseTypes.cs | 108 --
.../Tests/TangTests/SmokeTest/ObjectTreeTest.cs | 54 -
.../TangTests/SmokeTest/RootImplementation.cs | 178 ---
.../Tests/TangTests/SmokeTest/RootInterface.cs | 26 -
.../Tests/TangTests/SmokeTest/RoundTripTest.cs | 40 -
.../Tests/TangTests/SmokeTest/SetInterface.cs | 31 -
.../TangTests/SmokeTest/SetInterfaceImplOne.cs | 82 --
.../TangTests/SmokeTest/SetInterfaceImplTwo.cs | 82 --
.../Tests/TangTests/SmokeTest/SetOfBaseTypes.cs | 105 --
.../TangTests/SmokeTest/SetOfImplementations.cs | 72 --
.../SmokeTest/TestConfigurationModuleBuilder.cs | 107 --
.../TangTests/Tang/TestDefaultImpementaion.cs | 196 ---
.../TangTests/Tang/TestExternalConstructors.cs | 148 ---
.../TangTests/Tang/TestLegacyConstructors.cs | 73 --
lang/cs/Tests/TangTests/Tang/TestTang.cs | 1158 -----------------
lang/cs/Tests/TangTests/TangTests.csproj | 197 ---
.../Tests/TangTests/Utilities/TestUtilities.cs | 294 -----
lang/cs/Tests/TangTests/Utilities/Utilities.cs | 62 -
lang/cs/Tests/TangTests/evaluator.conf | Bin 2837 -> 0 bytes
lang/cs/Tests/TangTests/packages.config | 24 -
.../TangTests/simpleConstructorJavaProto.bin | Bin 1994 -> 0 bytes
lang/cs/Tests/WakeTests/ClockTest.cs | 183 ---
lang/cs/Tests/WakeTests/MultiCodecTest.cs | 102 --
.../Tests/WakeTests/Properties/AssemblyInfo.cs | 55 -
lang/cs/Tests/WakeTests/PubSubSubjectTest.cs | 209 ----
lang/cs/Tests/WakeTests/RemoteManagerTest.cs | 344 ------
lang/cs/Tests/WakeTests/TransportTest.cs | 205 ----
lang/cs/Tests/WakeTests/WakeTests.csproj | 120 --
lang/cs/Tests/WakeTests/packages.config | 23 -
lang/cs/pom.xml | 4 +-
1119 files changed, 51121 insertions(+), 51041 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/c1b5200f/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/ActiveContextClr2Java.cpp
----------------------------------------------------------------------
diff --git a/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/ActiveContextClr2Java.cpp b/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/ActiveContextClr2Java.cpp
index c381f50..3ad4e43 100644
--- a/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/ActiveContextClr2Java.cpp
+++ b/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/ActiveContextClr2Java.cpp
@@ -20,7 +20,7 @@
namespace Org {
namespace Apache {
- namespace Reef {
+ namespace REEF {
namespace Driver {
namespace Bridge {
private ref class ManagedLog {
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/c1b5200f/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/AllocatedEvaluatorClr2Java.cpp
----------------------------------------------------------------------
diff --git a/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/AllocatedEvaluatorClr2Java.cpp b/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/AllocatedEvaluatorClr2Java.cpp
index 6f158bc..b8f18c5 100644
--- a/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/AllocatedEvaluatorClr2Java.cpp
+++ b/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/AllocatedEvaluatorClr2Java.cpp
@@ -22,7 +22,7 @@ using namespace JavaClrBridge;
namespace Org {
namespace Apache {
- namespace Reef {
+ namespace REEF {
namespace Driver {
namespace Bridge {
ref class ManagedLog {
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/c1b5200f/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/ClosedContextClr2Java.cpp
----------------------------------------------------------------------
diff --git a/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/ClosedContextClr2Java.cpp b/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/ClosedContextClr2Java.cpp
index a141f45..1e1c879 100644
--- a/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/ClosedContextClr2Java.cpp
+++ b/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/ClosedContextClr2Java.cpp
@@ -20,7 +20,7 @@
namespace Org {
namespace Apache {
- namespace Reef {
+ namespace REEF {
namespace Driver {
namespace Bridge {
ref class ManagedLog {
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/c1b5200f/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/Clr2JavaImpl.h
----------------------------------------------------------------------
diff --git a/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/Clr2JavaImpl.h b/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/Clr2JavaImpl.h
index 41d6980..55c332a 100644
--- a/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/Clr2JavaImpl.h
+++ b/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/Clr2JavaImpl.h
@@ -21,19 +21,19 @@
#include "JavaClrBridge.h"
#include "InteropAssemblies.h"
#using "clrhandler.dll"
-#using "Org.Apache.Reef.Driver.dll"
+#using "Org.Apache.REEF.Driver.dll"
using namespace System;
using namespace System::IO;
using namespace System::Collections::Generic;
using namespace System::Runtime::InteropServices;
using namespace System::Reflection;
-using namespace Org::Apache::Reef::Driver::Bridge;
-using namespace Org::Apache::Reef::Driver::Evaluator;
+using namespace Org::Apache::REEF::Driver::Bridge;
+using namespace Org::Apache::REEF::Driver::Evaluator;
namespace Org {
namespace Apache {
- namespace Reef {
+ namespace REEF {
namespace Driver {
namespace Bridge {
public ref class CommonUtilities {
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/c1b5200f/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/CommonUtilities.cpp
----------------------------------------------------------------------
diff --git a/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/CommonUtilities.cpp b/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/CommonUtilities.cpp
index c668dab..2a397bc 100644
--- a/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/CommonUtilities.cpp
+++ b/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/CommonUtilities.cpp
@@ -20,7 +20,7 @@
namespace Org {
namespace Apache {
- namespace Reef {
+ namespace REEF {
namespace Driver {
namespace Bridge {
ref class ManagedLog {
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/c1b5200f/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/CompletedEvaluatorClr2Java.cpp
----------------------------------------------------------------------
diff --git a/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/CompletedEvaluatorClr2Java.cpp b/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/CompletedEvaluatorClr2Java.cpp
index 1bd9dbe..5d9b124 100644
--- a/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/CompletedEvaluatorClr2Java.cpp
+++ b/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/CompletedEvaluatorClr2Java.cpp
@@ -20,7 +20,7 @@
namespace Org {
namespace Apache {
- namespace Reef {
+ namespace REEF {
namespace Driver {
namespace Bridge {
ref class ManagedLog {
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/c1b5200f/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/CompletedTaskClr2Java.cpp
----------------------------------------------------------------------
diff --git a/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/CompletedTaskClr2Java.cpp b/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/CompletedTaskClr2Java.cpp
index ef7d9c7..10a1166 100644
--- a/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/CompletedTaskClr2Java.cpp
+++ b/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/CompletedTaskClr2Java.cpp
@@ -20,7 +20,7 @@
namespace Org {
namespace Apache {
- namespace Reef {
+ namespace REEF {
namespace Driver {
namespace Bridge {
ref class ManagedLog {
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/c1b5200f/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/ContextMessageClr2Java.cpp
----------------------------------------------------------------------
diff --git a/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/ContextMessageClr2Java.cpp b/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/ContextMessageClr2Java.cpp
index eda01f5..b036c8b 100644
--- a/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/ContextMessageClr2Java.cpp
+++ b/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/ContextMessageClr2Java.cpp
@@ -20,7 +20,7 @@
namespace Org {
namespace Apache {
- namespace Reef {
+ namespace REEF {
namespace Driver {
namespace Bridge {
ref class ManagedLog {
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/c1b5200f/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/EvaluatorRequestorClr2Java.cpp
----------------------------------------------------------------------
diff --git a/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/EvaluatorRequestorClr2Java.cpp b/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/EvaluatorRequestorClr2Java.cpp
index 610f2a4..f863a40 100644
--- a/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/EvaluatorRequestorClr2Java.cpp
+++ b/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/EvaluatorRequestorClr2Java.cpp
@@ -20,7 +20,7 @@
namespace Org {
namespace Apache {
- namespace Reef {
+ namespace REEF {
namespace Driver {
namespace Bridge {
ref class ManagedLog {
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/c1b5200f/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/FailedContextClr2Java.cpp
----------------------------------------------------------------------
diff --git a/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/FailedContextClr2Java.cpp b/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/FailedContextClr2Java.cpp
index 6dee54f..58c322e 100644
--- a/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/FailedContextClr2Java.cpp
+++ b/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/FailedContextClr2Java.cpp
@@ -20,7 +20,7 @@
namespace Org {
namespace Apache {
- namespace Reef {
+ namespace REEF {
namespace Driver {
namespace Bridge {
ref class ManagedLog {
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/c1b5200f/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/FailedEvaluatorClr2Java.cpp
----------------------------------------------------------------------
diff --git a/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/FailedEvaluatorClr2Java.cpp b/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/FailedEvaluatorClr2Java.cpp
index 60e4b1c..71f7a1b 100644
--- a/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/FailedEvaluatorClr2Java.cpp
+++ b/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/FailedEvaluatorClr2Java.cpp
@@ -22,7 +22,7 @@ using namespace JavaClrBridge;
namespace Org {
namespace Apache {
- namespace Reef {
+ namespace REEF {
namespace Driver {
namespace Bridge {
ref class ManagedLog {
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/c1b5200f/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/FailedTaskClr2Java.cpp
----------------------------------------------------------------------
diff --git a/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/FailedTaskClr2Java.cpp b/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/FailedTaskClr2Java.cpp
index 3422c61..15db236 100644
--- a/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/FailedTaskClr2Java.cpp
+++ b/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/FailedTaskClr2Java.cpp
@@ -20,7 +20,7 @@
namespace Org {
namespace Apache {
- namespace Reef {
+ namespace REEF {
namespace Driver {
namespace Bridge {
ref class ManagedLog {
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/c1b5200f/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/HttpServerClr2Java.cpp
----------------------------------------------------------------------
diff --git a/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/HttpServerClr2Java.cpp b/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/HttpServerClr2Java.cpp
index 1063243..78ab38a 100644
--- a/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/HttpServerClr2Java.cpp
+++ b/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/HttpServerClr2Java.cpp
@@ -20,7 +20,7 @@
namespace Org {
namespace Apache {
- namespace Reef {
+ namespace REEF {
namespace Driver {
namespace Bridge {
ref class ManagedLog {
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/c1b5200f/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/JavaClrBridge.cpp
----------------------------------------------------------------------
diff --git a/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/JavaClrBridge.cpp b/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/JavaClrBridge.cpp
index b4b79f0..2bd5c74 100644
--- a/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/JavaClrBridge.cpp
+++ b/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/JavaClrBridge.cpp
@@ -31,7 +31,7 @@ using namespace System::IO;
using namespace System::Collections::Generic;
using namespace System::Runtime::InteropServices;
using namespace System::Reflection;
-using namespace Org::Apache::Reef::Driver::Bridge;
+using namespace Org::Apache::REEF::Driver::Bridge;
ref class ManagedLog {
internal:
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/c1b5200f/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/RunningTaskClr2Java.cpp
----------------------------------------------------------------------
diff --git a/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/RunningTaskClr2Java.cpp b/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/RunningTaskClr2Java.cpp
index 8ca1e65..0bf4b73 100644
--- a/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/RunningTaskClr2Java.cpp
+++ b/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/RunningTaskClr2Java.cpp
@@ -20,7 +20,7 @@
namespace Org {
namespace Apache {
- namespace Reef {
+ namespace REEF {
namespace Driver {
namespace Bridge {
ref class ManagedLog {
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/c1b5200f/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/SuspendedTaskClr2Java.cpp
----------------------------------------------------------------------
diff --git a/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/SuspendedTaskClr2Java.cpp b/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/SuspendedTaskClr2Java.cpp
index a10f88e..e03aa57 100644
--- a/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/SuspendedTaskClr2Java.cpp
+++ b/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/SuspendedTaskClr2Java.cpp
@@ -20,7 +20,7 @@
namespace Org {
namespace Apache {
- namespace Reef {
+ namespace REEF {
namespace Driver {
namespace Bridge {
ref class ManagedLog {
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/c1b5200f/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/TaskMessageClr2Java.cpp
----------------------------------------------------------------------
diff --git a/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/TaskMessageClr2Java.cpp b/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/TaskMessageClr2Java.cpp
index d2f8286..57834b7 100644
--- a/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/TaskMessageClr2Java.cpp
+++ b/lang/cpp/reef-bridge-clr/src/main/Cpp/CppBridge/JavaClrBridge/TaskMessageClr2Java.cpp
@@ -20,7 +20,7 @@
namespace Org {
namespace Apache {
- namespace Reef {
+ namespace REEF {
namespace Driver {
namespace Bridge {
ref class ManagedLog {
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/c1b5200f/lang/cs/Org.Apache.REEF.Common/ClientJobStatusHandler.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Org.Apache.REEF.Common/ClientJobStatusHandler.cs b/lang/cs/Org.Apache.REEF.Common/ClientJobStatusHandler.cs
new file mode 100644
index 0000000..84e916f
--- /dev/null
+++ b/lang/cs/Org.Apache.REEF.Common/ClientJobStatusHandler.cs
@@ -0,0 +1,142 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+using Org.Apache.REEF.Common.Client;
+using Org.Apache.REEF.Common.ProtoBuf.ClienRuntimeProto;
+using Org.Apache.REEF.Common.ProtoBuf.ReefProtocol;
+using Org.Apache.REEF.Common.ProtoBuf.ReefServiceProto;
+using Org.Apache.REEF.Utilities;
+using Org.Apache.REEF.Utilities.Logging;
+using Org.Apache.REEF.Wake.Remote;
+using Org.Apache.REEF.Wake.Time;
+using System;
+
+namespace Org.Apache.REEF.Common
+{
+ public class ClientJobStatusHandler : IJobMessageObserver, IObserver<StartTime>
+ {
+ private static readonly Logger LOGGER = Logger.GetLogger(typeof(ClientJobStatusHandler));
+
+ private IClock _clock;
+
+ private string _jobId;
+
+ private IObserver<JobStatusProto> _jobStatusHandler;
+
+ private IDisposable _jobControlChannel;
+
+ State _state = State.INIT;
+
+ public ClientJobStatusHandler(
+ IRemoteManager<IRemoteMessage<REEFMessage>> remoteManager,
+ IClock clock,
+ IObserver<JobControlProto> jobControlHandler,
+ string jobId,
+ string clientRID)
+ {
+ _clock = clock;
+ _jobId = jobId;
+ _jobStatusHandler = null;
+ _jobControlChannel = null;
+ //_jobStatusHandler = remoteManager.GetRemoteObserver()
+ //_jobControlChannel = remoteManager.RegisterObserver()
+ }
+
+ public void Dispose(Optional<Exception> e)
+ {
+ try
+ {
+ if (e.IsPresent())
+ {
+ OnError(e.Value);
+ }
+ else
+ {
+ JobStatusProto proto = new JobStatusProto();
+ proto.identifier = _jobId;
+ proto.state = State.DONE;
+ Send(proto);
+ }
+ }
+ catch (Exception ex)
+ {
+ Org.Apache.REEF.Utilities.Diagnostics.Exceptions.CaughtAndThrow(ex, Level.Warning, "Error closing ClientJobStatusHandler", LOGGER);
+ }
+
+ try
+ {
+ _jobControlChannel.Dispose();
+ }
+ catch (Exception ex)
+ {
+ Org.Apache.REEF.Utilities.Diagnostics.Exceptions.CaughtAndThrow(ex, Level.Warning, "Error closing jobControlChannel", LOGGER);
+ }
+ }
+
+ public void OnNext(byte[] value)
+ {
+ LOGGER.Log(Level.Info, "Job message from {0}" + _jobId);
+ SendInit();
+ JobStatusProto proto = new JobStatusProto();
+ proto.identifier = _jobId;
+ proto.state = State.RUNNING;
+ proto.message = value;
+ Send(proto);
+ }
+
+ public void OnNext(StartTime value)
+ {
+ LOGGER.Log(Level.Info, "StartTime:" + value);
+ SendInit();
+ }
+
+ public void OnError(Exception error)
+ {
+ LOGGER.Log(Level.Error, "job excemption", error);
+ JobStatusProto proto = new JobStatusProto();
+ proto.identifier = _jobId;
+ proto.state = State.FAILED;
+ proto.exception = ByteUtilities.StringToByteArrays(error.Message);
+ _clock.Dispose();
+ }
+
+ public void OnCompleted()
+ {
+ throw new NotImplementedException();
+ }
+
+ private void Send(JobStatusProto status)
+ {
+ LOGGER.Log(Level.Info, "Sending job status " + status);
+ _jobStatusHandler.OnNext(status);
+ }
+
+ private void SendInit()
+ {
+ if (_state == State.INIT)
+ {
+ JobStatusProto proto = new JobStatusProto();
+ proto.identifier = _jobId;
+ proto.state = State.INIT;
+ Send(proto);
+ _state = State.RUNNING;
+ }
+ }
+ }
+}
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/c1b5200f/lang/cs/Org.Apache.REEF.Common/Constants.cs
----------------------------------------------------------------------
diff --git a/lang/cs/Org.Apache.REEF.Common/Constants.cs b/lang/cs/Org.Apache.REEF.Common/Constants.cs
new file mode 100644
index 0000000..27e185e
--- /dev/null
+++ b/lang/cs/Org.Apache.REEF.Common/Constants.cs
@@ -0,0 +1,38 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+namespace Org.Apache.REEF.Common
+{
+ public class Constants
+ {
+ public const string ClrBridgeRuntimeConfiguration = "clrBridge.config";
+
+ // if 8080 port is not used, then query would fail,
+ // this is only for local runtime testing purpose though, so it should be ok
+ public const string LocalHttpEndpointBaseUri = @"http://localhost:8080/";
+
+ public const string HDInsightClusterHttpEndpointBaseUri = @"http://headnodehost:9014/proxy/";
+
+ public const string HttpReefUriSpecification = @"Reef/v1/";
+
+ public const string HttpDriverUriTarget = @"Driver/";
+
+ public const string NameServerServiceName = "NameServer";
+ }
+}