X-Git-Url: http://wamblee.org/gitweb/?a=blobdiff_plain;f=support%2Fgeneral%2Fsrc%2Ftest%2Fjava%2Forg%2Fwamblee%2Ftest%2FEventTracker.java;h=37a4c76ae3326e4aac786264cfaa0c01f42637ad;hb=8de36ff0206c996baf3ee4adc3e2293b12ff5f39;hp=333da1e78748e36510fd3985535c47caea65ae7a;hpb=6f8bb575523e672b9f8797e543f7c59d15db7253;p=utils diff --git a/support/general/src/test/java/org/wamblee/test/EventTracker.java b/support/general/src/test/java/org/wamblee/test/EventTracker.java index 333da1e7..37a4c76a 100644 --- a/support/general/src/test/java/org/wamblee/test/EventTracker.java +++ b/support/general/src/test/java/org/wamblee/test/EventTracker.java @@ -1,12 +1,12 @@ /* * Copyright 2006 the original author or authors. - * + * * 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. @@ -15,15 +15,15 @@ */ package org.wamblee.test; +import org.apache.commons.logging.Log; +import org.apache.commons.logging.LogFactory; + import java.util.ArrayList; import java.util.Collections; import java.util.HashMap; import java.util.List; import java.util.Map; -import org.apache.commons.logging.Log; -import org.apache.commons.logging.LogFactory; - /** * Tracks the occurence of certain events in a test environment. Threads in a * test environment tell the event tracker of the occurrence of certain events @@ -37,17 +37,16 @@ import org.apache.commons.logging.LogFactory; * Type of event sent from test code. Usually String will be * sufficient. The event type must provide a sensible implementation * of {@link java.lang.Object#equals(java.lang.Object)}. - * + * * @author Erik Brakkee */ public class EventTracker { - private static final Log LOG = LogFactory.getLog(EventTracker.class); /** * Map of Thread object to a list of events. */ - private Map> _events; + private Map> events; /** * Constructs the event tracker. @@ -57,9 +56,9 @@ public class EventTracker { clear(); } - public void clear() { - _events = new HashMap>(); - } + public void clear() { + events = new HashMap>(); + } /** * Called by a thread to inform that an event has occurred. @@ -69,13 +68,16 @@ public class EventTracker { */ public synchronized void eventOccurred(Event aEvent) { LOG.info("Event '" + aEvent + "' sent."); + Thread current = Thread.currentThread(); - List events = _events.get(current); - if (events == null) { - events = new ArrayList(); - _events.put(current, events); + List eventList = events.get(current); + + if (eventList == null) { + eventList = new ArrayList(); + events.put(current, eventList); } - events.add(aEvent); + + eventList.add(aEvent); } /** @@ -88,11 +90,13 @@ public class EventTracker { * @return Whether or not the event was sent. */ public synchronized boolean isEventSent(Thread aThread, Event aEvent) { - List events = _events.get(aThread); - if (events == null) { + List eventList = events.get(aThread); + + if (eventList == null) { return false; } - return events.contains(aEvent); + + return eventList.contains(aEvent); } /** @@ -104,16 +108,17 @@ public class EventTracker { * events were sent. */ public synchronized List getEvents(Thread aThread) { - List events = _events.get(aThread); - if (events == null) { - events = Collections.emptyList(); + List eventList = events.get(aThread); + + if (eventList == null) { + eventList = Collections.emptyList(); } - return Collections.unmodifiableList(events); + + return Collections.unmodifiableList(eventList); } /** - * Gets the number of times an event was sent summed up - * over all threads. + * Gets the number of times an event was sent summed up over all threads. * * @param aEvent * Event to check. @@ -121,26 +126,32 @@ public class EventTracker { */ public synchronized int getEventCount(Event aEvent) { int count = 0; - for (Thread thread : _events.keySet()) { - List events = _events.get(thread); - for (Event event : events) { + + for (Thread thread : events.keySet()) { + List eventList = events.get(thread); + + for (Event event : eventList) { if (event.equals(aEvent)) { count++; } } } + return count; } - + /** - * Gets the total event count over all threads. + * Gets the total event count over all threads. + * * @return */ - public synchronized int getEventCount() { - int count = 0; - for (Thread thread: _events.keySet()) { - count += _events.get(thread).size(); - } - return count; + public synchronized int getEventCount() { + int count = 0; + + for (Thread thread : events.keySet()) { + count += events.get(thread).size(); + } + + return count; } }