Skip to content

K
k-sdk
Commit 97a82e1a authored by whmaizmy's avatar whmaizmy
Browse files
Options

【修改内容】调整工程目录结构 

【提交人】陈伟灿
parent 0580adb7
Expand all Hide whitespace changes
Inline Side-by-side
Showing with 2220 additions and 4822 deletions

Too many changes to show.
Plain diff Email patch

To preserve performance only 1000 of 1000+ files are displayed.

src/kcloud/kcloud_data_handle.c → application/kcloud/kcloud_data_handle.c
View file @ 97a82e1a
......@@ -19,7 +19,7 @@ static char * data_create(const char *topic,const char *data)
//free(out); /* Print to text, Delete the cJSON, print it, release the string. */
}
void KK_Sendto_CloudData(void *data)
void KK_Sendto_CloudData(void *data,int len)
{
cJSON *root,*pTopic,*pData;
char *topic = NULL;
......@@ -39,8 +39,8 @@ void KK_Sendto_CloudData(void *data)
{
return;
}
printf("[%s][%d] topic:%s\n",pTopic->valuestring);
printf("[%s][%d] payload:%s\n",pData->valuestring);
printf("[%s][%d] topic:%s\n",__FUNCTION__,__LINE__,pTopic->valuestring);
printf("[%s][%d] payload:%s\n",__FUNCTION__,__LINE__,pData->valuestring);
KK_MQTT_SendMsg(pTopic->valuestring,(const char*)pData->valuestring);
}
......
src/kcloud/mqtt_api.h → application/kcloud/mqtt_api.h
View file @ 97a82e1a
......@@ -4,7 +4,7 @@
#include "kcloud_log.h"
#include "kcloud_config.h"
extern void KK_Sendto_CloudData(void *data);
extern void KK_Sendto_CloudData(void *data,int len);
extern int KK_MQTT_SubTopic(char *topicName);
......
common/api/com_api.h
View file @ 97a82e1a
......@@ -36,5 +36,3 @@ int kk_ipc_send(ipc_type type, void* data, int len);
}
#endif
#endif
common/json/cJSON.c
View file @ 97a82e1a
This diff is collapsed.
common/json/cJSON.h
View file @ 97a82e1a
......@@ -38,6 +38,7 @@ extern "C"
#define cJSON_Object 6
#define cJSON_IsReference 256
#define cJSON_StringIsConst 512
/* The cJSON structure: */
typedef struct cJSON {
......@@ -64,15 +65,12 @@ extern void cJSON_InitHooks(cJSON_Hooks* hooks);
/* Supply a block of JSON, and this returns a cJSON object you can interrogate. Call cJSON_Delete when finished. */
extern cJSON *cJSON_Parse(const char *value);
/* Supply a block of JSON, and this returns a cJSON object you can interrogate. Call cJSON_Delete when finished.
* end_ptr will point to 1 past the end of the JSON object */
extern cJSON *cJSON_Parse_Stream(const char *value, char **end_ptr);
/* Render a cJSON entity to text for transfer/storage. Free the char* when finished. */
extern char *cJSON_Print(cJSON *item);
extern char *cJSON_Print_pure(cJSON *item);
/* Render a cJSON entity to text for transfer/storage without any formatting. Free the char* when finished. */
extern char *cJSON_PrintUnformatted(cJSON *item);
/* Render a cJSON entity to text using a buffered strategy. prebuffer is a guess at the final size. guessing well reduces reallocation. fmt=0 gives unformatted, =1 gives formatted */
extern char *cJSON_PrintBuffered(cJSON *item,int prebuffer,int fmt);
/* Delete a cJSON entity and all subentities. */
extern void cJSON_Delete(cJSON *c);
......@@ -83,25 +81,29 @@ extern cJSON *cJSON_GetArrayItem(cJSON *array,int item);
/* Get item "string" from object. Case insensitive. */
extern cJSON *cJSON_GetObjectItem(cJSON *object,const char *string);
/* For analysing failed parses. This returns a pointer to the parse error. You'll probably need to look a few chars back to make sense of it. Defined when cJSON_Parse() returns 0. 0 when cJSON_Parse() succeeds. */
extern const char *cJSON_GetErrorPtr(void);
/* These calls create a cJSON item of the appropriate type. */
extern cJSON *cJSON_CreateNull();
extern cJSON *cJSON_CreateTrue();
extern cJSON *cJSON_CreateFalse();
extern cJSON *cJSON_CreateNull(void);
extern cJSON *cJSON_CreateTrue(void);
extern cJSON *cJSON_CreateFalse(void);
extern cJSON *cJSON_CreateBool(int b);
extern cJSON *cJSON_CreateNumber(double num);
extern cJSON *cJSON_CreateString(const char *string);
extern cJSON *cJSON_CreateArray();
extern cJSON *cJSON_CreateObject();
extern cJSON *cJSON_CreateArray(void);
extern cJSON *cJSON_CreateObject(void);
/* These utilities create an Array of count items. */
extern cJSON *cJSON_CreateIntArray(int *numbers,int count);
extern cJSON *cJSON_CreateFloatArray(float *numbers,int count);
extern cJSON *cJSON_CreateDoubleArray(double *numbers,int count);
extern cJSON *cJSON_CreateIntArray(const int *numbers,int count);
extern cJSON *cJSON_CreateFloatArray(const float *numbers,int count);
extern cJSON *cJSON_CreateDoubleArray(const double *numbers,int count);
extern cJSON *cJSON_CreateStringArray(const char **strings,int count);
/* Append item to the specified array/object. */
extern void cJSON_AddItemToArray(cJSON *array, cJSON *item);
extern void cJSON_AddItemToObject(cJSON *object,const char *string,cJSON *item);
extern void cJSON_AddItemToObjectCS(cJSON *object,const char *string,cJSON *item); /* Use this when string is definitely const (i.e. a literal, or as good as), and will definitely survive the cJSON object */
/* Append reference to item to the specified array/object. Use this when you want to add an existing cJSON to a new cJSON, but don't want to corrupt your existing cJSON. */
extern void cJSON_AddItemReferenceToArray(cJSON *array, cJSON *item);
extern void cJSON_AddItemReferenceToObject(cJSON *object,const char *string,cJSON *item);
......@@ -113,15 +115,33 @@ extern cJSON *cJSON_DetachItemFromObject(cJSON *object,const char *string);
extern void cJSON_DeleteItemFromObject(cJSON *object,const char *string);
/* Update array items. */
extern void cJSON_InsertItemInArray(cJSON *array,int which,cJSON *newitem); /* Shifts pre-existing items to the right. */
extern void cJSON_ReplaceItemInArray(cJSON *array,int which,cJSON *newitem);
extern void cJSON_ReplaceItemInObject(cJSON *object,const char *string,cJSON *newitem);
#define cJSON_AddNullToObject(object,name) cJSON_AddItemToObject(object, name, cJSON_CreateNull())
#define cJSON_AddTrueToObject(object,name) cJSON_AddItemToObject(object, name, cJSON_CreateTrue())
/* Duplicate a cJSON item */
extern cJSON *cJSON_Duplicate(cJSON *item,int recurse);
/* Duplicate will create a new, identical cJSON item to the one you pass, in new memory that will
need to be released. With recurse!=0, it will duplicate any children connected to the item.
The item->next and ->prev pointers are always zero on return from Duplicate. */
/* ParseWithOpts allows you to require (and check) that the JSON is null terminated, and to retrieve the pointer to the final byte parsed. */
extern cJSON *cJSON_ParseWithOpts(const char *value,const char **return_parse_end,int require_null_terminated);
extern void cJSON_Minify(char *json);
/* Macros for creating things quickly. */
#define cJSON_AddNullToObject(object,name) cJSON_AddItemToObject(object, name, cJSON_CreateNull())
#define cJSON_AddTrueToObject(object,name) cJSON_AddItemToObject(object, name, cJSON_CreateTrue())
#define cJSON_AddFalseToObject(object,name) cJSON_AddItemToObject(object, name, cJSON_CreateFalse())
#define cJSON_AddBoolToObject(object,name,b) cJSON_AddItemToObject(object, name, cJSON_CreateBool(b))
#define cJSON_AddNumberToObject(object,name,n) cJSON_AddItemToObject(object, name, cJSON_CreateNumber(n))
#define cJSON_AddStringToObject(object,name,s) cJSON_AddItemToObject(object, name, cJSON_CreateString(s))
/* When assigning an integer value, it needs to be propagated to valuedouble too. */
#define cJSON_SetIntValue(object,val) ((object)?(object)->valueint=(object)->valuedouble=(val):(val))
#define cJSON_SetNumberValue(object,val) ((object)?(object)->valueint=(object)->valuedouble=(val):(val))
#ifdef __cplusplus
}
#endif
......
common/json/cson.c 0 → 100644
View file @ 97a82e1a
This diff is collapsed.
common/json/cson.h 0 → 100644
View file @ 97a82e1a
/**
* @file cson.h
* @author Letter (NevermindZZT@gmail.com)
* @brief cson
* @version 0.1
* @date 2019-08-26
*
* @copyright (c) 2019 Letter
*
*/
#ifndef __CSON_H__
#define __CSON_H__
#include "stddef.h"
#include "cJSON.h"
#define CSON_VERSION "1.0.3" /**< CSON版本 */
/**
* @defgroup CSON cson
* @brief json tools for C
* @addtogroup CSON
* @{
*/
/**
* @brief CSON数据类型定义
*
*/
typedef enum
{
CSON_TYPE_OBJ = 0,
CSON_TYPE_CHAR,
CSON_TYPE_SHORT,
CSON_TYPE_INT,
CSON_TYPE_LONG,
CSON_TYPE_FLOAT,
CSON_TYPE_DOUBLE,
CSON_TYPE_BOOL,
CSON_TYPE_STRING,
CSON_TYPE_STRUCT,
CSON_TYPE_LIST,
CSON_TYPE_ARRAY,
CSON_TYPE_JSON,
} CsonType;
/**
* @brief CSON数据模型定义
*
*/
typedef struct cson_model
{
CsonType type; /**< 数据类型 */
char *key; /**< 元素键值 */
short offset; /**< 元素偏移 */
union
{
struct
{
struct cson_model *model; /**< 子结构体模型 */
short size; /**< 子结构体模型大小 */
} sub; /**< 子结构体 */
struct
{
CsonType eleType; /**< 数组元素类型 */
short size; /**< 数组大小 */
} array; /**< 数组 */
int objSize; /**< 对象大小 */
CsonType basicListType; /**< 基础数据链表类型 */
} param;
} CsonModel;
/**
* @brief Cson链表
*
*/
typedef struct cson_list
{
struct cson_list *next; /**< 下一个元素 */
void *obj; /**< 对象 */
} CsonList;
extern CsonModel csonBasicListModel[]; /**< 基础类型链表数据模型 */
#define CSON_MODEL_CHAR_LIST &csonBasicListModel[0] /**< char型链表数据模型 */
#define CSON_MODEL_SHORT_LIST &csonBasicListModel[2] /**< short型链表数据模型 */
#define CSON_MODEL_INT_LIST &csonBasicListModel[4] /**< int型链表数据模型 */
#define CSON_MODEL_LONG_LIST &csonBasicListModel[6] /**< long型链表数据模型 */
#define CSON_MODEL_FLOAT_LIST &csonBasicListModel[8] /**< float型链表数据模型 */
#define CSON_MODEL_DOUBLE_LIST &csonBasicListModel[10] /**< double型链表数据模型 */
#define CSON_MODEL_STRING_LIST &csonBasicListModel[12] /**< string型链表数据模型 */
#define CSON_BASIC_LIST_MODEL_SIZE 2 /**< 基础类型链表数据模型大小 */
/**
* @brief 对象数据模型
*
* @param type 对象类型
*/
#define CSON_MODEL_OBJ(type) \
{CSON_TYPE_OBJ, NULL, 0, .param.objSize=sizeof(type)}
/**
* @brief char型数据模型
*
* @param type 对象模型
* @param key 数据键值
*/
#define CSON_MODEL_CHAR(type, key) \
{CSON_TYPE_CHAR, #key, offsetof(type, key)}
/**
* @brief short型数据模型
*
* @param type 对象模型
* @param key 数据键值
*/
#define CSON_MODEL_SHORT(type, key) \
{CSON_TYPE_SHORT, #key, offsetof(type, key)}
/**
* @brief int型数据模型
*
* @param type 对象模型
* @param key 数据键值
*/
#define CSON_MODEL_INT(type, key) \
{CSON_TYPE_INT, #key, offsetof(type, key)}
/**
* @brief long型数据模型
*
* @param type 对象模型
* @param key 数据键值
*/
#define CSON_MODEL_LONG(type, key) \
{CSON_TYPE_LONG, #key, offsetof(type, key)}
/**
* @brief float型数据模型
*
* @param type 对象模型
* @param key 数据键值
*/
#define CSON_MODEL_FLOAT(type, key) \
{CSON_TYPE_FLOAT, #key, offsetof(type, key)}
/**
* @brief double型数据模型
*
* @param type 对象模型
* @param key 数据键值
*/
#define CSON_MODEL_DOUBLE(type, key) \
{CSON_TYPE_DOUBLE, #key, offsetof(type, key)}
/**
* @brief bool型数据模型
*
* @param type 对象模型
* @param key 数据键值
*/
#define CSON_MODEL_BOOL(type, key) \
{CSON_TYPE_BOOL, #key, offsetof(type, key)}
/**
* @brief 字符串型数据模型
*
* @param type 对象模型
* @param key 数据键值
*/
#define CSON_MODEL_STRING(type, key) \
{CSON_TYPE_STRING, #key, offsetof(type, key)}
/**
* @brief 结构体型数据模型
*
* @param type 对象模型
* @param key 数据键值
* @param submodel 子结构体模型
* @param subsize 子结构体模型大小
*/
#define CSON_MODEL_STRUCT(type, key, submodel, subsize) \
{CSON_TYPE_STRUCT, #key, offsetof(type, key), .param.sub.model=submodel, .param.sub.size=subsize}
/**
* @brief list型数据模型
*
* @param type 对象模型
* @param key 数据键值
* @param submodel 子结构体模型
* @param subsize 子结构体模型大小
*/
#define CSON_MODEL_LIST(type, key, submodel, subsize) \
{CSON_TYPE_LIST, #key, offsetof(type, key), .param.sub.model=submodel, .param.sub.size=subsize}
/**
* @brief list型数据模型
*
* @param type 对象模型
* @param key 数据键值
* @param elementType 数组元素类型
* @param arraySize 数组大小
*/
#define CSON_MODEL_ARRAY(type, key, elementType, arraySize) \
{CSON_TYPE_ARRAY, #key, offsetof(type, key), .param.array.eleType=elementType, .param.array.size=arraySize}
/**
* @brief 子json数据模型
*
* @param type 对象模型
* @param key 数据键值
*/
#define CSON_MODEL_JSON(type, key) \
{CSON_TYPE_JSON, #key, offsetof(type, key)}
/**
* @brief CSON断言
*
* @param expr 表达式
* @param action 断言失败执行动作
*/
#define CSON_ASSERT(expr, action) \
if (!(expr)) { \
printf(#expr " assert failed at file: %s, line: %d\r\n", __FILE__, __LINE__); \
action; \
}
/**
* @brief CSON初始化
*
* @param malloc 内存分配函数
* @param free 内存释放函数
*/
void csonInit(void *malloc, void *free);
/**
* @brief 解析JSON对象
*
* @param json JSON对象
* @param model 数据模型
* @param modelSize 数据模型数量
* @return void* 解析得到的对象
*/
void *csonDecodeObject(cJSON *json, CsonModel *model, int modelSize);
/**
* @brief 解析JSON对象
*
* @param json JSON对象
* @param model 数据模型
* @return void* 解析得到的对象
*/
#define csonDecodeObjectEx(json, model) \
csonDecodeObject(json, model, sizeof(model) / sizeof(CsonModel))
/**
* @brief 解析JSON字符串
*
* @param jsonStr json字符串
* @param model 数据模型
* @param modelSize 数据模型数量
* @return void* 解析得到的对象
*/
void *csonDecode(const char *jsonStr, CsonModel *model, int modelSize);
/**
* @brief 解析JSON字符串
*
* @param jsonStr json字符串
* @param model 数据模型
* @return void* 解析得到的对象
*/
#define csonDecodeEx(jsonStr, model) \
csonDecode(jsonStr, model, sizeof(model) / sizeof(CsonModel));
/**
* @brief 编码成json字符串
*
* @param obj 对象
* @param model 数据模型
* @param modelSize 数据模型数量
* @return char* 编码得到的json字符串
*/
cJSON* csonEncodeObject(void *obj, CsonModel *model, int modelSize);
/**
* @brief 编码成json字符串
*
* @param obj 对象
* @param model 数据模型
* @param modelSize 数据模型数量
* @param bufferSize 分配给json字符串的空间大小
* @param fmt 是否格式化json字符串
* @return char* 编码得到的json字符串
*/
char* csonEncode(void *obj, CsonModel *model, int modelSize, int bufferSize, int fmt);
/**
* @brief 编码成json字符串
*
* @param obj 对象
* @param model 数据模型
* @param bufferSize 分配给json字符串的空间大小
* @param fmt 是否格式化json字符串
* @return char* 编码得到的json字符串
*/
#define csonEncodeEx(obj, model, bufferSize, fmt) \
csonEncode(obj, model, sizeof(model)/sizeof(CsonModel), bufferSize, fmt)
/**
* @brief 编码成json字符串
*
* @param obj 对象
* @param model 数据模型
* @param modelSize 数据模型数量
* @return char* 编码得到的json字符串
*/
char* csonEncodeUnformatted(void *obj, CsonModel *model, int modelSize);
/**
* @brief 编码成json字符串
*
* @param obj 对象
* @param model 数据模型
* @return char* 编码得到的json字符串
*/
#define csonEncodeUnformattedEx(obj, model) \
csonEncodeUnformatted(obj, model, sizeof(model) / sizeof(CsonModel))
/**
* @brief 释放CSON解析出的对象
*
* @param obj 对象
* @param model 对象模型
* @param modelSize 对象模型数量
*/
void csonFree(void *obj, CsonModel *model, int modelSize);
/**
* @brief 释放CSON解析出的对象
*
* @param obj 对象
* @param model 对象模型
*/
#define csonFreeEx(obj, model) \
csonFree(obj, model, sizeof(model) / sizeof(CsonModel))
/**
* @brief 释放cson编码生成的json字符串
*
* @param jsonStr json字符串
*/
void csonFreeJson(const char *jsonStr);
/**
* @brief CSON链表添加节点
*
* @param list 链表
* @param obj 节点对象
* @return CsonList 链表
*/
CsonList* csonListAdd(CsonList *list, void *obj);
/**
* @brief CSON链表删除节点
*
* @param list 链表
* @param obj 节点对象
* @param freeMem 释放内存
* @return CsonList 链表
*/
CsonList *csonListDelete(CsonList *list, void *obj, char freeMem);
/**
* @brief CSON新字符串
*
* @param src 源字符串
* @return char* 新字符串
* @note 此函数用于复制字符串，建议对结构体中字符串成员赋值时，使用此函数，
* 方便使用`csonFree`进行内存释放
*/
char* csonNewString(const char *src);
/**
* @}
*/
#endif
example/ev/iot.mk deleted 100644 → 0
View file @ 0580adb7
LIBA_TARGET := libev_fnc.a
SRCS_example := server.c
$(call Append_Conditional, LIB_SRCS_EXCLUDE, server.c)
$(call Append_Conditional, SRCS_ev-demo, server.c)
$(call Append_Conditional, TARGET, ev-demo)
#CFLAGS += -I../../work/ssl/include -lrt
#LDFLAGS += -L../../work/ssl/lib
#DEPENDS += common/mqtt
LDFLAGS += -L$(TOP_DIR)/example/ev -static -lev -ldl
example/ev/server.c deleted 100644 → 0
View file @ 0580adb7
#include <stdio.h>
#include "ev.h"
ev_io stdin_watcher;
ev_timer timeout_watcher;
static void stdin_cb(EV_P_ ev_io *w, int revents)
{
puts("stdin ready");
ev_io_stop(EV_A_ w);
ev_break(EV_A_ EVBREAK_ALL);
}
static void timeout_cb(EV_P_ ev_timer *w, int revnts)
{
puts("time out");
ev_break(EV_A_ EVBREAK_ONE);
}
int main(void)
{
struct ev_loop *loop = EV_DEFAULT;
ev_io_init(&stdin_watcher, stdin_cb, 0, EV_READ);
ev_io_start(loop, &stdin_watcher);
ev_timer_init(&timeout_watcher, timeout_cb, 10, 0);
ev_timer_start(loop, &timeout_watcher);
ev_run(loop, 0);
return 0;
}
example/ev/说明.txt deleted 100644 → 0
View file @ 0580adb7
版本：libev-4.33
发布包：http://dist.schmorp.de/libev/
API：http://pod.tst.eu/http://cvs.schmorp.de/libev/ev.pod
Csdn学习：https://blog.csdn.net/weixin_39510813/article/details/90711184
Demo：https://www.cnblogs.com/wunaozai/p/3950249.html
example/ev_nanomsg/ev_nanomsg.c deleted 100644 → 0
View file @ 0580adb7
#include <stdio.h>
#include <stdint.h>
#include <unistd.h>
#include <string.h>
#include <time.h>
#include "ev.h"
#include <pthread.h>
#include <nanomsg/pair.h>
#include <nanomsg/nn.h>
/***************************************************************************************************
动态库：libev nanomsg
概述：A B C 三个线程通过nanomsg通信，A线程作为主线程，控制中枢，B C请求均通过A.
demo示范：
A为指令处理模块
B为指令接收模块
C为指令执行模块
B -> A 开灯
A -> C 开灯
C : 执行开灯
C -> A OK
A -> B OK
总结：
这只是简单的测试使用例子，你可以通过在这个框架的基础上做更多的功能，对于多线程编程这将是一个不
错的选择.
***************************************************************************************************/
typedef struct {
int n; //nanomsg socket
int s; //nanomsg recieve fd
}nanomsg_info_t;
typedef struct {
nanomsg_info_t ab;
nanomsg_info_t ac;
}Aloop_ctrl_t;
typedef struct {
nanomsg_info_t ba;
}Bloop_ctrl_t;
typedef struct {
nanomsg_info_t ca;
}Cloop_ctrl_t;
/*获取系统时间打印*/
uint32_t print_timenow()
{
time_t now;
struct tm *tm_now;
time(&now);
tm_now = localtime(&now);
uint32_t times = tm_now->tm_hour * 3600 + tm_now->tm_min * 60 + tm_now->tm_sec;
printf("[%02d:%02d:%02d]\r\n", tm_now->tm_hour, tm_now->tm_min, tm_now->tm_sec);
return times;
}
/*****************************************子线程C相关**********************************************/
static void watcher_c_cb (struct ev_loop *loop ,struct ev_io *w, int revents)
{
void *user_data = ev_userdata(loop);
Cloop_ctrl_t *Cloop_ctrl = (Cloop_ctrl_t *)user_data;
uint8_t *dat = NULL;
uint32_t bytes = nn_recv(Cloop_ctrl->ca.n, &dat, NN_MSG, NN_DONTWAIT);
if (bytes <= 0) {
return;
}
printf("C:%s (A->C)\r\n", (char *)dat);
nn_freemsg(dat);
//接收成功，发送OK
char *str = "OK";
uint8_t *udata = nn_allocmsg(3, 0);
if (NULL != udata) {
memcpy(udata, str, 3);
nn_send(Cloop_ctrl->ca.n, &udata, NN_MSG, NN_DONTWAIT);
}
}
int C_nanomsg_init(Cloop_ctrl_t *Cloop_ctrl)
{
Cloop_ctrl->ca.n = nn_socket(AF_SP, NN_PAIR);
if (Cloop_ctrl->ca.n < 0) {
return -1;
}
if (nn_connect(Cloop_ctrl->ca.n, "inproc://c2a_loop") < 0) {
return -1;
}
size_t size = sizeof(size_t);
if (nn_getsockopt(Cloop_ctrl->ca.n, NN_SOL_SOCKET, NN_RCVFD, (char *)&Cloop_ctrl->ca.s, &size) < 0) {
return -1;
}
return 0;
}
struct ev_loop* C_loop_init(Cloop_ctrl_t *Cloop_ctrl)
{
static struct ev_io watcher_c;
struct ev_loop *loop = ev_loop_new(EVBACKEND_EPOLL);
if (NULL == loop) {
printf("create C loop failed\r\n");
return NULL;
}
ev_io_init (&watcher_c, watcher_c_cb, Cloop_ctrl->ca.s, EV_READ);
ev_io_start (loop, &watcher_c);
return loop;
}
void *C_thread(void *arg)
{
Cloop_ctrl_t Cloop_ctrl;
if (C_nanomsg_init(&Cloop_ctrl) < 0) {
printf("nanomsg init failed\r\n");
return ;
}
struct ev_loop* Cloop = C_loop_init(&Cloop_ctrl);
if (NULL == Cloop) {
printf("Cloop init failed\r\n");
return ;
}
ev_set_userdata(Cloop, &Cloop_ctrl);
ev_run (Cloop, 0);
return ;
}
/*****************************************子线程B相关**********************************************/
static void watcher_b_cb (struct ev_loop *loop ,struct ev_io *w, int revents)
{
void *user_data = ev_userdata(loop);
Bloop_ctrl_t *Bloop_ctrl = (Bloop_ctrl_t *)user_data;
uint8_t *dat = NULL;
uint32_t bytes = nn_recv(Bloop_ctrl->ba.n, &dat, NN_MSG, NN_DONTWAIT);
if (bytes <= 0) {
return;
}
printf("B:%s (A->B)\r\n\r\n", (char *)dat);
nn_freemsg(dat);
}
static void watcher_timer_cb (struct ev_loop *loop ,struct ev_timer *w, int revents)
{
static int i = 1;
char send_data[128] = {0};
void *user_data = ev_userdata(loop);
Bloop_ctrl_t *Bloop_ctrl = (Bloop_ctrl_t *)user_data;
sprintf(send_data, "Please turn on LED[%d]", i);
i ++;
int length = strlen(send_data) + 1;
uint8_t *udata = nn_allocmsg(length, 0);
if (NULL != udata) {
memcpy(udata, send_data, length);
nn_send(Bloop_ctrl->ba.n, &udata, NN_MSG, NN_DONTWAIT);
}
//如果定时器不重设，就会默认1秒进入一次回调
w->repeat = 10;
ev_timer_again(loop, w);
}
int B_nanomsg_init(Bloop_ctrl_t *Bloop_ctrl)
{
Bloop_ctrl->ba.n = nn_socket(AF_SP, NN_PAIR);
if (Bloop_ctrl->ba.n < 0) {
return -1;
}
if (nn_connect(Bloop_ctrl->ba.n, "inproc://b2a_loop") < 0) {
return -1;
}
size_t size = sizeof(size_t);
if (nn_getsockopt(Bloop_ctrl->ba.n, NN_SOL_SOCKET, NN_RCVFD, (char *)&Bloop_ctrl->ba.s, &size) < 0) {
return -1;
}
return 0;
}
struct ev_loop* B_loop_init(Bloop_ctrl_t *Bloop_ctrl)
{
static struct ev_io watcher_b;
static struct ev_timer watcher_timer;
struct ev_loop *loop = ev_loop_new(EVBACKEND_EPOLL);
if (NULL == loop) {
printf("create loop failed\r\n");
return NULL;
}
ev_io_init (&watcher_b, watcher_b_cb, Bloop_ctrl->ba.s, EV_READ);
ev_timer_init(&watcher_timer, watcher_timer_cb, 5, 1);
ev_io_start (loop, &watcher_b);
ev_timer_start (loop, &watcher_timer);
return loop;
}
void *B_thread(void *arg)
{
Bloop_ctrl_t Bloop_ctrl;
if (B_nanomsg_init(&Bloop_ctrl) < 0) {
printf("nanomsg init failed\r\n");
return ;
}
struct ev_loop* Bloop = B_loop_init(&Bloop_ctrl);
if (NULL == Bloop) {
printf("Bloop init failed\r\n");
return ;
}
ev_set_userdata(Bloop, &Bloop_ctrl);
ev_run (Bloop, 0);
return ;
}
/*****************************************主线程A相关**********************************************/
static void watcher_ab_cb (struct ev_loop *loop ,struct ev_io *w, int revents)
{
void *user_data = ev_userdata(loop);
Aloop_ctrl_t *Aloop_ctrl = (Aloop_ctrl_t *)user_data;
uint8_t *dat = NULL;
uint32_t bytes = nn_recv(Aloop_ctrl->ab.n, &dat, NN_MSG, NN_DONTWAIT);
if (bytes <= 0) {
return;
}
//转发到C
printf("A:%s (B->A)\r\n", (char *)dat);
nn_send(Aloop_ctrl->ac.n, &dat, NN_MSG, NN_DONTWAIT);
}
static void watcher_ac_cb (struct ev_loop *loop ,struct ev_io *w, int revents)
{
void *user_data = ev_userdata(loop);
Aloop_ctrl_t *Aloop_ctrl = (Aloop_ctrl_t *)user_data;
uint8_t *dat = NULL;
uint32_t bytes = nn_recv(Aloop_ctrl->ac.n, &dat, NN_MSG, NN_DONTWAIT);
if (bytes <= 0) {
return;
}
//转发到B
printf("A:%s (C->A)\r\n", (char *)dat);
nn_send(Aloop_ctrl->ab.n, &dat, NN_MSG, NN_DONTWAIT);
}
/*主事件nanomsg初始化*/
int A_nanomsg_init(Aloop_ctrl_t *Aloop_ctrl)
{
//ab通信的nanomsg初始化
Aloop_ctrl->ab.n = nn_socket(AF_SP, NN_PAIR);
if (Aloop_ctrl->ab.n < 0) {
return -1;
}
if (nn_bind(Aloop_ctrl->ab.n, "inproc://b2a_loop") < 0) {
return -1;
}
//获取此端口的接收数据fd描述符
size_t size = sizeof(size_t);
if (nn_getsockopt(Aloop_ctrl->ab.n, NN_SOL_SOCKET, NN_RCVFD, (char *)&Aloop_ctrl->ab.s, &size) < 0) {
return -1;
}
//ac通信的nanomsg初始化
Aloop_ctrl->ac.n = nn_socket(AF_SP, NN_PAIR);
if (Aloop_ctrl->ac.n < 0) {
return -1;
}
if (nn_bind(Aloop_ctrl->ac.n, "inproc://c2a_loop") < 0) {
return -1;
}
//获取此端口的接收数据fd描述符
if (nn_getsockopt(Aloop_ctrl->ac.n, NN_SOL_SOCKET, NN_RCVFD, (char *)&Aloop_ctrl->ac.s, &size) < 0) {
return -1;
}
return 0;
}
/*主事件循环初始化*/
struct ev_loop* A_loop_init(Aloop_ctrl_t *Aloop_ctrl)
{
static struct ev_io watcher_ab, watcher_ac;
struct ev_loop *loop = ev_loop_new(EVBACKEND_EPOLL);
if (NULL == loop) {
printf("create loop failed\r\n");
return NULL;
}
//传参
ev_set_userdata(loop, Aloop_ctrl);
//初始化
ev_io_init (&watcher_ab, watcher_ab_cb, Aloop_ctrl->ab.s, EV_READ);
ev_io_init (&watcher_ac, watcher_ac_cb, Aloop_ctrl->ac.s, EV_READ);
ev_io_start (loop, &watcher_ab);
ev_io_start (loop, &watcher_ac);
return loop;
}
/**************************************************************************************************/
int main()
{
pthread_t pb,pc;
Aloop_ctrl_t Aloop_ctrl;
if (A_nanomsg_init(&Aloop_ctrl) < 0) {
printf("nanomsg init failed\r\n");
return -1;
}
struct ev_loop* Aloop = A_loop_init(&Aloop_ctrl);
if (NULL == Aloop) {
printf("Aloop init failed\r\n");
return -1;
}
//创建线程B
if (0 != pthread_create(&pb, NULL, B_thread, NULL)) {
printf("create pthread B failed\r\n");
return -1;
}
//创建线程C
if (0 != pthread_create(&pc, NULL, C_thread, NULL)) {
printf("create pthread C failed\r\n");
return -1;
}
//运行
ev_run(Aloop, 0);
return 0;
}
\ No newline at end of file
example/ev_nanomsg/iot.mk deleted 100644 → 0
View file @ 0580adb7
LIBA_TARGET := libev_nano_fnc.a
SRCS_example := server.c
$(call Append_Conditional, LIB_SRCS_EXCLUDE, ev_nanomsg.c)
$(call Append_Conditional, SRCS_ev-nano-demo, ev_nanomsg.c)
$(call Append_Conditional, TARGET, ev-nano-demo)
#CFLAGS += -I../../work/ssl/include -lrt
#LDFLAGS += -L../../work/ssl/lib
#DEPENDS += common/mqtt
LDFLAGS += -L$(TOP_DIR)/example/ev_nanomsg -static -lev -lnanomsg -lanl -ldl
example/ev_nanomsg/nanomsg/bus.h deleted 100644 → 0
View file @ 0580adb7
/*
Copyright (c) 2013 Martin Sustrik All rights reserved.
Permission is hereby granted, free of charge, to any person obtaining a copy
of this software and associated documentation files (the "Software"),
to deal in the Software without restriction, including without limitation
the rights to use, copy, modify, merge, publish, distribute, sublicense,
and/or sell copies of the Software, and to permit persons to whom
the Software is furnished to do so, subject to the following conditions:
The above copyright notice and this permission notice shall be included
in all copies or substantial portions of the Software.
THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS
IN THE SOFTWARE.
*/
#ifndef BUS_H_INCLUDED
#define BUS_H_INCLUDED
#ifdef __cplusplus
extern "C" {
#endif
#define NN_PROTO_BUS 7
#define NN_BUS (NN_PROTO_BUS * 16 + 0)
#ifdef __cplusplus
}
#endif
#endif
example/ev_nanomsg/nanomsg/inproc.h deleted 100644 → 0
View file @ 0580adb7
/*
Copyright (c) 2012 Martin Sustrik All rights reserved.
Permission is hereby granted, free of charge, to any person obtaining a copy
of this software and associated documentation files (the "Software"),
to deal in the Software without restriction, including without limitation
the rights to use, copy, modify, merge, publish, distribute, sublicense,
and/or sell copies of the Software, and to permit persons to whom
the Software is furnished to do so, subject to the following conditions:
The above copyright notice and this permission notice shall be included
in all copies or substantial portions of the Software.
THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS
IN THE SOFTWARE.
*/
#ifndef INPROC_H_INCLUDED
#define INPROC_H_INCLUDED
#ifdef __cplusplus
extern "C" {
#endif
#define NN_INPROC -1
#ifdef __cplusplus
}
#endif
#endif
example/ev_nanomsg/nanomsg/ipc.h deleted 100644 → 0
View file @ 0580adb7
/*
Copyright (c) 2012 Martin Sustrik All rights reserved.
Permission is hereby granted, free of charge, to any person obtaining a copy
of this software and associated documentation files (the "Software"),
to deal in the Software without restriction, including without limitation
the rights to use, copy, modify, merge, publish, distribute, sublicense,
and/or sell copies of the Software, and to permit persons to whom
the Software is furnished to do so, subject to the following conditions:
The above copyright notice and this permission notice shall be included
in all copies or substantial portions of the Software.
THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS
IN THE SOFTWARE.
*/
#ifndef IPC_H_INCLUDED
#define IPC_H_INCLUDED
#ifdef __cplusplus
extern "C" {
#endif
#define NN_IPC -2
/* The object set here must be valid as long as you are using the socket */
#define NN_IPC_SEC_ATTR 1
#define NN_IPC_OUTBUFSZ 2
#define NN_IPC_INBUFSZ 3
#ifdef __cplusplus
}
#endif
#endif
example/ev_nanomsg/nanomsg/pipeline.h deleted 100644 → 0
View file @ 0580adb7
/*
Copyright (c) 2012 Martin Sustrik All rights reserved.
Copyright (c) 2013 GoPivotal, Inc. All rights reserved.
Permission is hereby granted, free of charge, to any person obtaining a copy
of this software and associated documentation files (the "Software"),
to deal in the Software without restriction, including without limitation
the rights to use, copy, modify, merge, publish, distribute, sublicense,
and/or sell copies of the Software, and to permit persons to whom
the Software is furnished to do so, subject to the following conditions:
The above copyright notice and this permission notice shall be included
in all copies or substantial portions of the Software.
THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS
IN THE SOFTWARE.
*/
#ifndef PIPELINE_H_INCLUDED
#define PIPELINE_H_INCLUDED
#ifdef __cplusplus
extern "C" {
#endif
#define NN_PROTO_PIPELINE 5
#define NN_PUSH (NN_PROTO_PIPELINE * 16 + 0)
#define NN_PULL (NN_PROTO_PIPELINE * 16 + 1)
#ifdef __cplusplus
}
#endif
#endif
example/ev_nanomsg/nanomsg/protocol.h deleted 100644 → 0
View file @ 0580adb7
/*
Copyright (c) 2012-2013 Martin Sustrik All rights reserved.
Copyright 2016 Garrett D'Amore <garrett@damore.org>
Permission is hereby granted, free of charge, to any person obtaining a copy
of this software and associated documentation files (the "Software"),
to deal in the Software without restriction, including without limitation
the rights to use, copy, modify, merge, publish, distribute, sublicense,
and/or sell copies of the Software, and to permit persons to whom
the Software is furnished to do so, subject to the following conditions:
The above copyright notice and this permission notice shall be included
in all copies or substantial portions of the Software.
THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS
IN THE SOFTWARE.
*/
#ifndef NN_PROTOCOL_INCLUDED
#define NN_PROTOCOL_INCLUDED
#include "utils/msg.h"
#include "utils/list.h"
#include <stddef.h>
#include <stdint.h>
struct nn_ctx;
/******************************************************************************/
/* Pipe class. */
/******************************************************************************/
/* Any combination of following flags can be returned from successful call
to nn_pipe_send or nn_pipe_recv. */
/* This flag means that the pipe can't be used for receiving (when returned
from nn_pipe_recv()) or sending (when returned from nn_pipe_send()).
Protocol implementation should not send/recv messages from the pipe until
the pipe is revived by in()/out() function. */
#define NN_PIPE_RELEASE 1
/* Specifies that received message is already split into header and body.
This flag is used only by inproc transport to avoid merging and re-splitting
the messages passed with a single process. */
#define NN_PIPE_PARSED 2
/* Events generated by the pipe. */
#define NN_PIPE_IN 33987
#define NN_PIPE_OUT 33988
struct nn_pipe;
/* Associates opaque pointer to protocol-specific data with the pipe. */
void nn_pipe_setdata (struct nn_pipe *self, void *data);
/* Retrieves the opaque pointer associated with the pipe. */
void *nn_pipe_getdata (struct nn_pipe *self);
/* Send the message to the pipe. If successful, pipe takes ownership of the
messages. */
int nn_pipe_send (struct nn_pipe *self, struct nn_msg *msg);
/* Receive a message from a pipe. 'msg' should not be initialised prior to
the call. It will be initialised when the call succeeds. */
int nn_pipe_recv (struct nn_pipe *self, struct nn_msg *msg);
/* Get option for pipe. Mostly useful for endpoint-specific options */
void nn_pipe_getopt (struct nn_pipe *self, int level, int option,
void *optval, size_t *optvallen);
/******************************************************************************/
/* Base class for all socket types. */
/******************************************************************************/
struct nn_sockbase;
/* Any combination of these events can be returned from 'events' virtual
function. */
#define NN_SOCKBASE_EVENT_IN 1
#define NN_SOCKBASE_EVENT_OUT 2
/* To be implemented by individual socket types. */
struct nn_sockbase_vfptr {
/* Ask socket to stop. */
void (*stop) (struct nn_sockbase *self);
/* Deallocate the socket. */
void (*destroy) (struct nn_sockbase *self);
/* Management of pipes. 'add' registers a new pipe. The pipe cannot be used
to send to or to be received from at the moment. 'rm' unregisters the
pipe. The pipe should not be used after this call as it may already be
deallocated. 'in' informs the socket that pipe is readable. 'out'
informs it that it is writable. */
int (*add) (struct nn_sockbase *self, struct nn_pipe *pipe);
void (*rm) (struct nn_sockbase *self, struct nn_pipe *pipe);
void (*in) (struct nn_sockbase *self, struct nn_pipe *pipe);
void (*out) (struct nn_sockbase *self, struct nn_pipe *pipe);
/* Return any combination of event flags defined above, thus specifying
whether the socket should be readable, writable, both or none. */
int (*events) (struct nn_sockbase *self);
/* Send a message to the socket. Returns -EAGAIN if it cannot be done at
the moment or zero in case of success. */
int (*send) (struct nn_sockbase *self, struct nn_msg *msg);
/* Receive a message from the socket. Returns -EAGAIN if it cannot be done
at the moment or zero in case of success. */
int (*recv) (struct nn_sockbase *self, struct nn_msg *msg);
/* Set a protocol specific option. */
int (*setopt) (struct nn_sockbase *self, int level, int option,
const void *optval, size_t optvallen);
/* Retrieve a protocol specific option. */
int (*getopt) (struct nn_sockbase *self, int level, int option,
void *optval, size_t *optvallen);
};
struct nn_sockbase {
const struct nn_sockbase_vfptr *vfptr;
struct nn_sock *sock;
};
/* Initialise the socket base class. 'hint' is the opaque value passed to the
nn_transport's 'create' function. */
void nn_sockbase_init (struct nn_sockbase *self,
const struct nn_sockbase_vfptr *vfptr, void *hint);
/* Terminate the socket base class. */
void nn_sockbase_term (struct nn_sockbase *self);
/* Call this function when stopping is done. */
void nn_sockbase_stopped (struct nn_sockbase *self);
/* Returns the AIO context associated with the socket. This function is
useful when socket type implementation needs to create async objects,
such as timers. */
struct nn_ctx *nn_sockbase_getctx (struct nn_sockbase *self);
/* Retrieve a NN_SOL_SOCKET-level option. */
int nn_sockbase_getopt (struct nn_sockbase *self, int option,
void *optval, size_t *optvallen);
/* Add some statistics for socket */
void nn_sockbase_stat_increment (struct nn_sockbase *self, int name,
int increment);
/******************************************************************************/
/* The socktype class. */
/******************************************************************************/
/* This structure defines a class factory for individual socket types. */
/* Specifies that the socket type can be never used to receive messages. */
#define NN_SOCKTYPE_FLAG_NORECV 1
/* Specifies that the socket type can be never used to send messages. */
#define NN_SOCKTYPE_FLAG_NOSEND 2
struct nn_socktype {
/* Domain and protocol IDs as specified in nn_socket() function. */
int domain;
int protocol;
/* Any combination of the flags defined above. */
int flags;
/* Function to create specific socket type. 'sockbase' is the output
parameter to return reference to newly created socket. This function
is called under global lock, so it is not possible that two sockets are
being created in parallel. */
int (*create) (void *hint, struct nn_sockbase **sockbase);
/* Returns 1 if the supplied socket type is a valid peer for this socket,
0 otherwise. Note that the validation is done only within a single
SP protocol. Peers speaking other SP protocols are discarded by the
core and socket is not even asked to validate them. */
int (*ispeer) (int socktype);
};
#endif
example/ev_nanomsg/nanomsg/pubsub.h deleted 100644 → 0
View file @ 0580adb7
/*
Copyright (c) 2012 Martin Sustrik All rights reserved.
Permission is hereby granted, free of charge, to any person obtaining a copy
of this software and associated documentation files (the "Software"),
to deal in the Software without restriction, including without limitation
the rights to use, copy, modify, merge, publish, distribute, sublicense,
and/or sell copies of the Software, and to permit persons to whom
the Software is furnished to do so, subject to the following conditions:
The above copyright notice and this permission notice shall be included
in all copies or substantial portions of the Software.
THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS
IN THE SOFTWARE.
*/
#ifndef PUBSUB_H_INCLUDED
#define PUBSUB_H_INCLUDED
#ifdef __cplusplus
extern "C" {
#endif
#define NN_PROTO_PUBSUB 2
#define NN_PUB (NN_PROTO_PUBSUB * 16 + 0)
#define NN_SUB (NN_PROTO_PUBSUB * 16 + 1)
#define NN_SUB_SUBSCRIBE 1
#define NN_SUB_UNSUBSCRIBE 2
#ifdef __cplusplus
}
#endif
#endif
example/ev_nanomsg/nanomsg/reqrep.h deleted 100644 → 0
View file @ 0580adb7
/*
Copyright (c) 2012 Martin Sustrik All rights reserved.
Copyright 2016 Garrett D'Amore <garrett@damore.org>
Permission is hereby granted, free of charge, to any person obtaining a copy
of this software and associated documentation files (the "Software"),
to deal in the Software without restriction, including without limitation
the rights to use, copy, modify, merge, publish, distribute, sublicense,
and/or sell copies of the Software, and to permit persons to whom
the Software is furnished to do so, subject to the following conditions:
The above copyright notice and this permission notice shall be included
in all copies or substantial portions of the Software.
THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS
IN THE SOFTWARE.
*/
#ifndef REQREP_H_INCLUDED
#define REQREP_H_INCLUDED
#include "nn.h"
#ifdef __cplusplus
extern "C" {
#endif
#define NN_PROTO_REQREP 3
#define NN_REQ (NN_PROTO_REQREP * 16 + 0)
#define NN_REP (NN_PROTO_REQREP * 16 + 1)
#define NN_REQ_RESEND_IVL 1
typedef union nn_req_handle {
int i;
void *ptr;
} nn_req_handle;
#ifdef __cplusplus
}
#endif
#endif
example/ev_nanomsg/nanomsg/survey.h deleted 100644 → 0
View file @ 0580adb7
/*
Copyright (c) 2012 Martin Sustrik All rights reserved.
Copyright 2015 Garrett D'Amore <garrett@damore.org>
Permission is hereby granted, free of charge, to any person obtaining a copy
of this software and associated documentation files (the "Software"),
to deal in the Software without restriction, including without limitation
the rights to use, copy, modify, merge, publish, distribute, sublicense,
and/or sell copies of the Software, and to permit persons to whom
the Software is furnished to do so, subject to the following conditions:
The above copyright notice and this permission notice shall be included
in all copies or substantial portions of the Software.
THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS
IN THE SOFTWARE.
*/
#ifndef SURVEY_H_INCLUDED
#define SURVEY_H_INCLUDED
#ifdef __cplusplus
extern "C" {
#endif
#define NN_PROTO_SURVEY 6
/* NB: Version 0 used 16 + 0/1. That version lacked backtraces, and so
is wire-incompatible with this version. */
#define NN_SURVEYOR (NN_PROTO_SURVEY * 16 + 2)
#define NN_RESPONDENT (NN_PROTO_SURVEY * 16 + 3)
#define NN_SURVEYOR_DEADLINE 1
#ifdef __cplusplus
}
#endif
#endif
example/ev_nanomsg/nanomsg/tcp.h deleted 100644 → 0
View file @ 0580adb7
/*
Copyright (c) 2012 Martin Sustrik All rights reserved.
Permission is hereby granted, free of charge, to any person obtaining a copy
of this software and associated documentation files (the "Software"),
to deal in the Software without restriction, including without limitation
the rights to use, copy, modify, merge, publish, distribute, sublicense,
and/or sell copies of the Software, and to permit persons to whom
the Software is furnished to do so, subject to the following conditions:
The above copyright notice and this permission notice shall be included
in all copies or substantial portions of the Software.
THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS
IN THE SOFTWARE.
*/
#ifndef TCP_H_INCLUDED
#define TCP_H_INCLUDED
#ifdef __cplusplus
extern "C" {
#endif
#define NN_TCP -3
#define NN_TCP_NODELAY 1
#ifdef __cplusplus
}
#endif
#endif
example/ev_nanomsg/nanomsg/transport.h deleted 100644 → 0
View file @ 0580adb7
/*
Copyright (c) 2012-2014 Martin Sustrik All rights reserved.
Copyright (c) 2013 GoPivotal, Inc. All rights reserved.
Copyright 2016 Garrett D'Amore <garrett@damore.org>
Permission is hereby granted, free of charge, to any person obtaining a copy
of this software and associated documentation files (the "Software"),
to deal in the Software without restriction, including without limitation
the rights to use, copy, modify, merge, publish, distribute, sublicense,
and/or sell copies of the Software, and to permit persons to whom
the Software is furnished to do so, subject to the following conditions:
The above copyright notice and this permission notice shall be included
in all copies or substantial portions of the Software.
THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS
IN THE SOFTWARE.
*/
#ifndef NN_TRANSPORT_INCLUDED
#define NN_TRANSPORT_INCLUDED
#include "nn.h"
#include "aio/fsm.h"
#include "utils/list.h"
#include "utils/msg.h"
#include <stddef.h>
/* This is the API between the nanomsg core and individual transports. */
struct nn_sock;
/******************************************************************************/
/* Container for transport-specific socket options. */
/******************************************************************************/
struct nn_optset;
struct nn_optset_vfptr {
void (*destroy) (struct nn_optset *self);
int (*setopt) (struct nn_optset *self, int option, const void *optval,
size_t optvallen);
int (*getopt) (struct nn_optset *self, int option, void *optval,
size_t *optvallen);
};
struct nn_optset {
const struct nn_optset_vfptr *vfptr;
};
/******************************************************************************/
/* The base class for endpoints. */
/******************************************************************************/
/* The best way to think about endpoints is that endpoint is an object created
by each nn_bind() or nn_connect() call. Each endpoint is associated with
exactly one address string (e.g. "tcp://127.0.0.1:5555"). */
struct nn_ep;
struct nn_ep_ops {
/* Ask the endpoint to stop itself. The endpoint is allowed to linger
to send the pending outbound data. When done, it reports the fact by
invoking nn_ep_stopped() function. */
void (*stop) (void *);
/* Deallocate the endpoint object. It will already have been stopped. */
void (*destroy) (void *);
};
/* Set up an ep for use by a transport. The final opaque argument is passed
as the first argument to the ops entry points. */
void nn_ep_tran_setup (struct nn_ep *, const struct nn_ep_ops *, void *);
/* Notify the user that stopping is done. */
void nn_ep_stopped (struct nn_ep *);
/* Returns the AIO context associated with the endpoint. */
struct nn_ctx *nn_ep_getctx (struct nn_ep *);
/* Returns the address string associated with this endpoint. */
const char *nn_ep_getaddr (struct nn_ep *self);
/* Retrieve value of a socket option. */
void nn_ep_getopt (struct nn_ep *, int level, int option,
void *optval, size_t *optvallen);
/* Returns 1 if the specified socket type is a valid peer for this socket,
or 0 otherwise. */
int nn_ep_ispeer (struct nn_ep *, int socktype);
/* Returns 1 if the ep's are valid peers for each other, 0 otherwise. */
int nn_ep_ispeer_ep (struct nn_ep *, struct nn_ep *);
/* Notifies a monitoring system the error on this endpoint */
void nn_ep_set_error(struct nn_ep*, int errnum);
/* Notifies a monitoring system that error is gone */
void nn_ep_clear_error(struct nn_ep *);
/* Increments statistics counters in the socket structure */
void nn_ep_stat_increment(struct nn_ep *, int name, int increment);
/******************************************************************************/
/* The base class for pipes. */
/******************************************************************************/
/* Pipe represents one "connection", i.e. perfectly ordered uni- or
bi-directional stream of messages. One endpoint can create multiple pipes
(for example, bound TCP socket is an endpoint, individual accepted TCP
connections are represented by pipes. */
struct nn_pipebase;
/* This value is returned by pipe's send and recv functions to signalise that
more sends/recvs are not possible at the moment. From that moment on,
the core will stop invoking the function. To re-establish the message
flow nn_pipebase_received (respectively nn_pipebase_sent) should
be called. */
#define NN_PIPEBASE_RELEASE 1
/* Specifies that received message is already split into header and body.
This flag is used only by inproc transport to avoid merging and re-splitting
the messages passed with a single process. */
#define NN_PIPEBASE_PARSED 2
struct nn_pipebase_vfptr {
/* Send a message to the network. The function can return either error
(negative number) or any combination of the flags defined above. */
int (*send) (struct nn_pipebase *self, struct nn_msg *msg);
/* Receive a message from the network. The function can return either error
(negative number) or any combination of the flags defined above. */
int (*recv) (struct nn_pipebase *self, struct nn_msg *msg);
};
/* Endpoint specific options. Same restrictions as for nn_pipebase apply */
struct nn_ep_options
{
int sndprio;
int rcvprio;
int ipv4only;
};
/* The member of this structure are used internally by the core. Never use
or modify them directly from the transport. */
struct nn_pipebase {
struct nn_fsm fsm;
const struct nn_pipebase_vfptr *vfptr;
uint8_t state;
uint8_t instate;
uint8_t outstate;
struct nn_sock *sock;
void *data;
struct nn_fsm_event in;
struct nn_fsm_event out;
struct nn_ep_options options;
};
/* Initialise the pipe. */
void nn_pipebase_init (struct nn_pipebase *self,
const struct nn_pipebase_vfptr *vfptr, struct nn_ep *ep);
/* Terminate the pipe. */
void nn_pipebase_term (struct nn_pipebase *self);
/* Call this function once the connection is established. */
int nn_pipebase_start (struct nn_pipebase *self);
/* Call this function once the connection is broken. */
void nn_pipebase_stop (struct nn_pipebase *self);
/* Call this function when new message was fully received. */
void nn_pipebase_received (struct nn_pipebase *self);
/* Call this function when current outgoing message was fully sent. */
void nn_pipebase_sent (struct nn_pipebase *self);
/* Retrieve value of a socket option. */
void nn_pipebase_getopt (struct nn_pipebase *self, int level, int option,
void *optval, size_t *optvallen);
/* Returns 1 is the specified socket type is a valid peer for this socket,
or 0 otherwise. */
int nn_pipebase_ispeer (struct nn_pipebase *self, int socktype);
/******************************************************************************/
/* The transport class. */
/******************************************************************************/
struct nn_transport {
/* Name of the transport as it appears in the connection strings ("tcp",
"ipc", "inproc" etc. */
const char *name;
/* ID of the transport. */
int id;
/* Following methods are guarded by a global critical section. Two of these
function will never be invoked in parallel. The first is called when
the library is initialised, the second one when it is terminated, i.e.
when there are no more open sockets. Either of them can be set to NULL
if no specific initialisation/termination is needed. */
void (*init) (void);
void (*term) (void);
/* Each of these functions creates an endpoint and sets up the newly
established endpoint in 'ep' parameter using nn_ep_tran_setup ().
These functions are guarded by a socket-wide critical section.
Two of these function will never be invoked in parallel on the same
socket. */
int (*bind) (struct nn_ep *);
int (*connect) (struct nn_ep *);
/* Create an object to hold transport-specific socket options.
Set this member to NULL in case there are no transport-specific
socket options available. */
struct nn_optset *(*optset) (void);
};
#endif
example/ev_nanomsg/nanomsg/ws.h deleted 100644 → 0
View file @ 0580adb7
/*
Copyright (c) 2012 250bpm s.r.o. All rights reserved.
Copyright (c) 2014 Wirebird Labs LLC. All rights reserved.
Copyright 2015 Garrett D'Amore <garrett@damore.org>
Permission is hereby granted, free of charge, to any person obtaining a copy
of this software and associated documentation files (the "Software"),
to deal in the Software without restriction, including without limitation
the rights to use, copy, modify, merge, publish, distribute, sublicense,
and/or sell copies of the Software, and to permit persons to whom
the Software is furnished to do so, subject to the following conditions:
The above copyright notice and this permission notice shall be included
in all copies or substantial portions of the Software.
THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS
IN THE SOFTWARE.
*/
#ifndef WS_H_INCLUDED
#define WS_H_INCLUDED
#include "nn.h"
#ifdef __cplusplus
extern "C" {
#endif
#define NN_WS -4
/* NN_WS level socket/cmsg options. Note that only NN_WSMG_TYPE_TEXT and
NN_WS_MSG_TYPE_BINARY messages are supported fully by this implementation.
Attempting to set other message types is undefined. */
#define NN_WS_MSG_TYPE 1
/* WebSocket opcode constants as per RFC 6455 5.2 */
#define NN_WS_MSG_TYPE_TEXT 0x01
#define NN_WS_MSG_TYPE_BINARY 0x02
#ifdef __cplusplus
}
#endif
#endif
example/nanomsg/bus.c deleted 100644 → 0
View file @ 0580adb7
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <nanomsg/nn.h>
#include <nanomsg/bus.h>
void
fatal(const char *func)
{
fprintf(stderr, "%s: %s\n", func, nn_strerror(nn_errno()));
exit(1);
}
int
node(const int argc, const char **argv)
{
int sock;
if ((sock = nn_socket (AF_SP, NN_BUS)) < 0) {
fatal("nn_socket");
}
if (nn_bind(sock, argv[2]) < 0) {
fatal("nn_bind");
}
sleep(1); // wait for peers to bind
if (argc >= 3) {
for (int x = 3; x < argc; x++) {
if (nn_connect(sock, argv[x]) < 0) {
fatal("nn_connect");
}
}
}
sleep(1); // wait for connections
int to = 100;
if (nn_setsockopt(sock, NN_SOL_SOCKET, NN_RCVTIMEO, &to,
sizeof (to)) < 0) {
fatal("nn_setsockopt");
}
// SEND
int sz_n = strlen(argv[1]) + 1; // '\0' too
printf("%s: SENDING '%s' ONTO BUS\n", argv[1], argv[1]);
if (nn_send(sock, argv[1], sz_n, 0) < 0) {
fatal("nn_send");
}
// RECV
for (;;) {
char *buf = NULL;
int recv = nn_recv(sock, &buf, NN_MSG, 0);
if (recv >= 0) {
printf("%s: RECEIVED '%s' FROM BUS\n", argv[1], buf);
nn_freemsg(buf);
}
}
return (nn_shutdown(sock, 0));
}
int
main(int argc, const char **argv)
{
if (argc >= 3) {
return (node(argc, argv));
}
fprintf(stderr, "Usage: bus <NODE_NAME> <URL> <URL> ...\n");
return 1;
}
example/nanomsg/iot.mk deleted 100644 → 0
View file @ 0580adb7
LIBA_TARGET := libnanomsg_fnc.a
SRCS_example := pair.c
$(call Append_Conditional, LIB_SRCS_EXCLUDE, bus.c)
$(call Append_Conditional, SRCS_bus, bus.c)
$(call Append_Conditional, TARGET, bus)
$(call Append_Conditional, LIB_SRCS_EXCLUDE, pair.c)
$(call Append_Conditional, SRCS_pair, pair.c)
$(call Append_Conditional, TARGET, pair)
$(call Append_Conditional, LIB_SRCS_EXCLUDE, pipeline.c)
$(call Append_Conditional, SRCS_pipeline, pipeline.c)
$(call Append_Conditional, TARGET, pipeline)
$(call Append_Conditional, LIB_SRCS_EXCLUDE, pubsub.c)
$(call Append_Conditional, SRCS_pubsub, pubsub.c)
$(call Append_Conditional, TARGET, pubsub)
$(call Append_Conditional, LIB_SRCS_EXCLUDE, reqrep.c)
$(call Append_Conditional, SRCS_reqrep, reqrep.c)
$(call Append_Conditional, TARGET, reqrep)
$(call Append_Conditional, LIB_SRCS_EXCLUDE, survey.c)
$(call Append_Conditional, SRCS_survey, survey.c)
$(call Append_Conditional, TARGET, survey)
#CFLAGS += -I../../work/ssl/include -lrt
#LDFLAGS += -L../../work/ssl/lib
#DEPENDS += common/mqtt
LDFLAGS += -L$(TOP_DIR)/example/nanomsg -static -lnanomsg -lanl
example/nanomsg/nanamsg例子.pdf deleted 100644 → 0
View file @ 0580adb7
This diff is collapsed.
example/nanomsg/nanomsg/bus.h deleted 100644 → 0
View file @ 0580adb7
/*
Copyright (c) 2013 Martin Sustrik All rights reserved.
Permission is hereby granted, free of charge, to any person obtaining a copy
of this software and associated documentation files (the "Software"),
to deal in the Software without restriction, including without limitation
the rights to use, copy, modify, merge, publish, distribute, sublicense,
and/or sell copies of the Software, and to permit persons to whom
the Software is furnished to do so, subject to the following conditions:
The above copyright notice and this permission notice shall be included
in all copies or substantial portions of the Software.
THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS
IN THE SOFTWARE.
*/
#ifndef BUS_H_INCLUDED
#define BUS_H_INCLUDED
#ifdef __cplusplus
extern "C" {
#endif
#define NN_PROTO_BUS 7
#define NN_BUS (NN_PROTO_BUS * 16 + 0)
#ifdef __cplusplus
}
#endif
#endif
example/nanomsg/nanomsg/inproc.h deleted 100644 → 0
View file @ 0580adb7
/*
Copyright (c) 2012 Martin Sustrik All rights reserved.
Permission is hereby granted, free of charge, to any person obtaining a copy
of this software and associated documentation files (the "Software"),
to deal in the Software without restriction, including without limitation
the rights to use, copy, modify, merge, publish, distribute, sublicense,
and/or sell copies of the Software, and to permit persons to whom
the Software is furnished to do so, subject to the following conditions:
The above copyright notice and this permission notice shall be included
in all copies or substantial portions of the Software.
THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS
IN THE SOFTWARE.
*/
#ifndef INPROC_H_INCLUDED
#define INPROC_H_INCLUDED
#ifdef __cplusplus
extern "C" {
#endif
#define NN_INPROC -1
#ifdef __cplusplus
}
#endif
#endif
example/nanomsg/nanomsg/ipc.h deleted 100644 → 0
View file @ 0580adb7
/*
Copyright (c) 2012 Martin Sustrik All rights reserved.
Permission is hereby granted, free of charge, to any person obtaining a copy
of this software and associated documentation files (the "Software"),
to deal in the Software without restriction, including without limitation
the rights to use, copy, modify, merge, publish, distribute, sublicense,
and/or sell copies of the Software, and to permit persons to whom
the Software is furnished to do so, subject to the following conditions:
The above copyright notice and this permission notice shall be included
in all copies or substantial portions of the Software.
THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS
IN THE SOFTWARE.
*/
#ifndef IPC_H_INCLUDED
#define IPC_H_INCLUDED
#ifdef __cplusplus
extern "C" {
#endif
#define NN_IPC -2
/* The object set here must be valid as long as you are using the socket */
#define NN_IPC_SEC_ATTR 1
#define NN_IPC_OUTBUFSZ 2
#define NN_IPC_INBUFSZ 3
#ifdef __cplusplus
}
#endif
#endif
example/nanomsg/nanomsg/nn.h deleted 100644 → 0
View file @ 0580adb7
This diff is collapsed.
example/nanomsg/nanomsg/pair.h deleted 100644 → 0
View file @ 0580adb7
/*
Copyright (c) 2012 Martin Sustrik All rights reserved.
Permission is hereby granted, free of charge, to any person obtaining a copy
of this software and associated documentation files (the "Software"),
to deal in the Software without restriction, including without limitation
the rights to use, copy, modify, merge, publish, distribute, sublicense,
and/or sell copies of the Software, and to permit persons to whom
the Software is furnished to do so, subject to the following conditions:
The above copyright notice and this permission notice shall be included
in all copies or substantial portions of the Software.
THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS
IN THE SOFTWARE.
*/
#ifndef PAIR_H_INCLUDED
#define PAIR_H_INCLUDED
#ifdef __cplusplus
extern "C" {
#endif
#define NN_PROTO_PAIR 1
#define NN_PAIR (NN_PROTO_PAIR * 16 + 0)
#ifdef __cplusplus
}
#endif
#endif
example/nanomsg/nanomsg/pipeline.h deleted 100644 → 0
View file @ 0580adb7
/*
Copyright (c) 2012 Martin Sustrik All rights reserved.
Copyright (c) 2013 GoPivotal, Inc. All rights reserved.
Permission is hereby granted, free of charge, to any person obtaining a copy
of this software and associated documentation files (the "Software"),
to deal in the Software without restriction, including without limitation
the rights to use, copy, modify, merge, publish, distribute, sublicense,
and/or sell copies of the Software, and to permit persons to whom
the Software is furnished to do so, subject to the following conditions:
The above copyright notice and this permission notice shall be included
in all copies or substantial portions of the Software.
THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS
IN THE SOFTWARE.
*/
#ifndef PIPELINE_H_INCLUDED
#define PIPELINE_H_INCLUDED
#ifdef __cplusplus
extern "C" {
#endif
#define NN_PROTO_PIPELINE 5
#define NN_PUSH (NN_PROTO_PIPELINE * 16 + 0)
#define NN_PULL (NN_PROTO_PIPELINE * 16 + 1)
#ifdef __cplusplus
}
#endif
#endif
example/nanomsg/nanomsg/protocol.h deleted 100644 → 0
View file @ 0580adb7
/*
Copyright (c) 2012-2013 Martin Sustrik All rights reserved.
Copyright 2016 Garrett D'Amore <garrett@damore.org>
Permission is hereby granted, free of charge, to any person obtaining a copy
of this software and associated documentation files (the "Software"),
to deal in the Software without restriction, including without limitation
the rights to use, copy, modify, merge, publish, distribute, sublicense,
and/or sell copies of the Software, and to permit persons to whom
the Software is furnished to do so, subject to the following conditions:
The above copyright notice and this permission notice shall be included
in all copies or substantial portions of the Software.
THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS
IN THE SOFTWARE.
*/
#ifndef NN_PROTOCOL_INCLUDED
#define NN_PROTOCOL_INCLUDED
#include "utils/msg.h"
#include "utils/list.h"
#include <stddef.h>
#include <stdint.h>
struct nn_ctx;
/******************************************************************************/
/* Pipe class. */
/******************************************************************************/
/* Any combination of following flags can be returned from successful call
to nn_pipe_send or nn_pipe_recv. */
/* This flag means that the pipe can't be used for receiving (when returned
from nn_pipe_recv()) or sending (when returned from nn_pipe_send()).
Protocol implementation should not send/recv messages from the pipe until
the pipe is revived by in()/out() function. */
#define NN_PIPE_RELEASE 1
/* Specifies that received message is already split into header and body.
This flag is used only by inproc transport to avoid merging and re-splitting
the messages passed with a single process. */
#define NN_PIPE_PARSED 2
/* Events generated by the pipe. */
#define NN_PIPE_IN 33987
#define NN_PIPE_OUT 33988
struct nn_pipe;
/* Associates opaque pointer to protocol-specific data with the pipe. */
void nn_pipe_setdata (struct nn_pipe *self, void *data);
/* Retrieves the opaque pointer associated with the pipe. */
void *nn_pipe_getdata (struct nn_pipe *self);
/* Send the message to the pipe. If successful, pipe takes ownership of the
messages. */
int nn_pipe_send (struct nn_pipe *self, struct nn_msg *msg);
/* Receive a message from a pipe. 'msg' should not be initialised prior to
the call. It will be initialised when the call succeeds. */
int nn_pipe_recv (struct nn_pipe *self, struct nn_msg *msg);
/* Get option for pipe. Mostly useful for endpoint-specific options */
void nn_pipe_getopt (struct nn_pipe *self, int level, int option,
void *optval, size_t *optvallen);
/******************************************************************************/
/* Base class for all socket types. */
/******************************************************************************/
struct nn_sockbase;
/* Any combination of these events can be returned from 'events' virtual
function. */
#define NN_SOCKBASE_EVENT_IN 1
#define NN_SOCKBASE_EVENT_OUT 2
/* To be implemented by individual socket types. */
struct nn_sockbase_vfptr {
/* Ask socket to stop. */
void (*stop) (struct nn_sockbase *self);
/* Deallocate the socket. */
void (*destroy) (struct nn_sockbase *self);
/* Management of pipes. 'add' registers a new pipe. The pipe cannot be used
to send to or to be received from at the moment. 'rm' unregisters the
pipe. The pipe should not be used after this call as it may already be
deallocated. 'in' informs the socket that pipe is readable. 'out'
informs it that it is writable. */
int (*add) (struct nn_sockbase *self, struct nn_pipe *pipe);
void (*rm) (struct nn_sockbase *self, struct nn_pipe *pipe);
void (*in) (struct nn_sockbase *self, struct nn_pipe *pipe);
void (*out) (struct nn_sockbase *self, struct nn_pipe *pipe);
/* Return any combination of event flags defined above, thus specifying
whether the socket should be readable, writable, both or none. */
int (*events) (struct nn_sockbase *self);
/* Send a message to the socket. Returns -EAGAIN if it cannot be done at
the moment or zero in case of success. */
int (*send) (struct nn_sockbase *self, struct nn_msg *msg);
/* Receive a message from the socket. Returns -EAGAIN if it cannot be done
at the moment or zero in case of success. */
int (*recv) (struct nn_sockbase *self, struct nn_msg *msg);
/* Set a protocol specific option. */
int (*setopt) (struct nn_sockbase *self, int level, int option,
const void *optval, size_t optvallen);
/* Retrieve a protocol specific option. */
int (*getopt) (struct nn_sockbase *self, int level, int option,
void *optval, size_t *optvallen);
};
struct nn_sockbase {
const struct nn_sockbase_vfptr *vfptr;
struct nn_sock *sock;
};
/* Initialise the socket base class. 'hint' is the opaque value passed to the
nn_transport's 'create' function. */
void nn_sockbase_init (struct nn_sockbase *self,
const struct nn_sockbase_vfptr *vfptr, void *hint);
/* Terminate the socket base class. */
void nn_sockbase_term (struct nn_sockbase *self);
/* Call this function when stopping is done. */
void nn_sockbase_stopped (struct nn_sockbase *self);
/* Returns the AIO context associated with the socket. This function is
useful when socket type implementation needs to create async objects,
such as timers. */
struct nn_ctx *nn_sockbase_getctx (struct nn_sockbase *self);
/* Retrieve a NN_SOL_SOCKET-level option. */
int nn_sockbase_getopt (struct nn_sockbase *self, int option,
void *optval, size_t *optvallen);
/* Add some statistics for socket */
void nn_sockbase_stat_increment (struct nn_sockbase *self, int name,
int increment);
/******************************************************************************/
/* The socktype class. */
/******************************************************************************/
/* This structure defines a class factory for individual socket types. */
/* Specifies that the socket type can be never used to receive messages. */
#define NN_SOCKTYPE_FLAG_NORECV 1
/* Specifies that the socket type can be never used to send messages. */
#define NN_SOCKTYPE_FLAG_NOSEND 2
struct nn_socktype {
/* Domain and protocol IDs as specified in nn_socket() function. */
int domain;
int protocol;
/* Any combination of the flags defined above. */
int flags;
/* Function to create specific socket type. 'sockbase' is the output
parameter to return reference to newly created socket. This function
is called under global lock, so it is not possible that two sockets are
being created in parallel. */
int (*create) (void *hint, struct nn_sockbase **sockbase);
/* Returns 1 if the supplied socket type is a valid peer for this socket,
0 otherwise. Note that the validation is done only within a single
SP protocol. Peers speaking other SP protocols are discarded by the
core and socket is not even asked to validate them. */
int (*ispeer) (int socktype);
};
#endif
example/nanomsg/nanomsg/pubsub.h deleted 100644 → 0
View file @ 0580adb7
/*
Copyright (c) 2012 Martin Sustrik All rights reserved.
Permission is hereby granted, free of charge, to any person obtaining a copy
of this software and associated documentation files (the "Software"),
to deal in the Software without restriction, including without limitation
the rights to use, copy, modify, merge, publish, distribute, sublicense,
and/or sell copies of the Software, and to permit persons to whom
the Software is furnished to do so, subject to the following conditions:
The above copyright notice and this permission notice shall be included
in all copies or substantial portions of the Software.
THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS
IN THE SOFTWARE.
*/
#ifndef PUBSUB_H_INCLUDED
#define PUBSUB_H_INCLUDED
#ifdef __cplusplus
extern "C" {
#endif
#define NN_PROTO_PUBSUB 2
#define NN_PUB (NN_PROTO_PUBSUB * 16 + 0)
#define NN_SUB (NN_PROTO_PUBSUB * 16 + 1)
#define NN_SUB_SUBSCRIBE 1
#define NN_SUB_UNSUBSCRIBE 2
#ifdef __cplusplus
}
#endif
#endif
example/nanomsg/nanomsg/reqrep.h deleted 100644 → 0
View file @ 0580adb7
/*
Copyright (c) 2012 Martin Sustrik All rights reserved.
Copyright 2016 Garrett D'Amore <garrett@damore.org>
Permission is hereby granted, free of charge, to any person obtaining a copy
of this software and associated documentation files (the "Software"),
to deal in the Software without restriction, including without limitation
the rights to use, copy, modify, merge, publish, distribute, sublicense,
and/or sell copies of the Software, and to permit persons to whom
the Software is furnished to do so, subject to the following conditions:
The above copyright notice and this permission notice shall be included
in all copies or substantial portions of the Software.
THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS
IN THE SOFTWARE.
*/
#ifndef REQREP_H_INCLUDED
#define REQREP_H_INCLUDED
#include "nn.h"
#ifdef __cplusplus
extern "C" {
#endif
#define NN_PROTO_REQREP 3
#define NN_REQ (NN_PROTO_REQREP * 16 + 0)
#define NN_REP (NN_PROTO_REQREP * 16 + 1)
#define NN_REQ_RESEND_IVL 1
typedef union nn_req_handle {
int i;
void *ptr;
} nn_req_handle;
#ifdef __cplusplus
}
#endif
#endif
example/nanomsg/nanomsg/survey.h deleted 100644 → 0
View file @ 0580adb7
/*
Copyright (c) 2012 Martin Sustrik All rights reserved.
Copyright 2015 Garrett D'Amore <garrett@damore.org>
Permission is hereby granted, free of charge, to any person obtaining a copy
of this software and associated documentation files (the "Software"),
to deal in the Software without restriction, including without limitation
the rights to use, copy, modify, merge, publish, distribute, sublicense,
and/or sell copies of the Software, and to permit persons to whom
the Software is furnished to do so, subject to the following conditions:
The above copyright notice and this permission notice shall be included
in all copies or substantial portions of the Software.
THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS
IN THE SOFTWARE.
*/
#ifndef SURVEY_H_INCLUDED
#define SURVEY_H_INCLUDED
#ifdef __cplusplus
extern "C" {
#endif
#define NN_PROTO_SURVEY 6
/* NB: Version 0 used 16 + 0/1. That version lacked backtraces, and so
is wire-incompatible with this version. */
#define NN_SURVEYOR (NN_PROTO_SURVEY * 16 + 2)
#define NN_RESPONDENT (NN_PROTO_SURVEY * 16 + 3)
#define NN_SURVEYOR_DEADLINE 1
#ifdef __cplusplus
}
#endif
#endif
example/nanomsg/nanomsg/tcp.h deleted 100644 → 0
View file @ 0580adb7
/*
Copyright (c) 2012 Martin Sustrik All rights reserved.
Permission is hereby granted, free of charge, to any person obtaining a copy
of this software and associated documentation files (the "Software"),
to deal in the Software without restriction, including without limitation
the rights to use, copy, modify, merge, publish, distribute, sublicense,
and/or sell copies of the Software, and to permit persons to whom
the Software is furnished to do so, subject to the following conditions:
The above copyright notice and this permission notice shall be included
in all copies or substantial portions of the Software.
THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS
IN THE SOFTWARE.
*/
#ifndef TCP_H_INCLUDED
#define TCP_H_INCLUDED
#ifdef __cplusplus
extern "C" {
#endif
#define NN_TCP -3
#define NN_TCP_NODELAY 1
#ifdef __cplusplus
}
#endif
#endif
example/nanomsg/nanomsg/transport.h deleted 100644 → 0
View file @ 0580adb7
/*
Copyright (c) 2012-2014 Martin Sustrik All rights reserved.
Copyright (c) 2013 GoPivotal, Inc. All rights reserved.
Copyright 2016 Garrett D'Amore <garrett@damore.org>
Permission is hereby granted, free of charge, to any person obtaining a copy
of this software and associated documentation files (the "Software"),
to deal in the Software without restriction, including without limitation
the rights to use, copy, modify, merge, publish, distribute, sublicense,
and/or sell copies of the Software, and to permit persons to whom
the Software is furnished to do so, subject to the following conditions:
The above copyright notice and this permission notice shall be included
in all copies or substantial portions of the Software.
THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS
IN THE SOFTWARE.
*/
#ifndef NN_TRANSPORT_INCLUDED
#define NN_TRANSPORT_INCLUDED
#include "nn.h"
#include "aio/fsm.h"
#include "utils/list.h"
#include "utils/msg.h"
#include <stddef.h>
/* This is the API between the nanomsg core and individual transports. */
struct nn_sock;
/******************************************************************************/
/* Container for transport-specific socket options. */
/******************************************************************************/
struct nn_optset;
struct nn_optset_vfptr {
void (*destroy) (struct nn_optset *self);
int (*setopt) (struct nn_optset *self, int option, const void *optval,
size_t optvallen);
int (*getopt) (struct nn_optset *self, int option, void *optval,
size_t *optvallen);
};
struct nn_optset {
const struct nn_optset_vfptr *vfptr;
};
/******************************************************************************/
/* The base class for endpoints. */
/******************************************************************************/
/* The best way to think about endpoints is that endpoint is an object created
by each nn_bind() or nn_connect() call. Each endpoint is associated with
exactly one address string (e.g. "tcp://127.0.0.1:5555"). */
struct nn_ep;
struct nn_ep_ops {
/* Ask the endpoint to stop itself. The endpoint is allowed to linger
to send the pending outbound data. When done, it reports the fact by
invoking nn_ep_stopped() function. */
void (*stop) (void *);
/* Deallocate the endpoint object. It will already have been stopped. */
void (*destroy) (void *);
};
/* Set up an ep for use by a transport. The final opaque argument is passed
as the first argument to the ops entry points. */
void nn_ep_tran_setup (struct nn_ep *, const struct nn_ep_ops *, void *);
/* Notify the user that stopping is done. */
void nn_ep_stopped (struct nn_ep *);
/* Returns the AIO context associated with the endpoint. */
struct nn_ctx *nn_ep_getctx (struct nn_ep *);
/* Returns the address string associated with this endpoint. */
const char *nn_ep_getaddr (struct nn_ep *self);
/* Retrieve value of a socket option. */
void nn_ep_getopt (struct nn_ep *, int level, int option,
void *optval, size_t *optvallen);
/* Returns 1 if the specified socket type is a valid peer for this socket,
or 0 otherwise. */
int nn_ep_ispeer (struct nn_ep *, int socktype);
/* Returns 1 if the ep's are valid peers for each other, 0 otherwise. */
int nn_ep_ispeer_ep (struct nn_ep *, struct nn_ep *);
/* Notifies a monitoring system the error on this endpoint */
void nn_ep_set_error(struct nn_ep*, int errnum);
/* Notifies a monitoring system that error is gone */
void nn_ep_clear_error(struct nn_ep *);
/* Increments statistics counters in the socket structure */
void nn_ep_stat_increment(struct nn_ep *, int name, int increment);
/******************************************************************************/
/* The base class for pipes. */
/******************************************************************************/
/* Pipe represents one "connection", i.e. perfectly ordered uni- or
bi-directional stream of messages. One endpoint can create multiple pipes
(for example, bound TCP socket is an endpoint, individual accepted TCP
connections are represented by pipes. */
struct nn_pipebase;
/* This value is returned by pipe's send and recv functions to signalise that
more sends/recvs are not possible at the moment. From that moment on,
the core will stop invoking the function. To re-establish the message
flow nn_pipebase_received (respectively nn_pipebase_sent) should
be called. */
#define NN_PIPEBASE_RELEASE 1
/* Specifies that received message is already split into header and body.
This flag is used only by inproc transport to avoid merging and re-splitting
the messages passed with a single process. */
#define NN_PIPEBASE_PARSED 2
struct nn_pipebase_vfptr {
/* Send a message to the network. The function can return either error
(negative number) or any combination of the flags defined above. */
int (*send) (struct nn_pipebase *self, struct nn_msg *msg);
/* Receive a message from the network. The function can return either error
(negative number) or any combination of the flags defined above. */
int (*recv) (struct nn_pipebase *self, struct nn_msg *msg);
};
/* Endpoint specific options. Same restrictions as for nn_pipebase apply */
struct nn_ep_options
{
int sndprio;
int rcvprio;
int ipv4only;
};
/* The member of this structure are used internally by the core. Never use
or modify them directly from the transport. */
struct nn_pipebase {
struct nn_fsm fsm;
const struct nn_pipebase_vfptr *vfptr;
uint8_t state;
uint8_t instate;
uint8_t outstate;
struct nn_sock *sock;
void *data;
struct nn_fsm_event in;
struct nn_fsm_event out;
struct nn_ep_options options;
};
/* Initialise the pipe. */
void nn_pipebase_init (struct nn_pipebase *self,
const struct nn_pipebase_vfptr *vfptr, struct nn_ep *ep);
/* Terminate the pipe. */
void nn_pipebase_term (struct nn_pipebase *self);
/* Call this function once the connection is established. */
int nn_pipebase_start (struct nn_pipebase *self);
/* Call this function once the connection is broken. */
void nn_pipebase_stop (struct nn_pipebase *self);
/* Call this function when new message was fully received. */
void nn_pipebase_received (struct nn_pipebase *self);
/* Call this function when current outgoing message was fully sent. */
void nn_pipebase_sent (struct nn_pipebase *self);
/* Retrieve value of a socket option. */
void nn_pipebase_getopt (struct nn_pipebase *self, int level, int option,
void *optval, size_t *optvallen);
/* Returns 1 is the specified socket type is a valid peer for this socket,
or 0 otherwise. */
int nn_pipebase_ispeer (struct nn_pipebase *self, int socktype);
/******************************************************************************/
/* The transport class. */
/******************************************************************************/
struct nn_transport {
/* Name of the transport as it appears in the connection strings ("tcp",
"ipc", "inproc" etc. */
const char *name;
/* ID of the transport. */
int id;
/* Following methods are guarded by a global critical section. Two of these
function will never be invoked in parallel. The first is called when
the library is initialised, the second one when it is terminated, i.e.
when there are no more open sockets. Either of them can be set to NULL
if no specific initialisation/termination is needed. */
void (*init) (void);
void (*term) (void);
/* Each of these functions creates an endpoint and sets up the newly
established endpoint in 'ep' parameter using nn_ep_tran_setup ().
These functions are guarded by a socket-wide critical section.
Two of these function will never be invoked in parallel on the same
socket. */
int (*bind) (struct nn_ep *);
int (*connect) (struct nn_ep *);
/* Create an object to hold transport-specific socket options.
Set this member to NULL in case there are no transport-specific
socket options available. */
struct nn_optset *(*optset) (void);
};
#endif
example/nanomsg/nanomsg/ws.h deleted 100644 → 0
View file @ 0580adb7
/*
Copyright (c) 2012 250bpm s.r.o. All rights reserved.
Copyright (c) 2014 Wirebird Labs LLC. All rights reserved.
Copyright 2015 Garrett D'Amore <garrett@damore.org>
Permission is hereby granted, free of charge, to any person obtaining a copy
of this software and associated documentation files (the "Software"),
to deal in the Software without restriction, including without limitation
the rights to use, copy, modify, merge, publish, distribute, sublicense,
and/or sell copies of the Software, and to permit persons to whom
the Software is furnished to do so, subject to the following conditions:
The above copyright notice and this permission notice shall be included
in all copies or substantial portions of the Software.
THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS
IN THE SOFTWARE.
*/
#ifndef WS_H_INCLUDED
#define WS_H_INCLUDED
#include "nn.h"
#ifdef __cplusplus
extern "C" {
#endif
#define NN_WS -4
/* NN_WS level socket/cmsg options. Note that only NN_WSMG_TYPE_TEXT and
NN_WS_MSG_TYPE_BINARY messages are supported fully by this implementation.
Attempting to set other message types is undefined. */
#define NN_WS_MSG_TYPE 1
/* WebSocket opcode constants as per RFC 6455 5.2 */
#define NN_WS_MSG_TYPE_TEXT 0x01
#define NN_WS_MSG_TYPE_BINARY 0x02
#ifdef __cplusplus
}
#endif
#endif
example/nanomsg/pair.c deleted 100644 → 0
View file @ 0580adb7
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <nanomsg/nn.h>
#include <nanomsg/pair.h>
#define NODE0 "node0"
#define NODE1 "node1"
void
fatal(const char *func)
{
fprintf(stderr, "%s: %s\n", func, nn_strerror(nn_errno()));
exit(1);
}
int
send_name(int sock, const char *name)
{
printf("%s: SENDING \"%s\"\n", name, name);
int sz_n = strlen(name) + 1; // '\0' too
return (nn_send(sock, name, sz_n, 0));
}
int
recv_name(int sock, const char *name)
{
char *buf = NULL;
int result = nn_recv(sock, &buf, NN_MSG, 0);
if (result > 0) {
printf("%s: RECEIVED \"%s\"\n", name, buf);
nn_freemsg(buf);
}
return (result);
}
int
send_recv(int sock, const char *name)
{
int to = 100;
if (nn_setsockopt(sock, NN_SOL_SOCKET, NN_RCVTIMEO, &to,
sizeof (to)) < 0) {
fatal("nn_setsockopt");
}
for (;;) {
recv_name(sock, name);
sleep(1);
send_name(sock, name);
}
}
int
node0(const char *url)
{
int sock;
if ((sock = nn_socket(AF_SP, NN_PAIR)) < 0) {
fatal("nn_socket");
}
if (nn_bind(sock, url) < 0) {
fatal("nn_bind");
}
return (send_recv(sock, NODE0));
}
int
node1(const char *url)
{
int sock;
if ((sock = nn_socket(AF_SP, NN_PAIR)) < 0) {
fatal("nn_socket");
}
if (nn_connect(sock, url) < 0) {
fatal("nn_connect");
}
return (send_recv(sock, NODE1));
}
int
main(const int argc, const char **argv)
{
if ((argc > 1) && (strcmp(NODE0, argv[1]) == 0))
return (node0(argv[2]));
if ((argc > 1) && (strcmp(NODE1, argv[1]) == 0))
return (node1(argv[2]));
fprintf(stderr, "Usage: pair %s|%s <URL> <ARG> ...\n", NODE0, NODE1);
return 1;
}
example/nanomsg/pipeline.c deleted 100644 → 0
View file @ 0580adb7
This diff is collapsed.
example/nanomsg/pubsub.c deleted 100644 → 0
View file @ 0580adb7
This diff is collapsed.
example/nanomsg/reqrep.c deleted 100644 → 0
View file @ 0580adb7
This diff is collapsed.
example/nanomsg/survey.c deleted 100644 → 0
View file @ 0580adb7
This diff is collapsed.
makefile
View file @ 97a82e1a
......@@ -6,20 +6,19 @@ include $(RULE_DIR)/funcs.mk
# CFLAGS += -DINSPECT_MQTT_FLOW
COMP_LIB := libiot_sdk.a
COMP_LIB := libkk_tsl.a
COMP_LIB_COMPONENTS := \
src/test \
midware/tsl \
SUBDIRS += src/kcloud
SUBDIRS += src/midware
SUBDIRS += application/kcloud
SUBDIRS += midware/midware
SUBDIRS += common/mqtt
SUBDIRS += common/json
SUBDIRS += common/api
SUBDIRS += common/nanomsg
SUBDIRS += common/ev
SUBDIRS += common/sqlite
SUBDIRS += platform/zigbee
#SUBDIRS += example/json
#SUBDIRS += platform/zigbee
$(call Append_Conditional, SUBDIRS)
......
src/midware/dm/kk_dm_msg.c → midware/midware/dm/kk_dm_msg.c
View file @ 97a82e1a
......@@ -11,6 +11,7 @@ const char DM_URI_SYS_PREFIX[] DM_READ_ONLY = "/sys/%s/%s
const char DM_URI_THING_EVENT_PROPERTY_POST[] DM_READ_ONLY = "thing/event/property/post";
const char DM_URI_THING_SERVICE_PROPERTY_SET_REPLY[] DM_READ_ONLY = "thing/service/property/set_reply";
const char DM_URI_THING_EVENT_POST[] DM_READ_ONLY = "thing/event/%.*s/post";
const char DM_URI_THING_SERVICE_RESPONSE[] DM_READ_ONLY = "thing/service/%.*s_reply";
......
src/midware/dm/kk_dm_msg.h → midware/midware/dm/kk_dm_msg.h
View file @ 97a82e1a
......@@ -58,6 +58,7 @@ extern const char DM_URI_SYS_PREFIX[] DM_READ_ONLY;
extern const char DM_URI_THING_EVENT_PROPERTY_POST[] DM_READ_ONLY;
const char DM_URI_THING_SERVICE_PROPERTY_SET_REPLY[] DM_READ_ONLY;
const char DM_URI_THING_EVENT_POST[] DM_READ_ONLY;
const char DM_URI_THING_SERVICE_RESPONSE[] DM_READ_ONLY;
#endif
src/midware/iot.mk → midware/midware/iot.mk
View file @ 97a82e1a
......@@ -7,7 +7,8 @@ $(call Append_Conditional, TARGET, midware)
CFLAGS += -I$(TOP_DIR)/common/nanomsg/include
CFLAGS += -I$(TOP_DIR)/common/ev/include
CFLAGS += -I$(TOP_DIR)/common/api
LDFLAGS += -lapi_com -liot_cjson
CFLAGS += -I$(TOP_DIR)/src/tsl/tsl_handle
LDFLAGS += -lapi_com -liot_cjson -lkk_tsl
LDFLAGS += -lsqlite -ldl -lm
LDFLAGS += -L$(TOP_DIR)/common/nanomsg -static -lnanomsg -lanl
LDFLAGS += -L$(TOP_DIR)/common/ev -static -lev
\ No newline at end of file
midware/tsl/iot.mk 0 → 100644
View file @ 97a82e1a
LIBA_TARGET := libtsl.a
src/midware/tsl_handle/kk_tsl_common.h → midware/tsl/tsl_handle/kk_tsl_common.h
View file @ 97a82e1a
......@@ -15,6 +15,7 @@
#define PRODUCT_KEY_MAXLEN (20 + 1)
#define DEVICE_NAME_MAXLEN (32 + 1)
#define DEVICE_SECRET_MAXLEN (64 + 1)
#define TSL_PATH_MAXLEN (64 + 1)
#define DM_UTILS_UINT16_STRLEN (5)
#define DM_UTILS_UINT32_STRLEN (10)
......
midware/tsl/tsl_handle/kk_tsl_load.c 0 → 100644
View file @ 97a82e1a
This diff is collapsed.
midware/tsl/tsl_handle/kk_tsl_load.h 0 → 100644
View file @ 97a82e1a
This diff is collapsed.
midware/tsl/tsl_handle/model.json 0 → 100644
View file @ 97a82e1a
This diff is collapsed.
platform/app/builder/Z3GatewayHost/jsonrpc/ev.h deleted 100644 → 0
View file @ 0580adb7
This diff is collapsed.
platform/app/builder/Z3GatewayHost/libnanomsg.a deleted 100644 → 0
View file @ 0580adb7
This diff is collapsed.
platform/app/builder/Z3GatewayHost/nn.h deleted 100644 → 0
View file @ 0580adb7
This diff is collapsed.
platform/app/builder/Z3GatewayHost/pair.h deleted 100644 → 0
View file @ 0580adb7
This diff is collapsed.
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment