16 #include <nn/pia/transport/transport_Definitions.h>
40 class TransportThreadStreamOld;
42 class SendThreadStream;
43 class ReceiveThreadStream;
63 #elif NN_PIA_NINTENDOSDK
82 #error "invalid platform"
109 uint32_t sendThreadMaxPacketNum,
110 uint32_t receiveThreadMaxPacketNum,
111 uint32_t sendThreadLatencyEmulationPacketNum,
112 uint32_t receiveThreadLatencyEmulationPacketNum,
113 bool bPacketLossEmulation);
124 static void DestroyInstance(
void);
457 ReceiveThreadStream* GetReceiveStream(
void)
459 return m_pReceiveStream;
468 const ReceiveThreadStream* GetReceiveStream(
void)
const
470 return m_pReceiveStream;
479 SendThreadStream* GetSendStream(
void)
481 return m_pSendStream;
490 const SendThreadStream* GetSendStream(
void)
const
492 return m_pSendStream;
501 common::IPacketInput* GetInputStream(
void)
503 return m_pInputStream;
511 common::IPacketOutput* GetOutputStream(
void)
513 return m_pOutputStream;
522 void SetMonitoringData(
void);
531 virtual void Trace(uint64_t flag)
const;
534 #if NN_PIA_ENABLE_STATISTIC_THREAD_STREAM_BLOCK_TIME
535 void ResetThreadStreamStatistic();
536 void PrintThreadStreamStatistic(uint32_t printMaxDataNum);
543 ThreadStreamManager(
void);
548 ThreadStreamManager(NetworkFactory* pFactory,
549 uint32_t sendThreadMaxPacketNum,
550 uint32_t receiveThreadMaxPacketNum,
551 uint32_t sendThreadLatencyEmulationPacketNum,
552 uint32_t receiveThreadLatencyEmulationPacketNum,
553 bool bPacketLossEmulation);
558 ThreadStreamManager(
const ThreadStreamManager&);
563 ThreadStreamManager& operator=(
const ThreadStreamManager&);
567 common::IPacketInput* m_pInputStream;
568 common::IPacketOutput* m_pOutputStream;
570 ReceiveThreadStream* m_pReceiveStream;
571 SendThreadStream* m_pSendStream;
573 static ThreadStreamManager* s_pInstance;