summaryrefslogtreecommitdiff
path: root/examples/QOS/QosEvent.h
blob: 3e53defbc813f4c2974ce677ad964e4fd01d64ab (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
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
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
/* -*- C++ -*- */
//$Id$

// ============================================================================
//
// = LIBRARY
//    ACE_wrappers/examples/QOS
//
// = FILENAME
//    QosEvent.h
//
// = AUTHOR
//    Vishal Kachroo <vishal@cs.wustl.edu>
//
// ============================================================================

#ifndef QOSEVENT_H
#define QOSEVENT_H

#if !(defined (ACE_HAS_WINSOCK2) && (ACE_HAS_WINSOCK2 != 0))

#define XP1_QOS_SUPPORTED        0x00002000
#define XP1_SUPPORT_MULTIPOINT   0x00000400

#define TRUE  1
#define FALSE 0

#define WSABASEERR              10000
#define WSAENOBUFS              (WSABASEERR+55)

#define FROM_PROTOCOL_INFO (-1)

#define WSA_FLAG_OVERLAPPED           0x01
#define WSA_FLAG_MULTIPOINT_C_ROOT    0x02
#define WSA_FLAG_MULTIPOINT_C_LEAF    0x04
#define WSA_FLAG_MULTIPOINT_D_ROOT    0x08
#define WSA_FLAG_MULTIPOINT_D_LEAF    0x10

#define QOS_NOT_SPECIFIED     0xFFFFFFFF
#define SERVICETYPE_NOTRAFFIC 0x00000000  // No data in this direction.
#define SERVICETYPE_CONTROLLEDLOAD 0x00000002  // Controlled Load. 
#define SERVICETYPE_GUARANTEED 0x00000003  // Guaranteed.

#define JL_SENDER_ONLY    0x01
#define JL_BOTH           0x04

#define SIO_GET_QOS              (0x40000000 | 0x08000000 | 7)
#define SIO_MULTIPOINT_LOOPBACK  (0x08000000 | 9)
#define SIO_MULTICAST_SCOPE      (0x08000000 | 10)
#define SIO_SET_QOS			     (0x08000000 | 11)

#endif /* ACE_HAS_WINSOCK2 */

#define MY_DEFPORT 5001

// Application-specific define - there is NO specific invalid send
// priority.  This value is simply used to indicate whether or not to
// even set priority.
#define INVALID_SEND_PRIORITY 255

// Application-specific define - there is no "default" QOS template in
// GQoS, only for this particular application does "default" have
// meaning.
#define QOS_DEFAULTNAME "default"       

// Use an arbitrary multicast group if none is specified on the
// command line
#define DEFAULT_MULTICASTGROUP "234.5.6.7"

typedef struct _SP_OPTIONS
{
  int iProtocol;             
  // protocol to use

  int bQos;                  
  // enable QOS

  int bMulticast;            
  // enable multicasting
} SP_OPTIONS;

typedef enum 
{
  QOS_IOCTL_SET_DURING,       
  // do not use ioctl to set Qos

  QOS_IOCTL_SET_BEFORE,       
  // set qos with ioctl before connection/accept

  QOS_IOCTL_SET_AFTER,        
  // set qos with ioctl after connection/accept

  QOS_IOCTL_SET_QOS           
  // set qos in receiver during FD_QOS, note that qos must be set
  // prior to wsaeventselect in order to ever receive fd_qos
} QOS_IOCTL_SET;


typedef struct _QOS_OPTIONS
{
  int bReceiver;          
  // act as receiver if TRUE

  int bWaitToSend;        
  // sender must wait for RESV before sending

  int bConfirmResv;       
  // have receiver request RESV confirmation

  int bQueryBufferSize;   
  // have WSAioctl return size of buffer needed when using SIO_GET_QOS
  // (behaviour not avail on Win98).

  int bMustSetQosInAccept;
  // Will be set for Win98 only.  Win98 currently needs valid qos
  // structure to be set in wsaaccept condition func in lpSQos is
  // valid

  int bDisableSignalling; 
  // If TRUE do not emit RSVP signalling, just use traffic control

  int bAlternateQos;      
  // Alternate between enabling and disabling QOS on a socket every N
  // sends

  u_int SendPriority;       
  // create QOS_OBJECT_PRIORITY structure, and set valid priority 0-7

  int bSetDestaddr;       
  // TRUE if unconnected UDP and QOS is used (not multicast)

  int bProviderSpecific;  
  // TRUE if a provider-specific object must be set

  int bFineGrainErrorAvail;   
  // TRUE if Win2000beta3 availability of fine grain errors on SIO_SET_QOS

  int bQosabilityIoctls;   
  // TRUE if Win2000beta3 qosablity ioctls 

  int bFixTemplate;       
  // TRUE if Win98 to divide ToeknRate and PeakBandwidth by 8 when
  // using WSAGetQOSByName

  QOS_IOCTL_SET qosIoctlSet;  
  // when to set QOS

  char szTemplate[64];     
  // qos template
} QOS_OPTIONS;

extern ACE_Flow_Spec default_notraffic;
extern ACE_Flow_Spec default_g711;

typedef struct _OPTIONS
{
  char szHostname[64];
  u_short port;
  int nRepeat;
  char fillchar;
  int nBufSize;
  char *buf;
  u_long dwSleep;
  u_long dwTotalClients;
  QOS_OPTIONS qosOptions;
  SP_OPTIONS spOptions;
} OPTIONS;

#ifdef QOSEVENT_MAIN

OPTIONS default_options = 
{
  "localhost",
  MY_DEFPORT,
  1,
  'c',
  4096,
  NULL,
  0,
  0,
  {TRUE, FALSE, FALSE, TRUE, FALSE, FALSE, FALSE, INVALID_SEND_PRIORITY, 
   TRUE, TRUE, TRUE, TRUE, FALSE, QOS_IOCTL_SET_BEFORE, QOS_DEFAULTNAME},
  {IPPROTO_TCP, FALSE, FALSE}
};

ACE_Flow_Spec default_notraffic (QOS_NOT_SPECIFIED,
                                 QOS_NOT_SPECIFIED,
                                 QOS_NOT_SPECIFIED,
                                 QOS_NOT_SPECIFIED,
                                 QOS_NOT_SPECIFIED,
                                 SERVICETYPE_NOTRAFFIC,
                                 QOS_NOT_SPECIFIED,
                                 QOS_NOT_SPECIFIED,
                                 25,
                                 1);
    
ACE_Flow_Spec default_g711 (9200,
                            708,
                            18400,
                            0,
                            0,
                            SERVICETYPE_CONTROLLEDLOAD,
                            368,
                            368,
                            25,
                            1);
#else
extern FLOWSPEC default_notraffic;
extern FLOWSPEC default_g711;
extern SOCKADDR_IN g_destaddr;
#endif /* QOSEVENT_MAIN */
extern int FindServiceProvider (int iProtocol,
                                int bQos,
                                int bMulticast,
                                ACE_Protocol_Info *pProtocolInfo);
#endif /* QOSEVENT_H */