def get_rrmgr_cmd(src, dst, compression=None, tcp_buf_size=None, connections=None):
 cmd = ['rrmgr', '-s', 'zfs']
 if compression:
  cmd.extend(['-c', ('%s' % compression)])
 cmd.append('-q')
 cmd.append('-e')
 if tcp_buf_size:
  cmd.extend(['-w', six.text_type(tcp_buf_size)])
 if connections:
  cmd.extend(['-n', six.text_type(connections)])
 cmd.extend([src, dst])
 return ' '.join(cmd)

def get_rrmgr_cmd ( src , dst , compression = None , tcp_buf_size = None , connections = None ) : cmd = [ 'rrmgr' , '-s' , 'zfs' ] if compression : cmd . extend ( [ '-c' , ( '%s' % compression ) ] ) cmd . append ( '-q' ) cmd . append ( '-e' ) if tcp_buf_size : cmd . extend ( [ '-w' , six . text_type ( tcp_buf_size ) ] ) if connections : cmd . extend ( [ '-n' , six . text_type ( connections ) ] ) cmd . extend ( [ src , dst ] ) return ' ' . join ( cmd )
returns rrmgr command for source and destination .