NativeMethods.h File Reference

Go to the source code of this file.

Functions
JNIEXPORT jlong JNICALL	Java_net_sf_farrago_fennel_FennelStorage_newObjectHandle (JNIEnv *, jclass, jobject)
JNIEXPORT void JNICALL	Java_net_sf_farrago_fennel_FennelStorage_deleteObjectHandle (JNIEnv *, jclass, jlong)
JNIEXPORT void JNICALL	Java_net_sf_farrago_fennel_FennelStorage_setObjectHandle (JNIEnv *, jclass, jlong, jobject)
JNIEXPORT jint JNICALL	Java_net_sf_farrago_fennel_FennelStorage_getHandleCount (JNIEnv *, jclass)
JNIEXPORT jstring JNICALL	Java_net_sf_farrago_fennel_FennelStorage_getAccessorXmiForTupleDescriptor (JNIEnv *, jclass, jobject)
JNIEXPORT jlong JNICALL	Java_net_sf_farrago_fennel_FennelStorage_executeJavaCmd (JNIEnv *, jclass, jobject, jlong)
JNIEXPORT void JNICALL	Java_net_sf_farrago_fennel_FennelStorage_tupleStreamGraphGetInputStreams (JNIEnv *, jclass, jlong, jstring, jobject)
JNIEXPORT void JNICALL	Java_net_sf_farrago_fennel_FennelStorage_tupleStreamGraphOpen (JNIEnv *, jclass, jlong, jlong, jobject, jobject)
JNIEXPORT jint JNICALL	Java_net_sf_farrago_fennel_FennelStorage_tupleStreamFetch (JNIEnv *, jclass, jlong, jbyteArray)
JNIEXPORT jint JNICALL	Java_net_sf_farrago_fennel_FennelStorage_tupleStreamTransformFetch (JNIEnv *, jclass, jlong, jint, jbyteArray)
JNIEXPORT void JNICALL	Java_net_sf_farrago_fennel_FennelStorage_tupleStreamRestart (JNIEnv *, jclass, jlong)
JNIEXPORT void JNICALL	Java_net_sf_farrago_fennel_FennelStorage_tupleStreamGraphClose (JNIEnv *, jclass, jlong, jint)
JNIEXPORT jlong JNICALL	Java_net_sf_farrago_fennel_FennelStorage_newExecutionHandle (JNIEnv *, jclass)
JNIEXPORT void JNICALL	Java_net_sf_farrago_fennel_FennelStorage_deleteExecutionHandle (JNIEnv *, jclass, jlong)
JNIEXPORT void JNICALL	Java_net_sf_farrago_fennel_FennelStorage_cancelExecution (JNIEnv *, jclass, jlong)

---

Function Documentation

JNIEXPORT void JNICALL Java_net_sf_farrago_fennel_FennelStorage_cancelExecution	(	JNIEnv *	,
		jclass	,
		jlong
	)

Definition at line 489 of file NativeMethods.cpp.

References CmdInterpreter::ExecutionHandle::aborted, and CmdInterpreter::getExecutionHandleFromLong().

{
    CmdInterpreter::ExecutionHandle &execHandle =
        CmdInterpreter::getExecutionHandleFromLong(handle);
    execHandle.aborted = true;
}

JNIEXPORT void JNICALL Java_net_sf_farrago_fennel_FennelStorage_deleteExecutionHandle	(	JNIEnv *	,
		jclass	,
		jlong
	)

Definition at line 478 of file NativeMethods.cpp.

References JniUtil::decrementHandleCount(), deleteAndNullify(), and CmdInterpreter::getExecutionHandleFromLong().

{
    CmdInterpreter::ExecutionHandle &execHandle =
        CmdInterpreter::getExecutionHandleFromLong(handle);
    CmdInterpreter::ExecutionHandle *pExecHandle = &execHandle;
    JniUtil::decrementHandleCount(EXECHANDLE_TRACE_TYPE_STR, pExecHandle);
    deleteAndNullify(pExecHandle);
}

