aboutsummaryrefslogtreecommitdiff
path: root/src/tests/serverticks.cpp
diff options
context:
space:
mode:
authorMike Buland <eichlan@xagasoft.com>2009-01-11 23:07:44 +0000
committerMike Buland <eichlan@xagasoft.com>2009-01-11 23:07:44 +0000
commit1291252a7b1317ad2dc13fbeb15f6e9d2d92192c (patch)
tree5eb88c7cef5417c043b03b34a77334c57286e526 /src/tests/serverticks.cpp
parent595afe519791894c77c77a949fba7732f4d94872 (diff)
downloadlibbu++-1291252a7b1317ad2dc13fbeb15f6e9d2d92192c.tar.gz
libbu++-1291252a7b1317ad2dc13fbeb15f6e9d2d92192c.tar.bz2
libbu++-1291252a7b1317ad2dc13fbeb15f6e9d2d92192c.tar.xz
libbu++-1291252a7b1317ad2dc13fbeb15f6e9d2d92192c.zip
A new feature has been added to Bu::Server. It's going to be trickier to
implement in Bu::ItoServer, but I'll get to it. Basically you can trigger a "tick" any time you want and it will propegate as an onTick event to all active clients. You can also have these generated automatically everytime the system passes through a polling cycle. In this case, you should never ever write data to the socket every tick. It will cause your program to go bursurk.
Diffstat (limited to 'src/tests/serverticks.cpp')
-rw-r--r--src/tests/serverticks.cpp61
1 files changed, 61 insertions, 0 deletions
diff --git a/src/tests/serverticks.cpp b/src/tests/serverticks.cpp
new file mode 100644
index 0000000..80c4dfa
--- /dev/null
+++ b/src/tests/serverticks.cpp
@@ -0,0 +1,61 @@
1#include "bu/server.h"
2#include "bu/client.h"
3#include "bu/protocol.h"
4
5class TickProtocol : public Bu::Protocol
6{
7public:
8 TickProtocol()
9 {
10 }
11
12 virtual ~TickProtocol()
13 {
14 }
15
16 virtual void onTick( Bu::Client *pClient )
17 {
18 printf("tick!\n");
19 pClient->write("tick!\n");
20 }
21};
22
23class TickServer : public Bu::Server
24{
25public:
26 TickServer()
27 {
28 }
29
30 virtual ~TickServer()
31 {
32 }
33
34 virtual void onNewConnection( Bu::Client *pClient, int )
35 {
36 pClient->setProtocol( new TickProtocol() );
37 }
38
39 virtual void onClosedConnection( Bu::Client *pClient )
40 {
41 delete pClient->getProtocol();
42 }
43};
44
45int main( int , char *[] )
46{
47 TickServer ts;
48
49 ts.setTimeout( 1, 0 );
50 ts.setAutoTick();
51 ts.addPort( 5555 );
52
53 for(;;)
54 {
55 ts.scan();
56 sleep( 1 );
57 }
58
59 return 0;
60}
61