android.net.ConnectivityManager#CONNECTIVITY_ACTION源码实例Demo

下面列出了android.net.ConnectivityManager#CONNECTIVITY_ACTION 实例代码,或者点击链接到github查看源代码,也可以在右侧发表评论。

源代码1 项目: VCL-Android   文件: BaseTvActivity.java
@Override
protected void onResume() {
    super.onResume();
    //Handle network connection state
    IntentFilter networkfilter = new IntentFilter(ConnectivityManager.CONNECTIVITY_ACTION);

    IntentFilter storageFilter = new IntentFilter(Intent.ACTION_MEDIA_MOUNTED);
    storageFilter.addAction(Intent.ACTION_MEDIA_UNMOUNTED);
    storageFilter.addDataScheme("file");

    registerReceiver(mExternalDevicesReceiver, networkfilter);
    registerReceiver(mExternalDevicesReceiver, storageFilter);
}
 
private void startNetworkConnectivityReceiver() {
    try {
        if (Build.VERSION.SDK_INT < Build.VERSION_CODES.N) {
            appendLog(getBaseContext(), TAG, "Start connectivity receiver with handler");
            networkConnectivityReceiver = new NetworkConnectivityReceiver();
            IntentFilter filterNetworkConnectivity = new IntentFilter(ConnectivityManager.CONNECTIVITY_ACTION);
            getApplicationContext().registerReceiver(networkConnectivityReceiver, filterNetworkConnectivity);
        } else {
            appendLog(getBaseContext(), TAG, "Start connectivity receiver with callback");
            ConnectivityManager connectivityManager
                    = (ConnectivityManager) getSystemService(Context.CONNECTIVITY_SERVICE);
            networkConnectionReceiver = new NetworkConnectionReceiver(this);
            connectivityManager.registerDefaultNetworkCallback(networkConnectionReceiver);
        }
    } catch (Exception e) {
        appendLog(getBaseContext(), TAG, e);
    }
}
 
/**
 * Check that when {@link WifiPeriodicReplicationReceiver} receives
 * {@link ConnectivityManager#CONNECTIVITY_ACTION} and WiFi is not connected,
 * an {@link Intent} is sent out to stop the Service
 * {@link ReplicationService} associated with
 * {@link WifiPeriodicReplicationReceiver} containing the extra
 * {@link ReplicationService#EXTRA_COMMAND} with the value
 * {@link PeriodicReplicationService#COMMAND_STOP_REPLICATION}.
 */
public void testWifiDisconnected() {
    Intent intent = new Intent(ConnectivityManager.CONNECTIVITY_ACTION);

    mMockContext.setMockConnectivityManager(ConnectivityManager.TYPE_WIFI, false);
    when(mMockPreferences.getBoolean(ReplicationService.class.getName() + ".wasOnWifi",
        false)).thenReturn(true);
    mMockPreferencesEditor = mock(SharedPreferences.Editor.class);
    when(mMockPreferences.edit()).thenReturn(mMockPreferencesEditor);

    mReceiver.onReceive(mMockContext, intent);
    verify(mMockPreferencesEditor, times(1)).putBoolean(ReplicationService.class.getName() + ".wasOnWifi",
        false);
    assertEquals(1, mMockContext.getIntentsReceived().size());

    Intent receivedIntent = mMockContext.getIntentsReceived().get(0);
    assertEquals(ReplicationService.class.getName(), receivedIntent.getComponent().getClassName());
    assertNull(receivedIntent.getAction());
    assertEquals(PeriodicReplicationService.COMMAND_STOP_REPLICATION, receivedIntent.getIntExtra(ReplicationService.EXTRA_COMMAND, ReplicationService.COMMAND_NONE));
}
 
源代码4 项目: TelePlus-Android   文件: ConnectionsManager.java
public void init(int version, int layer, int apiId, String deviceModel, String systemVersion,
                 String appVersion, String langCode, String systemLangCode, String configPath,
                 String logPath, int userId, boolean enablePushConnection)
{
    native_init(currentAccount, version, layer, apiId, deviceModel, systemVersion,
            appVersion, langCode, systemLangCode, configPath, logPath, userId,
            enablePushConnection, isNetworkOnline(), getCurrentNetworkType());

    checkConnection();
    BroadcastReceiver networkStateReceiver = new BroadcastReceiver()
    {
        @Override
        public void onReceive(Context context, Intent intent)
        {
            checkConnection();
            FileLoader.getInstance(currentAccount).onNetworkChanged(isConnectionSlow());
        }
    };
    IntentFilter filter = new IntentFilter(ConnectivityManager.CONNECTIVITY_ACTION);
    ApplicationLoader.applicationContext.registerReceiver(networkStateReceiver, filter);
}
 
