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
|
// Copyright 2017 AISIN AW CO.,LTD
#pragma once
#include <stdint.h>
#include <string>
#include <pthread.h>
extern "C" {
#include <afb/afb-wsj1.h>
#include <afb/afb-ws-client.h>
}
#include "RequestManageListener.h"
/**
* @brief Class for request
*/
class RequestManage
{
public:
pthread_cond_t cond;
pthread_mutex_t mutex;
struct afb_wsj1* wsj1;
std::string* requestURL;
struct afb_wsj1_itf wsj1_itf;
private:
RequestManageListener* listener;
int request_cnt;
uint32_t sessionHandle;
uint32_t routeHandle;
// Function called from thread
static void* BinderThread(void* param);
// Callback function
void OnReply(struct afb_wsj1_msg *msg);
void OnHangup(struct afb_wsj1 *wsj1);
void OnCallStatic(const char *api, const char *verb, struct afb_wsj1_msg *msg);
void OnEventStatic(const char *event, struct afb_wsj1_msg *msg);
static void OnReplyStatic(void *closure, struct afb_wsj1_msg *msg);
static void OnHangupStatic(void *closure, struct afb_wsj1 *wsj1);
static void OnCallStatic(void *closure, const char *api, const char *verb, struct afb_wsj1_msg *msg);
static void OnEventStatic(void *closure, const char *event, struct afb_wsj1_msg *msg);
// ==================================================================================================
// public
// ==================================================================================================
public:
RequestManage();
~RequestManage();
bool Connect(const char* api_url, RequestManageListener* listener);
bool IsConnect();
bool CallBinderAPI(const char *api, const char *verb, const char *object);
void SetSessionHandle(uint32_t session);
uint32_t GetSessionHandle();
void SetRouteHandle(uint32_t route);
uint32_t GetRouteHandle();
};
|
