Music{Pipe,Chunk}: use MusicChunkPtr for the list links

This commit is contained in:
Max Kellermann 2018-06-23 17:58:42 +02:00
parent 88f1233d7b
commit 076be809c2
4 changed files with 12 additions and 16 deletions

View File

@ -45,7 +45,7 @@ struct MusicChunk;
*/
struct MusicChunkInfo {
/** the next chunk in a linked list */
MusicChunk *next;
MusicChunkPtr next;
/**
* An optional chunk which should be mixed into this chunk.

View File

@ -28,7 +28,7 @@ MusicPipe::Contains(const MusicChunk *chunk) const noexcept
{
const std::lock_guard<Mutex> protect(mutex);
for (const MusicChunk *i = head; i != nullptr; i = i->next)
for (const MusicChunk *i = head.get(); i != nullptr; i = i->next.get())
if (i == chunk)
return true;
@ -42,11 +42,11 @@ MusicPipe::Shift() noexcept
{
const std::lock_guard<Mutex> protect(mutex);
MusicChunk *chunk = head;
auto chunk = std::move(head);
if (chunk != nullptr) {
assert(!chunk->IsEmpty());
head = chunk->next;
head = std::move(chunk->next);
--size;
if (head == nullptr) {
@ -60,15 +60,12 @@ MusicPipe::Shift() noexcept
}
#ifndef NDEBUG
/* poison the "next" reference */
chunk->next = (MusicChunk *)(void *)0x01010101;
if (size == 0)
audio_format.Clear();
#endif
}
return MusicChunkPtr(chunk, MusicChunkDeleter(buffer));
return chunk;
}
void
@ -94,10 +91,9 @@ MusicPipe::Push(MusicChunkPtr chunk) noexcept
audio_format = chunk->audio_format;
#endif
auto *c = chunk.release();
c->next = nullptr;
*tail_r = c;
tail_r = &c->next;
chunk->next.reset();
*tail_r = std::move(chunk);
tail_r = &(*tail_r)->next;
++size;
}

View File

@ -43,10 +43,10 @@ class MusicPipe {
MusicBuffer &buffer;
/** the first chunk */
MusicChunk *head = nullptr;
MusicChunkPtr head;
/** a pointer to the tail of the chunk */
MusicChunk **tail_r = &head;
MusicChunkPtr *tail_r = &head;
/** the current number of chunks */
unsigned size = 0;
@ -102,7 +102,7 @@ public:
gcc_pure
const MusicChunk *Peek() const noexcept {
const std::lock_guard<Mutex> protect(mutex);
return head;
return head.get();
}
/**

View File

@ -33,7 +33,7 @@ SharedPipeConsumer::Get() noexcept
return nullptr;
consumed = false;
return chunk = chunk->next;
return chunk = chunk->next.get();
} else {
/* get the first chunk from the pipe */
consumed = false;