|
@@ -235,9 +235,13 @@ info(StreamID, Data0={data, Pid, _, _}, State0=#state{stream_body_status=Status}
|
|
end,
|
|
end,
|
|
Data = erlang:delete_element(2, Data0),
|
|
Data = erlang:delete_element(2, Data0),
|
|
do_info(StreamID, Data, [Data], State);
|
|
do_info(StreamID, Data, [Data], State);
|
|
-info(StreamID, Alarm={alarm, Name, on}, State)
|
|
+info(StreamID, Alarm={alarm, Name, on}, State0=#state{stream_body_status=Status})
|
|
when Name =:= connection_buffer_full; Name =:= stream_buffer_full ->
|
|
when Name =:= connection_buffer_full; Name =:= stream_buffer_full ->
|
|
- do_info(StreamID, Alarm, [], State#state{stream_body_status=blocking});
|
|
+ State = case Status of
|
|
|
|
+ normal -> State0#state{stream_body_status=blocking};
|
|
|
|
+ _ -> State0
|
|
|
|
+ end,
|
|
|
|
+ do_info(StreamID, Alarm, [], State);
|
|
info(StreamID, Alarm={alarm, Name, off}, State=#state{stream_body_pid=Pid, stream_body_status=Status})
|
|
info(StreamID, Alarm={alarm, Name, off}, State=#state{stream_body_pid=Pid, stream_body_status=Status})
|
|
when Name =:= connection_buffer_full; Name =:= stream_buffer_full ->
|
|
when Name =:= connection_buffer_full; Name =:= stream_buffer_full ->
|
|
_ = case Status of
|
|
_ = case Status of
|