SyncDataFileWriter(DataManagerImpl fileManager) 
{
        this.dataManager = fileManager;
        this.buffer = new DataByteArrayOutputStream();
}

Construct a Store writer

Parameters:

fileId -

 public  void close() throws IOException 
{

}

 public synchronized  void force(DataFile dataFile) throws IOException 
{
        // If our dirty marker was set.. then we need to sync
        if (dataFile.getWriterData() != null && dataFile.isDirty()) {
            dataFile.getRandomAccessFile().getFD().sync();
            dataFile.setWriterData(null);
            dataFile.setDirty(false);
        }
}

 public synchronized DataItem storeItem(Marshaller marshaller,
    Object payload,
    byte type) throws IOException 
{
        // Write the packet our internal buffer.
        buffer.reset();
        buffer.position(DataManagerImpl.ITEM_HEAD_SIZE);
        marshaller.writePayload(payload, buffer);
        int size = buffer.size();
        int payloadSize = size - DataManagerImpl.ITEM_HEAD_SIZE;
        buffer.reset();
        buffer.writeByte(type);
        buffer.writeInt(payloadSize);
        // Find the position where this item will land at.
        DataItem item = new DataItem();
        item.setSize(payloadSize);
        DataFile dataFile = dataManager.findSpaceForData(item);
        // Now splat the buffer to the file.
        dataFile.getRandomAccessFile().seek(item.getOffset());
        dataFile.getRandomAccessFile().write(buffer.getData(), 0, size);
        dataFile.setWriterData(Boolean.TRUE); // Use as dirty marker..
        dataManager.addInterestInFile(dataFile);
        return item;
}

 public synchronized  void updateItem(DataItem item,
    Marshaller marshaller,
    Object payload,
    byte type) throws IOException 
{
        // Write the packet our internal buffer.
        buffer.reset();
        buffer.position(DataManagerImpl.ITEM_HEAD_SIZE);
        marshaller.writePayload(payload, buffer);
        int size = buffer.size();
        int payloadSize = size - DataManagerImpl.ITEM_HEAD_SIZE;
        buffer.reset();
        buffer.writeByte(type);
        buffer.writeInt(payloadSize);
        item.setSize(payloadSize);
        DataFile dataFile = dataManager.getDataFile(item);
        RandomAccessFile file = dataFile.getRandomAccessFile();
        file.seek(item.getOffset());
        file.write(buffer.getData(), 0, size);
        dataFile.setWriterData(Boolean.TRUE); // Use as dirty marker..
}