Commit f0283b58 authored by Charles Keepax's avatar Charles Keepax Committed by Takashi Iwai

ALSA: compress_core: Rework writes to use cumulative values

This patch reworks the writes to use cumulative values thus making the
app_pointer unecessary and removing it.

Only tested as far as build.
Signed-off-by: default avatarCharles Keepax <ckeepax@opensource.wolfsonmicro.com>
Signed-off-by: default avatarRichard Fitzgerald <rf@opensource.wolfsonmicro.com>
Acked-by: default avatarVinod Koul <vinod.koul@intel.com>
Signed-off-by: default avatarTakashi Iwai <tiwai@suse.de>
parent ccf17b13
...@@ -56,7 +56,6 @@ struct snd_compr_runtime { ...@@ -56,7 +56,6 @@ struct snd_compr_runtime {
u64 buffer_size; u64 buffer_size;
u32 fragment_size; u32 fragment_size;
u32 fragments; u32 fragments;
u64 app_pointer;
u64 total_bytes_available; u64 total_bytes_available;
u64 total_bytes_transferred; u64 total_bytes_transferred;
wait_queue_head_t sleep; wait_queue_head_t sleep;
......
...@@ -28,11 +28,13 @@ ...@@ -28,11 +28,13 @@
#include <linux/file.h> #include <linux/file.h>
#include <linux/fs.h> #include <linux/fs.h>
#include <linux/list.h> #include <linux/list.h>
#include <linux/math64.h>
#include <linux/mm.h> #include <linux/mm.h>
#include <linux/mutex.h> #include <linux/mutex.h>
#include <linux/poll.h> #include <linux/poll.h>
#include <linux/slab.h> #include <linux/slab.h>
#include <linux/sched.h> #include <linux/sched.h>
#include <linux/types.h>
#include <linux/uio.h> #include <linux/uio.h>
#include <linux/uaccess.h> #include <linux/uaccess.h>
#include <linux/module.h> #include <linux/module.h>
...@@ -223,21 +225,24 @@ static int snd_compr_write_data(struct snd_compr_stream *stream, ...@@ -223,21 +225,24 @@ static int snd_compr_write_data(struct snd_compr_stream *stream,
void *dstn; void *dstn;
size_t copy; size_t copy;
struct snd_compr_runtime *runtime = stream->runtime; struct snd_compr_runtime *runtime = stream->runtime;
/* 64-bit Modulus */
u64 app_pointer = div64_u64(runtime->total_bytes_available,
runtime->buffer_size);
app_pointer = runtime->total_bytes_available -
(app_pointer * runtime->buffer_size);
dstn = runtime->buffer + runtime->app_pointer; dstn = runtime->buffer + app_pointer;
pr_debug("copying %ld at %lld\n", pr_debug("copying %ld at %lld\n",
(unsigned long)count, runtime->app_pointer); (unsigned long)count, app_pointer);
if (count < runtime->buffer_size - runtime->app_pointer) { if (count < runtime->buffer_size - app_pointer) {
if (copy_from_user(dstn, buf, count)) if (copy_from_user(dstn, buf, count))
return -EFAULT; return -EFAULT;
runtime->app_pointer += count;
} else { } else {
copy = runtime->buffer_size - runtime->app_pointer; copy = runtime->buffer_size - app_pointer;
if (copy_from_user(dstn, buf, copy)) if (copy_from_user(dstn, buf, copy))
return -EFAULT; return -EFAULT;
if (copy_from_user(runtime->buffer, buf + copy, count - copy)) if (copy_from_user(runtime->buffer, buf + copy, count - copy))
return -EFAULT; return -EFAULT;
runtime->app_pointer = count - copy;
} }
/* if DSP cares, let it know data has been written */ /* if DSP cares, let it know data has been written */
if (stream->ops->ack) if (stream->ops->ack)
...@@ -656,7 +661,6 @@ static int snd_compr_stop(struct snd_compr_stream *stream) ...@@ -656,7 +661,6 @@ static int snd_compr_stop(struct snd_compr_stream *stream)
if (!retval) { if (!retval) {
stream->runtime->state = SNDRV_PCM_STATE_SETUP; stream->runtime->state = SNDRV_PCM_STATE_SETUP;
wake_up(&stream->runtime->sleep); wake_up(&stream->runtime->sleep);
stream->runtime->app_pointer = 0;
stream->runtime->total_bytes_available = 0; stream->runtime->total_bytes_available = 0;
stream->runtime->total_bytes_transferred = 0; stream->runtime->total_bytes_transferred = 0;
} }
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment