org.gluu.oxtrust.ldap.service.SvnSyncTimer クラス

org.gluu.oxtrust.ldap.service.SvnSyncTimer の継承関係図

org.gluu.oxtrust.ldap.service.SvnSyncTimer 連携図

公開メンバ関数
void	init ()
void	initTimer ()
void	processSvnSyncTimerEvent (@Observes @Scheduled SvnSyncEvent svnSyncEvent)
void	removeTrustRelationship (GluuSAMLTrustRelationship trustRelationship, String user) throws InterruptedException
void	addTrustRelationship (GluuSAMLTrustRelationship trustRelationship, String user)
void	updateTrustRelationship (GluuSAMLTrustRelationship trustRelationship, String user)

変数
List< Pair< GluuSAMLTrustRelationship, String > >	alteredTrustRelations

非公開メンバ関数
void	processSvnSync ()
void	commitShibboleth3Configuration (List< GluuSAMLTrustRelationship > trustRelationships)

非公開変数類
Logger	log
Event< TimerEvent >	timerEvent
Shibboleth3ConfService	shibboleth3ConfService
SubversionService	subversionService
OrganizationService	organizationService
AppConfiguration	appConfiguration
LinkedBlockingQueue< Pair< GluuSAMLTrustRelationship, String > >	removedTrustRelationship
String	svnComment = ""
TrustService	trustService
AtomicBoolean	isActive

静的非公開変数類
static final long	serialVersionUID = -6875538084008069405L
static final int	DEFAULT_INTERVAL = 5 * 60

詳解

関数詳解

addTrustRelationship()

void org.gluu.oxtrust.ldap.service.SvnSyncTimer.addTrustRelationship ( GluuSAMLTrustRelationship  trustRelationship, String  user  )

inline

                                                                                                   {
                alteredTrustRelations.add(new Pair<GluuSAMLTrustRelationship, String>(trustRelationship, user));
                svnComment += "User " + user + " added trust relationship " + trustRelationship.getDisplayName() + "\n";
        }

commitShibboleth3Configuration()

void org.gluu.oxtrust.ldap.service.SvnSyncTimer.commitShibboleth3Configuration ( List< GluuSAMLTrustRelationship >  trustRelationships )

inlineprivate

                                                                                                        {
                synchronized (this) {
                        List<SubversionFile> subversionFiles = new ArrayList<SubversionFile>();
                        try {
                                subversionFiles = subversionService.getDifferentFiles(shibboleth3ConfService
                                                .getConfigurationFilesForSubversion(trustRelationships));
                        } catch (IOException e) {
                                log.error("Failed to prepare files list to be persisted in svn", e);
                        }

                        List<SubversionFile> removeSubversionFiles = new ArrayList<SubversionFile>();
                        while (!removedTrustRelationship.isEmpty()) {
                                Pair<GluuSAMLTrustRelationship, String> removedRelationship = removedTrustRelationship.poll();

                                SubversionFile file = shibboleth3ConfService.getConfigurationFileForSubversion(removedRelationship.getValue0());
                                if (file != null) {
                                        removeSubversionFiles.add(file);
                                }
                        }
                        String idpSvnComment = "";
                        // Find all TRs modified not by user.
                        for (SubversionFile file : subversionFiles) {
                                String filename = file.getLocalFile();
                                if (filename.matches(".*/DA[0-9A-F]*-sp-metadata\\.xml")) {
                                        boolean found = false;
                                        String inum = filename.replaceAll("-sp-metadata\\.xml", "").replaceAll(".*/", "");
                                        for (Pair<GluuSAMLTrustRelationship, String> trust : alteredTrustRelations) {
                                                if (StringHelper.removePunctuation(trust.getValue0().getInum()).equals(inum)) {
                                                        found = true;
                                                        break;
                                                }
                                        }

                                        if (!found) {
                                                GluuSAMLTrustRelationship unknownTrust = trustService.getTrustByUnpunctuatedInum(inum);
                                                if (unknownTrust != null) {
                                                        idpSvnComment += "Trust relationship '" + unknownTrust.getDisplayName() + "' was updated automatically\n";
                                                } else {
                                                        idpSvnComment += "Appliance have no information about  '" + filename
                                                                        + "'. Please report this issue to appliance admin.\n";
                                                }
                                        }
                                }
                        }
                        log.debug("Files to be persisted in repository: " + StringHelper.toString(subversionFiles.toArray(new SubversionFile[] {})));
                        log.debug("Files to be removed from repository: "
                                        + StringHelper.toString(removeSubversionFiles.toArray(new SubversionFile[] {})));
                        if (!subversionService.commitShibboleth3ConfigurationFiles(organizationService.getOrganization(), subversionFiles,
                                        removeSubversionFiles, svnComment + idpSvnComment)) {
                                log.error("Failed to commit Shibboleth3 configuration to SVN repository");
                        } else {
                                svnComment = "";
                                alteredTrustRelations.clear();
                                log.info("Shibboleth3 configuration commited successfully to SVN repository");
                        }
                }
        }

