| /** |
| * 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. |
| */ |
| #include "InteropUtil.h" |
| #include "org_apache_reef_javabridge_NativeInterop.h" |
| #include "JavaClrBridge.h" |
| #include "InteropAssemblies.h" |
| #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; |
| |
| namespace Org { |
| namespace Apache { |
| namespace REEF { |
| namespace Driver { |
| namespace Bridge { |
| namespace Clr2java { |
| public ref class CommonUtilities { |
| public: |
| static IEvaluatorDescriptor^ RetrieveEvaluatorDescriptor(jobject object, JavaVM* jvm); |
| }; |
| |
| public ref class AllocatedEvaluatorClr2Java : public IAllocatedEvaluaotrClr2Java { |
| jobject _jobjectAllocatedEvaluator; |
| JavaVM* _jvm; |
| jstring _jstringId; |
| jstring _jstringNameServerInfo; |
| public: |
| AllocatedEvaluatorClr2Java(JNIEnv *env, jobject jallocatedEvaluator); |
| virtual void SubmitContextAndTask(String^ contextConfigStr, String^ taskConfigStr); |
| virtual void SubmitContext(String^ contextConfigStr); |
| virtual void SubmitContextAndService(String^ contextConfigStr, String^ serviceConfigStr); |
| virtual void SubmitContextAndServiceAndTask(String^ contextConfigStr, String^ serviceConfigStr, String^ taskConfigStr); |
| virtual void OnError(String^ message); |
| virtual void Close(); |
| virtual String^ GetId(); |
| virtual String^ GetNameServerInfo(); |
| virtual IEvaluatorDescriptor^ GetEvaluatorDescriptor(); |
| }; |
| |
| public ref class ActiveContextClr2Java : public IActiveContextClr2Java { |
| jobject _jobjectActiveContext; |
| jstring _jstringId; |
| jstring _jstringEvaluatorId; |
| JavaVM* _jvm; |
| public: |
| ActiveContextClr2Java(JNIEnv *env, jobject jallocatedEvaluator); |
| virtual void SubmitTask(String^ taskConfigStr); |
| virtual void Close(); |
| virtual void OnError(String^ message); |
| virtual String^ GetId(); |
| virtual String^ GetEvaluatorId(); |
| virtual IEvaluatorDescriptor^ GetEvaluatorDescriptor(); |
| }; |
| |
| public ref class EvaluatorRequestorClr2Java : public IEvaluatorRequestorClr2Java { |
| jobject _jobjectEvaluatorRequestor; |
| JavaVM* _jvm; |
| public: |
| EvaluatorRequestorClr2Java(JNIEnv *env, jobject jevaluatorRequestor); |
| virtual void OnError(String^ message); |
| virtual void Submit(IEvaluatorRequest^ request); |
| }; |
| |
| public ref class TaskMessageClr2Java : public ITaskMessageClr2Java { |
| jobject _jobjectTaskMessage; |
| JavaVM* _jvm; |
| jstring _jstringId; |
| public: |
| TaskMessageClr2Java(JNIEnv *env, jobject jtaskMessage); |
| virtual void OnError(String^ message); |
| virtual String^ GetId(); |
| }; |
| |
| public ref class FailedTaskClr2Java : public IFailedTaskClr2Java { |
| jobject _jobjectFailedTask; |
| JavaVM* _jvm; |
| public: |
| FailedTaskClr2Java(JNIEnv *env, jobject jfailedTask); |
| virtual void OnError(String^ message); |
| virtual IActiveContextClr2Java^ GetActiveContext(); |
| virtual String^ GetString(); |
| }; |
| |
| public ref class RunningTaskClr2Java : public IRunningTaskClr2Java { |
| jobject _jobjectRunningTask; |
| JavaVM* _jvm; |
| jstring _jstringId; |
| public: |
| RunningTaskClr2Java(JNIEnv *env, jobject jrunningTask); |
| virtual void OnError(String^ message); |
| virtual IActiveContextClr2Java^ GetActiveContext(); |
| virtual String^ GetId(); |
| virtual void Send(array<byte>^ message); |
| }; |
| |
| public ref class FailedEvaluatorClr2Java : public IFailedEvaluatorClr2Java { |
| jobject _jobjectFailedEvaluator; |
| JavaVM* _jvm; |
| jstring _jstringId; |
| public: |
| FailedEvaluatorClr2Java(JNIEnv *env, jobject jfailedEvaluator); |
| virtual void OnError(String^ message); |
| virtual IEvaluatorRequestorClr2Java^ GetEvaluatorRequestor(); |
| virtual String^ GetId(); |
| }; |
| |
| public ref class HttpServerClr2Java : public IHttpServerBridgeClr2Java { |
| jobject _jhttpServerEventBridge; |
| JavaVM* _jvm; |
| public: |
| HttpServerClr2Java(JNIEnv *env, jobject jhttpServerEventBridge); |
| virtual void OnError(String^ message); |
| virtual String^ GetQueryString(); |
| virtual void SetUriSpecification(String^ uriSpecification); |
| virtual void SetQueryResult(String^ queryResult); |
| virtual array<byte>^ GetQueryRequestData(); |
| virtual void SetQueryResponseData(array<byte>^ responseData); |
| }; |
| |
| public ref class CompletedTaskClr2Java : public ICompletedTaskClr2Java { |
| jobject _jobjectCompletedTask; |
| JavaVM* _jvm; |
| jstring _jstringId; |
| public: |
| CompletedTaskClr2Java(JNIEnv *env, jobject jcompletedTask); |
| virtual void OnError(String^ message); |
| virtual IActiveContextClr2Java^ GetActiveContext(); |
| virtual String^ GetId(); |
| virtual array<byte>^ Get(); |
| }; |
| |
| public ref class SuspendedTaskClr2Java : public ISuspendedTaskClr2Java { |
| jobject _jobjectSuspendedTask; |
| JavaVM* _jvm; |
| jstring _jstringId; |
| public: |
| SuspendedTaskClr2Java(JNIEnv *env, jobject jobjectSuspendedTask); |
| virtual void OnError(String^ message); |
| virtual IActiveContextClr2Java^ GetActiveContext(); |
| virtual String^ GetId(); |
| virtual array<byte>^ Get(); |
| }; |
| |
| public ref class CompletedEvaluatorClr2Java : public ICompletedEvaluatorClr2Java { |
| jobject _jobjectCompletedEvaluator; |
| JavaVM* _jvm; |
| jstring _jstringId; |
| public: |
| CompletedEvaluatorClr2Java(JNIEnv *env, jobject jobjectCompletedEvaluator); |
| virtual void OnError(String^ message); |
| virtual String^ GetId(); |
| }; |
| |
| public ref class ClosedContextClr2Java : public IClosedContextClr2Java { |
| jobject _jobjectClosedContext; |
| JavaVM* _jvm; |
| jstring _jstringContextId; |
| jstring _jstringEvaluatorId; |
| public: |
| ClosedContextClr2Java(JNIEnv *env, jobject jobjectClosedContext); |
| virtual void OnError(String^ message); |
| virtual String^ GetId(); |
| virtual String^ GetEvaluatorId(); |
| virtual IEvaluatorDescriptor^ GetEvaluatorDescriptor(); |
| virtual IActiveContextClr2Java^ GetParentContext(); |
| }; |
| |
| public ref class FailedContextClr2Java : public IFailedContextClr2Java { |
| jobject _jobjectFailedContext; |
| JavaVM* _jvm; |
| jstring _jstringContextId; |
| jstring _jstringEvaluatorId; |
| jstring _jstringParentContextId; |
| public: |
| FailedContextClr2Java(JNIEnv *env, jobject jobjectFailedContext); |
| virtual void OnError(String^ message); |
| virtual String^ GetId(); |
| virtual String^ GetEvaluatorId(); |
| virtual String^ GetParentId(); |
| virtual IEvaluatorDescriptor^ GetEvaluatorDescriptor(); |
| virtual IActiveContextClr2Java^ GetParentContext(); |
| }; |
| |
| public ref class ContextMessageClr2Java : public IContextMessageClr2Java { |
| jobject _jobjectContextMessage; |
| JavaVM* _jvm; |
| jbyteArray _jarrayMessage; |
| jstring _jstringId; |
| jstring _jstringSourceId; |
| public: |
| ContextMessageClr2Java(JNIEnv *env, jobject jobjectContextMessage); |
| virtual void OnError(String^ message); |
| virtual array<byte>^ Get(); |
| virtual String^ GetId(); |
| virtual String^ GetMessageSourceId(); |
| }; |
| |
| public ref class DriverRestartedClr2Java : public IDriverRestartedClr2Java { |
| jobject _jobjectDriverRestarted; |
| JavaVM* _jvm; |
| array<String^>^ _expectedEvaluatorIds; |
| DateTime _startTime; |
| int _resubmissionAttempts; |
| public: |
| DriverRestartedClr2Java(JNIEnv *env, jobject jobjectDriverRestarted); |
| virtual void OnError(String^ message); |
| virtual array<String^>^ GetExpectedEvaluatorIds(); |
| virtual DateTime GetStartTime(); |
| virtual int GetResubmissionAttempts(); |
| }; |
| |
| public ref class DriverRestartCompletedClr2Java : public IDriverRestartCompletedClr2Java { |
| jobject _jobjectDriverRestartCompleted; |
| JavaVM* _jvm; |
| DateTime _restartCompletedTime; |
| bool _isTimedOut; |
| public: |
| DriverRestartCompletedClr2Java(JNIEnv *env, jobject jobobjectDriverRestartCompleted); |
| virtual void OnError(String^ message); |
| virtual DateTime GetCompletedTime(); |
| virtual bool IsTimedOut(); |
| }; |
| } |
| } |
| } |
| } |
| } |
| } |