Lines Matching refs:MessageHeaderReadState
60 enum MessageHeaderReadState { enum
83 msg_header_read_state: MessageHeaderReadState,
103 msg_header_read_state: MessageHeaderReadState::ReadTimeStamp, in new()
412 MessageHeaderReadState::ReadTimeStamp => { in read_message_header()
415 self.msg_header_read_state = MessageHeaderReadState::ReadMsgLength; in read_message_header()
417 MessageHeaderReadState::ReadMsgLength => { in read_message_header()
425 self.msg_header_read_state = MessageHeaderReadState::ReadMsgTypeID; in read_message_header()
427 MessageHeaderReadState::ReadMsgTypeID => { in read_message_header()
434 self.msg_header_read_state = MessageHeaderReadState::ReadMsgStreamID; in read_message_header()
436 MessageHeaderReadState::ReadMsgStreamID => { in read_message_header()
439 self.msg_header_read_state = MessageHeaderReadState::ReadTimeStamp; in read_message_header()
464 MessageHeaderReadState::ReadTimeStamp => { in read_message_header()
467 self.msg_header_read_state = MessageHeaderReadState::ReadMsgLength; in read_message_header()
469 MessageHeaderReadState::ReadMsgLength => { in read_message_header()
477 self.msg_header_read_state = MessageHeaderReadState::ReadMsgTypeID; in read_message_header()
479 MessageHeaderReadState::ReadMsgTypeID => { in read_message_header()
486 self.msg_header_read_state = MessageHeaderReadState::ReadTimeStamp; in read_message_header()