(self, segment)
| 173 | return path.isdir(self.seg_dir(segment)) |
| 174 | |
| 175 | def running_size(self, segment): |
| 176 | byts = 0 |
| 177 | try: |
| 178 | sd = self.seg_dir(segment) |
| 179 | for s in os.listdir(sd): |
| 180 | byts += path.getsize(path.join(sd, s)) |
| 181 | |
| 182 | return byts |
| 183 | except EnvironmentError as e: |
| 184 | if e.errno == errno.ENOENT: |
| 185 | return byts |
| 186 | |
| 187 | raise |
| 188 | |
| 189 | def promote(self, segment, destination): |
| 190 | source = path.join(self.prefetched_dir, segment.name) |