Mercurial > mplayer.hg
view libao2/ao_nas.c @ 7668:76bd62c375e8
remove nonsense warnings now that libaf is used
author | rfelker |
---|---|
date | Tue, 08 Oct 2002 22:41:45 +0000 |
parents | 0761d6ac7ce9 |
children | 328bbac6224c |
line wrap: on
line source
/* * NAS output plugin for mplayer * * based on the libaudiooss parts rewritten by me, which were * originally based on the NAS output plugin for xmms. * * xmms plugin by Willem Monsuwe * adapted for libaudiooss by Jon Trulson * further modified by Erik Inge Bolsų * largely rewritten and used for this * plugin by Tobias Diedrich * * Theory of operation: * * The NAS consists of two parts, a server daemon and a client. * We setup the server to use a buffer of size NAS_BUFFER_SIZE * with a low watermark of NAS_BUFFER_SIZE - NAS_FRAG_SIZE. * Upon starting the flow the server will generate a buffer underrun * event and the event handler will fill the buffer for the first time. * Now the server will generate a lowwater event when the server buffer * falls below the low watermark value. The event handler gets called * again and refills the buffer by the number of bytes requested by the * server (usually a multiple of 4096). To prevent stuttering on * startup (start of playing, seeks, unpausing) the client buffer should * be bigger than the server buffer. (For debugging we also do some * accounting of what we think how much of the server buffer is filled) */ #include <stdio.h> #include <stdlib.h> #include <pthread.h> #include <audio/audiolib.h> #include "../mp_msg.h" #include "audio_out.h" #include "audio_out_internal.h" #include "afmt.h" #define NAS_FRAG_SIZE 4096 #define NAS_FRAG_COUNT 8 #define NAS_BUFFER_SIZE NAS_FRAG_SIZE * NAS_FRAG_COUNT static char *nas_event_types[] = { "Undefined", "Undefined", "ElementNotify", "GrabNotify", "MonitorNotify", "BucketNotify", "DeviceNotify" }; static char *nas_elementnotify_kinds[] = { "LowWater", "HighWater", "State", "Unknown" }; static char *nas_states[] = { "Stop", "Start", "Pause", "Any" }; static char *nas_reasons[] = { "User", "Underrun", "Overrun", "EOF", "Watermark", "Hardware", "Any" }; static char* nas_reason(unsigned int reason) { if (reason > 6) reason = 6; return nas_reasons[reason]; } static char* nas_elementnotify_kind(unsigned int kind) { if (kind > 2) kind = 3; return nas_elementnotify_kinds[kind]; } static char* nas_event_type(unsigned int type) { if (type > 6) type = 0; return nas_event_types[type]; } static char* nas_state(unsigned int state) { if (state>3) state = 3; return nas_states[state]; } static ao_info_t info = { "NAS audio output", "nas", "Tobias Diedrich", "" }; struct ao_nas_data { AuServer *aud; AuFlowID flow; AuDeviceID dev; int flow_stopped; int flow_paused; int expect_underrun; void *client_buffer; void *server_buffer; int client_buffer_size; int client_buffer_used; int server_buffer_size; int server_buffer_used; pthread_mutex_t buffer_mutex; pthread_t event_thread; int stop_thread; }; static struct ao_nas_data *nas_data; LIBAO_EXTERN(nas) static void nas_print_error(AuServer *aud, char *prefix, AuStatus as) { char s[100]; AuGetErrorText(aud, as, s, 100); mp_msg(MSGT_AO, MSGL_ERR, "ao_nas: %s: returned status %d (%s)\n", prefix, as, s); } static int nas_readBuffer(struct ao_nas_data *nas_data, int num) { AuStatus as; pthread_mutex_lock(&nas_data->buffer_mutex); mp_msg(MSGT_AO, MSGL_DBG2, "ao_nas: nas_readBuffer(): num=%d client=%d/%d server=%d/%d\n", num, nas_data->client_buffer_used, nas_data->client_buffer_size, nas_data->server_buffer_used, nas_data->server_buffer_size); if (nas_data->client_buffer_used == 0) { mp_msg(MSGT_AO, MSGL_DBG2, "ao_nas: buffer is empty, nothing read.\n"); pthread_mutex_unlock(&nas_data->buffer_mutex); return 0; } if (nas_data->client_buffer_used < num) num = nas_data->client_buffer_used; /* * It is not appropriate to call AuWriteElement() here because the * buffer is locked and delays writing to the network will cause * other threads to block waiting for buffer_mutex. Instead the * data is copied to "server_buffer" and written it to the network * outside of the locked section of code. * * (Note: Rather than these two buffers, a single circular buffer * could eliminate the memcpy/memmove steps.) */ memcpy(nas_data->server_buffer, nas_data->client_buffer, num); nas_data->client_buffer_used -= num; nas_data->server_buffer_used += num; memmove(nas_data->client_buffer, nas_data->client_buffer + num, nas_data->client_buffer_used); pthread_mutex_unlock(&nas_data->buffer_mutex); /* * Now write the new buffer to the network. */ AuWriteElement(nas_data->aud, nas_data->flow, 0, num, nas_data->server_buffer, AuFalse, &as); if (as != AuSuccess) nas_print_error(nas_data->aud, "nas_readBuffer(): AuWriteElement", as); if (nas_data->flow_paused) { AuPauseFlow(nas_data->aud, nas_data->flow, &as); if (as != AuSuccess) nas_print_error(nas_data->aud, "nas_readBuffer(): AuPauseFlow", as); } return num; } static void nas_writeBuffer(struct ao_nas_data *nas_data, void *data, int len) { pthread_mutex_lock(&nas_data->buffer_mutex); mp_msg(MSGT_AO, MSGL_DBG2, "ao_nas: nas_writeBuffer(): len=%d client=%d/%d server=%d/%d\n", len, nas_data->client_buffer_used, nas_data->client_buffer_size, nas_data->server_buffer_used, nas_data->server_buffer_size); memcpy(nas_data->client_buffer + nas_data->client_buffer_used, data, len); nas_data->client_buffer_used += len; pthread_mutex_unlock(&nas_data->buffer_mutex); } static int nas_empty_event_queue(struct ao_nas_data *nas_data) { AuEvent ev; int result = 0; while (AuScanForTypedEvent(nas_data->aud, AuEventsQueuedAfterFlush, AuTrue, AuEventTypeElementNotify, &ev)) { AuDispatchEvent(nas_data->aud, &ev); result = 1; } return result; } static void *nas_event_thread_start(void *data) { struct ao_nas_data *nas_data = data; AuEvent ev; AuBool result; do { nas_empty_event_queue(nas_data); usleep(10000); } while (!nas_data->stop_thread); } static AuBool nas_error_handler(AuServer* aud, AuErrorEvent* ev) { char s[100]; AuGetErrorText(aud, ev->error_code, s, 100); mp_msg(MSGT_AO, MSGL_ERR, "ao_nas: error [%s]\n" "error_code: %d\n" "request_code: %d\n" "minor_code: %d\n", s, ev->error_code, ev->request_code, ev->minor_code); return AuTrue; } static AuBool nas_event_handler(AuServer *aud, AuEvent *ev, AuEventHandlerRec *hnd) { AuElementNotifyEvent *event = (AuElementNotifyEvent *) ev; AuStatus as; struct ao_nas_data *nas_data = hnd->data; switch (ev->type) { case AuEventTypeElementNotify: mp_msg(MSGT_AO, MSGL_DBG2, "ao_nas: event_handler(): kind %s state %s->%s reason %s numbytes %d expect_underrun %d\n", nas_elementnotify_kind(event->kind), nas_state(event->prev_state), nas_state(event->cur_state), nas_reason(event->reason), event->num_bytes, nas_data->expect_underrun); nas_data->server_buffer_used -= event->num_bytes; if (nas_data->server_buffer_used < 0) nas_data->server_buffer_used = 0; switch (event->kind) { case AuElementNotifyKindLowWater: nas_readBuffer(nas_data, event->num_bytes); break; case AuElementNotifyKindState: if (event->cur_state == AuStatePause) { switch (event->reason) { case AuReasonUnderrun: // buffer underrun -> refill buffer if (nas_data->expect_underrun) nas_data->expect_underrun = 0; else { mp_msg(MSGT_AO, MSGL_WARN, "ao_nas: Buffer underrun.\n"); mp_msg(MSGT_AO, MSGL_HINT, "Possible reasons are network congestion or your NAS server is too slow.\n" "Try renicing your nasd to e.g. -15.\n"); } nas_data->server_buffer_used = 0; if (nas_readBuffer(nas_data, nas_data->server_buffer_size - nas_data->server_buffer_used) == 0) nas_data->flow_stopped = 1; break; default: break; } } break; default: // silently ignored break; } break; default: mp_msg(MSGT_AO, MSGL_WARN, "ao_nas: nas_event_handler(): unhandled event type %d\n", ev->type); break; } return AuTrue; } static AuDeviceID nas_find_device(AuServer *aud, int nch) { int i; for (i = 0; i < AuServerNumDevices(aud); i++) { AuDeviceAttributes *dev = AuServerDevice(aud, i); if ((AuDeviceKind(dev) == AuComponentKindPhysicalOutput) && AuDeviceNumTracks(dev) == nch) { return AuDeviceIdentifier(dev); } } return AuNone; } static unsigned int nas_aformat_to_auformat(unsigned int format) { unsigned int res=format << 8; switch (format) { case AFMT_U8: return res + AuFormatLinearUnsigned8; case AFMT_S8: return res + AuFormatLinearSigned8; case AFMT_U16_LE: return res + AuFormatLinearUnsigned16LSB; case AFMT_U16_BE: return res + AuFormatLinearUnsigned16MSB; #ifndef WORDS_BIGENDIAN default: #endif case AFMT_S16_LE: return (AFMT_S16_LE << 8) + AuFormatLinearSigned16LSB; #ifdef WORDS_BIGENDIAN default: #endif case AFMT_S16_BE: return (AFMT_S16_BE << 8) + AuFormatLinearSigned16MSB; case AFMT_MU_LAW: return res + AuFormatULAW8; } } // to set/get/query special features/parameters static int control(int cmd,int arg){ return -1; } // open & setup audio device // return: 1=success 0=fail static int init(int rate,int channels,int format,int flags) { AuElement elms[3]; AuStatus as; unsigned char auformat = nas_aformat_to_auformat(format); int bytes_per_sample = channels * AuSizeofFormat(auformat); char *server; nas_data=malloc(sizeof(struct ao_nas_data)); memset(nas_data, 0, sizeof(struct ao_nas_data)); mp_msg(MSGT_AO, MSGL_V, "ao2: %d Hz %d chans %s\n",rate,channels, audio_out_format_name(format)); nas_data->client_buffer_size = NAS_BUFFER_SIZE*2; nas_data->client_buffer = malloc(nas_data->client_buffer_size); nas_data->server_buffer_size = NAS_BUFFER_SIZE; nas_data->server_buffer = malloc(nas_data->server_buffer_size); ao_data.format = auformat >> 8; ao_data.samplerate = rate; ao_data.channels = channels; ao_data.buffersize = NAS_BUFFER_SIZE * 2; ao_data.outburst = NAS_FRAG_SIZE; ao_data.bps = rate * bytes_per_sample; if (!bytes_per_sample) { mp_msg(MSGT_AO, MSGL_ERR, "ao_nas: init(): Zero bytes per sample -> nosound\n"); return 0; } if (!(server = getenv("AUDIOSERVER")) && !(server = getenv("DISPLAY"))) { mp_msg(MSGT_AO, MSGL_ERR, "ao_nas: init(): AUDIOSERVER environment variable not set -> nosound\n"); return 0; } mp_msg(MSGT_AO, MSGL_V, "ao_nas: init(): Using audioserver %s\n", server); nas_data->aud = AuOpenServer(server, 0, NULL, 0, NULL, NULL); if (!nas_data->aud) { mp_msg(MSGT_AO, MSGL_ERR, "ao_nas: init(): Can't open nas audio server -> nosound\n"); return 0; } while (channels>1) { nas_data->dev = nas_find_device(nas_data->aud, channels); if (nas_data->dev != AuNone && (nas_data->flow = AuCreateFlow(nas_data->aud, NULL) != 0)) break; channels--; } if (nas_data->flow == 0) { mp_msg(MSGT_AO, MSGL_ERR, "ao_nas: init(): Can't find a suitable output device -> nosound\n"); AuCloseServer(nas_data->aud); nas_data->aud = 0; return 0; } AuMakeElementImportClient(elms, rate, auformat & 0xff, channels, AuTrue, NAS_BUFFER_SIZE / bytes_per_sample, (NAS_BUFFER_SIZE - NAS_FRAG_SIZE) / bytes_per_sample, 0, NULL); AuMakeElementExportDevice(elms+1, 0, nas_data->dev, rate, AuUnlimitedSamples, 0, NULL); AuSetElements(nas_data->aud, nas_data->flow, AuTrue, 2, elms, &as); if (as != AuSuccess) nas_print_error(nas_data->aud, "init(): AuSetElements", as); AuRegisterEventHandler(nas_data->aud, AuEventHandlerIDMask | AuEventHandlerTypeMask, AuEventTypeElementNotify, nas_data->flow, nas_event_handler, (AuPointer) nas_data); AuSetErrorHandler(nas_data->aud, nas_error_handler); nas_data->flow_stopped=1; nas_data->expect_underrun=0; pthread_mutex_init(&nas_data->buffer_mutex, NULL); pthread_create(&nas_data->event_thread, NULL, &nas_event_thread_start, nas_data); return 1; } // close audio device static void uninit(){ AuStatus as; mp_msg(MSGT_AO, MSGL_DBG2, "ao_nas: uninit()\n"); nas_data->stop_thread = 1; pthread_join(nas_data->event_thread, NULL); if (!nas_data->flow_stopped) { AuStopFlow(nas_data->aud, nas_data->flow, &as); if (as != AuSuccess) nas_print_error(nas_data->aud, "uninit(): AuStopFlow", as); } AuCloseServer(nas_data->aud); nas_data->aud = 0; free(nas_data->client_buffer); free(nas_data->server_buffer); } // stop playing and empty buffers (for seeking/pause) static void reset(){ AuStatus as; mp_msg(MSGT_AO, MSGL_DBG2, "ao_nas: reset()\n"); pthread_mutex_lock(&nas_data->buffer_mutex); nas_data->client_buffer_used = 0; if (!nas_data->flow_stopped) { AuStopFlow(nas_data->aud, nas_data->flow, &as); if (as != AuSuccess) nas_print_error(nas_data->aud, "reset(): AuStopFlow", as); nas_data->flow_stopped = 1; } nas_data->server_buffer_used = 0; AuSync(nas_data->aud, AuTrue); pthread_mutex_unlock(&nas_data->buffer_mutex); } // stop playing, keep buffers (for pause) static void audio_pause() { AuStatus as; mp_msg(MSGT_AO, MSGL_DBG2, "ao_nas: audio_pause()\n"); nas_data->flow_paused = 1; } // resume playing, after audio_pause() static void audio_resume() { AuStatus as; AuEvent ev; mp_msg(MSGT_AO, MSGL_DBG2, "ao_nas: audio_resume()\n"); nas_data->flow_stopped = 0; nas_data->flow_paused = 0; nas_data->expect_underrun = 1; AuStartFlow(nas_data->aud, nas_data->flow, &as); if (as != AuSuccess) nas_print_error(nas_data->aud, "play(): AuStartFlow", as); } // return: how many bytes can be played without blocking static int get_space() { int result; mp_msg(MSGT_AO, MSGL_DBG2, "ao_nas: get_space()\n"); pthread_mutex_lock(&nas_data->buffer_mutex); result = nas_data->client_buffer_size - nas_data->client_buffer_used; pthread_mutex_unlock(&nas_data->buffer_mutex); return result; } // plays 'len' bytes of 'data' // it should round it down to outburst*n // return: number of bytes played static int play(void* data,int len,int flags) { int maxbursts, playbursts, writelen; AuStatus as; mp_msg(MSGT_AO, MSGL_DBG2, "ao_nas: play()\n"); pthread_mutex_lock(&nas_data->buffer_mutex); maxbursts = (nas_data->client_buffer_size - nas_data->client_buffer_used) / ao_data.outburst; playbursts = len / ao_data.outburst; writelen = (playbursts > maxbursts ? maxbursts : playbursts) * ao_data.outburst; pthread_mutex_unlock(&nas_data->buffer_mutex); nas_writeBuffer(nas_data, data, writelen); if (nas_data->flow_stopped) { AuEvent ev; nas_data->expect_underrun = 1; AuStartFlow(nas_data->aud, nas_data->flow, &as); if (as != AuSuccess) nas_print_error(nas_data->aud, "play(): AuStartFlow", as); nas_data->flow_stopped = 0; } return writelen; } // return: delay in seconds between first and last sample in buffer static float get_delay() { float result; mp_msg(MSGT_AO, MSGL_DBG2, "ao_nas: get_delay()\n"); pthread_mutex_lock(&nas_data->buffer_mutex); result = ((float)(nas_data->client_buffer_used + nas_data->server_buffer_used)) / (float)ao_data.bps; pthread_mutex_unlock(&nas_data->buffer_mutex); return result; }