源代码5 项目: ShareBox   文件: WifiAutoConnect.java
public void startScan()
    {
        _wifiManager= (WifiManager) _context.getSystemService(Context.WIFI_SERVICE);
        _wifiReceiver=new WifiReceiver(_wifiManager,this);
        _wifiManager.disconnect();
        if(!_wifiManager.isWifiEnabled())
            _wifiManager.setWifiEnabled(true);


        IntentFilter filter=new IntentFilter(ConnectivityManager.CONNECTIVITY_ACTION);
//        IntentFilter filter=new IntentFilter("wifi_scan_available");
//        filter.addAction("wifi_scan_available");
        filter.setPriority(IntentFilter.SYSTEM_HIGH_PRIORITY);
        _context.registerReceiver(_wifiReceiver,filter);

    }
 
源代码6 项目: PresencePublisher   文件: Application.java
@SuppressWarnings("deprecation")
private void initNetworkReceiver() {
    if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.N) {
        SystemBroadcastReceiver receiver = new SystemBroadcastReceiver();
        IntentFilter filter = new IntentFilter(ConnectivityManager.CONNECTIVITY_ACTION);
        registerReceiver(receiver, filter);
    }
}
 
源代码7 项目: VCL-Android   文件: NetworkBrowserFragment.java
public void onStart(){
    super.onStart();

    //Handle network connection state
    IntentFilter filter = new IntentFilter(ConnectivityManager.CONNECTIVITY_ACTION);
    getActivity().registerReceiver(networkReceiver, filter);
}
 
源代码8 项目: Silence   文件: MmsRadio.java
public synchronized void connect() throws MmsRadioException {
  int status;

  try {
    final Method startUsingNetworkFeatureMethod = connectivityManager.getClass().getMethod("startUsingNetworkFeature", Integer.TYPE, String.class);
    status = (int)startUsingNetworkFeatureMethod.invoke(connectivityManager, ConnectivityManager.TYPE_MOBILE, FEATURE_ENABLE_MMS);
  } catch (NoSuchMethodException nsme) {
    throw new MmsRadioException(nsme);
  } catch (IllegalAccessException iae) {
    throw new MmsRadioException(iae);
  } catch (InvocationTargetException ite) {
    throw new MmsRadioException(ite);
  }

  Log.w(TAG, "startUsingNetworkFeature status: " + status);

  if (status == APN_ALREADY_ACTIVE) {
    wakeLock.acquire();
    connectedCounter++;
    return;
  } else {
    wakeLock.acquire();
    connectedCounter++;

    if (connectivityListener == null) {
      IntentFilter filter  = new IntentFilter(ConnectivityManager.CONNECTIVITY_ACTION);
      connectivityListener = new ConnectivityListener();
      context.registerReceiver(connectivityListener, filter);
    }

    Util.wait(this, 30000);

    if (!isConnected()) {
      Log.w(TAG, "Got back from connectivity wait, and not connected...");
      disconnect();
      throw new MmsRadioException("Unable to successfully enable MMS radio.");
    }
  }
}
 
void init() {
	if (mAMap == null) {
		mAMap = mMapView.getMap();
		mAMap.getUiSettings().setRotateGesturesEnabled(false);
		mAMap.moveCamera(CameraUpdateFactory.zoomBy(6));
		setUpMap();
	}

	resetView_polygon();

	btAddFence.setOnClickListener(this);
	cbAlertIn.setOnCheckedChangeListener(this);
	cbAlertOut.setOnCheckedChangeListener(this);
	cbAldertStated.setOnCheckedChangeListener(this);

	IntentFilter fliter = new IntentFilter(
			ConnectivityManager.CONNECTIVITY_ACTION);
	fliter.addAction(GEOFENCE_BROADCAST_ACTION);
	registerReceiver(mGeoFenceReceiver, fliter);
	/**
	 * 创建pendingIntent
	 */
	fenceClient.createPendingIntent(GEOFENCE_BROADCAST_ACTION);
	fenceClient.setGeoFenceListener(this);
	/**
	 * 设置地理围栏的触发行为,默认为进入
	 */
	fenceClient.setActivateAction(GeoFenceClient.GEOFENCE_IN);
}
 
void init() {
	if (mAMap == null) {
		mAMap = mMapView.getMap();
		mAMap.getUiSettings().setRotateGesturesEnabled(false);
		mAMap.moveCamera(CameraUpdateFactory.zoomBy(6));
		setUpMap();
	}

	resetView_polygon();

	btAddFence.setOnClickListener(this);
	cbAlertIn.setOnCheckedChangeListener(this);
	cbAlertOut.setOnCheckedChangeListener(this);
	cbAldertStated.setOnCheckedChangeListener(this);

	IntentFilter fliter = new IntentFilter(
			ConnectivityManager.CONNECTIVITY_ACTION);
	fliter.addAction(GEOFENCE_BROADCAST_ACTION);
	registerReceiver(mGeoFenceReceiver, fliter);
	/**
	 * 创建pendingIntent
	 */
	fenceClient.createPendingIntent(GEOFENCE_BROADCAST_ACTION);
	fenceClient.setGeoFenceListener(this);
	/**
	 * 设置地理围栏的触发行为,默认为进入
	 */
	fenceClient.setActivateAction(GeoFenceClient.GEOFENCE_IN);
}
 
