git.opendaylight Code Review

author	Shigeru Yasuda <s-yasuda@da.jp.nec.com>
	Thu, 3 Mar 2016 19:51:03 +0000 (04:51 +0900)
committer	Shigeru Yasuda <s-yasuda@da.jp.nec.com>
	Fri, 4 Mar 2016 04:40:54 +0000 (04:40 +0000)
commit	890069f373421ffc9297b1f14fa362d49f4d01d4
tree	999ea2edd4faff1583fd1985f1d26e7cf66cca0a	tree \| snapshot
parent	1ad4286f66e3553af96af771f2373dd81113d451	commit \| diff

Bug 5459: Cancel ongoing RPCs routed to the removed node.

Ongoing add-flow/remove-flow RPCs may not return result until timeout
if the target node is removed. This may block VTN internal threads.
This patch keeps track of node-routed RPCs, and cancels all the ongoing
RPCs routed to removed nodes.

Change-Id: I0f2485512ccadd88350f33a6887869c16f7222a5
Signed-off-by: Shigeru Yasuda <s-yasuda@da.jp.nec.com>
(cherry picked from commit bea45d2424bed23f511097fc6229ee7dc2dff63b)

38 files changed:

manager/implementation/src/main/java/org/opendaylight/vtn/manager/internal/VTNManagerProvider.java		diff \| blob \| history
manager/implementation/src/main/java/org/opendaylight/vtn/manager/internal/flow/add/FlowAddTask.java		diff \| blob \| history
manager/implementation/src/main/java/org/opendaylight/vtn/manager/internal/flow/remove/ClearNodeFlowsTask.java		diff \| blob \| history
manager/implementation/src/main/java/org/opendaylight/vtn/manager/internal/flow/remove/NodeFlowRemover.java		diff \| blob \| history
manager/implementation/src/main/java/org/opendaylight/vtn/manager/internal/flow/remove/PortFlowRemover.java		diff \| blob \| history
manager/implementation/src/main/java/org/opendaylight/vtn/manager/internal/flow/remove/RemovedAllFlows.java		diff \| blob \| history
manager/implementation/src/main/java/org/opendaylight/vtn/manager/internal/flow/remove/RemovedDataFlow.java		diff \| blob \| history
manager/implementation/src/main/java/org/opendaylight/vtn/manager/internal/flow/remove/RemovedDataFlows.java		diff \| blob \| history
manager/implementation/src/main/java/org/opendaylight/vtn/manager/internal/flow/remove/RemovedPortFlows.java		diff \| blob \| history
manager/implementation/src/main/java/org/opendaylight/vtn/manager/internal/flow/remove/ScanFlowRemover.java		diff \| blob \| history
manager/implementation/src/main/java/org/opendaylight/vtn/manager/internal/flow/remove/TenantFlowRemover.java		diff \| blob \| history
manager/implementation/src/main/java/org/opendaylight/vtn/manager/internal/flow/remove/TenantIndexFlowRemover.java		diff \| blob \| history
manager/implementation/src/main/java/org/opendaylight/vtn/manager/internal/flow/stats/StatsReaderService.java		diff \| blob \| history
manager/implementation/src/main/java/org/opendaylight/vtn/manager/internal/inventory/VTNInventoryManager.java		diff \| blob \| history
manager/implementation/src/main/java/org/opendaylight/vtn/manager/internal/inventory/VtnNodeManager.java	[new file with mode: 0644]	blob
manager/implementation/src/main/java/org/opendaylight/vtn/manager/internal/packet/TransmitPacketRpc.java	[new file with mode: 0644]	blob
manager/implementation/src/main/java/org/opendaylight/vtn/manager/internal/packet/VTNPacketService.java		diff \| blob \| history
manager/implementation/src/main/java/org/opendaylight/vtn/manager/internal/provider/VTNManagerProviderImpl.java		diff \| blob \| history
manager/implementation/src/main/java/org/opendaylight/vtn/manager/internal/util/flow/AddFlowRpc.java		diff \| blob \| history
manager/implementation/src/main/java/org/opendaylight/vtn/manager/internal/util/flow/FlowUtils.java		diff \| blob \| history
manager/implementation/src/main/java/org/opendaylight/vtn/manager/internal/util/flow/GetFlowStatsRpc.java		diff \| blob \| history
manager/implementation/src/main/java/org/opendaylight/vtn/manager/internal/util/flow/RemoveFlowRpc.java		diff \| blob \| history
manager/implementation/src/main/java/org/opendaylight/vtn/manager/internal/util/flow/RemoveFlowRpcList.java		diff \| blob \| history
manager/implementation/src/main/java/org/opendaylight/vtn/manager/internal/util/inventory/NodeRpcErrorCallback.java	[new file with mode: 0644]	blob
manager/implementation/src/main/java/org/opendaylight/vtn/manager/internal/util/inventory/NodeRpcInvocation.java	[new file with mode: 0644]	blob
manager/implementation/src/main/java/org/opendaylight/vtn/manager/internal/util/inventory/NodeRpcWatcher.java	[new file with mode: 0644]	blob
manager/implementation/src/main/java/org/opendaylight/vtn/manager/internal/util/rpc/RpcErrorCallback.java		diff \| blob \| history
manager/implementation/src/main/java/org/opendaylight/vtn/manager/internal/util/rpc/RpcInvocation.java		diff \| blob \| history
manager/implementation/src/test/java/org/opendaylight/vtn/manager/internal/inventory/VTNInventoryManagerTest.java		diff \| blob \| history
manager/implementation/src/test/java/org/opendaylight/vtn/manager/internal/inventory/VtnNodeManagerTest.java	[new file with mode: 0644]	blob
manager/implementation/src/test/java/org/opendaylight/vtn/manager/internal/packet/TransmitPacketRpcTest.java	[new file with mode: 0644]	blob
manager/implementation/src/test/java/org/opendaylight/vtn/manager/internal/util/flow/AddFlowRpcTest.java		diff \| blob \| history
manager/implementation/src/test/java/org/opendaylight/vtn/manager/internal/util/flow/FlowUtilsTest.java		diff \| blob \| history
manager/implementation/src/test/java/org/opendaylight/vtn/manager/internal/util/flow/GetFlowStatsRpcTest.java		diff \| blob \| history
manager/implementation/src/test/java/org/opendaylight/vtn/manager/internal/util/flow/RemoveFlowRpcListTest.java		diff \| blob \| history
manager/implementation/src/test/java/org/opendaylight/vtn/manager/internal/util/flow/RemoveFlowRpcTest.java		diff \| blob \| history
manager/implementation/src/test/java/org/opendaylight/vtn/manager/internal/util/inventory/NodeRpcErrorCallbackTest.java	[new file with mode: 0644]	blob
manager/implementation/src/test/java/org/opendaylight/vtn/manager/internal/util/inventory/NodeRpcInvocationTest.java	[new file with mode: 0644]	blob

OpenDaylight Virtual Tenant Network

RSS Atom