#51 adding synchronization to the appropriate methods

if the entire method body is in a synchronized block and all methods use
the same lock (transports). I feel we could make the method itself
synchronized.

Author: shroffk

pvAccessJava/src/org/epics/pvaccess/impl/remote/TransportRegistry.java

@@ -57,14 +57,15 @@ public void put(Transport transport) {
 		// TODO support type
 		final short priority = transport.getPriority();
 		final InetSocketAddress address = transport.getRemoteAddress();
-		Map<Short, Transport> priorities = transports.get(address);
-		if (priorities == null) {
-			priorities = Collections.synchronizedMap(new HashMap<Short, Transport>());
-			transports.put(address, priorities);
-		}
-		priorities.put(priority, transport);
-		allTransports.add(transport);
-
+        synchronized (transports) {
+            Map<Short, Transport> priorities = transports.get(address);
+            if (priorities == null) {
+                priorities = Collections.synchronizedMap(new HashMap<Short, Transport>());
+                transports.put(address, priorities);
+            }
+            priorities.put(priority, transport);
+            allTransports.add(transport);
+        }
 	}
 
 	/**
@@ -78,7 +79,7 @@ public void put(Transport transport) {
 	 *            priority of the transport.
 	 * @return corresponding transport, <code>null</code> if none found.
 	 */
-	public Transport get(String type, InetSocketAddress address, short priority) {
+	public synchronized Transport get(String type, InetSocketAddress address, short priority) {
 		// TODO support type
 		Map<Short, Transport> priorities = transports.get(address);
 		if (priorities != null)
@@ -96,7 +97,7 @@ public Transport get(String type, InetSocketAddress address, short priority) {
 	 *            address of the host computer.
 	 * @return array of corresponding transports, <code>null</code> if none found.
 	 */
-	public Transport[] get(String type, InetSocketAddress address) {
+	public synchronized Transport[] get(String type, InetSocketAddress address) {
 		// TODO support type
 		Map<Short, Transport> priorities = transports.get(address);
 		if (priorities != null) {
@@ -115,7 +116,7 @@ public Transport[] get(String type, InetSocketAddress address) {
 	 *            transport to remove.
 	 * @return removed transport, <code>null</code> if none found.
 	 */
-	public Transport remove(Transport transport) {
+	public synchronized Transport remove(Transport transport) {
 		// TODO support type
 		final short priority = transport.getPriority();
 		final InetSocketAddress address = transport.getRemoteAddress();
@@ -135,7 +136,7 @@ public Transport remove(Transport transport) {
 	/**
 	 * Clear cache.
 	 */
-	public void clear() {
+	public synchronized void clear() {
 
 		transports.clear();
 
@@ -147,7 +148,7 @@ public void clear() {
 	 * 
 	 * @return number of active (cached) transports.
 	 */
-	public int numberOfActiveTransports() {
+	public synchronized int numberOfActiveTransports() {
 
 		return allTransports.size();
 
@@ -160,7 +161,7 @@ public int numberOfActiveTransports() {
 	 *            protocol type (e.g. tcp, udp, ssl, etc.).
 	 * @return array of all active (cached) transports.
 	 */
-	public Transport[] toArray(String type) {
+	public synchronized Transport[] toArray(String type) {
 		// TODO support type
 
 		return allTransports.toArray(new Transport[transports.size()]);
@@ -172,7 +173,7 @@ public Transport[] toArray(String type) {
 	 * 
 	 * @return array of all active (cached) transports.
 	 */
-	public Transport[] toArray() {
+	public synchronized Transport[] toArray() {
 
 		return allTransports.toArray(new Transport[transports.size()]);