| /foundation/distributeddatamgr/relational_store/frameworks/native/rdb/src/ |
| H A D | connection.cpp | 21 static Connection::Creator g_creators[DB_BUTT] = { nullptr, nullptr };
22 static Connection::Repairer g_repairers[DB_BUTT] = { nullptr, nullptr };
23 static Connection::Deleter g_fileDeleter[DB_BUTT] = { nullptr, nullptr };
24 static Connection::Collector g_collectors[DB_BUTT] = { nullptr, nullptr };
25 std::pair<int, std::shared_ptr<Connection>> Connection::Create(const RdbStoreConfig &config, bool isWriter) in Create()
40 int32_t Connection::Repair(const RdbStoreConfig &config) in Repair()
55 int32_t Connection::Delete(const RdbStoreConfig &config) in Delete()
69 std::map<std::string, Connection::Info> Connection
[all...] |
| H A D | connection_pool.cpp | 39 using Conn = Connection;
41 using SharedConn = std::shared_ptr<Connection>;
42 using SharedConns = std::vector<std::shared_ptr<Connection>>;
55 std::shared_ptr<Connection> conn; in Create()
71 Reportor::FormatBrief(Connection::Collect(config), SqliteUtils::Anonymous(config.GetName())).c_str()); in Create()
81 errCode = Connection::Repair(storeConfig); in HandleDataCorruption()
85 Connection::Delete(storeConfig); in HandleDataCorruption()
107 std::pair<int32_t, std::shared_ptr<Connection>> ConnPool::Init(bool isAttach, bool needWriter) in Init()
110 std::pair<int32_t, std::shared_ptr<Connection>> result; in Init()
123 return Connection in Init()
[all...] |
| H A D | rd_connection.cpp | 33 const int32_t RdConnection::regCreator_ = Connection::RegisterCreator(DB_VECTOR, RdConnection::Create);
35 const int32_t RdConnection::regRepairer_ = Connection::RegisterRepairer(DB_VECTOR, RdConnection::Repair);
37 const int32_t RdConnection::regDeleter_ = Connection::RegisterDeleter(DB_VECTOR, RdConnection::Delete);
39 std::pair<int32_t, std::shared_ptr<Connection>> RdConnection::Create(const RdbStoreConfig& config, bool isWrite) in Create()
41 std::pair<int32_t, std::shared_ptr<Connection>> result = { E_ERROR, nullptr }; in Create()
180 std::pair<int32_t, RdConnection::Stmt> RdConnection::CreateStatement(const std::string& sql, Connection::SConn conn) in CreateStatement()
256 int32_t RdConnection::SubscribeTableChanges(const Connection::Notifier& notifier) in SubscribeTableChanges()
|
| H A D | rdb_helper.cpp | 94 int errCodeSqlite = Connection::Delete(config); in DeleteRdbStore()
97 int errCodeVector = Connection::Delete(config); in DeleteRdbStore()
118 Connection::Delete(config); in DeleteRdbStore()
|
| /foundation/distributeddatamgr/relational_store/test/native/rdb/unittest/ |
| H A D | connection_test.cpp | 56 auto [errCode, connection] = Connection::Create(config, true); in HWTEST_F()
61 auto [errCode1, connection1] = Connection::Create(config, true); in HWTEST_F()
75 int ret = Connection::Repair(config); in HWTEST_F()
79 ret = Connection::Repair(config); in HWTEST_F()
|
| /foundation/CastEngine/castengine_cast_plus_stream/src/channel/src/ |
| H A D | channel_manager.cpp | 41 std::shared_ptr<Connection> ChannelManager::GetConnection(ChannelLinkType linkType) in GetConnection()
43 std::shared_ptr<Connection> connection; in GetConnection()
47 CLOGD("GetConnection, Create SoftBus Connection, linkType = %{public}d.", linkType); in GetConnection()
52 CLOGD("GetConnection, Create Tcp Connection, linkType = %{public}d.", linkType); in GetConnection()
81 std::shared_ptr<Connection> connection = GetConnection(request.linkType); in CreateChannel()
86 connectionMap_.insert(std::pair<ChannelRequest, std::shared_ptr<Connection>>(request, connection)); in CreateChannel()
112 std::shared_ptr<Connection> connection = GetConnection(request.linkType); in CreateChannel()
117 connectionMap_.insert(std::pair<ChannelRequest, std::shared_ptr<Connection>>(request, connection)); in CreateChannel()
156 std::shared_ptr<Connection> connection = it->second; in DestroyChannel()
|
| /foundation/CastEngine/castengine_cast_framework/service/src/session/src/channel/src/ |
| H A D | channel_manager.cpp | 41 std::shared_ptr<Connection> ChannelManager::GetConnection(ChannelLinkType linkType) in GetConnection()
43 std::shared_ptr<Connection> connection; in GetConnection()
47 CLOGD("GetConnection, Create SoftBus Connection, linkType = %{public}d.", linkType); in GetConnection()
52 CLOGD("GetConnection, Create Tcp Connection, linkType = %{public}d.", linkType); in GetConnection()
81 std::shared_ptr<Connection> connection = GetConnection(request.linkType); in CreateChannel()
86 connectionMap_.insert(std::pair<ChannelRequest, std::shared_ptr<Connection>>(request, connection)); in CreateChannel()
112 std::shared_ptr<Connection> connection = GetConnection(request.linkType); in CreateChannel()
117 connectionMap_.insert(std::pair<ChannelRequest, std::shared_ptr<Connection>>(request, connection)); in CreateChannel()
156 std::shared_ptr<Connection> connection = it->second; in DestroyChannel()
|
| /foundation/distributeddatamgr/relational_store/frameworks/native/rdb/include/ |
| H A D | connection_pool.h | 38 using SharedConn = std::shared_ptr<Connection>;
45 std::pair<int32_t, std::shared_ptr<Connection>> CreateTransConn(bool limited = true);
75 std::shared_ptr<Connection> connect_;
77 explicit ConnNode(std::shared_ptr<Connection> conn);
78 std::shared_ptr<Connection> GetConnect();
85 using Creator = std::function<std::pair<int32_t, std::shared_ptr<Connection>>()>;
122 std::pair<int32_t, std::shared_ptr<Connection>> Init(bool isAttach = false, bool needWriter = false);
124 std::shared_ptr<Connection> Convert2AutoConn(std::shared_ptr<ConnNode> node, bool isTrans = false);
|
| H A D | connection.h | 31 class Connection { class
34 using SConn = std::shared_ptr<Connection>;
52 virtual ~Connection() = default;
|
| H A D | transaction_impl.h | 29 TransactionImpl(std::shared_ptr<Connection> connection, const std::string &name);
51 int32_t type, std::shared_ptr<Connection> connection, const std::string &name);
63 std::shared_ptr<Connection> connection_;
|
| H A D | sqlite_shared_result_set.h | 38 using Conn = std::shared_ptr<Connection>;
73 std::shared_ptr<Connection> conn_;
|
| H A D | step_result_set.h | 34 using Conn = std::shared_ptr<Connection>;
65 std::shared_ptr<Connection> conn_;
|
| H A D | trans_db.h | 26 TransDB(std::shared_ptr<Connection> conn, const std::string &name);
44 std::weak_ptr<Connection> conn_;
|
| /foundation/communication/netstack/frameworks/js/napi/tls/src/ |
| H A D | tls_socket_server.cpp | 565 void TLSSocketServer::Connection::OnMessage(const OnMessageCallback &onMessageCallback)
in OnMessage()
570 void TLSSocketServer::Connection::OnClose(const OnCloseCallback &onCloseCallback)
in OnClose()
587 void TLSSocketServer::Connection::OffMessage()
in OffMessage()
602 void TLSSocketServer::Connection::OnError(const TlsSocket::OnErrorCallback &onErrorCallback)
in OnError()
607 void TLSSocketServer::Connection::OffClose()
in OffClose()
614 void TLSSocketServer::Connection::OffError()
in OffError()
619 void TLSSocketServer::Connection::CallOnErrorCallback(int32_t err, const std::string &errString)
in CallOnErrorCallback()
706 std::shared_ptr<TLSSocketServer::Connection> TLSSocketServer::GetConnectionByClientID(int clientid)
in GetConnectionByClientID()
708 std::shared_ptr<Connection> ptrConnection = nullptr;
in GetConnectionByClientID()
738 void TLSSocketServer::Connection
[all...] |
| /foundation/communication/netstack/test/unittest/tls_test/server/ |
| H A D | tls_socket_server_branch_test.cpp | 94 std::shared_ptr<TLSSocketServer::Connection> connection = std::make_shared<TLSSocketServer::Connection>(); in HWTEST_F()
132 std::shared_ptr<TLSSocketServer::Connection> connection = std::make_shared<TLSSocketServer::Connection>(); in HWTEST_F()
193 std::shared_ptr<TLSSocketServer::Connection> connection = std::make_shared<TLSSocketServer::Connection>(); in HWTEST_F()
218 std::shared_ptr<TLSSocketServer::Connection> connection = std::make_shared<TLSSocketServer::Connection>(); in HWTEST_F()
259 std::shared_ptr<TLSSocketServer::Connection> connection = std::make_shared<TLSSocketServer::Connection>(); in HWTEST_F()
[all...] |
| /foundation/communication/netstack/test/unittest/tlssocket/server/ |
| H A D | tls_socket_server_branch_test.cpp | 94 std::shared_ptr<TLSSocketServer::Connection> connection = std::make_shared<TLSSocketServer::Connection>(); in HWTEST_F()
132 std::shared_ptr<TLSSocketServer::Connection> connection = std::make_shared<TLSSocketServer::Connection>(); in HWTEST_F()
193 std::shared_ptr<TLSSocketServer::Connection> connection = std::make_shared<TLSSocketServer::Connection>(); in HWTEST_F()
218 std::shared_ptr<TLSSocketServer::Connection> connection = std::make_shared<TLSSocketServer::Connection>(); in HWTEST_F()
259 std::shared_ptr<TLSSocketServer::Connection> connection = std::make_shared<TLSSocketServer::Connection>(); in HWTEST_F()
[all...] |
| /foundation/communication/netstack/interfaces/innerkits/tls_socket/include/ |
| H A D | tls_socket_server.h | 228 class Connection : public std::enable_shared_from_this<Connection> { class in OHOS::NetStack::TlsSocketServer::TLSSocketServer
230 ~Connection();
442 void AddConnect(int socketFd, std::shared_ptr<Connection> connection);
466 std::map<int, std::shared_ptr<Connection>> clientIdConnections_;
482 std::shared_ptr<Connection> GetConnectionByClientID(int clientid);
485 std::shared_ptr<Connection> GetConnectionByClientEventManager(const EventManager *eventManager);
489 int connectFD, std::shared_ptr<Connection> &connection);
|
| /foundation/CastEngine/castengine_cast_plus_stream/src/channel/include/ |
| H A D | connection.h | 28 class Connection { class
30 virtual ~Connection() {}; in ~Connection()
|
| H A D | channel_manager.h | 82 std::shared_ptr<Connection> GetConnection(ChannelLinkType linkType);
88 std::map<ChannelRequest, std::shared_ptr<Connection>> connectionMap_;
|
| /foundation/CastEngine/castengine_cast_framework/service/src/session/src/channel/include/ |
| H A D | connection.h | 28 class Connection { class
30 virtual ~Connection() {}; in ~Connection()
|
| H A D | channel_manager.h | 82 std::shared_ptr<Connection> GetConnection(ChannelLinkType linkType);
88 std::map<ChannelRequest, std::shared_ptr<Connection>> connectionMap_;
|
| /foundation/CastEngine/castengine_cast_framework/service/src/session/src/channel/src/tcp/ |
| H A D | tcp_connection.h | 36 class TcpConnection : public Connection, public Channel, public std::enable_shared_from_this<TcpConnection> {
38 using Connection::channelRequest_;
|
| /foundation/CastEngine/castengine_cast_plus_stream/src/channel/src/tcp/ |
| H A D | tcp_connection.h | 36 class TcpConnection : public Connection, public Channel, public std::enable_shared_from_this<TcpConnection> {
38 using Connection::channelRequest_;
|
| /foundation/distributeddatamgr/relational_store/interfaces/inner_api/rdb/include/ |
| H A D | transaction.h | 34 class Connection;
77 int32_t type, std::shared_ptr<Connection> connection, const std::string&)>;
80 int32_t type, std::shared_ptr<Connection> connection, const std::string &name);
|
| /foundation/distributeddatamgr/relational_store/frameworks/native/dfx/include/ |
| H A D | rdb_fault_hiview_reporter.h | 50 static bool RegCollector(Connection::Collector collector);
65 static Connection::Collector collector_;
|