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
|
/* -*- C++ -*- */
/* $Id$ */
/* Copyright (c) 1995 Oregon Graduate Institute of Science and Technology
* P.O.Box 91000-1000, Portland, OR 97291, USA;
*
* Permission to use, copy, modify, distribute, and sell this software and its
* documentation for any purpose is hereby granted without fee, provided that
* the above copyright notice appear in all copies and that both that
* copyright notice and this permission notice appear in supporting
* documentation, and that the name of O.G.I. not be used in advertising or
* publicity pertaining to distribution of the software without specific,
* written prior permission. O.G.I. makes no representations about the
* suitability of this software for any purpose. It is provided "as is"
* without express or implied warranty.
*
* O.G.I. DISCLAIMS ALL WARRANTIES WITH REGARD TO THIS SOFTWARE, INCLUDING
* ALL IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS, IN NO EVENT SHALL
* O.G.I. BE LIABLE FOR ANY SPECIAL, INDIRECT OR CONSEQUENTIAL DAMAGES OR ANY
* DAMAGES WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN
* AN ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
* OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
*
* Author: Shanwei Cen
* Department of Computer Science and Engineering
* email: scen@cse.ogi.edu
*/
#if !defined (AV_COMMAND_HANDLER_H)
#define AV_COMMAND_HANDLER_H
#include "ace/Reactor.h"
#include "ace/Event_Handler.h"
#include "ace/ARGV.h"
#include "tao/TAO.h"
#include "mpeg_shared/Video_ControlC.h"
#include "orbsvcs/CosNamingC.h"
#include "ace/SOCK_Dgram.h"
#include "ace/SOCK_Connector.h"
class Command_Handler
: public virtual ACE_Event_Handler
{
// = TITLE
// Defines the event handler class for the client commands
//
// = DESCRIPTION
// This class makes use of a UNIX socket, over which
// it will receive commands from the GUI
public:
Command_Handler (ACE_HANDLE command_handle);
// Construct this handler with a control (UNIX) handle
int init (void);
// initialize the ORB
int resolve_server_reference (void);
// Resolve the video control reference
virtual int handle_input (ACE_HANDLE fd = ACE_INVALID_HANDLE);
// Called when input events occur (e.g., connection or data).
virtual ACE_HANDLE get_handle (void) const;
// Returns the handle used by the event_handler.
CORBA::Boolean init_video (void);
int init_video_channel (char *phostname,char *videofile);
CORBA::Boolean stat_stream (CORBA::Char_out ch,
CORBA::Long_out size) ;
CORBA::Boolean close (void) ;
CORBA::Boolean stat_sent (void) ;
CORBA::Boolean fast_forward (void);
CORBA::Boolean fast_backward (void);
CORBA::Boolean step (void);
CORBA::Boolean play (int flag,
CORBA::Environment& env);
int position_action (int operation_tag);
int position (void);
int position_release (void);
int volume (void);
int balance (void);
CORBA::Boolean speed (void);
CORBA::Boolean stop (void);
int stop_playing (void);
int connect_to_server (char *address,
int *ctr_fd,
int *data_fd,
int *max_pkt_size);
private:
ACE_SOCK_Dgram dgram_;
// UDP datagram on which to send/recv data
ACE_SOCK_Stream stream_;
// TCP stream socket
ACE_SOCK_Connector connector_;
ACE_HANDLE command_handle_;
// The fd for the UNIX command socket
TAO_ORB_Manager *orb_manager_;
// the ORB manager
Video_Control_var video_control_;
// Video Control CORBA object
};
class Client_Sig_Handler
: public virtual ACE_Event_Handler
// = TITLE
// Defines the signal handler class for the client timer processing
//
// = DESCRIPTION
// %%
{
public:
Client_Sig_Handler (Command_Handler *command_handler);
// We need the command handler to call close ()
virtual ACE_HANDLE get_handle (void) const;
int register_handler (void);
// this will register this sig_handler
// with the reactor for SIGCHLD,SIGTERM,SIGINT
virtual int shutdown (ACE_HANDLE,
ACE_Reactor_Mask);
// handles the reactor shutdown
virtual int handle_input (ACE_HANDLE);
// handle input on the dummy handle.
virtual int handle_signal (ACE_HANDLE signum,
siginfo_t * = 0,
ucontext_t* = 0);
// handles SIGALRM
private:
ACE_HANDLE handle_;
// dummy handle for the sig handler.
Command_Handler *command_handler_;
// We need the command handler to call close ()
};
#endif /* AV_COMMAND_HANDLER_H */
|
