• Home
  • Line#
  • Scopes#
  • Navigate#
  • Raw
  • Download
1 /*
2  * Copyright (c) 2025 Huawei Device Co., Ltd.
3  * Licensed under the Apache License, Version 2.0 (the "License");
4  * you may not use this file except in compliance with the License.
5  * You may obtain a copy of the License at
6  *
7  * http://www.apache.org/licenses/LICENSE-2.0
8  *
9  * Unless required by applicable law or agreed to in writing, software
10  * distributed under the License is distributed on an "AS IS" BASIS,
11  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12  * See the License for the specific language governing permissions and
13  * limitations under the License.
14  */
15 
16 #include "create_stream_ani.h"
17 
18 #include "create_stream_core.h"
19 #include "error_handler.h"
20 #include "filemgmt_libhilog.h"
21 #include "stream_wrapper.h"
22 #include "type_converter.h"
23 
24 namespace OHOS {
25 namespace FileManagement {
26 namespace ModuleFileIO {
27 namespace ANI {
28 
29 using namespace std;
30 using namespace OHOS::FileManagement::ModuleFileIO;
31 
CreateStreamSync(ani_env * env,ani_class clazz,ani_string path,ani_string mode)32 ani_object CreateStreamAni::CreateStreamSync(
33     ani_env *env, [[maybe_unused]] ani_class clazz, ani_string path, ani_string mode)
34 {
35     auto [succPath, srcPath] = TypeConverter::ToUTF8String(env, path);
36     if (!succPath) {
37         HILOGE("Invalid path");
38         ErrorHandler::Throw(env, EINVAL);
39         return nullptr;
40     }
41 
42     auto [succMode, openMode] = TypeConverter::ToUTF8String(env, mode);
43     if (!succMode) {
44         HILOGE("Invalid mode");
45         ErrorHandler::Throw(env, EINVAL);
46         return nullptr;
47     }
48 
49     FsResult<FsStream *> ret = CreateStreamCore::DoCreateStream(srcPath, openMode);
50     if (!ret.IsSuccess()) {
51         HILOGE("create stream failed");
52         const auto &err = ret.GetError();
53         ErrorHandler::Throw(env, err);
54         return nullptr;
55     }
56 
57     const FsStream *stream = ret.GetData().value();
58     auto result = StreamWrapper::Wrap(env, move(stream));
59     if (result == nullptr) {
60         delete stream;
61         stream = nullptr;
62         HILOGE("Wrap failed");
63         ErrorHandler::Throw(env, UNKNOWN_ERR);
64         return nullptr;
65     }
66     return result;
67 }
68 
69 } // namespace ANI
70 } // namespace ModuleFileIO
71 } // namespace FileManagement
72 } // namespace OHOS