diff options
Diffstat (limited to 'src/gun_spdy.erl')
| -rw-r--r-- | src/gun_spdy.erl | 9 |
1 files changed, 9 insertions, 0 deletions
diff --git a/src/gun_spdy.erl b/src/gun_spdy.erl index 6aeb517..c417e78 100644 --- a/src/gun_spdy.erl +++ b/src/gun_spdy.erl @@ -15,6 +15,7 @@ -module(gun_spdy). -export([check_options/1]). +-export([name/0]). -export([init/4]). -export([handle/2]). -export([close/1]). @@ -23,6 +24,7 @@ -export([request/8]). -export([data/4]). -export([cancel/2]). +-export([down/1]). -record(stream, { id :: non_neg_integer(), @@ -52,6 +54,8 @@ do_check_options([{keepalive, K}|Opts]) when is_integer(K), K > 0 -> do_check_options([Opt|_]) -> {error, {options, {spdy, Opt}}}. +name() -> spdy. + init(Owner, Socket, Transport, _Opts) -> #spdy_state{owner=Owner, socket=Socket, transport=Transport, zdef=cow_spdy:deflate_init(), zinf=cow_spdy:inflate_init()}. @@ -263,6 +267,11 @@ cancel(State=#spdy_state{socket=Socket, transport=Transport}, error_stream_not_found(State) end. +%% @todo Add unprocessed streams when GOAWAY handling is done. +down(#spdy_state{streams=Streams}) -> + KilledStreams = [Ref || #stream{ref=Ref} <- Streams], + {KilledStreams, []}. + error_stream_closed(State=#spdy_state{owner=Owner}) -> Owner ! {gun_error, self(), {badstate, "The stream has already been closed."}}, |