- public Future<RpcResult<BarrierOutput>> barrier(final BarrierInput input) {
- return sendToSwitchExpectRpcResultFuture(
- input, BarrierOutput.class, "barrier-input sending failed");
- }
-
- @Override
- public Future<RpcResult<EchoOutput>> echo(final EchoInput input) {
- return sendToSwitchExpectRpcResultFuture(
- input, EchoOutput.class, "echo-input sending failed");
- }
-
- @Override
- public Future<RpcResult<Void>> echoReply(final EchoReplyInput input) {
- return sendToSwitchFuture(input, "echo-reply sending failed");
- }
-
- @Override
- public Future<RpcResult<Void>> experimenter(final ExperimenterInput input) {
- return sendToSwitchFuture(input, "experimenter sending failed");
- }
-
- @Override
- public Future<RpcResult<Void>> flowMod(final FlowModInput input) {
- statisticsCounters.incrementCounter(CounterEventTypes.DS_FLOW_MODS_ENTERED);
- return sendToSwitchFuture(input, "flow-mod sending failed");
- }
-
- @Override
- public Future<RpcResult<GetConfigOutput>> getConfig(final GetConfigInput input) {
- return sendToSwitchExpectRpcResultFuture(
- input, GetConfigOutput.class, "get-config-input sending failed");
- }
-
- @Override
- public Future<RpcResult<GetFeaturesOutput>> getFeatures(
- final GetFeaturesInput input) {
- return sendToSwitchExpectRpcResultFuture(
- input, GetFeaturesOutput.class, "get-features-input sending failed");
- }
-
- @Override
- public Future<RpcResult<GetQueueConfigOutput>> getQueueConfig(
- final GetQueueConfigInput input) {
- return sendToSwitchExpectRpcResultFuture(
- input, GetQueueConfigOutput.class, "get-queue-config-input sending failed");
- }
-
- @Override
- public Future<RpcResult<Void>> groupMod(final GroupModInput input) {
- return sendToSwitchFuture(input, "group-mod-input sending failed");
- }
-
- @Override
- public Future<RpcResult<Void>> hello(final HelloInput input) {
- return sendToSwitchFuture(input, "hello-input sending failed");
- }
-
- @Override
- public Future<RpcResult<Void>> meterMod(final MeterModInput input) {
- return sendToSwitchFuture(input, "meter-mod-input sending failed");
- }
-
- @Override
- public Future<RpcResult<Void>> packetOut(final PacketOutInput input) {
- return sendToSwitchFuture(input, "packet-out-input sending failed");
- }
-
- @Override
- public Future<RpcResult<Void>> multipartRequest(final MultipartRequestInput input) {
- return sendToSwitchFuture(input, "multi-part-request sending failed");
- }
-
- @Override
- public Future<RpcResult<Void>> portMod(final PortModInput input) {
- return sendToSwitchFuture(input, "port-mod-input sending failed");
- }
-
- @Override
- public Future<RpcResult<RoleRequestOutput>> roleRequest(
- final RoleRequestInput input) {
- return sendToSwitchExpectRpcResultFuture(
- input, RoleRequestOutput.class, "role-request-config-input sending failed");
- }
-
- @Override
- public Future<RpcResult<Void>> setConfig(final SetConfigInput input) {
- return sendToSwitchFuture(input, "set-config-input sending failed");
- }
-
- @Override
- public Future<RpcResult<Void>> tableMod(final TableModInput input) {
- return sendToSwitchFuture(input, "table-mod-input sending failed");
- }
-
- @Override
- public Future<RpcResult<GetAsyncOutput>> getAsync(final GetAsyncInput input) {
- return sendToSwitchExpectRpcResultFuture(
- input, GetAsyncOutput.class, "get-async-input sending failed");
- }
-
- @Override
- public Future<RpcResult<Void>> setAsync(final SetAsyncInput input) {
- return sendToSwitchFuture(input, "set-async-input sending failed");
- }
-
- @Override
- public Future<Boolean> disconnect() {
- final ChannelFuture disconnectResult = channel.disconnect();
- responseCache.invalidateAll();
- disconnectOccured = true;
-
- return handleTransportChannelFuture(disconnectResult);