Change read function signature.

This commit is contained in:
2019-03-22 21:22:36 +00:00
parent 544669c702
commit 99dc7ecb9c
4 changed files with 42 additions and 62 deletions

View File

@@ -44,7 +44,7 @@ void *open(const char *filepath);
int close(void *context); int close(void *context);
uint8_t *read_media_tag(void *context, int32_t tag, uint32_t *length); int32_t read_media_tag(void *context, uint8_t *data, int32_t tag, uint32_t *length);
void *crc64_init(uint64_t polynomial, uint64_t seed); void *crc64_init(uint64_t polynomial, uint64_t seed);
@@ -58,6 +58,6 @@ uint64_t crc64_data(const uint8_t *data, size_t len, uint64_t polynomial, uint64
uint64_t crc64_data_ecma(const uint8_t *data, size_t len); uint64_t crc64_data_ecma(const uint8_t *data, size_t len);
uint8_t *read_sector(void *context, uint64_t sectorAddress, uint32_t *length); int32_t read_sector(void *context, uint64_t sectorAddress, uint8_t *data, uint32_t *length);
#endif //LIBDICFORMAT_DECLS_H #endif //LIBDICFORMAT_DECLS_H

View File

@@ -236,6 +236,10 @@ typedef enum
CdMode2Form2 = 5 CdMode2Form2 = 5
} TrackType; } TrackType;
typedef enum
{
DICF_STATUS_INVALID_CONTEXT = -1,
} DicformatStatus;
#endif //LIBDICFORMAT_ENUMS_H #endif //LIBDICFORMAT_ENUMS_H

View File

@@ -13,5 +13,13 @@
#define DICF_ERROR_CANNOT_READ_HEADER -6 #define DICF_ERROR_CANNOT_READ_HEADER -6
#define DICF_ERROR_CANNOT_READ_BLOCK -7 #define DICF_ERROR_CANNOT_READ_BLOCK -7
#define DICF_ERROR_UNSUPPORTED_COMPRESSION -8 #define DICF_ERROR_UNSUPPORTED_COMPRESSION -8
#define DICF_ERROR_NOT_ENOUGH_MEMORY -9
#define DICF_ERROR_BUFFER_TOO_SMALL -10
#define DICF_ERROR_MEDIA_TAG_NOT_PRESENT -11
#define DICF_STATUS_OK 0
#define DICF_STATUS_SECTOR_NEVER_WRITTEN 1
#define DICF_STATUS_SECTOR_WITH_ERRORS 2
#define DICF_STATUS_SECTOR_DELETED 3
#endif //LIBDICFORMAT_ERRORS_H #endif //LIBDICFORMAT_ERRORS_H

View File

