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
|
// $Id$
#include "ace/Get_Opt.h"
#include "ace/Argv_Type_Converter.h"
#include "ace/SString.h"
#include "ace/Manual_Event.h"
#include "tao/Transport_Cache_Manager_T.h"
#include "tao/ORB.h"
class mock_transport;
class mock_tdi;
class mock_ps;
static int global_purged_count = 0;
typedef TAO::Transport_Cache_Manager_T<mock_transport, mock_tdi, mock_ps> TCM;
#include "mock_tdi.h"
#include "mock_transport.h"
#include "mock_ps.h"
int
ACE_TMAIN(int argc, ACE_TCHAR *argv[])
{
int result = 0;
try
{
// We need an ORB to get an ORB core
CORBA::ORB_var orb = CORBA::ORB_init (argc, argv);
// We create 10 transports and have a max of 10 tran
size_t const transport_max = 10;
int cache_maximum = 10;
int purging_percentage = 20;
size_t i = 0;
mock_transport mytransport[transport_max];
mock_tdi mytdi[transport_max];
mock_ps* myps = new mock_ps(10);
TCM my_cache (purging_percentage, myps, cache_maximum, false, 0);
// Cache all transports in the cache
for (i = 0; i < transport_max; i++)
{
my_cache.cache_transport (&mytdi[i], &mytransport[i]);
mytransport[i].purging_order (i);
}
// Now purge the cache and see which one get removed. Only transport
// 0 and 1 should be purged in that order, 0 has the lowest purging
// count, 1 has the second lowest value.
my_cache.purge ();
for (i = 2; i < transport_max; i++)
{
if (mytransport[i].purged_count () != 0)
{
ACE_ERROR ((LM_ERROR, "ERROR Incorrect purged count %d for transport %d\n", mytransport[i].purged_count(), i));
++result;
}
}
if (mytransport[0].purged_count () != 1)
{
ACE_ERROR ((LM_ERROR, "ERROR Incorrect purged count for transport 0: %d\n", mytransport[0].purged_count ()));
++result;
}
if (mytransport[1].purged_count () != 2)
{
ACE_ERROR ((LM_ERROR, "ERROR Incorrect purged count for transport 1: %d\n", mytransport[1].purged_count ()));
++result;
}
orb->destroy ();
}
catch (const CORBA::Exception&)
{
// Ignore exceptions..
}
return result;
}
|