JNIEXPORT void JNICALL Java_net_sf_farrago_fennel_FennelStorage_deleteObjectHandle	(	JNIEnv *	,
		jclass	,
		jlong
	)

Definition at line 421 of file NativeMethods.cpp.

References JniUtil::decrementHandleCount().

{
    // TODO:  excn handling?

    JniEnvRef pEnv(pEnvInit);
    jobject *pGlobalRef = reinterpret_cast<jobject *>(handle);
    jobject jGlobalRef = *pGlobalRef;
    if (jGlobalRef) {
        pEnv->DeleteGlobalRef(jGlobalRef);
    }
    delete pGlobalRef;
    JniUtil::decrementHandleCount(JAVAOBJECTHANDLE_TYPE_STR, pGlobalRef);
}

JNIEXPORT jlong JNICALL Java_net_sf_farrago_fennel_FennelStorage_executeJavaCmd	(	JNIEnv *	,
		jclass	,
		jobject	,
		jlong
	)

Definition at line 94 of file NativeMethods.cpp.

References CmdInterpreter::executeCommand(), CmdInterpreter::getExecutionHandleFromLong(), JniEnvRef::handleExcn(), and CmdInterpreter::pExecHandle.

{
    JniEnvRef pEnv(pEnvInit);
    try {
        ProxyCmd cmd;
        cmd.init(pEnv,jCmd);
        CmdInterpreter cmdInterpreter;
        if (jExecHandle == 0) {
            cmdInterpreter.pExecHandle = NULL;
        } else {
            CmdInterpreter::ExecutionHandle &execHandle =
                CmdInterpreter::getExecutionHandleFromLong(jExecHandle);
            cmdInterpreter.pExecHandle = &execHandle;
        }
        return cmdInterpreter.executeCommand(cmd);
    } catch (std::exception &ex) {
        pEnv.handleExcn(ex);
        return 0;
    }
}

JNIEXPORT jstring JNICALL Java_net_sf_farrago_fennel_FennelStorage_getAccessorXmiForTupleDescriptor	(	JNIEnv *	,
		jclass	,
		jobject
	)

Definition at line 320 of file NativeMethods.cpp.

References TupleAccessor::compute(), TupleAccessor::getAttributeAccessor(), TupleAccessor::getBitFieldOffset(), TupleAccessor::getMinByteCount(), JniProxy::init(), AttributeAccessor::iNullBit, isMAXU(), and CmdInterpreter::readTupleDescriptor().

