| | |
| | | // 返回 >= 0连接成功 |
| | | int CPin::accpetConnect(CPin* pPin) |
| | | { |
| | | assert(pPin); |
| | | ASSERT(pPin); |
| | | |
| | | |
| | | // 是否已经连接 |
| | |
| | | |
| | | int CPin::connectPin(CPin* pPin) |
| | | { |
| | | assert(pPin); |
| | | ASSERT(pPin); |
| | | |
| | | |
| | | // 是否已经连接 |
| | |
| | | return -1; |
| | | } |
| | | |
| | | assert(m_pConnectedPin->m_pConnectedPin == this); |
| | | ASSERT(m_pConnectedPin->m_pConnectedPin == this); |
| | | m_pConnectedPin->m_pConnectedPin = NULL; |
| | | m_pConnectedPin = NULL; |
| | | |
| | | return 0; |
| | | } |
| | | |
| | | int CPin::sendSample(CSample* pSample) |
| | | int CPin::sendIntent(CIntent* pIntent) |
| | | { |
| | | if (m_pConnectedPin != NULL) { |
| | | m_pConnectedPin->recvSample(pSample); |
| | | return m_pConnectedPin->recvIntent(pIntent); |
| | | } |
| | | |
| | | return 0; |
| | | return FLOW_REJECT; |
| | | } |
| | | |
| | | int CPin::recvSample(CSample* pSample) |
| | | int CPin::recvIntent(CIntent* pIntent) |
| | | { |
| | | assert(m_pEquipment); |
| | | m_pEquipment->recvSample(this, pSample); |
| | | return 0; |
| | | ASSERT(m_pEquipment); |
| | | return m_pEquipment->recvIntent(this, pIntent); |
| | | } |
| | | } |