aerie.cpp

   1 // aerie.cpp : Defines the entry point for the console application.
   2 //
   3
   4 #include "stdafx.h"
   5 #include "definitions.h"
   6 #include "helpers.h"
   7
   8 #ifdef __WIN32__
   9 /**
  10  * windows version
  11  *
  12  * \todo obs�uga b��d�w!
  13  */
  14 SOCKET win_start_server(int port)
  15 {
  16         WORD ver;
  17         WSADATA data;
  18         SOCKET s;
  19         sockaddr_in addr;
  20
  21
  22         ver = MAKEWORD(2,0);
  23         if (WSAStartup(ver,NULL) != 0)
  24         {
  25                 s = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
  26
  27                 memset(&addr, 0, sizeof(addr));
  28                 addr.sin_family = AF_INET;
  29                 addr.sin_port = htons(port);
  30                 addr.sin_addr.s_addr = htonl(INADDR_ANY);
  31
  32                 int foo = 1;
  33                 setsockopt(s, SOL_SOCKET, SO_REUSEADDR, (char*)&foo, sizeof(foo));
  34
  35                 bind(s, (sockaddr*)&addr, sizeof(addr));
  36
  37                 listen(s, CONF_TCP_QUEUE_SIZE);
  38
  39                 return s;
  40         }
  41
  42         return 0;
  43 }
  44 #endif // __WIN32__
  45
  46 /**
  47  * start server on linux
  48  */
  49 SOCKET lin_server_start(int port)
  50 {
  51         SOCKET s;
  52         sockaddr_in addr;
  53
  54         s = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
  55
  56         memset(&addr, 0, sizeof(addr));
  57         addr.sin_family = AF_INET;
  58         addr.sin_port = htons(port);
  59         addr.sin_addr.s_addr = htonl(INADDR_ANY);
  60
  61         int foo = 1;
  62         setsockopt(s, SOL_SOCKET, SO_REUSEADDR, (char*)&foo, sizeof(foo));
  63
  64         bind(s, (sockaddr*)&addr, sizeof(addr));
  65
  66         listen(s, CONF_TCP_QUEUE_SIZE);
  67
  68         return s;
  69 }
  70
  71 int main(int argc, char* argv[])
  72 {
  73         lin_server_start(2206);
  74         std::string s;
  75         s = "test123_!@#$%^&*()_+ za���";
  76         printf("[%s]\n", s.c_str());
  77         s = urlencode(string(s));
  78         printf("[%s]\n", s.c_str());
  79         s = urldecode(s);
  80         printf("[%s]\n", s.c_str());
  81         return 0;
  82 }
  83
  84
  85 /*
  86
  87 MAIN_LOOP:
  88 server_loop -> open_socket -> socket_reader
  89
  90 socket_reader -> request_factory -> request
  91
  92 request -> queue(read data for request - type of task)
  93
  94
  95 WORKER:
  96 queue -> get needed data -> queue(send)
  97
  98
  99 [task] : property of request(?)
 100 class task {
 101         bool run() - TRUE task is finished, FALSE needs to remain in queue
 102 }
 103
 104 class getFileTask : public task {
 105         bool run() {}
 106         char* getData()
 107 }
 108
 109 -- [code] ------------------------------------------------------------------------------
 110 :: obsluga kolejki zadan od zadan
 111
 112 queue< pair<request,task> > tasks_queue;
 113 while !empty(task_queue)
 114         pair = front(tasks_queue)
 115         if (pair.task.run())
 116                 requests_queue.add(pair.request)
 117         else
 118                 tasks_queue.add(pair);
 119 -- [/code] -----------------------------------------------------------------------------
 120
 121
 122 -- [code] ------------------------------------------------------------------------------
 123 :: obsluga czytania socketow
 124
 125 if (some_socket_need_to_be_read)
 126         socket = find_socket_to_read()
 127         reader = get_socket_reader(socket)
 128         reader.read()
 129 -- [/code] -----------------------------------------------------------------------------
 130
 131
 132 */