{
    JniEnvRef pEnv(pEnvInit);

    // NOTE: Since JniProxies are currently read-only, generate XMI
    // representation instead.  If more of this kind of thing starts to
    // accumulate, making the JniProxies read-write would be a good idea.

    ProxyTupleDescriptor proxyTupleDesc;
    proxyTupleDesc.init(pEnv,jTupleDesc);

    // TODO:  excn handling?

    // TODO:  should take database handle and use its factory instead
    StandardTypeDescriptorFactory typeFactory;
    TupleDescriptor tupleDescriptor;
    CmdInterpreter::readTupleDescriptor(
        tupleDescriptor,
        proxyTupleDesc,
        typeFactory);
    TupleAccessor tupleAccessor;
    tupleAccessor.compute(tupleDescriptor);
    std::ostringstream oss;
    oss << "<XMI xmi.version = '1.2' "
        << "xmlns:FEMFennel = 'org.omg.xmi.namespace.FEMFennel'>" << std::endl;
    oss << "<XMI.content>" << std::endl;
    oss << "<FEMFennel:TupleAccessor minByteLength='";
    oss << tupleAccessor.getMinByteCount();
    oss << "' bitFieldOffset='";
    if (!isMAXU(tupleAccessor.getBitFieldOffset())) {
        oss << tupleAccessor.getBitFieldOffset();
    } else {
        oss << "-1";
    }
    oss << "'>" << std::endl;
    for (uint i = 0; i < tupleDescriptor.size(); ++i) {
        AttributeAccessor const &attrAccessor =
            tupleAccessor.getAttributeAccessor(i);
        oss << "<FEMFennel:TupleAccessor.AttrAccessor>";
        oss << "<FEMFennel:TupleAttrAccessor ";
        oss << "nullBitIndex='";
        if (!isMAXU(attrAccessor.iNullBit)) {
            oss << attrAccessor.iNullBit;
        } else {
            oss << "-1";
        }
        oss << "' ";
        oss << "fixedOffset='";
        if (!isMAXU(attrAccessor.iFixedOffset)) {
            oss << attrAccessor.iFixedOffset;
        } else {
            oss << "-1";
        }
        oss << "' ";
        oss << "endIndirectOffset='";
        if (!isMAXU(attrAccessor.iEndIndirectOffset)) {
            oss << attrAccessor.iEndIndirectOffset;
        } else {
            oss << "-1";
        }
        oss << "' ";
        oss << "bitValueIndex='";
        if (!isMAXU(attrAccessor.iValueBit)) {
            oss << attrAccessor.iValueBit;
        } else {
            oss << "-1";
        }
        oss << "' ";
        oss << "/>" << std::endl;
        oss << "</FEMFennel:TupleAccessor.AttrAccessor>";
    }
    oss << "</FEMFennel:TupleAccessor>" << std::endl;
    oss << "</XMI.content>" << std::endl;
    oss << "</XMI>" << std::endl;
    std::string s = oss.str();
    return pEnv->NewStringUTF(s.c_str());
}

JNIEXPORT jint JNICALL Java_net_sf_farrago_fennel_FennelStorage_getHandleCount	(	JNIEnv *	,
		jclass
	)

Definition at line 461 of file NativeMethods.cpp.

References JniUtil::getHandleCount().

{
    return JniUtil::getHandleCount();
}

JNIEXPORT jlong JNICALL Java_net_sf_farrago_fennel_FennelStorage_newExecutionHandle	(	JNIEnv *	,
		jclass
	)

Definition at line 468 of file NativeMethods.cpp.

References JniUtil::incrementHandleCount().

{
    CmdInterpreter::ExecutionHandle *pExecHandle =
        new CmdInterpreter::ExecutionHandle();
    JniUtil::incrementHandleCount(EXECHANDLE_TRACE_TYPE_STR, pExecHandle);
    return reinterpret_cast<int64_t>(pExecHandle);
}

JNIEXPORT jlong JNICALL Java_net_sf_farrago_fennel_FennelStorage_newObjectHandle	(	JNIEnv *	,
		jclass	,
		jobject
	)

Definition at line 400 of file NativeMethods.cpp.

References JniUtil::incrementHandleCount().

{
    // TODO:  excn handling?

    JniEnvRef pEnv(pEnvInit);
    jobject jGlobalRef;
    if (obj) {
        jGlobalRef = pEnv->NewGlobalRef(obj);
        // TODO:  convert to Java excn instead
        assert(jGlobalRef);
    } else {
        jGlobalRef = NULL;
    }
    jobject *pGlobalRef = new jobject;
    JniUtil::incrementHandleCount(JAVAOBJECTHANDLE_TYPE_STR, pGlobalRef);
    *pGlobalRef = jGlobalRef;
    return reinterpret_cast<jlong>(pGlobalRef);
}

JNIEXPORT void JNICALL Java_net_sf_farrago_fennel_FennelStorage_setObjectHandle	(	JNIEnv *	,
		jclass	,
		jlong	,
		jobject
	)

Definition at line 439 of file NativeMethods.cpp.

