| | |
Methods defined here:
- __init__(self, config_filename=None)
- bad_transfers(self)
- Returns a list of bad transfers.
- cancel_non_matching_transfers(self)
- cancel_transfer(self, source, dest, pnfsid)
- Cancels the transfer from the source and destination side.
- check_all_pool_transfers(self, pool)
- For the dCache pool `pool`, parse all the P2P transfers.
Kill any extra clients with no servers.
- check_all_transfers(self)
- Check all transfers for the dCache system.
- get_info(self)
- get_p2p_transfer_id(self, pool, pnfsid)
- Find the transfer id on `pool` for file `pnfsid` when `pool` is the source.
- get_pp_transfer_id(self, pool, pnfsid)
- Find the transfer id on `pool` for file `pnfsid` when `pool` is the destination.
- init_transfer(self, source, dest, pnfsid)
- Creates a transfer for `pnfsid` from pool `source` to pool `dest`.
- parse_single_transfer(self, source, transfer_str)
- Check on the progress of a single transfer. Return the transfer tuple,
( source, dest, pnfsid ) if it is good. Return False if it is not.
Transfer string looks like this:
'
1019 A H {dcache06_1@dcache06Domain:0} 000400000000000002719700 h={SM={a=2763714494;u=2763714494};S=None} bytes=2712362580 time/sec=23713 LM=23699
'
- verify(transfer_list)
- For each transfer in transfer_list, make /sure
the transfer has achieved a minimum rate of `min_rate_KBs` or
is within the grace time `grace_time_s`, which allows transfers
to "ramp up".
Assumes each entry in the list has format (src, dest, pnfsid)
Returns a dictionary; the key is the transfer_list entry, the value
is a boolean; 0 if the transfer is progressing, 1 if the transfer is not
progressing, and 2 if the transfer isn't found.
Data and other attributes defined here:
- __dict__ = <dictproxy object>
- dictionary for instance variables (if defined)
- __weakref__ = <attribute '__weakref__' of 'dCacheP2P' objects>
- list of weak references to the object (if defined)
|