summary |
shortlog |
log |
commit | commitdiff |
tree
raw |
patch |
inline | side by side (from parent 1:
17d2533)
It was only a copy of mmd->afd.afhi, so make all users use the
latter directly.
"%s:%s\n" "%s:%lu.%lu\n" "%s:%lu.%lu\n",
status_item_list[SI_FILE_SIZE], nmmd->size / 1024,
status_item_list[SI_MTIME], mtime,
"%s:%s\n" "%s:%lu.%lu\n" "%s:%lu.%lu\n",
status_item_list[SI_FILE_SIZE], nmmd->size / 1024,
status_item_list[SI_MTIME], mtime,
- status_item_list[SI_LENGTH], nmmd->afi.seconds_total,
+ status_item_list[SI_LENGTH], nmmd->afd.afhi.seconds_total,
status_item_list[SI_NUM_PLAYED], nmmd->num_played,
status_item_list[SI_STATUS_BAR], bar ? bar : "(none)",
status_item_list[SI_NUM_PLAYED], nmmd->num_played,
status_item_list[SI_STATUS_BAR], bar ? bar : "(none)",
status_item_list[SI_OFFSET], offset,
status_item_list[SI_FORMAT], audio_format_name(nmmd->audio_format),
status_item_list[SI_AFS_MODE], mmd->afs_mode_string,
status_item_list[SI_OFFSET], offset,
status_item_list[SI_FORMAT], audio_format_name(nmmd->audio_format),
status_item_list[SI_AFS_MODE], mmd->afs_mode_string,
+ nmmd->afd.afhi.info_string,
status_item_list[SI_UPTIME], ut,
status_item_list[SI_STREAM_START],
status_item_list[SI_UPTIME], ut,
status_item_list[SI_STREAM_START],
backwards = 1; /* jmp backwards */
mmd_lock();
ret = -E_NO_AUDIO_FILE;
backwards = 1; /* jmp backwards */
mmd_lock();
ret = -E_NO_AUDIO_FILE;
- if (!mmd->afi.chunks_total || !mmd->afi.seconds_total)
+ if (!mmd->afd.afhi.chunks_total || !mmd->afd.afhi.seconds_total)
- promille = (1000 * mmd->current_chunk) / mmd->afi.chunks_total;
+ promille = (1000 * mmd->current_chunk) / mmd->afd.afhi.chunks_total;
- promille -= 1000 * i / mmd->afi.seconds_total;
+ promille -= 1000 * i / mmd->afd.afhi.seconds_total;
- promille += 1000 * i / mmd->afi.seconds_total;
+ promille += 1000 * i / mmd->afd.afhi.seconds_total;
if (promille < 0)
promille = 0;
if (promille > 1000) {
mmd->new_vss_status_flags |= VSS_NEXT;
goto out;
}
if (promille < 0)
promille = 0;
if (promille > 1000) {
mmd->new_vss_status_flags |= VSS_NEXT;
goto out;
}
- mmd->repos_request = (mmd->afi.chunks_total * promille) / 1000;
+ mmd->repos_request = (mmd->afd.afhi.chunks_total * promille) / 1000;
mmd->new_vss_status_flags |= VSS_REPOS;
mmd->new_vss_status_flags &= ~VSS_NEXT;
mmd->events++;
mmd->new_vss_status_flags |= VSS_REPOS;
mmd->new_vss_status_flags &= ~VSS_NEXT;
mmd->events++;
return -E_COMMAND_SYNTAX;
mmd_lock();
ret = -E_NO_AUDIO_FILE;
return -E_COMMAND_SYNTAX;
mmd_lock();
ret = -E_NO_AUDIO_FILE;
- if (!mmd->afi.chunks_total)
+ if (!mmd->afd.afhi.chunks_total)
goto out;
if (i > 100)
i = 100;
PARA_INFO_LOG("jumping to %lu%%\n", i);
goto out;
if (i > 100)
i = 100;
PARA_INFO_LOG("jumping to %lu%%\n", i);
- mmd->repos_request = (mmd->afi.chunks_total * i + 50)/ 100;
+ mmd->repos_request = (mmd->afd.afhi.chunks_total * i + 50)/ 100;
PARA_INFO_LOG("sent: %lu, offset before jmp: %lu\n",
mmd->chunks_sent, mmd->offset);
mmd->new_vss_status_flags |= VSS_REPOS;
PARA_INFO_LOG("sent: %lu, offset before jmp: %lu\n",
mmd->chunks_sent, mmd->offset);
mmd->new_vss_status_flags |= VSS_REPOS;
- * used for parent-child communication
+ * Used for parent-child communication.
*
* There's only one struct of this type which lives in shared memory
* for communication between the server instances. Access to this
*
* There's only one struct of this type which lives in shared memory
* for communication between the server instances. Access to this
* date.
*/
struct misc_meta_data {
* date.
*/
struct misc_meta_data {
- /** information on the current audio file */
- struct audio_format_info afi;
/** the size of the current audio file in bytes */
size_t size;
/** the full path of the current audio file */
/** the size of the current audio file in bytes */
size_t size;
/** the full path of the current audio file */
int selector_change;
/** used by the sender command */
struct sender_command_data sender_cmd_data;
int selector_change;
/** used by the sender command */
struct sender_command_data sender_cmd_data;
+ /** Describes the current audio file. */
struct audio_file_data afd;
};
struct audio_file_data afd;
};
- tv_scale(mmd->chunks_sent, &mmd->afi.chunk_tv, &tmp);
+ tv_scale(mmd->chunks_sent, &mmd->afd.afhi.chunk_tv, &tmp);
tv_add(&tmp, &mmd->stream_start, due);
}
tv_add(&tmp, &mmd->stream_start, due);
}
return;
}
gettimeofday(&now, NULL);
return;
}
gettimeofday(&now, NULL);
- tv_add(&mmd->afi.eof_tv, &now, &eof_barrier);
+ tv_add(&mmd->afd.afhi.eof_tv, &now, &eof_barrier);
munmap(map, mmd->size);
map = NULL;
mmd->audio_format = -1;
mmd->chunks_sent = 0;
mmd->offset = 0;
munmap(map, mmd->size);
map = NULL;
mmd->audio_format = -1;
mmd->chunks_sent = 0;
mmd->offset = 0;
- mmd->afi.seconds_total = 0;
- free(mmd->afi.chunk_table);
- mmd->afi.chunk_table = NULL;
+ mmd->afd.afhi.seconds_total = 0;
+ free(mmd->afd.afhi.chunk_table);
+ mmd->afd.afhi.chunk_table = NULL;
tmp = make_message("%s:\n%s:\n%s:\n", status_item_list[SI_AUDIO_INFO1],
status_item_list[SI_AUDIO_INFO2], status_item_list[SI_AUDIO_INFO3]);
tmp = make_message("%s:\n%s:\n%s:\n", status_item_list[SI_AUDIO_INFO1],
status_item_list[SI_AUDIO_INFO2], status_item_list[SI_AUDIO_INFO3]);
- strcpy(mmd->afi.info_string, tmp);
+ strcpy(mmd->afd.afhi.info_string, tmp);
free(tmp);
mmd->filename[0] = '\0';
mmd->size = 0;
free(tmp);
mmd->filename[0] = '\0';
mmd->size = 0;
*/
char *vss_get_header(size_t *header_len)
{
*/
char *vss_get_header(size_t *header_len)
{
- if (mmd->audio_format < 0 || !map || !mmd->afi.header_len)
+ if (mmd->audio_format < 0 || !map || !mmd->afd.afhi.header_len)
- *header_len = mmd->afi.header_len;
- return map + mmd->afi.header_offset;
+ *header_len = mmd->afd.afhi.header_len;
+ return map + mmd->afd.afhi.header_offset;
{
if (mmd->audio_format < 0)
return NULL;
{
if (mmd->audio_format < 0)
return NULL;
- return &mmd->afi.chunk_tv;
+ return &mmd->afd.afhi.chunk_tv;
}
enum afs_socket_status {
}
enum afs_socket_status {
struct timeval now;
gettimeofday(&now, NULL);
if (!vss_paused() || mmd->chunks_sent)
struct timeval now;
gettimeofday(&now, NULL);
if (!vss_paused() || mmd->chunks_sent)
- tv_add(&mmd->afi.eof_tv, &now, &eof_barrier);
+ tv_add(&mmd->afd.afhi.eof_tv, &now, &eof_barrier);
if (vss_repos())
tv_add(&now, &announce_tv, &data_send_barrier);
if (mmd->new_vss_status_flags & VSS_NOMORE)
if (vss_repos())
tv_add(&now, &announce_tv, &data_send_barrier);
if (mmd->new_vss_status_flags & VSS_NOMORE)
passed_fd, 0);
close(passed_fd);
strcpy(mmd->filename, mmd->afd.path); /* FIXME: check length */
passed_fd, 0);
close(passed_fd);
strcpy(mmd->filename, mmd->afd.path); /* FIXME: check length */
- mmd->afi.header_len = 0; /* default: no header */
+ mmd->afd.afhi.header_len = 0; /* default: no header */
mmd->audio_format = mmd->afd.afsi.audio_format_id;
mmd->chunks_sent = 0;
mmd->current_chunk = 0;
mmd->offset = 0;
mmd->events++;
mmd->num_played++;
mmd->audio_format = mmd->afd.afsi.audio_format_id;
mmd->chunks_sent = 0;
mmd->current_chunk = 0;
mmd->offset = 0;
mmd->events++;
mmd->num_played++;
- mmd->afi = mmd->afd.afhi;
mmd->new_vss_status_flags &= (~VSS_NEXT);
gettimeofday(&now, NULL);
tv_add(&now, &announce_tv, &data_send_barrier);
mmd->new_vss_status_flags &= (~VSS_NEXT);
gettimeofday(&now, NULL);
tv_add(&now, &announce_tv, &data_send_barrier);
static void get_chunk(long unsigned chunk_num, char **buf, size_t *len)
{
static void get_chunk(long unsigned chunk_num, char **buf, size_t *len)
{
- size_t pos = mmd->afi.chunk_table[chunk_num];
+ size_t pos = mmd->afd.afhi.chunk_table[chunk_num];
- *len = mmd->afi.chunk_table[chunk_num + 1] - pos;
+ *len = mmd->afd.afhi.chunk_table[chunk_num + 1] - pos;
if (chunk_num + 5 > mmd->afd.afhi.chunks_total)
PARA_NOTICE_LOG("chunk %lu/%lu\n, len: %zu\n", chunk_num,
if (chunk_num + 5 > mmd->afd.afhi.chunks_total)
PARA_NOTICE_LOG("chunk %lu/%lu\n, len: %zu\n", chunk_num,
{
if (mmd->audio_format < 0 || !map || !vss_playing())
return -E_CHUNK;
{
if (mmd->audio_format < 0 || !map || !vss_playing())
return -E_CHUNK;
- if (chunk_num >= mmd->afi.chunks_total)
+ if (chunk_num >= mmd->afd.afhi.chunks_total)
return -E_CHUNK;
get_chunk(chunk_num, buf, len);
return 1;
return -E_CHUNK;
get_chunk(chunk_num, buf, len);
return 1;
&due, 1) < 0)
return;
mmd->new_vss_status_flags &= ~VSS_REPOS;
&due, 1) < 0)
return;
mmd->new_vss_status_flags &= ~VSS_REPOS;
- if (mmd->current_chunk >= mmd->afi.chunks_total) { /* eof */
+ if (mmd->current_chunk >= mmd->afd.afhi.chunks_total) { /* eof */
mmd->new_vss_status_flags |= VSS_NEXT;
return vss_eof();
}
mmd->new_vss_status_flags |= VSS_NEXT;
return vss_eof();
}
if (!mmd->chunks_sent) {
struct timeval tmp;
gettimeofday(&mmd->stream_start, NULL);
if (!mmd->chunks_sent) {
struct timeval tmp;
gettimeofday(&mmd->stream_start, NULL);
- tv_scale(mmd->current_chunk, &mmd->afi.chunk_tv, &tmp);
+ tv_scale(mmd->current_chunk, &mmd->afd.afhi.chunk_tv, &tmp);
mmd->offset = tv2ms(&tmp);
mmd->events++;
}
mmd->offset = tv2ms(&tmp);
mmd->events++;
}