Lines Matching refs:pConn
852 sp<NfaConn> pConn = NULL; in send() local
854 if ((pConn = findConnection(jniHandle)) == NULL) { in send()
862 pConn->mJniHandle, pConn->mNfaConnHandle); in send()
865 SyncEventGuard guard(pConn->mCongEvent); in send()
866 nfaStat = NFA_P2pSendData(pConn->mNfaConnHandle, bufferLen, buffer); in send()
868 pConn->mCongEvent.wait(); // wait for NFA_P2P_CONGEST_EVT in send()
872 if (pConn->mNfaConnHandle == in send()
884 jniHandle, pConn->mNfaConnHandle); in send()
888 fn, jniHandle, pConn->mNfaConnHandle, nfaStat); in send()
911 sp<NfaConn> pConn = NULL; in receive() local
917 if ((pConn = findConnection(jniHandle)) == NULL) { in receive()
925 pConn->mJniHandle, pConn->mNfaConnHandle, bufferLen); in receive()
927 while (pConn->mNfaConnHandle != NFA_HANDLE_INVALID) { in receive()
929 stat = NFA_P2pReadData(pConn->mNfaConnHandle, bufferLen, &actualDataLen2, in receive()
940 SyncEventGuard guard(pConn->mReadEvent); in receive()
941 pConn->mReadEvent.wait(); in receive()
947 pConn->mNfaConnHandle, retVal, actualLen); in receive()
965 sp<NfaConn> pConn = NULL; in disconnectConnOriented() local
970 if ((pConn = findConnection(jniHandle)) == NULL) { in disconnectConnOriented()
985 SyncEventGuard guard1(pConn->mCongEvent); in disconnectConnOriented()
986 pConn->mCongEvent.notifyOne(); // unblock send() if congested in disconnectConnOriented()
989 SyncEventGuard guard2(pConn->mReadEvent); in disconnectConnOriented()
990 pConn->mReadEvent.notifyOne(); // unblock receive() in disconnectConnOriented()
993 if (pConn->mNfaConnHandle != NFA_HANDLE_INVALID) { in disconnectConnOriented()
995 "%s: try disconn nfa h=0x%04X", fn, pConn->mNfaConnHandle); in disconnectConnOriented()
996 SyncEventGuard guard(pConn->mDisconnectingEvent); in disconnectConnOriented()
997 nfaStat = NFA_P2pDisconnect(pConn->mNfaConnHandle, FALSE); in disconnectConnOriented()
1002 pConn->mDisconnectingEvent.wait(); in disconnectConnOriented()
1026 sp<NfaConn> pConn = NULL; in getRemoteMaxInfoUnit() local
1028 if ((pConn = findConnection(jniHandle)) == NULL) { in getRemoteMaxInfoUnit()
1034 "%s: jniHandle: %u MIU: %u", fn, jniHandle, pConn->mRemoteMaxInfoUnit); in getRemoteMaxInfoUnit()
1035 return (pConn->mRemoteMaxInfoUnit); in getRemoteMaxInfoUnit()
1052 sp<NfaConn> pConn = NULL; in getRemoteRecvWindow() local
1054 if ((pConn = findConnection(jniHandle)) == NULL) { in getRemoteRecvWindow()
1058 return pConn->mRemoteRecvWindow; in getRemoteRecvWindow()
1217 sp<NfaConn> pConn = NULL; in nfaServerCallback() local
1277 if ((pConn = pSrv->findServerConnection( in nfaServerCallback()
1283 pConn->mNfaConnHandle = eventData->conn_req.conn_handle; in nfaServerCallback()
1284 pConn->mRemoteMaxInfoUnit = eventData->conn_req.remote_miu; in nfaServerCallback()
1285 pConn->mRemoteRecvWindow = eventData->conn_req.remote_rw; in nfaServerCallback()
1289 fn, pSrv->mJniHandle, pConn->mJniHandle); in nfaServerCallback()
1305 if ((pConn = sP2p.findConnection(eventData->disc.handle)) == NULL) { in nfaServerCallback()
1311 pConn->mNfaConnHandle = NFA_HANDLE_INVALID; in nfaServerCallback()
1315 SyncEventGuard guard3(pConn->mDisconnectingEvent); in nfaServerCallback()
1316 pConn->mDisconnectingEvent.notifyOne(); in nfaServerCallback()
1323 SyncEventGuard guard1(pConn->mCongEvent); in nfaServerCallback()
1324 pConn->mCongEvent.notifyOne(); // unblock write (if congested) in nfaServerCallback()
1331 SyncEventGuard guard2(pConn->mReadEvent); in nfaServerCallback()
1332 pConn->mReadEvent.notifyOne(); // unblock receive() in nfaServerCallback()
1342 if ((pConn = sP2p.findConnection(eventData->data.handle)) == NULL) { in nfaServerCallback()
1350 SyncEventGuard guard(pConn->mReadEvent); in nfaServerCallback()
1351 pConn->mReadEvent.notifyOne(); in nfaServerCallback()
1357 if ((pConn = sP2p.findConnection(eventData->congest.handle)) == NULL) { in nfaServerCallback()
1366 SyncEventGuard guard(pConn->mCongEvent); in nfaServerCallback()
1367 pConn->mCongEvent.notifyOne(); in nfaServerCallback()
1394 sp<NfaConn> pConn = NULL; in nfaClientCallback() local
1466 if ((pConn = sP2p.findConnection(eventData->disc.handle)) == NULL) { in nfaClientCallback()
1479 pConn->mNfaConnHandle = NFA_HANDLE_INVALID; in nfaClientCallback()
1483 SyncEventGuard guard3(pConn->mDisconnectingEvent); in nfaClientCallback()
1484 pConn->mDisconnectingEvent.notifyOne(); in nfaClientCallback()
1491 SyncEventGuard guard1(pConn->mCongEvent); in nfaClientCallback()
1492 pConn->mCongEvent.notifyOne(); // unblock write (if congested) in nfaClientCallback()
1499 SyncEventGuard guard2(pConn->mReadEvent); in nfaClientCallback()
1500 pConn->mReadEvent.notifyOne(); // unblock receive() in nfaClientCallback()
1510 if ((pConn = sP2p.findConnection(eventData->data.handle)) == NULL) { in nfaClientCallback()
1518 SyncEventGuard guard(pConn->mReadEvent); in nfaClientCallback()
1519 pConn->mReadEvent.notifyOne(); in nfaClientCallback()
1525 if ((pConn = sP2p.findConnection(eventData->congest.handle)) == NULL) { in nfaClientCallback()
1534 SyncEventGuard guard(pConn->mCongEvent); in nfaClientCallback()
1535 pConn->mCongEvent.notifyOne(); in nfaClientCallback()