cloudstack-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bhais...@apache.org
Subject git commit: updated refs/heads/master to 835abe6
Date Wed, 03 Dec 2014 21:10:19 GMT
Repository: cloudstack
Updated Branches:
  refs/heads/master fac7bfc5d -> 835abe6c7


Revert "CLOUDSTACK-7566:Many jobs getting stuck in pending state and cloud is unusable."

This reverts commit 6df38427cffe9cab5a2a842571941a97a3a07b52.


Project: http://git-wip-us.apache.org/repos/asf/cloudstack/repo
Commit: http://git-wip-us.apache.org/repos/asf/cloudstack/commit/835abe6c
Tree: http://git-wip-us.apache.org/repos/asf/cloudstack/tree/835abe6c
Diff: http://git-wip-us.apache.org/repos/asf/cloudstack/diff/835abe6c

Branch: refs/heads/master
Commit: 835abe6c7c98fd3db6af65597d0c7e9c48bb034e
Parents: fac7bfc
Author: Rohit Yadav <rohit.yadav@shapeblue.com>
Authored: Thu Dec 4 02:38:47 2014 +0530
Committer: Rohit Yadav <rohit.yadav@shapeblue.com>
Committed: Thu Dec 4 02:38:47 2014 +0530

----------------------------------------------------------------------
 .../cloudstack/framework/jobs/impl/AsyncJobManagerImpl.java | 9 +++------
 1 file changed, 3 insertions(+), 6 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/cloudstack/blob/835abe6c/framework/jobs/src/org/apache/cloudstack/framework/jobs/impl/AsyncJobManagerImpl.java
----------------------------------------------------------------------
diff --git a/framework/jobs/src/org/apache/cloudstack/framework/jobs/impl/AsyncJobManagerImpl.java
b/framework/jobs/src/org/apache/cloudstack/framework/jobs/impl/AsyncJobManagerImpl.java
index 63a5864..bdc7cb0 100644
--- a/framework/jobs/src/org/apache/cloudstack/framework/jobs/impl/AsyncJobManagerImpl.java
+++ b/framework/jobs/src/org/apache/cloudstack/framework/jobs/impl/AsyncJobManagerImpl.java
@@ -255,17 +255,14 @@ public class AsyncJobManagerImpl extends ManagerBase implements AsyncJobManager,
             s_logger.debug("Publish async job-" + jobId + " complete on message bus");
         }
 
-        publishOnEventBus(job, "complete"); // publish before the instance type and ID are
wiped out
-
         if (s_logger.isDebugEnabled()) {
-            s_logger.debug("Wake up jobs related to job- " + jobId);
+            s_logger.debug("Wake up jobs related to job-" + jobId);
         }
-
         List<Long> wakeupList = Transaction.execute(new TransactionCallback<List<Long>>()
{
             @Override
             public List<Long> doInTransaction(TransactionStatus status) {
                 if (s_logger.isDebugEnabled()) {
-                    s_logger.debug("Update db status for job- " + jobId);
+                    s_logger.debug("Update db status for job-" + jobId);
                 }
                 job.setCompleteMsid(getMsid());
                 job.setStatus(jobStatus);
@@ -282,7 +279,7 @@ public class AsyncJobManagerImpl extends ManagerBase implements AsyncJobManager,
                 _jobDao.update(jobId, job);
 
                 if (s_logger.isDebugEnabled()) {
-                    s_logger.debug("Wake up jobs joined with job- " + jobId + " and disjoin
all subjobs created from job- " + jobId);
+                    s_logger.debug("Wake up jobs joined with job-" + jobId + " and disjoin
all subjobs created from job- " + jobId);
                 }
                 List<Long> wakeupList = wakeupByJoinedJobCompletion(jobId);
                 _joinMapDao.disjoinAllJobs(jobId);


Mime
View raw message