void init() {
	if (mAMap == null) {
		mAMap = mMapView.getMap();
		mAMap.getUiSettings().setRotateGesturesEnabled(false);
		mAMap.moveCamera(CameraUpdateFactory.zoomBy(6));
		setUpMap();
	}

	btOption.setVisibility(View.VISIBLE);
	btOption.setText(getString(R.string.hideOption));
	resetView_round();

	btAddFence.setOnClickListener(this);
	btOption.setOnClickListener(this);
	cbAlertIn.setOnCheckedChangeListener(this);
	cbAlertOut.setOnCheckedChangeListener(this);
	cbAldertStated.setOnCheckedChangeListener(this);

	IntentFilter fliter = new IntentFilter(
			ConnectivityManager.CONNECTIVITY_ACTION);
	fliter.addAction(GEOFENCE_BROADCAST_ACTION);
	registerReceiver(mGeoFenceReceiver, fliter);

	/**
	 * 创建pendingIntent
	 */
	fenceClient.createPendingIntent(GEOFENCE_BROADCAST_ACTION);
	fenceClient.setGeoFenceListener(this);
	/**
	 * 设置地理围栏的触发行为,默认为进入
	 */
	fenceClient.setActivateAction(GeoFenceClient.GEOFENCE_IN);
}
 
源代码12 项目: Netty_Demo   文件: NettyService.java
@Override
public void onCreate() {
    super.onCreate();
    receiver = new NetworkReceiver();
    IntentFilter filter = new IntentFilter(ConnectivityManager.CONNECTIVITY_ACTION);
    LocalBroadcastManager.getInstance(this).registerReceiver(receiver, filter);

}
 
源代码13 项目: triviums   文件: ConnectivityReceiver.java
@Override
protected void onActive() {
    super.onActive();
    IntentFilter filter = new IntentFilter(ConnectivityManager.CONNECTIVITY_ACTION);
    context.registerReceiver(networkReceiver, filter);

}
 
源代码14 项目: Easer   文件: ConnectivitySlot.java
@Override
public void onReceive(Context context, Intent intent) {
    switch (intent.getAction()) {
        case ConnectivityManager.CONNECTIVITY_ACTION:
            checkConnectivity();
            break;
    }
}
 
源代码15 项目: GracefulMovies   文件: BaseActivity.java
@Override
protected void onCreate(@Nullable Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);

    mActivity = this;
    MARGIN_TOP_DP = Util.getStatusBarHeight() + Util.dp2px(56);

    mReceiver = new NetworkStateChangedReceiver();
    IntentFilter intentFilter = new IntentFilter(ConnectivityManager.CONNECTIVITY_ACTION);
    registerReceiver(mReceiver, intentFilter);

    mBinding = DataBindingUtil.setContentView(this, contentLayoutRes());
    afterSetContentView();
}
 
@Test
public void test_should_not_perform_retry_sync_on_internet_not_connected() throws Exception {
    // Given
    Intent givenIntent = new Intent(ConnectivityManager.CONNECTIVITY_ACTION);
    givenIntent.putExtra(ConnectivityManager.EXTRA_NO_CONNECTIVITY, true);

    // When
    mobileMessagingConnectivityReceiver.onReceive(contextMock, givenIntent);

    // Then
    verify(mmcMock, never()).retrySyncOnNetworkAvailable();
}
 
void init() {
	if (mAMap == null) {
		mAMap = mMapView.getMap();
		mAMap.getUiSettings().setRotateGesturesEnabled(false);
		mAMap.moveCamera(CameraUpdateFactory.zoomBy(6));
		setUpMap();
	}

	lyOption.setVisibility(View.GONE);
	btOption.setText(getString(R.string.showOption));
	resetView();
	resetView_keyword();

	btAddFence.setOnClickListener(this);
	btOption.setOnClickListener(this);
	cbAlertIn.setOnCheckedChangeListener(this);
	cbAlertOut.setOnCheckedChangeListener(this);
	cbAldertStated.setOnCheckedChangeListener(this);

	IntentFilter fliter = new IntentFilter(
			ConnectivityManager.CONNECTIVITY_ACTION);
	fliter.addAction(GEOFENCE_BROADCAST_ACTION);
	registerReceiver(mGeoFenceReceiver, fliter);
	/**
	 * 创建pendingIntent
	 */
	fenceClient.createPendingIntent(GEOFENCE_BROADCAST_ACTION);
	fenceClient.setGeoFenceListener(this);
	/**
	 * 设置地理围栏的触发行为,默认为进入
	 */
	fenceClient.setActivateAction(GeoFenceClient.GEOFENCE_IN);
}
 
