Initial revision

src/osgPlugins/flt/Input.cpp

@@ -0,0 +1,202 @@
+// Input.cpp
+
+#include <string>
+#include <malloc.h>
+
+#include <osg/Notify>
+
+#include "Input.h"
+#include "Record.h"
+#include "Registry.h"
+
+#ifdef __sgi
+using std::string;
+#endif
+
+#ifdef OSG_USE_IO_DOT_H
+#include <iostream.h>
+#else
+#include <iostream>
+using namespace std;
+#endif
+
+using namespace flt;
+
+
+
+
+FileInput::FileInput()
+{
+    _init();
+}
+
+
+FileInput::~FileInput()
+{
+    close();
+}
+
+
+void FileInput::_init()
+{
+    _lRecOffset = 0L;
+    _file = NULL;
+    _eof = true;
+}
+
+
+size_t FileInput::_read(void *buffer, size_t size)
+{
+    if (_eof) return 0;
+
+    size_t nItemsRead = ::fread(buffer, size, 1, _file);
+    if (nItemsRead != 1)
+        _eof = true;
+
+    return nItemsRead;
+}
+
+
+bool FileInput::eof()
+{
+    return _eof;
+}
+
+
+
+bool FileInput::open(const std::string& fileName)
+{
+    _file=::fopen( fileName.c_str(), "rb");
+    if (_file == NULL) return false;
+    _eof = false;
+    return true;
+}
+
+
+void FileInput::close()
+{
+    if (_file) ::fclose(_file);
+    _init();
+}
+
+
+bool FileInput::rewindLast()
+{
+    if (_file == NULL) return false;
+    return (fseek(_file, _lRecOffset, SEEK_SET) == 0);
+}
+
+
+long FileInput::offset()
+{
+    return _lRecOffset;
+}
+
+
+// read opcode and size
+
+bool FileInput::_readHeader(SRecHeader* pHdr)
+{
+    int nItemsRead;
+
+    _lRecOffset = ::ftell( _file );     // Save file position for rewind operation
+
+    // Read record header (4 bytes)
+    nItemsRead = _read(pHdr, sizeof(SRecHeader));
+    if (nItemsRead != 1)
+		return false;
+
+    if (isLittleEndianMachine())
+        pHdr->endian();
+
+    if ((unsigned)pHdr->length() < sizeof(SRecHeader))
+        return false;
+
+	return true;
+}
+
+
+bool FileInput::_readBody(SRecHeader* pData)
+{
+	// Read record body
+    int nBodySize = pData->length() - sizeof(SRecHeader);
+    if (nBodySize > 0)
+    {
+        int nItemsRead = _read(pData+1, nBodySize);
+	    if (nItemsRead != 1)
+		    return false;
+    }
+
+	return true;
+}
+
+
+SRecHeader* FileInput::readRecord()
+{
+    SRecHeader hdr;
+    SRecHeader* pData;
+
+    if (!_readHeader(&hdr))
+        return NULL;
+
+	// Allocate buffer for record (including header)
+    pData = (SRecHeader*)::malloc(hdr.length());
+    if (pData == NULL)
+        return NULL;
+
+    *pData = hdr;
+
+    // Some records contains only the header
+    if (hdr.length() == sizeof(SRecHeader))
+        return pData;
+
+    if (!_readBody(pData))
+        return NULL;
+
+    return pData;
+}
+
+
+Record* Input::readCreateRecord()
+{
+    SRecHeader* pData = readRecord();
+
+    if (pData == NULL) return NULL;
+
+    // find matching record prototype class
+    Record* pProto = Registry::instance()->getRecordProto(pData->opcode());
+
+    if (pProto == NULL)
+        pProto = Registry::instance()->getRecordProto(0);
+
+    if (pProto == NULL)
+    {
+        // Should not be possible to end up here!
+        osg::notify(osg::INFO) << "UnknownRecord not in registry!" << endl;
+        ::free(pData);
+        return NULL;
+    }
+
+    // clone protoype
+    Record* pRec = pProto->cloneRecord(pData);
+    if (pRec == NULL)
+    {
+        osg::notify(osg::INFO) << "Can't clone record!" << endl;
+        ::free(pData);
+        return NULL;
+    }
+
+#if 0
+    osg::notify(osg::INFO) << "class=" << pRec->className();
+    osg::notify(osg::INFO) << " op=" << pRec->getOpcode();
+    osg::notify(osg::INFO) << " name=" << pRec->getName();
+    osg::notify(osg::INFO) << " offset=" << offset() << endl;
+#endif
+
+    if (isLittleEndianMachine())    // From Intel with love  :-(
+        pRec->endian();
+
+    return pRec;
+}
+
+