{
    // TODO:  excn handling?

    JniEnvRef pEnv(pEnvInit);
    jobject *pGlobalRef = reinterpret_cast<jobject *>(handle);
    jobject jGlobalRef = *pGlobalRef;
    if (jGlobalRef) {
        pEnv->DeleteGlobalRef(jGlobalRef);
    }
    if (obj) {
        jGlobalRef = pEnv->NewGlobalRef(obj);
        // TODO:  convert to Java excn instead
        assert(jGlobalRef);
    } else {
        jGlobalRef = NULL;
    }
    *pGlobalRef = jGlobalRef;
}

JNIEXPORT jint JNICALL Java_net_sf_farrago_fennel_FennelStorage_tupleStreamFetch	(	JNIEnv *	,
		jclass	,
		jlong	,
		jbyteArray
	)

Definition at line 117 of file NativeMethods.cpp.

References ExecStreamBufAccessor::consumeData(), EXECBUF_EOS, ExecStreamBufAccessor::getConsumptionAvailableBounded(), ExecStreamBufAccessor::getConsumptionStart(), CmdInterpreter::getExecStreamFromLong(), ExecStream::getGraph(), ExecStreamGraph::getScheduler(), ExecStreamBufAccessor::getState(), JniEnvRef::handleExcn(), ExecStreamBufAccessor::isConsumptionPossible(), and ExecStreamScheduler::readStream().

{
    JniEnvRef pEnv(pEnvInit);
    try {
        ExecStream &stream =
            CmdInterpreter::getExecStreamFromLong(hStream);
        ExecStreamScheduler *scheduler = stream.getGraph().getScheduler();
        assert(scheduler);
        ExecStreamBufAccessor &bufAccessor = scheduler->readStream(stream);
        if (bufAccessor.getState() == EXECBUF_EOS) {
            return 0;
        }
        assert(bufAccessor.isConsumptionPossible());
        uint cbLimit = uint(pEnv->GetArrayLength(byteArray));
        uint cbActual = bufAccessor.getConsumptionAvailableBounded(cbLimit);
        assert(cbActual);
        PConstBuffer pBuffer = bufAccessor.getConsumptionStart();
        assert(cbLimit >= cbActual);
        pEnv->SetByteArrayRegion(
            byteArray,0,cbActual,(jbyte *)(pBuffer));
        bufAccessor.consumeData(pBuffer + cbActual);
        return cbActual;
    } catch (std::exception &ex) {
        pEnv.handleExcn(ex);
        return 0;
    }
}

JNIEXPORT void JNICALL Java_net_sf_farrago_fennel_FennelStorage_tupleStreamGraphClose	(	JNIEnv *	,
		jclass	,
		jlong	,
		jint
	)

Definition at line 277 of file NativeMethods.cpp.

References CmdInterpreter::getStreamGraphHandleFromLong(), JniEnvRef::handleExcn(), CmdInterpreter::StreamGraphHandle::pExecStreamGraph, and CmdInterpreter::StreamGraphHandle::pScheduler.

{
    JniEnvRef pEnv(pEnvInit);
    try {
        CmdInterpreter::StreamGraphHandle &streamGraphHandle =
            CmdInterpreter::getStreamGraphHandleFromLong(hStreamGraph);
        switch (action) {
        case net_sf_farrago_fennel_FennelStorage_CLOSE_RESULT:
            if (streamGraphHandle.pScheduler.unique()) {
                streamGraphHandle.pScheduler->stop();
            }
            if (streamGraphHandle.pExecStreamGraph) {
                streamGraphHandle.pExecStreamGraph->close();
            }
            break;
        case net_sf_farrago_fennel_FennelStorage_CLOSE_ABORT:
            if (streamGraphHandle.pScheduler) {
                if (streamGraphHandle.pExecStreamGraph) {
                    streamGraphHandle.pScheduler->abort(
                        *(streamGraphHandle.pExecStreamGraph));
                }
            }
            break;
        case net_sf_farrago_fennel_FennelStorage_CLOSE_DEALLOCATE:
            if (streamGraphHandle.pScheduler) {
                if (streamGraphHandle.pScheduler.unique()) {
                    streamGraphHandle.pScheduler->stop();
                }
                streamGraphHandle.pScheduler->removeGraph(
                    streamGraphHandle.pExecStreamGraph);
            }
            delete &streamGraphHandle;
            break;
        default:
            permAssert(false);
        }
    } catch (std::exception &ex) {
        pEnv.handleExcn(ex);
    }
}

