自学教程：C++ CreateTransport函数代码示例

boolOpen(const PrivateIPDLInterface&,     MessageChannel* aOpenerChannel, ProcessId aOtherProcessId,     Transport::Mode aOpenerMode,     ProtocolId aProtocol, ProtocolId aChildProtocol){  bool isParent = (Transport::MODE_SERVER == aOpenerMode);  ProcessId thisPid = GetCurrentProcId();  ProcessId parentId = isParent ? thisPid : aOtherProcessId;  ProcessId childId = !isParent ? thisPid : aOtherProcessId;  if (!parentId || !childId) {    return false;  }  TransportDescriptor parentSide, childSide;  if (!CreateTransport(parentId, &parentSide, &childSide)) {    return false;  }  Message* parentMsg = new ChannelOpened(parentSide, childId, aProtocol);  Message* childMsg = new ChannelOpened(childSide, parentId, aChildProtocol);  nsAutoPtr<Message> messageForUs(isParent ? parentMsg : childMsg);  nsAutoPtr<Message> messageForOtherSide(!isParent ? parentMsg : childMsg);  if (!aOpenerChannel->Echo(messageForUs.forget()) ||      !aOpenerChannel->Send(messageForOtherSide.forget())) {    CloseDescriptor(parentSide);    CloseDescriptor(childSide);    return false;  }  return true;}

boolBridge(const PrivateIPDLInterface&,       MessageChannel* aParentChannel, ProcessHandle aParentProcess,       MessageChannel* aChildChannel, ProcessHandle aChildProcess,       ProtocolId aProtocol, ProtocolId aChildProtocol){  ProcessId parentId = GetProcId(aParentProcess);  ProcessId childId = GetProcId(aChildProcess);  if (!parentId || !childId) {    return false;  }  TransportDescriptor parentSide, childSide;  if (!CreateTransport(aParentProcess, aChildProcess,                       &parentSide, &childSide)) {    return false;  }  if (!aParentChannel->Send(new ChannelOpened(parentSide,                                              childId,                                              aProtocol)) ||      !aChildChannel->Send(new ChannelOpened(childSide,                                             parentId,                                             aChildProtocol))) {    CloseDescriptor(parentSide);    CloseDescriptor(childSide);    return false;  }  return true;}

boolBridge(const PrivateIPDLInterface&,       MessageChannel* aParentChannel, ProcessId aParentPid,       MessageChannel* aChildChannel, ProcessId aChildPid,       ProtocolId aProtocol, ProtocolId aChildProtocol){  if (!aParentPid || !aChildPid) {    return false;  }  TransportDescriptor parentSide, childSide;  if (!CreateTransport(aParentPid, &parentSide, &childSide)) {    return false;  }  if (!aParentChannel->Send(new ChannelOpened(parentSide,                                              aChildPid,                                              aProtocol,                                              IPC::Message::PRIORITY_URGENT)) ||      !aChildChannel->Send(new ChannelOpened(childSide,                                             aParentPid,                                             aChildProtocol,                                             IPC::Message::PRIORITY_URGENT))) {    CloseDescriptor(parentSide);    CloseDescriptor(childSide);    return false;  }  return true;}

void TransportMgr::SpawnContinentTransports(){    if (_transportTemplates.empty())        return;    uint32 oldMSTime = getMSTime();    QueryResult result = WorldDatabase.Query("SELECT guid, entry FROM transports");    uint32 count = 0;    if (result)    {        do        {            Field* fields = result->Fetch();            uint32 guid = fields[0].GetUInt32();            uint32 entry = fields[1].GetUInt32();            if (TransportTemplate const* tInfo = GetTransportTemplate(entry))                if (!tInfo->inInstance)                    if (CreateTransport(entry, guid))                        ++count;        } while (result->NextRow());    }    TC_LOG_INFO("server.loading", ">> Spawned %u continent transports in %u ms", count, GetMSTimeDiffToNow(oldMSTime));}

 ReplicaManagerWrapper() :     ComponentRoot(),     guid_(Guid::NewGuid()),     oldConfig_(CreateGenericConfig()),     perfCounters_(),     endpointUniqueId_(guid_, 1),     transport_(CreateTransport(oldConfig_)),     stateProvider_(ComTestStateProvider::GetProvider(1, -1, GetRoot())),     replicaManagerSPtr_() { }

