diff options
| author | Essien Ita Essien <essiene@gmail.com> | 2008-12-28 23:54:04 +0100 |
|---|---|---|
| committer | Essien Ita Essien <essiene@gmail.com> | 2008-12-28 23:54:04 +0100 |
| commit | 2955e19dfa2950d165e046ba3fea79ab4c3bd608 (patch) | |
| tree | a97ff8ba583f18c7765aab24f8686e866c53f5d4 /src | |
| parent | 7071f433724aefa5525c9d7f27a4f54492a512a8 (diff) | |
| download | rabbitmq-server-git-2955e19dfa2950d165e046ba3fea79ab4c3bd608.tar.gz | |
Make rabbit_net:port_command mimick erlang:port_command more closely
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_net.erl | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/src/rabbit_net.erl b/src/rabbit_net.erl index 8c704b821b..a8b030b825 100644 --- a/src/rabbit_net.erl +++ b/src/rabbit_net.erl @@ -91,9 +91,11 @@ peername(Sock) when is_port(Sock) -> port_command(Sock, Data) when is_record(Sock, ssl_socket) -> case ssl:send(Sock#ssl_socket.ssl, Data) of ok -> + self() ! {inet_reply, Sock, ok}, true; {error, Reason} -> - throw(Reason) + self() ! {inet_reply, Sock, {error, Reason}}, + erlang:error(Reason) end; port_command(Sock, Data) when is_port(Sock) -> |