|
a/src/filters/rclwar |
|
b/src/filters/rclwar |
|
... |
|
... |
20 |
ok = False
|
20 |
ok = False
|
21 |
return (ok, docdata, tarinfo.name, rclexecm.RclExecM.noteof)
|
21 |
return (ok, docdata, tarinfo.name, rclexecm.RclExecM.noteof)
|
22 |
|
22 |
|
23 |
###### File type handler api, used by rclexecm ---------->
|
23 |
###### File type handler api, used by rclexecm ---------->
|
24 |
def openfile(self, params):
|
24 |
def openfile(self, params):
|
25 |
self.currentindex = 0
|
25 |
self.currentindex = -1
|
26 |
try:
|
26 |
try:
|
27 |
self.tar = tarfile.open(params["filename:"])
|
27 |
self.tar = tarfile.open(params["filename:"])
|
28 |
return True
|
28 |
return True
|
29 |
except Exception, err:
|
29 |
except Exception, err:
|
30 |
self.em.rclog(str(err))
|
30 |
self.em.rclog(str(err))
|
|
... |
|
... |
38 |
self.em.rclog(str(err))
|
38 |
self.em.rclog(str(err))
|
39 |
return (False, "", ipath, rclexecm.RclExecM.noteof)
|
39 |
return (False, "", ipath, rclexecm.RclExecM.noteof)
|
40 |
return self.extractone(tarinfo)
|
40 |
return self.extractone(tarinfo)
|
41 |
|
41 |
|
42 |
def getnext(self, params):
|
42 |
def getnext(self, params):
|
|
|
43 |
if self.currentindex == -1:
|
|
|
44 |
# Return "self" doc
|
|
|
45 |
self.currentindex = 0
|
|
|
46 |
return (True, "", "", rclexecm.RclExecM.noteof)
|
|
|
47 |
|
43 |
tarinfo = self.tar.next()
|
48 |
tarinfo = self.tar.next()
|
44 |
if tarinfo is None:
|
49 |
if tarinfo is None:
|
45 |
#self.em.rclog("getnext: EOF hit")
|
50 |
#self.em.rclog("getnext: EOF hit")
|
46 |
return (False, "", "", rclexecm.RclExecM.eofnow)
|
51 |
return (False, "", "", rclexecm.RclExecM.eofnow)
|
47 |
else:
|
52 |
else:
|