ObjectReaperTask.java (eucalyptus-4.4.1) | : | ObjectReaperTask.java (eucalyptus-4.4.2) | ||
---|---|---|---|---|
skipping to change at line 45 | skipping to change at line 45 | |||
import com.eucalyptus.objectstorage.providers.ObjectStorageProviders; | import com.eucalyptus.objectstorage.providers.ObjectStorageProviders; | |||
import com.eucalyptus.util.EucalyptusCloudException; | import com.eucalyptus.util.EucalyptusCloudException; | |||
/** | /** | |||
* Scans metadata for "deleted" objects and removes them from the backend. Many of these may be running concurrently. | * Scans metadata for "deleted" objects and removes them from the backend. Many of these may be running concurrently. | |||
* | * | |||
*/ | */ | |||
public class ObjectReaperTask implements Runnable { | public class ObjectReaperTask implements Runnable { | |||
private static final Logger LOG = Logger.getLogger(ObjectReaperTask.class); | private static final Logger LOG = Logger.getLogger(ObjectReaperTask.class); | |||
private boolean interrupted = false; | private volatile boolean interrupted = false; | |||
public ObjectReaperTask() {} | public ObjectReaperTask() {} | |||
public void interrupt() { | public void interrupt() { | |||
this.interrupted = true; | this.interrupted = true; | |||
} | } | |||
public void resume() { | public void resume() { | |||
this.interrupted = false; | this.interrupted = false; | |||
} | } | |||
End of changes. 1 change blocks. | ||||
1 lines changed or deleted | 1 lines changed or added |