Function Test_pipe

tests/test_connection.cpp:1206–1287

}

void Test_pipe()
{
	TEST_Printf( "***************************************************\n" );
	TEST_Printf( "Pipe (socket pair, no network loopback)\n" );
	TEST_Printf( "***************************************************\n" );

	// CreateSocketPair with bUseNetworkLoopback=false: pure internal buffer path,
	// no encryption, no packet fragmentation, no network stack involvement.
	HSteamNetConnection hAlice, hBob;
	SteamNetworkingIdentity identAlice, identBob;
	identAlice.SetGenericString( "alice" );
	identBob.SetGenericString( "bob" );
	// NOTE: each pPeerIdentity is the remote identity seen by the *corresponding* connection.
	assert( SteamNetworkingSockets()->CreateSocketPair( &hAlice, &hBob, false, &identBob, &identAlice ) );

	// Verify each end observes the correct remote identity.
	{
		SteamNetConnectionInfo_t infoAlice, infoBob;
		assert( SteamNetworkingSockets()->GetConnectionInfo( hAlice, &infoAlice ) );
		assert( SteamNetworkingSockets()->GetConnectionInfo( hBob, &infoBob ) );
		assert( infoAlice.m_identityRemote == identBob );
		assert( infoBob.m_identityRemote == identAlice );
	}

	// Wire up to the global peer state used by TestNetworkConditions / PumpCallbacksAndMakeSureStillConnected.
	g_peerClient.Reset();
	g_peerServer.Reset();
	g_peerClient.m_hSteamNetConnection = hAlice;
	g_peerClient.m_bIsConnected = true;
	g_peerClient.SetConnectionConfig();
	g_peerServer.m_hSteamNetConnection = hBob;
	g_peerServer.m_bIsConnected = true;
	g_peerServer.SetConnectionConfig();

	// Cursory connection test. Fake loss/lag config has no effect on a pipe
	// (no network path), but the send/receive loop still exercises the connection.
	TestNetworkConditions( 10*1000*1000, 0, 0, 0, 0, false, ETestConnectionMode::Cursory );

	// Zero-copy: for a pipe connection the received message must point at the
	// exact same data buffer that was handed to SendMessages -- no copy through
	// any network or encryption layer.
	{
		SteamNetworkingMessage_t *pSendMsg = SteamNetworkingUtils()->AllocateMessage( 256 );
		pSendMsg->m_conn = hAlice;
		pSendMsg->m_nFlags = k_nSteamNetworkingSend_Reliable;
		void *pSendData = pSendMsg->m_pData;

		int64 nMsgNum = 0;
		SteamNetworkingSockets()->SendMessages( 1, &pSendMsg, &nMsgNum, true );
		assert( nMsgNum > 0 );

		SteamNetworkingMessage_t *pRecvMsg = nullptr;
		int nRecv = SteamNetworkingSockets()->ReceiveMessagesOnConnection( hBob, &pRecvMsg, 1 );
		assert( nRecv == 1 );
		assert( pRecvMsg->m_pData == pSendData ); // zero-copy: must be the same pointer
		pRecvMsg->Release();
	}