Lines Matching refs:pConn
892 sp<NfaConn> pConn = NULL; in send() local
894 if ((pConn = findConnection (jniHandle)) == NULL) in send()
901 fn, pConn->mJniHandle, pConn->mNfaConnHandle); in send()
905 SyncEventGuard guard (pConn->mCongEvent); in send()
906 nfaStat = NFA_P2pSendData (pConn->mNfaConnHandle, bufferLen, buffer); in send()
908 pConn->mCongEvent.wait (); //wait for NFA_P2P_CONGEST_EVT in send()
912 if (pConn->mNfaConnHandle == NFA_HANDLE_INVALID) //peer already disconnected in send()
920 …L_DEBUG), "%s: exit OK; JNI handle: %u NFA Handle: 0x%04x", fn, jniHandle, pConn->mNfaConnHandle); in send()
923 fn, jniHandle, pConn->mNfaConnHandle, nfaStat); in send()
946 sp<NfaConn> pConn = NULL; in receive() local
952 if ((pConn = findConnection (jniHandle)) == NULL) in receive()
958 …DEBUG), "%s: jniHandle: %u nfaHandle: 0x%04X buf len=%u", fn, pConn->mJniHandle, pConn->mNfaConn… in receive()
960 while (pConn->mNfaConnHandle != NFA_HANDLE_INVALID) in receive()
963 … stat = NFA_P2pReadData (pConn->mNfaConnHandle, bufferLen, &actualDataLen2, buffer, &isMoreData); in receive()
972 SyncEventGuard guard (pConn->mReadEvent); in receive()
973 pConn->mReadEvent.wait(); in receive()
977 …_TRACE_LEVEL_DEBUG), "%s: exit; nfa h: 0x%X ok: %u actual len: %u", fn, pConn->mNfaConnHandle, r… in receive()
997 sp<NfaConn> pConn = NULL; in disconnectConnOriented() local
1001 if ((pConn = findConnection(jniHandle)) == NULL) in disconnectConnOriented()
1016 SyncEventGuard guard1 (pConn->mCongEvent); in disconnectConnOriented()
1017 pConn->mCongEvent.notifyOne (); //unblock send() if congested in disconnectConnOriented()
1020 SyncEventGuard guard2 (pConn->mReadEvent); in disconnectConnOriented()
1021 pConn->mReadEvent.notifyOne (); //unblock receive() in disconnectConnOriented()
1024 if (pConn->mNfaConnHandle != NFA_HANDLE_INVALID) in disconnectConnOriented()
1026 ALOGV("%s: try disconn nfa h=0x%04X", fn, pConn->mNfaConnHandle); in disconnectConnOriented()
1027 SyncEventGuard guard (pConn->mDisconnectingEvent); in disconnectConnOriented()
1028 nfaStat = NFA_P2pDisconnect (pConn->mNfaConnHandle, FALSE); in disconnectConnOriented()
1033 pConn->mDisconnectingEvent.wait(); in disconnectConnOriented()
1058 sp<NfaConn> pConn = NULL; in getRemoteMaxInfoUnit() local
1060 if ((pConn = findConnection(jniHandle)) == NULL) in getRemoteMaxInfoUnit()
1065 ALOGV("%s: jniHandle: %u MIU: %u", fn, jniHandle, pConn->mRemoteMaxInfoUnit); in getRemoteMaxInfoUnit()
1066 return (pConn->mRemoteMaxInfoUnit); in getRemoteMaxInfoUnit()
1084 sp<NfaConn> pConn = NULL; in getRemoteRecvWindow() local
1086 if ((pConn = findConnection(jniHandle)) == NULL) in getRemoteRecvWindow()
1091 return pConn->mRemoteRecvWindow; in getRemoteRecvWindow()
1270 sp<NfaConn> pConn = NULL; in nfaServerCallback() local
1318 if ((pConn = pSrv->findServerConnection((tNFA_HANDLE) NFA_HANDLE_INVALID)) == NULL) in nfaServerCallback()
1325 pConn->mNfaConnHandle = eventData->conn_req.conn_handle; in nfaServerCallback()
1326 pConn->mRemoteMaxInfoUnit = eventData->conn_req.remote_miu; in nfaServerCallback()
1327 pConn->mRemoteRecvWindow = eventData->conn_req.remote_rw; in nfaServerCallback()
1328 …EQ_EVT; server jni h=%u; conn jni h=%u; notify conn req", fn, pSrv->mJniHandle, pConn->mJniHandle); in nfaServerCallback()
1341 if ((pConn = sP2p.findConnection(eventData->disc.handle)) == NULL) in nfaServerCallback()
1348 pConn->mNfaConnHandle = NFA_HANDLE_INVALID; in nfaServerCallback()
1351 SyncEventGuard guard3 (pConn->mDisconnectingEvent); in nfaServerCallback()
1352 pConn->mDisconnectingEvent.notifyOne (); in nfaServerCallback()
1357 SyncEventGuard guard1 (pConn->mCongEvent); in nfaServerCallback()
1358 pConn->mCongEvent.notifyOne (); //unblock write (if congested) in nfaServerCallback()
1363 SyncEventGuard guard2 (pConn->mReadEvent); in nfaServerCallback()
1364 pConn->mReadEvent.notifyOne (); //unblock receive() in nfaServerCallback()
1373 if ((pConn = sP2p.findConnection(eventData->data.handle)) == NULL) in nfaServerCallback()
1381 SyncEventGuard guard (pConn->mReadEvent); in nfaServerCallback()
1382 pConn->mReadEvent.notifyOne(); in nfaServerCallback()
1388 if ((pConn = sP2p.findConnection(eventData->congest.handle)) == NULL) in nfaServerCallback()
1398 SyncEventGuard guard (pConn->mCongEvent); in nfaServerCallback()
1399 pConn->mCongEvent.notifyOne(); in nfaServerCallback()
1426 sp<NfaConn> pConn = NULL; in nfaClientCallback() local
1487 if ((pConn = sP2p.findConnection(eventData->disc.handle)) == NULL) in nfaClientCallback()
1502 pConn->mNfaConnHandle = NFA_HANDLE_INVALID; in nfaClientCallback()
1505 SyncEventGuard guard3 (pConn->mDisconnectingEvent); in nfaClientCallback()
1506 pConn->mDisconnectingEvent.notifyOne (); in nfaClientCallback()
1511 SyncEventGuard guard1 (pConn->mCongEvent); in nfaClientCallback()
1512 pConn->mCongEvent.notifyOne(); //unblock write (if congested) in nfaClientCallback()
1517 SyncEventGuard guard2 (pConn->mReadEvent); in nfaClientCallback()
1518 pConn->mReadEvent.notifyOne(); //unblock receive() in nfaClientCallback()
1527 if ((pConn = sP2p.findConnection(eventData->data.handle)) == NULL) in nfaClientCallback()
1535 SyncEventGuard guard (pConn->mReadEvent); in nfaClientCallback()
1536 pConn->mReadEvent.notifyOne(); in nfaClientCallback()
1542 if ((pConn = sP2p.findConnection(eventData->congest.handle)) == NULL) in nfaClientCallback()
1551 SyncEventGuard guard (pConn->mCongEvent); in nfaClientCallback()
1552 pConn->mCongEvent.notifyOne(); in nfaClientCallback()