blob: b796f6b7c3d396cbaea6b48f18be24c1fc3ca26e (
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
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
96
97
98
99
100
101
102
103
104
105
|
// -*- C++ -*-
//=============================================================================
/**
* @file UIPMC_Transport_Recv_Packet.h
*
* @author Vladimir Zykov <vz@prismtech.com>
*/
//=============================================================================
#ifndef TAO_UIPMC_TRANSPORT_RECV_PACKET_H
#define TAO_UIPMC_TRANSPORT_RECV_PACKET_H
#include /**/ "ace/pre.h"
#include "tao/orbconf.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
#pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#include "tao/Versioned_Namespace.h"
#include "tao/corba.h"
TAO_BEGIN_VERSIONED_NAMESPACE_DECL
class TAO_UIPMC_Mcast_Transport;
namespace TAO_PG
{
/**
* @class UIPMC_Recv_Packet_Cleanup_Guard
*
* @brief A guard that will cleanup broken/expired packets.
*/
class UIPMC_Recv_Packet_Cleanup_Guard
{
public:
UIPMC_Recv_Packet_Cleanup_Guard (TAO_UIPMC_Mcast_Transport *transport);
~UIPMC_Recv_Packet_Cleanup_Guard ();
private:
TAO_UIPMC_Mcast_Transport *transport_;
};
/**
* @class UIPMC_Recv_Packet
*
* @brief A MIOP packet for receiving.
*/
class UIPMC_Recv_Packet
{
public:
/// Constructs a new recv packet.
UIPMC_Recv_Packet ();
~UIPMC_Recv_Packet ();
/// Adds a new fragment to the packet and if it fails marks the packet
/// as broken.
/// Returns 1 if all fragments are in AND if there are no fragments
/// with unexpected IDs. In case unexpected IDs are encountered the
/// packet is marked as broken.
int add_fragment (char *data, CORBA::UShort len,
CORBA::ULong id, bool is_last);
/// Returns the time when the first fragment was received or
/// ACE_Time_Value::zero if the whole packet was not able to
/// reconstruct for some reason.
ACE_Time_Value const &started () const;
CORBA::ULong data_length () const;
/// Copies fragments to buf. Caller ensures that the buf is big enough
/// for all fragments.
void copy_data (char *buf) const;
private:
/// The id of the last fragment.
CORBA::ULong last_fragment_id_;
/// The length of the data stored in all fragments.
CORBA::ULong data_length_;
/// The time when the packet will expire.
mutable ACE_Time_Value started_;
/// Fragments.
struct Fragment
{
char *buf;
CORBA::UShort len;
};
typedef ACE_Hash_Map_Manager<CORBA::ULong,
Fragment,
ACE_SYNCH_NULL_MUTEX> Fragments_Map;
Fragments_Map fragments_;
};
} // namespace TAO_PG
TAO_END_VERSIONED_NAMESPACE_DECL
#include /**/ "ace/post.h"
#endif // TAO_UIPMC_TRANSPORT_RECV_PACKET_H
|
