View Javadoc

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  * *** Centre de Calcul de l'IN2P3 - Lyon (France) ***
12  * ***             http://cc.in2p3.fr/             ***
13  * ***************************************************
14  * File:   CopyListener
15  * Author: lionel.schwarz@in2p3.fr
16  * Date:   15 NOV 2013
17  * ***************************************************
18  * Description:                                      */
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  }