JNIEXPORT void JNICALL Java_net_sf_farrago_fennel_FennelStorage_tupleStreamGraphGetInputStreams	(	JNIEnv *	,
		jclass	,
		jlong	,
		jstring	,
		jobject
	)

Definition at line 186 of file NativeMethods.cpp.

References CmdInterpreter::getStreamGraphHandleFromLong(), JniEnvRef::handleExcn(), CmdInterpreter::StreamGraphHandle::pExecStreamGraph, and JniUtil::toStdString().

{
    JniEnvRef pEnv(pEnvInit);
    try {
        // TODO lift these to JniUtil:
        jclass classList = pEnv->FindClass("java/util/List");
        jmethodID methListAdd = pEnv->GetMethodID(classList, "add", "(Ljava/lang/Object;)Z");
        CmdInterpreter::StreamGraphHandle &streamGraphHandle =
            CmdInterpreter::getStreamGraphHandleFromLong(hStreamGraph);
        SharedExecStreamGraph pgraph = streamGraphHandle.pExecStreamGraph;
        assert(pgraph);

        SharedExecStream base =
            pgraph->findStream(JniUtil::toStdString(pEnv, baseName));
        assert(base);
        uint ct = pgraph->getInputCount(base->getStreamId());
        for (uint i = 0; i < ct; i++) {
            SharedExecStream input =
                pgraph->getStreamInput(base->getStreamId(), i);
            assert(input);
            jstring inputName = pEnv->NewStringUTF(input->getName().c_str());
            pEnv->CallObjectMethod(inputStreamNameList, methListAdd, inputName);
        }
    } catch (std::exception &ex) {
        pEnv.handleExcn(ex);
    }
}

JNIEXPORT void JNICALL Java_net_sf_farrago_fennel_FennelStorage_tupleStreamGraphOpen	(	JNIEnv *	,
		jclass	,
		jlong	,
		jlong	,
		jobject	,
		jobject
	)

Definition at line 231 of file NativeMethods.cpp.

References CmdInterpreter::getStreamGraphHandleFromLong(), CmdInterpreter::getTxnHandleFromLong(), JniEnvRef::handleExcn(), CmdInterpreter::StreamGraphHandle::javaRuntimeContext, CmdInterpreter::newErrorTarget(), CmdInterpreter::TxnHandle::pDb, CmdInterpreter::StreamGraphHandle::pExecStreamGraph, CmdInterpreter::StreamGraphHandle::pReadCommittedSegment, CmdInterpreter::TxnHandle::pReadCommittedSnapshotSegment, CmdInterpreter::TxnHandle::pResourceGovernor, CmdInterpreter::StreamGraphHandle::pScheduler, CmdInterpreter::StreamGraphHandle::pSegment, CmdInterpreter::TxnHandle::pSnapshotSegment, and CmdInterpreter::TxnHandle::pTxn.

