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

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

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

公開メンバ関数
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)

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

詳解

構築子と解体子

EmptyPageCountingPageOperation()

org.mitre.data.AbstractPageOperationTemplateTest.EmptyPageCountingPageOperation.EmptyPageCountingPageOperation ( 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.CountingPageOperation.doOperation ( String  item )

inlineprotectedinherited

                                                        {
                        counter++;
                }

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.EmptyPageCountingPageOperation.fetchPage ( )

inline

                                                      {
                        return new ArrayList<>(0);
                }

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;
        }

---

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

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