123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750 |
- #include "Game.h"
- #include "Zeit.h"
- #include "Player.h"
- #include "OverworldDimension.h"
- #include "NoBlock.h"
- #include "AsynchronCall.h"
- #include "Entity.h"
- #include "AddEntityUpdate.h"
- #include "EntityRemovedUpdate.h"
- #include "NetworkMessage.h"
- using namespace Framework;
- GameClient::GameClient(Player* zPlayer, FCKlient* client)
- : Thread(),
- zPlayer(zPlayer),
- client(client),
- viewDistance(DEFAULT_VIEW_DISTANCE),
- first(1),
- online(1),
- finished(0),
- backgroundFinished(0),
- foregroundFinished(0)
- {
- new AsynchronCall("Game Client Updates", [this]()
- {
- while (online)
- {
- other.lock();
- if (updateQueue.hat(0))
- {
- WorldUpdate* update = updateQueue.get(0);
- updateQueue.remove(0);
- other.unlock();
- background.lock();
- this->client->zBackgroundWriter()->schreibe((char*)&Message::WORLD_UPDATE, 1);
- update->writeAndCheck(this->client->zBackgroundWriter());
- background.unlock();
- update->release();
- }
- else
- {
- other.unlock();
- updateSync.wait();
- }
- }
- finished = 1;
- });
- start();
- }
- GameClient::~GameClient()
- {
- online = 0;
- updateSync.notify();
- emptyForegroundQueueSync.notifyAll();
- emptyBackgroundQueueSync.notifyAll();
- foregroundQueueSync.notify();
- backgroundQueueSync.notify();
- while (!finished || !foregroundFinished || !backgroundFinished)
- Sleep(100);
- client->release();
- }
- void GameClient::thread()
- {
- new AsynchronCall("Game Client Background", [this]()
- {
- while (online)
- {
- queueCs.lock();
- if (backgroundQueue.hat(0))
- {
- NetworkMessage* message = backgroundQueue.get(0);
- backgroundQueue.remove(0);
- queueCs.unlock();
- background.lock();
- message->writeTo(client->zBackgroundWriter());
- background.unlock();
- message->release();
- }
- else
- {
- queueCs.unlock();
- emptyBackgroundQueueSync.notifyAll();
- backgroundQueueSync.wait();
- }
- }
- backgroundFinished = 1;
- });
- while (online)
- {
- queueCs.lock();
- if (foregroundQueue.hat(0))
- {
- NetworkMessage* message = foregroundQueue.get(0);
- foregroundQueue.remove(0);
- queueCs.unlock();
- foreground.lock();
- message->writeTo(client->zForegroundWriter());
- foreground.unlock();
- message->release();
- }
- else
- {
- queueCs.unlock();
- emptyForegroundQueueSync.notifyAll();
- foregroundQueueSync.wait();
- }
- }
- foregroundFinished = 1;
- }
- void GameClient::sendWorldUpdate(WorldUpdate* update)
- {
- bool add = 0;
- if (zPlayer->getCurrentDimensionId() == update->getAffectedDimension())
- {
- auto pos = (Vec3<int>)zPlayer->getPosition();
- int dist = update->distanceTo(pos.x, pos.y);
- if (dist < viewDistance * CHUNK_SIZE)
- {
- other.lock();
- int index = 0;
- for (auto update2 : updateQueue)
- {
- int dist2 = update2->distanceTo(pos.x, pos.y);
- if (dist2 > dist)
- break;
- index++;
- }
- updateQueue.add(update, index);
- other.unlock();
- updateSync.notify();
- add = 1;
- }
- }
- if (!add)
- update->release();
- }
- void GameClient::reply()
- {
- other.lock();
- for (auto req : requests)
- Game::INSTANCE->api(req, this);
- requests.leeren();
- other.unlock();
- if (first)
- {
- foreground.lock();
- int id = zPlayer->getId();
- client->zForegroundWriter()->schreibe((char*)&Message::POSITION_UPDATE, 1);
- client->zForegroundWriter()->schreibe((char*)&id, 4);
- foreground.unlock();
- first = 0;
- }
- }
- void GameClient::logout()
- {
- online = 0;
- }
- void GameClient::addMessage(StreamReader* reader)
- {
- short len = 0;
- reader->lese((char*)&len, 2);
- InMemoryBuffer* buffer = new InMemoryBuffer();
- char* tmp = new char[len];
- reader->lese(tmp, len);
- buffer->schreibe(tmp, len);
- delete[]tmp;
- other.lock();
- requests.add(buffer);
- other.unlock();
- }
- bool GameClient::isOnline() const
- {
- return online;
- }
- void GameClient::sendResponse(NetworkMessage* response)
- {
- queueCs.lock();
- if (response->isUseBackground())
- {
- if (backgroundQueue.getEintragAnzahl() > 20)
- {
- queueCs.unlock();
- emptyBackgroundQueueSync.wait();
- queueCs.lock();
- }
- backgroundQueue.add(response);
- queueCs.unlock();
- backgroundQueueSync.notify();
- }
- else
- {
- if (foregroundQueue.getEintragAnzahl() > 100)
- {
- queueCs.unlock();
- std::cout << "WARNING: Game paused because nework connection to " << zPlayer->getName() << " is to slow.\n";
- ZeitMesser m;
- m.messungStart();
- emptyForegroundQueueSync.wait();
- m.messungEnde();
- std::cout << "WARNING: Game resumed after " << m.getSekunden() << " seconds.\n";
- queueCs.lock();
- }
- foregroundQueue.add(response);
- queueCs.unlock();
- foregroundQueueSync.notify();
- }
- }
- Player* GameClient::zEntity() const
- {
- return zPlayer;
- }
- void GameClient::sendTypes()
- {
- foreground.lock();
- int count = StaticRegistry<BlockType>::INSTANCE.getCount();
- client->zForegroundWriter()->schreibe((char*)&count, 4);
- for (int i = 0; i < count; i++)
- {
- BlockType* t = StaticRegistry<BlockType>::INSTANCE.zElement(i);
- int id = t->getId();
- client->zForegroundWriter()->schreibe((char*)&id, 4);
- bool inst = t->doesNeedClientInstance();
- client->zForegroundWriter()->schreibe((char*)&inst, 1);
- int maxHp = t->getInitialMaxHP();
- client->zForegroundWriter()->schreibe((char*)&maxHp, 4);
- t->getModel().writeTo(client->zForegroundWriter());
- }
- count = StaticRegistry<ItemType>::INSTANCE.getCount();
- client->zForegroundWriter()->schreibe((char*)&count, 4);
- for (int i = 0; i < count; i++)
- {
- ItemType* t = StaticRegistry<ItemType>::INSTANCE.zElement(i);
- int id = t->getId();
- client->zForegroundWriter()->schreibe((char*)&id, 4);
- t->getModel().writeTo(client->zForegroundWriter());
- }
- count = StaticRegistry<EntityType>::INSTANCE.getCount();
- client->zForegroundWriter()->schreibe((char*)&count, 4);
- for (int i = 0; i < count; i++)
- {
- EntityType* t = StaticRegistry<EntityType>::INSTANCE.zElement(i);
- int id = t->getId();
- client->zForegroundWriter()->schreibe((char*)&id, 4);
- t->getModel().writeTo(client->zForegroundWriter());
- }
- foreground.unlock();
- }
- Game::Game(Framework::Text name, Framework::Text worldsDir)
- : Thread(),
- name(name),
- dimensions(new RCArray<Dimension>()),
- updates(new RCArray<WorldUpdate>()),
- clients(new RCArray<GameClient>()),
- ticker(new TickOrganizer()),
- path((const char*)(worldsDir + "/" + name)),
- stop(0),
- tickId(0),
- nextEntityId(0),
- generator(0),
- loader(0),
- totalTickTime(0),
- tickCounter(0)
- {
- if (!DateiExistiert(worldsDir + "/" + name))
- DateiPfadErstellen(worldsDir + "/" + name + "/");
- Datei d;
- d.setDatei(path + "/eid");
- if (d.existiert())
- {
- d.open(Datei::Style::lesen);
- d.lese((char*)&nextEntityId, 4);
- d.close();
- }
- start();
- }
- Game::~Game()
- {
- dimensions->release();
- updates->release();
- clients->release();
- generator->release();
- loader->release();
- }
- void Game::initialize()
- {
- int seed = 0;
- int index = 0;
- for (char* n = name; *n; n++)
- seed += (int)pow((float)*n * 31, (float)++index);
- generator = new WorldGenerator(seed);
- loader = new WorldLoader();
- recipies.loadRecipies("data/recipies");
- }
- void Game::thread()
- {
- ZeitMesser waitForLock;
- ZeitMesser removeOldClients;
- ZeitMesser tickEntities;
- ZeitMesser worldUpdates;
- ZeitMesser clientReply;
- ZeitMesser removeOldChunks;
- ZeitMesser m;
- while (!stop)
- {
- m.messungStart();
- ticker->nextTick();
- Array<int> removed;
- double waitTotal = 0;
- waitForLock.messungStart();
- cs.lock();
- waitForLock.messungEnde();
- waitTotal += waitForLock.getSekunden();
- removeOldClients.messungStart();
- int index = 0;
- for (auto player : *clients)
- {
- if (!player->isOnline())
- {
- std::cout << "player " << player->zEntity()->getName() << " disconnected.\n";
- Datei pFile;
- pFile.setDatei(path + "/player/" + player->zEntity()->getName());
- pFile.erstellen();
- if (pFile.open(Datei::Style::schreiben))
- PlayerEntityType::INSTANCE->saveEntity(player->zEntity(), &pFile);
- pFile.close();
- removed.add(index, 0);
- Dimension* dim = zDimension(player->zEntity()->getCurrentDimensionId());
- dim->removeSubscriptions(player->zEntity());
- this->requestWorldUpdate(new EntityRemovedUpdate(player->zEntity()->getId(), player->zEntity()->getCurrentDimensionId(), player->zEntity()->getPosition()));
- }
- index++;
- }
- for (auto i : removed)
- clients->remove(i);
- removeOldClients.messungEnde();
- cs.unlock();
- tickEntities.messungStart();
- for (auto dim : *dimensions)
- dim->tickEntities();
- tickEntities.messungEnde();
- waitForLock.messungStart();
- cs.lock();
- waitForLock.messungEnde();
- waitTotal += waitForLock.getSekunden();
- worldUpdates.messungStart();
- while (updates->hat(0))
- {
- WorldUpdate* update = updates->z(0);
- for (auto client : *clients)
- client->sendWorldUpdate(dynamic_cast<WorldUpdate*>(update->getThis()));
- if (!zDimension(update->getAffectedDimension()))
- addDimension(new Dimension(update->getAffectedDimension()));
- update->onUpdate(zDimension(update->getAffectedDimension()));
- updates->remove(0);
- }
- worldUpdates.messungEnde();
- cs.unlock();
- clientReply.messungStart();
- for (auto client : *clients)
- client->reply();
- clientReply.messungEnde();
- waitForLock.messungStart();
- cs.lock();
- waitForLock.messungEnde();
- waitTotal += waitForLock.getSekunden();
- removeOldChunks.messungStart();
- for (auto dim : *dimensions)
- dim->removeOldChunks();
- removeOldChunks.messungEnde();
- cs.unlock();
- m.messungEnde();
- double sec = m.getSekunden();
- tickCounter++;
- totalTickTime += sec;
- if (tickCounter >= 1000)
- {
- std::cout << "Average Tick time: " << (totalTickTime / 1000) << "\n";
- if ((totalTickTime / 1000) * 20 > 1)
- {
- std::cout << "The game runns slower than normal.\n";
- }
- else
- {
- std::cout << "No performance issues detected.\n";
- }
- totalTickTime = 0;
- tickCounter = 0;
- }
- if (sec < 0.05)
- Sleep((int)((0.05 - sec) * 1000));
- else if (sec > 1)
- {
- std::cout << "WARNING: tick needed " << sec << " seconds. The game will run sower then normal.\n";
- std::cout << "waiting: " << waitTotal << "\nremoveOldClients: " << removeOldClients.getSekunden() << "\ntickEntities:" << tickEntities.getSekunden() << "\nworldUpdates: " << worldUpdates.getSekunden() << "\nclientReply: " << clientReply.getSekunden() << "\nremoveOldChunks:" << removeOldChunks.getSekunden() << "\n";
- }
- }
- save();
- }
- void Game::api(Framework::InMemoryBuffer* zRequest, GameClient* zOrigin)
- {
- char type;
- zRequest->lese(&type, 1);
- NetworkMessage* response = new NetworkMessage();
- switch (type)
- {
- case 1: // world
- {
- Dimension* dim = zDimension(zOrigin->zEntity()->getCurrentDimensionId());
- if (!dim)
- {
- dim = new Dimension(zOrigin->zEntity()->getCurrentDimensionId());
- addDimension(dim);
- }
- dim->api(zRequest, response, zOrigin->zEntity());
- break;
- }
- case 2: // player
- zOrigin->zEntity()->playerApi(zRequest, response);
- break;
- case 3: // entity
- {
- int id;
- zRequest->lese((char*)&id, 4);
- for (Dimension* dim : *dimensions)
- {
- Entity* entity = dim->zEntity(id);
- if (entity)
- {
- entity->api(zRequest, response);
- break;
- }
- }
- break;
- }
- case 4:
- { // inventory
- bool isEntity;
- zRequest->lese((char*)&isEntity, 1);
- Inventory* target;
- if (isEntity)
- {
- int id;
- zRequest->lese((char*)&id, 4);
- target = zEntity(id);
- }
- else
- {
- int dim;
- Vec3<int> pos;
- zRequest->lese((char*)&dim, 4);
- zRequest->lese((char*)&pos.x, 4);
- zRequest->lese((char*)&pos.y, 4);
- zRequest->lese((char*)&pos.z, 4);
- target = zBlockAt(pos, dim);
- }
- if (target)
- target->inventoryApi(zRequest, response, zOrigin->zEntity());
- break;
- }
- default:
- std::cout << "received unknown api request in game with type " << (int)type << "\n";
- }
- if (!response->isEmpty())
- {
- if (response->isBroadcast())
- broadcastMessage(response);
- else
- zOrigin->sendResponse(response);
- }
- else
- {
- response->release();
- }
- }
- void Game::updateLightning(int dimensionId, Vec3<int> location)
- {
- Dimension* zDim = zDimension(dimensionId);
- if (zDim)
- zDim->updateLightning(location);
- }
- void Game::updateLightningWithoutWait(int dimensionId, Vec3<int> location)
- {
- Dimension* zDim = zDimension(dimensionId);
- if (zDim)
- zDim->updateLightningWithoutWait(location);
- }
- void Game::broadcastMessage(NetworkMessage* response)
- {
- for (auto client : *clients)
- client->sendResponse(dynamic_cast<NetworkMessage*>(response->getThis()));
- }
- void Game::sendMessage(NetworkMessage* response, Entity* zTargetPlayer)
- {
- for (auto client : *clients)
- {
- if (client->zEntity()->getId() == zTargetPlayer->getId())
- {
- client->sendResponse(response);
- return;
- }
- }
- response->release();
- }
- bool Game::requestWorldUpdate(WorldUpdate* update)
- {
- cs.lock();
- for (WorldUpdate* u : *updates)
- {
- if (u->getMaxAffectedPoint().x >= update->getMinAffectedPoint().x && u->getMinAffectedPoint().x <= update->getMaxAffectedPoint().x &&
- u->getMaxAffectedPoint().y >= update->getMinAffectedPoint().y && u->getMinAffectedPoint().y <= update->getMaxAffectedPoint().y &&
- u->getMaxAffectedPoint().z >= update->getMinAffectedPoint().z && u->getMinAffectedPoint().z <= update->getMaxAffectedPoint().z && u->getType() == update->getType())
- {
- cs.unlock();
- update->release();
- return 0;
- }
- }
- updates->add(update);
- cs.unlock();
- return 1;
- }
- GameClient* Game::addPlayer(FCKlient* client, Framework::Text name)
- {
- cs.lock();
- Datei pFile;
- pFile.setDatei(path + "/player/" + name);
- std::cout << "player " << name.getText() << " connected.\n";
- Player* player;
- bool isNew = 0;
- if (!pFile.existiert() || !pFile.open(Datei::Style::lesen))
- {
- player = (Player*)PlayerEntityType::INSTANCE->createEntityAt(Vec3<float>(0.5, 0.5, 0), OverworldDimension::ID);
- player->setName(name);
- isNew = 1;
- }
- else
- {
- player = (Player*)PlayerEntityType::INSTANCE->loadEntity(&pFile);
- pFile.close();
- }
- if (player->getId() >= nextEntityId)
- {
- nextEntityId = player->getId() + 1;
- }
- GameClient* gameClient = new GameClient(player, client);
- gameClient->sendTypes();
- clients->add(gameClient);
- if (!zDimension(player->getCurrentDimensionId()))
- {
- this->addDimension(new Dimension(player->getCurrentDimensionId()));
- }
- // subscribe the new player as an observer of the new chunk
- Dimension* dim = zDimension(player->getCurrentDimensionId());
- InMemoryBuffer* buffer = new InMemoryBuffer();
- buffer->schreibe("\0", 1);
- Punkt center = getChunkCenter((int)player->getPosition().x, (int)player->getPosition().y);
- buffer->schreibe((char*)¢er.x, 4);
- buffer->schreibe((char*)¢er.y, 4);
- buffer->schreibe("\0", 1);
- dim->api(buffer, 0, player);
- buffer->release();
- while (isNew && !dim->zChunk(getChunkCenter((int)player->getPosition().x, (int)player->getPosition().y)))
- {
- cs.unlock();
- Sleep(1000);
- cs.lock();
- }
- if (isNew)
- {
- Either<Block*, int> b = AirBlockBlockType::ID;
- int h = WORLD_HEIGHT;
- while (((b.isA() && (!(Block*)b || ((Block*)b)->isPassable())) || (b.isB() && StaticRegistry<BlockType>::INSTANCE.zElement(b)->zDefault()->isPassable())) && h > 0)
- b = zBlockAt({ (int)player->getPosition().x, (int)player->getPosition().y, --h }, player->getCurrentDimensionId());
- player->setPosition({ player->getPosition().x, player->getPosition().y, (float)h + 1.f });
- }
- requestWorldUpdate(new AddEntityUpdate(player, player->getCurrentDimensionId()));
- cs.unlock();
- return dynamic_cast<GameClient*>(gameClient->getThis());
- }
- bool Game::isChunkLoaded(int x, int y, int dimension) const
- {
- Dimension* dim = zDimension(dimension);
- return (dim && dim->hasChunck(x, y));
- }
- bool Game::doesChunkExist(int x, int y, int dimension)
- {
- cs.lock();
- bool result = isChunkLoaded(x, y, dimension) || loader->existsChunk(x, y, dimension);
- cs.unlock();
- return result;
- }
- Framework::Either<Block*, int> Game::zBlockAt(Framework::Vec3<int> location, int dimension) const
- {
- Dimension* dim = zDimension(dimension);
- if (dim)
- return dim->zBlock(location);
- return 0;
- }
- Block* Game::zRealBlockInstance(Framework::Vec3<int> location, int dimension)
- {
- Dimension* dim = zDimension(dimension);
- if (dim)
- return dim->zRealBlockInstance(location);
- return 0;
- }
- Dimension* Game::zDimension(int id) const
- {
- for (auto dim : *dimensions)
- {
- if (dim->getDimensionId() == id)
- return dim;
- }
- return 0;
- }
- Framework::Punkt Game::getChunkCenter(int x, int y)
- {
- return Punkt(((x < 0 ? x + 1 : x) / CHUNK_SIZE) * CHUNK_SIZE + (x < 0 ? -CHUNK_SIZE : CHUNK_SIZE) / 2, ((y < 0 ? y + 1 : y) / CHUNK_SIZE) * CHUNK_SIZE + (y < 0 ? -CHUNK_SIZE : CHUNK_SIZE) / 2);
- }
- Area Game::getChunckArea(Punkt center) const
- {
- return { center.x - CHUNK_SIZE / 2, center.y - CHUNK_SIZE / 2, center.x + CHUNK_SIZE / 2 - 1, center.y + CHUNK_SIZE / 2 - 1, 0 };
- }
- Framework::Text Game::getWorldDirectory() const
- {
- return path;
- }
- void Game::requestArea(Area area)
- {
- generator->requestGeneration(area);
- loader->requestLoading(area);
- }
- void Game::save() const
- {
- Datei d;
- d.setDatei(path + "/eid");
- d.open(Datei::Style::schreiben);
- d.schreibe((char*)&nextEntityId, 4);
- d.close();
- for (auto dim : *dimensions)
- dim->save(path);
- }
- void Game::requestStop()
- {
- stop = 1;
- warteAufThread(1000000);
- }
- void Game::addDimension(Dimension* d)
- {
- dimensions->add(d);
- }
- int Game::getNextEntityId()
- {
- cs.lock();
- int result = nextEntityId++;
- cs.unlock();
- return result;
- }
- WorldGenerator* Game::zGenerator() const
- {
- return generator;
- }
- Game* Game::INSTANCE = 0;
- void Game::initialize(Framework::Text name, Framework::Text worldsDir)
- {
- if (!Game::INSTANCE)
- {
- Game::INSTANCE = new Game(name, worldsDir);
- Game::INSTANCE->initialize();
- }
- }
- Entity* Game::zEntity(int id, int dimensionId) const
- {
- Dimension* d = zDimension(dimensionId);
- if (d)
- return d->zEntity(id);
- return 0;
- }
- Entity* Game::zEntity(int id) const
- {
- for (Dimension* d : *dimensions)
- {
- Entity* e = d->zEntity(id);
- if (e)
- return e;
- }
- // for new players that are currently loading
- for (GameClient* client : *clients)
- {
- if (client->zEntity()->getId() == id)
- {
- return client->zEntity();
- }
- }
- return 0;
- }
- Entity* Game::zNearestEntity(int dimensionId, Framework::Vec3<float> pos, std::function<bool(Entity*)> filter)
- {
- Dimension* d = zDimension(dimensionId);
- if (!d)
- return 0;
- return d->zNearestEntity(pos, filter);
- }
- const RecipieLoader& Game::getRecipies() const
- {
- return recipies;
- }
|