streamfile.cpp

Go to the documentation of this file.

/*
 *  ix stream-file methods. The filename is inferred from the class;
 *  no diagnostic string names this source file in the retail image.
 *
 *  Retail address range: 0x0046DD00 - 0x0046DF07 (6 functions).
 *  The initial 16-byte boundary follows ten padding bytes after the
 *  thread helpers. See docs/ORDER.md for compilation-unit evidence.
 */
#include "ix.h"
 
/* Function start: 0x46DD00 */
unsigned int IxStreamFile::ix_stream_file_read(void *newDestination,
                                                unsigned int bytes)
{
    ix_stream_file_wait();
    EnterCriticalSection(&g_csStreamerFileFifo);
    if (position + bytes > size)
        bytes = size - position;
    if (bytes > 0) {
        destination = (unsigned char *)newDestination;
        remaining = bytes;
        flags |= IX_STREAM_FILE_READING;
        if (previous != 0)
            previous->next = next;
        if (next == 0)
            g_48_pPumpIdleFiles = previous;
        else
            next->previous = previous;
        previous = g_1_pPlayerReadQueue;
        next = 0;
        if (g_1_pPlayerReadQueue != 0)
            g_1_pPlayerReadQueue->next = this;
        g_1_pPlayerReadQueue = this;
    }
    LeaveCriticalSection(&g_csStreamerFileFifo);
    SetEvent(g_1_hStreamRouseEvent);
    return bytes;
}
 
/* Function start: 0x46DE09 */
void IxStreamFile::ix_stream_file_seek(unsigned int newPosition)
{
    ix_stream_file_wait();
    if (newPosition >= 0)
        position = size < newPosition ? size : newPosition;
    else
        position = 0;
}
 
/* Function start: 0x46DE5B */
unsigned int IxStreamFile::ix_stream_file_tell(void)
{
    ix_stream_file_wait();
    return position;
}
 
/* Function start: 0x46DE7F */
unsigned int IxStreamFile::ix_stream_file_size(void)
{
    return size;
}
 
/* Function start: 0x46DE9B */
void IxStreamFile::ix_stream_file_wait(void)
{
    if ((flags & IX_STREAM_FILE_READING) != 0) {
        WaitForSingleObject(completionEvent, INFINITE);
        ResetEvent(completionEvent);
    }
}
 
/* Function start: 0x46DED9 */
int IxStreamFile::ix_stream_file_is_reading(void)
{
    return (flags & IX_STREAM_FILE_READING) != 0;
}