equal
deleted
inserted
replaced
468 void ConnStates::TProcessIncomingConnection::DoL() |
468 void ConnStates::TProcessIncomingConnection::DoL() |
469 { |
469 { |
470 __ASSERT_DEBUG(iContext.iNodeActivity, ConnPanic(KPanicNoActivity)); |
470 __ASSERT_DEBUG(iContext.iNodeActivity, ConnPanic(KPanicNoActivity)); |
471 CSubConnection* waitingSubConn = iContext.Node().Session()->CSubConnectionFromHandle(static_cast<CESockClientActivityBase&>(*iContext.iNodeActivity).Int0()); |
471 CSubConnection* waitingSubConn = iContext.Node().Session()->CSubConnectionFromHandle(static_cast<CESockClientActivityBase&>(*iContext.iNodeActivity).Int0()); |
472 User::LeaveIfError(waitingSubConn != NULL ? KErrNone : KErrCancel); |
472 User::LeaveIfError(waitingSubConn != NULL ? KErrNone : KErrCancel); |
473 |
473 RNodeInterface* waitingSubConnPeer = iContext.Node().FindClient(waitingSubConn->Id()); //To my surprise SC is a peer of this (so must use peer handle when talking to it) |
|
474 __ASSERT_DEBUG(waitingSubConnPeer, ConnPanic(KPanicNoDataClient)); |
|
475 |
474 TCFServiceProvider::TCommsBinderResponse& binderResp = message_cast<TCFServiceProvider::TCommsBinderResponse>(iContext.iMessage); |
476 TCFServiceProvider::TCommsBinderResponse& binderResp = message_cast<TCFServiceProvider::TCommsBinderResponse>(iContext.iMessage); |
475 iContext.iNodeActivity->PostRequestTo(waitingSubConn->Id(), |
477 iContext.iNodeActivity->PostRequestTo(*waitingSubConnPeer, |
476 TCFDataClient::TBindTo(binderResp.iNodeId).CRef()); |
478 TCFDataClient::TBindTo(binderResp.iNodeId).CRef()); |
477 } |
479 } |
478 |
480 |
479 |
481 |
480 // |
482 // |