org.mitre.data.AbstractPageOperationTemplateTest.EvenExceptionCountingPageOperation クラス

org.mitre.data.AbstractPageOperationTemplateTest.EvenExceptionCountingPageOperation の継承関係図

org.mitre.data.AbstractPageOperationTemplateTest.EvenExceptionCountingPageOperation 連携図

公開メンバ関数
Collection< String >	fetchPage ()
long	getCounter ()
long	getTimeToLastFetch ()
long	getTimeToPreviousFetch ()
void	execute ()
int	getMaxPages ()
void	setMaxPages (int maxPages)
long	getMaxTime ()
void	setMaxTime (long maxTime)
boolean	isSwallowExceptions ()
void	setSwallowExceptions (boolean swallowExceptions)
String	getOperationName ()
void	setOperationName (String operationName)

限定公開メンバ関数
void	doOperation (String item)
abstract void	doOperation (T item)
void	finalReport (int operationsCompleted, int exceptionsSwallowedCount, Set< String > exceptionsSwallowedClasses)

非公開メンバ関数
	EvenExceptionCountingPageOperation (int maxPages, long maxTime)

非公開変数類
int	callCounter

詳解

構築子と解体子

EvenExceptionCountingPageOperation()

org.mitre.data.AbstractPageOperationTemplateTest.EvenExceptionCountingPageOperation.EvenExceptionCountingPageOperation ( int  maxPages, long  maxTime  )

inlineprivate

                                                                                       {
                        super(maxPages, maxTime);
                }

関数詳解

doOperation() [1/2]

abstract void org.mitre.data.AbstractPageOperationTemplate< T >.doOperation ( T  item )

abstractprotectedinherited

method responsible for performing desired operation on a fetched page item.

引数

item

the item

doOperation() [2/2]

void org.mitre.data.AbstractPageOperationTemplateTest.EvenExceptionCountingPageOperation.doOperation ( String  item )

inlineprotected

                                                        {
                        callCounter++;
                        if(callCounter%2 == 0){
                                throw new IllegalStateException("even number items cannot be processed");
                        }

                        super.doOperation(item);

                }

execute()

void org.mitre.data.AbstractPageOperationTemplate< T >.execute ( )

inlineinherited

Execute the operation on each member of a page of results retrieved through the fetch method. the method will execute until either the maxPages or maxTime limit is reached or until the fetch method returns no more results. Exceptions thrown performing the operation on the item will be swallowed if the swallowException (default true) field is set true.

                             {
                logger.debug("[" + getOperationName() +  "] Starting execution of paged operation. maximum time: " + maxTime + ", maximum pages: " + maxPages);

                long startTime = System.currentTimeMillis();
                long executionTime = 0;
                int i = 0;

                int exceptionsSwallowedCount = 0;
                int operationsCompleted = 0;
                Set<String> exceptionsSwallowedClasses = new HashSet<String>();


                while (i< maxPages && executionTime < maxTime){
                        Collection<T> page = fetchPage();
                        if(page == null || page.size() == 0){
                                break;
                        }

                        for (T item : page) {
                                try {
                                        doOperation(item);
                                        operationsCompleted++;
                                } catch (Exception e){
                                        if(swallowExceptions){
                                                exceptionsSwallowedCount++;
                                                exceptionsSwallowedClasses.add(e.getClass().getName());
                                                logger.debug("Swallowing exception " + e.getMessage(), e);
                                        } else {
                                                logger.debug("Rethrowing exception " + e.getMessage());
                                                throw e;
                                        }
                                }
                        }

                        i++;
                        executionTime = System.currentTimeMillis() - startTime;
                }

                finalReport(operationsCompleted, exceptionsSwallowedCount, exceptionsSwallowedClasses);
        }

fetchPage()

Collection<String> org.mitre.data.AbstractPageOperationTemplateTest.CountingPageOperation.fetchPage ( )

inlineinherited

                                                      {
                        timeToPreviousFetch = timeToLastFetch > 0 ? timeToLastFetch : 0;
                        timeToLastFetch = System.currentTimeMillis() - startTime;

                        List<String> page = new ArrayList<String>(pageSize);
                        for(int i = 0; i < pageSize; i++ ) {
                                page.add("item " + currentPageFetch * pageSize + i);
                        }
                        currentPageFetch++;
                        return page;
                }

finalReport()

void org.mitre.data.AbstractPageOperationTemplate< T >.finalReport ( int  operationsCompleted, int  exceptionsSwallowedCount, Set< String >  exceptionsSwallowedClasses  )

inlineprotectedinherited

Method responsible for final report of progress.

戻り値

                                                                                                                                  {
                if (operationsCompleted > 0 || exceptionsSwallowedCount > 0) {
                        logger.info("[" + getOperationName() +  "] Paged operation run: completed " + operationsCompleted + "; swallowed " + exceptionsSwallowedCount + " exceptions");
                }
                for(String className:  exceptionsSwallowedClasses) {
                        logger.warn("[" + getOperationName() +  "] Paged operation swallowed at least one exception of type " + className);
                }
        }

getCounter()

long org.mitre.data.AbstractPageOperationTemplateTest.CountingPageOperation.getCounter ( )

inlineinherited

                                         {
                        return counter;
                }

getMaxPages()

int org.mitre.data.AbstractPageOperationTemplate< T >.getMaxPages ( )

inlineinherited

                                 {
                return maxPages;
        }

getMaxTime()

long org.mitre.data.AbstractPageOperationTemplate< T >.getMaxTime ( )

inlineinherited

                                 {
                return maxTime;
        }

getOperationName()

String org.mitre.data.AbstractPageOperationTemplate< T >.getOperationName ( )

inlineinherited

戻り値

the operationName

                                         {
                return operationName;
        }

getTimeToLastFetch()

long org.mitre.data.AbstractPageOperationTemplateTest.CountingPageOperation.getTimeToLastFetch ( )

inlineinherited

                                                 {
                        return timeToLastFetch;
                }

getTimeToPreviousFetch()

long org.mitre.data.AbstractPageOperationTemplateTest.CountingPageOperation.getTimeToPreviousFetch ( )

inlineinherited

                                                     {
                        return timeToPreviousFetch;
                }

isSwallowExceptions()

boolean org.mitre.data.AbstractPageOperationTemplate< T >.isSwallowExceptions ( )

inlineinherited

                                             {
                return swallowExceptions;
        }

setMaxPages()

void org.mitre.data.AbstractPageOperationTemplate< T >.setMaxPages ( int  maxPages )

inlineinherited

                                              {
                this.maxPages = maxPages;
        }

setMaxTime()

void org.mitre.data.AbstractPageOperationTemplate< T >.setMaxTime ( long  maxTime )

inlineinherited

                                             {
                this.maxTime = maxTime;
        }

setOperationName()

void org.mitre.data.AbstractPageOperationTemplate< T >.setOperationName ( String  operationName )

inlineinherited

引数

operationName

the operationName to set

                                                           {
                this.operationName = operationName;
        }

setSwallowExceptions()

void org.mitre.data.AbstractPageOperationTemplate< T >.setSwallowExceptions ( boolean  swallowExceptions )

inlineinherited

                                                                    {
                this.swallowExceptions = swallowExceptions;
        }

メンバ詳解

callCounter

int org.mitre.data.AbstractPageOperationTemplateTest.EvenExceptionCountingPageOperation.callCounter

private

---

このクラス詳解は次のファイルから抽出されました:

• D:/AppData/OpenId/mitreid-connect/src/openid-connect-common/src/test/java/org/mitre/data/AbstractPageOperationTemplateTest.java