1

#include "NetworkServer.hh"

     2

     3

#include <iostream>

     4

     5

NetworkServer::NetworkServer (GameState &state, const CL_IPAddress &listen_ip) : NetworkBase(), state(state) {

     6

	socket.bind(listen_ip);

     7

	socket.listen(NETWORK_SERVER_BACKLOG);

     8

     9

	// add socket to listener

    10

	listener.add_trigger(socket.get_read_trigger());

    11

    12

	// bind slot for recv

    13

	slot_on_recv = socket.sig_read_triggered.connect(this, &NetworkServer::_onRecv);

    14

}

    15

    16

static NetworkServer *NetworkServer::newServer (void) {

    17

	GameState *state = new GameState(/* XXX */);

    18

	CL_IPAddress listen_ip(NETWORK_PORT_STR);

    19

    20

	return new NetworkServer(state, listen_ip);

    21

}		

    22

    23

void run (void) {

    24

	bool isRunning = true;

    25

    26

	while (isRunning) {

    27

		/* XXX: all I need to do? */

    28

		listener.wait();

    29

		listener.reset_all();

    30

	}

    31

}

    32

    33

void NetworkServer::_onRecv (void) {

    34

	char buf[NETWORK_PACKET_MAX];

    35

	CL_Socket src;

    36

	int ret;

    37

    38

	ret = socket.recv(buf, NETWORK_PACKET_MAX, src);

    39

    40

	std::cout << src.get_address() << ":" << src.get_port() << " <- " << std::string(buf, NETWORK_PACKET_MAX) << std::endl;

    41

}

    42

    43

NetworkServerClient::NetworkServerClient (NetworkServer &server) : server(server) {

    44

    45

}

    46

    47

void NetworkServerClient::_onRecv (void) {

    48

    49

}

    50

    51

void runNetworkServer (void) {

    52

	NetworkServer *server = NULL;

    53

    54

	server = NetworkServer::newServer();

    55

	server->run();

    56

}

    57

    58

int main (int argc, char **argv) {

    59

	runNetworkServer();

    60

    61

	return 0;

    62

}

    63