// Copyright Keith D Gregory
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
//     http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.

package net.sf.kdgcommons.buffer;

import java.nio.ByteBuffer;

import junit.framework.TestCase;


public class TestByteBufferThreadLocal
extends TestCase
{
    private ByteBufferThreadLocal _tl;

    private final int testLoc = 4;
    private final int testVal = 0x12345678;


    private class MyRunnable
    implements Runnable
    {
        public ByteBuffer myBuffer;
        public int myValue;

        public void run()
        {
            myBuffer = _tl.get();
            myValue = myBuffer.getInt(testLoc);
        }
    }


//----------------------------------------------------------------------------
//  Test Case -- there's really only one, and it doesn't truly test
//               concurrent access
//----------------------------------------------------------------------------

    public void testOperation()
    throws Exception
    {
        ByteBuffer src = ByteBuffer.allocate(1024);
        src.putInt(testLoc, testVal);

        _tl = new ByteBufferThreadLocal(src);

        MyRunnable r1 = new MyRunnable();
        Thread t1 = new Thread(r1);

        MyRunnable r2 = new MyRunnable();
        Thread t2 = new Thread(r2);

        t1.start();
        t2.start();
        t1.join();
        t2.join();

        assertNotNull(r1.myBuffer);
        assertNotNull(r2.myBuffer);

        assertNotSame(src, r1.myBuffer);
        assertNotSame(src, r2.myBuffer);
        assertNotSame(r1.myBuffer, r2.myBuffer);

        assertEquals(testVal, r1.myValue);
        assertEquals(testVal, r2.myValue);
    }
}