mirror of
https://github.com/openharmony/startup_init_lite.git
synced 2026-07-21 20:45:22 -04:00
sun_fan
133 lines
3.8 KiB
C
Executable File
133 lines
3.8 KiB
C
Executable File
/*
|
|
* Copyright (c) 2021 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 BASE_STARTUP_PARAM_MESSAGE_H
|
|
#define BASE_STARTUP_PARAM_MESSAGE_H
|
|
#include <stdint.h>
|
|
#include <string.h>
|
|
#include <unistd.h>
|
|
|
|
#include "param.h"
|
|
#include "param_utils.h"
|
|
#include "securec.h"
|
|
|
|
#ifdef __cplusplus
|
|
#if __cplusplus
|
|
extern "C" {
|
|
#endif
|
|
#endif
|
|
|
|
#ifndef PARAM_SUPPORT_LIBUV
|
|
#ifndef PARAM_SUPPORT_EVENT
|
|
#define PARAM_SUPPORT_LIBUV 1
|
|
#endif
|
|
#endif
|
|
|
|
#define WORKER_TYPE_MSG 0x01
|
|
#define WORKER_TYPE_EVENT 0x02
|
|
#define WORKER_TYPE_TIMER 0x08
|
|
|
|
#define WORKER_TYPE_ASYNC 0x10
|
|
#define WORKER_TYPE_SERVER 0x20
|
|
#define WORKER_TYPE_CLIENT 0x40
|
|
|
|
typedef enum {
|
|
MSG_SET_PARAM,
|
|
MSG_WAIT_PARAM,
|
|
MSG_ADD_WATCHER,
|
|
MSG_DEL_WATCHER,
|
|
MSG_NOTIFY_PARAM
|
|
} ParamMsgType;
|
|
|
|
typedef enum ContentType {
|
|
PARAM_NAME,
|
|
PARAM_VALUE,
|
|
PARAM_LABEL,
|
|
PARAM_WAIT_TIMEOUT,
|
|
PARAM_NAME_VALUE,
|
|
} ContentType;
|
|
|
|
typedef struct {
|
|
uint8_t type;
|
|
uint8_t rev;
|
|
uint16_t contentSize;
|
|
char content[0];
|
|
} ParamMsgContent;
|
|
|
|
typedef struct {
|
|
uint32_t type;
|
|
uint32_t msgSize;
|
|
union {
|
|
uint32_t msgId;
|
|
uint32_t watcherId;
|
|
uint32_t waitId;
|
|
} id;
|
|
char key[PARAM_NAME_LEN_MAX];
|
|
char data[0];
|
|
} ParamMessage;
|
|
|
|
typedef struct {
|
|
ParamMessage msg;
|
|
uint32_t result;
|
|
} ParamResponseMessage;
|
|
|
|
struct ParamTask_;
|
|
typedef struct ParamTask_ *ParamTaskPtr;
|
|
typedef int (*IncomingConnect)(const ParamTaskPtr stream, uint32_t flags);
|
|
typedef int (*RecvMessage)(const ParamTaskPtr stream, const ParamMessage *msg);
|
|
typedef void (*TimerProcess)(const ParamTaskPtr stream, void *context);
|
|
typedef void (*EventProcess)(uint64_t eventId, const char *context, uint32_t size);
|
|
typedef void (*TaskClose)(const ParamTaskPtr stream);
|
|
|
|
typedef struct ParamTask_ {
|
|
uint32_t flags;
|
|
} ParamTask;
|
|
|
|
typedef struct {
|
|
uint32_t flags;
|
|
char *server;
|
|
IncomingConnect incomingConnect;
|
|
RecvMessage recvMessage;
|
|
TaskClose close;
|
|
} ParamStreamInfo;
|
|
|
|
int ParamServiceStop(void);
|
|
int ParamServiceStart(void);
|
|
|
|
int ParamTaskClose(ParamTaskPtr stream);
|
|
int ParamServerCreate(ParamTaskPtr *server, const ParamStreamInfo *info);
|
|
int ParamStreamCreate(ParamTaskPtr *client, ParamTaskPtr server, const ParamStreamInfo *info, uint16_t userDataSize);
|
|
int ParamTaskSendMsg(const ParamTaskPtr stream, const ParamMessage *msg);
|
|
|
|
int ParamEventTaskCreate(ParamTaskPtr *stream, EventProcess eventProcess, EventProcess eventBeforeProcess);
|
|
int ParamEventSend(ParamTaskPtr stream, uint64_t eventId, const char *content, uint32_t size);
|
|
|
|
int ParamTimerCreate(ParamTaskPtr *timer, TimerProcess process, void *context);
|
|
int ParamTimerStart(ParamTaskPtr timer, uint64_t timeout, uint64_t repeat);
|
|
|
|
void *ParamGetTaskUserData(ParamTaskPtr stream);
|
|
|
|
int FillParamMsgContent(const ParamMessage *request, uint32_t *start, int type, const char *value, uint32_t length);
|
|
ParamMsgContent *GetNextContent(const ParamMessage *reqest, uint32_t *offset);
|
|
ParamMessage *CreateParamMessage(int type, const char *name, uint32_t msgSize);
|
|
|
|
int ConntectServer(int fd, const char *servername);
|
|
|
|
#ifdef __cplusplus
|
|
#if __cplusplus
|
|
}
|
|
#endif
|
|
#endif
|
|
#endif // BASE_STARTUP_PARAM_MESSAGE_H
|