Skip to content

Commit a527f86

Browse files
authored
Fix message offset (#374)
* Correct message iterator offset append * Added destructor and removed opening file twice * Added close of trace
1 parent b64133d commit a527f86

File tree

3 files changed

+4
-7
lines changed

3 files changed

+4
-7
lines changed

format/OSITrace.py

Lines changed: 1 addition & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -45,11 +45,6 @@ def __init__(self, path=None, type_name="SensorView"):
4545
self.timestep_count = 0
4646
self.retrieved_scenario_size = 0
4747

48-
if path is not None and type_name is not None:
49-
self.from_file(path)
50-
51-
# Open and Read text file
52-
5348
def from_file(self, path, type_name="SensorView", max_index=-1, format_type=None):
5449
"""Import a scenario from a file"""
5550

@@ -142,7 +137,7 @@ def retrieve_message(self):
142137
message_length = struct.unpack("<L", serialized_message[i:INT_LENGTH+i])[0]
143138
message.ParseFromString(serialized_message[i+INT_LENGTH:i+INT_LENGTH+message_length])
144139
i += message_length + INT_LENGTH
145-
self.message_offsets.append(message)
140+
self.message_offsets.append(i)
146141

147142
if eof:
148143
self.retrieved_scenario_size = scenario_size

format/osi2read.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -56,7 +56,8 @@ def main():
5656
if args.output == 'converted.txth':
5757
args.output = args.data.split('.', 1)[0] + '.txth'
5858

59-
trace.make_readable(args.output)
59+
trace.make_readable(args.output)
60+
trace.scenario_file.close()
6061

6162
if __name__ == "__main__":
6263
main()

format/txt2osi.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -69,6 +69,7 @@ def main():
6969
f.write(struct.pack("<L", len(byte_buffer)) + byte_buffer)
7070

7171
f.close()
72+
trace.scenario_file.close()
7273

7374
if __name__ == "__main__":
7475
main()

0 commit comments

Comments
 (0)