| /* |
| * Copyright (C) 2012 The Android Open Source Project |
| * |
| * Licensed 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 <semaphore.h> |
| #include <errno.h> |
| #include "OverrideLog.h" |
| #include "NfcJniUtil.h" |
| #include "JavaClassConstants.h" |
| #include <ScopedLocalRef.h> |
| #include <ScopedPrimitiveArray.h> |
| extern "C" |
| { |
| #include "nfa_api.h" |
| #include "nfa_p2p_api.h" |
| } |
| |
| |
| namespace android |
| { |
| |
| |
| /***************************************************************************** |
| ** |
| ** private variables and functions |
| ** |
| *****************************************************************************/ |
| static sem_t sConnlessRecvSem; |
| static jboolean sConnlessRecvWaitingForData = JNI_FALSE; |
| static uint8_t* sConnlessRecvBuf = NULL; |
| static uint32_t sConnlessRecvLen = 0; |
| static uint32_t sConnlessRecvRemoteSap = 0; |
| |
| |
| /******************************************************************************* |
| ** |
| ** Function: nativeLlcpConnectionlessSocket_doSendTo |
| ** |
| ** Description: Send data to peer. |
| ** e: JVM environment. |
| ** o: Java object. |
| ** nsap: service access point. |
| ** data: buffer for data. |
| ** |
| ** Returns: True if ok. |
| ** |
| *******************************************************************************/ |
| static jboolean nativeLlcpConnectionlessSocket_doSendTo (JNIEnv *e, jobject o, jint nsap, jbyteArray data) |
| { |
| ALOGD ("%s: nsap = %d", __FUNCTION__, nsap); |
| |
| ScopedLocalRef<jclass> c(e, e->GetObjectClass(o)); |
| jfieldID f = e->GetFieldID(c.get(), "mHandle", "I"); |
| jint handle = e->GetIntField(o, f); |
| |
| ScopedByteArrayRO bytes(e, data); |
| if (bytes.get() == NULL) { |
| return JNI_FALSE; |
| } |
| size_t byte_count = bytes.size(); |
| |
| ALOGD("NFA_P2pSendUI: len = %d", byte_count); |
| UINT8* raw_ptr = const_cast<UINT8*>(reinterpret_cast<const UINT8*>(&bytes[0])); // TODO: API bug; NFA_P2pSendUI should take const*! |
| tNFA_STATUS status = NFA_P2pSendUI((tNFA_HANDLE) handle, nsap, byte_count, raw_ptr); |
| |
| ALOGD("%s: NFA_P2pSendUI done, status = %d", __FUNCTION__, status); |
| if (status != NFA_STATUS_OK) { |
| ALOGE("%s: NFA_P2pSendUI failed, status = %d", __FUNCTION__, status); |
| return JNI_FALSE; |
| } |
| return JNI_TRUE; |
| } |
| |
| |
| /******************************************************************************* |
| ** |
| ** Function: nativeLlcpConnectionlessSocket_receiveData |
| ** |
| ** Description: Receive data from the stack. |
| ** data: buffer contains data. |
| ** len: length of data. |
| ** remoteSap: remote service access point. |
| ** |
| ** Returns: None |
| ** |
| *******************************************************************************/ |
| void nativeLlcpConnectionlessSocket_receiveData (uint8_t* data, uint32_t len, uint32_t remoteSap) |
| { |
| ALOGD ("%s: waiting for data = %d, len = %d", __FUNCTION__, sConnlessRecvWaitingForData, len); |
| |
| // Sanity... |
| if (sConnlessRecvLen < len) |
| { |
| len = sConnlessRecvLen; |
| } |
| |
| if (sConnlessRecvWaitingForData) |
| { |
| sConnlessRecvWaitingForData = JNI_FALSE; |
| sConnlessRecvLen = len; |
| memcpy (sConnlessRecvBuf, data, len); |
| sConnlessRecvRemoteSap = remoteSap; |
| |
| sem_post (&sConnlessRecvSem); |
| } |
| } |
| |
| |
| /******************************************************************************* |
| ** |
| ** Function: connectionlessCleanup |
| ** |
| ** Description: Free resources. |
| ** |
| ** Returns: None |
| ** |
| *******************************************************************************/ |
| static jobject connectionlessCleanup () |
| { |
| sConnlessRecvWaitingForData = JNI_FALSE; |
| sConnlessRecvLen = 0; |
| if (sConnlessRecvBuf != NULL) |
| { |
| free (sConnlessRecvBuf); |
| sConnlessRecvBuf = NULL; |
| } |
| return NULL; |
| } |
| |
| |
| /******************************************************************************* |
| ** |
| ** Function: nativeLlcpConnectionlessSocket_abortWait |
| ** |
| ** Description: Abort current operation and unblock threads. |
| ** |
| ** Returns: None |
| ** |
| *******************************************************************************/ |
| void nativeLlcpConnectionlessSocket_abortWait () |
| { |
| sem_post (&sConnlessRecvSem); |
| } |
| |
| |
| /******************************************************************************* |
| ** |
| ** Function: nativeLlcpConnectionlessSocket_doReceiveFrom |
| ** |
| ** Description: Receive data from a peer. |
| ** e: JVM environment. |
| ** o: Java object. |
| ** linkMiu: max info unit |
| ** |
| ** Returns: LlcpPacket Java object. |
| ** |
| *******************************************************************************/ |
| static jobject nativeLlcpConnectionlessSocket_doReceiveFrom (JNIEnv* e, jobject, jint linkMiu) |
| { |
| ALOGD ("%s: linkMiu = %d", __FUNCTION__, linkMiu); |
| jobject llcpPacket = NULL; |
| ScopedLocalRef<jclass> clsLlcpPacket(e, NULL); |
| |
| if (sConnlessRecvWaitingForData != JNI_FALSE) |
| { |
| ALOGD ("%s: Already waiting for incoming data", __FUNCTION__); |
| return NULL; |
| } |
| |
| sConnlessRecvBuf = (uint8_t*) malloc (linkMiu); |
| if (sConnlessRecvBuf == NULL) |
| { |
| ALOGD ("%s: Failed to allocate %d bytes memory buffer", __FUNCTION__, linkMiu); |
| return NULL; |
| } |
| sConnlessRecvLen = linkMiu; |
| |
| // Create the write semaphore |
| if (sem_init (&sConnlessRecvSem, 0, 0) == -1) |
| { |
| ALOGE ("%s: semaphore creation failed (errno=0x%08x)", __FUNCTION__, errno); |
| return connectionlessCleanup (); |
| } |
| |
| sConnlessRecvWaitingForData = JNI_TRUE; |
| |
| // Wait for sConnlessRecvSem completion status |
| if (sem_wait (&sConnlessRecvSem)) |
| { |
| ALOGE ("%s: Failed to wait for write semaphore (errno=0x%08x)", __FUNCTION__, errno); |
| goto TheEnd; |
| } |
| |
| // Create new LlcpPacket object |
| if (nfc_jni_cache_object (e, "com/android/nfc/LlcpPacket", &(llcpPacket)) == -1) |
| { |
| ALOGE ("%s: Find LlcpPacket class error", __FUNCTION__); |
| return connectionlessCleanup (); |
| } |
| |
| // Get NativeConnectionless class object |
| clsLlcpPacket.reset(e->GetObjectClass(llcpPacket)); |
| if (e->ExceptionCheck()) |
| { |
| e->ExceptionClear(); |
| ALOGE ("%s: Get Object class error", __FUNCTION__); |
| return connectionlessCleanup (); |
| } |
| |
| // Set Llcp Packet remote SAP |
| jfieldID f; |
| f = e->GetFieldID(clsLlcpPacket.get(), "mRemoteSap", "I"); |
| e->SetIntField(llcpPacket, f, (jbyte) sConnlessRecvRemoteSap); |
| |
| // Set Llcp Packet Buffer |
| ALOGD ("%s: Received Llcp packet buffer size = %d\n", __FUNCTION__, sConnlessRecvLen); |
| f = e->GetFieldID(clsLlcpPacket.get(), "mDataBuffer", "[B"); |
| |
| { |
| ScopedLocalRef<jbyteArray> receivedData(e, e->NewByteArray(sConnlessRecvLen)); |
| e->SetByteArrayRegion(receivedData.get(), 0, sConnlessRecvLen, (jbyte*) sConnlessRecvBuf); |
| e->SetObjectField(llcpPacket, f, receivedData.get()); |
| } |
| |
| TheEnd: // TODO: should all the "return connectionlessCleanup()"s in this function jump here instead? |
| connectionlessCleanup (); |
| if (sem_destroy (&sConnlessRecvSem)) |
| { |
| ALOGE ("%s: Failed to destroy sConnlessRecvSem semaphore (errno=0x%08x)", __FUNCTION__, errno); |
| } |
| return llcpPacket; |
| } |
| |
| |
| /******************************************************************************* |
| ** |
| ** Function: nativeLlcpConnectionlessSocket_doClose |
| ** |
| ** Description: Close socket. |
| ** e: JVM environment. |
| ** o: Java object. |
| ** |
| ** Returns: True if ok. |
| ** |
| *******************************************************************************/ |
| static jboolean nativeLlcpConnectionlessSocket_doClose (JNIEnv *e, jobject o) |
| { |
| ALOGD ("%s", __FUNCTION__); |
| |
| ScopedLocalRef<jclass> c(e, e->GetObjectClass(o)); |
| jfieldID f = e->GetFieldID(c.get(), "mHandle", "I"); |
| jint handle = e->GetIntField(o, f); |
| |
| tNFA_STATUS status = NFA_P2pDisconnect((tNFA_HANDLE) handle, FALSE); |
| if (status != NFA_STATUS_OK) { |
| ALOGE ("%s: disconnect failed, status = %d", __FUNCTION__, status); |
| return JNI_FALSE; |
| } |
| return JNI_TRUE; |
| } |
| |
| |
| /***************************************************************************** |
| ** |
| ** Description: JNI functions |
| ** |
| *****************************************************************************/ |
| static JNINativeMethod gMethods[] = |
| { |
| {"doSendTo", "(I[B)Z", (void*) nativeLlcpConnectionlessSocket_doSendTo}, |
| {"doReceiveFrom", "(I)Lcom/android/nfc/LlcpPacket;", (void*) nativeLlcpConnectionlessSocket_doReceiveFrom}, |
| {"doClose", "()Z", (void*) nativeLlcpConnectionlessSocket_doClose}, |
| }; |
| |
| |
| /******************************************************************************* |
| ** |
| ** Function: register_com_android_nfc_NativeLlcpConnectionlessSocket |
| ** |
| ** Description: Regisgter JNI functions with Java Virtual Machine. |
| ** e: Environment of JVM. |
| ** |
| ** Returns: Status of registration. |
| ** |
| *******************************************************************************/ |
| int register_com_android_nfc_NativeLlcpConnectionlessSocket (JNIEnv *e) |
| { |
| return jniRegisterNativeMethods (e, gNativeLlcpConnectionlessSocketClassName, gMethods, NELEM(gMethods)); |
| } |
| |
| |
| } // android namespace |