import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ProviderContext; //导入依赖的package包/类
@Override
public void onSessionInitiated(ProviderContext session) {
    LOG.info("ExampleProvider Session Initiated");
    DataBroker db = session.getSALService(DataBroker.class);
    exampleService = session.addRpcImplementation(OdlexampleService.class, new ExampleImpl(db));

    ApplicationRegistryUtils.getInstance().setDb(db);
    ApplicationRegistryUtils.getInstance().initializeDataTree();

    SalFlowService salFlowService = session.getRpcService(SalFlowService.class);
    SwitchConfigurator.getInstance().setDb(db);
    SwitchConfigurator.getInstance().setSalFlowService(salFlowService);

    NetworkGraphImpl.getInstance().setDb(db);
    NetworkGraphImpl.getInstance().init();

}
 

import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ProviderContext; //导入依赖的package包/类
@Override
public void onSessionInitiated(ProviderContext session) {
    LOG.info("HelloProvider Session Initiated");
    db = session.getSALService(DataBroker.class);
    helloService = session.addRpcImplementation(HelloService.class, this);

    initializeDataTree(db);
}
 

import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ProviderContext; //导入依赖的package包/类
@Override
public void onSessionInitiated(ProviderContext session) {
    LOG.info("NetideProvider Session Initiated");
    connectionProvider = new SwitchConnectionProviderImpl();
    coreConnector = new ZeroMQBaseConnector();

    ShimSwitchConnectionHandlerImpl handler = new ShimSwitchConnectionHandlerImpl(coreConnector,
            notificationProviderService);
    handler.init();

    coreConnector.RegisterCoreListener(handler);
    coreConnector.setAddress(coreAddress);
    coreConnector.setPort(corePort);

    connectionProvider.setSwitchConnectionHandler(handler);

    connectionProvider.setConfiguration(conf);
    coreConnector.Start();
    connectionProvider.startup();

    netideService = session.addRpcImplementation(NetideService.class, new StatusImpl(handler));
}
 

import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ProviderContext; //导入依赖的package包/类
@Override
public void onSessionInitiated(ProviderContext session) {
	service = session.addRpcImplementation(SdnaService.class, new SdnaImpl());
	dataBroker = session.getSALService(DataBroker.class);
	LOG.info("SdnaProvider Session Initiated");
}
 

import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ProviderContext; //导入依赖的package包/类
@Override
public void onSessionInitiated(ProviderContext session) {
	LOG.info("Router Session Initiated");
	routesWaitingOnArp = Multimaps.synchronizedSetMultimap(HashMultimap.<AtriumIpAddress, RouteEntry> create());
	ribTable4 = new ConcurrentInvertedRadixTree<>(new DefaultByteArrayNodeFactory());
	bgpUpdatesExecutor = Executors
			.newSingleThreadExecutor(new ThreadFactoryBuilder().setNameFormat("atrium-bgp-updates-%d").build());
}
 

import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ProviderContext; //导入依赖的package包/类
@Before
public void setUp() throws Exception {
	setupHostService();
	ribManager = new RibManager(dataBroker, ribReference, hostService, routingConfigService);
	ribManager.onSessionInitiated(mock(ProviderContext.class));
	ribManager.addFibListener(fibListener);
}
 

import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ProviderContext; //导入依赖的package包/类
@Before
public void init() {
	routingConfigService = new RoutingConfigServiceImpl(dataBroker);
	WriteTransaction writeTx = mock(WriteTransaction.class);
	when(dataBroker.newWriteOnlyTransaction()).thenReturn(writeTx);
	routingConfigService.onSessionInitiated(mock(ProviderContext.class));
}
 

import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ProviderContext; //导入依赖的package包/类
@Override
public void onSessionInitiated(ProviderContext session) {
	// Get the mount service provider
       this.mountService = session.getSALService(MountPointService.class);
}
 

import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ProviderContext; //导入依赖的package包/类
@Override
public void onSessionInitiated(ProviderContext providerContext) {
    try {
        this.providerContext = providerContext;
        service.setNotificationProvider(this.providerContext
                .getSALService(NotificationProviderService.class));
        registration = providerContext.addRpcImplementation(
                HelloService.class, service);
        log.info(
                "Registered 'HelloService' implementation '{}' with registration '{}'",
                service, registration);
    } catch (IllegalStateException e) {
        log.error("Unable to register 'HelloService' implementation", e);
    }
}
 

import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ProviderContext; //导入依赖的package包/类
public static ProviderContext createProviderContext(BindingAwareProvider provider,
        ClassToInstanceMap<BindingAwareService> serviceProvider) {
    checkNotNull(provider,"Provider should not be null");
    checkNotNull(serviceProvider,"Service map should not be null");
    return new SingleProviderContextImpl(serviceProvider);
}
 

import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ProviderContext; //导入依赖的package包/类
public static ProviderContext createProviderContextAndInitialize(BindingAwareProvider provider,
        ClassToInstanceMap<BindingAwareService> serviceProvider) {
    ProviderContext context = createProviderContext(provider, serviceProvider);
    provider.onSessionInitiated(context);
    return context;
}
 

import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ProviderContext; //导入依赖的package包/类
public ProviderContext getSession() {
    return session;
}
 

import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ProviderContext; //导入依赖的package包/类
@Override
public void onSessionInitiated(ProviderContext session) {
    LOG.info("Session Initiated: {}",session);
    this.session = session;
}
 

import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ProviderContext; //导入依赖的package包/类
@Override
protected final void onBrokerAvailable(BindingAwareBroker broker, BundleContext context) {
    ProviderContext ctx = broker.registerProvider(this, context);
}
 

import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ProviderContext; //导入依赖的package包/类
@Override
public void onSessionInitiated(ProviderContext session) {
    LOG.info("NegotiatorProvider Session Initiated");
}
 

import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ProviderContext; //导入依赖的package包/类
@Override
public void onSessionInitiated(ProviderContext session) {
    LOG.info("MonitoringProvider Session Initiated");

}
 

import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ProviderContext; //导入依赖的package包/类
@Override
public void onSessionInitiated(ProviderContext providerContext) {
    LOG.info("ReferenceProvider Initiated");
}
 

import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ProviderContext; //导入依赖的package包/类
@Override
public void onSessionInitiated(ProviderContext session) {
	log.info("RoutingserviceConfiguration Session Initiated");
	readConfiguration();
}
 

import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ProviderContext; //导入依赖的package包/类
@Override
public void onSessionInitiated(ProviderContext session) {
	LOG.debug("Host service session starterd");
	hostStore = new ConcurrentHashMap<>();
}
 

import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ProviderContext; //导入依赖的package包/类
public final ProviderContext getProviderContext() {
    return providerContext;
}