/*

* Copyright (c) 2008 Nokia Corporation and/or its subsidiary(-ies).

* All rights reserved.

* This component and the accompanying materials are made available

* under the terms of "Eclipse Public License v1.0"

* which accompanies this distribution, and is available

* at the URL "http://www.eclipse.org/legal/epl-v10.html".

*

* Initial Contributors:

* Nokia Corporation - initial contribution.

*

* Contributors:

*

* Description:

 *

*/

#include "com_nokia_mj_impl_datagram_UDPDatagramConnectionImpl.h"

#include "stdlib.h"

#include "string.h"

#include "nativedatagramconnection.h"

#include "logger.h"

#include "pushexception.h"

#include "pusherrorcodes.h"

using namespace java;

JNIEXPORT jint JNICALL Java_com_nokia_mj_impl_datagram_UDPDatagramConnectionImpl__1createNativePeer

(JNIEnv* aJni, jobject /*peer*/, jstring aName, jint aMode, jstring aHost, jint aPort)

{

    const char* name = aJni->GetStringUTFChars(aName, 0);

    const char* host = aJni->GetStringUTFChars(aHost, 0);

    NativeDatagramConnection* datagramConn = new NativeDatagramConnection(name, aMode, host, aPort);

    // Delete the memory

    (aJni)->ReleaseStringUTFChars(aName, name);

    (aJni)->ReleaseStringUTFChars(aHost, host);

    return reinterpret_cast<jint>(datagramConn);

}

JNIEXPORT jint JNICALL Java_com_nokia_mj_impl_datagram_UDPDatagramConnectionImpl__1openConnection

(JNIEnv* aJni, jobject /*peer*/, jint nativePeerHandle, jint aType, jint aApn, jintArray  aReturnValue)

{

    int err  = 0;

    NativeDatagramConnection* datagramConn = reinterpret_cast<NativeDatagramConnection*>(nativePeerHandle);

    try

    {

        int retVal = datagramConn->openConnection(aType, aApn, &err);

        LOG1(ESOCKET,EInfo,"DatagramConnectionJni : openconnection return value : %d",retVal);

        aJni->SetIntArrayRegion(aReturnValue,0,1,&err);

        return retVal;

    }

    catch (PushException& ex)

    {

        ELOG(ESOCKET,"ERROR!!! CreateConnection() PushException was caught");

        if (datagramConn!=NULL)

        {

            datagramConn->datagramClose();

            delete datagramConn;

            datagramConn = NULL;

        }

        return ex.mErrCode;

    }

}

JNIEXPORT jint JNICALL Java_com_nokia_mj_impl_datagram_UDPDatagramConnectionImpl__1send

(JNIEnv *aJni, jobject, jint nativePeerHandle, jbyteArray aJavaBuffer, jint aOffset, jint aLength, jstring aDestAddr, jint aDestPort)

{

    const char* destaddr = aJni->GetStringUTFChars(aDestAddr, 0);

    NativeDatagramConnection* datagramConn = reinterpret_cast<NativeDatagramConnection*>(nativePeerHandle);

    int retVal = datagramConn->sendDatagram(*aJni,aJavaBuffer,aOffset,aLength,destaddr,aDestPort);

    aJni->ReleaseStringUTFChars(aDestAddr,destaddr);

    return retVal;

}

JNIEXPORT jint JNICALL Java_com_nokia_mj_impl_datagram_UDPDatagramConnectionImpl__1receive

(JNIEnv *aJni, jobject, jint nativePeerHandle, jbyteArray aJavaBuffer, jint aOffset, jint aLength, jobjectArray aSenderAddr, jintArray aSenderPort)

{

    int port;

    jstring jnistring;

    char * addr = new char[256];

    LOG1(ESOCKET,EInfo,"Datagram JNI, receive called len = %d", aLength);

    NativeDatagramConnection* datagramConn = reinterpret_cast<NativeDatagramConnection*>(nativePeerHandle);

    int retVal = datagramConn->receiveDatagram(*aJni,aJavaBuffer,aOffset,aLength,addr,&port);

    LOG1(ESOCKET,EInfo,"addr = %s",addr);

    jnistring = aJni->NewStringUTF(addr);

    aJni->SetObjectArrayElement(aSenderAddr,0,jnistring);

    aJni->SetIntArrayRegion(aSenderPort,0,1,&port);

    LOG1(ESOCKET,EInfo,"Datagram JNI, receive called ", 2);

    LOG1(ESOCKET,EInfo,"Datagram JNI, receive called , offset %d", aOffset);

    LOG1(ESOCKET,EInfo,"Datagram JNI, receive called , len %d", aLength);

    LOG1(ESOCKET,EInfo,"Datagram JNI, receive, returning ", 2);

    return retVal;

}

JNIEXPORT jint JNICALL Java_com_nokia_mj_impl_datagram_UDPDatagramConnectionImpl__1getLocalAddress

(JNIEnv *aJni, jobject, jint nativePeerHandle, jobjectArray aAddress)

{

    char * addr = new char[256];

    NativeDatagramConnection* datagramConn = reinterpret_cast<NativeDatagramConnection*>(nativePeerHandle);

    int retVal = datagramConn->getLocalAddress(addr);

    jstring jnistring = aJni->NewStringUTF(addr);

    aJni->SetObjectArrayElement(aAddress, 0, jnistring);

    aJni->DeleteLocalRef(jnistring);

    delete[] addr;

    return retVal;

}

JNIEXPORT jint JNICALL Java_com_nokia_mj_impl_datagram_UDPDatagramConnectionImpl__1getLocalPort

(JNIEnv* /*aJni*/, jobject, jint nativePeerHandle)

{

    NativeDatagramConnection * datagramConn = reinterpret_cast<NativeDatagramConnection *>(nativePeerHandle);

    return datagramConn->getLocalPort();

}

JNIEXPORT jint JNICALL Java_com_nokia_mj_impl_datagram_UDPDatagramConnectionImpl__1close

(JNIEnv* /*aJni*/, jobject, jint nativePeerHandle)

{

    NativeDatagramConnection * datagramConn = reinterpret_cast<NativeDatagramConnection *>(nativePeerHandle);

    return datagramConn->datagramClose();

}

JNIEXPORT void JNICALL Java_com_nokia_mj_impl_datagram_UDPDatagramConnectionImpl__1dispose

(JNIEnv* /*aJni*/, jobject, jint nativePeerHandle)

{

    NativeDatagramConnection * datagramConn = reinterpret_cast<NativeDatagramConnection *>(nativePeerHandle);

    delete datagramConn;

}