mirror of
https://github.com/balloonwj/TeamTalk.git
synced 2026-10-19 06:41:50 +08:00
balloonwj
111 lines
3.5 KiB
C++
111 lines
3.5 KiB
C++
/*******************************************************************************
|
|
* @file ImCore.h 2014\11\28 13:28:49 $
|
|
* @author 蓝狐<lanhu@mogujie.com>
|
|
* @brief im cross platform library,currently include network、opertion manager
|
|
******************************************************************************/
|
|
|
|
#ifndef IMCORE_A19CD639_91DF_4383_9D8F_4698959A8FD1_H__
|
|
#define IMCORE_A19CD639_91DF_4383_9D8F_4698959A8FD1_H__
|
|
|
|
#include "GlobalDefine.h"
|
|
#include "util.h"
|
|
#include <iostream>
|
|
#include <string.h>
|
|
#include <functional>
|
|
using namespace std;
|
|
|
|
#ifdef ANDROID
|
|
#include <jni.h>
|
|
#include <android/LOG__.h>
|
|
#endif
|
|
/******************************************************************************/
|
|
class ClientConn;
|
|
struct ITcpSocketCallback;
|
|
NAMESPACE_BEGIN(imcore)
|
|
|
|
const std::string OPERATION_NAME_MSG_READ_ACK = "operation_name_msg_read_ack";
|
|
|
|
class Operation;
|
|
|
|
#ifdef __cplusplus
|
|
extern "C" {
|
|
#endif
|
|
|
|
/**@name start/stop*/
|
|
//@{
|
|
NETWORK_DLL bool IMLibCoreRunEvent();
|
|
NETWORK_DLL bool IMLibCoreStopEvent();
|
|
NETWORK_DLL bool IMLibCoreIsRunning();
|
|
//@}
|
|
|
|
/**@name network*/
|
|
//@{
|
|
NETWORK_DLL int IMLibCoreConnect(string ip, int port);
|
|
NETWORK_DLL int IMLibCoreWrite(int key, uchar_t* data, uint32_t size);
|
|
NETWORK_DLL void IMLibCoreShutdown(int key);
|
|
NETWORK_DLL void IMLibCoreClose(int key);
|
|
NETWORK_DLL void IMLibCoreRegisterCallback(int handle,ITcpSocketCallback* pCB);
|
|
NETWORK_DLL void IMLibCoreUnRegisterCallback(int handle);
|
|
//@}
|
|
|
|
/**@name operation*/
|
|
//@{
|
|
/**
|
|
* 发起一个Operation到任务队列尾部(放入容器的Operation对象实例不需要自己释放)
|
|
*
|
|
* @param IOperation * pOperation
|
|
* @param int delay = 0
|
|
* @return void
|
|
*/
|
|
NETWORK_DLL void IMLibCoreStartOperation(IN Operation* pOperation, Int32 delay = 0);
|
|
/**
|
|
* 将Operation 以lambda表达式方式放入到任务队列中
|
|
*
|
|
* @param std::function<void()> operationRun
|
|
* @return void
|
|
*/
|
|
NETWORK_DLL void IMLibCoreStartOperationWithLambda(std::function<void()> operationRun
|
|
, Int32 delay = 0
|
|
, std::string oper_name = "_common_operation_name");
|
|
/**
|
|
* 从任务队列中删除
|
|
*
|
|
* @param std::function<void()> operationRun
|
|
* @return void
|
|
*/
|
|
NETWORK_DLL void IMLibCoreClearOperationByName(std::string oper_name);
|
|
//@}
|
|
|
|
|
|
|
|
#ifdef ANDROID
|
|
JNIEXPORT void JNICALL Java_com_mogujie_im_libcore_LibCore_setJNIEnv(JNIEnv *, jobject);
|
|
JNIEXPORT void JNICALL Java_com_mogujie_im_libcore_LibCore_runEvent(JNIEnv*, jclass);
|
|
JNIEXPORT void JNICALL Java_com_mogujie_im_libcore_LibCore_stopEvent(JNIEnv*, jclass);
|
|
JNIEXPORT jboolean JNICALL Java_com_mogujie_im_libcore_LibCore_isRunning(JNIEnv*, jclass);
|
|
JNIEXPORT jint JNICALL Java_com_mogujie_im_libcore_LibCore_connect(JNIEnv*, jclass, jstring, jint);
|
|
JNIEXPORT jint JNICALL Java_com_mogujie_im_libcore_LibCore_write(JNIEnv* env, jclass, jint, jstring);
|
|
JNIEXPORT void JNICALL Java_com_mogujie_im_libcore_LibCore_close(JNIEnv*, jclass, jint);
|
|
JNIEXPORT jstring JNICALL Java_com_mogujie_im_libcore_LibCore_getToken(JNIEnv*, jclass, jstring);
|
|
char* jstringTostr(JNIEnv* env, jstring jstr);
|
|
jstring strToJstring(JNIEnv* env, const char* pStr);
|
|
|
|
void onRead(int nHandle, string strJson);
|
|
void onClose(int nHandle);
|
|
void onConnect(int nHandle);
|
|
#endif
|
|
|
|
#ifdef _MSC_VER
|
|
unsigned int __stdcall event_run(void* threadArgu);
|
|
#else
|
|
void *event_run(void* arg);
|
|
#endif
|
|
|
|
#ifdef __cplusplus
|
|
}
|
|
#endif
|
|
NAMESPACE_END(imcore)
|
|
/******************************************************************************/
|
|
#endif// IMCORE_A19CD639_91DF_4383_9D8F_4698959A8FD1_H__
|
|
|