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
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
|
/*
*
*
* Inter Asterisk Exchange 2
*
* Class definition for describing the entity that sends all packets
* for all calls
*
* Open Phone Abstraction Library (OPAL)
*
* Copyright (c) 2005 Indranet Technologies Ltd.
*
* 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 Open Phone Abstraction Library.
*
* The Initial Developer of the Original Code is Indranet Technologies Ltd.
*
* The author of this code is Derek J Smithies
*
* $Log: transmit.h,v $
* Revision 1.2 2005/08/26 03:07:38 dereksmithies
* Change naming convention, so all class names contain the string "IAX2"
*
* Revision 1.1 2005/07/30 07:01:32 csoutheren
* Added implementation of IAX2 (Inter Asterisk Exchange 2) protocol
* Thanks to Derek Smithies of Indranet Technologies Ltd. for
* writing and contributing this code
*
*
*
*
*/
#ifndef TRANSMIT_H
#define TRANSMIT_H
#include <ptlib.h>
#include <ptlib/sockets.h>
#include <iax2/frame.h>
#include <iax2/iax2ep.h>
#ifdef P_USE_PRAGMA
#pragma interface
#endif
/**Manage the transmission of etherenet packets on the specified
port. All transmitted packets are received from any of the current
connections. A separate thread is used to wait on the request to
send packets. Full frame packets, which have been resent the
requisite number of times are deleted. This class will
(eventually) delete all the frames it is given.
Note that this class is a thread, and runs when activated by outside
events.*/
class IAX2Transmit : public PThread
{
PCLASSINFO(IAX2Transmit, PThread);
public:
/**@name Construction/destruction*/
//@{
/**
Constructor, which creates a thread to send all packets on the
designated socket. */
IAX2Transmit(IAX2EndPoint & _newEndpoint, PUDPSocket & _newSocket);
/**
Destructor. Deletes all pending packets.
*/
~IAX2Transmit();
//@}
/**@name Worker methods*/
//@{
/**Queue a frame for delivery. This is called by a connection, and then
the transmit thread is woken up.
*/
void SendFrame(IAX2Frame *newFrame);
/**Activate the transmit thread to process all frames in the lists
*/
void ProcessLists() { activate.Signal(); }
/**An Ack has been received..
Delete the matching frame from the queue waiting for an ack
*/
void AckReceived();
/**Do the work of the thread here. Read all lists and check for
frames to send/delete.*/
virtual void Main();
/** A full frame was transmitted a while ago, and the receiver has replied with
a suitable acknowledgement. The acknowledgment (the newFrame) means that matching
frames in the ack list should be removed.
*/
void PurgeMatchingFullFrames(IAX2Frame *frame);
/** Report on the contents of the lists waiting for transmission */
void ReportLists();
//@}
protected:
/**Go through the acking list:: delete those who have too many
retries, and transmit those who need retransmitting */
void ProcessAckingList();
/**Go through the send list:: send all frames on this list */
void ProcessSendList();
/**Global variable specifying application specific variables */
IAX2EndPoint &ep;
/**Network socket used to transmit packets*/
PUDPSocket & sock;
/**Flag to activate this thread*/
PSyncPoint activate;
/**Frames in the acking list - These frames are waiting on an ack*/
IAX2FrameList ackingFrames;
/**Send Now list of frames - These frames are to be sent now */
IAX2FrameList sendNowFrames;
/**Flag to indicate that this thread should keep working */
BOOL keepGoing;
};
#endif // IAX2_TRANSMIT_H
/* The comment below is magic for those who use emacs to edit this file. */
/* With the comment below, the tab key does auto indent to 4 spaces. */
/*
* Local Variables:
* mode:c
* c-file-style:linux
* c-basic-offset:2
* End:
*/
|
