gerrit.opnfv Code Review - onosfw.git/blob

   1 package org.onosproject.provider.pcep.tunnel.impl;
   2
   3 import static org.junit.Assert.assertNotNull;
   4
   5 import java.util.List;
   6 import java.util.concurrent.RejectedExecutionException;
   7
   8 import org.jboss.netty.channel.Channel;
   9 import org.onosproject.pcep.controller.PccId;
  10 import org.onosproject.pcep.controller.PcepClient;
  11 import org.onosproject.pcepio.protocol.PcepFactories;
  12 import org.onosproject.pcepio.protocol.PcepFactory;
  13 import org.onosproject.pcepio.protocol.PcepMessage;
  14 import org.onosproject.pcepio.protocol.PcepVersion;
  15
  16 public class PcepClientAdapter implements PcepClient {
  17
  18     private Channel channel;
  19     protected String channelId;
  20
  21     private boolean connected;
  22     private PccId pccId;
  23
  24     private PcepVersion pcepVersion;
  25
  26     public void init(PccId pccId, PcepVersion pcepVersion) {
  27         this.pccId = pccId;
  28         this.pcepVersion = pcepVersion;
  29     }
  30
  31     @Override
  32     public final void disconnectClient() {
  33         this.channel.close();
  34     }
  35
  36     @Override
  37     public final void sendMessage(PcepMessage m) {
  38     }
  39
  40     @Override
  41     public final void sendMessage(List<PcepMessage> msgs) {
  42         try {
  43             PcepMessage pcepMsg = msgs.get(0);
  44             assertNotNull("PCEP MSG should be created.", pcepMsg);
  45         } catch (RejectedExecutionException e) {
  46             throw e;
  47         }
  48     }
  49
  50     @Override
  51     public final boolean isConnected() {
  52         return this.connected;
  53     }
  54
  55     @Override
  56     public String channelId() {
  57         return channelId;
  58     }
  59
  60     @Override
  61     public final PccId getPccId() {
  62         return this.pccId;
  63     };
  64
  65     @Override
  66     public final String getStringId() {
  67         return this.pccId.toString();
  68     }
  69
  70     @Override
  71     public final void handleMessage(PcepMessage m) {
  72     }
  73
  74     @Override
  75     public boolean isOptical() {
  76         return false;
  77     }
  78
  79     @Override
  80     public PcepFactory factory() {
  81         return PcepFactories.getFactory(pcepVersion);
  82     }
  83
  84     @Override
  85     public final boolean isSyncComplete() {
  86         return false;
  87     }
  88
  89     @Override
  90     public final void setIsSyncComplete(boolean value) {
  91     }
  92 }