我在写入文件时遇到了比我预期更多的问题。我有一台小型单板计算机,运行在带有Angstrom嵌入式发行版的arm处理器上。我正在用python为它写一个应用程序。应用程序应检测到U盘,然后将文件转储到U盘。我遇到的问题是,即使我的脚本似乎正确地写入了文件,并且文件在Linux中使用"ls“和"cat”显示在那里,当我移除U盘并尝试在Windows或其他linux发行版中查看文件时,它仍然是空的,或者更常见的情况是根本不在那里。我的应用程序是多线程的。我创建了/media/mymntpnt作为root (目录)。
任何帮助都是非常感谢的。
下面是我的一些代码片段:
这部分是我用来识别U盘的部分:
class MediaScanner():
def __init__(self):
self.lok = thread.allocate_lock()
self.running = True
self.started = False
def register_cb(self,func):
self.cb = func
def start(self):
if not self.started:
thread.start_new_thread(self.scan_thread,())
def scan_thread(self):
self.quit = False
self.started = True
last_devices = []
while self.running:
devices = self.scan_media()
if (devices != last_devices):
self.cb(devices) #call the callback as its own thread
last_devices = devices
time.sleep(0.1)
self.quit = True
def stop(self):
self.running = False
while(not self.quit):
pass
return True
def is_running(self):
return self.running
def scan_media(self):
with self.lok:
partitionsFile = open("/proc/partitions")
lines = partitionsFile.readlines()[2:]#Skips the header lines
devices = []
for line in lines:
words = [x.strip() for x in line.split()]
minorNumber = int(words[1])
deviceName = words[3]
if minorNumber % 16 == 0:
path = "/sys/class/block/" + deviceName
if os.path.islink(path):
if os.path.realpath(path).find("/usb") > 0:
devices.append('/dev/'+deviceName)
partitionsFile.close()
return devices下面是我编写该文件的脚本示例:
from mediascanner import *
from util import *
from database import *
from log import *
ms = MediaScanner()
devices = ms.scan_media()
print devices
if devices:
db = TestDatabase(init_tables=False)
data = db.get_all_test_data()
for device in devices:
print device
mount_partition(get_partition(device))
write_and_verify('/media/mymntpnt/test_'+get_log_file_name(),flatten_tests(data))
unmount_partition()下面是我的实用函数:
def write_and_verify(f_n,data):
f = file(f_n,'w')
f.write(data)
f.flush()
f.close()
f = file(f_n,'r')
verified = f.read()
f.close()
return verified == data and f.closed
def get_partition(dev):
os.system('fdisk -l %s > output' % dev)
f = file('output')
data = f.read()
print data
f.close()
return data.split('\n')[-2].split()[0].strip()
def mount_partition(partition):
os.system('mount %s /media/mymntpnt' % partition)
def unmount_partition():
os.system('umount /media/mymntpnt')发布于 2011-08-04 10:01:41
错误出现在write函数中,该函数应该在关闭文件之前同步它,如下所示。读取将始终成功,因为数据已在RAM中。您可能想尝试一些不同的方法来验证它,比如检查字节计数。
def write_and_verify(f_n,data):
f = file(f_n,'w')
f.write(data)
f.flush()
os.fsync(f.fileno())
f.close()
f = file(f_n,'r')
verified = f.read()
f.close()
return verified == data and f.closed如果你得到的文件信息像这样的finfo = os.stat(f_n),那么你可以将finfo.st_size与你期望写入的字节数进行比较。
https://stackoverflow.com/questions/6840711
复制相似问题