diff options
author | Jared Adams <jaxad0127@gmail.com> | 2009-03-23 11:14:00 -0600 |
---|---|---|
committer | Jared Adams <jaxad0127@gmail.com> | 2009-03-23 11:14:00 -0600 |
commit | eee4c9a1e2a9fc58ccb8ad05acfe0b0e41ec3fab (patch) | |
tree | e6a09e53f092b94614ea66d92af27c684772cd42 /src/net/tmwserv/connection.cpp | |
parent | 1850cca2e8ba43b1e70385d848dca9f3a91fef4a (diff) | |
download | mana-client-eee4c9a1e2a9fc58ccb8ad05acfe0b0e41ec3fab.tar.gz mana-client-eee4c9a1e2a9fc58ccb8ad05acfe0b0e41ec3fab.tar.bz2 mana-client-eee4c9a1e2a9fc58ccb8ad05acfe0b0e41ec3fab.tar.xz mana-client-eee4c9a1e2a9fc58ccb8ad05acfe0b0e41ec3fab.zip |
Move all TMWServ-specific code to net/tmwserv
Also fix several instances where the same net handler was being used for
both servers, and a few other related oddities.
Diffstat (limited to 'src/net/tmwserv/connection.cpp')
-rw-r--r-- | src/net/tmwserv/connection.cpp | 103 |
1 files changed, 103 insertions, 0 deletions
diff --git a/src/net/tmwserv/connection.cpp b/src/net/tmwserv/connection.cpp new file mode 100644 index 00000000..5e61ba61 --- /dev/null +++ b/src/net/tmwserv/connection.cpp @@ -0,0 +1,103 @@ +/* + * The Mana World + * Copyright 2004 The Mana World Development Team + * + * This file is part of The Mana World. + * + * The Mana World is free software; you can redistribute it and/or modify + * it under the terms of the GNU General Public License as published by + * the Free Software Foundation; either version 2 of the License, or + * any later version. + * + * The Mana World is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Public License for more details. + * + * You should have received a copy of the GNU General Public License + * along with The Mana World; if not, write to the Free Software + * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA + */ + +#include "connection.h" + +#include <string> + +#include "internal.h" +#include "../messageout.h" + +#include "../../log.h" + +Net::Connection::Connection(ENetHost *client): + mConnection(0), mClient(client) +{ + Net::connections++; +} + +Net::Connection::~Connection() +{ + Net::connections--; +} + +bool Net::Connection::connect(const std::string &address, short port) +{ + logger->log("Net::Connection::connect(%s, %i)", address.c_str(), port); + + if (address.empty()) + { + logger->log("Net::Connection::connect() got empty address!"); + mState = NET_ERROR; + return false; + } + + ENetAddress enetAddress; + + enet_address_set_host(&enetAddress, address.c_str()); + enetAddress.port = port; + + // Initiate the connection, allocating channel 0. + mConnection = enet_host_connect(mClient, &enetAddress, 1); + + if (!mConnection) + { + logger->log("Unable to initiate connection to the server."); + mState = NET_ERROR; + return false; + } + + return true; +} + +void Net::Connection::disconnect() +{ + if (!mConnection) + return; + + enet_peer_disconnect(mConnection, 0); + enet_host_flush(mClient); + enet_peer_reset(mConnection); + + mConnection = 0; +} + +bool Net::Connection::isConnected() +{ + return bool (mConnection) ? + (mConnection->state == ENET_PEER_STATE_CONNECTED) : false; +} + +void Net::Connection::send(const MessageOut &msg) +{ + if (!isConnected()) + { + logger->log("Warning: cannot send message to not connected server!"); + return; + } + + //logger->log("Sending message of size %d...", msg.getDataSize()); + + ENetPacket *packet = enet_packet_create(msg.getData(), + msg.getDataSize(), + ENET_PACKET_FLAG_RELIABLE); + enet_peer_send(mConnection, 0, packet); +} |