2015-03-31 07:46:03 +00:00
|
|
|
%% -------------------------------------------------------------------
|
|
|
|
%%
|
|
|
|
%% Copyright (c) 2007-2015 Basho Technologies, Inc. All Rights Reserved.
|
|
|
|
%%
|
|
|
|
%% This file is provided to you under the Apache License,
|
|
|
|
%% Version 2.0 (the "License"); you may not use this file
|
|
|
|
%% except in compliance with the License. You may obtain
|
|
|
|
%% a copy of the License at
|
|
|
|
%%
|
|
|
|
%% http://www.apache.org/licenses/LICENSE-2.0
|
|
|
|
%%
|
|
|
|
%% Unless required by applicable law or agreed to in writing,
|
|
|
|
%% software distributed under the License is distributed on an
|
|
|
|
%% "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
|
|
|
|
%% KIND, either express or implied. See the License for the
|
|
|
|
%% specific language governing permissions and limitations
|
|
|
|
%% under the License.
|
|
|
|
%%
|
|
|
|
%% -------------------------------------------------------------------
|
|
|
|
|
|
|
|
-module(machi_flu1_client).
|
|
|
|
|
|
|
|
-include("machi.hrl").
|
|
|
|
|
|
|
|
-export([
|
|
|
|
append_chunk/3, append_chunk/4,
|
|
|
|
read_chunk/4, read_chunk/5,
|
|
|
|
checksum_list/2, checksum_list/3,
|
|
|
|
list_files/1, list_files/2,
|
|
|
|
quit/1
|
|
|
|
]).
|
|
|
|
%% For "internal" replication only.
|
|
|
|
-export([
|
|
|
|
write_chunk/4, write_chunk/5,
|
|
|
|
delete_migration/2, delete_migration/3,
|
|
|
|
trunc_hack/2, trunc_hack/3
|
|
|
|
]).
|
|
|
|
|
2015-04-02 03:38:12 +00:00
|
|
|
-type chunk() :: binary() | iolist(). % client can use either
|
|
|
|
-type chunk_csum() :: {file_offset(), chunk_size(), binary()}.
|
|
|
|
-type chunk_s() :: binary(). % server always uses binary()
|
2015-03-31 07:46:03 +00:00
|
|
|
-type chunk_pos() :: {file_offset(), chunk_size(), file_name_s()}.
|
|
|
|
-type chunk_size() :: non_neg_integer().
|
|
|
|
-type inet_host() :: inet:ip_address() | inet:hostname().
|
|
|
|
-type inet_port() :: inet:port_number().
|
2015-04-02 03:38:12 +00:00
|
|
|
-type file_info() :: {file_size(), file_name_s()}.
|
2015-03-31 07:46:03 +00:00
|
|
|
-type file_name() :: binary() | list().
|
|
|
|
-type file_name_s() :: binary(). % server reply
|
|
|
|
-type file_offset() :: non_neg_integer().
|
2015-04-02 03:38:12 +00:00
|
|
|
-type file_size() :: non_neg_integer().
|
2015-03-31 07:46:03 +00:00
|
|
|
-type file_prefix() :: binary() | list().
|
|
|
|
|
|
|
|
%% @doc Append a chunk (binary- or iolist-style) of data to a file
|
|
|
|
%% with `Prefix'.
|
|
|
|
|
|
|
|
-spec append_chunk(port(), file_prefix(), chunk()) ->
|
|
|
|
{ok, chunk_pos()} | {error, term()}.
|
|
|
|
append_chunk(Sock, Prefix, Chunk) ->
|
|
|
|
append_chunk2(Sock, Prefix, Chunk).
|
|
|
|
|
|
|
|
%% @doc Append a chunk (binary- or iolist-style) of data to a file
|
|
|
|
%% with `Prefix'.
|
|
|
|
|
|
|
|
-spec append_chunk(inet_host(), inet_port(), file_prefix(), chunk()) ->
|
|
|
|
{ok, chunk_pos()} | {error, term()}.
|
|
|
|
append_chunk(Host, TcpPort, Prefix, Chunk) ->
|
|
|
|
Sock = machi_util:connect(Host, TcpPort),
|
|
|
|
try
|
|
|
|
append_chunk2(Sock, Prefix, Chunk)
|
|
|
|
after
|
|
|
|
catch gen_tcp:close(Sock)
|
|
|
|
end.
|
|
|
|
|
|
|
|
%% @doc Read a chunk of data of size `Size' from `File' at `Offset'.
|
|
|
|
|
|
|
|
-spec read_chunk(port(), file_name(), file_offset(), chunk_size()) ->
|
|
|
|
{ok, chunk_s()} | {error, term()}.
|
2015-04-02 03:38:12 +00:00
|
|
|
read_chunk(Sock, File, Offset, Size)
|
|
|
|
when Offset >= ?MINIMUM_OFFSET, Size >= 0 ->
|
2015-03-31 07:46:03 +00:00
|
|
|
read_chunk2(Sock, File, Offset, Size).
|
|
|
|
|
|
|
|
%% @doc Read a chunk of data of size `Size' from `File' at `Offset'.
|
|
|
|
|
|
|
|
-spec read_chunk(inet_host(), inet_port(), file_name(), file_offset(), chunk_size()) ->
|
|
|
|
{ok, chunk_s()} | {error, term()}.
|
2015-04-02 03:38:12 +00:00
|
|
|
read_chunk(Host, TcpPort, File, Offset, Size)
|
|
|
|
when Offset >= ?MINIMUM_OFFSET, Size >= 0 ->
|
2015-03-31 07:46:03 +00:00
|
|
|
Sock = machi_util:connect(Host, TcpPort),
|
|
|
|
try
|
|
|
|
read_chunk2(Sock, File, Offset, Size)
|
|
|
|
after
|
|
|
|
catch gen_tcp:close(Sock)
|
|
|
|
end.
|
|
|
|
|
|
|
|
%% @doc Fetch the list of chunk checksums for `File'.
|
|
|
|
|
|
|
|
-spec checksum_list(port(), file_name()) ->
|
2015-04-02 03:38:12 +00:00
|
|
|
{ok, [chunk_csum()]} | {error, term()}.
|
2015-03-31 07:46:03 +00:00
|
|
|
checksum_list(Sock, File) when is_port(Sock) ->
|
|
|
|
checksum_list2(Sock, File).
|
|
|
|
|
|
|
|
%% @doc Fetch the list of chunk checksums for `File'.
|
|
|
|
|
|
|
|
-spec checksum_list(inet_host(), inet_port(), file_name()) ->
|
2015-04-02 03:38:12 +00:00
|
|
|
{ok, [chunk_csum()]} | {error, term()}.
|
2015-03-31 07:46:03 +00:00
|
|
|
checksum_list(Host, TcpPort, File) when is_integer(TcpPort) ->
|
|
|
|
Sock = machi_util:connect(Host, TcpPort),
|
|
|
|
try
|
|
|
|
checksum_list2(Sock, File)
|
|
|
|
after
|
|
|
|
catch gen_tcp:close(Sock)
|
|
|
|
end.
|
|
|
|
|
|
|
|
%% @doc Fetch the list of all files on the remote FLU.
|
|
|
|
|
|
|
|
-spec list_files(port()) ->
|
2015-04-02 03:38:12 +00:00
|
|
|
{ok, [file_info()]} | {error, term()}.
|
2015-03-31 07:46:03 +00:00
|
|
|
list_files(Sock) when is_port(Sock) ->
|
|
|
|
list2(Sock).
|
|
|
|
|
|
|
|
%% @doc Fetch the list of all files on the remote FLU.
|
|
|
|
|
|
|
|
-spec list_files(inet_host(), inet_port()) ->
|
2015-04-02 03:38:12 +00:00
|
|
|
{ok, [file_info()]} | {error, term()}.
|
2015-03-31 07:46:03 +00:00
|
|
|
list_files(Host, TcpPort) when is_integer(TcpPort) ->
|
|
|
|
Sock = machi_util:connect(Host, TcpPort),
|
|
|
|
try
|
|
|
|
list2(Sock)
|
|
|
|
after
|
|
|
|
catch gen_tcp:close(Sock)
|
|
|
|
end.
|
|
|
|
|
|
|
|
%% @doc Quit & close the connection to remote FLU.
|
|
|
|
|
|
|
|
-spec quit(port()) ->
|
|
|
|
ok.
|
|
|
|
quit(Sock) when is_port(Sock) ->
|
|
|
|
catch (_ = gen_tcp:send(Sock, <<"QUIT\n">>)),
|
|
|
|
catch gen_tcp:close(Sock),
|
|
|
|
ok.
|
|
|
|
|
|
|
|
%%%%%%%%%%%%%%%%%%%%%%%%%%%
|
|
|
|
|
|
|
|
%% @doc Restricted API: Write a chunk of already-sequenced data to
|
|
|
|
%% `File' at `Offset'.
|
|
|
|
|
|
|
|
-spec write_chunk(port(), file_name(), file_offset(), chunk()) ->
|
2015-04-02 03:38:12 +00:00
|
|
|
ok | {error, term()}.
|
|
|
|
write_chunk(Sock, File, Offset, Chunk)
|
|
|
|
when Offset >= ?MINIMUM_OFFSET ->
|
2015-03-31 07:46:03 +00:00
|
|
|
write_chunk2(Sock, File, Offset, Chunk).
|
|
|
|
|
|
|
|
%% @doc Restricted API: Write a chunk of already-sequenced data to
|
|
|
|
%% `File' at `Offset'.
|
|
|
|
|
|
|
|
-spec write_chunk(inet_host(), inet_port(), file_name(), file_offset(), chunk()) ->
|
2015-04-02 03:38:12 +00:00
|
|
|
ok | {error, term()}.
|
|
|
|
write_chunk(Host, TcpPort, File, Offset, Chunk)
|
|
|
|
when Offset >= ?MINIMUM_OFFSET ->
|
2015-03-31 07:46:03 +00:00
|
|
|
Sock = machi_util:connect(Host, TcpPort),
|
|
|
|
try
|
|
|
|
write_chunk2(Sock, File, Offset, Chunk)
|
|
|
|
after
|
|
|
|
catch gen_tcp:close(Sock)
|
|
|
|
end.
|
|
|
|
|
|
|
|
%% @doc Restricted API: Delete a file after it has been successfully
|
|
|
|
%% migrated.
|
|
|
|
|
|
|
|
-spec delete_migration(port(), file_name()) ->
|
2015-04-02 03:38:12 +00:00
|
|
|
ok | {error, term()}.
|
2015-03-31 07:46:03 +00:00
|
|
|
delete_migration(Sock, File) when is_port(Sock) ->
|
|
|
|
delete_migration2(Sock, File).
|
|
|
|
|
|
|
|
%% @doc Restricted API: Delete a file after it has been successfully
|
|
|
|
%% migrated.
|
|
|
|
|
|
|
|
-spec delete_migration(inet_host(), inet_port(), file_name()) ->
|
2015-04-02 03:38:12 +00:00
|
|
|
ok | {error, term()}.
|
2015-03-31 07:46:03 +00:00
|
|
|
delete_migration(Host, TcpPort, File) when is_integer(TcpPort) ->
|
|
|
|
Sock = machi_util:connect(Host, TcpPort),
|
|
|
|
try
|
|
|
|
delete_migration2(Sock, File)
|
|
|
|
after
|
|
|
|
catch gen_tcp:close(Sock)
|
|
|
|
end.
|
|
|
|
|
|
|
|
%% @doc Restricted API: Truncate a file after it has been successfully
|
|
|
|
%% erasure coded.
|
|
|
|
|
|
|
|
-spec trunc_hack(port(), file_name()) ->
|
2015-04-02 03:38:12 +00:00
|
|
|
ok | {error, term()}.
|
2015-03-31 07:46:03 +00:00
|
|
|
trunc_hack(Sock, File) when is_port(Sock) ->
|
|
|
|
trunc_hack2(Sock, File).
|
|
|
|
|
|
|
|
%% @doc Restricted API: Truncate a file after it has been successfully
|
|
|
|
%% erasure coded.
|
|
|
|
|
|
|
|
-spec trunc_hack(inet_host(), inet_port(), file_name()) ->
|
2015-04-02 03:38:12 +00:00
|
|
|
ok | {error, term()}.
|
2015-03-31 07:46:03 +00:00
|
|
|
trunc_hack(Host, TcpPort, File) when is_integer(TcpPort) ->
|
|
|
|
Sock = machi_util:connect(Host, TcpPort),
|
|
|
|
try
|
|
|
|
trunc_hack2(Sock, File)
|
|
|
|
after
|
|
|
|
catch gen_tcp:close(Sock)
|
|
|
|
end.
|
|
|
|
|
|
|
|
%%%%%%%%%%%%%%%%%%%%%%%%%%%
|
|
|
|
|
|
|
|
append_chunk2(Sock, Prefix0, Chunk0) ->
|
|
|
|
try
|
|
|
|
%% TODO: add client-side checksum to the server's protocol
|
|
|
|
%% _ = crypto:hash(md5, Chunk),
|
|
|
|
Prefix = machi_util:make_binary(Prefix0),
|
|
|
|
Chunk = machi_util:make_binary(Chunk0),
|
|
|
|
Len = iolist_size(Chunk0),
|
|
|
|
true = (Len =< ?MAX_CHUNK_SIZE),
|
|
|
|
LenHex = machi_util:int_to_hexbin(Len, 32),
|
|
|
|
Cmd = <<"A ", LenHex/binary, " ", Prefix/binary, "\n">>,
|
|
|
|
ok = gen_tcp:send(Sock, [Cmd, Chunk]),
|
|
|
|
{ok, Line} = gen_tcp:recv(Sock, 0),
|
|
|
|
PathLen = byte_size(Line) - 3 - 16 - 1 - 1,
|
|
|
|
case Line of
|
|
|
|
<<"OK ", OffsetHex:16/binary, " ",
|
|
|
|
Path:PathLen/binary, _:1/binary>> ->
|
|
|
|
Offset = machi_util:hexstr_to_int(OffsetHex),
|
|
|
|
{ok, {Offset, Len, Path}};
|
|
|
|
<<"ERROR BAD-ARG", _/binary>> ->
|
|
|
|
{error, bad_arg};
|
|
|
|
<<"ERROR ", Rest/binary>> ->
|
|
|
|
{error, Rest}
|
|
|
|
end
|
|
|
|
catch
|
|
|
|
throw:Error ->
|
|
|
|
Error;
|
|
|
|
error:{badmatch,_}=BadMatch ->
|
|
|
|
{error, {badmatch, BadMatch, erlang:get_stacktrace()}}
|
|
|
|
end.
|
|
|
|
|
|
|
|
read_chunk2(Sock, File0, Offset, Size) ->
|
|
|
|
File = machi_util:make_binary(File0),
|
|
|
|
PrefixHex = machi_util:int_to_hexbin(Offset, 64),
|
|
|
|
SizeHex = machi_util:int_to_hexbin(Size, 32),
|
|
|
|
CmdLF = [$R, 32, PrefixHex, 32, SizeHex, 32, File, 10],
|
|
|
|
ok = gen_tcp:send(Sock, CmdLF),
|
|
|
|
case gen_tcp:recv(Sock, 3) of
|
|
|
|
{ok, <<"OK\n">>} ->
|
|
|
|
{ok, _Chunk}=Res = gen_tcp:recv(Sock, Size),
|
|
|
|
Res;
|
|
|
|
{ok, Else} ->
|
|
|
|
{ok, OldOpts} = inet:getopts(Sock, [packet]),
|
|
|
|
ok = inet:setopts(Sock, [{packet, line}]),
|
|
|
|
{ok, Else2} = gen_tcp:recv(Sock, 0),
|
|
|
|
ok = inet:setopts(Sock, OldOpts),
|
|
|
|
case Else of
|
|
|
|
<<"ERA">> ->
|
|
|
|
{error, todo_erasure_coded}; %% escript_cc_parse_ec_info(Sock, Line, Else2);
|
|
|
|
<<"ERR">> ->
|
|
|
|
case Else2 of
|
|
|
|
<<"OR BAD-IO\n">> ->
|
|
|
|
{error, no_such_file};
|
|
|
|
<<"OR NOT-ERASURE\n">> ->
|
|
|
|
{error, no_such_file};
|
|
|
|
<<"OR BAD-ARG\n">> ->
|
|
|
|
{error, bad_arg};
|
|
|
|
<<"OR PARTIAL-READ\n">> ->
|
|
|
|
{error, partial_read};
|
|
|
|
_ ->
|
|
|
|
{error, Else2}
|
|
|
|
end;
|
|
|
|
_ ->
|
|
|
|
{error, {whaaa, <<Else/binary, Else2/binary>>}}
|
|
|
|
end
|
|
|
|
end.
|
|
|
|
|
|
|
|
list2(Sock) ->
|
|
|
|
try
|
|
|
|
ok = gen_tcp:send(Sock, <<"L\n">>),
|
|
|
|
ok = inet:setopts(Sock, [{packet, line}]),
|
|
|
|
{ok, <<"OK\n">>} = gen_tcp:recv(Sock, 0),
|
|
|
|
Res = list2(gen_tcp:recv(Sock, 0), Sock),
|
|
|
|
ok = inet:setopts(Sock, [{packet, raw}]),
|
|
|
|
{ok, Res}
|
|
|
|
catch
|
|
|
|
throw:Error ->
|
|
|
|
Error;
|
|
|
|
error:{badmatch,_}=BadMatch ->
|
|
|
|
{error, {badmatch, BadMatch}}
|
|
|
|
end.
|
|
|
|
|
|
|
|
list2({ok, <<".\n">>}, _Sock) ->
|
|
|
|
[];
|
|
|
|
list2({ok, Line}, Sock) ->
|
2015-04-01 08:59:40 +00:00
|
|
|
FileLen = byte_size(Line) - 16 - 1 - 1,
|
|
|
|
<<SizeHex:16/binary, " ", File:FileLen/binary, _/binary>> = Line,
|
|
|
|
Size = machi_util:hexstr_to_int(SizeHex),
|
|
|
|
[{Size, File}|list2(gen_tcp:recv(Sock, 0), Sock)];
|
2015-03-31 07:46:03 +00:00
|
|
|
list2(Else, _Sock) ->
|
|
|
|
throw({server_protocol_error, Else}).
|
|
|
|
|
|
|
|
checksum_list2(Sock, File) ->
|
|
|
|
try
|
|
|
|
ok = gen_tcp:send(Sock, [<<"C ">>, File, <<"\n">>]),
|
|
|
|
ok = inet:setopts(Sock, [{packet, line}]),
|
|
|
|
case gen_tcp:recv(Sock, 0) of
|
|
|
|
{ok, <<"OK ", Rest/binary>> = Line} ->
|
|
|
|
put(status, ok), % may be unset later
|
|
|
|
RestLen = byte_size(Rest) - 1,
|
|
|
|
<<LenHex:RestLen/binary, _:1/binary>> = Rest,
|
|
|
|
<<Len:64/big>> = machi_util:hexstr_to_bin(LenHex),
|
|
|
|
ok = inet:setopts(Sock, [{packet, raw}]),
|
2015-04-01 08:59:40 +00:00
|
|
|
{ok, checksum_list_finish(checksum_list_fast(Sock, Len))};
|
2015-03-31 07:46:03 +00:00
|
|
|
{ok, <<"ERROR NO-SUCH-FILE", _/binary>>} ->
|
|
|
|
{error, no_such_file};
|
|
|
|
{ok, <<"ERROR BAD-ARG", _/binary>>} ->
|
|
|
|
{error, bad_arg};
|
|
|
|
{ok, Else} ->
|
|
|
|
throw({server_protocol_error, Else})
|
|
|
|
end
|
|
|
|
catch
|
|
|
|
throw:Error ->
|
|
|
|
Error;
|
|
|
|
error:{badmatch,_}=BadMatch ->
|
|
|
|
{error, {badmatch, BadMatch}}
|
|
|
|
end.
|
|
|
|
|
|
|
|
checksum_list_fast(Sock, 0) ->
|
|
|
|
{ok, <<".\n">> = _Line} = gen_tcp:recv(Sock, 2),
|
|
|
|
[];
|
|
|
|
checksum_list_fast(Sock, Remaining) ->
|
|
|
|
Num = erlang:min(Remaining, 1024*1024),
|
|
|
|
{ok, Bytes} = gen_tcp:recv(Sock, Num),
|
|
|
|
[Bytes|checksum_list_fast(Sock, Remaining - byte_size(Bytes))].
|
|
|
|
|
2015-04-01 08:59:40 +00:00
|
|
|
checksum_list_finish(Chunks) ->
|
|
|
|
Bin = case Chunks of
|
|
|
|
[X] ->
|
|
|
|
X;
|
|
|
|
_ ->
|
|
|
|
iolist_to_binary(Chunks)
|
|
|
|
end,
|
|
|
|
[begin
|
|
|
|
CSumLen = byte_size(Line) - 16 - 1 - 8 - 1,
|
|
|
|
<<OffsetHex:16/binary, " ", SizeHex:8/binary, " ",
|
|
|
|
CSum:CSumLen/binary>> = Line,
|
|
|
|
{machi_util:hexstr_to_int(OffsetHex),
|
|
|
|
machi_util:hexstr_to_int(SizeHex),
|
|
|
|
machi_util:hexstr_to_bin(CSum)}
|
|
|
|
end || Line <- re:split(Bin, "\n", [{return, binary}]),
|
|
|
|
Line /= <<>>].
|
2015-03-31 07:46:03 +00:00
|
|
|
|
|
|
|
write_chunk2(Sock, File0, Offset, Chunk0) ->
|
|
|
|
try
|
|
|
|
%% TODO: add client-side checksum to the server's protocol
|
|
|
|
%% _ = crypto:hash(md5, Chunk),
|
|
|
|
File = machi_util:make_binary(File0),
|
|
|
|
true = (Offset >= ?MINIMUM_OFFSET),
|
|
|
|
OffsetHex = machi_util:int_to_hexbin(Offset, 64),
|
|
|
|
Chunk = machi_util:make_binary(Chunk0),
|
|
|
|
Len = iolist_size(Chunk0),
|
|
|
|
true = (Len =< ?MAX_CHUNK_SIZE),
|
|
|
|
LenHex = machi_util:int_to_hexbin(Len, 32),
|
|
|
|
Cmd = <<"W-repl ", OffsetHex/binary, " ",
|
|
|
|
LenHex/binary, " ", File/binary, "\n">>,
|
|
|
|
|
|
|
|
ok = gen_tcp:send(Sock, [Cmd, Chunk]),
|
|
|
|
{ok, Line} = gen_tcp:recv(Sock, 0),
|
|
|
|
PathLen = byte_size(Line) - 3 - 16 - 1 - 1,
|
|
|
|
case Line of
|
|
|
|
<<"OK\n">> ->
|
|
|
|
ok;
|
|
|
|
<<"ERROR BAD-ARG", _/binary>> ->
|
|
|
|
{error, bad_arg};
|
|
|
|
<<"ERROR ", _/binary>>=Else ->
|
|
|
|
{error, {server_said, Else}}
|
|
|
|
end
|
|
|
|
catch
|
|
|
|
throw:Error ->
|
|
|
|
Error;
|
|
|
|
error:{badmatch,_}=BadMatch ->
|
|
|
|
{error, {badmatch, BadMatch, erlang:get_stacktrace()}}
|
|
|
|
end.
|
|
|
|
|
|
|
|
delete_migration2(Sock, File) ->
|
|
|
|
try
|
|
|
|
ok = gen_tcp:send(Sock, [<<"DEL-migration ">>, File, <<"\n">>]),
|
|
|
|
ok = inet:setopts(Sock, [{packet, line}]),
|
|
|
|
case gen_tcp:recv(Sock, 0) of
|
|
|
|
{ok, <<"OK\n">>} ->
|
|
|
|
ok;
|
|
|
|
{ok, <<"ERROR NO-SUCH-FILE", _/binary>>} ->
|
|
|
|
{error, no_such_file};
|
|
|
|
{ok, <<"ERROR BAD-ARG", _/binary>>} ->
|
|
|
|
{error, bad_arg};
|
|
|
|
{ok, Else} ->
|
|
|
|
throw({server_protocol_error, Else})
|
|
|
|
end
|
|
|
|
catch
|
|
|
|
throw:Error ->
|
|
|
|
Error;
|
|
|
|
error:{badmatch,_}=BadMatch ->
|
|
|
|
{error, {badmatch, BadMatch}}
|
|
|
|
end.
|
|
|
|
|
|
|
|
trunc_hack2(Sock, File) ->
|
|
|
|
try
|
|
|
|
ok = gen_tcp:send(Sock, [<<"TRUNC-hack--- ">>, File, <<"\n">>]),
|
|
|
|
ok = inet:setopts(Sock, [{packet, line}]),
|
|
|
|
case gen_tcp:recv(Sock, 0) of
|
|
|
|
{ok, <<"OK\n">>} ->
|
|
|
|
ok;
|
|
|
|
{ok, <<"ERROR NO-SUCH-FILE", _/binary>>} ->
|
|
|
|
{error, no_such_file};
|
|
|
|
{ok, <<"ERROR BAD-ARG", _/binary>>} ->
|
|
|
|
{error, bad_arg};
|
|
|
|
{ok, Else} ->
|
|
|
|
throw({server_protocol_error, Else})
|
|
|
|
end
|
|
|
|
catch
|
|
|
|
throw:Error ->
|
|
|
|
Error;
|
|
|
|
error:{badmatch,_}=BadMatch ->
|
|
|
|
{error, {badmatch, BadMatch}}
|
|
|
|
end.
|