X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=oss_write.c;h=1d9add7b9a296e5a8d9750c77fa1f28a77894453;hp=70a58203db8a2f2e3eca5cfc12506334ed7133da;hb=45af9a7f2b089e3a983d320ef1d4c0b600f1fc67;hpb=9a0dd8271e92a2e3bbd330c2a7e2fc05c7f3bde9 diff --git a/oss_write.c b/oss_write.c index 70a58203..1d9add7b 100644 --- a/oss_write.c +++ b/oss_write.c @@ -1,5 +1,5 @@ /* - * Copyright (C) 2009-2011 Andre Noll + * Copyright (C) 2009-2012 Andre Noll * * Licensed under the GPL v2. For licencing details see COPYING. */ @@ -9,9 +9,7 @@ #include #include #include -#include #include -#include #include "para.h" #include "fd.h" @@ -154,6 +152,8 @@ err: close(powd->fd); err_free: free(powd); + PARA_ERROR_LOG("failed to init %s: %s\n", conf->device_arg, + para_strerror(-ret)); return ret; } @@ -185,13 +185,13 @@ static void oss_post_select(__a_unused struct sched *s, bytes = btr_next_buffer(btrn, &data); frames = bytes / powd->bytes_per_frame; if (!frames) { /* eof and less than a single frame available */ - ret = -E_OSS_EOF; + ret = -E_WRITE_COMMON_EOF; goto out; } ret = 0; if (!FD_ISSET(powd->fd, &s->wfds)) goto out; - ret = write_nonblock(powd->fd, data, frames * powd->bytes_per_frame); + ret = xwrite(powd->fd, data, frames * powd->bytes_per_frame); if (ret < 0) goto out; btr_consume(btrn, ret); @@ -199,7 +199,7 @@ static void oss_post_select(__a_unused struct sched *s, out: t->error = ret; if (ret < 0) - btr_remove_node(btrn); + btr_remove_node(&wn->btrn); } __malloc static void *oss_parse_config_or_die(const char *options) @@ -233,7 +233,6 @@ void oss_write_init(struct writer *w) w->post_select = oss_post_select; w->parse_config_or_die = oss_parse_config_or_die; w->free_config = oss_free_config; - w->shutdown = NULL; w->help = (struct ggo_help) { .short_help = oss_write_args_info_help, .detailed_help = oss_write_args_info_detailed_help