bool BattleGroundIC::SetupBattleGround(){    gunshipHorde = CreateTransport(GO_HORDE_GUNSHIP,TRANSPORT_PERIOD_TIME);    gunshipAlliance = CreateTransport(GO_ALLIANCE_GUNSHIP,TRANSPORT_PERIOD_TIME);    if (!gunshipAlliance || !gunshipHorde)    {        sLog.outError("Isle of Conquest: There was an error creating gunships!");        return false;    }    //Send transport init packet to all player in map    for (BattleGroundPlayerMap::const_iterator itr = GetPlayers().begin(); itr != GetPlayers().end();itr++)    {        if (Player* player = sObjectMgr.GetPlayer(itr->first))            SendTransportInit(player);    }    return true;}

void TransportMgr::CreateInstanceTransports(Map* map){    TransportInstanceMap::const_iterator mapTransports = _instanceTransports.find(map->GetId());    // no transports here    if (mapTransports == _instanceTransports.end() || mapTransports->second.empty())        return;    // create transports    for (std::set<uint32>::const_iterator itr = mapTransports->second.begin(); itr != mapTransports->second.end(); ++itr)        CreateTransport(*itr, 0, map);}

void TransportMgr::SpawnContinentTransports(){    if (_transportTemplates.empty())        return;    uint32 oldMSTime = getMSTime();    QueryResult result = WorldDatabase.Query("SELECT guid, entry FROM transports");    uint32 count = 0;    if (result)    {        do        {            Field* fields = result->Fetch();            uint32 guid = fields[0].GetUInt32();            uint32 entry = fields[1].GetUInt32();            if (TransportTemplate const* tInfo = GetTransportTemplate(entry))                if (!tInfo->inInstance)                    if (CreateTransport(entry, guid))                        ++count;        } while (result->NextRow());    }    sLog->outString(">> Spawned %u continent motion transports in %u ms", count, GetMSTimeDiffToNow(oldMSTime));    // pussywizard: preload grids for continent static transports    oldMSTime = getMSTime();    result = WorldDatabase.Query("SELECT map, position_x, position_y FROM gameobject g JOIN gameobject_template t ON g.id = t.entry WHERE t.type = 11");    count = 0;    if (result)    {        do        {            Field* fields = result->Fetch();            uint32 mapId = fields[0].GetUInt32();            float x = fields[1].GetFloat();            float y = fields[2].GetFloat();            MapEntry const* mapEntry = sMapStore.LookupEntry(mapId);            if (mapEntry && !mapEntry->Instanceable())                if (Map* map = sMapMgr->CreateBaseMap(mapId))                {                    map->LoadGrid(x, y);                    ++count;                }        } while (result->NextRow());    }    sLog->outString(">> Preloaded grids for %u continent static transports in %u ms", count, GetMSTimeDiffToNow(oldMSTime));}

// called on the socket threadnsresultnsHttpConnection::Activate(nsAHttpTransaction *trans, PRUint8 caps){    nsresult rv;    LOG(("nsHttpConnection::Activate [this=%x trans=%x caps=%x]/n",         this, trans, caps));    NS_ENSURE_ARG_POINTER(trans);    NS_ENSURE_TRUE(!mTransaction, NS_ERROR_IN_PROGRESS);    // take ownership of the transaction    mTransaction = trans;    NS_ADDREF(mTransaction);    // set mKeepAlive according to what will be requested    mKeepAliveMask = mKeepAlive = (caps & NS_HTTP_ALLOW_KEEPALIVE);    // if we don't have a socket transport then create a new one    if (!mSocketTransport) {        rv = CreateTransport(caps);        if (NS_FAILED(rv))            goto loser;    }    // need to handle SSL proxy CONNECT if this is the first time.    if (mConnInfo->UsingSSL() && mConnInfo->UsingHttpProxy() && !mCompletedSSLConnect) {        rv = SetupSSLProxyConnect();        if (NS_FAILED(rv))            goto loser;    }    // wait for the output stream to be readable    rv = mSocketOut->AsyncWait(this, 0, 0, nsnull);    if (NS_SUCCEEDED(rv))        return rv;loser:    NS_RELEASE(mTransaction);    return rv;}

nsresultBridge(const PrivateIPDLInterface&,       MessageChannel* aParentChannel, ProcessId aParentPid,       MessageChannel* aChildChannel, ProcessId aChildPid,       ProtocolId aProtocol, ProtocolId aChildProtocol){  if (!aParentPid || !aChildPid) {    return NS_ERROR_INVALID_ARG;  }  TransportDescriptor parentSide, childSide;  nsresult rv;  if (NS_FAILED(rv = CreateTransport(aParentPid, &parentSide, &childSide))) {    return rv;  }  if (!aParentChannel->Send(new ChannelOpened(parentSide,                                              aChildPid,                                              aProtocol,                                              IPC::Message::NESTED_INSIDE_CPOW))) {    CloseDescriptor(parentSide);    CloseDescriptor(childSide);    return NS_ERROR_BRIDGE_OPEN_PARENT;  }  if (!aChildChannel->Send(new ChannelOpened(childSide,                                            aParentPid,                                            aChildProtocol,                                            IPC::Message::NESTED_INSIDE_CPOW))) {    CloseDescriptor(parentSide);    CloseDescriptor(childSide);    return NS_ERROR_BRIDGE_OPEN_CHILD;  }  return NS_OK;}

bool BattlegroundIC::SetupBattleground(){    for (uint8 i = 0; i < MAX_NORMAL_GAMEOBJECTS_SPAWNS; ++i)    {        if (!AddObject(BG_IC_ObjSpawnlocs[i].type, BG_IC_ObjSpawnlocs[i].entry,            BG_IC_ObjSpawnlocs[i].x, BG_IC_ObjSpawnlocs[i].y,            BG_IC_ObjSpawnlocs[i].z, BG_IC_ObjSpawnlocs[i].o,            0, 0, 0, 0, RESPAWN_ONE_DAY))        {            sLog->outError(LOG_FILTER_BATTLEGROUND, "Isle of Conquest: There was an error spawning gameobject %u", BG_IC_ObjSpawnlocs[i].entry);            return false;        }    }    for (uint8 i = 2; i < MAX_NORMAL_NPCS_SPAWNS; ++i)    {        if (!AddCreature(BG_IC_NpcSpawnlocs[i].entry, BG_IC_NpcSpawnlocs[i].type, BG_IC_NpcSpawnlocs[i].team,            BG_IC_NpcSpawnlocs[i].x, BG_IC_NpcSpawnlocs[i].y,            BG_IC_NpcSpawnlocs[i].z, BG_IC_NpcSpawnlocs[i].o,            RESPAWN_ONE_DAY))        {            sLog->outError(LOG_FILTER_BATTLEGROUND, "Isle of Conquest: There was an error spawning creature %u", BG_IC_NpcSpawnlocs[i].entry);            return false;        }    }    if (!AddSpiritGuide(BG_IC_NPC_SPIRIT_GUIDE_1+5, BG_IC_SpiritGuidePos[5][0], BG_IC_SpiritGuidePos[5][1], BG_IC_SpiritGuidePos[5][2], BG_IC_SpiritGuidePos[5][3], ALLIANCE)        || !AddSpiritGuide(BG_IC_NPC_SPIRIT_GUIDE_1+6, BG_IC_SpiritGuidePos[6][0], BG_IC_SpiritGuidePos[6][1], BG_IC_SpiritGuidePos[6][2], BG_IC_SpiritGuidePos[6][3], HORDE)        || !AddSpiritGuide(BG_IC_NPC_SPIRIT_GUIDE_1+3, BG_IC_SpiritGuidePos[7][0], BG_IC_SpiritGuidePos[7][1], BG_IC_SpiritGuidePos[7][2], BG_IC_SpiritGuidePos[7][3], ALLIANCE)        || !AddSpiritGuide(BG_IC_NPC_SPIRIT_GUIDE_1+4, BG_IC_SpiritGuidePos[8][0], BG_IC_SpiritGuidePos[8][1], BG_IC_SpiritGuidePos[8][2], BG_IC_SpiritGuidePos[8][3], HORDE))    {        sLog->outError(LOG_FILTER_BATTLEGROUND, "Isle of Conquest: Failed to spawn initial spirit guide!");        return false;    }    gunshipHorde = CreateTransport(GO_HORDE_GUNSHIP, TRANSPORT_PERIOD_TIME);    gunshipAlliance = CreateTransport(GO_ALLIANCE_GUNSHIP, TRANSPORT_PERIOD_TIME);    if (!gunshipAlliance || !gunshipHorde)    {        sLog->outError(LOG_FILTER_BATTLEGROUND, "Isle of Conquest: There was an error creating gunships!");        return false;    }    //Send transport init packet to all player in map    for (BattlegroundPlayerMap::const_iterator itr = GetPlayers().begin(); itr != GetPlayers().end(); ++itr)    {        if (Player* player = ObjectAccessor::FindPlayer(itr->first))            SendTransportInit(player);    }    // setting correct factions for Keep Cannons    for (uint8 i = BG_IC_NPC_KEEP_CANNON_1; i < BG_IC_NPC_KEEP_CANNON_12; ++i)        GetBGCreature(i)->setFaction(BG_IC_Factions[0]);    for (uint8 i = BG_IC_NPC_KEEP_CANNON_13; i < BG_IC_NPC_KEEP_CANNON_25; ++i)        GetBGCreature(i)->setFaction(BG_IC_Factions[1]);    // correcting spawn time for keeps bombs    for (uint8 i = BG_IC_GO_HUGE_SEAFORIUM_BOMBS_A_1; i < BG_IC_GO_HUGE_SEAFORIUM_BOMBS_H_4; ++i)        GetBGObject(i)->SetRespawnTime(10);    return true;}

bool BattlegroundIC::SetupBattleground(){    for (uint8 i = 0; i < MAX_NORMAL_GAMEOBJECTS_SPAWNS; i++)    {        if (!AddObject(BG_IC_ObjSpawnlocs[i].type, BG_IC_ObjSpawnlocs[i].entry,            BG_IC_ObjSpawnlocs[i].x, BG_IC_ObjSpawnlocs[i].y,            BG_IC_ObjSpawnlocs[i].z, BG_IC_ObjSpawnlocs[i].o,            0, 0, 0, 0, RESPAWN_ONE_DAY))        {            sLog->outError("Isle of Conquest: There was an error spawning gameobject %u", BG_IC_ObjSpawnlocs[i].entry);            return false;        }    }    for (uint8 i = 0; i < MAX_NORMAL_NPCS_SPAWNS; i++)    {        Creature *temp = AddCreature(BG_IC_NpcSpawnlocs[i].entry, BG_IC_NpcSpawnlocs[i].type, BG_IC_NpcSpawnlocs[i].team,                                     BG_IC_NpcSpawnlocs[i].x, BG_IC_NpcSpawnlocs[i].y, BG_IC_NpcSpawnlocs[i].z, BG_IC_NpcSpawnlocs[i].o,                                      RESPAWN_ONE_DAY);        if (!temp)        {            sLog->outError("Isle of Conquest: There was an error spawning creature %u", BG_IC_NpcSpawnlocs[i].entry);            return false;        }        if (temp->GetEntry() == NPC_OVERLORD_AGMAR || temp->GetEntry() == NPC_HIGH_COMMANDER_HALFORD_WYRMBANE)            temp->SetFlag(UNIT_FIELD_FLAGS, UNIT_FLAG_NON_ATTACKABLE);    }    if (!AddSpiritGuide(BG_IC_NPC_SPIRIT_GUIDE_1+5, BG_IC_SpiritGuidePos[5][0], BG_IC_SpiritGuidePos[5][1], BG_IC_SpiritGuidePos[5][2], BG_IC_SpiritGuidePos[5][3], ALLIANCE)        || !AddSpiritGuide(BG_IC_NPC_SPIRIT_GUIDE_1+6, BG_IC_SpiritGuidePos[6][0], BG_IC_SpiritGuidePos[6][1], BG_IC_SpiritGuidePos[6][2], BG_IC_SpiritGuidePos[6][3], HORDE)        || !AddSpiritGuide(BG_IC_NPC_SPIRIT_GUIDE_1+3, BG_IC_SpiritGuidePos[7][0], BG_IC_SpiritGuidePos[7][1], BG_IC_SpiritGuidePos[7][2], BG_IC_SpiritGuidePos[7][3], ALLIANCE)        || !AddSpiritGuide(BG_IC_NPC_SPIRIT_GUIDE_1+4, BG_IC_SpiritGuidePos[8][0], BG_IC_SpiritGuidePos[8][1], BG_IC_SpiritGuidePos[8][2], BG_IC_SpiritGuidePos[8][3], HORDE))    {        sLog->outError("Isle of Conquest: Failed to spawn initial spirit guide!");        return false;    }    gunshipHorde = CreateTransport(GO_HORDE_GUNSHIP, TRANSPORT_PERIOD_TIME);    gunshipAlliance = CreateTransport(GO_ALLIANCE_GUNSHIP, TRANSPORT_PERIOD_TIME);    if (!gunshipAlliance || !gunshipHorde)    {        sLog->outError("Isle of Conquest: There was an error creating gunships!");        return false;    }    //Send transport init packet to all player in map    for (BattlegroundPlayerMap::const_iterator itr = GetPlayers().begin(); itr != GetPlayers().end();itr++)    {        if (Player* player = sObjectMgr->GetPlayer(itr->first))            SendTransportInit(player);    }    // setting correct factions for Keep Cannons    for (uint8 i = BG_IC_NPC_KEEP_CANNON_1; i < BG_IC_NPC_KEEP_CANNON_12; i++)        GetBGCreature(i)->setFaction(BG_IC_Factions[0]);    for (uint8 i = BG_IC_NPC_KEEP_CANNON_13; i < BG_IC_NPC_KEEP_CANNON_25; i++)        GetBGCreature(i)->setFaction(BG_IC_Factions[1]);    // correcting spawn time for keeps bombs    for (uint8 i = BG_IC_GO_HUGE_SEAFORIUM_BOMBS_A_1; i < BG_IC_GO_HUGE_SEAFORIUM_BOMBS_H_4; i++)        GetBGObject(i)->SetRespawnTime(10);    return true;}