1 /*****************************************************************************
2 * eyetv.m : 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" )
62 set_shortname( "EyeTV" )
63 set_description( N_("EyeTV input") )
64 set_category( CAT_INPUT )
65 set_subcategory( SUBCAT_INPUT_ACCESS )
67 add_integer( "eyetv-channel", 0,
68 CHANNEL_TEXT, CHANNEL_LONGTEXT, false )
70 set_capability( "access", 0 )
71 add_shortcut( "eyetv" )
72 set_callbacks( Open, Close )
75 /*****************************************************************************
76 * Access: local prototypes
77 *****************************************************************************/
83 static block_t *BlockRead( access_t *);
84 static int Control( access_t *, int, va_list );
86 static void selectChannel( vlc_object_t *p_this, int theChannelNum )
88 NSAppleScript *script;
89 NSAutoreleasePool *pool = [[NSAutoreleasePool alloc] init];
90 switch( theChannelNum )
93 script = [[NSAppleScript alloc] initWithSource:
94 @"tell application \"EyeTV\"\n"
95 " input_change input source composite video input\n"
96 " volume_change level 0\n"
97 " show player_window\n"
98 " tell application \"System Events\" to set visible of process \"EyeTV\" to false\n"
102 script = [[NSAppleScript alloc] initWithSource:
103 @"tell application \"EyeTV\"\n"
104 " input_change input source S video input\n"
105 " volume_change level 0\n"
106 " show player_window\n"
107 " tell application \"System Events\" to set visible of process \"EyeTV\" to false\n"
111 script = [[NSAppleScript alloc] initWithSource:
112 @"tell application \"EyeTV\"\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 if( theChannelNum > 0 )
121 NSString *channel_change = [NSString stringWithFormat:
122 @"tell application \"EyeTV\"\n"
123 " channel_change channel number %d\n"
124 " volume_change level 0\n"
125 " show player_window\n"
126 " tell application \"System Events\" to set visible of process \"EyeTV\" to false\n"
127 "end tell", theChannelNum];
128 script = [[NSAppleScript alloc] initWithSource:channel_change];
133 NSDictionary *errorDict;
134 NSAppleEventDescriptor *descriptor = [script executeAndReturnError:&errorDict];
135 if( nil == descriptor )
137 NSString *errorString = [errorDict objectForKey:NSAppleScriptErrorMessage];
138 msg_Err( p_this, "EyeTV source change failed with error status '%s'", [errorString UTF8String] );
144 /*****************************************************************************
145 * Open: sets up the module and its threads
146 *****************************************************************************/
147 static int Open( vlc_object_t *p_this )
149 access_t *p_access = (access_t *)p_this;
152 struct sockaddr_un publicAddr, peerAddr;
156 access_InitFields( p_access );
157 ACCESS_SET_CALLBACKS( NULL, BlockRead, Control, NULL );
158 p_sys = p_access->p_sys = calloc( 1, sizeof( access_sys_t ) );
162 msg_Dbg( p_access, "coming up" );
163 selectChannel( p_this, var_InheritInteger( p_access, "eyetv-channel" ) );
166 memset(&publicAddr, 0, sizeof(publicAddr));
167 publicAddr.sun_family = AF_UNIX;
168 strncpy(publicAddr.sun_path, "/tmp/.vlc-eyetv-bridge", sizeof(publicAddr.sun_path)-1);
169 /* remove previous public path if it wasn't cleanly removed */
170 if( (0 != unlink(publicAddr.sun_path)) && (ENOENT != errno) )
172 msg_Err( p_access, "local socket path is not usable (errno=%d)", errno );
177 publicSock = socket(PF_UNIX, SOCK_STREAM, 0);
178 if( publicSock == -1 )
180 msg_Err( p_access, "create local socket failed (errno=%d)", errno );
185 if( bind(publicSock, (struct sockaddr *)&publicAddr, sizeof(struct sockaddr_un)) == -1 )
187 msg_Err( p_access, "bind local socket failed (errno=%d)", errno );
193 /* we are not expecting more than one connection */
194 if( listen(publicSock, 1) == -1 )
196 msg_Err( p_access, "cannot accept connection (errno=%d)", errno );
203 socklen_t peerSockLen = sizeof(struct sockaddr_un);
206 /* tell the EyeTV plugin to open start sending */
207 CFNotificationCenterPostNotification( CFNotificationCenterGetDistributedCenter (),
208 CFSTR("VLCAccessStartDataSending"),
209 CFSTR("VLCEyeTVSupport"),
213 msg_Dbg( p_access, "plugin notified" );
215 peerSock = accept(publicSock, (struct sockaddr *)&peerAddr, &peerSockLen);
218 msg_Err( p_access, "cannot wait for connection (errno=%d)", errno );
224 msg_Dbg( p_access, "plugin connected" );
226 p_sys->eyetvSock = peerSock;
228 /* remove public access */
230 unlink(publicAddr.sun_path);
235 /*****************************************************************************
236 * Close: closes msg-port, free resources
237 *****************************************************************************/
238 static void Close( vlc_object_t *p_this )
240 access_t *p_access = (access_t *)p_this;
241 access_sys_t *p_sys = p_access->p_sys;
243 msg_Dbg( p_access, "closing" );
245 /* tell the EyeTV plugin to close its msg port and stop sending */
246 CFNotificationCenterPostNotification( CFNotificationCenterGetDistributedCenter (),
247 CFSTR("VLCAccessStopDataSending"),
248 CFSTR("VLCEyeTVSupport"),
252 msg_Dbg( p_access, "plugin notified" );
255 close(p_sys->eyetvSock);
257 msg_Dbg( p_access, "msg port closed and freed" );
262 /*****************************************************************************
263 * BlockRead: forwarding data from EyeTV plugin which was received above
264 *****************************************************************************/
265 static block_t *BlockRead( access_t *p_access )
267 access_sys_t *p_sys = p_access->p_sys;
271 if( p_access->info.b_eof )
275 p_block = block_New( p_access, MTU );
276 len = net_Read( p_access, p_sys->eyetvSock, NULL,
277 p_block->p_buffer, MTU, false );
281 block_Release( p_block );
285 return block_Realloc( p_block, 0, p_block->i_buffer = len );
288 /*****************************************************************************
290 *****************************************************************************/
291 static int Control( access_t *p_access, int i_query, va_list args )
296 access_sys_t *p_sys = (access_sys_t *) p_access->p_sys;
300 case ACCESS_CAN_SEEK:
301 case ACCESS_CAN_FASTSEEK:
302 pb_bool = (bool*)va_arg( args, bool* );
305 case ACCESS_CAN_PAUSE:
306 pb_bool = (bool*)va_arg( args, bool* );
309 case ACCESS_CAN_CONTROL_PACE:
310 pb_bool = (bool*)va_arg( args, bool* );
315 case ACCESS_GET_PTS_DELAY:
316 pi_64 = (int64_t*)va_arg( args, int64_t * );
318 INT64_C(1000) * var_InheritInteger( p_access, "live-caching" );
321 case ACCESS_SET_PAUSE_STATE:
322 case ACCESS_GET_TITLE_INFO:
323 case ACCESS_SET_TITLE:
324 case ACCESS_SET_SEEKPOINT:
325 case ACCESS_SET_PRIVATE_ID_STATE:
326 case ACCESS_GET_CONTENT_TYPE:
330 msg_Warn( p_access, "unimplemented query in control" );