Merge "Updated rpcResult for GetEgressPointer"
authorPrem Sankar <prem.sankar.g@ericsson.com>
Thu, 7 May 2015 23:04:03 +0000 (23:04 +0000)
committerGerrit Code Review <gerrit@opendaylight.org>
Thu, 7 May 2015 23:04:03 +0000 (23:04 +0000)
1  2 
nexthopmgr/nexthopmgr-impl/src/main/java/org/opendaylight/vpnservice/nexthopmgr/NexthopManager.java

index 1b04ca03852be2713569860c1ab34557130c9a80,8239e9a8eb8c90e702e815ed30eaf12c19998068..546e60f8a91ee5970da596eb3d4cfdf3b9c1d66e
@@@ -17,13 -17,13 +17,13 @@@ import com.google.common.base.Optional
  import com.google.common.util.concurrent.Futures;
  import com.google.common.util.concurrent.FutureCallback;
  
- //import org.opendaylight.controller.netconf.confignetconfconnector.mapping.rpc.Rpcs;
  import org.opendaylight.controller.md.sal.binding.api.DataBroker;
  import org.opendaylight.controller.md.sal.binding.api.WriteTransaction;
  import org.opendaylight.yangtools.yang.binding.DataObject;
  import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  import org.opendaylight.yangtools.yang.binding.InstanceIdentifier.InstanceIdentifierBuilder;
  import org.opendaylight.yangtools.yang.common.RpcResult;
+ import org.opendaylight.yangtools.yang.common.RpcResultBuilder;
  import org.opendaylight.controller.md.sal.binding.api.ReadOnlyTransaction;
  import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
  import org.opendaylight.yang.gen.v1.urn.huawei.params.xml.ns.yang.l3vpn.rev140815.VpnInstances;
@@@ -79,6 -79,7 +79,6 @@@ public class NexthopManager implements 
      */
      public NexthopManager(final DataBroker db) {
          broker = db;
 -        createNexthopPointerPool();
      }
  
      @Override
@@@ -98,7 -99,7 +98,7 @@@
          this.idManager = idManager;
      }
  
 -    private void createNexthopPointerPool() {
 +    protected void createNexthopPointerPool() {
          CreateIdPoolInput createPool = new CreateIdPoolInputBuilder()
              .setPoolName("nextHopPointerPool")
              .setIdStart(1L)
          GetEgressPointerOutputBuilder output = new GetEgressPointerOutputBuilder();
          output.setEgressPointer(egressGroupId);
  
-         RpcResult<GetEgressPointerOutput> result = null;
-         //Rpcs.<GetEgressPointerOutput> getRpcResult(false, output.build());
-         return Futures.immediateFuture(result); 
+         RpcResultBuilder<GetEgressPointerOutput> rpcResultBuilder = RpcResultBuilder.success();
+         rpcResultBuilder.withResult(output.build());
+         return Futures.immediateFuture(rpcResultBuilder.build());
+         
      }
  
      private <T extends DataObject> Optional<T> read(LogicalDatastoreType datastoreType,
          Futures.addCallback(tx.submit(), DEFAULT_CALLBACK);
      }
  
--}
++}