Changeset 590
- Timestamp:
- 03/25/11 18:57:37 (2 years ago)
- Location:
- raptor-ua/trunk/src/main/java/uk/ac/cardiff/RaptorUA
- Files:
-
- 10 edited
-
dao/UADataConnection.java (modified) (1 diff)
-
dao/UADataConnectionImpl.java (modified) (1 diff)
-
engine/EntryReleaseEngine.java (modified) (3 diffs)
-
engine/UnitAggregatorEngine.java (modified) (3 diffs)
-
engine/sei/ServiceEndpointInterface.java (modified) (3 diffs)
-
model/EntryHandler.java (modified) (2 diffs)
-
model/MemoryEntryHandler.java (modified) (3 diffs)
-
model/PersistantEntryHandler.java (modified) (6 diffs)
-
service/impl/UAProcessImpl.java (modified) (2 diffs)
-
wsinterface/impl/UnitAggregatorImpl.java (modified) (1 diff)
Legend:
- Unmodified
- Added
- Removed
-
raptor-ua/trunk/src/main/java/uk/ac/cardiff/RaptorUA/dao/UADataConnection.java
r361 r590 22 22 import java.util.List; 23 23 24 import uk.ac.cardiff.model.E ntry;24 import uk.ac.cardiff.model.Event; 25 25 26 26 /** -
raptor-ua/trunk/src/main/java/uk/ac/cardiff/RaptorUA/dao/UADataConnectionImpl.java
r411 r590 32 32 import org.springframework.orm.hibernate3.HibernateTemplate; 33 33 34 import uk.ac.cardiff.model.E ntry;34 import uk.ac.cardiff.model.Event; 35 35 36 36 /** -
raptor-ua/trunk/src/main/java/uk/ac/cardiff/RaptorUA/engine/EntryReleaseEngine.java
r411 r590 30 30 import uk.ac.cardiff.RaptorUA.model.EntryHandler; 31 31 import uk.ac.cardiff.RaptorUA.model.MUAEntry; 32 import uk.ac.cardiff.model.E ntry;32 import uk.ac.cardiff.model.Event; 33 33 import uk.ac.cardiff.model.ICAMetadata; 34 34 import uk.ac.cardiff.model.UAMetadata; … … 47 47 */ 48 48 public boolean release(EntryHandler entryHandler, MUARegistry muaRegistry, UAMetadata uaMetaData) { 49 Set<E ntry> allEntries = entryHandler.getEntries();49 Set<Event> allEntries = entryHandler.getEntries(); 50 50 log.debug("Releasing {} entries to approved MUAs",entryHandler.getEntries().size()); 51 51 boolean releasedtoAll = true; … … 74 74 } 75 75 76 private UAEntryPush constructEntryPush(UAMetadata uaMetaData, Set<E ntry> entries){76 private UAEntryPush constructEntryPush(UAMetadata uaMetaData, Set<Event> entries){ 77 77 UAEntryPush pushMessage = new UAEntryPush(); 78 78 pushMessage.setUaMetaData(uaMetaData); -
raptor-ua/trunk/src/main/java/uk/ac/cardiff/RaptorUA/engine/UnitAggregatorEngine.java
r444 r590 31 31 import uk.ac.cardiff.RaptorUA.model.ICAEntry; 32 32 import uk.ac.cardiff.RaptorUA.model.MemoryEntryHandler; 33 import uk.ac.cardiff.model.E ntry;33 import uk.ac.cardiff.model.Event; 34 34 import uk.ac.cardiff.model.ICAMetadata; 35 35 import uk.ac.cardiff.model.ShibbolethEntry; … … 102 102 log.info("Outputting All Entries to StdOut"); 103 103 int count = 0; 104 for (E ntryentryObject : entryHandler.getEntries()) {104 for (Event entryObject : entryHandler.getEntries()) { 105 105 if (entryObject instanceof ShibbolethEntry) 106 106 log.info(count + ". Stored Entry -- " + ((ShibbolethEntry) entryObject)); … … 114 114 */ 115 115 public Set getAllAuthentications() { 116 LinkedHashSet<E ntry> returnedAuths = new LinkedHashSet();117 for (E ntryentry : entryHandler.getEntries())116 LinkedHashSet<Event> returnedAuths = new LinkedHashSet(); 117 for (Event entry : entryHandler.getEntries()) 118 118 returnedAuths.add(entry); 119 119 -
raptor-ua/trunk/src/main/java/uk/ac/cardiff/RaptorUA/engine/sei/ServiceEndpointInterface.java
r464 r590 32 32 import uk.ac.cardiff.RaptorUA.engine.UnitAggregatorEngine; 33 33 import uk.ac.cardiff.model.AuthenticationEntry; 34 import uk.ac.cardiff.model.E ntry;34 import uk.ac.cardiff.model.Event; 35 35 import uk.ac.cardiff.model.ShibbolethEntry; 36 36 import uk.ac.cardiff.model.UsageEntry; … … 69 69 Collector client = (Collector) factory.create(); 70 70 log.debug("Accessing the ICA version "+client.getVersion()); 71 Set<E ntry> auths = client.getAllAuthentications();71 Set<Event> auths = client.getAllAuthentications(); 72 72 log.debug("Retrieved "+auths.size()+" authentications from the ICA ["+endpoint+"]"); 73 73 // for (Entry ent : auths){// … … 138 138 Collector client = (Collector) factory.create(); 139 139 log.debug("Accessing the ICA version "+client.getVersion()); 140 Set<E ntry> auths = client.getAllUsages();140 Set<Event> auths = client.getAllUsages(); 141 141 log.debug("Retrieved "+auths.size()+" usages"); 142 142 // for (Entry ent : auths){// -
raptor-ua/trunk/src/main/java/uk/ac/cardiff/RaptorUA/model/EntryHandler.java
r444 r590 26 26 import java.util.Set; 27 27 28 import uk.ac.cardiff.model.E ntry;28 import uk.ac.cardiff.model.Event; 29 29 30 30 import org.apache.log4j.Logger; … … 36 36 37 37 38 public void addEntries(Set<E ntry> entries);38 public void addEntries(Set<Event> entries); 39 39 40 public Set<E ntry> getEntries();40 public Set<Event> getEntries(); 41 41 42 public void setEntries(Set<E ntry> entries);42 public void setEntries(Set<Event> entries); 43 43 44 44 public void removeAllEntries(); -
raptor-ua/trunk/src/main/java/uk/ac/cardiff/RaptorUA/model/MemoryEntryHandler.java
r464 r590 27 27 import org.slf4j.LoggerFactory; 28 28 29 import uk.ac.cardiff.model.E ntry;29 import uk.ac.cardiff.model.Event; 30 30 import uk.ac.cardiff.model.ShibbolethEntry; 31 31 … … 38 38 39 39 /* set of all entries stored by this EntryHanlder */ 40 Set<E ntry> entries;40 Set<Event> entries; 41 41 42 42 public MemoryEntryHandler() { 43 entries = new LinkedHashSet<E ntry>();43 entries = new LinkedHashSet<Event>(); 44 44 } 45 45 46 public void addEntries(Set<E ntry> entries) {46 public void addEntries(Set<Event> entries) { 47 47 log.info("Adding " + entries.size() + " entries to the UA"); 48 for (E ntryentry : entries) {48 for (Event entry : entries) { 49 49 this.entries.add(entry); 50 50 } … … 60 60 } 61 61 62 public void setEntries(Set<E ntry> entries) {62 public void setEntries(Set<Event> entries) { 63 63 this.entries = entries; 64 64 } -
raptor-ua/trunk/src/main/java/uk/ac/cardiff/RaptorUA/model/PersistantEntryHandler.java
r464 r590 30 30 31 31 import uk.ac.cardiff.RaptorUA.dao.UADataConnection; 32 import uk.ac.cardiff.model.E ntry;32 import uk.ac.cardiff.model.Event; 33 33 import uk.ac.cardiff.model.ShibbolethEntry; 34 34 … … 46 46 47 47 /* set of all entries stored by this EntryHandler */ 48 Set<E ntry> entries;48 Set<Event> entries; 49 49 50 50 public PersistantEntryHandler(UADataConnection dataConnection) { … … 61 61 Integer rowCount = (Integer) dataConnection.runQueryUnique("select count(*) from Entry", null); 62 62 log.info("Persistent data store has {} entries", rowCount); 63 List<E ntry> entriesAsList = dataConnection.runQuery("from Entry", null);63 List<Event> entriesAsList = dataConnection.runQuery("from Entry", null); 64 64 log.info("UA has loaded " + entriesAsList.size() + " entries from DB backed cache"); 65 entries = new LinkedHashSet<E ntry>(entriesAsList);65 entries = new LinkedHashSet<Event>(entriesAsList); 66 66 log.info("Persistant entry handler [{}] started", this); 67 67 } … … 73 73 */ 74 74 @Override 75 public void addEntries(Set<E ntry> entries) {75 public void addEntries(Set<Event> entries) { 76 76 log.debug("Current: " + this.getEntries().size() + " in: " + entries.size()); 77 for (E ntryentry : entries) {77 for (Event entry : entries) { 78 78 this.getEntries().add(entry); 79 79 } … … 82 82 } 83 83 84 public void addEntry(E ntryentry) {84 public void addEntry(Event entry) { 85 85 entries.add(entry); 86 86 … … 137 137 */ 138 138 @Override 139 public void setEntries(Set<E ntry> entries) {139 public void setEntries(Set<Event> entries) { 140 140 // TODO Auto-generated method stub 141 141 -
raptor-ua/trunk/src/main/java/uk/ac/cardiff/RaptorUA/service/impl/UAProcessImpl.java
r411 r590 31 31 import uk.ac.cardiff.RaptorUA.engine.UnitAggregatorEngine; 32 32 import uk.ac.cardiff.RaptorUA.service.UAProcess; 33 import uk.ac.cardiff.model.E ntry;33 import uk.ac.cardiff.model.Event; 34 34 import uk.ac.cardiff.model.wsmodel.ICAEntryPush; 35 35 … … 98 98 */ 99 99 public Set getAllAuthentications() { 100 Set authentications = new LinkedHashSet<E ntry>();100 Set authentications = new LinkedHashSet<Event>(); 101 101 try { 102 102 if (lockR.tryLock(getTimeout, TimeUnit.MILLISECONDS)) { -
raptor-ua/trunk/src/main/java/uk/ac/cardiff/RaptorUA/wsinterface/impl/UnitAggregatorImpl.java
r464 r590 28 28 29 29 import uk.ac.cardiff.RaptorUA.service.impl.UAProcessImpl; 30 import uk.ac.cardiff.model.E ntry;30 import uk.ac.cardiff.model.Event; 31 31 import uk.ac.cardiff.model.ShibbolethEntry; 32 32 import uk.ac.cardiff.model.wsmodel.ICAEntryPush;
Note: See TracChangeset
for help on using the changeset viewer.
