| 30 | |
| 31 | |
| 32 | class JNIExecutor : public Executor |
| 33 | { |
| 34 | public: |
| 35 | JNIExecutor(JNIEnv* _env, jweak _jdriver) |
| 36 | : jvm(nullptr), env(_env), jdriver(_jdriver) |
| 37 | { |
| 38 | env->GetJavaVM(&jvm); |
| 39 | } |
| 40 | |
| 41 | ~JNIExecutor() override {} |
| 42 | |
| 43 | void registered(ExecutorDriver* driver, |
| 44 | const ExecutorInfo& executorInfo, |
| 45 | const FrameworkInfo& frameworkInfo, |
| 46 | const SlaveInfo& slaveInfo) override; |
| 47 | void reregistered( |
| 48 | ExecutorDriver* driver, const SlaveInfo& slaveInfo) override; |
| 49 | void disconnected(ExecutorDriver* driver) override; |
| 50 | void launchTask(ExecutorDriver* driver, const TaskInfo& task) override; |
| 51 | void killTask(ExecutorDriver* driver, const TaskID& taskId) override; |
| 52 | void frameworkMessage(ExecutorDriver* driver, const string& data) override; |
| 53 | void shutdown(ExecutorDriver* driver) override; |
| 54 | void error(ExecutorDriver* driver, const string& message) override; |
| 55 | |
| 56 | JavaVM* jvm; |
| 57 | JNIEnv* env; |
| 58 | jweak jdriver; |
| 59 | }; |
| 60 | |
| 61 | |
| 62 | void JNIExecutor::registered(ExecutorDriver* driver, |
nothing calls this directly
no outgoing calls
no test coverage detected