Searched refs:queueData (Results 1 – 6 of 6) sorted by relevance
/ohos5.0/base/security/device_security_level/baselib/msglib/src/utils/ |
H A D | messenger_utils.c | 32 QueueMsgData *queueData = MALLOC(dataLen); in CreateQueueMsgData() local 33 if (queueData == NULL) { in CreateQueueMsgData() 37 …uint32_t ret = (uint32_t)memcpy_s(&queueData->srcIdentity, sizeof(DeviceIdentify), devId, sizeof(D… in CreateQueueMsgData() 40 FREE(queueData); in CreateQueueMsgData() 43 ret = (uint32_t)memcpy_s(queueData->msgData, msgLen, msg, msgLen); in CreateQueueMsgData() 46 FREE(queueData); in CreateQueueMsgData() 49 queueData->msgLen = msgLen; in CreateQueueMsgData() 52 return queueData; in CreateQueueMsgData()
|
/ohos5.0/base/security/device_security_level/baselib/msglib/src/lite/ |
H A D | messenger_device_session_manager.c | 89 QueueMsgData *queueData = (QueueMsgData *)data; in ProcessSessionMessageReceived() local 90 if (queueData->msgLen + sizeof(QueueMsgData) != len) { in ProcessSessionMessageReceived() 101 messageReceiver(&queueData->srcIdentity, queueData->msgData, queueData->msgLen); in ProcessSessionMessageReceived() 102 FREE(queueData); in ProcessSessionMessageReceived() 119 QueueMsgData *queueData = CreateQueueMsgData(devId, msg, msgLen, &queueDataLen); in OnSessionMessageReceived() local 120 if (queueData == NULL) { in OnSessionMessageReceived() 123 …uint32_t ret = QueueWork(queue, ProcessSessionMessageReceived, (uint8_t *)queueData, queueDataLen); in OnSessionMessageReceived() 126 FREE(queueData); in OnSessionMessageReceived()
|
H A D | messenger_device_status_manager.c | 67 QueueStatusData *queueData = (QueueStatusData *)data; in ProcessDeviceStatusReceived() local 79 deviceStatusReceiver(&queueData->srcIdentity, queueData->status, queueData->level); in ProcessDeviceStatusReceived() 80 FREE(queueData); in ProcessDeviceStatusReceived()
|
/ohos5.0/base/security/device_security_level/baselib/msglib/src/standard/ |
H A D | messenger_device_socket_manager.c | 93 QueueMsgData *queueData = (QueueMsgData *)data; in ProcessSocketMessageReceived() local 94 if (queueData->msgLen + sizeof(QueueMsgData) != len) { in ProcessSocketMessageReceived() 96 FREE(queueData); in ProcessSocketMessageReceived() 103 FREE(queueData); in ProcessSocketMessageReceived() 106 messageReceiver(&queueData->srcIdentity, queueData->msgData, queueData->msgLen); in ProcessSocketMessageReceived() 107 FREE(queueData); in ProcessSocketMessageReceived() 128 QueueMsgData *queueData = CreateQueueMsgData(devId, msg, msgLen, &queueDataLen); in OnSocketMessageReceived() local 129 if (queueData == NULL) { in OnSocketMessageReceived() 132 … uint32_t ret = QueueWork(queue, ProcessSocketMessageReceived, (uint8_t *)queueData, queueDataLen); in OnSocketMessageReceived() 135 FREE(queueData); in OnSocketMessageReceived()
|
H A D | messenger_device_status_manager.cpp | 169 auto *queueData = static_cast<const QueueStatusData *>(static_cast<const void *>(data)); in ProcessDeviceStatusReceiver() local 179 processor(&queueData->srcIdentity, queueData->status, queueData->level); in ProcessDeviceStatusReceiver() 180 delete queueData; in ProcessDeviceStatusReceiver()
|
/ohos5.0/foundation/communication/nfc/services/src/card_emulation/ |
H A D | host_card_emulation_manager.cpp | 371 …std::string queueData = KITS::NfcSdkCommon::BytesVecToHexString(&queueHceData_[0], queueHceData_.s… in HandleQueueData() local 378 queueData.c_str(), hceState_, abilityConnection_->ServiceConnected()); in HandleQueueData()
|