Package org.olat.core.util.coordinate

Examples of org.olat.core.util.coordinate.SyncerExecutor

100
101
102
103
104
105
106
107
108
109
110
   * @param toUpdate
   */
  public void updatePropertiesFor(final Identity identity, final ImPreferences toUpdate) {
    //o_clusterOK by guido
    CoordinatorManager.getCoordinator().getSyncer().doInSync(
        OresHelper.createOLATResourceableInstanceWithoutCheck(LOCK_KEY, identity.getKey()), new SyncerExecutor(){

          public void execute() {
            PropertyManager pm = PropertyManager.getInstance();
            // generate x-stream serialization of this object
            String props = XStreamHelper.toXML(toUpdate);
View Full Code Here
161
162
163
164
165
166
167
168
169
170
171
   * @return The feed cache
   */
  protected CacheWrapper initFeedCache() {
    if (feedCache == null) {
      OLATResourceable ores = OresHelper.createOLATResourceableType(this.getClass());
      CoordinatorManager.getCoordinator().getSyncer().doInSync(ores, new SyncerExecutor() {
        public void execute() {
          if (feedCache == null) {
            feedCache = CoordinatorManager.getCoordinator().getCacher().getOrCreateCache(this.getClass(), "feed");
          }
        }
View Full Code Here
243
244
245
246
247
248
249
250
251
252
253
   * @param feed
   */
  void syncedFeedCacheUpdate(final Feed feed, boolean inSync) {
    initFeedCache();
    if(inSync) {
      CoordinatorManager.getCoordinator().getSyncer().doInSync(feed, new SyncerExecutor() {
        public void execute() {
          // update and put behaves the same way
          feedCache.update(feed.getResourceableId().toString(), feed);
        }
      });
View Full Code Here
345
346
347
348
349
350
351
352
353
354
355
    // the AssessmentEditController - which as the 2nd last method calls into saveScoreEvaluation
    // - which in turn does update the EfficiencyStatement - at which point we're happy and everything works fine.
    // But it seems like this mechanism is a bit unobvious and might well be worth some refactoring...
    ICourse course = CourseFactory.loadCourse(ores);
    final CoursePropertyManager cpm = course.getCourseEnvironment().getCoursePropertyManager();
    CoordinatorManager.getCoordinator().getSyncer().doInSync(createOLATResourceableForLocking(assessedIdentity), new SyncerExecutor(){
      public void execute() {
        Property attemptsProperty = cpm.findCourseNodeProperty(courseNode, assessedIdentity, null, ATTEMPTS);
        if (attemptsProperty == null) {
          attemptsProperty = cpm.createCourseNodePropertyInstance(courseNode, assessedIdentity, null, ATTEMPTS,
              null, new Long(attempts.intValue()), null, null);
View Full Code Here
416
417
418
419
420
421
422
423
424
425
426
   *      java.lang.String)
   */
  public void saveNodeComment(final CourseNode courseNode, final Identity identity, final Identity assessedIdentity, final String comment) {
    ICourse course = CourseFactory.loadCourse(ores);
    final CoursePropertyManager cpm = course.getCourseEnvironment().getCoursePropertyManager();
    CoordinatorManager.getCoordinator().getSyncer().doInSync(createOLATResourceableForLocking(assessedIdentity), new SyncerExecutor(){
      public void execute() {
        Property commentProperty = cpm.findCourseNodeProperty(courseNode, assessedIdentity, null, COMMENT);
        if (commentProperty == null) {
          commentProperty = cpm.createCourseNodePropertyInstance(courseNode, assessedIdentity, null, COMMENT, null, null, null, comment);
          cpm.saveProperty(commentProperty);
View Full Code Here
452
453
454
455
456
457
458
459
460
461
462
   *      org.olat.core.id.Identity, java.lang.String)
   */
  public void saveNodeCoachComment(final CourseNode courseNode, final Identity assessedIdentity, final String comment) {
    ICourse course = CourseFactory.loadCourse(ores);
    final CoursePropertyManager cpm = course.getCourseEnvironment().getCoursePropertyManager();
    CoordinatorManager.getCoordinator().getSyncer().doInSync(createOLATResourceableForLocking(assessedIdentity), new SyncerExecutor(){
      public void execute() {
        Property commentProperty = cpm.findCourseNodeProperty(courseNode, assessedIdentity, null, COACH_COMMENT);
        if (commentProperty == null) {
          commentProperty = cpm.createCourseNodePropertyInstance(courseNode, assessedIdentity, null, COACH_COMMENT, null, null, null, comment);
          cpm.saveProperty(commentProperty);
View Full Code Here
330
331
332
333
334
335
336
337
338
339
340
      Iterator<Identity> iter = identities.iterator();     
      while (iter.hasNext()) {
        final Identity identity = iter.next();         
        //o_clusterOK: by ld
        OLATResourceable efficiencyStatementResourceable = am.createOLATResourceableForLocking(identity);
        CoordinatorManager.getCoordinator().getSyncer().doInSync(efficiencyStatementResourceable, new SyncerExecutor() {
          public void execute() {         
            // create temporary user course env
            UserCourseEnvironment uce = AssessmentHelper.createAndInitUserCourseEnvironment(identity, course);
            updateUserEfficiencyStatement(uce, re.getKey(), course, checkForExistingProperty);
            }
View Full Code Here
94
95
96
97
98
99
100
101
102
103
104
   * Update checklist.
   * @param checklist
   */
  public void updateChecklist(final Checklist cl) {
    OLATResourceable ores = OresHelper.createOLATResourceableInstance(Checklist.class, cl.getKey());
    CoordinatorManager.getCoordinator().getSyncer().doInSync(ores, new SyncerExecutor() {
      public void execute() {
        cl.setLastModified(new Date());
        DBFactory.getInstance().updateObject(cl);
      }
    });
View Full Code Here
109
110
111
112
113
114
115
116
117
118
119
   * @param checklist
   */
  public void deleteChecklist(final Checklist cl) {
    final DB db = DBFactory.getInstance();
    OLATResourceable ores = OresHelper.createOLATResourceableInstance(Checklist.class, cl.getKey());
    CoordinatorManager.getCoordinator().getSyncer().doInSync(ores, new SyncerExecutor() {
        public void execute() {
          Checklist checklist = (Checklist) db.loadObject(cl);
          db.deleteObject(checklist);
        }
    });
View Full Code Here
123
124
125
126
127
128
129
130
131
132
133
   * Update checkpoint
   * @param checkpoint
   */
  public void updateCheckpoint(final Checkpoint cp) {
    OLATResourceable ores = OresHelper.createOLATResourceableInstance(Checkpoint.class, cp.getKey());
    CoordinatorManager.getCoordinator().getSyncer().doInSync(ores, new SyncerExecutor() {
      public void execute() {
        cp.setLastModified(new Date());
        DBFactory.getInstance().updateObject(cp);
      }
    });
View Full Code Here
TOP

Related Classes of org.olat.core.util.coordinate.SyncerExecutor

  • de.bps.course.nodes.den.DENManager
  • de.bps.olat.modules.cl.ChecklistManager
  • org.olat.admin.sysinfo.InfoMessageManager
  • org.olat.admin.user.delete.service.UserDeletionManager
  • org.olat.collaboration.CollaborationTools
  • org.olat.commons.coordinate.cluster.jms.ClusterAdminControllerCluster
  • org.olat.commons.coordinate.CoordinatorTest
  • org.olat.core.commons.contextHelp.ContextHelpManager
  • org.olat.core.commons.modules.glossary.GlossaryItemManager
  • org.olat.course.assessment.EfficiencyStatementManager
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.