diff options
Diffstat (limited to 'lib/cosFileTransfer/src/cosFileTransferNATIVE_file.erl')
| -rw-r--r-- | lib/cosFileTransfer/src/cosFileTransferNATIVE_file.erl | 358 |
1 files changed, 358 insertions, 0 deletions
diff --git a/lib/cosFileTransfer/src/cosFileTransferNATIVE_file.erl b/lib/cosFileTransfer/src/cosFileTransferNATIVE_file.erl new file mode 100644 index 0000000000..634dfd4b8a --- /dev/null +++ b/lib/cosFileTransfer/src/cosFileTransferNATIVE_file.erl @@ -0,0 +1,358 @@ +%%---------------------------------------------------------------------- +%% +%% %CopyrightBegin% +%% +%% Copyright Ericsson AB 2000-2009. All Rights Reserved. +%% +%% The contents of this file are subject to the Erlang Public License, +%% Version 1.1, (the "License"); you may not use this file except in +%% compliance with the License. You should have received a copy of the +%% Erlang Public License along with this software. If not, it can be +%% retrieved online at http://www.erlang.org/. +%% +%% Software distributed under the License is distributed on an "AS IS" +%% basis, WITHOUT WARRANTY OF ANY KIND, either express or implied. See +%% the License for the specific language governing rights and limitations +%% under the License. +%% +%% %CopyrightEnd% +%% +%% +%%---------------------------------------------------------------------- +%% File : cosFileTransferNATIVE_file.erl +%% Description : +%% +%% Created : 9 Nov 2000 +%%---------------------------------------------------------------------- +-module('cosFileTransferNATIVE_file'). + + +%%---------------------------------------------------------------------- +%% Include files +%%---------------------------------------------------------------------- +-include("cosFileTransferApp.hrl"). +-include_lib("kernel/include/file.hrl"). + +%%---------------------------------------------------------------------- +%% External exports +%%---------------------------------------------------------------------- +-export([open/1, + open/2, + open/3, + user/3, + pwd/1, + cd/2, + mkdir/2, + rmdir/2, + nlist/1, + nlist/2, + delete/2, + recv/2, + recv/3, + send/2, + send/3, + close/1, + insert/4]). + +%%---------------------------------------------------------------------- +%% Internal exports +%%---------------------------------------------------------------------- +-export([]). + +%%---------------------------------------------------------------------- +%% Records +%%---------------------------------------------------------------------- + +%%---------------------------------------------------------------------- +%% Macros +%%---------------------------------------------------------------------- + +%%====================================================================== +%% External functions +%%====================================================================== +%%---------------------------------------------------------------------- +%% function : open +%% Arguments: +%% Returns : {ok, Ref} | {error, ehost} for future use +%% Effect : +%%---------------------------------------------------------------------- +open(_Host) -> + {ok, 'NATIVE'}. +open(_Host, _Port) -> + {ok, 'NATIVE'}. +open(_Host, _Port, _Flags) -> + {ok, 'NATIVE'}. + +%%---------------------------------------------------------------------- +%% function : user +%% Arguments: Ref - what's returned by open/1/2 +%% User = Password = string() +%% Returns : ok | {error, euser | econn} for future use +%% Effect : +%%---------------------------------------------------------------------- +user(_Ref, _User, _Password) -> + ok. + +%%---------------------------------------------------------------------- +%% function : pwd +%% Arguments: Ref - what's returned by open/1/2 +%% Returns : {ok, string()} | {error, elogin | econn} +%% Effect : +%%---------------------------------------------------------------------- +pwd(_Ref) -> + case file:get_cwd() of + {ok, Cwd} -> + {ok, Cwd}; + _ -> + {error, econn} + end. + +%%---------------------------------------------------------------------- +%% function : cd +%% Arguments: Ref - what's returned by open/1/2 +%% Dir - string() +%% Returns : ok | {error, epath | elogin | econn} +%% Effect : +%%---------------------------------------------------------------------- +cd(_Ref, Dir) -> + case file:set_cwd(Dir) of + ok -> + ok; + {error, _} -> + {error, epath} + end. + +%%---------------------------------------------------------------------- +%% function : mkdir +%% Arguments: Ref - what's returned by open/1/2 +%% Dir - string() +%% Returns : ok | {error, epath} +%% Effect : +%%---------------------------------------------------------------------- +mkdir(_Ref, Dir) -> + case file:make_dir(Dir) of + ok -> + ok; + {error, _Reason} -> + {error, epath} + end. + +%%---------------------------------------------------------------------- +%% function : rmdir +%% Arguments: Ref - what's returned by open/1/2 +%% Dir - string() +%% Returns : ok | {error, epath} +%% Effect : +%%---------------------------------------------------------------------- +rmdir(_Ref, Dir) -> + case file:del_dir(Dir) of + ok -> + ok; + {error, _Reason} -> + {error, epath} + end. + +%%---------------------------------------------------------------------- +%% function : nlist +%% Arguments: Ref - what's returned by open/1/2 +%% Dir - string() +%% Returns : {ok, Listing} | {error, epath | elogin | econn} +%% Effect : +%%---------------------------------------------------------------------- +nlist(_Ref) -> + case file:get_cwd() of + {ok, Cwd} -> + %% Here we can assume that it's a Directory is tested. + convert_to_nlist(file:list_dir(Cwd)); + _ -> + {error, epath} + end. +nlist(_Ref, Dir) -> + case file:list_dir(Dir) of + {error, _} -> + %% Might be a File + case file:read_file_info(Dir) of + {ok, _} -> + convert_to_nlist_helper([Dir], []); + _ -> + {error, epath} + end; + {ok, Content} -> + convert_to_nlist_helper(Content, []) + end. + +convert_to_nlist({error, _}) -> + {error, epath}; +convert_to_nlist({ok, Content}) -> + convert_to_nlist_helper(Content, []). + +convert_to_nlist_helper([], Acc) -> + {ok, lists:concat(Acc)}; +convert_to_nlist_helper([H|T], Acc) -> + convert_to_nlist_helper(T, [H, "\r\n"|Acc]). + +%%---------------------------------------------------------------------- +%% function : delete +%% Arguments: Ref - what's returned by open/1/2 +%% File - string() +%% Returns : ok | {error, epath} +%% Effect : +%%---------------------------------------------------------------------- +delete(_Ref, File) -> + case file:delete(File) of + ok -> + ok; + {error, _Reason} -> + {error, epath} + end. + +%%---------------------------------------------------------------------- +%% function : recv +%% Arguments: Ref - what's returned by open/1/2 +%% Returns : ok | {error, epath | elogin | econn} +%% Effect : +%%---------------------------------------------------------------------- +recv(_Ref, _Remote) -> + ok. +recv(_Ref, Remote, Local) -> + copy_file(Remote, Local). + +%%---------------------------------------------------------------------- +%% function : send +%% Arguments: Ref - what's returned by open/1/2 +%% Returns : ok | {error, epath | elogin | econn | etnospc | epnospc | efnamena} +%% Effect : +%%---------------------------------------------------------------------- +send(_Ref, _Local) -> + ok. +send(_Ref, Local, Remote) -> + copy_file(Local, Remote). + +%%---------------------------------------------------------------------- +%% function : close +%% Arguments: Ref - what's returned by open/1/2 +%% Returns : ok +%% Effect : Currently none. +%%---------------------------------------------------------------------- +close(_) -> + ok. + + +%%---------------------------------------------------------------------- +%% function : insert +%% Arguments: Ref - what's returned by open/1/2 +%% Local - absolute file name +%% Remote - absolute file name +%% Offset - long() +%% Returns : ok +%% Effect : +%%---------------------------------------------------------------------- +insert(_Ref, Source, Target, Offset) -> + case file:open(Source, [raw, binary, read]) of + {ok, SourceDev} -> + case file:open(Target, [raw, binary, read, write]) of + {ok, TargetDev} -> + {ok, #file_info{size=SSize}} = + file:read_file_info(Source), + {ok, #file_info{size=TSize}} = + file:read_file_info(Target), + insert_file_helper(SourceDev, TargetDev, SSize, TSize, Offset); + Reason -> + file:close(SourceDev), + convert_error(Reason) + end; + Reason -> + convert_error(Reason) + end. + + +insert_file_helper(SourceDev, TargetDev, SSize, TSize, Offset) -> + BuffSize = cosFileTransferApp:get_buffert_size(), + move_data(TargetDev, TSize, SSize+TSize, TSize-Offset, BuffSize), + insert_data(SourceDev, TargetDev, 0, Offset, BuffSize), + file:close(SourceDev), + file:close(TargetDev). +move_data(_F, _RLocation, _WLocation, Counter, _BuffSize) when Counter == 0 -> + ok; +move_data(F, RLocation, WLocation, Counter, BuffSize) when Counter =< BuffSize -> + case file:pread(F, RLocation-Counter, Counter) of + {ok, Bin} -> + file:pwrite(F, WLocation-Counter, Bin); + eof -> + ok + end; +move_data(F, RLocation, WLocation, Counter, BuffSize) -> + NewRLC = RLocation-BuffSize, + NewWLC = WLocation-BuffSize, + case file:pread(F, NewRLC, BuffSize) of + {ok, Bin} -> + file:pwrite(F, NewWLC, Bin), + move_data(F, NewRLC, NewWLC, Counter-BuffSize, BuffSize); + eof -> + ok + end. + +insert_data(FSRC, FTGT, RLocation, WLocation, BuffSize) -> + case file:pread(FSRC, RLocation, BuffSize) of + {ok, Bin} -> + file:pwrite(FTGT, WLocation, Bin), + insert_data(FSRC, FTGT, RLocation+BuffSize, WLocation+BuffSize, BuffSize); + eof -> + ok + end. + + +%%====================================================================== +%% Internal functions +%%====================================================================== +copy_file(Source, Target) -> + case file:open(Source, [raw, binary, read]) of + {ok, SourceDev} -> + case file:open(Target, [raw, binary, append]) of + {ok, TargetDev} -> + BuffSize = cosFileTransferApp:get_buffert_size(), + copy_file_helper(SourceDev, TargetDev, BuffSize); + Reason -> + file:close(SourceDev), + convert_error(Reason) + end; + Reason -> + convert_error(Reason) + end. + +copy_file_helper(SourceDev, TargetDev, BuffSize) -> + case file:read(SourceDev, BuffSize) of + eof -> + file:close(SourceDev), + file:close(TargetDev); + {ok, Bin} -> + case file:write(TargetDev, Bin) of + ok -> + copy_file_helper(SourceDev, TargetDev, BuffSize); + Reason -> + file:close(SourceDev), + file:close(TargetDev), + convert_error(Reason) + end; + {error, Reason} -> + file:close(SourceDev), + file:close(TargetDev), + convert_error(Reason) + end. + +convert_error({error, eacces}) -> + {error, elogin}; +convert_error({error, enoent}) -> + {error, epath}; +convert_error({error, enotdir}) -> + {error, epath}; +convert_error({error, eidir}) -> + {error, epath}; +convert_error({error, enospc}) -> + {error, etnospc}; +convert_error(_) -> + {error, epath}. + +%%====================================================================== +%% END OF MODULE +%%====================================================================== |