etan39
/
cloudstack
mirror of https://github.com/apache/cloudstack.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix 

Signed-off-by: Abhishek Kumar <abhishek.mrt22@gmail.com>
This commit is contained in:
Abhishek Kumar 2024-09-03 17:56:03 +05:30
parent 4f1eeae9f7
commit 060a8ca623
1 changed files with 12 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
server/src/main/java/com/cloud/storage/download/DownloadListener.java
View File

@ -140,6 +140,13 @@ public class DownloadListener implements Listener {
private Cache<Long, List<Hypervisor.HypervisorType>> zoneHypervisorsCache;
protected void initZoneHypervisorsCache() {
zoneHypervisorsCache = Caffeine.newBuilder()
.maximumSize(32)
.expireAfterWrite(30, TimeUnit.SECONDS)
.build();
}
// TODO: this constructor should be the one used for template only, remove other template constructor later
public DownloadListener(EndPoint ssAgent, DataStore store, DataObject object, Timer timer, DownloadMonitorImpl downloadMonitor, DownloadCommand cmd,
AsyncCompletionCallback<DownloadAnswer> callback) {
@ -155,12 +162,12 @@ public class DownloadListener implements Listener {
_callback = callback;
DownloadAnswer answer = new DownloadAnswer("", Status.NOT_DOWNLOADED);
callback(answer);
initZoneHypervisorsCache();
}
zoneHypervisorsCache = Caffeine.newBuilder()
.maximumSize(512)
.expireAfterWrite(30, TimeUnit.SECONDS)
.build();
public DownloadListener(DownloadMonitorImpl monitor) {
_downloadMonitor = monitor;
initZoneHypervisorsCache();
}
public AsyncCompletionCallback<DownloadAnswer> getCallback() {
@ -218,10 +225,6 @@ public class DownloadListener implements Listener {
s_logger.log(level, message + ", " + object.getType() + ": " + object.getId() + " at host " + _ssAgent.getId());
}
public DownloadListener(DownloadMonitorImpl monitor) {
_downloadMonitor = monitor;
}
@Override
public boolean isRecurring() {
return false;