源代码18 项目: TelePlus-Android   文件: DownloadController.java
public DownloadController(int instance)
{
    currentAccount = instance;
    SharedPreferences preferences = MessagesController.getMainSettings(currentAccount);
    for (int a = 0; a < 4; a++)
    {
        String key = "mobileDataDownloadMask" + (a == 0 ? "" : a);
        if (a == 0 || preferences.contains(key))
        {
            mobileDataDownloadMask[a] = preferences.getInt(key, AUTODOWNLOAD_MASK_PHOTO | AUTODOWNLOAD_MASK_AUDIO | AUTODOWNLOAD_MASK_MUSIC | AUTODOWNLOAD_MASK_GIF | AUTODOWNLOAD_MASK_VIDEOMESSAGE);
            wifiDownloadMask[a] = preferences.getInt("wifiDownloadMask" + (a == 0 ? "" : a), AUTODOWNLOAD_MASK_PHOTO | AUTODOWNLOAD_MASK_AUDIO | AUTODOWNLOAD_MASK_MUSIC | AUTODOWNLOAD_MASK_GIF | AUTODOWNLOAD_MASK_VIDEOMESSAGE);
            roamingDownloadMask[a] = preferences.getInt("roamingDownloadMask" + (a == 0 ? "" : a), 0);
        }
        else
        {
            mobileDataDownloadMask[a] = mobileDataDownloadMask[0];
            wifiDownloadMask[a] = wifiDownloadMask[0];
            roamingDownloadMask[a] = roamingDownloadMask[0];
        }
    }
    for (int a = 0; a < 7; a++)
    {
        int sdefault;
        if (a == 1)
        {
            sdefault = 2 * 1024 * 1024;
        }
        else if (a == 6)
        {
            sdefault = 5 * 1024 * 1024;
        }
        else
        {
            sdefault = 10 * 1024 * 1024;
        }
        mobileMaxFileSize[a] = preferences.getInt("mobileMaxDownloadSize" + a, sdefault);
        wifiMaxFileSize[a] = preferences.getInt("wifiMaxDownloadSize" + a, sdefault);
        roamingMaxFileSize[a] = preferences.getInt("roamingMaxDownloadSize" + a, sdefault);
    }
    globalAutodownloadEnabled = preferences.getBoolean("globalAutodownloadEnabled", false);

    AndroidUtilities.runOnUIThread(() ->
    {
        NotificationCenter.getInstance(currentAccount).addObserver(DownloadController.this, NotificationCenter.FileDidFailedLoad);
        NotificationCenter.getInstance(currentAccount).addObserver(DownloadController.this, NotificationCenter.FileDidLoaded);
        NotificationCenter.getInstance(currentAccount).addObserver(DownloadController.this, NotificationCenter.FileLoadProgressChanged);
        NotificationCenter.getInstance(currentAccount).addObserver(DownloadController.this, NotificationCenter.FileUploadProgressChanged);
        NotificationCenter.getInstance(currentAccount).addObserver(DownloadController.this, NotificationCenter.httpFileDidLoaded);
        NotificationCenter.getInstance(currentAccount).addObserver(DownloadController.this, NotificationCenter.httpFileDidFailedLoad);
    });

    BroadcastReceiver networkStateReceiver = new BroadcastReceiver()
    {
        @Override
        public void onReceive(Context context, Intent intent)
        {
            checkAutodownloadSettings();
        }
    };
    IntentFilter filter = new IntentFilter(ConnectivityManager.CONNECTIVITY_ACTION);
    ApplicationLoader.applicationContext.registerReceiver(networkStateReceiver, filter);

    if (UserConfig.getInstance(currentAccount).isClientActivated())
    {
        checkAutodownloadSettings();
    }
}
 
源代码19 项目: thunderboard-android   文件: CloudManager.java
private void registerWifiUpdateReceiver() {
    IntentFilter connectionFilter = new IntentFilter(ConnectivityManager.CONNECTIVITY_ACTION);
    context.registerReceiver(wifiUpdateReceiver, connectionFilter);
}
 
源代码20 项目: tinybus   文件: ConnectivityWire.java
public ConnectivityWire(Class<? extends ConnectionStateEvent> producedEventClass) {
	mpProducedEventClass = producedEventClass;
	mFilter = new IntentFilter(ConnectivityManager.CONNECTIVITY_ACTION);
}