]> git.sesse.net Git - vlc/blob - modules/access/dvdplay/demux.c
* ./modules/*: moved plugins to the new tree. Yet untested builds include
[vlc] / modules / access / dvdplay / demux.c
1 /*****************************************************************************
2  * demux.c: demux functions for dvdplay.
3  *****************************************************************************
4  * Copyright (C) 1998-2001 VideoLAN
5  * $Id: demux.c,v 1.1 2002/08/04 17:23:42 sam Exp $
6  *
7  * Author: Stéphane Borel <stef@via.ecp.fr>
8  *
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.
13  * 
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.
18  *
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., 59 Temple Place - Suite 330, Boston, MA  02111, USA.
22  *****************************************************************************/
23
24 /*****************************************************************************
25  * Preamble
26  *****************************************************************************/
27 #include <stdio.h>
28 #include <stdlib.h>
29 #include <string.h>
30
31 #include <vlc/vlc.h>
32 #include <vlc/input.h>
33
34 #ifdef HAVE_UNISTD_H
35 #   include <unistd.h>
36 #endif
37
38 #include <fcntl.h>
39 #include <sys/types.h>
40 #include <sys/stat.h>
41 #include <string.h>
42 #include <errno.h>
43
44 #ifdef STRNCASECMP_IN_STRINGS_H
45 #   include <strings.h>
46 #endif
47
48 #include "interface.h"
49 #include "dvd.h"
50 #include "intf.h"
51 #include "es.h"
52
53 /* how many packets dvdplay_Demux will read in each loop */
54 #define dvdplay_READ_ONCE 64
55
56 /*****************************************************************************
57  * Local prototypes
58  *****************************************************************************/
59 static int  Demux         ( input_thread_t * );
60
61 /*****************************************************************************
62  * InitDVD: initializes dvdplay structures
63  *****************************************************************************/
64 int E_(InitDVD) ( vlc_object_t *p_this )
65 {
66     input_thread_t *p_input = (input_thread_t *)p_this;
67     dvd_data_t *    p_dvd;
68     char *          psz_intf = NULL;
69
70     if( p_input->stream.i_method != INPUT_METHOD_DVD )
71     {
72         return -1;
73     }
74
75     p_input->p_demux_data = (void*)p_input->p_access_data;
76     p_dvd = (dvd_data_t *)p_input->p_demux_data;
77
78     p_input->pf_demux = Demux;
79     p_input->pf_rewind = NULL;
80
81     psz_intf = config_GetPsz( p_input, "intf" );
82     config_PutPsz( p_input, "intf", "dvdplay" );
83     p_dvd->p_intf = intf_Create( p_input );
84     p_dvd->p_intf->b_block = VLC_FALSE;
85     intf_RunThread( p_dvd->p_intf );
86     
87     if( psz_intf != NULL )
88     {
89         config_PutPsz( p_input, "intf", psz_intf );
90     }
91
92     return 0;
93 }
94
95 /*****************************************************************************
96  * EndDVD: frees unused data
97  *****************************************************************************/
98 void E_(EndDVD) ( vlc_object_t *p_this )
99 {
100     input_thread_t *p_input = (input_thread_t *)p_this;
101     dvd_data_t *    p_dvd;
102     intf_thread_t * p_intf = NULL;
103
104     p_intf = vlc_object_find( p_input, VLC_OBJECT_INTF, FIND_CHILD );
105     if( p_intf != NULL )
106     {
107         intf_StopThread( p_intf );
108         vlc_object_detach_all( p_intf );
109         vlc_object_release( p_intf );
110         intf_Destroy( p_intf );
111     }
112
113     p_dvd = (dvd_data_t *)p_input->p_demux_data;
114     p_dvd->p_intf = NULL;
115 }
116
117 /*****************************************************************************
118  * Demux
119  *****************************************************************************/
120 static int Demux( input_thread_t * p_input )
121 {
122     dvd_data_t *            p_dvd;
123     data_packet_t *         p_data;
124     ssize_t                 i_result;
125     ptrdiff_t               i_remains;
126     int                     i_data_nb = 0;
127
128     p_dvd = (dvd_data_t *)p_input->p_demux_data;
129    
130     /* Read headers to compute payload length */
131     do
132     {
133         if( ( i_result = input_ReadPS( p_input, &p_data ) ) <= 0)
134         {
135             return i_result;
136         }
137
138         i_remains = p_input->p_last_data - p_input->p_current_data;
139
140         input_DemuxPS( p_input, p_data );
141         
142
143         ++i_data_nb;
144     }
145     while( i_remains );
146     
147
148     
149 //    if( p_dvd->b_still && p_dvd->b_end_of_cell && p_dvd->p_intf != NULL )
150     if( p_dvd->i_still_time && p_dvd->b_end_of_cell && p_dvd->p_intf != NULL )
151     {
152         pgrm_descriptor_t * p_pgrm;
153
154         /* when we receive still_time flag, we have to pause immediately */
155         input_SetStatus( p_input, INPUT_STATUS_PAUSE );
156
157         dvdIntfStillTime( p_dvd->p_intf, p_dvd->i_still_time );
158         p_dvd->i_still_time = 0;
159         
160         vlc_mutex_lock( &p_input->stream.stream_lock );
161         
162         p_pgrm = p_input->stream.p_selected_program;
163         p_pgrm->i_synchro_state = SYNCHRO_REINIT;
164         
165         vlc_mutex_unlock( &p_input->stream.stream_lock );
166         
167         input_ClockManageControl( p_input, p_pgrm, 0 );
168     }
169
170     return i_data_nb;
171 }
172