1 package fr.in2p3.jsaga.adaptor.data;
2
3 import org.globus.ftp.Marker;
4 import org.globus.ftp.MarkerListener;
5 import org.globus.ftp.PerfMarker;
6
7 import fr.in2p3.jsaga.adaptor.data.optimise.DataCopyMonitor;
8
9
10
11
12
13
14
15
16
17
18
19
20
21 public class CopyListener implements MarkerListener {
22
23 private DataCopyMonitor m_progressMonitor;
24
25 public CopyListener(DataCopyMonitor m) {
26 this.m_progressMonitor = m;
27 }
28
29 public void markerArrived(Marker marker) {
30 if (marker instanceof PerfMarker) {
31 PerfMarker perfMarker = (PerfMarker)marker;
32 try {
33 long bytes = perfMarker.getStripeBytesTransferred();
34 this.m_progressMonitor.setTotal(bytes);
35 } catch (Exception ex) {
36 }
37 }
38 }
39 }