Changeset 766


Ignore:
Timestamp:
05/08/11 23:19:12 (8 years ago)
Author:
philsmart
Message:
 
Location:
raptor-ica/trunk/src/main
Files:
6 edited

Legend:

Unmodified
Added
Removed
  • raptor-ica/trunk/src/main/config/data-access.xml

    r735 r766  
    7474                                        <property name="entryHandler"><ref bean="memoryEntryHandler"></ref></property> 
    7575                                        <property name="logfile"> 
    76                                                 <value>file:///Users/philsmart/Documents/DataSets/Logs/shib2comb-2011-04.log 
     76                                                <value>file:///Users/philsmart/Documents/DataSets/Logs/idp-audit-2010-10-20.idp2.log 
    7777                                                </value> 
    7878                                        </property> 
     
    104104 
    105105        <!-- Create the entry handler --> 
    106         <bean name="memoryEntryHandler" class="uk.ac.cardiff.raptor.store.impl.MemoryEntryHandler"></bean> 
     106        <bean name="memoryEntryHandler" class="uk.ac.cardiff.raptor.store.impl.LogFileMemoryEntryHandler"></bean> 
    107107        <bean name="persistantEntryHandler" class="uk.ac.cardiff.raptor.store.impl.PersistantEntryHandler"> 
    108108                <constructor-arg index="0"><ref bean="dataConnectionImpl"></ref></constructor-arg> 
  • raptor-ica/trunk/src/main/config/ica-core.xml

    r729 r766  
    6464        </property> 
    6565    </bean> 
     66     
     67    <!-- event sweep (garbage collection) trigger setup --> 
     68    <bean id="icaGarbageCollectionQuickTrigger" class="org.springframework.scheduling.quartz.SimpleTriggerBean"> 
     69        <property name="jobDetail"> 
     70            <ref local="icaGarbageCollectionJobDetail" /> 
     71        </property> 
     72        <property name="startDelay" value="15000" /> 
     73        <property name="repeatInterval" value="55000" /> 
     74    </bean> 
    6675 
     76    <bean id="icaGarbageCollectionJobDetail" 
     77        class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean"> 
     78        <property name="targetObject"> 
     79            <ref bean="ICAProcess" /> 
     80        </property> 
     81        <property name="targetMethod"> 
     82            <value>garbageCollect</value> 
     83        </property> 
     84        <property name="concurrent"> 
     85            <value>false</value> 
     86        </property> 
     87    </bean> 
     88 
     89    <!--  DONE --> 
     90 
     91    <!--  Trigger setup --> 
    6792        <bean class="org.springframework.scheduling.quartz.SchedulerFactoryBean"> 
    6893                <property name="triggers"> 
     
    7095                                <ref local="ICAProcessQuickTrigger" /> 
    7196                <ref local="icaReleaseQuickTrigger" /> 
     97                <ref local="icaGarbageCollectionQuickTrigger"/> 
    7298                        </list> 
    7399                </property> 
    74100        </bean> 
    75101        <!--  DONE --> 
     102     
     103      
    76104 
    77105 
  • raptor-ica/trunk/src/main/config/metadata.xml

    r748 r766  
    2323    <!-- ICA Metadata --> 
    2424    <bean id="ICAMetadata" class="uk.ac.cardiff.model.ServiceMetadata"> 
    25         <property name="clientName"><value>Cardiff University IdP Shibboleth Log File Parser</value></property> 
     25        <property name="description"><value>Cardiff University IdP Shibboleth Log File Parser</value></property> 
    2626        <property name="organisationName"><value>Cardiff University</value></property> 
    2727        <property name="contactEmail"><value>smartp@cf.ac.uk</value></property> 
  • raptor-ica/trunk/src/main/java/uk/ac/cardiff/raptorica/engine/ICAEngine.java

    r748 r766  
    6363                } 
    6464        } 
     65         
     66 
     67        public void garbageCollect() { 
     68                dataAccessRegister.garbageCollect(eventReleaseClient.getEndpoints()); 
     69        } 
    6570 
    6671 
     
    98103                        log.error("Release failed ", e); 
    99104                } 
    100                 if (success) 
    101                         retrieveTransactionFinished(); 
     105//              if (success) 
     106//                      retrieveTransactionFinished(); 
    102107                return success; 
    103108        } 
     
    127132        } 
    128133 
     134 
    129135} 
  • raptor-ica/trunk/src/main/java/uk/ac/cardiff/raptorica/service/IcaProcess.java

    r729 r766  
    1616package uk.ac.cardiff.raptorica.service; 
    1717 
    18 import java.util.List; 
    19 import java.util.Set; 
    2018 
    2119public interface IcaProcess{ 
     
    2523        public void release(); 
    2624 
     25        public void garbageCollect(); 
    2726 
    2827} 
  • raptor-ica/trunk/src/main/java/uk/ac/cardiff/raptorica/service/IcaProcessImpl.java

    r729 r766  
    6464                                log.info("Capture Success, taking {} ms", (end - start)); 
    6565                        } catch (Exception e) { 
    66                                 log.error(e.getMessage()); 
    67                                 e.printStackTrace(); 
     66                                log.error("",e); 
    6867                        } finally { 
    6968                                lockR.unlock(); 
    7069                        } 
     70                } 
     71                else{ 
     72                        log.warn("Lock was hit for method [capture]"); 
     73                } 
     74 
     75        } 
     76         
     77        /**  
     78         * Initiates a process on the <code>engine</code> that removes events from the 
     79         * <code>entryHandler</code> iff they have been released to all attached  
     80         * endpoints.  
     81         */ 
     82        public void garbageCollect() { 
     83                if (lockR.tryLock()) { 
     84                        try { 
     85                                log.info("GC. Running Event Garbage Collection"); 
     86                                long start = System.currentTimeMillis(); 
     87                                engine.garbageCollect(); 
     88                                long end = System.currentTimeMillis(); 
     89                                log.info("GC. Event Garbage Collection Success, taking {} ms", (end - start)); 
     90                        } catch (Exception e) { 
     91                                log.error("",e); 
     92                        } finally { 
     93                                lockR.unlock(); 
     94                        } 
     95                } 
     96                else{ 
     97                        log.warn("Lock was hit for method [garbageCollect]"); 
    7198                } 
    7299 
     
    86113                        } 
    87114                } 
     115                else{ 
     116                        log.warn("Lock was hit for method [release]"); 
     117                } 
    88118        } 
    89119 
Note: See TracChangeset for help on using the changeset viewer.