Class NetworkManager

java.lang.Object
com.biglybt.core.networkmanager.NetworkManager
public class NetworkManager extends Object

  • Field Details

    • UNLIMITED_RATE

      public static final long UNLIMITED_RATE
      See Also:

    • PARTITION_BY_CONNECTION

      private static final boolean PARTITION_BY_CONNECTION
      See Also:

    • instance

      private static final NetworkManager instance

    • external_max_download_rate_bps

      private static long external_max_download_rate_bps

    • external_max_upload_rate_bps_normal

      private static long external_max_upload_rate_bps_normal

    • external_max_upload_rate_bps_seeding_only

      private static long external_max_upload_rate_bps_seeding_only

    • max_download_rate_bps_adj

      private static long max_download_rate_bps_adj

    • max_upload_rate_bps_normal_adj

      private static long max_upload_rate_bps_normal_adj

    • max_upload_rate_bps_seeding_only_adj

      private static long max_upload_rate_bps_seeding_only_adj

    • max_upload_rate_bps_adj

      private static long max_upload_rate_bps_adj

    • lan_rate_enabled

      private static boolean lan_rate_enabled

    • max_lan_upload_rate_bps_adj

      private static long max_lan_upload_rate_bps_adj

    • max_lan_download_rate_bps_adj

      private static long max_lan_download_rate_bps_adj

    • seeding_only_mode_allowed

      private static boolean seeding_only_mode_allowed

    • seeding_only_mode

      private static boolean seeding_only_mode

    • REQUIRE_CRYPTO_HANDSHAKE

      public static boolean REQUIRE_CRYPTO_HANDSHAKE

    • INCOMING_HANDSHAKE_FALLBACK_ALLOWED

      public static boolean INCOMING_HANDSHAKE_FALLBACK_ALLOWED

    • OUTGOING_HANDSHAKE_FALLBACK_ALLOWED

      public static boolean OUTGOING_HANDSHAKE_FALLBACK_ALLOWED

    • INCOMING_CRYPTO_ALLOWED

      public static boolean INCOMING_CRYPTO_ALLOWED

    • USE_REQUEST_LIMITING

      static boolean USE_REQUEST_LIMITING

    • core

      private Core core

    • write_controllers

      private final List<WriteController> write_controllers

    • read_controllers

      private final List<ReadController> read_controllers

    • upload_processor

      private TransferProcessor upload_processor

    • download_processor

      private TransferProcessor download_processor

    • lan_upload_processor

      private TransferProcessor lan_upload_processor

    • lan_download_processor

      private TransferProcessor lan_download_processor

    • CRYPTO_OVERRIDE_NONE

      public static final int CRYPTO_OVERRIDE_NONE
      See Also:

    • CRYPTO_OVERRIDE_REQUIRED

      public static final int CRYPTO_OVERRIDE_REQUIRED
      See Also:

    • CRYPTO_OVERRIDE_NOT_REQUIRED

      public static final int CRYPTO_OVERRIDE_NOT_REQUIRED
      See Also:

  • Constructor Details

    • NetworkManager

      private NetworkManager()

  • Method Details

    • getWriteControllers

      public List<WriteController> getWriteControllers()

    • isLANRateEnabled

      public static boolean isLANRateEnabled()

    • getMinMssSize

      public static int getMinMssSize()

    • refreshRates

      static void refreshRates()

    • isSeedingOnlyUploadRate

      public static boolean isSeedingOnlyUploadRate()

    • getMaxUploadRateBPSNormal

      public static long getMaxUploadRateBPSNormal()

    • getMaxUploadRateBPSSeedingOnly

      public static long getMaxUploadRateBPSSeedingOnly()

    • getMaxDownloadRateBPS

      public static long getMaxDownloadRateBPS()

    • getCryptoRequired

      public static boolean getCryptoRequired(int override_level)

    • initialize

      public void initialize(Core _core)

    • getSingleton

      public static NetworkManager getSingleton()
      Get the singleton instance of the network manager.
      Returns:
      the network manager

    • createConnection

      public NetworkConnection createConnection(ConnectionEndpoint target, MessageStreamEncoder encoder, MessageStreamDecoder decoder, boolean connect_with_crypto, boolean allow_fallback, byte[][] shared_secrets)
      Create a new unconnected remote network connection (for outbound-initiated connections).
      Parameters:
      encoder - default message stream encoder to use for the outgoing queue
      decoder - default message stream decoder to use for the incoming queue
      remote_address - to connect to
      Returns:
      a new connection

    • requestIncomingConnectionRouting

      public void requestIncomingConnectionRouting(NetworkManager.ByteMatcher matcher, NetworkManager.RoutingListener listener, MessageStreamFactory factory)
      Request the acceptance and routing of new incoming connections that match the given initial byte sequence.
      Parameters:
      matcher - initial byte sequence used for routing
      listener - for handling new inbound connections
      factory - to use for creating default stream encoder/decoders

    • bindTransport

      public NetworkConnection bindTransport(Transport transport, MessageStreamEncoder encoder, MessageStreamDecoder decoder)

    • cancelIncomingConnectionRouting

      public void cancelIncomingConnectionRouting(NetworkManager.ByteMatcher matcher)
      Cancel a request for inbound connection routing.
      Parameters:
      matcher - byte sequence originally used to register

    • addWriteEntity

      public void addWriteEntity(RateControlledEntity entity, int _partition_id)
      Add an upload entity for write processing.
      Parameters:
      entity - to add

    • removeWriteEntity

      public boolean removeWriteEntity(RateControlledEntity entity, int _partition_id)
      Remove an upload entity from write processing.
      Parameters:
      entity - to remove

    • addReadEntity

      public void addReadEntity(RateControlledEntity entity, int _partition_id)
      Add a download entity for read processing.
      Parameters:
      entity - to add

    • removeReadEntity

      public boolean removeReadEntity(RateControlledEntity entity, int _partition_id)
      Remove a download entity from read processing.
      Parameters:
      entity - to remove

    • getConnections

      public Set<NetworkConnectionBase> getConnections()

    • startTransferProcessing

      public void startTransferProcessing(NetworkConnectionBase peer_connection)
      Register peer connection for network upload and download handling. NOTE: The given max rate limits are ignored until the connection is upgraded. NOTE: The given max rate limits are ignored for LANLocal connections.
      Parameters:
      peer_connection - to register for network transfer processing
      upload_group - upload rate limit group
      download_group - download rate limit group

    • stopTransferProcessing

      public void stopTransferProcessing(NetworkConnectionBase peer_connection, int partition_id)
      Cancel network upload and download handling for the given connection.
      Parameters:
      peer_connection - to cancel

    • upgradeTransferProcessing

      public void upgradeTransferProcessing(NetworkConnectionBase peer_connection, int partition_id)
      Upgrade the given connection to high-speed network transfer handling.
      Parameters:
      peer_connection - to upgrade

    • downgradeTransferProcessing

      public void downgradeTransferProcessing(NetworkConnectionBase peer_connection, int partition_id)
      Downgrade the given connection back to a normal-speed network transfer handling.
      Parameters:
      peer_connection - to downgrade

    • getUploadProcessor

      public TransferProcessor getUploadProcessor()

    • addRateLimiter

      public void addRateLimiter(NetworkConnectionBase peer_connection, LimitedRateGroup group, boolean upload)

    • removeRateLimiter

      public void removeRateLimiter(NetworkConnectionBase peer_connection, LimitedRateGroup group, boolean upload)

    • getRateHandler

      public RateHandler getRateHandler(boolean upload, boolean lan)

    • getRateHandler

      public RateHandler getRateHandler(NetworkConnectionBase peer_connection, boolean upload)