/*
 * Copyright (c) 2007-2010 Nokia Corporation and/or its subsidiary(-ies). 
 * All rights reserved.
 * This component and the accompanying materials are made available
 * under the terms of "Eclipse Public License v1.0"
 * which accompanies this distribution, and is available
 * at the URL "http://www.eclipse.org/legal/epl-v10.html".
 *
 * Initial Contributors:
 * Nokia Corporation - initial contribution.
 *
 * Contributors:
 *
 * Description:
 *
 * OST Writer
 *
 */
package com.nokia.traceviewer.ost;

import java.io.IOException;
import java.nio.ByteBuffer;
import java.nio.channels.ByteChannel;

import com.nokia.traceviewer.engine.DataWriter;

/**
 * OST Writer
 * 
 */
public class OstWriter implements DataWriter {

	/**
	 * Target channel for write operations
	 */
	private ByteChannel writeChannel;

	/**
	 * Constructor
	 * 
	 * @param writeChannel
	 *            write channel
	 */
	public OstWriter(ByteChannel writeChannel) {
		this.writeChannel = writeChannel;
	}

	/*
	 * (non-Javadoc)
	 * 
	 * @see
	 * com.nokia.traceviewer.engine.DataWriter#writeMessage(java.nio.ByteBuffer,
	 * int, int)
	 */
	public void writeMessage(ByteBuffer sourceBuffer, int msgStart, int msgLen) {
		try {
			// Write the message to file
			if (sourceBuffer != null && writeChannel != null) {
				int position = sourceBuffer.position();
				int limit = sourceBuffer.limit();
				sourceBuffer.limit(msgStart + msgLen);
				sourceBuffer.position(msgStart);
				writeChannel.write(sourceBuffer);
				sourceBuffer.limit(limit);
				sourceBuffer.position(position);
			}
		} catch (Exception e) {
			e.printStackTrace();
		}
	}

	/*
	 * (non-Javadoc)
	 * 
	 * @see com.nokia.traceviewer.engine.DataWriter#close()
	 */
	public void closeChannel() {
		try {
			if (writeChannel != null) {
				writeChannel.close();
				writeChannel = null;
			}
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
}