Lines Matching full:stream
206 def __init__ (self, stream, msg):
207 stream.error_loc = stream.tell()
208 self.stream = stream
211 return '[%d]: %s' % (self.stream.error_loc, self.msg)
257 def ReadByte (stream):
259 return ord(stream.read(1))
261 stream.error_loc = stream.tell()
262 raise MIDIFileException(stream, 'Unexpected EOF')
264 def ReadBytes (stream, length):
267 bytes.append(ReadByte(stream))
270 def ReadVarLenQty (stream):
273 byte = ReadByte(stream)
278 def WriteByte (stream, value):
279 stream.write(chr(value))
281 def WriteBytes (stream, bytes):
283 WriteByte(stream, byte)
285 def WriteVarLenQty (stream, value):
292 WriteBytes(stream, bytes)
333 """Factory for creating MIDI events from a stream."""
335 def ReadFromStream (stream, seq, ticks, msg_type):
337 return SysExEvent.ReadFromStream(stream, seq, ticks, msg_type)
339 return SysExContEvent.ReadFromStream(stream, seq, ticks, msg_type)
341 return MetaEvent.ReadFromStream(stream, seq, ticks, msg_type)
345 return NoteOffEvent.ReadFromStream(stream, seq, ticks, msg_type)
347 return NoteOnEvent.ReadFromStream(stream, seq, ticks, msg_type)
349 return PolyKeyPressureEvent.ReadFromStream(stream, seq, ticks, msg_type)
351 return ControlChangeEvent.ReadFromStream(stream, seq, ticks, msg_type)
353 return ProgramChangeEvent.ReadFromStream(stream, seq, ticks, msg_type)
355 return ChannelPressureEvent.ReadFromStream(stream, seq, ticks, msg_type)
357 return PitchBendEvent.ReadFromStream(stream, seq, ticks, msg_type)
359 stream.Warning('Ignoring unexpected message type 0x%02x' % msg_type)
360 def WriteTicks (self, stream, track):
361 WriteVarLenQty(stream, self.ticks - track.ticks)
363 def WriteRunningStatus (self, stream, track, filters, msg, data1, data2=None):
366 self.WriteTicks(stream, track)
369 WriteByte(stream, status)
371 WriteByte(stream, data1)
373 WriteByte(stream, data2)
404 def ReadFromStream (stream, seq, ticks, msg_type):
407 note = ReadByte(stream)
408 velocity = ReadByte(stream)
410 stream.seek(-2,1)
411 raise MIDIFileException(stream, MSG_TYPE_MISMATCH)
413 def WriteToStream (self, stream, track, filters=None):
416 self.WriteRunningStatus(stream, track, filters, NOTE_ON, self.note, self.velocity)
418 self.WriteRunningStatus(stream, track, filters, NOTE_ON, self.note, self.velocity)
420 self.WriteRunningStatus(stream, track, filters, NOTE_ON, self.note, 0)
439 def ReadFromStream (stream, seq, ticks, msg_type):
441 note = ReadByte(stream)
442 velocity = ReadByte(stream)
444 stream.seek(-2,1)
445 raise MIDIFileException(stream, MSG_TYPE_MISMATCH)
449 def WriteToStream (self, stream, track, filters=None):
450 self.WriteRunningStatus(stream, track, filters, NOTE_ON, self.note, self.velocity)
470 def ReadFromStream (stream, seq, ticks, msg_type):
472 note = ReadByte(stream)
473 value = ReadByte(stream)
475 stream.seek(-2,1)
476 raise MIDIFileException(stream, MSG_TYPE_MISMATCH)
478 def WriteToStream (self, stream, track, filters=None):
479 self.WriteRunningStatus(stream, track, filters, POLY_KEY_PRESSURE, self.note, self.value)
496 def ReadFromStream (stream, seq, ticks, msg_type):
498 controller = ReadByte(stream)
499 value = ReadByte(stream)
501 stream.seek(-2,1)
502 raise MIDIFileException(stream, MSG_TYPE_MISMATCH)
506 def WriteToStream (self, stream, track, filters=None):
507 self.WriteRunningStatus(stream, track, filters, CONTROL_CHANGE, self.controller, self.value)
524 def ReadFromStream (stream, seq, ticks, msg_type):
526 controller = ReadByte(stream)
527 value = ReadByte(stream)
529 stream.seek(-2,1)
530 raise MIDIFileException(stream, MSG_TYPE_MISMATCH)
534 def WriteToStream (self, stream, track, filters=None):
535 self.WriteRunningStatus(stream, track, filters, CONTROL_CHANGE, self.controller, self.value)
551 def ReadFromStream (stream, seq, ticks, msg_type):
553 program = ReadByte(stream)
555 stream.seek(-1,1)
556 raise MIDIFileException(stream, MSG_TYPE_MISMATCH)
558 def WriteToStream (self, stream, track, filters=None):
559 self.WriteRunningStatus(stream, track, filters, PROGRAM_CHANGE, self.program)
575 def ReadFromStream (stream, seq, ticks, msg_type):
577 value = ReadByte(stream)
579 stream.seek(-1,1)
580 raise MIDIFileException(stream, MSG_TYPE_MISMATCH)
582 def WriteToStream (self, stream, track, filters=None):
583 self.WriteRunningStatus(stream, track, filters, CHANNEL_PRESSURE, self.value)
599 def ReadFromStream (stream, seq, ticks, msg_type):
601 value = (ReadByte(stream) << 7) + ReadByte(stream) - 0x2000
603 stream.seek(-2,1)
604 raise MIDIFileException(stream, MSG_TYPE_MISMATCH)
606 def WriteToStream (self, stream, track, filters=None):
612 self.WriteRunningStatus(stream, track, filters, PITCH_BEND, value >> 7, value & 0x7f)
628 def ReadFromStream (stream, seq, ticks, msg_type):
629 pos = stream.tell()
630 length = ReadVarLenQty(stream)
631 msg = ReadBytes(stream, length)
633 stream.seek(pos,0)
634 raise MIDIFileException(stream, MSG_TYPE_MISMATCH)
636 def WriteToStream (self, stream, track, filters=None):
639 self.WriteTicks(stream, track)
640 WriteByte(stream, SYSEX)
641 WriteVarLenQty(stream, self.length)
642 WriteBytes(stream, self.msg)
660 def ReadFromStream (stream, seq, ticks, msg_type):
661 pos = stream.tell()
662 length = ReadVarLenQty(stream)
663 msg = ReadBytes(stream, length)
665 stream.seek(pos,0)
666 raise MIDIFileException(stream, MSG_TYPE_MISMATCH)
668 def WriteToStream (self, stream, track, filters=None):
671 self.WriteTicks(stream, track)
672 WriteByte(stream, END_SYSEX)
673 WriteVarLenQty(stream, self.length)
674 WriteBytes(stream, self.msg)
693 def ReadFromStream (stream, seq, ticks, msg_type):
694 pos = stream.tell()
695 meta_type = ReadByte(stream)
696 length = ReadVarLenQty(stream)
697 msg = ReadBytes(stream, length)
699 stream.seek(pos,0)
700 raise MIDIFileException(stream, MSG_TYPE_MISMATCH)
703 def WriteToStream (self, stream, track, filters=None):
706 self.WriteTicks(stream, track)
707 WriteByte(stream, META_EVENT)
708 WriteByte(stream, self.meta_type)
709 WriteVarLenQty(stream, self.length)
710 WriteBytes(stream, self.msg)
978 def ReadFromStream (self, stream, offset, file_size):
979 self.stream = stream
983 tick_warning_level = stream.timebase.ppqn * LARGE_TICK_WARNING
986 stream.seek(offset)
987 bytes = stream.read(struct.calcsize(SMF_TRACK_HEADER_FMT))
991 raise MIDIFileException(stream, MSG_INVALID_TRACK_HEADER)
992 self.start = stream.tell()
996 stream.Warning('Ignoring illegal track length - %d exceeds length of file' % track_len)
1004 pos = stream.tell()
1013 stream.Warning('Ignoring data encountered beyond end-of-track meta-event')
1017 delta = ReadVarLenQty(stream)
1019 stream.Warning('Tick value is excessive - possibly corrupt data?')
1023 msg_type = ReadByte(stream)
1032 stream.seek(-1,1)
1036 stream.Warning('Ignoring data byte received with no running status')
1038 # create event type from stream
1039 event = MIDIEvent.ReadFromStream(stream, seq, ticks, msg_type)
1056 stream.Warning('Duplicate note-on\'s encountered without intervening note-off')
1057 stream.Warning(' [%s]: %s' % (stream.timebase.ConvertTicksToStr(event.ticks), event.__str__()))
1060 stream.Warning('Eliminating duplicate note-on')
1076 # stream.Warning('Note-off encountered without corresponding note-on')
1077 # stream.Warning(' [%s]: %s' % (stream.timebase.ConvertTicksToStr(event.ticks), event.__str__()))
1093 stream.last_good_event = pos
1103 # stream.Warning('Note-ons encountered without corresponding note-offs')
1108 stream.Warning('End of track encountered with no end-of-track meta-event')
1112 track_len = stream.tell() - offset - 8
1116 def Write (self, stream, filters=None):
1118 header_loc = stream.tell()
1119 stream.seek(header_loc + struct.calcsize(SMF_TRACK_HEADER_FMT))
1153 event.WriteToStream(stream, self, filters)
1159 MetaEvent(self.end_of_track, 0, META_EVENT_END_OF_TRACK,[]).WriteToStream(stream, self, None)
1162 end_of_track = stream.tell()
1164 stream.seek(header_loc)
1166 stream.write(bytes)
1167 stream.seek(end_of_track)
1195 controller_events.DumpEvents(None, self.stream.timebase)
1219 midi_file_logger.debug('Trim: trimming note that extends past end %s' % event.TimeEventStr(self.stream.timebase))
1242 self.events.DumpEvents(output, self.stream.timebase)
1244 output.write('[%s]: end-of-track\n' % self.stream.timebase.ConvertTicksToStr(self.end_of_track))
1246 midi_file_logger.debug('[%s]: end-of-track' % self.stream.timebase.ConvertTicksToStr(self.end_of_track))
