Module: NativeFS
- Defined in:
- lib/fs/MiqFS/modules/NativeFS.rb
Constant Summary collapse
- MOUNT_DIR =
"/miq_mounts"
- VOL_ID =
"/KNOPPIX/lib/udev/vol_id"
Class Method Summary collapse
Instance Method Summary collapse
- #dirRmdir(p) ⇒ Object
- #freeBytes ⇒ Object
- #fs_dirEntries(p) ⇒ Object
- #fs_dirMkdir(p) ⇒ Object
- #fs_fileAtime(p) ⇒ Object
- #fs_fileAtime_obj(fobj) ⇒ Object
- #fs_fileClose(fobj) ⇒ Object
- #fs_fileCtime(p) ⇒ Object
- #fs_fileCtime_obj(fobj) ⇒ Object
- #fs_fileDelete(p) ⇒ Object
- #fs_fileDirectory?(p) ⇒ Boolean
- #fs_fileExists?(p) ⇒ Boolean
- #fs_fileFile?(p) ⇒ Boolean
- #fs_fileMtime(p) ⇒ Object
- #fs_fileMtime_obj(fobj) ⇒ Object
- #fs_fileOpen(p, mode = "r") ⇒ Object
- #fs_fileRead(fobj, len) ⇒ Object
- #fs_fileSeek(fobj, offset, whence) ⇒ Object
- #fs_fileSize(p) ⇒ Object
- #fs_fileSize_obj(fobj) ⇒ Object
- #fs_fileWrite(fobj, buf, len) ⇒ Object
- #fs_init ⇒ Object
- #fs_umount ⇒ Object
- #internalPath(p) ⇒ Object
Class Method Details
.supported?(dobj) ⇒ Boolean
5 6 7 8 9 10 11 12 |
# File 'lib/fs/MiqFS/modules/NativeFS.rb', line 5 def self.supported?(dobj) devNode = dobj.devFile fsType = `fstype #{devNode}`.chomp $log.debug "NativeFS.supported?: devNode = #{devNode}, fsType = #{fsType}" if $log.debug? return(false) if fsType.empty? || fsType == "auto" || fsType == "swap" (true) end |
Instance Method Details
#dirRmdir(p) ⇒ Object
71 72 73 |
# File 'lib/fs/MiqFS/modules/NativeFS.rb', line 71 def dirRmdir(p) Dir.rmdir(internalPath(p)) end |
#freeBytes ⇒ Object
58 59 60 61 |
# File 'lib/fs/MiqFS/modules/NativeFS.rb', line 58 def freeBytes raise "NativeFS: #{@devNode} is not mounted" if @mountPoint.nil? (`df -lPB1 | grep '#{@mountPoint}$' | awk '{ print $4 }'`.chomp.to_i) end |
#fs_dirEntries(p) ⇒ Object
63 64 65 |
# File 'lib/fs/MiqFS/modules/NativeFS.rb', line 63 def fs_dirEntries(p) Dir.entries(internalPath(p)) end |
#fs_dirMkdir(p) ⇒ Object
67 68 69 |
# File 'lib/fs/MiqFS/modules/NativeFS.rb', line 67 def fs_dirMkdir(p) Dir.mkdir(internalPath(p)) end |
#fs_fileAtime(p) ⇒ Object
99 100 101 |
# File 'lib/fs/MiqFS/modules/NativeFS.rb', line 99 def fs_fileAtime(p) File.atime(internalPath(p)) end |
#fs_fileAtime_obj(fobj) ⇒ Object
111 112 113 |
# File 'lib/fs/MiqFS/modules/NativeFS.rb', line 111 def fs_fileAtime_obj(fobj) fobj.atime end |
#fs_fileClose(fobj) ⇒ Object
141 142 143 |
# File 'lib/fs/MiqFS/modules/NativeFS.rb', line 141 def fs_fileClose(fobj) fobj.close end |
#fs_fileCtime(p) ⇒ Object
103 104 105 |
# File 'lib/fs/MiqFS/modules/NativeFS.rb', line 103 def fs_fileCtime(p) File.ctime(internalPath(p)) end |
#fs_fileCtime_obj(fobj) ⇒ Object
115 116 117 |
# File 'lib/fs/MiqFS/modules/NativeFS.rb', line 115 def fs_fileCtime_obj(fobj) fobj.ctime end |
#fs_fileDelete(p) ⇒ Object
75 76 77 |
# File 'lib/fs/MiqFS/modules/NativeFS.rb', line 75 def fs_fileDelete(p) File.delete(internalPath(p)) end |
#fs_fileDirectory?(p) ⇒ Boolean
87 88 89 |
# File 'lib/fs/MiqFS/modules/NativeFS.rb', line 87 def fs_fileDirectory?(p) File.directory? internalPath((p)) end |
#fs_fileExists?(p) ⇒ Boolean
79 80 81 |
# File 'lib/fs/MiqFS/modules/NativeFS.rb', line 79 def fs_fileExists?(p) File.exist?(internalPath(p)) end |
#fs_fileFile?(p) ⇒ Boolean
83 84 85 |
# File 'lib/fs/MiqFS/modules/NativeFS.rb', line 83 def fs_fileFile?(p) File.file?(internalPath(p)) end |
#fs_fileMtime(p) ⇒ Object
107 108 109 |
# File 'lib/fs/MiqFS/modules/NativeFS.rb', line 107 def fs_fileMtime(p) File.mtime(internalPath(p)) end |
#fs_fileMtime_obj(fobj) ⇒ Object
119 120 121 |
# File 'lib/fs/MiqFS/modules/NativeFS.rb', line 119 def fs_fileMtime_obj(fobj) fobj.mtime end |
#fs_fileOpen(p, mode = "r") ⇒ Object
123 124 125 |
# File 'lib/fs/MiqFS/modules/NativeFS.rb', line 123 def fs_fileOpen(p, mode = "r") File.new(internalPath(p), mode) end |
#fs_fileRead(fobj, len) ⇒ Object
131 132 133 |
# File 'lib/fs/MiqFS/modules/NativeFS.rb', line 131 def fs_fileRead(fobj, len) fobj.read(len) end |
#fs_fileSeek(fobj, offset, whence) ⇒ Object
127 128 129 |
# File 'lib/fs/MiqFS/modules/NativeFS.rb', line 127 def fs_fileSeek(fobj, offset, whence) fobj.seek(offset, whence) end |
#fs_fileSize(p) ⇒ Object
91 92 93 |
# File 'lib/fs/MiqFS/modules/NativeFS.rb', line 91 def fs_fileSize(p) File.size(internalPath(p)) end |
#fs_fileSize_obj(fobj) ⇒ Object
95 96 97 |
# File 'lib/fs/MiqFS/modules/NativeFS.rb', line 95 def fs_fileSize_obj(fobj) fobj.stat.size end |
#fs_fileWrite(fobj, buf, len) ⇒ Object
135 136 137 138 139 |
# File 'lib/fs/MiqFS/modules/NativeFS.rb', line 135 def fs_fileWrite(fobj, buf, len) return(fobj.write(buf)) if buf.length == len return(fobj.write(buf[0, len])) if buf.length > len raise "NativeFS.fs_fileWrite: attempt to write passed the end of buffer" end |
#fs_init ⇒ Object
14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 |
# File 'lib/fs/MiqFS/modules/NativeFS.rb', line 14 def fs_init dInfo = @dobj.dInfo raise "NativeFS: disk is not a local device" unless @dobj.devFile @devNode = @dobj.devFile self.fsType = `fstype #{@devNode}`.chomp raise "NativeFS: cannot determine filesystem type for: #{@devNode}" if fsType.empty? @volName = `#{VOL_ID} -l #{@devNode}`.chomp @fsId = `#{VOL_ID} -u #{@devNode}`.chomp if dInfo.lvObj lv = "#{dInfo.lvObj.vgObj.vgName}-#{dInfo.lvObj.lvName}" @mountPoint = File.join(MOUNT_DIR, lv) @devNode = File.join("/dev/mapper", lv) else @mountPoint = File.join(MOUNT_DIR, File.basename(@devNode)) end if $log.debug? $log.debug "NativeFS.fs_init: devNode = #{@devNode}" $log.debug "NativeFS.fs_init: fsType = #{fsType}" $log.debug "NativeFS.fs_init: volName = #{@volName}" $log.debug "NativeFS.fs_init: fsId = #{@fsId}" end return if isMounted?(@devNode) system("mkdir", "-p", @mountPoint) $log.debug "NativeFS.fs_init: mounting #{@devNode} on #{@mountPoint}" if $log.debug? unless system("mount", @devNode, @mountPoint) raise "NativeFS: Could not mount #{@devNode} on #{@mountPoint}, exit status: #{$?.exitstatus}" end end |
#fs_umount ⇒ Object
49 50 51 52 53 54 55 56 |
# File 'lib/fs/MiqFS/modules/NativeFS.rb', line 49 def fs_umount raise "NativeFS: #{@devNode} is not mounted" if @mountPoint.nil? $log.debug "NativeFS.fs_umount: unmounting #{@mountPoint}" if $log.debug? unless system("umount", @mountPoint) raise "NativeFS: Could not unmount #{@devNode} from #{@mountPoint}, exit status: #{$?.exitstatus}" end @mountPoint = nil end |
#internalPath(p) ⇒ Object
145 146 147 148 |
# File 'lib/fs/MiqFS/modules/NativeFS.rb', line 145 def internalPath(p) raise "NativeFS: #{@devNode} is not mounted" if @mountPoint.nil? (File.join(@mountPoint, p)) end |