-
Notifications
You must be signed in to change notification settings - Fork 0
/
rtConnection.h
146 lines (128 loc) · 3.39 KB
/
rtConnection.h
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
/*
##########################################################################
# If not stated otherwise in this file or this component's LICENSE
# file the following copyright and licenses apply:
#
# Copyright 2019 RDK Management
#
# 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 __RTMSG_CONNECTION_H__
#define __RTMSG_CONNECTION_H__
#include "rtError.h"
#include "rtMessage.h"
#include "rtMessageHeader.h"
#define RTMSG_DEFAULT_ROUTER_LOCATION "tcp://127.0.0.1:10001"
#ifdef __cplusplus
extern "C" {
#endif
struct _rtConnection;
typedef struct _rtConnection* rtConnection;
typedef void (*rtMessageCallback)(rtMessageHeader const* hdr, uint8_t const* buff,
uint32_t n, void* closure);
typedef enum
{
rtConnectionState_ReadHeaderPreamble,
rtConnectionState_ReadHeader,
rtConnectionState_ReadPayload
} rtConnectionState;
/**
* Creates an rtConnection
* @param con
* @param application_name
* @param router_config
* @return error
*/
rtError
rtConnection_Create(rtConnection* con, char const* application_name, char const* router_config);
rtError
rtConnection_CreateWithConfig(rtConnection* con, rtMessage const conf);
/**
* Destroy an rtConnection
* @param con
* @return error
*/
rtError
rtConnection_Destroy(rtConnection con);
/** Send an Error message to caller when no provide/Route is available
*@param clnt_fd
*@param request_header
*@return error
*/
rtError
rtConnection_SendErrorMessageToCaller(int clnt_fd , rtMessageHeader const* request_header);
/**
* Sends a message
* @param con
* @param msg
* @param topic
* @return error
*/
rtError
rtConnection_SendMessage(rtConnection con, rtMessage msg, char const* topic);
/**
* Sends a binary payload
* @param con
* @param topic
* @param pointer to buffer
* @param length of buffer
* @return error
*/
rtError
rtConnection_SendBinary(rtConnection con, char const* topic, uint8_t const* p, uint32_t n);
/**
* Sends a request and receive a response
* @param con
* @param req
* @param topic
* @param response
* @param timeout
* @return error
*/
rtError
rtConnection_SendRequest(rtConnection con, rtMessage const req, char const* topic,
rtMessage* res, int32_t timeout);
rtError
rtConnection_SendResponse(rtConnection con, rtMessageHeader const* request_hdr, rtMessage const res,
int32_t timeout);
/**
* Register a callback for message receipt
* @param con
* @param topic expression
* @param callback handler
* @param closure
* @return error
*/
rtError
rtConnection_AddListener(rtConnection con, char const* expression,
rtMessageCallback callback, void* closure);
/**
* Dispatch incoming messages
* @param con
* @return error
*/
rtError
rtConnection_Dispatch(rtConnection con);
/**
* Dispatch with a timeout
* @param con
* @param timeout
* return error
*/
rtError
rtConnection_TimedDispatch(rtConnection con, int32_t timeout);
#ifdef __cplusplus
}
#endif
#endif