abignumscalc/server.cpp at master · jojaquix/abignumscalc · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
#include <iostream>
#include <cstdio>
#include <boost/asio.hpp>
#include <atomic>
#include <thread>
#include <functional>
#include <memory>
#include "server.h"


using namespace std;
using namespace std::placeholders;
using namespace boost::asio;
using namespace boost::asio::ip;
using namespace alert::bignums;


Server::Server(io_service& ioService, int port) :
	ioService(ioService),
	acceptor(ioService, tcp::endpoint(tcp::v4(), port))
{}


//sync server
void Server::run()
{
	while (!mExit)
	{
		socket_ptr sock(new tcp::socket(ioService));
		acceptor.accept(*sock);
		thread(bind(&Server::onClientSession, this, sock));
	}
}


void Server::exit(bool e)
{
	mExit = e;
}


void Server::start_accept()
{
	socket_ptr sock(new ip::tcp::socket(ioService));
	acceptor.async_accept(*sock, bind(&Server::on_accept, this, sock, _1));
}

void Server::on_accept(socket_ptr sock, const boost::system::error_code & err)
{
	if (err)
	{
		//todo: log error
		return;
	}

	onClientSession(sock);

	start_accept();
}


void Server::onClientSession(socket_ptr sock)
{
	std::vector<uint1024_t> nums;
	boost::system::error_code err;
	size_t len;
	uint16_t size;
	uint1024_t myNum;

	len = sock->read_some(buffer(&size, sizeof(size)), err);
	std::cout << "Size of vector: " << size << std::endl;

	for (int i = 0; i < size; ++i)
	{
		len = sock->read_some(buffer(&myNum, sizeof(myNum)), err);
		std::cout << "Val : " << myNum << std::endl;
		nums.push_back(myNum);
	}

	auto sorted = Operations::sort(nums);
	auto sum = Operations::sum(nums);
	write(*sock, buffer(&sum, sizeof(sum)), err);

	for (int i = 0; i < size; ++i)
	{
		write(*sock, buffer(&sorted.at(i), sizeof(uint1024_t)), err);
	}


}