/foundation/communication/bluetooth_service/services/bluetooth/service/src/obex/ |
H A D | obex_headers.cpp | 40 const uint8_t ObexHeader::MIN_PACKET_LENGTH; 41 const uint8_t ObexHeader::TARGET_LENGTH; 42 const uint8_t ObexHeader::U16STRING_NULL_LENGTH; 43 const uint8_t ObexHeader::U16STRING_LENGTH; 44 const uint8_t ObexHeader::UINT16_LENGTH; 45 const uint8_t ObexHeader::UINT32_LENGTH; 46 const uint8_t ObexHeader::UINT64_LENGTH; 47 const uint8_t ObexHeader::HDR_UNICODE_PREFIX_LENGTH; 48 const uint8_t ObexHeader::HDR_BYTES_PREFIX_LENGTH; 50 const std::unordered_map<uint8_t, std::string> ObexHeader 80 ObexHeader::ObexHeader() ObexHeader() function in OHOS::bluetooth::ObexHeader 236 ObexHeader::ObexHeader(const ObexHeader &header, bool fieldOnly) ObexHeader() function in OHOS::bluetooth::ObexHeader [all...] |
H A D | obex_session.cpp | 47 return SendResponse(*ObexHeader::CreateResponse(rspCode)); in SendSimpleResponse() 50 int ObexServerSession::SendResponse(ObexHeader &resp) const in SendResponse() 73 int ObexServerSession::SendGetResponse(const ObexHeader &req, ObexHeader &resp, std::shared_ptr<ObexBodyObject> reader) in SendGetResponse() 79 if (resp.HasHeader(ObexHeader::BODY) || resp.HasHeader(ObexHeader::END_OF_BODY)) { in SendGetResponse() 139 nextReqHdr = ObexHeader::CreateResponse(ObexRspCode::INTERNAL_SERVER_ERROR); in ProcessSendSrmResponse() 206 const ObexHeader &firstReq, std::shared_ptr<ObexBodyObject> bodyReader, uint16_t mtu) in ObexClientSendObject() 208 firstReq_(std::make_unique<ObexHeader>(firstReq)), in ObexClientSendObject() 212 bool ObexClientSendObject::SetBodyToHeader(ObexHeader [all...] |
H A D | obex_client.h | 81 virtual void OnConnected(ObexClient &client, const ObexHeader &resp) = 0; 88 virtual void OnConnectFailed(ObexClient &client, const ObexHeader &resp) = 0; 101 virtual void OnActionCompleted(ObexClient &client, const ObexHeader &resp) = 0; 129 int SendRequest(const ObexHeader &req); 163 int Put(const ObexHeader &req); 171 int Get(const ObexHeader &req); 280 std::unique_ptr<bluetooth::ObexHeader> GetObexHeaderFromPacket(ObexPacket &obexPacket); 281 void HandleDataAvailableConnect(const ObexHeader &resp); 282 void HandleDataAvailableDisconnect(const ObexHeader &resp); 283 void HandleDataAvailablePut(const ObexHeader [all...] |
H A D | obex_mp_client.h | 31 int Put(const ObexHeader &req); 40 int Put(const ObexHeader &req, std::shared_ptr<ObexBodyObject> reader); 47 int Get(const ObexHeader &req); 56 int Get(const ObexHeader &req, std::shared_ptr<ObexBodyObject> writer, int srmpCount = 0); 78 void PutDataAvailable(const ObexHeader &resp) override; 79 void GetDataAvailable(const ObexHeader &resp) override; 80 void SetPathDataAvailable(const ObexHeader &resp) override; 81 void AbortDataAvailable(const ObexHeader &resp) override; 84 void ProcessGetContinueData(const ObexHeader &resp); 85 void ProcessGetSuccessData(const ObexHeader [all...] |
H A D | obex_session.h | 155 ObexClientSendObject(const ObexHeader &firstReq, std::shared_ptr<ObexBodyObject> bodyReader, uint16_t mtu); 157 std::unique_ptr<ObexHeader> GetNextReqHeader(bool useSrm = false); 169 bool SetBodyToHeader(ObexHeader &header, const uint16_t &remainLength); 177 std::unique_ptr<ObexHeader> firstReq_ = nullptr; 184 const ObexHeader &firstReq, std::shared_ptr<ObexBodyObject> writer, bool supportSrm, int srmpCount); 186 ObexHeader &GetFirstReqHeader() const; 187 std::unique_ptr<ObexHeader> GetContinueReqHeader(); 189 const ObexHeader *GetFirstRespHeader() const; 190 void CacheResp(const ObexHeader &resp); 209 std::unique_ptr<ObexHeader> firstReq [all...] |
H A D | obex_server.h | 55 virtual void OnConnect(ObexServerSession &session, const ObexHeader &req) = 0; 56 virtual void OnDisconnect(ObexServerSession &session, const ObexHeader &req) = 0; 57 virtual void OnPut(ObexServerSession &session, const ObexHeader &req); 58 virtual void OnGet(ObexServerSession &session, const ObexHeader &req); 59 virtual void OnAbort(ObexServerSession &session, const ObexHeader &req); 60 virtual void OnSetPath(ObexServerSession &session, const ObexHeader &req); 61 virtual void OnAction(ObexServerSession &session, const ObexHeader &req); 62 virtual void OnSession(ObexServerSession &session, const ObexHeader &req); 100 void HandleDataAvailableConnect(ObexServerSession &serverSession, const ObexHeader &req); 102 std::unique_ptr<bluetooth::ObexHeader> GetObexHeaderFromPacke [all...] |
H A D | obex_mp_client.cpp | 25 int ObexMpClient::Put(const ObexHeader &req) in Put() 30 int ObexMpClient::Put(const ObexHeader &req, std::shared_ptr<ObexBodyObject> reader) in Put() 41 if (req.HasHeader(ObexHeader::BODY) || req.HasHeader(ObexHeader::END_OF_BODY)) { in Put() 64 int ObexMpClient::Get(const ObexHeader &req) in Get() 69 int ObexMpClient::Get(const ObexHeader &req, std::shared_ptr<ObexBodyObject> writer, int srmpCount) in Get() 113 void ObexMpClient::PutDataAvailable(const ObexHeader &resp) in PutDataAvailable() 131 void ObexMpClient::HandlePutData(const ObexHeader &resp) in HandlePutData() 136 if (resp.HasHeader(ObexHeader::SRM)) { in HandlePutData() 141 if (resp.HasHeader(ObexHeader in HandlePutData() [all...] |
H A D | obex_client.cpp | 108 void ObexClient::ObexClientTransportObserver::HandleDataAvailableAction(const ObexHeader &resp) in HandleDataAvailableAction() 113 void ObexClient::ObexClientTransportObserver::HandleDataAvailableAbort(const ObexHeader &resp) in HandleDataAvailableAbort() 123 void ObexClient::ObexClientTransportObserver::HandleDataAvailableSession(const ObexHeader &resp) in HandleDataAvailableSession() 141 void ObexClient::ObexClientTransportObserver::HandleDataAvailableSetPath(const ObexHeader &resp) in HandleDataAvailableSetPath() 146 void ObexClient::ObexClientTransportObserver::HandleDataAvailablePut(const ObexHeader &resp) in HandleDataAvailablePut() 151 void ObexClient::ObexClientTransportObserver::HandleDataAvailableGet(const ObexHeader &resp) in HandleDataAvailableGet() 156 void ObexClient::ObexClientTransportObserver::HandleDataAvailableDisconnect(const ObexHeader &resp) in HandleDataAvailableDisconnect() 165 void ObexClient::ObexClientTransportObserver::HandleDataAvailableConnect(const ObexHeader &resp) in HandleDataAvailableConnect() 194 std::unique_ptr<bluetooth::ObexHeader> ObexClient::ObexClientTransportObserver::GetObexHeaderFromPacket( in GetObexHeaderFromPacket() 199 if (packetBufSize < ObexHeader in GetObexHeaderFromPacket() [all...] |
H A D | obex_mp_server.h | 30 void HandlePutRequest(ObexServerSession &session, ObexHeader &req) const override; 31 void HandleGetRequest(ObexServerSession &session, ObexHeader &req) override; 32 void HandleAbortRequest(ObexServerSession &session, ObexHeader &req) override; 35 void HandlePutFinalRequest(ObexServerSession &session, ObexHeader &req) const;
|
H A D | obex_server.cpp | 116 void ObexServerObserver::OnPut(ObexServerSession &session, const ObexHeader &req) in OnPut() 119 session.SendResponse(*ObexHeader::CreateResponse(ObexRspCode::NOT_IMPLEMENTED, false)); in OnPut() 122 void ObexServerObserver::OnGet(ObexServerSession &session, const ObexHeader &req) in OnGet() 125 session.SendResponse(*ObexHeader::CreateResponse(ObexRspCode::NOT_IMPLEMENTED, false)); in OnGet() 128 void ObexServerObserver::OnAbort(ObexServerSession &session, const ObexHeader &req) in OnAbort() 131 session.SendResponse(*ObexHeader::CreateResponse(ObexRspCode::NOT_IMPLEMENTED, false)); in OnAbort() 134 void ObexServerObserver::OnSetPath(ObexServerSession &session, const ObexHeader &req) in OnSetPath() 137 session.SendResponse(*ObexHeader::CreateResponse(ObexRspCode::NOT_IMPLEMENTED, false)); in OnSetPath() 140 void ObexServerObserver::OnAction(ObexServerSession &session, const ObexHeader &req) in OnAction() 143 session.SendResponse(*ObexHeader in OnAction() [all...] |
H A D | obex_mp_server.cpp | 53 void ObexPrivateMpServer::HandlePutRequest(ObexServerSession &session, ObexHeader &req) const in HandlePutRequest() 72 auto respHeader = ObexHeader::CreateResponse(ObexRspCode::CONTINUE); in HandlePutRequest() 102 void ObexPrivateMpServer::HandlePutFinalRequest(ObexServerSession &session, ObexHeader &req) const in HandlePutFinalRequest() 124 req.RemoveItem(ObexHeader::END_OF_BODY); in HandlePutFinalRequest() 148 void ObexPrivateMpServer::HandleGetRequest(ObexServerSession &session, ObexHeader &req) in HandleGetRequest() 185 nextReqHdr = ObexHeader::CreateResponse(ObexRspCode::INTERNAL_SERVER_ERROR); in HandleGetRequest() 200 void ObexPrivateMpServer::HandleAbortRequest(ObexServerSession &session, ObexHeader &req) in HandleAbortRequest() 205 auto header = ObexHeader::CreateResponse(ObexRspCode::SUCCESS); in HandleAbortRequest()
|
H A D | obex_headers.h | 324 class ObexHeader { class in OHOS::bluetooth::ObexActionType::ObexSessionParameters::ObexHeaderDataType 395 * @return std::unique_ptr<ObexHeader> 397 static std::unique_ptr<ObexHeader> CreateRequest(ObexOpeId opcode); 404 * @return std::unique_ptr<ObexHeader> 406 static std::unique_ptr<ObexHeader> CreateResponse(ObexRspCode rspCode, bool isConnectResp = false); 407 static std::unique_ptr<ObexHeader> ParseRequest(const uint8_t *buf, const uint16_t size); 408 static std::unique_ptr<ObexHeader> ParseResponse(const uint8_t *buf, const uint16_t size, bool isConnect); 411 ObexHeader(); 412 ObexHeader(const ObexHeader [all...] |
H A D | obex_utils.h | 40 static void ObexHeaderDebug(const ObexHeader &header);
|
H A D | obex_utils.cpp | 178 void ObexUtils::ObexHeaderDebug(const ObexHeader &header) in ObexHeaderDebug() 180 OBEX_LOG_INFO("----------ObexHeader Debug Start----------"); in ObexHeaderDebug() 211 OBEX_LOG_INFO("----------ObexHeader Debug End----------"); in ObexHeaderDebug()
|