| /* |
| * Licensed to the Apache Software Foundation (ASF) under one or more |
| * contributor license agreements. See the NOTICE file distributed with |
| * this work for additional information regarding copyright ownership. |
| * The ASF licenses this file to You 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 org.apache.logging.log4j.core.util; |
| |
| import java.util.UUID; |
| |
| import org.junit.Test; |
| |
| import static org.junit.Assert.*; |
| /** |
| * |
| */ |
| public class UuidTest { |
| |
| private static final int COUNT = 200; |
| private static final int THREADS = 10; |
| |
| private static final long NUM_100NS_INTERVALS_SINCE_UUID_EPOCH = 0x01b21dd213814000L; |
| |
| @Test |
| public void testTimeBaseUuid() { |
| final UUID uuid = UuidUtil.getTimeBasedUuid(); |
| //final UUID uuid2 = UuidUtil.getTimeBasedUUID(); // unused |
| final long current = (System.currentTimeMillis() * 10000) + NUM_100NS_INTERVALS_SINCE_UUID_EPOCH; |
| final long time = uuid.timestamp(); |
| assertTrue("Incorrect time", current + 10000 - time > 0); |
| final UUID[] uuids = new UUID[COUNT]; |
| final long start = System.nanoTime(); |
| for (int i=0; i < COUNT; ++i) { |
| uuids[i] = UuidUtil.getTimeBasedUuid(); |
| } |
| final long elapsed = System.nanoTime() - start; |
| System.out.println("Elapsed for " + COUNT + " UUIDS = " + elapsed + " Average = " + elapsed / COUNT + " ns"); |
| int errors = 0; |
| for (int i=0; i < COUNT; ++i) { |
| for (int j=i+1; j < COUNT; ++j) { |
| if (uuids[i].equals(uuids[j])) { |
| ++errors; |
| System.out.println("UUID " + i + " equals UUID " + j); |
| } |
| } |
| } |
| assertEquals(errors + " duplicate UUIDS", 0, errors); |
| final int variant = uuid.variant(); |
| assertEquals("Incorrect variant. Expected 2 got " + variant, 2, variant); |
| final int version = uuid.version(); |
| assertEquals("Incorrect version. Expected 1 got " + version, 1, version); |
| final long node = uuid.node(); |
| assertTrue("Invalid node", node != 0); |
| } |
| |
| @Test |
| public void testInitialize() { |
| // Test if no ArrayIndexOutOfBoundsException is thrown when Mac address array is null |
| UuidUtil.initialize(null); |
| |
| // Test if no ArrayIndexOutOfBoundsException is thrown for different Mac address lengths |
| for (int i=0; i < 10; i++) { |
| // Create MAC address byte array with i as size |
| byte[] mac = new byte[i]; |
| for(int j=0; j < i; j++) { |
| mac[j] = (byte)j; |
| } |
| UuidUtil.initialize(mac); |
| } |
| } |
| |
| @Test |
| public void testThreads() throws Exception { |
| final Thread[] threads = new Thread[THREADS]; |
| final UUID[] uuids = new UUID[COUNT * THREADS]; |
| final long[] elapsed = new long[THREADS]; |
| for (int i=0; i < THREADS; ++i) { |
| threads[i] = new Worker(uuids, elapsed, i, COUNT); |
| } |
| for (int i=0; i < THREADS; ++i) { |
| threads[i].start(); |
| } |
| long elapsedTime = 0; |
| for (int i=0; i < THREADS; ++i) { |
| threads[i].join(); |
| elapsedTime += elapsed[i]; |
| } |
| System.out.println("Elapsed for " + COUNT * THREADS + " UUIDS = " + elapsedTime + " Average = " + |
| elapsedTime / (COUNT * THREADS) + " ns"); |
| int errors = 0; |
| for (int i=0; i < COUNT * THREADS; ++i) { |
| for (int j=i+1; j < COUNT * THREADS; ++j) { |
| if (uuids[i].equals(uuids[j])) { |
| ++errors; |
| System.out.println("UUID " + i + " equals UUID " + j); |
| } |
| } |
| } |
| assertEquals(errors + " duplicate UUIDS", 0, errors); |
| } |
| |
| |
| |
| private static class Worker extends Thread { |
| |
| private final UUID[] uuids; |
| private final long[] elapsed; |
| private final int index; |
| private final int count; |
| |
| public Worker(final UUID[] uuids, final long[] elapsed, final int index, final int count) { |
| this.uuids = uuids; |
| this.index = index; |
| this.count = count; |
| this.elapsed = elapsed; |
| } |
| |
| @Override |
| public void run() { |
| final int pos = index * count; |
| final long start = System.nanoTime(); |
| for (int i=pos; i < pos + count; ++i) { |
| uuids[i] = UuidUtil.getTimeBasedUuid(); |
| } |
| elapsed[index] = System.nanoTime() - start; |
| } |
| } |
| } |