init()

void org.gluu.oxtrust.ldap.service.SvnSyncTimer.init ( )

inline

                           {
                this.isActive = new AtomicBoolean(true);
                try {
                        this.removedTrustRelationship = new LinkedBlockingQueue<Pair<GluuSAMLTrustRelationship, String>>();
                        this.alteredTrustRelations = new ArrayList<Pair<GluuSAMLTrustRelationship, String>>();
                } finally {
                        this.isActive.set(false);
                }
        }

initTimer()

void org.gluu.oxtrust.ldap.service.SvnSyncTimer.initTimer ( )

inline

                                {
                log.debug("Initializing SVN Sync Timer");

                if (!appConfiguration.isPersistSVN()) {
                        return;
                }

                final int delay = 30;
                final int interval = DEFAULT_INTERVAL;

                timerEvent.fire(new TimerEvent(new TimerSchedule(delay, interval), new SvnSyncEvent(),
                                Scheduled.Literal.INSTANCE));
        }

processSvnSync()

void org.gluu.oxtrust.ldap.service.SvnSyncTimer.processSvnSync ( )

inlineprivate

                                      {
                commitShibboleth3Configuration(trustService.getAllActiveTrustRelationships());
        }

processSvnSyncTimerEvent()

void org.gluu.oxtrust.ldap.service.SvnSyncTimer.processSvnSyncTimerEvent ( @Observes @Scheduled SvnSyncEvent  svnSyncEvent )

inline

                                                                                             {
                if (this.isActive.get()) {
                        return;
                }

                if (!this.isActive.compareAndSet(false, true)) {
                        return;
                }

                try {
                        processSvnSync();
                } catch (Throwable ex) {
                        log.error("Exception happened while running SVN sync", ex);
                } finally {
                        this.isActive.set(false);
                }
        }

removeTrustRelationship()

void org.gluu.oxtrust.ldap.service.SvnSyncTimer.removeTrustRelationship ( GluuSAMLTrustRelationship  trustRelationship, String  user  ) throws InterruptedException

inline

                                                                                                                                  {
                removedTrustRelationship.put(new Pair<GluuSAMLTrustRelationship, String>(trustRelationship, user));
                alteredTrustRelations.add(new Pair<GluuSAMLTrustRelationship, String>(trustRelationship, user));
                svnComment += "User " + user + " removed trust relationship " + trustRelationship.getDisplayName() + "\n";
        }

updateTrustRelationship()

void org.gluu.oxtrust.ldap.service.SvnSyncTimer.updateTrustRelationship ( GluuSAMLTrustRelationship  trustRelationship, String  user  )

inline

                                                                                                      {
                alteredTrustRelations.add(new Pair<GluuSAMLTrustRelationship, String>(trustRelationship, user));
                svnComment += "User " + user + " updated trust relationship " + trustRelationship.getDisplayName() + "\n";
        }

メンバ詳解

alteredTrustRelations

List<Pair<GluuSAMLTrustRelationship, String> > org.gluu.oxtrust.ldap.service.SvnSyncTimer.alteredTrustRelations

package

appConfiguration

AppConfiguration org.gluu.oxtrust.ldap.service.SvnSyncTimer.appConfiguration

private

DEFAULT_INTERVAL

final int org.gluu.oxtrust.ldap.service.SvnSyncTimer.DEFAULT_INTERVAL = 5 * 60

staticprivate

isActive

AtomicBoolean org.gluu.oxtrust.ldap.service.SvnSyncTimer.isActive

private

log

Logger org.gluu.oxtrust.ldap.service.SvnSyncTimer.log

private

organizationService

OrganizationService org.gluu.oxtrust.ldap.service.SvnSyncTimer.organizationService

private

removedTrustRelationship

LinkedBlockingQueue<Pair<GluuSAMLTrustRelationship, String> > org.gluu.oxtrust.ldap.service.SvnSyncTimer.removedTrustRelationship

private

serialVersionUID

final long org.gluu.oxtrust.ldap.service.SvnSyncTimer.serialVersionUID = -6875538084008069405L

staticprivate

shibboleth3ConfService

Shibboleth3ConfService org.gluu.oxtrust.ldap.service.SvnSyncTimer.shibboleth3ConfService

private

subversionService

SubversionService org.gluu.oxtrust.ldap.service.SvnSyncTimer.subversionService

private

svnComment

String org.gluu.oxtrust.ldap.service.SvnSyncTimer.svnComment = ""

private

timerEvent

Event<TimerEvent> org.gluu.oxtrust.ldap.service.SvnSyncTimer.timerEvent

private

trustService

TrustService org.gluu.oxtrust.ldap.service.SvnSyncTimer.trustService

private

---

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

• D:/AppData/OpenId/gluu/src/oxTrust/server/src/main/java/org/gluu/oxtrust/ldap/service/SvnSyncTimer.java