#NEWLINE# def _mount_output( self , position , vt = None , dirs_only = False ) : #NEWLINE# #INDENT# if dirs_only : #NEWLINE# #INDENT# print_cmd = "{print $3}}'; done" #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# print_cmd = ( '{print $3"%s"$1}}\'; done' % MOUNT_DELIM ) #NEWLINE# #UNINDENT# res = None #NEWLINE# if vt : #NEWLINE# #INDENT# res = self . _mount_output_all ( position , dirs_only = dirs_only ) . get ( vt [ 'id' ] , None ) #NEWLINE# #UNINDENT# if ( not res ) : #NEWLINE# #INDENT# res = self . _mount_output_all ( position , dirs_only = dirs_only ) . get ( DEFAULT , None ) #NEWLINE# #UNINDENT# if ( not res ) : #NEWLINE# #INDENT# cmd = "for exp in $(awk -F'[ =\t]+' '" #NEWLINE# cmd += ( AWK_GET_MOUNTED_LAST_NFS_SHARES % self . storage [ position ] . conf ) #NEWLINE# cmd += print_cmd #NEWLINE# res = self . _run_cmd ( self . clouds [ position ] , cmd ) #NEWLINE# res = set ( ( res if isinstance ( res , list ) else [ res ] ) ) #NEWLINE# #UNINDENT# if ( not res ) : #NEWLINE# #INDENT# raise exception . AbortMigrationError ( ( 'No NFS share found on "%s"' % position ) ) #NEWLINE# #UNINDENT# return dirs_only