From 2b471378b49c04db7bb84d1e75db981f91ad93db Mon Sep 17 00:00:00 2001 From: Andre Noll Date: Sat, 12 Apr 2008 14:12:19 +0200 Subject: [PATCH] Introduce the vss task. --- vss.c | 73 ++++++++++++++++++++++++++++++----------------------------- 1 file changed, 37 insertions(+), 36 deletions(-) diff --git a/vss.c b/vss.c index 7b84dcf5..98965efd 100644 --- a/vss.c +++ b/vss.c @@ -30,11 +30,6 @@ #include "ipc.h" #include "fd.h" -static struct timeval announce_tv; -static struct timeval data_send_barrier; -static struct timeval eof_barrier; -static struct timeval autoplay_barrier; - extern struct misc_meta_data *mmd; extern void dccp_send_init(struct sender *); @@ -62,10 +57,28 @@ struct sender senders[] = { } }; - +/** The possible states of the afs socket. See \ref afs_socket. */ +enum afs_socket_status { + /** Socket is inactive. */ + AFS_SOCKET_READY, + /** Socket fd was included in the write fd set for select(). */ + AFS_SOCKET_CHECK_FOR_WRITE, + /** vss wrote a request to the socket and waits for afs to reply. */ + AFS_SOCKET_AFD_PENDING +}; static char *map; +struct vss_task { + struct timeval announce_tv; + struct timeval data_send_barrier; + struct timeval eof_barrier; + struct timeval autoplay_barrier; + enum afs_socket_status afsss; +}; + +static struct vss_task vss_task_struct, *vsst = &vss_task_struct; + /** * Check if vss status flag \a P (playing) is set. * @@ -156,8 +169,8 @@ void vss_init(void) conf.announce_time_arg : 300, autoplay_delay = conf.autoplay_delay_arg > 0? conf.autoplay_delay_arg : 0; - ms2tv(announce_time, &announce_tv); - PARA_INFO_LOG("announce timeval: %lums\n", tv2ms(&announce_tv)); + ms2tv(announce_time, &vsst->announce_tv); + PARA_INFO_LOG("announce timeval: %lums\n", tv2ms(&vsst->announce_tv)); for (i = 0; senders[i].name; i++) { PARA_NOTICE_LOG("initializing %s sender\n", senders[i].name); senders[i].init(&senders[i]); @@ -171,7 +184,7 @@ void vss_init(void) mmd->new_vss_status_flags |= VSS_PLAYING; gettimeofday(&now, NULL); ms2tv(autoplay_delay, &tmp); - tv_add(&now, &tmp, &autoplay_barrier); + tv_add(&now, &tmp, &vsst->autoplay_barrier); } } @@ -205,12 +218,12 @@ static struct timeval *vss_compute_timeout(void) return &the_timeout; } gettimeofday(&now, NULL); - if (chk_barrier("autoplay_delay", &now, &autoplay_barrier, + if (chk_barrier("autoplay_delay", &now, &vsst->autoplay_barrier, &the_timeout, 1) < 0) return &the_timeout; - if (chk_barrier("eof", &now, &eof_barrier, &the_timeout, 1) < 0) + if (chk_barrier("eof", &now, &vsst->eof_barrier, &the_timeout, 1) < 0) return &the_timeout; - if (chk_barrier("data send", &now, &data_send_barrier, + if (chk_barrier("data send", &now, &vsst->data_send_barrier, &the_timeout, 1) < 0) return &the_timeout; if (!vss_playing() || !map) @@ -235,7 +248,7 @@ static void vss_eof(void) if (mmd->new_vss_status_flags & VSS_NOMORE) mmd->new_vss_status_flags = VSS_NEXT; gettimeofday(&now, NULL); - tv_add(&mmd->afd.afhi.eof_tv, &now, &eof_barrier); + tv_add(&mmd->afd.afhi.eof_tv, &now, &vsst->eof_barrier); para_munmap(map, mmd->size); map = NULL; mmd->chunks_sent = 0; @@ -292,18 +305,6 @@ struct timeval *vss_chunk_time(void) return &mmd->afd.afhi.chunk_tv; } -/** The possible states of the afs socket. See \ref afs_socket. */ -enum afs_socket_status { - /** Socket is inactive. */ - AFS_SOCKET_READY, - /** Socket fd was included in the write fd set for select(). */ - AFS_SOCKET_CHECK_FOR_WRITE, - /** vss wrote a request to the socket and waits for afs to reply. */ - AFS_SOCKET_AFD_PENDING -}; - -static enum afs_socket_status afsss; - static int need_to_request_new_audio_file(void) { if (map) /* have audio file */ @@ -312,7 +313,7 @@ static int need_to_request_new_audio_file(void) return 0; if (mmd->new_vss_status_flags & VSS_NOMORE) return 0; - if (afsss == AFS_SOCKET_AFD_PENDING) /* already requested one */ + if (vsst->afsss == AFS_SOCKET_AFD_PENDING) /* already requested one */ return 0; return 1; } @@ -351,13 +352,13 @@ struct timeval *vss_preselect(fd_set *rfds, fd_set *wfds, int *max_fileno) else if (vss_paused()) { if (mmd->chunks_sent) { gettimeofday(&now, NULL); - tv_add(&mmd->afd.afhi.eof_tv, &now, &eof_barrier); + tv_add(&mmd->afd.afhi.eof_tv, &now, &vsst->eof_barrier); } mmd->chunks_sent = 0; } else if (vss_repos()) { gettimeofday(&now, NULL); - tv_add(&now, &announce_tv, &data_send_barrier); - tv_add(&mmd->afd.afhi.eof_tv, &now, &eof_barrier); + tv_add(&now, &vsst->announce_tv, &vsst->data_send_barrier); + tv_add(&mmd->afd.afhi.eof_tv, &now, &vsst->eof_barrier); mmd->chunks_sent = 0; mmd->current_chunk = mmd->repos_request; mmd->new_vss_status_flags &= ~VSS_REPOS; @@ -366,7 +367,7 @@ struct timeval *vss_preselect(fd_set *rfds, fd_set *wfds, int *max_fileno) if (need_to_request_new_audio_file()) { PARA_DEBUG_LOG("ready and playing, but no audio file\n"); para_fd_set(afs_socket, wfds, max_fileno); - afsss = AFS_SOCKET_CHECK_FOR_WRITE; + vsst->afsss = AFS_SOCKET_CHECK_FOR_WRITE; } else para_fd_set(afs_socket, rfds, max_fileno); for (i = 0; senders[i].name; i++) { @@ -396,7 +397,7 @@ static int recv_afs_msg(int *fd, uint32_t *code, uint32_t *data) ret = recvmsg(afs_socket, &msg, 0); if (ret < 0) return -ERRNO_TO_PARA_ERROR(errno); - afsss = AFS_SOCKET_READY; + vsst->afsss = AFS_SOCKET_READY; if (iov.iov_len != sizeof(buf)) return -E_AFS_SHORT_READ; *code = *(uint32_t*)buf; @@ -453,7 +454,7 @@ static void recv_afs_result(void) mmd->num_played++; mmd->new_vss_status_flags &= (~VSS_NEXT); gettimeofday(&now, NULL); - tv_add(&now, &announce_tv, &data_send_barrier); + tv_add(&now, &vsst->announce_tv, &vsst->data_send_barrier); return; err: free(mmd->afd.afhi.chunk_table); @@ -486,9 +487,9 @@ static void vss_send_chunk(void) &mmd->stream_start, &due); if (tv_diff(&due, &now, NULL) > 0) return; - if (chk_barrier("eof", &now, &eof_barrier, &due, 1) < 0) + if (chk_barrier("eof", &now, &vsst->eof_barrier, &due, 1) < 0) return; - if (chk_barrier("data send", &now, &data_send_barrier, + if (chk_barrier("data send", &now, &vsst->data_send_barrier, &due, 1) < 0) return; mmd->new_vss_status_flags &= ~VSS_REPOS; @@ -527,13 +528,13 @@ void vss_post_select(fd_set *rfds, fd_set *wfds) senders[s].client_cmds[num](&mmd->sender_cmd_data); mmd->sender_cmd_data.cmd_num = -1; } - if (afsss != AFS_SOCKET_CHECK_FOR_WRITE) { + if (vsst->afsss != AFS_SOCKET_CHECK_FOR_WRITE) { if (FD_ISSET(afs_socket, rfds)) recv_afs_result(); } else if (FD_ISSET(afs_socket, wfds)) { PARA_NOTICE_LOG("requesting new fd from afs\n"); ret = send_buffer(afs_socket, "new"); - afsss = AFS_SOCKET_AFD_PENDING; + vsst->afsss = AFS_SOCKET_AFD_PENDING; } for (i = 0; senders[i].name; i++) { if (!senders[i].post_select) -- 2.39.5