espace / eventmachine forked from riham/eventmachine

A fast network I/O and event-management framework for Ruby, Java, and C++ programmers.

eventmachine / ext / eventmachine_cpp.h
100644 95 lines (61 sloc) 2.045 kb
raw blame history 
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
93
94
95

/*****************************************************************************
 
$Id$
 
File:     eventmachine_cpp.h
Date:     27Jul07
 
Copyright (C) 2006-07 by Francis Cianfrocca. All Rights Reserved.
Gmail: blackhedd
 
This program is free software; you can redistribute it and/or modify
it under the terms of either: 1) the GNU General Public License
as published by the Free Software Foundation; either version 2 of the
License, or (at your option) any later version; or 2) Ruby's License.
 
See the file COPYING for complete licensing information.
 
*****************************************************************************/
 
 
#ifndef __EVMA_EventmachineCpp__H_
#define __EVMA_EventmachineCpp__H_
 
 
// This material is only for directly integrating EM into C++ programs.
 
namespace EM {
 
	void Callback (const char *sig, int event, const char *data, int length);
	void Run (void(*)(void));
	void AddTimer (int, void(*)());
	void StopReactor();
 
	/***************
	class Eventable
	***************/
 
	class Eventable {
		public:
			Eventable() {}
			virtual ~Eventable() {}
 
			std::string Signature;
 
			// Called by the framework
			virtual void ReceiveData (const char *data, int length) {}
			virtual void ConnectionCompleted() {}
			virtual void Accept (const char*) {}
			virtual void Unbind() {}
			virtual void PostInit() {}
 
			void StopReactor() {EM::StopReactor();}
	};
 
	/****************
	class Connection
	****************/
 
	class Connection: public Eventable {
		public:
			Connection() {}
			virtual ~Connection() {}
 
			virtual void Connect (const char*, int);
 
			void SendData (const char *data);
			void SendData (const char *data, int length);
			void Close (bool afterWriting);
	};
 
 
	/**************
	class Acceptor
	**************/
 
	class Acceptor: public Eventable {
		public:
			Acceptor() {PostInit();}
			virtual ~Acceptor() {}
 
			void Start (const char*, int);
			void Accept (const char*);
 
			virtual Connection *MakeConnection() {return new Connection();}
	};
 
 
};
 
 
 
 
 
#endif // __EVMA_EventmachineCpp__H_