* Copyright (c) 2022 Huawei Device Co., Ltd.
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
#ifndef SEC_MESSENGER_INFO_H
#define SEC_MESSENGER_INFO_H
#include <stdint.h>
#include <stdbool.h>
#ifdef __cplusplus
extern "C" {
#endif
#ifndef DEVICE_SECURITY_DEFINES_H
#define DEVICE_ID_MAX_LEN 64
typedef struct DeviceIdentify {
uint32_t length;
uint8_t identity[DEVICE_ID_MAX_LEN];
} DeviceIdentify;
#endif
typedef int32_t (*DeviceMessageReceiver)(const DeviceIdentify *devId, const uint8_t *msg, uint32_t msgLen);
typedef int32_t (*DeviceStatusReceiver)(const DeviceIdentify *devId, uint32_t status, int32_t level);
typedef int32_t (*MessageSendResultNotifier)(const DeviceIdentify *devId, uint64_t transNo, uint32_t result);
typedef int32_t (*DeviceProcessor)(const DeviceIdentify *devId, int32_t level, void *para);
typedef struct MessengerConfig {
const char *pkgName;
#ifdef L2_STANDARD
const char *primarySockName;
const char *secondarySockName;
#else
const char *primarySessName;
const char *secondarySessName;
#endif
DeviceMessageReceiver messageReceiver;
DeviceStatusReceiver statusReceiver;
MessageSendResultNotifier sendResultNotifier;
uint32_t threadCnt;
} MessengerConfig;
typedef struct StatisticInformation {
uint64_t firstOnlineTime;
uint64_t lastOnlineTime;
uint64_t firstOfflineTime;
uint64_t lastOfflineTime;
uint64_t lastSessOpenTime;
uint32_t lastSessOpenResult;
uint32_t lastSessOpenCost;
uint64_t lastSessCloseTime;
uint64_t lastMsgSendTime;
uint32_t lastMsgSendResult;
uint32_t lastMsgSendCost;
uint64_t lastMsgRecvTime;
uint64_t packetRx;
uint64_t packetTotalRx;
uint64_t packetTx;
uint64_t packetTotalTx;
uint64_t packetTxFailed;
uint64_t packetTotalTxFailed;
} StatisticInformation;
typedef struct Messenger Messenger;
Messenger *CreateMessenger(const MessengerConfig *config);
void DestroyMessenger(Messenger *messenger);
bool IsMessengerReady(const Messenger *messenger);
void SendMsgTo(const Messenger *messenger, uint64_t transNo, const DeviceIdentify *devId, const uint8_t *msg,
uint32_t msgLen);
bool GetDeviceOnlineStatus(const Messenger *messenger, const DeviceIdentify *devId, int32_t *level);
bool GetSelfDeviceIdentify(const Messenger *messenger, DeviceIdentify *devId, int32_t *level);
void ForEachDeviceProcess(const Messenger *messenger, const DeviceProcessor processor, void *para);
bool GetDeviceStatisticInfo(const Messenger *messenger, const DeviceIdentify *devId, StatisticInformation *info);
#ifdef __cplusplus
}
#endif
#endif