blob: 097f3afdaba766d85b37d35130c7d2a1a15da8ff (
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
43
44
45
46
47
48
49
|
// $Id$
#ifndef XMIT_H
#define XMIT_h
#include "Protocol_Task.h"
// Forward reference reduces #include dependencies
class ACE_SOCK_Stream;
/* A class suitable for sending data to a peer from within an
ACE_Stream.
*/
class Xmit : public Protocol_Task
{
public:
typedef Protocol_Task inherited;
// We must be given a valid peer when constructed. Without that
// we don't know who to send data to.
Xmit( ACE_SOCK_Stream & _peer );
~Xmit(void);
// As you know, close() will be called in a couple of ways by the
// ACE framework. We use that opportunity to terminate the
// connection to the peer.
int close(u_long flags);
protected:
ACE_SOCK_Stream & peer(void)
{
return this->peer_;
}
// Send the data to the peer. By now it will have been
// completely protocol-ized by other tasks in the stream.
int send(ACE_Message_Block *message,
ACE_Time_Value *timeout);
private:
// A representation of the peer we're talking to.
ACE_SOCK_Stream & peer_;
};
#endif // XMIT_H
|
