pub fn process_control_receive_queue(
    queue: &mut Queue,
    pending_receive_control_msgs: &mut VecDeque<ControlMsgBytes>
)