aboutsummaryrefslogtreecommitdiffstats
path: root/evc/evcbase/src/main
diff options
context:
space:
mode:
authorMufaddal Makati <mmakati@mmakatimbpr15.cablelabs.com>2015-08-07 13:09:49 -0700
committerMufaddal Makati <mmakati@mmakatimbpr15.cablelabs.com>2015-08-07 13:09:49 -0700
commited73dbf357aff41edcbab401a94e5fbc266d9391 (patch)
treee3561a9290e4bd0de19704228867ec91910e68ed /evc/evcbase/src/main
parentf44f4aa8b5eb244fc7603c17e875eebf0f3b0b67 (diff)
First Commit
Diffstat (limited to 'evc/evcbase/src/main')
-rw-r--r--evc/evcbase/src/main/java/com/cablelabs/vcpe/evc/evcbase/client/EvcClient.java149
-rw-r--r--evc/evcbase/src/main/java/com/cablelabs/vcpe/evc/evcbase/model/Evc.java235
-rw-r--r--evc/evcbase/src/main/java/com/cablelabs/vcpe/evc/evcbase/model/EvcPerformance.java102
-rw-r--r--evc/evcbase/src/main/java/com/cablelabs/vcpe/evc/evcbase/repository/EvcRespository.java21
-rw-r--r--evc/evcbase/src/main/java/com/cablelabs/vcpe/evc/evcbase/repository/EvcRespositoryInMem.java91
5 files changed, 598 insertions, 0 deletions
diff --git a/evc/evcbase/src/main/java/com/cablelabs/vcpe/evc/evcbase/client/EvcClient.java b/evc/evcbase/src/main/java/com/cablelabs/vcpe/evc/evcbase/client/EvcClient.java
new file mode 100644
index 0000000..25fae8b
--- /dev/null
+++ b/evc/evcbase/src/main/java/com/cablelabs/vcpe/evc/evcbase/client/EvcClient.java
@@ -0,0 +1,149 @@
+package com.cablelabs.vcpe.evc.evcbase.client;
+
+import com.cablelabs.vcpe.evc.evcbase.model.Evc;
+
+import javax.ws.rs.client.Client;
+import javax.ws.rs.client.ClientBuilder;
+import javax.ws.rs.client.Entity;
+import javax.ws.rs.client.WebTarget;
+import javax.ws.rs.core.GenericType;
+import javax.ws.rs.core.MediaType;
+import javax.ws.rs.core.Response;
+import java.util.List;
+
+/**
+ * Created by steve on 6/8/15.
+ */
+public class EvcClient {
+
+ private Client client; // provided by Jersey
+
+ public EvcClient() {
+ client = ClientBuilder.newClient();
+ }
+
+ //--------------------------------------------------------
+ public Evc create(Evc evc)
+ //--------------------------------------------------------
+ {
+ WebTarget target =client.target("http://localhost:9090/evcmgr/webapi/");
+ Response response = target.path("evc")
+ .request(MediaType.APPLICATION_JSON)
+ .post(Entity.entity(evc, MediaType.APPLICATION_JSON));
+
+ if (response.getStatus() != 200 ) // figure out how to use Status.OK
+ {
+ // in production you can be more specific based on reponse code, id, etc
+ throw new RuntimeException(response.getStatus() + ": there was an error on the server.");
+ }
+ return response.readEntity(Evc.class);
+ }
+
+ //--------------------------------------------------------
+ public Evc update(Evc evc)
+ //--------------------------------------------------------
+ {
+ WebTarget target =client.target("http://localhost:9090/evcmgr/webapi/");
+ Response response = target.path("evc/"+evc.getId())
+ .request(MediaType.APPLICATION_JSON)
+ .put(Entity.entity(evc, MediaType.APPLICATION_JSON));
+
+ if (response.getStatus() != 200 ) // figure out how to use Status.OK
+ {
+ // in production you can be more specific based on reponse code, id, etc
+ throw new RuntimeException(response.getStatus() + ": there was an error on the server.");
+ }
+ return response.readEntity(Evc.class);
+ }
+
+ //--------------------------------------------------------
+ public Evc get(String evcId)
+ //--------------------------------------------------------
+ // get Evc of specified ID
+
+ {
+ WebTarget target = client.target("http://localhost:9090/evcmgr/webapi/");
+
+ Response response = target.path("evc/"+evcId).request(MediaType.APPLICATION_JSON).get(Response.class);
+ if (response.getStatus() != 200) // figure out how to use Status.OK
+ {
+ // in production you can be more specific based on reponse code, id, etc
+ throw new RuntimeException(response.getStatus() + ": there was an error on the server.");
+ }
+
+ //return response;
+ return response.readEntity(Evc.class);
+ }
+
+ //--------------------------------------------------------
+ public List<Evc> getAll()
+ //--------------------------------------------------------
+ // get a list of all Evc instances
+ {
+
+ WebTarget target = client.target("http://localhost:9090/evcmgr/webapi/");
+
+ // Can I do this with a Response, so that I can check for errors
+ List<Evc> response = target.path("evc/list")
+ .request(MediaType.APPLICATION_JSON)
+ .get(new GenericType<List<Evc>>() {
+ });
+ if (response == null) // figure out how to use Status.OK
+ {
+ // in production you can be more specific based on reponse code, id, etc
+ throw new RuntimeException("there was an error on the server.");
+ }
+ return response;
+ }
+
+ //--------------------------------------------------------
+ public void delete(String evcId)
+ //--------------------------------------------------------
+ // delete Evc of specified ID
+ {
+ WebTarget target = client.target("http://localhost:9090/evcmgr/webapi/");
+ Response response = target.path("evc/"+evcId).request(MediaType.APPLICATION_JSON).delete();
+ if (response.getStatus() != 200) // figure out how to use Status.OK
+ {
+ // in production you can be more specific based on reponse code, id, etc
+ throw new RuntimeException(response.getStatus() + ": there was an error on the server.");
+ }
+ }
+
+ //--------------------------------------------------------
+ public Evc testGet()
+ //--------------------------------------------------------
+ // test marshaling of Evc class from server json
+
+ {
+ WebTarget target = client.target("http://localhost:9090/evcmgr/webapi/");
+
+ Response response = target.path("evc").request(MediaType.APPLICATION_JSON).get(Response.class);
+ if (response.getStatus() != 200) // figure out how to use Status.OK
+ {
+ // in production you can be more specific based on reponse code, id, etc
+ throw new RuntimeException(response.getStatus() + ": there was an error on the server.");
+ }
+
+ //return response;
+ return response.readEntity(Evc.class);
+ }
+
+ //--------------------------------------------------------
+ public String ping()
+ //--------------------------------------------------------
+ // test connectivity
+ {
+
+ WebTarget target = client.target("http://localhost:9090/evcmgr/webapi/");
+
+ Response response = target.path("evc").request(MediaType.TEXT_PLAIN).get();
+ if (response.getStatus() != 200) // figure out how to use Status.OK
+ {
+ // in production you can be more specific based on reponse code, id, etc
+ throw new RuntimeException(response.getStatus() + ": there was an error on the server.");
+ }
+
+ return response.readEntity(String.class);
+ }
+}
diff --git a/evc/evcbase/src/main/java/com/cablelabs/vcpe/evc/evcbase/model/Evc.java b/evc/evcbase/src/main/java/com/cablelabs/vcpe/evc/evcbase/model/Evc.java
new file mode 100644
index 0000000..f44af27
--- /dev/null
+++ b/evc/evcbase/src/main/java/com/cablelabs/vcpe/evc/evcbase/model/Evc.java
@@ -0,0 +1,235 @@
+package com.cablelabs.vcpe.evc.evcbase.model;
+
+import com.cablelabs.vcpe.common.Dbg;
+
+import javax.xml.bind.annotation.XmlRootElement;
+import java.util.List;
+
+/**
+ * Created by steve on 5/24/15.
+ */
+
+@XmlRootElement
+public class Evc
+{
+ // set up so that we can use the ENUM's as strings for REST calls & dbg prints
+
+ public enum EvcType {
+
+ UNASSIGNED ("UNASSIGNED"),
+ POINT_TO_POINT ("POINT_TO_POINT"),
+ MULTIPOINT_TO_MULTIPOINT ("MULTIPOINT_TO_MULTIPOINT"),
+ ROOTED_MULTIPOINT ("ROOTED_MULTIPOINT");
+ private final String s;
+ private EvcType(final String s) {this.s = s;}
+ @Override public String toString() { return s; }
+ }
+ public enum FrameDelivery { // may belong in more general location eventually
+
+ UNASSIGNED ("UNASSIGNED"),
+ DISCARD ("DISCARD"),
+ UNCONDITIONAL ("UNCONDITIONAL"),
+ CONDITIONAL ("CONDITIONAL");
+ private final String s;
+ private FrameDelivery(final String s) {this.s = s;}
+ @Override public String toString() { return s; }
+ }
+
+ private String id;
+ private EvcType evcType;
+ private long maxUnis;
+ private FrameDelivery unicastFrameDelivery;
+ private FrameDelivery multicastFrameDelivery;
+ private FrameDelivery broadcastFrameDelivery;
+ private List<String> uniIdList = null;
+ private List<String> uniIpList = null;
+ private List<String> uniMacList = null;
+ private boolean ceVLanIdPreservation;
+ private boolean ceVlanCosPreservation;
+ private long evcMaxSvcFrameSize; // at least 1522, should be > 1600 byte
+ private String cosId; // CoS Attributes serving as EVCPerformance attr for now
+ //private EvcPerf evcPerf = null;
+
+ // EVC Perf params
+ private double oneWayFrameDelay; // milliseconds
+ private double oneWayFrameLossRatio; // percentage
+ private double oneWayAvailability; // percentage
+
+ // zero argument constructor required for JAX-RS
+ public Evc() {
+ id = "unset";
+ evcType = EvcType.UNASSIGNED;
+ maxUnis = -1;
+ unicastFrameDelivery = FrameDelivery.UNASSIGNED;
+ multicastFrameDelivery = FrameDelivery.UNASSIGNED;;
+ broadcastFrameDelivery = FrameDelivery.UNASSIGNED;;
+ uniIdList = null;
+ uniIpList = null;
+ uniMacList = null;
+ ceVLanIdPreservation = false;
+ ceVlanCosPreservation = false;
+ evcMaxSvcFrameSize = -1;
+ cosId = "unset";
+
+ //evcPerf = new EvcPerf();
+ oneWayFrameDelay = -1.0;
+ oneWayFrameLossRatio = -1.0;
+ oneWayAvailability = -1.0;
+ }
+
+ // Utility methods
+
+ public void setAllNonPerfProps(String id, EvcType evcType, long maxUnis,
+ List<String> uniIdList, List<String> uniMacList, List<String> uniIpList,
+ FrameDelivery unicastFrameDelivery,
+ FrameDelivery multicastFrameDelivery,
+ FrameDelivery broadcastFrameDelivery,
+ boolean ceVLanIdPreservation, boolean ceVlanCosPreservation,
+ long evcMaxSvcFrameSize, String cosId) {
+ this.id = id;
+ this.evcType = evcType;
+ this.uniIdList = uniIdList;
+ this.uniMacList = uniMacList;
+ this.uniIpList = uniIpList;
+ this.maxUnis = maxUnis;
+ this.unicastFrameDelivery = unicastFrameDelivery;
+ this.multicastFrameDelivery = multicastFrameDelivery;
+ this.broadcastFrameDelivery = broadcastFrameDelivery;
+ this.ceVLanIdPreservation = ceVLanIdPreservation;
+ this.ceVlanCosPreservation = ceVlanCosPreservation;
+ this.evcMaxSvcFrameSize = evcMaxSvcFrameSize;
+ this.cosId = cosId;
+ }
+
+ public void setAllPerfProps( double oneWayFrameDelay,
+ double oneWayFrameLossRatio,
+ double oneWayAvailability )
+ {
+ this.oneWayFrameDelay = oneWayFrameDelay;
+ this.oneWayFrameLossRatio = oneWayFrameLossRatio;
+ this.oneWayAvailability = oneWayAvailability;
+ }
+
+ public void dump() { dump(0); }
+ public void dump(int tab) {
+ Dbg.p(tab, "id: " + this.id);
+ Dbg.p(tab, "cosId: " + this.cosId);
+ Dbg.p(tab, "evcType: " + this.evcType);
+ Dbg.p(tab, "maxUnis: " + this.maxUnis);
+ Dbg.p(tab, "Uni ID List:");
+ for (String uniId : uniIdList)
+ Dbg.p(tab+1, uniId);
+ Dbg.p(tab, "Uni Mac List:");
+ for (String macId : uniMacList)
+ Dbg.p(tab+1, macId);
+ Dbg.p(tab, "Uni IP List:");
+ for (String ipAddr : uniIpList)
+ Dbg.p(tab+1, ipAddr);
+ Dbg.p(tab, "UnicastFrameDelivery: " + this.unicastFrameDelivery);
+ Dbg.p(tab, "MulticastFrameDelivery: " + this.multicastFrameDelivery);
+ Dbg.p(tab, "BroadcastFrameDelivery: " + this.broadcastFrameDelivery);
+ Dbg.p(tab, "CeVLanIdPreservation: " + this.ceVLanIdPreservation);
+ Dbg.p(tab, "CeVlanCosPreservation: " + this.ceVlanCosPreservation);
+ Dbg.p(tab, "EvcMaxSvcFrameSize: " + this.evcMaxSvcFrameSize);
+ Dbg.p(tab, "--- EVC Performance Params");
+ Dbg.p(tab+1, "oneWayFrameDelay: " + this.oneWayFrameDelay);
+ Dbg.p(tab+1, "oneWayFrameLossRatio: " + this.oneWayFrameLossRatio);
+ Dbg.p(tab+1, "oneWayAvailability: " + this.oneWayAvailability);
+ }
+
+ public static void dumpList(List<Evc> evcList) { dumpList(0, evcList); }
+ public static void dumpList(int tab, List<Evc> evcList) {
+ int numEvc = 0;
+ Dbg.p("----- Evc List : [" + evcList.size() + "] elements");
+ for (Evc curEvc : evcList) {
+ numEvc++;
+ Dbg.p(tab+1, "<Entry " + numEvc+">");
+ curEvc.dump(tab+2);
+ }
+ }
+
+ // Getters & Setters
+
+ public String getId() { return id; }
+ public void setId(String id) { this.id = id; }
+
+ public EvcType getEvcType() { return evcType; }
+ public void setEvcType(EvcType evcType) { this.evcType = evcType; }
+
+ public long getMaxUnis() { return maxUnis; }
+
+ public void setMaxUnis(long maxUnis) { this.maxUnis = maxUnis; }
+
+ public FrameDelivery getUnicastFrameDelivery() { return unicastFrameDelivery; }
+ public void setUnicastFrameDelivery(FrameDelivery unicastFrameDelivery) {
+ this.unicastFrameDelivery = unicastFrameDelivery; }
+
+ public FrameDelivery getMulticastFrameDelivery() { return multicastFrameDelivery; }
+ public void setMulticastFrameDelivery(FrameDelivery multicastFrameDelivery) {
+ this.multicastFrameDelivery = multicastFrameDelivery; }
+
+ public FrameDelivery getBroadcastFrameDelivery() { return broadcastFrameDelivery; }
+ public void setBroadcastFrameDelivery(FrameDelivery broadcastFrameDelivery) {
+ this.broadcastFrameDelivery = broadcastFrameDelivery; }
+
+ public List<String> getUniIdList() { return uniIdList; }
+ public void setUniIdList(List<String> uniIdList) { this.uniIdList = uniIdList; }
+
+ public List<String> getUniMacList() { return uniMacList; }
+ public void setUniMacList(List<String> uniMacList) { this.uniMacList = uniMacList; }
+
+
+ public List<String> getUniIpList() { return uniIpList; }
+ public void setUniIpList(List<String> uniIpList) { this.uniIpList = uniIpList; }
+
+ public boolean isCeVLanIdPreservation() { return ceVLanIdPreservation; }
+ public void setCeVLanIdPreservation(boolean ceVLanIdPreservation) {
+ this.ceVLanIdPreservation = ceVLanIdPreservation; }
+
+ public boolean isCeVlanCosPreservation() { return ceVlanCosPreservation; }
+
+ public void setCeVlanCosPreservation(boolean ceVlanCosPreservation) {
+ this.ceVlanCosPreservation = ceVlanCosPreservation; }
+
+ public long getEvcMaxSvcFrameSize() { return evcMaxSvcFrameSize; }
+ public void setEvcMaxSvcFrameSize(long evcMaxSvcFrameSize) {
+ this.evcMaxSvcFrameSize = evcMaxSvcFrameSize; }
+
+ public String getCosId() { return cosId; }
+ public void setCosId(String cosId) { this.cosId = cosId; }
+
+ public double getOneWayFrameDelay() { return oneWayFrameDelay; }
+ public void setOneWayFrameDelay(double oneWayFrameDelay) { this.oneWayFrameDelay = oneWayFrameDelay; }
+
+ public double getOneWayFrameLossRatio() { return oneWayFrameLossRatio; }
+ public void setOneWayFrameLossRatio(double oneWayFrameLossRatio) { this.oneWayFrameLossRatio = oneWayFrameLossRatio; }
+
+ public double getOneWayAvailability() { return oneWayAvailability; }
+ public void setOneWayAvailability(double oneWayAvailability) { this.oneWayAvailability = oneWayAvailability; }
+
+
+ // Someday might make sense to put all EVC Perf params in seperate class
+// private class EvcPerf {
+// private long oneWayFrameDelay; // milliseconds
+// private long oneWayFrameDelayRange; // milliseconds
+//
+//
+// public EvcPerf () {
+// this.oneWayFrameDelay = -333;
+// this.oneWayFrameDelayRange = -333;
+// }
+//
+// public void setAllParams (long oneWayFrameDelay, long oneWayFrameDelayRange) {
+// this.oneWayFrameDelay = oneWayFrameDelay;
+// this.oneWayFrameDelayRange = oneWayFrameDelayRange;
+// }
+//
+// public long getOneWayFrameDelay() { return oneWayFrameDelay; }
+// public void setOneWayFrameDelay(long oneWayFrameDelay) {
+// this.oneWayFrameDelay = oneWayFrameDelay; }
+//
+// public long getOneWayFrameDelayRange() { return oneWayFrameDelayRange; }
+// public void setOneWayFrameDelayRange(long oneWayFrameDelayRange) {
+// this.oneWayFrameDelayRange = oneWayFrameDelayRange; }
+// }
+}
diff --git a/evc/evcbase/src/main/java/com/cablelabs/vcpe/evc/evcbase/model/EvcPerformance.java b/evc/evcbase/src/main/java/com/cablelabs/vcpe/evc/evcbase/model/EvcPerformance.java
new file mode 100644
index 0000000..e1bd19e
--- /dev/null
+++ b/evc/evcbase/src/main/java/com/cablelabs/vcpe/evc/evcbase/model/EvcPerformance.java
@@ -0,0 +1,102 @@
+package com.cablelabs.vcpe.evc.evcbase.model;
+
+import com.cablelabs.vcpe.common.Dbg;
+
+/**
+ * Created by steve on 6/9/15.
+ */
+public class EvcPerformance {
+
+ private String cosId; // associated CoS
+ private long oneWayFrameDelay; // milliseconds
+ private long oneWayFrameDelayRange; // milliseconds
+ private long oneWayMeanFrameDelay; // milliseconds
+ private long oneWayInterFrameDelayVariation; // milliseconds
+ private double oneWayFrameLossRatio; // percentage
+ private double oneWayAvailability; // percentage
+ private long oneWayResilHighLossIntervals; //count
+ private long oneWayResilConsecHighLossIntervals; //count
+
+ // zero argument constructor required for JAX-RS
+ public EvcPerformance() {
+ oneWayFrameDelay = -1;
+ oneWayFrameDelayRange = -1;
+ oneWayMeanFrameDelay = -1;
+ oneWayInterFrameDelayVariation = -1;
+ oneWayFrameLossRatio = -1.0;
+ oneWayAvailability = -1.0;
+ oneWayResilHighLossIntervals = -1;
+ oneWayResilConsecHighLossIntervals = -1;
+ }
+
+ public void setAllProps (String cosId, long oneWayFrameDelay, long oneWayFrameDelayRange,
+ long oneWayMeanFrameDelay, long oneWayInterFrameDelayVariation,
+ double oneWayFrameLossRatio, double oneWayAvailability,
+ long oneWayResilHighLossIntervals, long oneWayResilConsecHighLossIntervals)
+ {
+ this.cosId = cosId;
+ this.oneWayFrameDelay = oneWayFrameDelay;
+ this.oneWayFrameDelayRange = oneWayFrameDelayRange;
+ this.oneWayMeanFrameDelay = oneWayMeanFrameDelay;
+ this.oneWayInterFrameDelayVariation = oneWayInterFrameDelayVariation;
+ this.oneWayFrameLossRatio = oneWayFrameLossRatio;
+ this.oneWayAvailability = oneWayAvailability;
+ this.oneWayResilHighLossIntervals = oneWayResilHighLossIntervals;
+ this.oneWayResilConsecHighLossIntervals = oneWayResilConsecHighLossIntervals;
+ }
+
+
+ // util fxns
+
+ public void dump() { dump(0); }
+ public void dump(int tab) {
+ Dbg.p(tab, "cosId: " + this.cosId);
+ Dbg.p(tab, "oneWayFrameDelay: " + this.oneWayFrameDelay);
+ Dbg.p(tab, "oneWayFrameDelayRange: " + this.oneWayFrameDelayRange);
+ Dbg.p(tab, "oneWayMeanFrameDelay: " + this.oneWayMeanFrameDelay);
+ Dbg.p(tab, "oneWayFrameLossRatio: " + this.oneWayFrameLossRatio);
+ Dbg.p(tab, "oneWayAvailability: " + this.oneWayAvailability);
+ Dbg.p(tab, "oneWayInterFrameDelayVariation: " + this.oneWayInterFrameDelayVariation);
+ Dbg.p(tab, "oneWayResilHighLossIntervals: " + this.oneWayResilHighLossIntervals);
+ Dbg.p(tab, "oneWayResilConsecHighLossIntervals: " + this.oneWayResilConsecHighLossIntervals);
+ }
+
+ // Getters and setters
+
+ public String getCosId() { return cosId; }
+ public void setCosId(String cosId) { this.cosId = cosId; }
+
+ public long getOneWayFrameDelay() { return oneWayFrameDelay; }
+ public void setOneWayFrameDelay(long oneWayFrameDelay) {
+ this.oneWayFrameDelay = oneWayFrameDelay; }
+
+ public long getOneWayFrameDelayRange() { return oneWayFrameDelayRange; }
+ public void setOneWayFrameDelayRange(long oneWayFrameDelayRange) {
+ this.oneWayFrameDelayRange = oneWayFrameDelayRange; }
+
+ public long getOneWayMeanFrameDelay() { return oneWayMeanFrameDelay; }
+ public void setOneWayMeanFrameDelay(long oneWayMeanFrameDelay) {
+ this.oneWayMeanFrameDelay = oneWayMeanFrameDelay; }
+
+ public long getOneWayInterFrameDelayVariation() { return oneWayInterFrameDelayVariation; }
+ public void setOneWayInterFrameDelayVariation(long oneWayInterFrameDelayVariation) {
+ this.oneWayInterFrameDelayVariation = oneWayInterFrameDelayVariation; }
+
+ public double getOneWayFrameLossRatio() { return oneWayFrameLossRatio; }
+ public void setOneWayFrameLossRatio(double oneWayFrameLossRatio) {
+ this.oneWayFrameLossRatio = oneWayFrameLossRatio; }
+
+ public double getOneWayAvailability() { return oneWayAvailability; }
+ public void setOneWayAvailability(double oneWayAvailability) {
+ this.oneWayAvailability = oneWayAvailability; }
+
+ public long getOneWayResilHighLossIntervals() { return oneWayResilHighLossIntervals; }
+ public void setOneWayResilHighLossIntervals(long oneWayResilHighLossIntervals) {
+ this.oneWayResilHighLossIntervals = oneWayResilHighLossIntervals; }
+
+ public long getOneWayResilConsecHighLossIntervals() { return oneWayResilConsecHighLossIntervals; }
+ public void setOneWayResilConsecHighLossIntervals(long oneWayResilConsecHighLossIntervals) {
+ this.oneWayResilConsecHighLossIntervals = oneWayResilConsecHighLossIntervals; }
+
+
+}
diff --git a/evc/evcbase/src/main/java/com/cablelabs/vcpe/evc/evcbase/repository/EvcRespository.java b/evc/evcbase/src/main/java/com/cablelabs/vcpe/evc/evcbase/repository/EvcRespository.java
new file mode 100644
index 0000000..80bebc7
--- /dev/null
+++ b/evc/evcbase/src/main/java/com/cablelabs/vcpe/evc/evcbase/repository/EvcRespository.java
@@ -0,0 +1,21 @@
+package com.cablelabs.vcpe.evc.evcbase.repository;
+
+import com.cablelabs.vcpe.evc.evcbase.model.Evc;
+
+import java.util.List;
+
+/**
+ * Created by steve on 5/25/15.
+ */
+public interface EvcRespository
+{
+ // TODO add exceptions
+
+ Evc add(Evc evc); // returns null if already exists, otherwise returns stored evc
+ Evc get(String evcId); // returns null if not found, otherwise stored evc
+ Evc update(Evc evc); // returns null if did not exit, otherwise evc as it was previous to update (put in any case)
+ Evc delete(String evcId); // returns null if not found, otherwise evc as it was previous to delete
+ int count(); // number of Evc stored in the repo
+ public void dump(int tab); // print out contents of the repo
+ List<Evc> getAll();
+}
diff --git a/evc/evcbase/src/main/java/com/cablelabs/vcpe/evc/evcbase/repository/EvcRespositoryInMem.java b/evc/evcbase/src/main/java/com/cablelabs/vcpe/evc/evcbase/repository/EvcRespositoryInMem.java
new file mode 100644
index 0000000..158ae3f
--- /dev/null
+++ b/evc/evcbase/src/main/java/com/cablelabs/vcpe/evc/evcbase/repository/EvcRespositoryInMem.java
@@ -0,0 +1,91 @@
+package com.cablelabs.vcpe.evc.evcbase.repository;
+
+import com.cablelabs.vcpe.common.Dbg;
+import com.cablelabs.vcpe.evc.evcbase.model.Evc;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
+
+/**
+ * Created by steve on 5/24/15.
+ */
+
+
+/*
+ Singleton that contains a hashmap which holds instances of Evc objects, indexed by CiS ID
+ */
+
+public enum EvcRespositoryInMem implements EvcRespository {
+ INSTANCE; // Singleton
+
+ private Map<String, Evc> evcDB = new ConcurrentHashMap<>();
+
+ @Override
+ //--------------------------------------------------------
+ public Evc add(Evc evc)
+ //--------------------------------------------------------
+ {
+ if ( this.get(evc.getId()) != null ) {
+ return null;
+ }
+ evcDB.put(evc.getId(), evc );
+ return evc;
+ }
+
+ @Override
+ //--------------------------------------------------------
+ public Evc get(String evcId) {
+ return evcDB.get(evcId);
+ }
+ //--------------------------------------------------------
+
+ @Override
+ //--------------------------------------------------------
+ public Evc update(Evc evc)
+ //--------------------------------------------------------
+ {
+ // put returns null if evc did not exist, other returns evc as it stood prior to put
+ return evcDB.put(evc.getId(), evc);
+ }
+
+ @Override
+ //--------------------------------------------------------
+ public Evc delete(String evcId)
+ //--------------------------------------------------------
+ {
+ // remove returns null if evc did not exist, other returns evc as it stood prior to remove
+ return evcDB.remove(evcId);
+ }
+
+ @Override
+ //--------------------------------------------------------
+ public int count() {
+ return evcDB.size();
+ }
+ //--------------------------------------------------------
+
+ @Override
+ //--------------------------------------------------------
+ public List<Evc> getAll()
+ //--------------------------------------------------------
+ {
+ List<Evc> evcList = new ArrayList<Evc>(evcDB.values());
+ return evcList;
+ }
+
+ @Override
+ //--------------------------------------------------------
+ public void dump(int tab)
+ //--------------------------------------------------------
+ {
+ Dbg.p(tab, "Evc Repo: " + evcDB.size() + " entrie(s)");
+ int numEvc = 0;
+ for (Evc curEvc : evcDB.values()) {
+ numEvc++;
+ Dbg.p(tab+1, "<Entry " + numEvc+">");
+ curEvc.dump(tab+2);
+ }
+ }
+}