AdapterIO: Add debug

This commit is contained in:
Dario Casalinuovo
2016-06-23 00:38:33 +02:00
parent b13f52bf20
commit 6b697577fe
+28
View File
@@ -10,6 +10,8 @@
#include <stdio.h> #include <stdio.h>
#include "debug.h"
class RelativePositionIO : public BPositionIO class RelativePositionIO : public BPositionIO
{ {
@@ -194,6 +196,8 @@ BAdapterIO::BAdapterIO(int32 flags, bigtime_t timeout)
fBuffer(NULL), fBuffer(NULL),
fInputAdapter(NULL) fInputAdapter(NULL)
{ {
CALLED();
fBuffer = new RelativePositionIO(this, new BMallocIO()); fBuffer = new RelativePositionIO(this, new BMallocIO());
} }
@@ -206,6 +210,8 @@ BAdapterIO::BAdapterIO(const BAdapterIO &)
BAdapterIO::~BAdapterIO() BAdapterIO::~BAdapterIO()
{ {
CALLED();
delete fInputAdapter; delete fInputAdapter;
delete fBuffer; delete fBuffer;
} }
@@ -214,6 +220,8 @@ BAdapterIO::~BAdapterIO()
void void
BAdapterIO::GetFlags(int32* flags) const BAdapterIO::GetFlags(int32* flags) const
{ {
CALLED();
*flags = fFlags; *flags = fFlags;
} }
@@ -221,6 +229,8 @@ BAdapterIO::GetFlags(int32* flags) const
ssize_t ssize_t
BAdapterIO::ReadAt(off_t position, void* buffer, size_t size) BAdapterIO::ReadAt(off_t position, void* buffer, size_t size)
{ {
CALLED();
printf("read at %d %d \n", (int)position, (int)size); printf("read at %d %d \n", (int)position, (int)size);
status_t ret = _EvaluateWait(position+size); status_t ret = _EvaluateWait(position+size);
if (ret != B_OK) if (ret != B_OK)
@@ -233,6 +243,8 @@ BAdapterIO::ReadAt(off_t position, void* buffer, size_t size)
ssize_t ssize_t
BAdapterIO::WriteAt(off_t position, const void* buffer, size_t size) BAdapterIO::WriteAt(off_t position, const void* buffer, size_t size)
{ {
CALLED();
status_t ret = _EvaluateWait(position+size); status_t ret = _EvaluateWait(position+size);
if (ret != B_OK) if (ret != B_OK)
return ret; return ret;
@@ -244,6 +256,8 @@ BAdapterIO::WriteAt(off_t position, const void* buffer, size_t size)
off_t off_t
BAdapterIO::Seek(off_t position, uint32 seekMode) BAdapterIO::Seek(off_t position, uint32 seekMode)
{ {
CALLED();
status_t ret = _EvaluateWait(position); status_t ret = _EvaluateWait(position);
if (ret != B_OK) if (ret != B_OK)
return ret; return ret;
@@ -255,6 +269,8 @@ BAdapterIO::Seek(off_t position, uint32 seekMode)
off_t off_t
BAdapterIO::Position() const BAdapterIO::Position() const
{ {
CALLED();
return fBuffer->Position(); return fBuffer->Position();
} }
@@ -262,6 +278,8 @@ BAdapterIO::Position() const
status_t status_t
BAdapterIO::SetSize(off_t size) BAdapterIO::SetSize(off_t size)
{ {
CALLED();
if (!fBuffer->IsMutable()) { if (!fBuffer->IsMutable()) {
fTotalSize = size; fTotalSize = size;
return B_OK; return B_OK;
@@ -274,6 +292,8 @@ BAdapterIO::SetSize(off_t size)
status_t status_t
BAdapterIO::GetSize(off_t* size) const BAdapterIO::GetSize(off_t* size) const
{ {
CALLED();
if (!fBuffer->IsMutable()) { if (!fBuffer->IsMutable()) {
*size = fTotalSize; *size = fTotalSize;
return B_OK; return B_OK;
@@ -286,6 +306,8 @@ BAdapterIO::GetSize(off_t* size) const
ssize_t ssize_t
BAdapterIO::BackWrite(const void* buffer, size_t size) BAdapterIO::BackWrite(const void* buffer, size_t size)
{ {
CALLED();
return fBuffer->BackWrite(buffer, size); return fBuffer->BackWrite(buffer, size);
} }
@@ -293,6 +315,8 @@ BAdapterIO::BackWrite(const void* buffer, size_t size)
status_t status_t
BAdapterIO::_EvaluateWait(off_t pos) BAdapterIO::_EvaluateWait(off_t pos)
{ {
CALLED();
status_t err = fBuffer->EvaluatePosition(pos); status_t err = fBuffer->EvaluatePosition(pos);
if (err != B_RESOURCE_UNAVAILABLE && err != B_OK) if (err != B_RESOURCE_UNAVAILABLE && err != B_OK)
@@ -322,6 +346,8 @@ BAdapterIO::BuildInputAdapter()
status_t status_t
BAdapterIO::SeekRequested(off_t position) BAdapterIO::SeekRequested(off_t position)
{ {
CALLED();
return B_ERROR; return B_ERROR;
} }
@@ -329,6 +355,8 @@ BAdapterIO::SeekRequested(off_t position)
status_t status_t
BAdapterIO::SeekCompleted(off_t position) BAdapterIO::SeekCompleted(off_t position)
{ {
CALLED();
return fBuffer->ResetStartOffset(position); return fBuffer->ResetStartOffset(position);
} }