blob: b822c6be59c18b29ba2dfd3dc2a3001e863207eb (
plain)
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
|
// $Id$
#ifndef COMPRESSOR_H
#define COMPRESSOR_h
#include "Protocol_Task.h"
/* A reallly dumb compression object. (It actually adds 3 bytes to
every message block.)
*/
class Compressor : public Protocol_Task
{
public:
typedef Protocol_Task inherited;
// I've given you the option of creating this task derivative
// with a number of threads. In retro-spect that really isn't
// a good idea. Most client/server systems rely on requests
// and responses happening in a predicatable order. Introduce
// a thread pool and message queue and that ordering goes
// right out the window. In other words: Don't ever use the
// constructor parameter!
Compressor (int thr_count = 0);
~Compressor (void);
protected:
// This is called when the compressor is on the downstream side.
// We'll take the message, compress it and move it along to the next
// module.
int send (ACE_Message_Block *message,
ACE_Time_Value *timeout);
// This one is called on the upstream side. No surprise: we
// decompress the data and send it on up the stream.
int recv (ACE_Message_Block *message,
ACE_Time_Value *timeout);
};
#endif /* COMPRESSOR_H */
|
