Fix #101. Rename BroadcastTransport to UdpBroadcastTransport.

channelaccess · Jun 21, 2020 · aaaf272 · aaaf272
1 parent 94d400e
commit aaaf272
Showing 1 changed file with 9 additions and 9 deletions.
diff --git a/src/main/java/org/epics/ca/impl/search/ChannelSearchManager.java b/src/main/java/org/epics/ca/impl/search/ChannelSearchManager.java
@@ -10,7 +10,7 @@
 import java.util.logging.Logger;
 
 import org.epics.ca.Constants;
-import org.epics.ca.impl.BroadcastTransport;
+import org.epics.ca.impl.UdpBroadcastTransport;
 import org.epics.ca.impl.ChannelImpl;
 import org.epics.ca.impl.Messages;
 import org.epics.ca.util.logging.LibraryLogManager;
@@ -64,7 +64,7 @@ public class ChannelSearchManager
    /**
     * Broadcast transport.
     */
-   private final BroadcastTransport broadcastTransport;
+   private final UdpBroadcastTransport udpBroadcastTransport;
 
    /**
     * Search (datagram) sequence number.
@@ -83,11 +83,11 @@ public class ChannelSearchManager
    /**
     * Constructor.
     *
-    * @param broadcastTransport transport
+    * @param udpBroadcastTransport transport
     */
-   public ChannelSearchManager( BroadcastTransport broadcastTransport )
+   public ChannelSearchManager( UdpBroadcastTransport udpBroadcastTransport )
    {
-      this.broadcastTransport = broadcastTransport;
+      this.udpBroadcastTransport = udpBroadcastTransport;
 
       minSendInterval = MIN_SEND_INTERVAL_MS_DEFAULT;
       maxSendInterval = MAX_SEND_INTERVAL_MS_DEFAULT;
@@ -192,7 +192,7 @@ private void initializeSendBuffer()
 
       // put version message
       sequenceNumber.incrementAndGet();
-      Messages.generateVersionRequestMessage( broadcastTransport, sendBuffer, (short) 0, sequenceNumber.get(), true );
+      Messages.generateVersionRequestMessage( udpBroadcastTransport, sendBuffer, (short) 0, sequenceNumber.get(), true );
    }
 
    /**
@@ -213,7 +213,7 @@ private synchronized void flushSendBuffer()
          immediatePacketCount.set( 0 );
       }
 
-      broadcastTransport.send( sendBuffer );
+      udpBroadcastTransport.send( sendBuffer );
       initializeSendBuffer();
    }
 
@@ -226,14 +226,14 @@ private synchronized void flushSendBuffer()
     */
    private synchronized boolean generateSearchRequestMessage( ChannelImpl<?> channel, @SuppressWarnings( "SameParameterValue" ) boolean allowNewFrame )
    {
-      boolean success = channel.generateSearchRequestMessage (broadcastTransport, sendBuffer);
+      boolean success = channel.generateSearchRequestMessage (udpBroadcastTransport, sendBuffer);
       // buffer full, flush
       if ( !success )
       {
          flushSendBuffer();
          if ( allowNewFrame )
          {
-            channel.generateSearchRequestMessage( broadcastTransport, sendBuffer );
+            channel.generateSearchRequestMessage( udpBroadcastTransport, sendBuffer );
          }
          return true;
       }