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
|
/*
* main.h
*
* Queue - a tester of the PQueueChannel class in pwlib
*
* Copyright (c) 2006 Derek J Smithies
*
* The contents of this file are subject to the Mozilla Public License
* Version 1.0 (the "License"); you may not use this file except in
* compliance with the License. You may obtain a copy of the License at
* http://www.mozilla.org/MPL/
*
* Software distributed under the License is distributed on an "AS IS"
* basis, WITHOUT WARRANTY OF ANY KIND, either express or implied. See
* the License for the specific language governing rights and limitations
* under the License.
*
* The Original Code is Jester
*
* The Initial Developer of the Original Code is Derek J Smithies
*
* Contributor(s): ______________________________________.
*
* $Revision: 20385 $
* $Author: rjongbloed $
* $Date: 2008-06-04 05:40:38 -0500 (Wed, 04 Jun 2008) $
*/
#ifndef _QUEUE_MAIN_H
#define _QUEUE_MAIN_H
#include <ptlib/pprocess.h>
#include <ptclib/delaychan.h>
#include <ptclib/qchannel.h>
/** The main class that is instantiated to do things */
class QueueProcess : public PProcess
{
PCLASSINFO(QueueProcess, PProcess)
public:
/**Constructor, which initalises version number, application name etc*/
QueueProcess();
/**Execution starts here, where the command line is processed. In here, the
child threads (for generating and consuming data) are launched. */
void Main();
protected:
#ifdef DOC_PLUS_PLUS
/**Generate a Block of data, (an array of bytes) and push them onto the
PQueueChannel class, at some user specified rate. The rate of writing
the data can be different to the rate of reading the data */
virtual void GenerateBlockData(PThread &, INT);
#else
PDECLARE_NOTIFIER(PThread, QueueProcess, GenerateBlockData);
#endif
#ifdef DOC_PLUS_PLUS
/**Read in a block of data (an array of bytes) from the PQueueChannel
class at some user specified rate. The rate of reading the data can be
different to the rate of writing the data */
virtual void ConsumeBlockData(PThread &, INT);
#else
PDECLARE_NOTIFIER(PThread, QueueProcess, ConsumeBlockData);
#endif
/**The class that acts as a queue */
PQueueChannel queue;
/**The number of iterations we run for */
PINDEX iterations;
/**The delay (in ms) between consecutive writes */
PINDEX writeDelay;
/**the delay (in ms) between consucutive reads */
PINDEX readDelay;
/**The size (in bytes) of each write block */
PINDEX writeSize;
/**The size (in bytes) of each read block */
PINDEX readSize;
};
#endif // _QUEUE_MAIN_H
// End of File ///////////////////////////////////////////////////////////////
|