@@ -31,31 +31,23 @@
// ****************************************************************************/ // ****************************************************************************/
#include <dicformat.h> #include <dicformat.h>
#include <errno.h>
#include <malloc.h> #include <malloc.h>
#include <string.h> #include <string.h>
uint8_t *read_media_tag(void *context, int32_t tag, uint32_t *length) int32_t read_media_tag(void *context, uint8_t *data, int32_t tag, uint32_t *length)
{ {
dicformatContext *ctx; dicformatContext *ctx;
dataLinkedList *item; dataLinkedList *item;
*length = 0;
if(context == NULL) if(context == NULL)
{ return DICF_ERROR_NOT_DICFORMAT;
errno = EINVAL;
return NULL;
}
ctx = context; ctx = context;
// TODO: Cast this field without casting the whole structure, as this can buffer overflow // TODO: Cast this field without casting the whole structure, as this can buffer overflow
// Not a libdicformat context // Not a libdicformat context
if(ctx->magic != DIC_MAGIC) if(ctx->magic != DIC_MAGIC)
{ return DICF_ERROR_NOT_DICFORMAT;
errno = EINVAL;
return NULL;
}
item = ctx->mediaTagsHead; item = ctx->mediaTagsHead;
@@ -63,51 +55,46 @@ uint8_t *read_media_tag(void *context, int32_t tag, uint32_t *length)
{ {
if(item->type == tag) if(item->type == tag)
{ {
if(data == NULL || *length < item->length)
{
*length = item->length;
return DICF_ERROR_BUFFER_TOO_SMALL;
}
*length = item->length; *length = item->length;
return item->data; memcpy(data, item->data, item->length);
} }
item = item->next; item = item->next;
} }
return NULL; *length = 0;
return DICF_ERROR_MEDIA_TAG_NOT_PRESENT;
} }
uint8_t *read_sector(void *context, uint64_t sectorAddress, uint32_t *length) int32_t read_sector(void *context, uint64_t sectorAddress, uint8_t *data, uint32_t *length)
{ {
dicformatContext *ctx; dicformatContext *ctx;
uint64_t ddtEntry; uint64_t ddtEntry;
uint32_t offsetMask; uint32_t offsetMask;
uint64_t offset; uint64_t offset;
uint64_t blockOffset; uint64_t blockOffset;
uint8_t *sector;
BlockHeader blockHeader; BlockHeader blockHeader;
uint8_t *block; uint8_t *block;
size_t readBytes; size_t readBytes;
*length = 0;
if(context == NULL) if(context == NULL)
{ return DICF_ERROR_NOT_DICFORMAT;
errno = EINVAL;
return NULL;
}
ctx = context; ctx = context;
// TODO: Cast this field without casting the whole structure, as this can buffer overflow // TODO: Cast this field without casting the whole structure, as this can buffer overflow
// Not a libdicformat context // Not a libdicformat context
if(ctx->magic != DIC_MAGIC) if(ctx->magic != DIC_MAGIC)
{ return DICF_ERROR_NOT_DICFORMAT;
errno = EINVAL;
return NULL;
}
if(sectorAddress > ctx->imageInfo.Sectors - 1) if(sectorAddress > ctx->imageInfo.Sectors - 1)
{ return DICF_ERROR_SECTOR_OUT_OF_BOUNDS;
errno = DICF_ERROR_SECTOR_OUT_OF_BOUNDS;
return NULL;
}
ddtEntry = ctx->userDataDdt[sectorAddress]; ddtEntry = ctx->userDataDdt[sectorAddress];
offsetMask = (uint32_t)((1 << ctx->shift) - 1); offsetMask = (uint32_t)((1 << ctx->shift) - 1);
@@ -117,17 +104,9 @@ uint8_t *read_sector(void *context, uint64_t sectorAddress, uint32_t *length)
// Partially written image... as we can't know the real sector size just assume it's common :/ // Partially written image... as we can't know the real sector size just assume it's common :/
if(ddtEntry == 0) if(ddtEntry == 0)
{ {
sector = (uint8_t *)malloc(ctx->imageInfo.SectorSize); memset(data, 0, ctx->imageInfo.SectorSize);
if(sector == NULL)
{
errno = ENOMEM;
return NULL;
}
memset(sector, 0, ctx->imageInfo.SectorSize);
*length = ctx->imageInfo.SectorSize; *length = ctx->imageInfo.SectorSize;
return sector; return DICF_STATUS_SECTOR_NEVER_WRITTEN;
} }
// Check if block is cached // Check if block is cached
@@ -138,9 +117,12 @@ uint8_t *read_sector(void *context, uint64_t sectorAddress, uint32_t *length)
readBytes = fread(&blockHeader, sizeof(BlockHeader), 1, ctx->imageStream); readBytes = fread(&blockHeader, sizeof(BlockHeader), 1, ctx->imageStream);
if(readBytes != sizeof(BlockHeader)) if(readBytes != sizeof(BlockHeader))
return DICF_ERROR_CANNOT_READ_HEADER;
if(data == NULL || *length < blockHeader.sectorSize)
{ {
errno = DICF_ERROR_CANNOT_READ_HEADER; *length = blockHeader.sectorSize;
return NULL; return DICF_ERROR_BUFFER_TOO_SMALL;
} }
// Decompress block // Decompress block
@@ -148,23 +130,18 @@ uint8_t *read_sector(void *context, uint64_t sectorAddress, uint32_t *length)
{ {
case None:block = (uint8_t *)malloc(blockHeader.length); case None:block = (uint8_t *)malloc(blockHeader.length);
if(block == NULL) if(block == NULL)
{ return DICF_ERROR_NOT_ENOUGH_MEMORY;
errno = ENOMEM;
return NULL;
}
readBytes = fread(block, blockHeader.length, 1, ctx->imageStream); readBytes = fread(block, blockHeader.length, 1, ctx->imageStream);
if(readBytes != blockHeader.length) if(readBytes != blockHeader.length)
{ {
free(block); free(block);
errno = DICF_ERROR_CANNOT_READ_BLOCK; return DICF_ERROR_CANNOT_READ_BLOCK;
return NULL;
} }
break; break;
default:errno = DICF_ERROR_UNSUPPORTED_COMPRESSION; default:return DICF_ERROR_UNSUPPORTED_COMPRESSION;
return NULL;
} }
// Check if cache needs to be emptied // Check if cache needs to be emptied
@@ -173,17 +150,8 @@ uint8_t *read_sector(void *context, uint64_t sectorAddress, uint32_t *length)
// Add block to cache // Add block to cache
// TODO: Caches // TODO: Caches
sector = (uint8_t *)malloc(blockHeader.sectorSize); memcpy(data, block + offset, blockHeader.sectorSize);
if(sector == NULL)
{
free(block);
errno = ENOMEM;
return NULL;
}
memcpy(sector, block + offset, blockHeader.sectorSize);
*length = blockHeader.sectorSize; *length = blockHeader.sectorSize;
free(block); free(block);
return sector; return DICF_STATUS_OK;
} }