本文整理汇总了Java中org.onosproject.incubator.net.resource.label.LabelResourcePool类的典型用法代码示例。如果您正苦于以下问题：Java LabelResourcePool类的具体用法？Java LabelResourcePool怎么用？Java LabelResourcePool使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
LabelResourcePool类属于org.onosproject.incubator.net.resource.label包，在下文中一共展示了LabelResourcePool类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: create
import org.onosproject.incubator.net.resource.label.LabelResourcePool; //导入依赖的package包/类
private boolean create(LabelResourcePool pool) {
Device device = deviceService.getDevice(pool.deviceId());
if (device == null) {
return false;
}
NodeId master = mastershipService.getMasterFor(pool.deviceId());
if (master == null) {
log.warn("Failed to create label resource pool: No master for {}", pool);
return false;
}
if (master.equals(clusterService.getLocalNode().id())) {
return internalCreate(pool);
}
log.trace("Forwarding getFlowEntries to {}, which is the primary (master) for device {}",
master, pool.deviceId());
return complete(clusterCommunicator
.sendAndReceive(pool,
LabelResourceMessageSubjects.LABEL_POOL_CREATED,
SERIALIZER::encode, SERIALIZER::decode,
master));
}
开发者ID:shlee89，项目名称:athena，代码行数:27，代码来源:DistributedLabelResourceStore.java
示例2: createDevicePool
import org.onosproject.incubator.net.resource.label.LabelResourcePool; //导入依赖的package包/类
@Override
public boolean createDevicePool(DeviceId deviceId, LabelResourceId beginLabel, LabelResourceId endLabel) {
LabelResourcePool labelResource = new LabelResourcePool(deviceId.toString(),
beginLabel.labelId(),
endLabel.labelId());
if (resourcePool.containsValue(labelResource)) {
return false;
}
resourcePool.put(deviceId, labelResource);
return true;
}
开发者ID:shlee89，项目名称:athena，代码行数:13，代码来源:BgpTopologyProviderTest.java
示例3: destroyDevicePool
import org.onosproject.incubator.net.resource.label.LabelResourcePool; //导入依赖的package包/类
@Override
public boolean destroyDevicePool(DeviceId deviceId) {
LabelResourcePool devicePool = resourcePool.get(deviceId);
if (devicePool == null) {
return false;
}
resourcePool.remove(deviceId);
return true;
}
开发者ID:shlee89，项目名称:athena，代码行数:12，代码来源:BgpTopologyProviderTest.java
示例4: createDevicePool
import org.onosproject.incubator.net.resource.label.LabelResourcePool; //导入依赖的package包/类
@Override
public boolean createDevicePool(DeviceId deviceId,
LabelResourceId beginLabel,
LabelResourceId endLabel) {
LabelResourcePool pool = new LabelResourcePool(deviceId.toString(),
beginLabel.labelId(),
endLabel.labelId());
return this.create(pool);
}
开发者ID:shlee89，项目名称:athena，代码行数:10，代码来源:DistributedLabelResourceStore.java
示例5: createGlobalPool
import org.onosproject.incubator.net.resource.label.LabelResourcePool; //导入依赖的package包/类
@Override
public boolean createGlobalPool(LabelResourceId beginLabel,
LabelResourceId endLabel) {
LabelResourcePool pool = new LabelResourcePool(GLOBAL_RESOURCE_POOL_DEVICE_ID,
beginLabel.labelId(),
endLabel.labelId());
return this.internalCreate(pool);
}
开发者ID:shlee89，项目名称:athena，代码行数:9，代码来源:DistributedLabelResourceStore.java
示例6: internalCreate
import org.onosproject.incubator.net.resource.label.LabelResourcePool; //导入依赖的package包/类
private boolean internalCreate(LabelResourcePool pool) {
Versioned<LabelResourcePool> poolOld = resourcePool
.get(pool.deviceId());
if (poolOld == null) {
resourcePool.put(pool.deviceId(), pool);
LabelResourceEvent event = new LabelResourceEvent(Type.POOL_CREATED,
pool);
notifyDelegate(event);
return true;
}
return false;
}
开发者ID:shlee89，项目名称:athena，代码行数:13，代码来源:DistributedLabelResourceStore.java
示例7: internalDestroy
import org.onosproject.incubator.net.resource.label.LabelResourcePool; //导入依赖的package包/类
private boolean internalDestroy(DeviceId deviceId) {
Versioned<LabelResourcePool> poolOld = resourcePool.get(deviceId);
if (poolOld != null) {
resourcePool.remove(deviceId);
LabelResourceEvent event = new LabelResourceEvent(Type.POOL_DESTROYED,
poolOld.value());
notifyDelegate(event);
}
log.info("success to destroy the label resource pool of device id {}",
deviceId);
return true;
}
开发者ID:shlee89，项目名称:athena，代码行数:13，代码来源:DistributedLabelResourceStore.java
示例8: isDevicePoolFull
import org.onosproject.incubator.net.resource.label.LabelResourcePool; //导入依赖的package包/类
@Override
public boolean isDevicePoolFull(DeviceId deviceId) {
Versioned<LabelResourcePool> pool = resourcePool.get(deviceId);
if (pool == null) {
return true;
}
return pool.value().currentUsedMaxLabelId() == pool.value().endLabel()
&& pool.value().releaseLabelId().size() == 0 ? true : false;
}
开发者ID:shlee89，项目名称:athena，代码行数:10，代码来源:DistributedLabelResourceStore.java
示例9: getFreeNumOfDevicePool
import org.onosproject.incubator.net.resource.label.LabelResourcePool; //导入依赖的package包/类
@Override
public long getFreeNumOfDevicePool(DeviceId deviceId) {
Versioned<LabelResourcePool> pool = resourcePool.get(deviceId);
if (pool == null) {
return 0;
}
return pool.value().endLabel().labelId()
- pool.value().currentUsedMaxLabelId().labelId()
+ pool.value().releaseLabelId().size();
}
开发者ID:shlee89，项目名称:athena，代码行数:11，代码来源:DistributedLabelResourceStore.java
示例10: execute
import org.onosproject.incubator.net.resource.label.LabelResourcePool; //导入依赖的package包/类
@Override
protected void execute() {
LabelResourceService lrs = get(LabelResourceService.class);
LabelResourcePool pool = lrs.getDeviceLabelResourcePool(DeviceId
.deviceId(deviceId));
if (pool != null) {
print(FMT, pool.deviceId().toString(), pool.beginLabel(),
pool.endLabel(), pool.totalNum(), pool.usedNum(),
pool.currentUsedMaxLabelId(), pool.releaseLabelId()
.toString());
} else {
print(FMT, deviceId, null, null, null, null, null, null);
}
}
开发者ID:shlee89，项目名称:athena，代码行数:15，代码来源:LabelResourceCommand.java
示例11: execute
import org.onosproject.incubator.net.resource.label.LabelResourcePool; //导入依赖的package包/类
@Override
protected void execute() {
LabelResourceService lrs = get(LabelResourceService.class);
LabelResourcePool pool = lrs.getGlobalLabelResourcePool();
if (pool != null) {
print(FMT, pool.deviceId().toString(), pool.beginLabel(),
pool.endLabel(), pool.totalNum(), pool.usedNum(),
pool.currentUsedMaxLabelId(), pool.releaseLabelId()
.toString());
}
}
开发者ID:shlee89，项目名称:athena，代码行数:12，代码来源:GlobalLabelCommand.java
示例12: getDeviceLabelResourcePool
import org.onosproject.incubator.net.resource.label.LabelResourcePool; //导入依赖的package包/类
@Override
public LabelResourcePool getDeviceLabelResourcePool(DeviceId deviceId) {
checkNotNull(deviceId, "deviceId is not null");
return store.getDeviceLabelResourcePool(deviceId);
}
开发者ID:shlee89，项目名称:athena，代码行数:6，代码来源:LabelResourceManager.java
示例13: getGlobalLabelResourcePool
import org.onosproject.incubator.net.resource.label.LabelResourcePool; //导入依赖的package包/类
@Override
public LabelResourcePool getGlobalLabelResourcePool() {
return store.getGlobalLabelResourcePool();
}
开发者ID:shlee89，项目名称:athena，代码行数:5，代码来源:LabelResourceManager.java
示例14: activate
import org.onosproject.incubator.net.resource.label.LabelResourcePool; //导入依赖的package包/类
@Activate
public void activate() {
resourcePool = storageService
.<DeviceId, LabelResourcePool>consistentMapBuilder()
.withName(POOL_MAP_NAME).withSerializer(SERIALIZER)
.withPartitionsDisabled().build();
messageHandlingExecutor = Executors
.newFixedThreadPool(MESSAGE_HANDLER_THREAD_POOL_SIZE,
groupedThreads("onos/store/flow",
"message-handlers"));
clusterCommunicator
.addSubscriber(LabelResourceMessageSubjects.LABEL_POOL_CREATED,
SERIALIZER::<LabelResourcePool>decode,
operation -> {
log.trace("received get flow entry request for {}", operation);
return internalCreate(operation);
},
SERIALIZER::<Boolean>encode,
messageHandlingExecutor);
clusterCommunicator
.addSubscriber(LabelResourceMessageSubjects.LABEL_POOL_DESTROYED,
SERIALIZER::<DeviceId>decode,
deviceId -> {
log.trace("received get flow entry request for {}", deviceId);
return internalDestroy(deviceId);
},
SERIALIZER::<Boolean>encode,
messageHandlingExecutor);
clusterCommunicator
.addSubscriber(LabelResourceMessageSubjects.LABEL_POOL_APPLY,
SERIALIZER::<LabelResourceRequest>decode,
request -> {
log.trace("received get flow entry request for {}", request);
return internalApply(request);
},
SERIALIZER::<Collection<LabelResource>>encode,
messageHandlingExecutor);
clusterCommunicator
.addSubscriber(LabelResourceMessageSubjects.LABEL_POOL_RELEASE,
SERIALIZER::<LabelResourceRequest>decode,
request -> {
log.trace("received get flow entry request for {}",
request);
return internalRelease(request);
},
SERIALIZER::<Boolean>encode,
messageHandlingExecutor);
log.info("Started");
}
开发者ID:shlee89，项目名称:athena，代码行数:52，代码来源:DistributedLabelResourceStore.java
示例15: internalRelease
import org.onosproject.incubator.net.resource.label.LabelResourcePool; //导入依赖的package包/类
private boolean internalRelease(LabelResourceRequest request) {
DeviceId deviceId = request.deviceId();
Collection<LabelResource> release = request.releaseCollection();
Versioned<LabelResourcePool> poolOld = resourcePool.get(deviceId);
if (poolOld == null) {
log.info("the label resource pool of device id {} not allocated");
return false;
}
LabelResourcePool pool = poolOld.value();
if (pool == null) {
log.info("the label resource pool of device id {} does not exist");
return false;
}
Set<LabelResource> storeSet = new HashSet<>(pool.releaseLabelId());
LabelResource labelResource = null;
long realReleasedNum = 0;
for (Iterator<LabelResource> it = release.iterator(); it.hasNext();) {
labelResource = it.next();
if (labelResource.labelResourceId().labelId() < pool.beginLabel()
.labelId()
|| labelResource.labelResourceId().labelId() > pool
.endLabel().labelId()) {
continue;
}
if (pool.currentUsedMaxLabelId().labelId() > labelResource
.labelResourceId().labelId()
|| !storeSet.contains(labelResource)) {
storeSet.add(labelResource);
realReleasedNum++;
}
}
long beginNum = pool.beginLabel().labelId();
long endNum = pool.endLabel().labelId();
long totalNum = pool.totalNum();
long usedNum = pool.usedNum() - realReleasedNum;
long current = pool.currentUsedMaxLabelId().labelId();
ImmutableSet<LabelResource> s = ImmutableSet.copyOf(storeSet);
LabelResourcePool newPool = new LabelResourcePool(deviceId.toString(),
beginNum, endNum,
totalNum, usedNum,
current, s);
resourcePool.put(deviceId, newPool);
log.info("success to release label resource");
return true;
}
开发者ID:shlee89，项目名称:athena，代码行数:46，代码来源:DistributedLabelResourceStore.java
示例16: getDeviceLabelResourcePool
import org.onosproject.incubator.net.resource.label.LabelResourcePool; //导入依赖的package包/类
@Override
public LabelResourcePool getDeviceLabelResourcePool(DeviceId deviceId) {
Versioned<LabelResourcePool> pool = resourcePool.get(deviceId);
return pool == null ? null : pool.value();
}
开发者ID:shlee89，项目名称:athena，代码行数:6，代码来源:DistributedLabelResourceStore.java
示例17: getGlobalLabelResourcePool
import org.onosproject.incubator.net.resource.label.LabelResourcePool; //导入依赖的package包/类
@Override
public LabelResourcePool getGlobalLabelResourcePool() {
return this.getDeviceLabelResourcePool(DeviceId
.deviceId(GLOBAL_RESOURCE_POOL_DEVICE_ID));
}
开发者ID:shlee89，项目名称:athena，代码行数:6，代码来源:DistributedLabelResourceStore.java
示例18: getDeviceLabelResourcePool
import org.onosproject.incubator.net.resource.label.LabelResourcePool; //导入依赖的package包/类
@Override
public LabelResourcePool getDeviceLabelResourcePool(DeviceId deviceId) {
return null;
}
开发者ID:shlee89，项目名称:athena，代码行数:5，代码来源:LabelResourceAdapter.java
示例19: getGlobalLabelResourcePool
import org.onosproject.incubator.net.resource.label.LabelResourcePool; //导入依赖的package包/类
@Override
public LabelResourcePool getGlobalLabelResourcePool() {
return null;
}
开发者ID:shlee89，项目名称:athena，代码行数:5，代码来源:LabelResourceAdapter.java
示例20: activate
import org.onosproject.incubator.net.resource.label.LabelResourcePool; //导入依赖的package包/类
@Activate
public void activate() {
resourcePool = storageService
.<DeviceId, LabelResourcePool>consistentMapBuilder()
.withName(POOL_MAP_NAME).withSerializer(SERIALIZER).build();
messageHandlingExecutor = Executors
.newFixedThreadPool(MESSAGE_HANDLER_THREAD_POOL_SIZE,
groupedThreads("onos/store/flow",
"message-handlers",
log));
clusterCommunicator
.addSubscriber(LabelResourceMessageSubjects.LABEL_POOL_CREATED,
SERIALIZER::<LabelResourcePool>decode,
operation -> {
log.trace("received get flow entry request for {}", operation);
return internalCreate(operation);
},
SERIALIZER::<Boolean>encode,
messageHandlingExecutor);
clusterCommunicator
.addSubscriber(LabelResourceMessageSubjects.LABEL_POOL_DESTROYED,
SERIALIZER::<DeviceId>decode,
deviceId -> {
log.trace("received get flow entry request for {}", deviceId);
return internalDestroy(deviceId);
},
SERIALIZER::<Boolean>encode,
messageHandlingExecutor);
clusterCommunicator
.addSubscriber(LabelResourceMessageSubjects.LABEL_POOL_APPLY,
SERIALIZER::<LabelResourceRequest>decode,
request -> {
log.trace("received get flow entry request for {}", request);
return internalApply(request);
},
SERIALIZER::<Collection<LabelResource>>encode,
messageHandlingExecutor);
clusterCommunicator
.addSubscriber(LabelResourceMessageSubjects.LABEL_POOL_RELEASE,
SERIALIZER::<LabelResourceRequest>decode,
request -> {
log.trace("received get flow entry request for {}",
request);
return internalRelease(request);
},
SERIALIZER::<Boolean>encode,
messageHandlingExecutor);
log.info("Started");
}
开发者ID:opennetworkinglab，项目名称:onos，代码行数:52，代码来源:DistributedLabelResourceStore.java
注：本文中的org.onosproject.incubator.net.resource.label.LabelResourcePool类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
请发表评论