utils/dnp3_src/java/cpp/adapters/MasterApplicationAdapter.cpp - master - tisit/OpenPLC_v3

utils/dnp3_src/java/cpp/adapters/MasterApplicationAdapter.cpp
107 строк4 KB
thiagoralves
First commit. OpenPLC v3 beta 1
14 июн 2018, 20:43
14 июн 2018, 20:431b10e97
/**
 * Copyright 2013 Automatak, LLC
 *
 * Licensed to Automatak, LLC (www.automatak.com) under one or more
 * contributor license agreements. See the NOTICE file distributed with this
 * work for additional information regarding copyright ownership. Automatak, LLC
 * 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.html
 *
 * 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 "MasterApplicationAdapter.h"

#include "../jni/JCache.h"

using namespace opendnp3;

openpal::UTCTimestamp MasterApplicationAdapter::Now()
{
	const auto env = JNI::GetEnv();
	const auto ms = jni::JCache::MasterApplication.getMillisecondsSinceEpoch(env, proxy);
	return openpal::UTCTimestamp(ms);
}

void MasterApplicationAdapter::OnReceiveIIN(const IINField& iin)
{
	const auto env = JNI::GetEnv();
	auto jiin = jni::JCache::IINField.init2(env, iin.LSB, iin.MSB);
	jni::JCache::MasterApplication.onReceiveIIN(env, proxy, jiin);
}

void MasterApplicationAdapter::OnTaskStart(MasterTaskType type, TaskId id)
{
	const auto env = JNI::GetEnv();
	auto jtasktype = jni::JCache::MasterTaskType.fromType(env, static_cast<jint>(type));
	auto jtaskid = jni::JCache::TaskId.init2(env, id.GetId(), id.IsDefined());
	jni::JCache::MasterApplication.onTaskStart(env, proxy, jtasktype, jtaskid);
}

void MasterApplicationAdapter::OnTaskComplete(const TaskInfo& info)
{
	const auto env = JNI::GetEnv();
	auto jtype = jni::JCache::MasterTaskType.fromType(env, static_cast<jint>(info.type));
	auto jresult = jni::JCache::TaskCompletion.fromType(env, static_cast<jint>(info.result));
	auto jtaskid = jni::JCache::TaskId.init2(env, info.id.GetId(), info.id.IsDefined());

	auto jinfo = jni::JCache::TaskInfo.init3(env, jtype, jresult, jtaskid);
	jni::JCache::MasterApplication.onTaskComplete(env, proxy, jinfo);
}

void MasterApplicationAdapter::OnOpen()
{
	const auto env = JNI::GetEnv();
	jni::JCache::MasterApplication.onOpen(env, proxy);
}

void MasterApplicationAdapter::OnClose()
{
	const auto env = JNI::GetEnv();
	jni::JCache::MasterApplication.onClose(env, proxy);
}

bool MasterApplicationAdapter::AssignClassDuringStartup()
{
	const auto env = JNI::GetEnv();
	return !!jni::JCache::MasterApplication.assignClassDuringStartup(env, proxy);
}

void MasterApplicationAdapter::ConfigureAssignClassRequest(const WriteHeaderFunT& fun)
{
	const auto env = JNI::GetEnv();

	auto jiterable = jni::JCache::MasterApplication.getClassAssignments(env, proxy);

	auto write = [&](LocalRef<jobject> assigment)
	{
		const auto clazz = static_cast<PointClass>(jni::JCache::PointClass.toType(env, jni::JCache::ClassAssignment.getclazz(env, assigment)));
		const auto jgroup = jni::JCache::ClassAssignment.getgroup(env, assigment);
		const auto jvariation = jni::JCache::ClassAssignment.getvariation(env, assigment);
		const auto jrange = jni::JCache::ClassAssignment.getrange(env, assigment);

		// write the group 60 header
		fun(Header::From(clazz));

		// write the header for the assigned type
		if (jni::JCache::Range.isDefined(env, jrange))
		{
			const auto jstart = jni::JCache::Range.getstart(env, jrange);
			const auto jstop = jni::JCache::Range.getstop(env, jrange);

			fun(Header::Range16(jgroup, jvariation, static_cast<uint16_t>(jstart), static_cast<uint16_t>(jstop)));
		}
		else
		{
			fun(Header::AllObjects(jgroup, jvariation));
		}
	};

	JNI::Iterate(env, jiterable, write);
}