Home
last modified time | relevance | path

Searched refs:SoftBusClient (Results 1 – 4 of 4) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/communicator/src/
H A Dsoftbus_client.cpp31 SoftBusClient::SoftBusClient(const PipeInfo& pipeInfo, const DeviceId& deviceId, uint32_t type) in SoftBusClient() function in OHOS::AppDistributedKv::SoftBusClient
37 SoftBusClient::~SoftBusClient() in ~SoftBusClient()
55 uint32_t SoftBusClient::GetMtuSize() const in GetMtuSize()
61 uint32_t SoftBusClient::GetTimeout() const in GetTimeout()
86 int32_t SoftBusClient::GetSoftBusError() in GetSoftBusError()
133 Status SoftBusClient::CheckStatus() in CheckStatus()
179 SoftBusClient::Time SoftBusClient::GetExpireTime() const in GetExpireTime()
185 int32_t SoftBusClient::GetSocket() const in GetSocket()
190 void SoftBusClient::UpdateExpireTime() in UpdateExpireTime()
206 uint32_t SoftBusClient::GetQoSType() const in GetQoSType()
[all …]
H A Dsoftbus_client.h29 class SoftBusClient : public std::enable_shared_from_this<SoftBusClient> {
36 SoftBusClient(const PipeInfo &pipeInfo, const DeviceId &deviceId, uint32_t type = QOS_HML);
37 ~SoftBusClient();
H A Dsoftbus_adapter_standard.cpp171 void SoftBusAdapter::GetExpireTime(std::shared_ptr<SoftBusClient> &conn) in GetExpireTime()
185 std::shared_ptr<SoftBusClient> conn; in SendData()
187 uint32_t qosType = isOHOSType ? SoftBusClient::QOS_HML : SoftBusClient::QOS_BR; in SendData()
189 std::vector<std::shared_ptr<SoftBusClient>> &connects) -> bool { in SendData()
196 auto connect = std::make_shared<SoftBusClient>(pipeInfo, deviceId, qosType); in SendData()
219 std::pair<Status, int32_t> SoftBusAdapter::OpenConnect(const std::shared_ptr<SoftBusClient> &conn, in OpenConnect()
222 auto task = [this, connect = std::weak_ptr<SoftBusClient>(conn)]() { in OpenConnect()
235 std::shared_ptr<SoftBusClient> conn; in StartCloseSessionTask()
237 uint32_t qosType = isOHOSType ? SoftBusClient::QOS_HML : SoftBusClient::QOS_BR; in StartCloseSessionTask()
265 std::vector<std::shared_ptr<SoftBusClient>> connToClose; in GetCloseSessionTask()
[all …]
H A Dsoftbus_adapter.h95 void GetExpireTime(std::shared_ptr<SoftBusClient> &conn);
96 …std::pair<Status, int32_t> OpenConnect(const std::shared_ptr<SoftBusClient> &conn, const DeviceId …
104 ConcurrentMap<std::string, std::vector<std::shared_ptr<SoftBusClient>>> connects_;