{
    JniEnvRef pEnv(pEnvInit);
    try {
        CmdInterpreter::StreamGraphHandle &streamGraphHandle =
            CmdInterpreter::getStreamGraphHandleFromLong(hStreamGraph);
        CmdInterpreter::TxnHandle &txnHandle =
            CmdInterpreter::getTxnHandleFromLong(hTxn);
        // Provide runtime context for stream open(), which a scheduler may
        // defer til after out java caller returns: hence the global ref.
        streamGraphHandle.javaRuntimeContext =
            pEnv->NewGlobalRef(hJavaStreamMap);
        streamGraphHandle.pExecStreamGraph->setTxn(txnHandle.pTxn);

        // When snapshots are enabled, switch the delegating segment so
        // the stream graph accesses the snapshot segment associated with
        // the current txn
        SharedDatabase pDb = txnHandle.pDb;
        if (pDb->areSnapshotsEnabled()) {
            DynamicDelegatingSegment *pSegment =
                SegmentFactory::dynamicCast<DynamicDelegatingSegment *>(
                    streamGraphHandle.pSegment);
            pSegment->setDelegatingSegment(
                WeakSegment(txnHandle.pSnapshotSegment));
            pSegment =
                SegmentFactory::dynamicCast<DynamicDelegatingSegment *>(
                    streamGraphHandle.pReadCommittedSegment);
            pSegment->setDelegatingSegment(
                WeakSegment(txnHandle.pReadCommittedSnapshotSegment));
        }
        streamGraphHandle.pExecStreamGraph->setErrorTarget(
            CmdInterpreter::newErrorTarget(hJavaErrorTarget));
        txnHandle.pResourceGovernor->requestResources(
            *(streamGraphHandle.pExecStreamGraph));
        streamGraphHandle.pExecStreamGraph->open();
        if (streamGraphHandle.pScheduler.unique()) {
            streamGraphHandle.pScheduler->start();
        }
    } catch (std::exception &ex) {
        pEnv.handleExcn(ex);
    }
}

JNIEXPORT void JNICALL Java_net_sf_farrago_fennel_FennelStorage_tupleStreamRestart	(	JNIEnv *	,
		jclass	,
		jlong
	)

Definition at line 217 of file NativeMethods.cpp.

References CmdInterpreter::getExecStreamFromLong(), JniEnvRef::handleExcn(), and ExecStream::open().

{
    JniEnvRef pEnv(pEnvInit);
    try {
        ExecStream &stream =
            CmdInterpreter::getExecStreamFromLong(hStream);
        stream.open(true);
    } catch (std::exception &ex) {
        pEnv.handleExcn(ex);
    }
}

JNIEXPORT jint JNICALL Java_net_sf_farrago_fennel_FennelStorage_tupleStreamTransformFetch	(	JNIEnv *	,
		jclass	,
		jlong	,
		jint	,
		jbyteArray
	)

Definition at line 147 of file NativeMethods.cpp.

References EXECBUF_EOS, CmdInterpreter::getExecStreamFromLong(), ExecStream::getGraph(), ExecStream::getStreamId(), ExecStreamGraph::getStreamInputAccessor(), and JniEnvRef::handleExcn().

{
    JniEnvRef pEnv(pEnvInit);
    try {
        ExecStream &stream =
            CmdInterpreter::getExecStreamFromLong(hStream);

        uint iInput = static_cast<uint>(inputOrdinal);

        SharedExecStreamBufAccessor bufAccessor =
            stream.getGraph().getStreamInputAccessor(
                stream.getStreamId(), iInput);

        if (bufAccessor->getState() == EXECBUF_EOS) {
            return 0;
        }

        if (!bufAccessor->isConsumptionPossible()) {
            return -1;
        }

        uint cbLimit = uint(pEnv->GetArrayLength(byteArray));
        uint cbActual = bufAccessor->getConsumptionAvailableBounded(cbLimit);
        assert(cbActual);
        PConstBuffer pBuffer = bufAccessor->getConsumptionStart();
        assert(cbLimit >= cbActual);
        pEnv->SetByteArrayRegion(
            byteArray,0,cbActual,(jbyte *)(pBuffer));
        bufAccessor->consumeData(pBuffer + cbActual);
        return cbActual;
    } catch (std::exception &ex) {
        pEnv.handleExcn(ex);
        return 0;
    }
}

---