1 /*****************************************************************************
2 * eyetv.c : Access module to connect to our plugin running within EyeTV
3 *****************************************************************************
4 * Copyright (C) 2006-2007 the VideoLAN team
7 * Author: Felix Kühne <fkuehne at videolan dot org>
9 * This program is free software; you can redistribute it and/or modify
10 * it under the terms of the GNU General Public License as published by
11 * the Free Software Foundation; either version 2 of the License, or
12 * (at your option) any later version.
14 * This program is distributed in the hope that it will be useful,
15 * but WITHOUT ANY WARRANTY; without even the implied warranty of
16 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
17 * GNU General Public License for more details.
19 * You should have received a copy of the GNU General Public License
20 * along with this program; if not, write to the Free Software
21 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston MA 02110-1301, USA.
22 *****************************************************************************/
24 /*****************************************************************************
26 *****************************************************************************/
32 #include <vlc_common.h>
33 #include <vlc_plugin.h>
34 #include <vlc_access.h>
36 #include <vlc_network.h>
38 #include <sys/types.h>
39 #include <sys/socket.h>
43 #import <Foundation/Foundation.h>
48 * watch for PluginQuit or DeviceRemoved to stop output to VLC's core then */
50 /*****************************************************************************
52 *****************************************************************************/
53 static int Open ( vlc_object_t * );
54 static void Close( vlc_object_t * );
56 #define CHANNEL_TEXT N_("Channel number")
57 #define CHANNEL_LONGTEXT N_( \
58 "EyeTV program number, or use 0 for last channel, " \
59 "-1 for S-Video input, -2 for Composite input" )
61 #define CACHING_TEXT N_("Caching value in ms")
62 #define CACHING_LONGTEXT N_( \
63 "Caching value for EyeTV captures. This " \
64 "value should be set in milliseconds." )
67 set_shortname( "EyeTV" )
68 set_description( N_("EyeTV input") )
69 set_category( CAT_INPUT )
70 set_subcategory( SUBCAT_INPUT_ACCESS )
72 add_integer( "eyetv-channel", 0,
73 CHANNEL_TEXT, CHANNEL_LONGTEXT, false )
75 set_capability( "access", 0 )
76 add_shortcut( "eyetv" )
77 set_callbacks( Open, Close )
78 add_integer( "eyetv-caching", DEFAULT_PTS_DELAY / 1000,
79 CACHING_TEXT, CACHING_LONGTEXT, true);
82 /*****************************************************************************
83 * Access: local prototypes
84 *****************************************************************************/
91 static block_t *BlockRead( access_t *);
92 static int Control( access_t *, int, va_list );
94 static void selectChannel( vlc_object_t *p_this, int theChannelNum )
96 NSAppleScript *script;
97 NSAutoreleasePool *pool = [[NSAutoreleasePool alloc] init];
98 switch( theChannelNum )
100 case -2: // Composite
101 script = [[NSAppleScript alloc] initWithSource:
102 @"tell application \"EyeTV\"\n"
103 " input_change input source composite video input\n"
104 " volume_change level 0\n"
105 " show player_window\n"
106 " tell application \"System Events\" to set visible of process \"EyeTV\" to false\n"
110 script = [[NSAppleScript alloc] initWithSource:
111 @"tell application \"EyeTV\"\n"
112 " input_change input source S video input\n"
113 " volume_change level 0\n"
114 " show player_window\n"
115 " tell application \"System Events\" to set visible of process \"EyeTV\" to false\n"
119 script = [[NSAppleScript alloc] initWithSource:
120 @"tell application \"EyeTV\"\n"
121 " volume_change level 0\n"
122 " show player_window\n"
123 " tell application \"System Events\" to set visible of process \"EyeTV\" to false\n"
127 if( theChannelNum > 0 )
129 NSString *channel_change = [NSString stringWithFormat:
130 @"tell application \"EyeTV\"\n"
131 " channel_change channel number %d\n"
132 " volume_change level 0\n"
133 " show player_window\n"
134 " tell application \"System Events\" to set visible of process \"EyeTV\" to false\n"
135 "end tell", theChannelNum];
136 script = [[NSAppleScript alloc] initWithSource:channel_change];
141 NSDictionary *errorDict;
142 NSAppleEventDescriptor *descriptor = [script executeAndReturnError:&errorDict];
143 if( nil == descriptor )
145 NSString *errorString = [errorDict objectForKey:NSAppleScriptErrorMessage];
146 msg_Err( p_this, "EyeTV source change failed with error status '%s'", [errorString UTF8String] );
152 /*****************************************************************************
153 * Open: sets up the module and its threads
154 *****************************************************************************/
155 static int Open( vlc_object_t *p_this )
157 access_t *p_access = (access_t *)p_this;
160 struct sockaddr_un publicAddr, peerAddr;
164 access_InitFields( p_access );
165 ACCESS_SET_CALLBACKS( NULL, BlockRead, Control, NULL );
166 p_sys = p_access->p_sys = calloc( 1, sizeof( access_sys_t ) );
170 p_sys->i_pts_delay = var_InheritInteger( p_access, "eyetv-caching" );
172 msg_Dbg( p_access, "coming up" );
173 selectChannel( p_this, var_InheritInteger( p_access, "eyetv-channel" ) );
176 memset(&publicAddr, 0, sizeof(publicAddr));
177 publicAddr.sun_family = AF_UNIX;
178 strncpy(publicAddr.sun_path, "/tmp/.vlc-eyetv-bridge", sizeof(publicAddr.sun_path)-1);
179 /* remove previous public path if it wasn't cleanly removed */
180 if( (0 != unlink(publicAddr.sun_path)) && (ENOENT != errno) )
182 msg_Err( p_access, "local socket path is not usable (errno=%d)", errno );
187 publicSock = socket(PF_UNIX, SOCK_STREAM, 0);
188 if( publicSock == -1 )
190 msg_Err( p_access, "create local socket failed (errno=%d)", errno );
195 if( bind(publicSock, (struct sockaddr *)&publicAddr, sizeof(struct sockaddr_un)) == -1 )
197 msg_Err( p_access, "bind local socket failed (errno=%d)", errno );
203 /* we are not expecting more than one connection */
204 if( listen(publicSock, 1) == -1 )
206 msg_Err( p_access, "cannot accept connection (errno=%d)", errno );
213 socklen_t peerSockLen = sizeof(struct sockaddr_un);
216 /* tell the EyeTV plugin to open start sending */
217 CFNotificationCenterPostNotification( CFNotificationCenterGetDistributedCenter (),
218 CFSTR("VLCAccessStartDataSending"),
219 CFSTR("VLCEyeTVSupport"),
223 msg_Dbg( p_access, "plugin notified" );
225 peerSock = accept(publicSock, (struct sockaddr *)&peerAddr, &peerSockLen);
228 msg_Err( p_access, "cannot wait for connection (errno=%d)", errno );
234 msg_Dbg( p_access, "plugin connected" );
236 p_sys->eyetvSock = peerSock;
238 /* remove public access */
240 unlink(publicAddr.sun_path);
245 /*****************************************************************************
246 * Close: closes msg-port, free resources
247 *****************************************************************************/
248 static void Close( vlc_object_t *p_this )
250 access_t *p_access = (access_t *)p_this;
251 access_sys_t *p_sys = p_access->p_sys;
253 msg_Dbg( p_access, "closing" );
255 /* tell the EyeTV plugin to close its msg port and stop sending */
256 CFNotificationCenterPostNotification( CFNotificationCenterGetDistributedCenter (),
257 CFSTR("VLCAccessStopDataSending"),
258 CFSTR("VLCEyeTVSupport"),
262 msg_Dbg( p_access, "plugin notified" );
264 close(p_sys->eyetvSock);
266 msg_Dbg( p_access, "msg port closed and freed" );
271 /*****************************************************************************
272 * BlockRead: forwarding data from EyeTV plugin which was received above
273 *****************************************************************************/
274 static block_t *BlockRead( access_t *p_access )
276 access_sys_t *p_sys = p_access->p_sys;
280 if( p_access->info.b_eof )
284 p_block = block_New( p_access, MTU );
285 len = net_Read( p_access, p_sys->eyetvSock, NULL,
286 p_block->p_buffer, MTU, false );
290 block_Release( p_block );
294 return block_Realloc( p_block, 0, p_block->i_buffer = len );
297 /*****************************************************************************
299 *****************************************************************************/
300 static int Control( access_t *p_access, int i_query, va_list args )
305 access_sys_t *p_sys = (access_sys_t *) p_access->p_sys;
309 case ACCESS_CAN_SEEK:
310 case ACCESS_CAN_FASTSEEK:
311 pb_bool = (bool*)va_arg( args, bool* );
314 case ACCESS_CAN_PAUSE:
315 pb_bool = (bool*)va_arg( args, bool* );
318 case ACCESS_CAN_CONTROL_PACE:
319 pb_bool = (bool*)va_arg( args, bool* );
324 case ACCESS_GET_PTS_DELAY:
325 pi_64 = (int64_t*)va_arg( args, int64_t * );
326 *pi_64 = (int64_t) p_sys->i_pts_delay * 1000;
329 case ACCESS_SET_PAUSE_STATE:
330 case ACCESS_GET_TITLE_INFO:
331 case ACCESS_SET_TITLE:
332 case ACCESS_SET_SEEKPOINT:
333 case ACCESS_SET_PRIVATE_ID_STATE:
334 case ACCESS_GET_CONTENT_TYPE:
338 msg_Warn( p_access, "unimplemented query in control" );