2 * Copyright (C) 2004-2010 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
);
41 ret
= ogg_stream_packetout(stream
, &packet
);
45 return -E_STREAM_PACKETOUT
;
46 ret
= ci
->packet_callback(&packet
, i
+ 1, afhi
,
50 if (ret
== 0) /* header complete */
59 static int process_ogg_packets(ogg_sync_state
*oss
, struct afh_info
*afhi
,
60 struct ogg_afh_callback_info
*ci
)
63 ogg_stream_state stream
;
67 ret
= -E_SYNC_PAGEOUT
;
68 if (ogg_sync_pageout(oss
, &page
) != 1)
71 ret
= ogg_page_serialno(&page
);
72 ogg_stream_init(&stream
, ret
);
74 ret
= -E_STREAM_PAGEIN
;
75 if (ogg_stream_pagein(&stream
, &page
) < 0)
78 ret
= -E_STREAM_PACKETOUT
;
79 if (ogg_stream_packetout(&stream
, &packet
) != 1)
81 ret
= ci
->packet_callback(&packet
, 0, afhi
, ci
->private_data
);
84 ret
= process_packets_2_and_3(oss
, &stream
, afhi
, ci
);
87 afhi
->header_offset
= 0;
88 afhi
->header_len
= oss
->returned
;
91 ogg_stream_clear(&stream
);
95 static void set_chunk_tv(int num_frames
, int num_chunks
, int frequency
,
96 struct timeval
*result
)
98 uint64_t x
= (uint64_t)num_frames
* 1000 * 1000
99 / frequency
/ num_chunks
;
101 result
->tv_sec
= x
/ 1000 / 1000;
102 result
->tv_usec
= x
% (1000 * 1000);
103 PARA_INFO_LOG("%d chunks, chunk time: %lums\n", num_chunks
,
108 * Pass first three ogg packets to callback and build the chunk table.
110 * This function extracts the first three ogg packets of the audio data
111 * given by \a map and \a numbytes and passes each packet to the callback
114 * If the packet callback indicates success, the chunk table is built. Chunk
115 * zero contains the first three ogg packets while all other chunks consist of
116 * exactly one ogg page.
118 * \param map Audio file data.
119 * \param numbytes The length of \a map.
120 * \param afhi Passed to the packet callback, contains chunk table.
121 * \param ci The callback structure.
125 int ogg_get_file_info(char *map
, size_t numbytes
, struct afh_info
*afhi
,
126 struct ogg_afh_callback_info
*ci
)
132 int ret
, i
, j
, frames_per_chunk
, ct_size
;
133 long long unsigned num_frames
= 0;
137 buf
= ogg_sync_buffer(&oss
, len
);
140 memcpy(buf
, map
, len
);
142 if (ogg_sync_wrote(&oss
, len
) < 0)
144 ret
= process_ogg_packets(&oss
, afhi
, ci
);
149 /* count ogg packages and get duration of the file */
150 for (i
= 0; ogg_sync_pageseek(&oss
, &op
) > 0; i
++)
151 num_frames
= ogg_page_granulepos(&op
);
152 PARA_INFO_LOG("%d pages, %llu frames\n", i
, num_frames
);
156 afhi
->seconds_total
= num_frames
/ afhi
->frequency
;
157 /* use roughly one page per chunk */
158 frames_per_chunk
= num_frames
/ i
;
159 PARA_INFO_LOG("%lu seconds, %d frames/chunk\n",
160 afhi
->seconds_total
, frames_per_chunk
);
162 afhi
->chunk_table
= para_malloc(ct_size
* sizeof(uint32_t));
163 afhi
->chunk_table
[0] = 0;
164 afhi
->chunk_table
[1] = afhi
->header_len
;
165 oss
.returned
= afhi
->header_len
;
167 for (i
= 0, j
= 1; ogg_sync_pageseek(&oss
, &op
) > 0; i
++) {
168 int granule
= ogg_page_granulepos(&op
);
170 while (granule
> j
* frames_per_chunk
) {
174 afhi
->chunk_table
= para_realloc(
176 ct_size
* sizeof(uint32_t));
178 afhi
->chunk_table
[j
] = oss
.returned
;
181 afhi
->chunks_total
= j
;
182 set_chunk_tv(num_frames
, j
, afhi
->frequency
, &afhi
->chunk_tv
);
185 ogg_sync_clear(&oss
);