Something went wrong. Try again.
the game where you go into mines and start crafting! but for consoles (forked directly from smartcmd's github)
Something went wrong. Try again.
70 kB · 2091 lines
C++
at main
1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092#include "stdafx.h"#include "..\..\..\Minecraft.World\StringHelpers.h"#include "..\..\..\Minecraft.World\AABB.h"#include "..\..\..\Minecraft.World\Vec3.h"#include "..\..\..\Minecraft.World\Socket.h"#include "..\..\..\Minecraft.World\ThreadName.h"#include "..\..\..\Minecraft.World\Entity.h"#include "..\..\..\Minecraft.World\net.minecraft.world.level.tile.h"#include "..\..\..\Minecraft.World\FireworksRecipe.h"#include "..\..\ClientConnection.h"#include "..\..\Minecraft.h"#include "..\..\User.h"#include "..\..\MinecraftServer.h"#include "..\..\PlayerList.h"#include "..\..\ServerPlayer.h"#include "..\..\PlayerConnection.h"#include "..\..\MultiPlayerLevel.h"#include "..\..\ProgressRenderer.h"#include "..\..\MultiPlayerLocalPlayer.h"#include "..\..\..\Minecraft.World\DisconnectPacket.h"#include "..\..\..\Minecraft.World\compression.h"#include "..\..\..\Minecraft.World\OldChunkStorage.h"#include "..\..\TexturePackRepository.h"#include "..\..\TexturePack.h"
#include "..\..\Gui.h"#include "..\..\LevelRenderer.h"#include "..\..\..\Minecraft.World\IntCache.h"#include "..\GameRules\ConsoleGameRules.h"#include "GameNetworkManager.h"
#ifdef _XBOX#include "Common\XUI\XUI_PauseMenu.h"#else#include "Common\UI\UI.h"#include "Common\UI\UIScene_PauseMenu.h"#include "..\..\Xbox\Network\NetworkPlayerXbox.h"#endif
#ifdef _DURANGO#include "..\Minecraft.World\DurangoStats.h"#endif
// Global instanceCGameNetworkManager g_NetworkManager;CPlatformNetworkManager *CGameNetworkManager::s_pPlatformNetworkManager;
__int64 CGameNetworkManager::messageQueue[512];__int64 CGameNetworkManager::byteQueue[512];int CGameNetworkManager::messageQueuePos = 0;
CGameNetworkManager::CGameNetworkManager(){ m_bInitialised = false; m_bLastDisconnectWasLostRoomOnly = false; m_bFullSessionMessageOnNextSessionChange = false;
#ifdef __ORBIS__ m_pUpsell = NULL; m_pInviteInfo = NULL;#endif}
void CGameNetworkManager::Initialise(){ ServerStoppedCreate( false ); ServerReadyCreate( false ); int flagIndexSize = LevelRenderer::getGlobalChunkCount() / (Level::maxBuildHeight / 16); // dividing here by number of renderer chunks in one column#ifdef _XBOX s_pPlatformNetworkManager = new CPlatformNetworkManagerXbox();#elif defined __PS3__ || defined __ORBIS__ || defined __PSVITA__ s_pPlatformNetworkManager = new CPlatformNetworkManagerSony();#elif defined _DURANGO s_pPlatformNetworkManager = new CPlatformNetworkManagerDurango();#else s_pPlatformNetworkManager = new CPlatformNetworkManagerStub();#endif s_pPlatformNetworkManager->Initialise( this, flagIndexSize ); m_bNetworkThreadRunning = false; m_bInitialised = true;}
void CGameNetworkManager::Terminate(){ if( m_bInitialised ) { s_pPlatformNetworkManager->Terminate(); }}
void CGameNetworkManager::DoWork(){#ifdef _XBOX // did we get any notifications from the game listener? if(app.GetNotifications()->size()!=0) { PNOTIFICATION pNotification=app.GetNotifications()->back();
switch(pNotification->dwNotification) { case XN_LIVE_LINK_STATE_CHANGED: { int iPrimaryPlayer = g_NetworkManager.GetPrimaryPad(); bool bConnected = (pNotification->uiParam!=0)?true:false; if((g_NetworkManager.GetLockedProfile()!=-1) && iPrimaryPlayer!=-1 && bConnected == false && g_NetworkManager.IsInSession() ) { app.SetAction(iPrimaryPlayer,eAppAction_EthernetDisconnected); } } break; case XN_LIVE_INVITE_ACCEPTED: s_pPlatformNetworkManager->Notify(pNotification->dwNotification,pNotification->uiParam); break; }
app.GetNotifications()->pop_back(); delete pNotification; }#endif s_pPlatformNetworkManager->DoWork();
#ifdef __ORBIS__ if (m_pUpsell != NULL && m_pUpsell->hasResponse()) { int iPad_invited = m_iPlayerInvited, iPad_checking = m_pUpsell->m_userIndex;
m_iPlayerInvited = -1;
delete m_pUpsell; m_pUpsell = NULL;
if (ProfileManager.HasPlayStationPlus(iPad_checking)) { this->GameInviteReceived(iPad_invited, m_pInviteInfo);
// m_pInviteInfo deleted by GameInviteReceived. m_pInviteInfo = NULL; } else { delete m_pInviteInfo; m_pInviteInfo = NULL; } }#endif}
bool CGameNetworkManager::_RunNetworkGame(LPVOID lpParameter){ bool success = true;
bool isHost = g_NetworkManager.IsHost(); // Start the network game Minecraft *pMinecraft=Minecraft::GetInstance(); success = StartNetworkGame(pMinecraft,lpParameter);
if(!success) return false;
if( isHost ) { // We do not have a lobby, so the only players in the game at this point are local ones.
success = s_pPlatformNetworkManager->_RunNetworkGame(); if(!success) { app.SetAction(ProfileManager.GetPrimaryPad(),eAppAction_ExitWorld,(void *)TRUE); return true; } } else { // Client needs QNET_STATE_GAME_PLAY so that IsInGameplay() returns true s_pPlatformNetworkManager->SetGamePlayState(); } if( g_NetworkManager.IsLeavingGame() ) return false;
app.SetGameStarted(true);
// 4J-PB - if this is the trial game, start the trial timer if(!ProfileManager.IsFullVersion()) { ui.SetTrialTimerLimitSecs(MinecraftDynamicConfigurations::GetTrialTime()); app.SetTrialTimerStart(); } //app.CloseXuiScenes(ProfileManager.GetPrimaryPad());
return success;}
bool CGameNetworkManager::StartNetworkGame(Minecraft *minecraft, LPVOID lpParameter){#ifdef _DURANGO ProfileManager.SetDeferredSignoutEnabled(true);#endif
__int64 seed = 0; if(lpParameter != NULL) { NetworkGameInitData *param = (NetworkGameInitData *)lpParameter; seed = param->seed; app.setLevelGenerationOptions(param->levelGen); if(param->levelGen != NULL) { if(app.getLevelGenerationOptions() == NULL) { app.DebugPrintf("Game rule was not loaded, and seed is required. Exiting.\n"); return false; } else { param->seed = seed = app.getLevelGenerationOptions()->getLevelSeed();
if(param->levelGen->isTutorial()) { // Load the tutorial save data here if(param->levelGen->requiresBaseSave() && !param->levelGen->getBaseSavePath().empty() ) {#ifdef _XBOX#ifdef _TU_BUILD wstring fileRoot = L"UPDATE:\\res\\GameRules\\" + param->levelGen->getBaseSavePath();#else wstring fileRoot = L"GAME:\\res\\TitleUpdate\\GameRules\\" + param->levelGen->getBaseSavePath();#endif#else#ifdef _WINDOWS64 wstring fileRoot = L"Windows64Media\\Tutorial\\" + param->levelGen->getBaseSavePath(); File root(fileRoot); if(!root.exists()) fileRoot = L"Windows64\\Tutorial\\" + param->levelGen->getBaseSavePath();#elif defined(__ORBIS__) wstring fileRoot = L"/app0/orbis/Tutorial/" + param->levelGen->getBaseSavePath();#elif defined(__PSVITA__) wstring fileRoot = L"PSVita/Tutorial/" + param->levelGen->getBaseSavePath();#elif defined(__PS3__) wstring fileRoot = L"PS3/Tutorial/" + param->levelGen->getBaseSavePath();#else wstring fileRoot = L"Tutorial\\" + param->levelGen->getBaseSavePath();#endif#endif File grf(fileRoot); if (grf.exists()) {#ifdef _UNICODE wstring path = grf.getPath(); const WCHAR *pchFilename=path.c_str(); HANDLE fileHandle = CreateFile( pchFilename, // file name GENERIC_READ, // access mode 0, // share mode // TODO 4J Stu - Will we need to share file? Probably not but... NULL, // Unused OPEN_EXISTING , // how to create // TODO 4J Stu - Assuming that the file already exists if we are opening to read from it FILE_FLAG_SEQUENTIAL_SCAN, // file attributes NULL // Unsupported );#else const char *pchFilename=wstringtofilename(grf.getPath()); HANDLE fileHandle = CreateFile( pchFilename, // file name GENERIC_READ, // access mode 0, // share mode // TODO 4J Stu - Will we need to share file? Probably not but... NULL, // Unused OPEN_EXISTING , // how to create // TODO 4J Stu - Assuming that the file already exists if we are opening to read from it FILE_FLAG_SEQUENTIAL_SCAN, // file attributes NULL // Unsupported );#endif
if( fileHandle != INVALID_HANDLE_VALUE ) { DWORD bytesRead,dwFileSize = GetFileSize(fileHandle,NULL); PBYTE pbData = (PBYTE) new BYTE[dwFileSize]; BOOL bSuccess = ReadFile(fileHandle,pbData,dwFileSize,&bytesRead,NULL); if(bSuccess==FALSE) { app.FatalLoadError(); } CloseHandle(fileHandle);
// 4J-PB - is it possible that we can get here after a read fail and it's not an error? param->levelGen->setBaseSaveData(pbData, dwFileSize); } } } } } } }
static __int64 sseed = seed; // Create static version so this will be valid until next call to this function & whilst thread is running ServerStoppedCreate(false); if( g_NetworkManager.IsHost() ) { ServerStoppedCreate(true); ServerReadyCreate(true); // Ready to go - create actual networking thread & start hosting C4JThread* thread = new C4JThread(&CGameNetworkManager::ServerThreadProc, lpParameter, "Server", 256 * 1024);#if defined __PS3__ || defined __PSVITA__ thread->SetPriority(THREAD_PRIORITY_BELOW_NORMAL);#endif //__PS3__
thread->SetProcessor(CPU_CORE_SERVER); thread->Run();
ServerReadyWait(); ServerReadyDestroy();
if( MinecraftServer::serverHalted() ) return false;
// printf("Server ready to go!\n"); } else { Socket::Initialise(NULL); }
#ifndef _XBOX Minecraft *pMinecraft = Minecraft::GetInstance(); // Make sure that we have transitioned through any joining/creating stages and are actually playing the game, so that we know the players should be valid bool changedMessage = false; while(!IsReadyToPlayOrIdle()) { changedMessage = true; pMinecraft->progressRenderer->progressStage( g_NetworkManager.CorrectErrorIDS(IDS_PROGRESS_SAVING_TO_DISC) ); // "Finalizing..." vaguest message I could find pMinecraft->progressRenderer->progressStagePercentage( g_NetworkManager.GetJoiningReadyPercentage() ); Sleep(10); } if( changedMessage ) { pMinecraft->progressRenderer->progressStagePercentage( 100 ); }#endif
// If we aren't in session, then something bad must have happened - we aren't joining, creating or ready play if(!IsInSession() ) { MinecraftServer::HaltServer(); return false; }
// 4J Stu - Wait a while to make sure that DLC is loaded. This is the last point before the network communication starts // so the latest we can check this while( !app.DLCInstallProcessCompleted() && app.DLCInstallPending() && !g_NetworkManager.IsLeavingGame() ) { Sleep( 10 ); } if( g_NetworkManager.IsLeavingGame() ) { MinecraftServer::HaltServer(); return false; }
// PRIMARY PLAYER
vector<ClientConnection *> createdConnections; ClientConnection *connection;
if( g_NetworkManager.IsHost() ) { connection = new ClientConnection(minecraft, NULL); } else { INetworkPlayer *pNetworkPlayer = g_NetworkManager.GetLocalPlayerByUserIndex(ProfileManager.GetLockedProfile()); if(pNetworkPlayer == NULL) { MinecraftServer::HaltServer(); app.DebugPrintf("%d\n",ProfileManager.GetLockedProfile()); // If the player is NULL here then something went wrong in the session setup, and continuing will end up in a crash return false; }
Socket *socket = pNetworkPlayer->GetSocket();
// Fix for #13259 - CRASH: Gameplay: loading process is halted when player loads saved data if(socket == NULL) { assert(false); MinecraftServer::HaltServer(); // If the socket is NULL here then something went wrong in the session setup, and continuing will end up in a crash return false; }
connection = new ClientConnection(minecraft, socket); }
if( !connection->createdOk ) { assert(false); delete connection; connection = NULL; MinecraftServer::HaltServer(); return false; }
connection->send( shared_ptr<PreLoginPacket>( new PreLoginPacket(minecraft->user->name) ) );
// Tick connection until we're ready to go. The stages involved in this are: // (1) Creating the ClientConnection sends a prelogin packet to the server // (2) the server sends a prelogin back, which is handled by the clientConnection, and returns a login packet // (3) the server sends a login back, which is handled by the client connection to start the game if( !g_NetworkManager.IsHost() ) { Minecraft::GetInstance()->progressRenderer->progressStart(IDS_PROGRESS_CONNECTING); } else { // 4J Stu - Host needs to generate a unique multiplayer id for sentient telemetry reporting INT multiplayerInstanceId = TelemetryManager->GenerateMultiplayerInstanceId(); TelemetryManager->SetMultiplayerInstanceId(multiplayerInstanceId); } TexturePack *tPack = Minecraft::GetInstance()->skins->getSelected(); do { app.DebugPrintf("ticking connection A\n"); connection->tick();
// 4J Stu - We were ticking this way too fast which could cause the connection to time out // The connections should tick at 20 per second Sleep(50); } while ( (IsInSession() && !connection->isStarted() && !connection->isClosed() && !g_NetworkManager.IsLeavingGame()) || tPack->isLoadingData() || (Minecraft::GetInstance()->skins->needsUIUpdate() || ui.IsReloadingSkin()) ); ui.CleanUpSkinReload();
// 4J Stu - Fix for #11279 - CRASH: TCR 001: BAS Game Stability: Signing out of game will cause title to crash // We need to break out of the above loop if m_bLeavingGame is set, and close the connection if( g_NetworkManager.IsLeavingGame() || !IsInSession() ) { connection->close(); }
if( connection->isStarted() && !connection->isClosed() ) { createdConnections.push_back( connection );
int primaryPad = ProfileManager.GetPrimaryPad(); app.SetRichPresenceContext(primaryPad,CONTEXT_GAME_STATE_BLANK); if (GetPlayerCount() > 1) // Are we offline or online, and how many players are there { if (IsLocalGame()) ProfileManager.SetCurrentGameActivity(primaryPad,CONTEXT_PRESENCE_MULTIPLAYEROFFLINE,false); else ProfileManager.SetCurrentGameActivity(primaryPad,CONTEXT_PRESENCE_MULTIPLAYER,false); } else { if(IsLocalGame()) ProfileManager.SetCurrentGameActivity(primaryPad,CONTEXT_PRESENCE_MULTIPLAYER_1POFFLINE,false); else ProfileManager.SetCurrentGameActivity(primaryPad,CONTEXT_PRESENCE_MULTIPLAYER_1P,false); }
// ALL OTHER LOCAL PLAYERS for(int idx = 0; idx < XUSER_MAX_COUNT; ++idx) { // Already have setup the primary pad if(idx == ProfileManager.GetPrimaryPad() ) continue;
if( GetLocalPlayerByUserIndex(idx) != NULL && !ProfileManager.IsSignedIn(idx) ) { INetworkPlayer *pNetworkPlayer = g_NetworkManager.GetLocalPlayerByUserIndex(idx); Socket *socket = pNetworkPlayer->GetSocket(); app.DebugPrintf("Closing socket due to player %d not being signed in any more\n"); if( !socket->close(false) ) socket->close(true);
continue; }
// By default when we host we only have the local player, but currently allow multiple local players to join // when joining any other way, so just because they are signed in doesn't mean they are in the session // 4J Stu - If they are in the session, then we should add them to the game. Otherwise we won't be able to add them later INetworkPlayer *pNetworkPlayer = g_NetworkManager.GetLocalPlayerByUserIndex(idx); if( pNetworkPlayer == NULL ) continue;
ClientConnection *connection;
Socket *socket = pNetworkPlayer->GetSocket(); connection = new ClientConnection(minecraft, socket, idx);
minecraft->addPendingLocalConnection(idx, connection); //minecraft->createExtraLocalPlayer(idx, (convStringToWstring( ProfileManager.GetGamertag(idx) )).c_str(), idx, connection);
// Open the socket on the server end to accept incoming data Socket::addIncomingSocket(socket);
connection->send( shared_ptr<PreLoginPacket>( new PreLoginPacket(convStringToWstring( ProfileManager.GetGamertag(idx) )) ) );
createdConnections.push_back( connection );
// Tick connection until we're ready to go. The stages involved in this are: // (1) Creating the ClientConnection sends a prelogin packet to the server // (2) the server sends a prelogin back, which is handled by the clientConnection, and returns a login packet // (3) the server sends a login back, which is handled by the client connection to start the game do { // We need to keep ticking the connections for players that already logged in for(AUTO_VAR(it, createdConnections.begin()); it < createdConnections.end(); ++it) { (*it)->tick(); }
// 4J Stu - We were ticking this way too fast which could cause the connection to time out // The connections should tick at 20 per second Sleep(50); app.DebugPrintf("<***> %d %d %d %d %d\n",IsInSession(), !connection->isStarted(),!connection->isClosed(),ProfileManager.IsSignedIn(idx),!g_NetworkManager.IsLeavingGame());#if defined _XBOX || __PS3__ } while (IsInSession() && !connection->isStarted() && !connection->isClosed() && ProfileManager.IsSignedIn(idx) && !g_NetworkManager.IsLeavingGame() );#else // TODO - This SHOULD be something just like the code above but temporarily changing here so that we don't have to depend on the profilemanager behaviour } while (IsInSession() && !connection->isStarted() && !connection->isClosed() && !g_NetworkManager.IsLeavingGame() );#endif
// 4J Stu - Fix for #11279 - CRASH: TCR 001: BAS Game Stability: Signing out of game will cause title to crash // We need to break out of the above loop if m_bLeavingGame is set, and stop creating new connections // The connections in the createdConnections vector get closed at the end of the thread if( g_NetworkManager.IsLeavingGame() || !IsInSession() ) break;
if( ProfileManager.IsSignedIn(idx) && !connection->isClosed() ) { app.SetRichPresenceContext(idx,CONTEXT_GAME_STATE_BLANK); if (IsLocalGame()) ProfileManager.SetCurrentGameActivity(idx,CONTEXT_PRESENCE_MULTIPLAYEROFFLINE,false); else ProfileManager.SetCurrentGameActivity(idx,CONTEXT_PRESENCE_MULTIPLAYER,false); } else { connection->close(); AUTO_VAR(it, find( createdConnections.begin(), createdConnections.end(), connection )); if(it != createdConnections.end() ) createdConnections.erase( it ); } }
app.SetGameMode( eMode_Multiplayer ); } else if ( connection->isClosed() || !IsInSession()) {// assert(false); MinecraftServer::HaltServer(); return false; }
if(g_NetworkManager.IsLeavingGame() || !IsInSession() ) { for(AUTO_VAR(it, createdConnections.begin()); it < createdConnections.end(); ++it) { (*it)->close(); }// assert(false); MinecraftServer::HaltServer(); return false; }
// Catch in-case server has been halted (by a player signout). if ( MinecraftServer::serverHalted() ) return false;
return true;}
int CGameNetworkManager::CorrectErrorIDS(int IDS){ return s_pPlatformNetworkManager->CorrectErrorIDS(IDS);}
int CGameNetworkManager::GetLocalPlayerMask(int playerIndex){ return s_pPlatformNetworkManager->GetLocalPlayerMask( playerIndex );}
int CGameNetworkManager::GetPlayerCount(){ return s_pPlatformNetworkManager->GetPlayerCount();}
int CGameNetworkManager::GetOnlinePlayerCount(){ return s_pPlatformNetworkManager->GetOnlinePlayerCount();}
bool CGameNetworkManager::AddLocalPlayerByUserIndex( int userIndex ){ return s_pPlatformNetworkManager->AddLocalPlayerByUserIndex( userIndex );}
bool CGameNetworkManager::RemoveLocalPlayerByUserIndex( int userIndex ){ return s_pPlatformNetworkManager->RemoveLocalPlayerByUserIndex( userIndex );}
INetworkPlayer *CGameNetworkManager::GetLocalPlayerByUserIndex(int userIndex ){ return s_pPlatformNetworkManager->GetLocalPlayerByUserIndex( userIndex );}
INetworkPlayer *CGameNetworkManager::GetPlayerByIndex(int playerIndex){ return s_pPlatformNetworkManager->GetPlayerByIndex( playerIndex );}
INetworkPlayer *CGameNetworkManager::GetPlayerByXuid(PlayerUID xuid){ return s_pPlatformNetworkManager->GetPlayerByXuid( xuid );}
INetworkPlayer *CGameNetworkManager::GetPlayerBySmallId(unsigned char smallId){ return s_pPlatformNetworkManager->GetPlayerBySmallId( smallId );}
#ifdef _DURANGOwstring CGameNetworkManager::GetDisplayNameByGamertag(wstring gamertag){ return s_pPlatformNetworkManager->GetDisplayNameByGamertag(gamertag);}#endif
INetworkPlayer *CGameNetworkManager::GetHostPlayer(){ return s_pPlatformNetworkManager->GetHostPlayer();}
void CGameNetworkManager::RegisterPlayerChangedCallback(int iPad, void (*callback)(void *callbackParam, INetworkPlayer *pPlayer, bool leaving), void *callbackParam){ s_pPlatformNetworkManager->RegisterPlayerChangedCallback( iPad, callback, callbackParam );}
void CGameNetworkManager::UnRegisterPlayerChangedCallback(int iPad, void (*callback)(void *callbackParam, INetworkPlayer *pPlayer, bool leaving), void *callbackParam){ s_pPlatformNetworkManager->UnRegisterPlayerChangedCallback( iPad, callback, callbackParam );}
void CGameNetworkManager::HandleSignInChange(){ s_pPlatformNetworkManager->HandleSignInChange();}
bool CGameNetworkManager::ShouldMessageForFullSession(){ return s_pPlatformNetworkManager->ShouldMessageForFullSession();}
bool CGameNetworkManager::IsInSession(){ return s_pPlatformNetworkManager->IsInSession();}
bool CGameNetworkManager::IsInGameplay(){ return s_pPlatformNetworkManager->IsInGameplay();}
bool CGameNetworkManager::IsReadyToPlayOrIdle(){ return s_pPlatformNetworkManager->IsReadyToPlayOrIdle();}
bool CGameNetworkManager::IsLeavingGame(){ return s_pPlatformNetworkManager->IsLeavingGame();}
bool CGameNetworkManager::SetLocalGame(bool isLocal){ return s_pPlatformNetworkManager->SetLocalGame( isLocal );}
bool CGameNetworkManager::IsLocalGame(){ return s_pPlatformNetworkManager->IsLocalGame();}
void CGameNetworkManager::SetPrivateGame(bool isPrivate){ s_pPlatformNetworkManager->SetPrivateGame( isPrivate );}
bool CGameNetworkManager::IsPrivateGame(){ return s_pPlatformNetworkManager->IsPrivateGame();}
void CGameNetworkManager::HostGame(int localUsersMask, bool bOnlineGame, bool bIsPrivate, unsigned char publicSlots, unsigned char privateSlots){ // 4J Stu - clear any previous connection errors Minecraft::GetInstance()->clearConnectionFailed();
s_pPlatformNetworkManager->HostGame( localUsersMask, bOnlineGame, bIsPrivate, publicSlots, privateSlots );}
bool CGameNetworkManager::IsHost(){ return (s_pPlatformNetworkManager->IsHost() == TRUE);}
bool CGameNetworkManager::IsInStatsEnabledSession(){ return s_pPlatformNetworkManager->IsInStatsEnabledSession();}
bool CGameNetworkManager::SessionHasSpace(unsigned int spaceRequired){ return s_pPlatformNetworkManager->SessionHasSpace( spaceRequired );}
vector<FriendSessionInfo *> *CGameNetworkManager::GetSessionList(int iPad, int localPlayers, bool partyOnly){ return s_pPlatformNetworkManager->GetSessionList( iPad, localPlayers, partyOnly );}
bool CGameNetworkManager::GetGameSessionInfo(int iPad, SessionID sessionId,FriendSessionInfo *foundSession){ return s_pPlatformNetworkManager->GetGameSessionInfo( iPad, sessionId, foundSession );}
void CGameNetworkManager::SetSessionsUpdatedCallback( void (*SessionsUpdatedCallback)(LPVOID pParam), LPVOID pSearchParam ){ s_pPlatformNetworkManager->SetSessionsUpdatedCallback( SessionsUpdatedCallback, pSearchParam );}
void CGameNetworkManager::GetFullFriendSessionInfo( FriendSessionInfo *foundSession, void (* FriendSessionUpdatedFn)(bool success, void *pParam), void *pParam ){ s_pPlatformNetworkManager->GetFullFriendSessionInfo(foundSession, FriendSessionUpdatedFn, pParam);}
void CGameNetworkManager::ForceFriendsSessionRefresh(){ s_pPlatformNetworkManager->ForceFriendsSessionRefresh();}
bool CGameNetworkManager::JoinGameFromInviteInfo( int userIndex, int userMask, const INVITE_INFO *pInviteInfo){ return s_pPlatformNetworkManager->JoinGameFromInviteInfo( userIndex, userMask, pInviteInfo );}
CGameNetworkManager::eJoinGameResult CGameNetworkManager::JoinGame(FriendSessionInfo *searchResult, int localUsersMask){ app.SetTutorialMode( false ); g_NetworkManager.SetLocalGame(false);
int primaryUserIndex = ProfileManager.GetLockedProfile();
// 4J-PB - clear any previous connection errors Minecraft::GetInstance()->clearConnectionFailed();
// Make sure that the Primary Pad is in by default localUsersMask |= GetLocalPlayerMask( ProfileManager.GetPrimaryPad() );
return (eJoinGameResult)(s_pPlatformNetworkManager->JoinGame( searchResult, localUsersMask, primaryUserIndex ));}
void CGameNetworkManager::CancelJoinGame(LPVOID lpParam){#ifdef _XBOX_ONE s_pPlatformNetworkManager->CancelJoinGame();#endif}
bool CGameNetworkManager::LeaveGame(bool bMigrateHost){ Minecraft::GetInstance()->gui->clearMessages(); return s_pPlatformNetworkManager->LeaveGame( bMigrateHost );}
int CGameNetworkManager::JoinFromInvite_SignInReturned(void *pParam,bool bContinue, int iPad){ INVITE_INFO * pInviteInfo = (INVITE_INFO *)pParam;
if(bContinue==true) {#ifdef __ORBIS__ // Check if PSN is unavailable because of age restriction int npAvailability = ProfileManager.getNPAvailability(iPad); if (npAvailability == SCE_NP_ERROR_AGE_RESTRICTION) { UINT uiIDA[1]; uiIDA[0] = IDS_OK; ui.RequestErrorMessage(IDS_ONLINE_SERVICE_TITLE, IDS_CONTENT_RESTRICTION, uiIDA, 1, iPad);
return 0; }#endif
app.DebugPrintf("JoinFromInvite_SignInReturned, iPad %d\n",iPad); // It's possible that the player has not signed in - they can back out if(ProfileManager.IsSignedIn(iPad) && ProfileManager.IsSignedInLive(iPad) ) { app.DebugPrintf("JoinFromInvite_SignInReturned, passed sign-in tests\n"); int localUsersMask = 0; int joiningUsers = 0;
bool noPrivileges = false; for(unsigned int index = 0; index < XUSER_MAX_COUNT; ++index) { if(ProfileManager.IsSignedIn(index) ) { ++joiningUsers; if( !ProfileManager.AllowedToPlayMultiplayer(index) ) noPrivileges = true; localUsersMask |= GetLocalPlayerMask( index ); } }
// Check if user-created content is allowed, as we cannot play multiplayer if it's not bool noUGC = false;#if defined(__PS3__) || defined(__PSVITA__) ProfileManager.GetChatAndContentRestrictions(iPad,false,&noUGC,NULL,NULL);#elif defined(__ORBIS__) ProfileManager.GetChatAndContentRestrictions(iPad,false,NULL,&noUGC,NULL);#endif
if(noUGC) { int messageText = IDS_NO_USER_CREATED_CONTENT_PRIVILEGE_SINGLE_LOCAL; if(joiningUsers > 1) messageText = IDS_NO_USER_CREATED_CONTENT_PRIVILEGE_ALL_LOCAL;
ui.RequestUGCMessageBox(IDS_CONNECTION_FAILED, messageText); } else if(noPrivileges) { UINT uiIDA[1]; uiIDA[0]=IDS_CONFIRM_OK; ui.RequestErrorMessage( IDS_NO_MULTIPLAYER_PRIVILEGE_TITLE, IDS_NO_MULTIPLAYER_PRIVILEGE_JOIN_TEXT, uiIDA,1,ProfileManager.GetPrimaryPad()); } else {#if defined(__ORBIS__) || defined(__PSVITA__) bool chatRestricted = false; ProfileManager.GetChatAndContentRestrictions(iPad,false,&chatRestricted,NULL,NULL); if(chatRestricted) { ProfileManager.DisplaySystemMessage( 0, ProfileManager.GetPrimaryPad() ); }#endif ProfileManager.SetLockedProfile(iPad); ProfileManager.SetPrimaryPad(iPad);
g_NetworkManager.SetLocalGame(false); // If the player was signed in before selecting play, we'll not have read the profile yet, so query the sign-in status to get this to happen ProfileManager.QuerySigninStatus();
// 4J-PB - clear any previous connection errors Minecraft::GetInstance()->clearConnectionFailed();
// change the minecraft player name Minecraft::GetInstance()->user->name = convStringToWstring( ProfileManager.GetGamertag(ProfileManager.GetPrimaryPad()));
bool success = g_NetworkManager.JoinGameFromInviteInfo( iPad, // dwUserIndex localUsersMask, // dwUserMask pInviteInfo ); // pInviteInfo if( !success ) { app.DebugPrintf( "Failed joining game from invite\n" ); } } } else { app.DebugPrintf("JoinFromInvite_SignInReturned, failed sign-in tests :%d %d\n",ProfileManager.IsSignedIn(iPad),ProfileManager.IsSignedInLive(iPad)); } } return 0;
}
void CGameNetworkManager::UpdateAndSetGameSessionData(INetworkPlayer *pNetworkPlayerLeaving){ Minecraft *pMinecraft = Minecraft::GetInstance(); TexturePack *tPack = pMinecraft->skins->getSelected(); s_pPlatformNetworkManager->SetSessionTexturePackParentId( tPack->getDLCParentPackId() ); s_pPlatformNetworkManager->SetSessionSubTexturePackId( tPack->getDLCSubPackId() );
s_pPlatformNetworkManager->UpdateAndSetGameSessionData( pNetworkPlayerLeaving );}
void CGameNetworkManager::SendInviteGUI(int quadrant){ s_pPlatformNetworkManager->SendInviteGUI(quadrant);}
void CGameNetworkManager::ResetLeavingGame(){ s_pPlatformNetworkManager->ResetLeavingGame();}
bool CGameNetworkManager::IsNetworkThreadRunning(){ return m_bNetworkThreadRunning;;}
int CGameNetworkManager::RunNetworkGameThreadProc( void* lpParameter ){ // Share AABB & Vec3 pools with default (main thread) - should be ok as long as we don't tick the main thread whilst this thread is running AABB::UseDefaultThreadStorage(); Vec3::UseDefaultThreadStorage(); Compression::UseDefaultThreadStorage(); Tile::CreateNewThreadStorage(); IntCache::CreateNewThreadStorage(); g_NetworkManager.m_bNetworkThreadRunning = true; bool success = g_NetworkManager._RunNetworkGame(lpParameter); g_NetworkManager.m_bNetworkThreadRunning = false; if( !success) { TexturePack *tPack = Minecraft::GetInstance()->skins->getSelected(); while ( tPack->isLoadingData() || (Minecraft::GetInstance()->skins->needsUIUpdate() || ui.IsReloadingSkin()) ) { Sleep(1); } ui.CleanUpSkinReload(); if(app.GetDisconnectReason() == DisconnectPacket::eDisconnect_None) { app.SetDisconnectReason( DisconnectPacket::eDisconnect_ConnectionCreationFailed ); } // If we failed before the server started, clear the game rules. Otherwise the server will clear it up. if(MinecraftServer::getInstance() == NULL) app.m_gameRules.unloadCurrentGameRules(); Tile::ReleaseThreadStorage(); return -1; }
#ifdef __PSVITA__ // 4J-JEV: Wait for the loading/saving to finish. while (StorageManager.GetSaveState() != C4JStorage::ESaveGame_Idle) Sleep(10);#endif
Tile::ReleaseThreadStorage(); IntCache::ReleaseThreadStorage(); return 0;}
int CGameNetworkManager::ServerThreadProc( void* lpParameter ){ __int64 seed = 0; if(lpParameter != NULL) { NetworkGameInitData *param = (NetworkGameInitData *)lpParameter; seed = param->seed; app.SetGameHostOption(eGameHostOption_All,param->settings);
// 4J Stu - If we are loading a DLC save that's separate from the texture pack, load if( param->levelGen != NULL && (param->texturePackId == 0 || param->levelGen->getRequiredTexturePackId() != param->texturePackId) ) { while((Minecraft::GetInstance()->skins->needsUIUpdate() || ui.IsReloadingSkin())) { Sleep(1); } param->levelGen->loadBaseSaveData(); } }
SetThreadName(-1, "Minecraft Server thread"); AABB::CreateNewThreadStorage(); Vec3::CreateNewThreadStorage(); IntCache::CreateNewThreadStorage(); Compression::UseDefaultThreadStorage(); OldChunkStorage::UseDefaultThreadStorage(); Entity::useSmallIds(); Level::enableLightingCache(); Tile::CreateNewThreadStorage(); FireworksRecipe::CreateNewThreadStorage();
MinecraftServer::main(seed, lpParameter); //saveData, app.GetGameHostOption(eGameHostOption_All)); Tile::ReleaseThreadStorage(); AABB::ReleaseThreadStorage(); Vec3::ReleaseThreadStorage(); IntCache::ReleaseThreadStorage(); Level::destroyLightingCache();
if(lpParameter != NULL) delete lpParameter;
return S_OK;}
int CGameNetworkManager::ExitAndJoinFromInviteThreadProc( void* lpParam ){ // Share AABB & Vec3 pools with default (main thread) - should be ok as long as we don't tick the main thread whilst this thread is running AABB::UseDefaultThreadStorage(); Vec3::UseDefaultThreadStorage(); Compression::UseDefaultThreadStorage();
//app.SetGameStarted(false); UIScene_PauseMenu::_ExitWorld(NULL);
while( g_NetworkManager.IsInSession() ) { Sleep(1); }
// Xbox should always be online when receiving invites - on PS3 we need to check & ask the user to sign in#if !defined(__PS3__) && !defined(__PSVITA__) JoinFromInviteData *inviteData = (JoinFromInviteData *)lpParam; app.SetAction(inviteData->dwUserIndex, eAppAction_JoinFromInvite, lpParam);#else if(ProfileManager.IsSignedInLive(ProfileManager.GetPrimaryPad())) { JoinFromInviteData *inviteData = (JoinFromInviteData *)lpParam; app.SetAction(inviteData->dwUserIndex, eAppAction_JoinFromInvite, lpParam); } else { UINT uiIDA[2]; uiIDA[0]=IDS_PRO_NOTONLINE_ACCEPT; uiIDA[1]=IDS_PRO_NOTONLINE_DECLINE; ui.RequestErrorMessage(IDS_PRO_NOTONLINE_TITLE, IDS_PRO_NOTONLINE_TEXT, uiIDA, 2, ProfileManager.GetPrimaryPad(),&CGameNetworkManager::MustSignInReturned_0,lpParam); }#endif
return S_OK;}
#if defined __PS3__ || defined __PSVITA__ || defined __ORBIS__// This case happens when we have been returned from the game to the main menu after receiving an invite and are now trying to go back in to join the new game// The pair of methods MustSignInReturned_0 & PSNSignInReturned_0 handle thisint CGameNetworkManager::MustSignInReturned_0(void *pParam,int iPad,C4JStorage::EMessageResult result){ if(result==C4JStorage::EMessage_ResultAccept) {#ifdef __PS3__ SQRNetworkManager_PS3::AttemptPSNSignIn(&CGameNetworkManager::PSNSignInReturned_0, pParam,true);#elif defined __PSVITA__ SQRNetworkManager_Vita::AttemptPSNSignIn(&CGameNetworkManager::PSNSignInReturned_0, pParam,true);#elif defined __ORBIS__ SQRNetworkManager_Orbis::AttemptPSNSignIn(&CGameNetworkManager::PSNSignInReturned_0, pParam,true);#endif } else { app.SetAction(0,eAppAction_Idle); ui.NavigateToHomeMenu(); ui.UpdatePlayerBasePositions(); }
return 0;}
int CGameNetworkManager::PSNSignInReturned_0(void* pParam, bool bContinue, int iPad){ JoinFromInviteData *inviteData = (JoinFromInviteData *)pParam;
// If the invite data isn't set up yet (indicated by it being all zeroes, easiest detected via the net version), then try and get it again... this can happen if we got // the invite whilst signed out
if( bContinue ) { if(inviteData->pInviteInfo->netVersion == 0) {#if defined __PS3__ || defined __VITA__ if(!SQRNetworkManager_PS3::UpdateInviteData((SQRNetworkManager::PresenceSyncInfo *)inviteData->pInviteInfo)) { bContinue = false; }#elif defined __ORBIS__ // TODO: No Orbis equivalent (should there be?)#endif } }
if( bContinue ) { app.SetAction(inviteData->dwUserIndex, eAppAction_JoinFromInvite, pParam); } else { app.SetAction(inviteData->dwUserIndex,eAppAction_Idle); ui.NavigateToHomeMenu(); ui.UpdatePlayerBasePositions(); }
return 0;}
// This case happens when we were in the main menus when we got an invite, and weren't signed in... now can proceed with the normal flow of code for this situation// The pair of methods MustSignInReturned_1 & PSNSignInReturned_1 handle thisint CGameNetworkManager::MustSignInReturned_1(void *pParam,int iPad,C4JStorage::EMessageResult result){ if(result==C4JStorage::EMessage_ResultAccept) {#ifdef __PS3__ SQRNetworkManager_PS3::AttemptPSNSignIn(&CGameNetworkManager::PSNSignInReturned_1, pParam,true);#elif defined __PSVITA__ SQRNetworkManager_Vita::AttemptPSNSignIn(&CGameNetworkManager::PSNSignInReturned_1, pParam,true);#elif defined __ORBIS__ SQRNetworkManager_Orbis::AttemptPSNSignIn(&CGameNetworkManager::PSNSignInReturned_1, pParam,true);#endif } return 0;}
int CGameNetworkManager::PSNSignInReturned_1(void* pParam, bool bContinue, int iPad){ INVITE_INFO *inviteInfo = (INVITE_INFO *)pParam;
// If the invite data isn't set up yet (indicated by it being all zeroes, easiest detected via the net version), then try and get it again... this can happen if we got // the invite whilst signed out
if( bContinue ) { if(inviteInfo->netVersion == 0) {#if defined __PS3__ || defined __VITA__ if(!SQRNetworkManager_PS3::UpdateInviteData((SQRNetworkManager::PresenceSyncInfo *)inviteInfo)) { bContinue = false; }#elif defined __ORBIS__ // TODO: No Orbis equivalent (should there be?)#endif } }
if( bContinue ) { g_NetworkManager.HandleInviteWhenInMenus(0, inviteInfo); }
return 0;}#endif
void CGameNetworkManager::_LeaveGame(){ s_pPlatformNetworkManager->_LeaveGame(false, true);}
int CGameNetworkManager::ChangeSessionTypeThreadProc( void* lpParam ){ // Share AABB & Vec3 pools with default (main thread) - should be ok as long as we don't tick the main thread whilst this thread is running AABB::UseDefaultThreadStorage(); Vec3::UseDefaultThreadStorage(); Compression::UseDefaultThreadStorage();
Minecraft *pMinecraft = Minecraft::GetInstance(); MinecraftServer *pServer = MinecraftServer::getInstance();
#if defined(__PS3__) || defined(__ORBIS__) || defined __PSVITA__ UINT uiIDA[1]; uiIDA[0]=IDS_CONFIRM_OK; if( g_NetworkManager.m_bLastDisconnectWasLostRoomOnly ) { if(g_NetworkManager.m_bSignedOutofPSN) { C4JStorage::EMessageResult result = ui.RequestErrorMessage( IDS_PROGRESS_CONVERTING_TO_OFFLINE_GAME, IDS_ERROR_PSN_SIGN_OUT, uiIDA,1,ProfileManager.GetPrimaryPad()); } else { C4JStorage::EMessageResult result = ui.RequestErrorMessage( IDS_ERROR_NETWORK_TITLE, IDS_PROGRESS_CONVERTING_TO_OFFLINE_GAME, uiIDA,1,ProfileManager.GetPrimaryPad()); } } else { C4JStorage::EMessageResult result = ui.RequestErrorMessage( IDS_CONNECTION_LOST, g_NetworkManager.CorrectErrorIDS(IDS_CONNECTION_LOST_LIVE_NO_EXIT), uiIDA,1,ProfileManager.GetPrimaryPad()); }
// Swap these two messages around as one is too long to display at 480 pMinecraft->progressRenderer->progressStartNoAbort( IDS_PROGRESS_CONVERTING_TO_OFFLINE_GAME ); pMinecraft->progressRenderer->progressStage( -1 ); //g_NetworkManager.CorrectErrorIDS(IDS_CONNECTION_LOST_LIVE_NO_EXIT) );#elif defined(_XBOX_ONE) if( g_NetworkManager.m_bFullSessionMessageOnNextSessionChange ) { UINT uiIDA[1]; uiIDA[0]=IDS_CONFIRM_OK; C4JStorage::EMessageResult result = ui.RequestErrorMessage( IDS_PROGRESS_CONVERTING_TO_OFFLINE_GAME, IDS_IN_PARTY_SESSION_FULL, uiIDA,1,ProfileManager.GetPrimaryPad()); pMinecraft->progressRenderer->progressStartNoAbort( IDS_PROGRESS_CONVERTING_TO_OFFLINE_GAME ); pMinecraft->progressRenderer->progressStage( -1 ); } else { pMinecraft->progressRenderer->progressStartNoAbort( g_NetworkManager.CorrectErrorIDS(IDS_CONNECTION_LOST_LIVE_NO_EXIT) ); pMinecraft->progressRenderer->progressStage( IDS_PROGRESS_CONVERTING_TO_OFFLINE_GAME ); } #else pMinecraft->progressRenderer->progressStartNoAbort( g_NetworkManager.CorrectErrorIDS(IDS_CONNECTION_LOST_LIVE_NO_EXIT) ); pMinecraft->progressRenderer->progressStage( IDS_PROGRESS_CONVERTING_TO_OFFLINE_GAME );#endif
while( app.GetXuiServerAction(ProfileManager.GetPrimaryPad() ) != eXuiServerAction_Idle && !MinecraftServer::serverHalted() ) { Sleep(10); } app.SetXuiServerAction(ProfileManager.GetPrimaryPad(),eXuiServerAction_PauseServer,(void *)TRUE);
// wait for the server to be in a non-ticking state pServer->m_serverPausedEvent->WaitForSignal(INFINITE); #if defined(__PS3__) || defined(__ORBIS__) || defined __PSVITA__ // Swap these two messages around as one is too long to display at 480 pMinecraft->progressRenderer->progressStartNoAbort( IDS_PROGRESS_CONVERTING_TO_OFFLINE_GAME ); pMinecraft->progressRenderer->progressStage( -1 ); //g_NetworkManager.CorrectErrorIDS(IDS_CONNECTION_LOST_LIVE_NO_EXIT) );#elif defined(_XBOX_ONE) if( g_NetworkManager.m_bFullSessionMessageOnNextSessionChange ) { pMinecraft->progressRenderer->progressStartNoAbort( IDS_PROGRESS_CONVERTING_TO_OFFLINE_GAME ); pMinecraft->progressRenderer->progressStage( -1 ); } else { pMinecraft->progressRenderer->progressStartNoAbort( g_NetworkManager.CorrectErrorIDS(IDS_CONNECTION_LOST_LIVE_NO_EXIT) ); pMinecraft->progressRenderer->progressStage( IDS_PROGRESS_CONVERTING_TO_OFFLINE_GAME ); }#else pMinecraft->progressRenderer->progressStartNoAbort( g_NetworkManager.CorrectErrorIDS(IDS_CONNECTION_LOST_LIVE_NO_EXIT) ); pMinecraft->progressRenderer->progressStage( IDS_PROGRESS_CONVERTING_TO_OFFLINE_GAME );#endif
pMinecraft->progressRenderer->progressStagePercentage(25);
#ifdef _XBOX_ONE // wait for any players that were being added, to finish doing this. On XB1, if we don't do this then there's an async thread running doing this, // which could then finish at any inappropriate time later while( s_pPlatformNetworkManager->IsAddingPlayer() ) { Sleep(1); }#endif
// Null the network player of all the server players that are local, to stop them being removed from the server when removed from the session if( pServer != NULL ) { PlayerList *players = pServer->getPlayers(); for(AUTO_VAR(it, players->players.begin()); it < players->players.end(); ++it) { shared_ptr<ServerPlayer> servPlayer = *it; if( servPlayer->connection->isLocal() && !servPlayer->connection->isGuest() ) { servPlayer->connection->connection->getSocket()->setPlayer(NULL); } } }
// delete the current session - if we weren't actually disconnected fully from the network but have just lost our room, then pass a bLeaveRoom flag of false // here as by definition we don't need to leave the room (again). This is currently only an issue for sony platforms. if( g_NetworkManager.m_bLastDisconnectWasLostRoomOnly ) { s_pPlatformNetworkManager->_LeaveGame(false, false); } else { s_pPlatformNetworkManager->_LeaveGame(false, true); }
// wait for the current session to end while( g_NetworkManager.IsInSession() ) { Sleep(1); } // Reset this flag as the we don't need to know that we only lost the room only from this point onwards, the behaviour is exactly the same g_NetworkManager.m_bLastDisconnectWasLostRoomOnly = false; g_NetworkManager.m_bFullSessionMessageOnNextSessionChange = false;
pMinecraft->progressRenderer->progressStagePercentage(50);
// Defaulting to making this a local game g_NetworkManager.SetLocalGame(true);
// Create a new session with all the players that were in the old one int localUsersMask = 0; char numLocalPlayers = 0; for(unsigned int index = 0; index < XUSER_MAX_COUNT; ++index) { if(ProfileManager.IsSignedIn(index) && pMinecraft->localplayers[index] != NULL ) { numLocalPlayers++; localUsersMask |= GetLocalPlayerMask(index); } }
s_pPlatformNetworkManager->_HostGame( localUsersMask );
pMinecraft->progressRenderer->progressStagePercentage(75);
// Wait for all the local players to rejoin the session while( g_NetworkManager.GetPlayerCount() < numLocalPlayers ) { Sleep(1); } // Restore the network player of all the server players that are local if( pServer != NULL ) { for(unsigned int index = 0; index < XUSER_MAX_COUNT; ++index) { if(ProfileManager.IsSignedIn(index) && pMinecraft->localplayers[index] != NULL ) { PlayerUID localPlayerXuid = pMinecraft->localplayers[index]->getXuid();
PlayerList *players = pServer->getPlayers(); for(AUTO_VAR(it, players->players.begin()); it < players->players.end(); ++it) { shared_ptr<ServerPlayer> servPlayer = *it; if( servPlayer->getXuid() == localPlayerXuid ) { servPlayer->connection->connection->getSocket()->setPlayer( g_NetworkManager.GetLocalPlayerByUserIndex(index) ); } }
// Player might have a pending connection if (pMinecraft->m_pendingLocalConnections[index] != NULL) { // Update the network player pMinecraft->m_pendingLocalConnections[index]->getConnection()->getSocket()->setPlayer(g_NetworkManager.GetLocalPlayerByUserIndex(index)); } else if ( pMinecraft->m_connectionFailed[index] && (pMinecraft->m_connectionFailedReason[index] == DisconnectPacket::eDisconnect_ConnectionCreationFailed) ) { pMinecraft->removeLocalPlayerIdx(index);#ifdef _XBOX_ONE ProfileManager.RemoveGamepadFromGame(index);#endif } } } } pMinecraft->progressRenderer->progressStagePercentage(100);
#ifndef _XBOX // Make sure that we have transitioned through any joining/creating stages so we're actually ready to set to play while(!s_pPlatformNetworkManager->IsReadyToPlayOrIdle()) { Sleep(10); }#endif
s_pPlatformNetworkManager->_StartGame();
#ifndef _XBOX // Wait until the message box has been closed while(ui.IsSceneInStack(XUSER_INDEX_ANY, eUIScene_MessageBox)) { Sleep(10); }#endif
// Start the game again app.SetGameStarted(true); app.SetXuiServerAction(ProfileManager.GetPrimaryPad(),eXuiServerAction_PauseServer,(void *)FALSE); app.SetChangingSessionType(false); app.SetReallyChangingSessionType(false);
return S_OK;
}
void CGameNetworkManager::SystemFlagSet(INetworkPlayer *pNetworkPlayer, int index){ s_pPlatformNetworkManager->SystemFlagSet( pNetworkPlayer, index );}
bool CGameNetworkManager::SystemFlagGet(INetworkPlayer *pNetworkPlayer, int index){ return s_pPlatformNetworkManager->SystemFlagGet( pNetworkPlayer, index );}
wstring CGameNetworkManager::GatherStats(){ return s_pPlatformNetworkManager->GatherStats();}
void CGameNetworkManager::renderQueueMeter(){#ifdef _XBOX int height = 720;
CGameNetworkManager::byteQueue[(CGameNetworkManager::messageQueuePos) & (CGameNetworkManager::messageQueue_length - 1)] = GetHostPlayer()->GetSendQueueSizeBytes(NULL, false); CGameNetworkManager::messageQueue[(CGameNetworkManager::messageQueuePos++) & (CGameNetworkManager::messageQueue_length - 1)] = GetHostPlayer()->GetSendQueueSizeMessages(NULL, false);
Minecraft *pMinecraft = Minecraft::GetInstance(); pMinecraft->gui->renderGraph(CGameNetworkManager::messageQueue_length, CGameNetworkManager::messageQueuePos, CGameNetworkManager::messageQueue, 10, 1000, CGameNetworkManager::byteQueue, 100, 25000);#endif}
wstring CGameNetworkManager::GatherRTTStats(){ return s_pPlatformNetworkManager->GatherRTTStats();}
void CGameNetworkManager::StateChange_AnyToHosting(){ app.DebugPrintf("Disabling Guest Signin\n"); XEnableGuestSignin(FALSE); Minecraft::GetInstance()->clearPendingClientTextureRequests();}
void CGameNetworkManager::StateChange_AnyToJoining(){ app.DebugPrintf("Disabling Guest Signin\n"); XEnableGuestSignin(FALSE); Minecraft::GetInstance()->clearPendingClientTextureRequests(); ConnectionProgressParams *param = new ConnectionProgressParams(); param->iPad = ProfileManager.GetPrimaryPad(); param->stringId = -1; param->showTooltips = false; param->setFailTimer = true; param->timerTime = CONNECTING_PROGRESS_CHECK_TIME;
ui.NavigateToScene(ProfileManager.GetPrimaryPad(), eUIScene_ConnectingProgress, param);}
void CGameNetworkManager::StateChange_JoiningToIdle(CPlatformNetworkManager::eJoinFailedReason reason){ DisconnectPacket::eDisconnectReason disconnectReason; switch(reason) { case CPlatformNetworkManager::JOIN_FAILED_SERVER_FULL: disconnectReason = DisconnectPacket::eDisconnect_ServerFull; break; case CPlatformNetworkManager::JOIN_FAILED_INSUFFICIENT_PRIVILEGES: disconnectReason = DisconnectPacket::eDisconnect_NoMultiplayerPrivilegesJoin; app.SetAction(ProfileManager.GetPrimaryPad(),eAppAction_FailedToJoinNoPrivileges); break; default: disconnectReason = DisconnectPacket::eDisconnect_ConnectionCreationFailed; break; }; Minecraft::GetInstance()->connectionDisconnected(ProfileManager.GetPrimaryPad(), disconnectReason);}
void CGameNetworkManager::StateChange_AnyToStarting(){#if defined __PS3__ || defined __ORBIS__ || defined __PSVITA__ app.getRemoteStorage()->shutdown(); // shut the remote storage lib down and hopefully get our 7mb back#endif
if(!g_NetworkManager.IsHost()) { LoadingInputParams *loadingParams = new LoadingInputParams(); loadingParams->func = &CGameNetworkManager::RunNetworkGameThreadProc; loadingParams->lpParam = NULL;
UIFullscreenProgressCompletionData *completionData = new UIFullscreenProgressCompletionData(); completionData->bShowBackground=TRUE; completionData->bShowLogo=TRUE; completionData->type = e_ProgressCompletion_CloseAllPlayersUIScenes; completionData->iPad = ProfileManager.GetPrimaryPad(); loadingParams->completionData = completionData; ui.NavigateToScene(ProfileManager.GetPrimaryPad(),eUIScene_FullscreenProgress, loadingParams); }}
void CGameNetworkManager::StateChange_AnyToEnding(bool bStateWasPlaying){ // Kick off a stats write for players that are signed into LIVE, if this is a local game if( bStateWasPlaying && g_NetworkManager.IsLocalGame() ) { for(unsigned int i = 0; i < XUSER_MAX_COUNT; ++i) { INetworkPlayer *pNetworkPlayer = g_NetworkManager.GetLocalPlayerByUserIndex(i); if(pNetworkPlayer != NULL && ProfileManager.IsSignedIn( i ) ) { app.DebugPrintf("Stats save for an offline game for the player at index %d\n", i ); Minecraft::GetInstance()->forceStatsSave(pNetworkPlayer->GetUserIndex()); } } }
Minecraft::GetInstance()->gui->clearMessages();
if(!g_NetworkManager.IsHost() && !g_NetworkManager.IsLeavingGame() ) { // 4J Stu - If the host is saving then it might take a while to quite the session, so do it ourself //m_bLeavingGame = true;
// The host has notified that the game is about to end if(app.GetDisconnectReason() == DisconnectPacket::eDisconnect_None) app.SetDisconnectReason( DisconnectPacket::eDisconnect_Quitting ); app.SetAction(ProfileManager.GetPrimaryPad(),eAppAction_ExitWorld,(void *)TRUE); }}
void CGameNetworkManager::StateChange_AnyToIdle(){ app.DebugPrintf("Enabling Guest Signin\n"); XEnableGuestSignin(TRUE); // Reset this here so that we can search for games again // 4J Stu - If we are changing session type there is a race between that thread setting the game to local, and this setting it to not local if(!app.GetChangingSessionType()) g_NetworkManager.SetLocalGame( false );
}
void CGameNetworkManager::CreateSocket( INetworkPlayer *pNetworkPlayer, bool localPlayer ){ Minecraft *pMinecraft = Minecraft::GetInstance();
Socket *socket = NULL; shared_ptr<MultiplayerLocalPlayer> mpPlayer = nullptr; int userIdx = pNetworkPlayer->GetUserIndex(); if (userIdx >= 0 && userIdx < XUSER_MAX_COUNT) mpPlayer = pMinecraft->localplayers[userIdx]; if( localPlayer && mpPlayer != NULL && mpPlayer->connection != NULL) { // If we already have a MultiplayerLocalPlayer here then we are doing a session type change socket = mpPlayer->connection->getSocket();
// Pair this socket and network player pNetworkPlayer->SetSocket( socket); if( socket ) { socket->setPlayer( pNetworkPlayer ); } } else { socket = new Socket( pNetworkPlayer, g_NetworkManager.IsHost(), g_NetworkManager.IsHost() && localPlayer ); pNetworkPlayer->SetSocket( socket );
// 4J Stu - May be other states we want to accept aswell // Add this user to the game server if the game is started already if( g_NetworkManager.IsHost() && g_NetworkManager.IsInGameplay() ) { Socket::addIncomingSocket(socket); }
// If this is a local player and we are already in the game, we need to setup a local connection and log // the player in to the game server if( localPlayer && g_NetworkManager.IsInGameplay() ) { int idx = pNetworkPlayer->GetUserIndex(); app.DebugPrintf("Creating new client connection for idx: %d\n", idx);
ClientConnection *connection; connection = new ClientConnection(pMinecraft, socket, idx);
if( connection->createdOk ) { connection->send( shared_ptr<PreLoginPacket>( new PreLoginPacket( pNetworkPlayer->GetOnlineName() ) ) ); pMinecraft->addPendingLocalConnection(idx, connection); } else { pMinecraft->connectionDisconnected( idx , DisconnectPacket::eDisconnect_ConnectionCreationFailed ); delete connection; connection = NULL; } } }
}
void CGameNetworkManager::CloseConnection( INetworkPlayer *pNetworkPlayer ){ MinecraftServer *server = MinecraftServer::getInstance(); if( server != NULL ) { PlayerList *players = server->getPlayers(); if( players != NULL ) { players->closePlayerConnectionBySmallId(pNetworkPlayer->GetSmallId()); } }}
void CGameNetworkManager::PlayerJoining( INetworkPlayer *pNetworkPlayer ){ if (g_NetworkManager.IsInGameplay()) // 4J-JEV: Wait to do this at StartNetworkGame if not in-game yet. { // 4J-JEV: Update RichPresence when a player joins the game. bool multiplayer = g_NetworkManager.GetPlayerCount() > 1, localgame = g_NetworkManager.IsLocalGame(); for (int iPad=0; iPad<XUSER_MAX_COUNT; ++iPad) { INetworkPlayer *pNetworkPlayer = g_NetworkManager.GetLocalPlayerByUserIndex(iPad); if (pNetworkPlayer == NULL) continue;
app.SetRichPresenceContext(iPad,CONTEXT_GAME_STATE_BLANK); if (multiplayer) { if (localgame) ProfileManager.SetCurrentGameActivity(iPad, CONTEXT_PRESENCE_MULTIPLAYEROFFLINE, false); else ProfileManager.SetCurrentGameActivity(iPad, CONTEXT_PRESENCE_MULTIPLAYER, false); } else { if (localgame) ProfileManager.SetCurrentGameActivity(iPad, CONTEXT_PRESENCE_MULTIPLAYER_1POFFLINE, false); else ProfileManager.SetCurrentGameActivity(iPad, CONTEXT_PRESENCE_MULTIPLAYER_1P, false); } } }
if( pNetworkPlayer->IsLocal() ) { TelemetryManager->RecordPlayerSessionStart(pNetworkPlayer->GetUserIndex()); }#ifdef _XBOX else { if( !pNetworkPlayer->IsHost() ) { for(int idx = 0; idx < XUSER_MAX_COUNT; ++idx) { if(Minecraft::GetInstance()->localplayers[idx] != NULL) { TelemetryManager->RecordLevelStart(idx, eSen_FriendOrMatch_Playing_With_Invited_Friends, eSen_CompeteOrCoop_Coop_and_Competitive, Minecraft::GetInstance()->level->difficulty, app.GetLocalPlayerCount(), g_NetworkManager.GetOnlinePlayerCount()); } } } }#endif}
void CGameNetworkManager::PlayerLeaving( INetworkPlayer *pNetworkPlayer ){ if( pNetworkPlayer->IsLocal() ) { ProfileManager.SetCurrentGameActivity(pNetworkPlayer->GetUserIndex(),CONTEXT_PRESENCE_IDLE,false);
TelemetryManager->RecordPlayerSessionExit(pNetworkPlayer->GetUserIndex(), app.GetDisconnectReason()); }#ifdef _XBOX else { for(int idx = 0; idx < XUSER_MAX_COUNT; ++idx) { if(Minecraft::GetInstance()->localplayers[idx] != NULL) { TelemetryManager->RecordLevelStart(idx, eSen_FriendOrMatch_Playing_With_Invited_Friends, eSen_CompeteOrCoop_Coop_and_Competitive, Minecraft::GetInstance()->level->difficulty, app.GetLocalPlayerCount(), g_NetworkManager.GetOnlinePlayerCount()); } } }#endif}
void CGameNetworkManager::HostChanged(){ // Disable host migration app.SetAction(ProfileManager.GetPrimaryPad(),eAppAction_ExitWorld,(void *)TRUE);}
void CGameNetworkManager::WriteStats( INetworkPlayer *pNetworkPlayer ){ Minecraft::GetInstance()->forceStatsSave( pNetworkPlayer->GetUserIndex() );}
void CGameNetworkManager::GameInviteReceived( int userIndex, const INVITE_INFO *pInviteInfo){#ifdef __ORBIS__ if (m_pUpsell != NULL) { delete pInviteInfo; return; }
// Need to check we're signed in to PSN bool isSignedInLive = true; bool isLocalMultiplayerAvailable = app.IsLocalMultiplayerAvailable(); int iPadNotSignedInLive = -1; for(unsigned int i = 0; i < XUSER_MAX_COUNT; i++) { if (ProfileManager.IsSignedIn(i) && (i == ProfileManager.GetPrimaryPad() || isLocalMultiplayerAvailable)) { if (isSignedInLive && !ProfileManager.IsSignedInLive(i)) { // Record the first non signed in live pad iPadNotSignedInLive = i; }
isSignedInLive = isSignedInLive && ProfileManager.IsSignedInLive(i); } }
if (!isSignedInLive) { // Determine why they're not "signed in live"
// Check if PSN is unavailable because of age restriction int npAvailability = ProfileManager.getNPAvailability(iPadNotSignedInLive); if (npAvailability == SCE_NP_ERROR_AGE_RESTRICTION) { // 4J Stu - This is a bit messy and is due to the library incorrectly returning false for IsSignedInLive if the npAvailability isn't SCE_OK UINT uiIDA[1]; uiIDA[0]=IDS_OK; ui.RequestErrorMessage(IDS_ONLINE_SERVICE_TITLE, IDS_CONTENT_RESTRICTION, uiIDA, 1, iPadNotSignedInLive); } else if (ProfileManager.isSignedInPSN(iPadNotSignedInLive)) { // Signed in to PSN but not connected (no internet access) assert(!ProfileManager.isConnectedToPSN(iPadNotSignedInLive));
UINT uiIDA[1]; uiIDA[0] = IDS_OK; ui.RequestErrorMessage( IDS_ERROR_NETWORK_TITLE, IDS_ERROR_NETWORK, uiIDA, 1, iPadNotSignedInLive); } else { // Not signed in to PSN UINT uiIDA[1]; uiIDA[0] = IDS_PRO_NOTONLINE_ACCEPT; ui.RequestAlertMessage( IDS_PRO_NOTONLINE_TITLE, IDS_PRO_NOTONLINE_TEXT, uiIDA, 1, iPadNotSignedInLive, &CGameNetworkManager::MustSignInReturned_1, (void *)pInviteInfo); } return; }
// if this is the trial game, we'll check and send the user to unlock the game later, in HandleInviteWhenInMenus if(ProfileManager.IsFullVersion()) { // 4J-JEV: Check that all players are authorised for PsPlus, present upsell to players that aren't and try again. for (unsigned int index = 0; index < XUSER_MAX_COUNT; index++) { if ( ProfileManager.IsSignedIn(index) && !ProfileManager.HasPlayStationPlus(userIndex) ) { m_pInviteInfo = (INVITE_INFO *) pInviteInfo; m_iPlayerInvited = userIndex; m_pUpsell = new PsPlusUpsellWrapper(index); m_pUpsell->displayUpsell(); return; } } }#endif
int localUsersMask = 0; Minecraft *pMinecraft = Minecraft::GetInstance(); int joiningUsers = 0;
bool noPrivileges = false; for(unsigned int index = 0; index < XUSER_MAX_COUNT; ++index) { if(ProfileManager.IsSignedIn(index) ) { // 4J-PB we shouldn't bring any inactive players into the game, except for the invited player (who may be an inactive player) // 4J Stu - If we are not in a game, then bring in all players signed in if(index==userIndex || pMinecraft->localplayers[index]!=NULL ) { ++joiningUsers; if( !ProfileManager.AllowedToPlayMultiplayer(index) ) noPrivileges = true; localUsersMask |= GetLocalPlayerMask( index ); } } }
// Check if user-created content is allowed, as we cannot play multiplayer if it's not bool noUGC = false; bool bContentRestricted=false; BOOL pccAllowed = TRUE; BOOL pccFriendsAllowed = TRUE;#if defined(__PS3__) || defined(__PSVITA__) ProfileManager.GetChatAndContentRestrictions(userIndex,false,&noUGC,&bContentRestricted,NULL);#else ProfileManager.AllowedPlayerCreatedContent(ProfileManager.GetPrimaryPad(),false,&pccAllowed,&pccFriendsAllowed); if(!pccAllowed && !pccFriendsAllowed) noUGC = true;#endif #if defined(_XBOX) || defined(__PS3__) if(joiningUsers > 1 && !RenderManager.IsHiDef() && userIndex != ProfileManager.GetPrimaryPad()) { UINT uiIDA[1]; uiIDA[0]=IDS_CONFIRM_OK;
// 4J-PB - it's possible there is no primary pad here, when accepting an invite from the dashboard ui.RequestErrorMessage( IDS_CONNECTION_FAILED, IDS_CONNECTION_FAILED_NO_SD_SPLITSCREEN, uiIDA,1,XUSER_INDEX_ANY); } else#endif
if( noUGC ) {#ifdef __PSVITA__ // showing the system message for chat restriction here instead now, to fix FQA bug report ProfileManager.DisplaySystemMessage( SCE_MSG_DIALOG_SYSMSG_TYPE_TRC_PSN_CHAT_RESTRICTION, ProfileManager.GetPrimaryPad() );#else int messageText = IDS_NO_USER_CREATED_CONTENT_PRIVILEGE_SINGLE_LOCAL; if(joiningUsers > 1) messageText = IDS_NO_USER_CREATED_CONTENT_PRIVILEGE_ALL_LOCAL;
ui.RequestUGCMessageBox(IDS_CONNECTION_FAILED, messageText, XUSER_INDEX_ANY);#endif }#if defined(__PS3__) || defined __PSVITA__ else if(bContentRestricted) { int messageText = IDS_CONTENT_RESTRICTION; if(joiningUsers > 1) messageText = IDS_CONTENT_RESTRICTION_MULTIPLAYER;
ui.RequestContentRestrictedMessageBox(IDS_CONNECTION_FAILED, messageText, XUSER_INDEX_ANY); }#endif else if(noPrivileges) { UINT uiIDA[1]; uiIDA[0]=IDS_CONFIRM_OK;
// 4J-PB - it's possible there is no primary pad here, when accepting an invite from the dashboard //StorageManager.RequestMessageBox( IDS_NO_MULTIPLAYER_PRIVILEGE_TITLE, IDS_NO_MULTIPLAYER_PRIVILEGE_JOIN_TEXT, uiIDA,1,ProfileManager.GetPrimaryPad(),NULL,NULL, app.GetStringTable()); ui.RequestErrorMessage( IDS_NO_MULTIPLAYER_PRIVILEGE_TITLE, IDS_NO_MULTIPLAYER_PRIVILEGE_JOIN_TEXT, uiIDA,1,XUSER_INDEX_ANY); } else {#if defined(__ORBIS__) || defined(__PSVITA__) bool chatRestricted = false; ProfileManager.GetChatAndContentRestrictions(ProfileManager.GetPrimaryPad(),false,&chatRestricted,NULL,NULL); if(chatRestricted) { ProfileManager.DisplaySystemMessage( SCE_MSG_DIALOG_SYSMSG_TYPE_TRC_PSN_CHAT_RESTRICTION, ProfileManager.GetPrimaryPad() ); }#endif if( !g_NetworkManager.IsInSession() ) { #if defined (__PS3__) || defined (__PSVITA__) // PS3 is more complicated here - we need to make sure that the player is online. If they are then we can do the same as the xbox, if not we need to try and get them online and then, if they do sign in, go down the same path // Determine why they're not "signed in live" // MGH - On Vita we need to add a new message at some point for connecting when already signed in if(ProfileManager.IsSignedInLive(ProfileManager.GetPrimaryPad())) { HandleInviteWhenInMenus(userIndex, pInviteInfo); } else { UINT uiIDA[2]; uiIDA[0]=IDS_PRO_NOTONLINE_ACCEPT; uiIDA[1]=IDS_PRO_NOTONLINE_DECLINE; ui.RequestErrorMessage(IDS_PRO_NOTONLINE_TITLE, IDS_PRO_NOTONLINE_TEXT, uiIDA, 2, ProfileManager.GetPrimaryPad(),&CGameNetworkManager::MustSignInReturned_1,(void *)pInviteInfo); }
#else HandleInviteWhenInMenus(userIndex, pInviteInfo); #endif } else { app.DebugPrintf("We are already in a multiplayer game...need to leave it\n");
// JoinFromInviteData *joinData = new JoinFromInviteData();// joinData->dwUserIndex = dwUserIndex;// joinData->dwLocalUsersMask = dwLocalUsersMask;// joinData->pInviteInfo = pInviteInfo;
// tell the app to process this#ifdef __PSVITA__ if(((CPlatformNetworkManagerSony*)s_pPlatformNetworkManager)->checkValidInviteData(pInviteInfo))#endif { app.ProcessInvite(userIndex,localUsersMask,pInviteInfo); } } }}
volatile bool waitHere = true;
void CGameNetworkManager::HandleInviteWhenInMenus( int userIndex, const INVITE_INFO *pInviteInfo){ // We are in the root menus somewhere
#if 0 while( waitHere ) { Sleep(1); }#endif
// if this is the trial game, then we need the user to unlock the full game if(!ProfileManager.IsFullVersion()) { // The marketplace will fail with the primary player set to -1 ProfileManager.SetPrimaryPad(userIndex);
app.SetAction(userIndex,eAppAction_DashboardTrialJoinFromInvite); } else {#ifndef _XBOX_ONE ProfileManager.SetPrimaryPad(userIndex);#endif
// 4J Stu - If we accept an invite from the main menu before going to play game we need to load the DLC // These checks are done within the StartInstallDLCProcess - (!app.DLCInstallProcessCompleted() && !app.DLCInstallPending()) app.StartInstallDLCProcess(dwUserIndex); app.StartInstallDLCProcess(userIndex);
// 4J Stu - Fix for #10936 - MP Lab: TCR 001: Matchmaking: Player is stuck in a soft-locked state after selecting the guest account when prompted // The locked profile should not be changed if we are in menus as the main player might sign out in the sign-in ui //ProfileManager.SetLockedProfile(-1);
#ifdef _XBOX_ONE if((!app.IsLocalMultiplayerAvailable())&&InputManager.IsPadLocked(userIndex))#else if(!app.IsLocalMultiplayerAvailable())#endif { bool noPrivileges=!ProfileManager.AllowedToPlayMultiplayer(userIndex);
if(noPrivileges) { UINT uiIDA[1]; uiIDA[0]=IDS_CONFIRM_OK; ui.RequestErrorMessage( IDS_NO_MULTIPLAYER_PRIVILEGE_TITLE, IDS_NO_MULTIPLAYER_PRIVILEGE_JOIN_TEXT, uiIDA,1,ProfileManager.GetPrimaryPad()); } else { ProfileManager.SetLockedProfile(userIndex); ProfileManager.SetPrimaryPad(userIndex);
int localUsersMask=0; localUsersMask |= GetLocalPlayerMask( userIndex );
// If the player was signed in before selecting play, we'll not have read the profile yet, so query the sign-in status to get this to happen ProfileManager.QuerySigninStatus();
// 4J-PB - clear any previous connection errors Minecraft::GetInstance()->clearConnectionFailed();
g_NetworkManager.SetLocalGame(false);
// change the minecraft player name Minecraft::GetInstance()->user->name = convStringToWstring( ProfileManager.GetGamertag(ProfileManager.GetPrimaryPad()));
bool success = g_NetworkManager.JoinGameFromInviteInfo( userIndex, localUsersMask, pInviteInfo ); if( !success ) { app.DebugPrintf( "Failed joining game from invite\n" ); } } } else { // the FromInvite will make the lib decide how many panes to display based on connected pads/signed in players#ifdef _XBOX ProfileManager.RequestSignInUI(true, false, false, false, false,&CGameNetworkManager::JoinFromInvite_SignInReturned, (LPVOID)pInviteInfo,userIndex);#else SignInInfo info; info.Func = &CGameNetworkManager::JoinFromInvite_SignInReturned; info.lpParam = (LPVOID)pInviteInfo; info.requireOnline = true; app.DebugPrintf("Using fullscreen layer\n"); ui.NavigateToScene(ProfileManager.GetPrimaryPad(),eUIScene_QuadrantSignin,&info,eUILayer_Alert,eUIGroup_Fullscreen);#endif } }}
void CGameNetworkManager::AddLocalPlayerFailed(int idx, bool serverFull/* = false*/){ Minecraft::GetInstance()->connectionDisconnected(idx, serverFull ? DisconnectPacket::eDisconnect_ServerFull : DisconnectPacket::eDisconnect_ConnectionCreationFailed);}
#if defined __PS3__ || defined __PSVITA__ || defined __ORBIS__void CGameNetworkManager::HandleDisconnect(bool bLostRoomOnly,bool bPSNSignout)#elsevoid CGameNetworkManager::HandleDisconnect(bool bLostRoomOnly)#endif{ int iPrimaryPlayer = g_NetworkManager.GetPrimaryPad();
if((g_NetworkManager.GetLockedProfile()!=-1) && iPrimaryPlayer!=-1 && g_NetworkManager.IsInSession() ) { m_bLastDisconnectWasLostRoomOnly = bLostRoomOnly;#if defined __PS3__ || defined __PSVITA__ || defined __ORBIS__ m_bSignedOutofPSN=bPSNSignout;#endif app.SetAction(iPrimaryPlayer,eAppAction_EthernetDisconnected); } else { m_bLastDisconnectWasLostRoomOnly = false; }}
int CGameNetworkManager::GetPrimaryPad(){ return ProfileManager.GetPrimaryPad();}
int CGameNetworkManager::GetLockedProfile(){ return ProfileManager.GetLockedProfile();}
bool CGameNetworkManager::IsSignedInLive(int playerIdx){ return ProfileManager.IsSignedInLive(playerIdx);}
bool CGameNetworkManager::AllowedToPlayMultiplayer(int playerIdx){ return ProfileManager.AllowedToPlayMultiplayer(playerIdx);}
char *CGameNetworkManager::GetOnlineName(int playerIdx){ return ProfileManager.GetGamertag(playerIdx);}
void CGameNetworkManager::ServerReadyCreate(bool create){ m_hServerReadyEvent = ( create ? ( new C4JThread::Event ) : NULL );}
void CGameNetworkManager::ServerReady(){ m_hServerReadyEvent->Set();}
void CGameNetworkManager::ServerReadyWait(){ m_hServerReadyEvent->WaitForSignal(INFINITE);}
void CGameNetworkManager::ServerReadyDestroy(){ delete m_hServerReadyEvent; m_hServerReadyEvent = NULL;}
bool CGameNetworkManager::ServerReadyValid(){ return ( m_hServerReadyEvent != NULL );}
void CGameNetworkManager::ServerStoppedCreate(bool create){ m_hServerStoppedEvent = ( create ? ( new C4JThread::Event ) : NULL );}
void CGameNetworkManager::ServerStopped(){ m_hServerStoppedEvent->Set();}
void CGameNetworkManager::ServerStoppedWait(){ // If this is called from the main thread, then this won't be ticking anything which can mean that the storage manager state can't progress. // This means that the server thread we are waiting on won't ever finish, as it might be locked waiting for this to complete itself. // Do some ticking here then if this is the case. if( C4JThread::isMainThread() ) { int result = WAIT_TIMEOUT; do {#ifndef _XBOX RenderManager.StartFrame();#endif result = m_hServerStoppedEvent->WaitForSignal(20); // Tick some simple things ProfileManager.Tick(); StorageManager.Tick(); InputManager.Tick(); RenderManager.Tick(); ui.tick(); ui.render(); RenderManager.Present(); } while( result == WAIT_TIMEOUT ); } else { m_hServerStoppedEvent->WaitForSignal(INFINITE); }}
void CGameNetworkManager::ServerStoppedDestroy(){ delete m_hServerStoppedEvent; m_hServerStoppedEvent = NULL;}
bool CGameNetworkManager::ServerStoppedValid(){ return ( m_hServerStoppedEvent != NULL );}
int CGameNetworkManager::GetJoiningReadyPercentage(){ return s_pPlatformNetworkManager->GetJoiningReadyPercentage();}
#ifndef _XBOXvoid CGameNetworkManager::FakeLocalPlayerJoined(){ s_pPlatformNetworkManager->FakeLocalPlayerJoined();}#endif
#ifdef __PSVITA__bool CGameNetworkManager::usingAdhocMode(){ return ((CPlatformNetworkManagerSony*)s_pPlatformNetworkManager)->usingAdhocMode();}
void CGameNetworkManager::setAdhocMode(bool bAdhoc){ ((CPlatformNetworkManagerSony*)s_pPlatformNetworkManager)->setAdhocMode(bAdhoc);}
void CGameNetworkManager::startAdhocMatching(){ ((CPlatformNetworkManagerSony*)s_pPlatformNetworkManager)->startAdhocMatching();}
#endif