2 * Copyright (C) 2004-2011 Andre Noll <maan@systemlinux.org>
4 * Licensed under the GPL v2. For licencing details see COPYING.
7 /** \file ogg_afh_common.c Functions common to ogg/vorbis and ogg/speex. */
16 #include "ogg_afh_common.h"
19 /* Taken from decoder_example.c of libvorbis-1.2.3. */
20 static int process_packets_2_and_3(ogg_sync_state
*oss
,
21 ogg_stream_state
*stream
, struct afh_info
*afhi
,
22 struct ogg_afh_callback_info
*ci
)
30 int ret
= ogg_sync_pageout(oss
, &page
);
32 break; /* Need more data */
36 * We can ignore any errors here as they'll also become
37 * apparent at packetout.
39 ogg_stream_pagein(stream
, &page
);
40 PARA_INFO_LOG("ogg page serial: %d\n",
41 ogg_page_serialno(&page
));
43 ret
= ogg_stream_packetout(stream
, &packet
);
47 return -E_STREAM_PACKETOUT
;
48 ret
= ci
->packet_callback(&packet
, i
+ 1,
49 ogg_page_serialno(&page
), afhi
,
53 if (ret
== 0) /* header complete */
62 static int process_ogg_packets(ogg_sync_state
*oss
, struct afh_info
*afhi
,
63 struct ogg_afh_callback_info
*ci
)
66 ogg_stream_state stream
;
70 if (ogg_sync_pageout(oss
, &page
) != 1)
71 return -E_SYNC_PAGEOUT
;
73 ret
= ogg_page_serialno(&page
);
74 ogg_stream_init(&stream
, ret
);
76 ret
= -E_STREAM_PAGEIN
;
77 if (ogg_stream_pagein(&stream
, &page
) < 0)
80 ret
= -E_STREAM_PACKETOUT
;
81 if (ogg_stream_packetout(&stream
, &packet
) != 1)
83 ret
= ci
->packet_callback(&packet
, 0, ogg_page_serialno(&page
),
84 afhi
, ci
->private_data
);
87 ret
= process_packets_2_and_3(oss
, &stream
, afhi
, ci
);
92 ogg_stream_clear(&stream
);
96 static void set_chunk_tv(int num_frames
, int num_chunks
, int frequency
,
97 struct timeval
*result
)
99 uint64_t x
= (uint64_t)num_frames
* 1000 * 1000
100 / frequency
/ num_chunks
;
102 result
->tv_sec
= x
/ 1000 / 1000;
103 result
->tv_usec
= x
% (1000 * 1000);
104 PARA_INFO_LOG("%d chunks, chunk time: %lums\n", num_chunks
,
109 * Pass first three ogg packets to callback and build the chunk table.
111 * This function extracts the first three ogg packets of the audio data
112 * given by \a map and \a numbytes and passes each packet to the callback
115 * If the packet callback indicates success and \a afhi is not \p NULL, the
116 * chunk table is built. Chunk zero contains the first three ogg packets while
117 * all other chunks consist of exactly one ogg page.
119 * \param map Audio file data.
120 * \param numbytes The length of \a map.
121 * \param afhi Passed to the packet callback, contains chunk table.
122 * \param ci The callback structure.
126 int ogg_get_file_info(char *map
, size_t numbytes
, struct afh_info
*afhi
,
127 struct ogg_afh_callback_info
*ci
)
133 int ret
, i
, j
, frames_per_chunk
, ct_size
;
134 long long unsigned num_frames
= 0;
138 buf
= ogg_sync_buffer(&oss
, len
);
141 memcpy(buf
, map
, len
);
143 if (ogg_sync_wrote(&oss
, len
) < 0)
145 ret
= process_ogg_packets(&oss
, afhi
, ci
);
150 afhi
->header_len
= oss
.returned
;
153 /* count ogg packages and get duration of the file */
154 for (i
= 0; ogg_sync_pageseek(&oss
, &op
) > 0; i
++)
155 num_frames
= ogg_page_granulepos(&op
);
156 PARA_INFO_LOG("%d pages, %llu frames\n", i
, num_frames
);
160 afhi
->seconds_total
= num_frames
/ afhi
->frequency
;
161 /* use roughly one page per chunk */
162 frames_per_chunk
= num_frames
/ i
;
163 PARA_INFO_LOG("%lu seconds, %d frames/chunk\n",
164 afhi
->seconds_total
, frames_per_chunk
);
166 afhi
->chunk_table
= para_malloc(ct_size
* sizeof(uint32_t));
167 afhi
->chunk_table
[0] = 0;
168 afhi
->chunk_table
[1] = afhi
->header_len
;
169 oss
.returned
= afhi
->header_len
;
171 for (j
= 1; ogg_sync_pageseek(&oss
, &op
) > 0; /* nothing */) {
172 int granule
= ogg_page_granulepos(&op
);
174 while (granule
> j
* frames_per_chunk
) {
178 afhi
->chunk_table
= para_realloc(
180 ct_size
* sizeof(uint32_t));
182 afhi
->chunk_table
[j
] = oss
.returned
;
185 afhi
->chunks_total
= j
;
186 set_chunk_tv(num_frames
, j
, afhi
->frequency
, &afhi
->chunk_tv
);
189 ogg_sync_clear(&oss
);