summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rwxr-xr-xPICA_client.c112
-rwxr-xr-xPICA_client.h48
-rw-r--r--pica-client/nodethread.cpp2
-rw-r--r--pica-client/nodethread.h6
-rw-r--r--pica-client/skynet.cpp30
-rw-r--r--pica-client/skynet.h4
-rwxr-xr-xtests/test_client.c6
7 files changed, 104 insertions, 104 deletions
diff --git a/PICA_client.c b/PICA_client.c
index da192ee..c30f283 100755
--- a/PICA_client.c
+++ b/PICA_client.c
@@ -28,10 +28,10 @@ static pthread_mutex_t *mt_locks;
#endif
-static int PICA_send_file_fragment(struct PICA_chaninfo *chn);
-static int PICA_sendfile_open_read(struct PICA_chaninfo *chn, const char *filename_utf8, uint64_t *file_size);
-static int PICA_recvfile_open_write(struct PICA_chaninfo *chn, const char *filename_utf8, unsigned int filenamesize);
-static int PICA_send_filecontrol(struct PICA_chaninfo *chan, int senderctl, int receiverctl);
+static int PICA_send_file_fragment(struct PICA_c2c *chn);
+static int PICA_sendfile_open_read(struct PICA_c2c *chn, const char *filename_utf8, uint64_t *file_size);
+static int PICA_recvfile_open_write(struct PICA_c2c *chn, const char *filename_utf8, unsigned int filenamesize);
+static int PICA_send_filecontrol(struct PICA_c2c *chan, int senderctl, int receiverctl);
static unsigned int procmsg_INITRESP(unsigned char*,unsigned int,void*);
static unsigned int procmsg_CONNREQINC(unsigned char*,unsigned int,void*);
@@ -47,8 +47,8 @@ static unsigned int procmsg_DENIEDFILE(unsigned char*,unsigned int,void*);
static unsigned int procmsg_FILEFRAGMENT(unsigned char*,unsigned int,void*);
static unsigned int procmsg_FILECONTROL(unsigned char*,unsigned int,void*);
-static struct PICA_proto_msg* c2n_writebuf_push(struct PICA_conninfo *ci, unsigned int msgid, unsigned int size);
-static struct PICA_proto_msg* c2c_writebuf_push(struct PICA_chaninfo *chn, unsigned int msgid, unsigned int size);
+static struct PICA_proto_msg* c2n_writebuf_push(struct PICA_c2n *ci, unsigned int msgid, unsigned int size);
+static struct PICA_proto_msg* c2c_writebuf_push(struct PICA_c2c *chn, unsigned int msgid, unsigned int size);
#define MSGINFO_MSGSNUM(arr) (sizeof(arr)/sizeof(struct PICA_msginfo))
const struct PICA_msginfo c2n_messages[] = {
@@ -193,11 +193,11 @@ if (!preverify_ok) {
return preverify_ok;
}
-static int add_chaninfo(struct PICA_conninfo *ci, struct PICA_chaninfo **chn, const unsigned char *peer_id, int is_outgoing)
+static int add_chaninfo(struct PICA_c2n *ci, struct PICA_c2c **chn, const unsigned char *peer_id, int is_outgoing)
{
-struct PICA_chaninfo *chnl,*ipt;
+struct PICA_c2c *chnl,*ipt;
-chnl=*chn=(struct PICA_chaninfo*)calloc(sizeof(struct PICA_chaninfo),1);
+chnl=*chn=(struct PICA_c2c*)calloc(sizeof(struct PICA_c2c),1);
if (!chnl)
return 0;//ERR_CHECK
@@ -227,7 +227,7 @@ else
return 1;
}
-static int establish_data_connection(struct PICA_chaninfo *chnl)
+static int establish_data_connection(struct PICA_c2c *chnl)
{
char* DN_str;
//unsigned char buf[12];
@@ -400,7 +400,7 @@ return err_ret;
static unsigned int procmsg_INITRESP(unsigned char* buf, unsigned int nb,void* p)
{
-struct PICA_conninfo *ci=(struct PICA_conninfo *)p;
+struct PICA_c2n *ci=(struct PICA_c2n *)p;
switch(buf[0])
{
@@ -424,14 +424,14 @@ return 1;
static unsigned int procmsg_CONNREQINC(unsigned char* buf,unsigned int nb,void* p)
{
int ret;
-struct PICA_conninfo *ci=(struct PICA_conninfo *)p;
+struct PICA_c2n *ci=(struct PICA_c2n *)p;
struct PICA_proto_msg *mp;
unsigned char *peer_id = buf + 2;
if (callbacks.accept_cb(peer_id))
{
- struct PICA_chaninfo *_chnl;
+ struct PICA_c2c *_chnl;
mp = c2n_writebuf_push( ci, PICA_PROTO_CONNALLOW, PICA_PROTO_CONNALLOW_SIZE);
@@ -480,8 +480,8 @@ return 1;
static unsigned int procmsg_NOTFOUND(unsigned char* buf,unsigned int nb,void* p)
{
-struct PICA_conninfo *ci=(struct PICA_conninfo *)p;
-struct PICA_chaninfo *ipt,*rq=0;
+struct PICA_c2n *ci=(struct PICA_c2n *)p;
+struct PICA_c2c *ipt,*rq=0;
unsigned char *peer_id = buf + 2;
//puts("procmsg_NOTFOUND");//debug
@@ -511,8 +511,8 @@ return 1;
static unsigned int procmsg_FOUND(unsigned char* buf,unsigned int nb,void* p)
{
-struct PICA_conninfo *ci=(struct PICA_conninfo *)p;
-struct PICA_chaninfo *ipt,*rq=0;
+struct PICA_c2n *ci=(struct PICA_c2n *)p;
+struct PICA_c2c *ipt,*rq=0;
unsigned char *peer_id = buf + 2;
int ret;
@@ -609,7 +609,7 @@ return 1;
static unsigned int procmsg_MSGUTF8(unsigned char* buf, unsigned int nb, void* p)
{
-struct PICA_chaninfo *chan = (struct PICA_chaninfo *)p;
+struct PICA_c2c *chan = (struct PICA_c2c *)p;
struct PICA_proto_msg *mp;
callbacks.newmsg_cb(chan->peer_id, buf + 4, nb - 4, buf[0]);
@@ -629,7 +629,7 @@ return 1;
static unsigned int procmsg_MSGOK(unsigned char* buf, unsigned int nb, void* p)
{
-struct PICA_chaninfo *chan = (struct PICA_chaninfo *)p;
+struct PICA_c2c *chan = (struct PICA_c2c *)p;
callbacks.msgok_cb(chan -> peer_id);
return 1;
@@ -637,7 +637,7 @@ return 1;
unsigned int procmsg_PINGREQ(unsigned char* buf,unsigned int nb,void* p)
{
-struct PICA_conninfo *ci=(struct PICA_conninfo *)p;
+struct PICA_c2n *ci=(struct PICA_c2n *)p;
struct PICA_proto_msg *mp;
mp = c2n_writebuf_push(ci, PICA_PROTO_PINGREP, PICA_PROTO_PINGREP_SIZE);
@@ -652,7 +652,7 @@ else
return 1;
}
-int PICA_deny_file(struct PICA_chaninfo *chan)
+int PICA_deny_file(struct PICA_c2c *chan)
{
struct PICA_proto_msg *mp;
@@ -673,7 +673,7 @@ else
return PICA_OK;
}
-int PICA_accept_file(struct PICA_chaninfo *chan, char *filename, unsigned int filenamesize)
+int PICA_accept_file(struct PICA_c2c *chan, char *filename, unsigned int filenamesize)
{
struct PICA_proto_msg *mp;
int ret;
@@ -703,7 +703,7 @@ return PICA_OK;
static unsigned int procmsg_SENDFILEREQUEST(unsigned char* buf, unsigned int nb, void* p)
{
-struct PICA_chaninfo *chan = (struct PICA_chaninfo *)p;
+struct PICA_c2c *chan = (struct PICA_c2c *)p;
struct PICA_proto_msg *mp;
int ret;
@@ -740,7 +740,7 @@ return 1;
static unsigned int procmsg_ACCEPTEDFILE(unsigned char* buf, unsigned int nb, void* p)
{
-struct PICA_chaninfo *chan = (struct PICA_chaninfo *)p;
+struct PICA_c2c *chan = (struct PICA_c2c *)p;
if (chan->sendfilestate != PICA_CHANSENDFILESTATE_SENTREQ)
return 0;
@@ -754,7 +754,7 @@ return 1;
static unsigned int procmsg_DENIEDFILE(unsigned char* buf, unsigned int nb, void* p)
{
-struct PICA_chaninfo *chan = (struct PICA_chaninfo *)p;
+struct PICA_c2c *chan = (struct PICA_c2c *)p;
if (chan->sendfilestate != PICA_CHANSENDFILESTATE_SENTREQ)
return 0;
@@ -771,7 +771,7 @@ return 1;
static unsigned int procmsg_FILEFRAGMENT(unsigned char* buf, unsigned int nb, void* p)
{
-struct PICA_chaninfo *chan = (struct PICA_chaninfo *)p;
+struct PICA_c2c *chan = (struct PICA_c2c *)p;
/*
*Allow incoming FILEFRAGMENTs while paused
@@ -818,7 +818,7 @@ return 1;
static unsigned int procmsg_FILECONTROL(unsigned char* buf, unsigned int nb, void* p)
{
-struct PICA_chaninfo *chan = (struct PICA_chaninfo *)p;
+struct PICA_c2c *chan = (struct PICA_c2c *)p;
unsigned int sender_cmd, receiver_cmd;
sender_cmd = buf[2];
@@ -997,7 +997,7 @@ return 1;
//cert_file - имя файла, содержащего сертфикат клиента в формате PEM
//pkey_file - имя файла, содержащего приватный ключ в формате PEM
//password_cb - callback-функция, запрашивающая пароль к приватному ключу, см. man 3 SSL_CTX_set_default_passwd_cb;в userdata передается указатель на id
-//ci -указатель на указатель на структуру PICA_conninfo, который будет проинициализирован при успешном выполнении функции
+//ci -указатель на указатель на структуру PICA_c2n, который будет проинициализирован при успешном выполнении функции
//Память, выделенная под структуру, освобождается при вызове PICA_close_connection
//Возвращаемое значение - код завершения
//PICA_OK - успешное завершение функции
@@ -1010,10 +1010,10 @@ int PICA_new_connection(const char *nodeaddr,
const char *pkey_file,
const char *dh_param_file,
int (*password_cb)(char *buf, int size, int rwflag, void *userdata),
- struct PICA_conninfo **ci)
+ struct PICA_c2n **ci)
{
int ret,ret_err;
-struct PICA_conninfo *cid;
+struct PICA_c2n *cid;
struct sockaddr_in a;
DH *dh = NULL;
FILE *dh_file = NULL;
@@ -1023,7 +1023,7 @@ if (!(nodeaddr && CA_file && cert_file && pkey_file && ci))
return PICA_ERRINVARG;
-cid=*ci=(struct PICA_conninfo*)calloc(sizeof(struct PICA_conninfo),1);//(1)
+cid=*ci=(struct PICA_c2n*)calloc(sizeof(struct PICA_c2n),1);//(1)
if (!cid)
return PICA_ERRNOMEM;
@@ -1268,10 +1268,10 @@ return ret_err;
//создает ИСХОДЯЩИЙ логический зашифрованный канал связи с указанным собеседником, если тот доступен
// в данный момент.
-int PICA_create_channel(struct PICA_conninfo *ci,const unsigned char *peer_id,struct PICA_chaninfo **chn)
+int PICA_create_channel(struct PICA_c2n *ci,const unsigned char *peer_id,struct PICA_c2c **chn)
{
struct PICA_proto_msg *mp;
-struct PICA_chaninfo *chnl;
+struct PICA_c2c *chnl;
if (!(ci && chn))
return PICA_ERRINVARG;
@@ -1294,11 +1294,11 @@ mp = c2n_writebuf_push( ci, PICA_PROTO_CONNREQOUTG, PICA_PROTO_CONNREQOUTG_SIZE)
return PICA_OK;
}
-int PICA_read(struct PICA_conninfo *ci,int timeout)
+int PICA_read(struct PICA_c2n *ci,int timeout)
{
fd_set fds;
struct timeval tv={0,1000};
-struct PICA_chaninfo *ipt, *kill_ptr = 0;
+struct PICA_c2c *ipt, *kill_ptr = 0;
int ret,nfds;
//puts("PICA_read<<");//debug
@@ -1379,9 +1379,9 @@ if (ret>0)
return PICA_OK;
}
-int PICA_write(struct PICA_conninfo *ci)
+int PICA_write(struct PICA_c2n *ci)
{
-struct PICA_chaninfo *ipt, *kill_ptr = 0;
+struct PICA_c2c *ipt, *kill_ptr = 0;
int ret = PICA_OK;
//puts("PICA_write>>");//debug
@@ -1494,7 +1494,7 @@ return PICA_OK;
//int PICA_read_socket()
//int PICA_read_ssl()
-int PICA_write_c2n(struct PICA_conninfo *ci)
+int PICA_write_c2n(struct PICA_c2n *ci)
{
int ret = PICA_ERRINVARG;
@@ -1506,7 +1506,7 @@ else if (PICA_CONNSTATE_CONNECTED == ci->state)
return ret;
}
-int PICA_write_c2c(struct PICA_chaninfo *chn)
+int PICA_write_c2c(struct PICA_c2c *chn)
{
int ret = PICA_ERRINVARG;
@@ -1590,7 +1590,7 @@ if (ret > 0)
return PICA_OK;
}
-int PICA_read_c2c(struct PICA_chaninfo *chn)
+int PICA_read_c2c(struct PICA_c2c *chn)
{
int ret;
@@ -1610,7 +1610,7 @@ return ret;
}
//функция читает и обрабатывает данные, приходящие от сервера по управляющему соединению.
-int PICA_read_c2n(struct PICA_conninfo *ci)
+int PICA_read_c2n(struct PICA_c2n *ci)
{
int ret;
@@ -1636,7 +1636,7 @@ if (ret == PICA_OK)
return ret;
}
-struct PICA_proto_msg* c2n_writebuf_push(struct PICA_conninfo *ci, unsigned int msgid, unsigned int size)
+struct PICA_proto_msg* c2n_writebuf_push(struct PICA_c2n *ci, unsigned int msgid, unsigned int size)
{
struct PICA_proto_msg *mp;
@@ -1669,7 +1669,7 @@ ci->write_pos += size;
return mp;
}
-struct PICA_proto_msg* c2c_writebuf_push(struct PICA_chaninfo *chn, unsigned int msgid, unsigned int size)
+struct PICA_proto_msg* c2c_writebuf_push(struct PICA_c2c *chn, unsigned int msgid, unsigned int size)
{
struct PICA_proto_msg *mp;
@@ -1702,7 +1702,7 @@ chn->write_pos += size;
return mp;
}
-int PICA_send_msg(struct PICA_chaninfo *chn, char *buf,unsigned int len)
+int PICA_send_msg(struct PICA_c2c *chn, char *buf,unsigned int len)
{
struct PICA_proto_msg *mp;
@@ -1720,7 +1720,7 @@ else
return PICA_OK;
}
-int PICA_send_file(struct PICA_chaninfo *chn, const char *filepath)
+int PICA_send_file(struct PICA_c2c *chn, const char *filepath)
{
struct PICA_proto_msg *mp;
size_t namelen;
@@ -1771,7 +1771,7 @@ chn->sendfile_pos = 0;
return PICA_OK;
}
-int PICA_pause_file(struct PICA_chaninfo *chan, int sending)
+int PICA_pause_file(struct PICA_c2c *chan, int sending)
{
int senderctl = PICA_PROTO_FILECONTROL_VOID;
int receiverctl = PICA_PROTO_FILECONTROL_VOID;
@@ -1800,7 +1800,7 @@ if (sending)
return PICA_send_filecontrol(chan, senderctl, receiverctl);
}
-int PICA_resume_file(struct PICA_chaninfo *chan, int sending)
+int PICA_resume_file(struct PICA_c2c *chan, int sending)
{
int senderctl = PICA_PROTO_FILECONTROL_VOID;
int receiverctl = PICA_PROTO_FILECONTROL_VOID;
@@ -1827,7 +1827,7 @@ if (sending)
return PICA_send_filecontrol(chan, senderctl, receiverctl);
}
-int PICA_cancel_file(struct PICA_chaninfo *chan, int sending)
+int PICA_cancel_file(struct PICA_c2c *chan, int sending)
{
int senderctl = PICA_PROTO_FILECONTROL_VOID;
int receiverctl = PICA_PROTO_FILECONTROL_VOID;
@@ -1860,7 +1860,7 @@ if (sending)
return PICA_send_filecontrol(chan, senderctl, receiverctl);
}
-int PICA_send_filecontrol(struct PICA_chaninfo *chan, int senderctl, int receiverctl)
+int PICA_send_filecontrol(struct PICA_c2c *chan, int senderctl, int receiverctl)
{
struct PICA_proto_msg *mp;
@@ -1877,7 +1877,7 @@ else
return PICA_OK;
}
-int PICA_send_file_fragment(struct PICA_chaninfo *chn)
+int PICA_send_file_fragment(struct PICA_c2c *chn)
{
struct PICA_proto_msg *mp;
char buf[PICA_FILEFRAGMENTSIZE];
@@ -1929,9 +1929,9 @@ if (chn->sendfile_pos > chn->sendfile_size)
return PICA_OK;
}
-void PICA_close_channel(struct PICA_chaninfo *chn)
+void PICA_close_channel(struct PICA_c2c *chn)
{
-struct PICA_chaninfo *ipt;
+struct PICA_c2c *ipt;
fprintf(stderr, "PICA_close_channel(%p)\n", chn);//debug
@@ -1994,9 +1994,9 @@ free(chn);
//puts("PICA_close_channel_chkp7");//debug
}
-void PICA_close_connection(struct PICA_conninfo *cid)
+void PICA_close_connection(struct PICA_c2n *cid)
{
-struct PICA_chaninfo *ipt;
+struct PICA_c2c *ipt;
while((ipt = cid->chan_list_head))
PICA_close_channel(ipt);
@@ -2041,7 +2041,7 @@ free(cid);
#endif
-int PICA_sendfile_open_read(struct PICA_chaninfo *chn, const char *filename_utf8, uint64_t *file_size)
+int PICA_sendfile_open_read(struct PICA_c2c *chn, const char *filename_utf8, uint64_t *file_size)
{
#ifdef WIN32
{
@@ -2093,7 +2093,7 @@ if (fseeko(chn->sendfile_stream, 0, SEEK_SET) != 0)
return PICA_OK;
}
-int PICA_recvfile_open_write(struct PICA_chaninfo *chn, const char *filename_utf8, unsigned int filenamesize)
+int PICA_recvfile_open_write(struct PICA_c2c *chn, const char *filename_utf8, unsigned int filenamesize)
{
/////////////
#ifdef WIN32
diff --git a/PICA_client.h b/PICA_client.h
index db1a52d..cbd3ed8 100755
--- a/PICA_client.h
+++ b/PICA_client.h
@@ -115,10 +115,10 @@ typedef unsigned __int64 uint64_t;
#define PICA_CHANNEL_INCOMING 0
#define PICA_CHANNEL_OUTGOING 1
-struct PICA_conninfo;
-struct PICA_chaninfo;
+struct PICA_c2n;
+struct PICA_c2c;
-struct PICA_conninfo
+struct PICA_c2n
{
//#warning "sockaddr!"
struct sockaddr_in srv_addr; // sockaddr !!
@@ -137,16 +137,16 @@ unsigned int write_pos;
unsigned int write_buflen;
unsigned int write_sslbytestowrite;
-struct PICA_chaninfo *chan_list_head;
-struct PICA_chaninfo *chan_list_end;
+struct PICA_c2c *chan_list_head;
+struct PICA_c2c *chan_list_end;
int init_resp_ok;
unsigned char node_ver_major, node_ver_minor;
};
-struct PICA_chaninfo
+struct PICA_c2c
{
-struct PICA_conninfo *conn;//соединение с сервером, через которое установлен данный логический канал связи
+struct PICA_c2n *conn;//соединение с сервером, через которое установлен данный логический канал связи
unsigned char peer_id[PICA_ID_SIZE];
SOCKET sck_data;
SSL *ssl;
@@ -161,8 +161,8 @@ unsigned int write_pos;
unsigned int write_buflen;
unsigned int write_sslbytestowrite;
-struct PICA_chaninfo *next;
-struct PICA_chaninfo *prev;
+struct PICA_c2c *next;
+struct PICA_c2c *prev;
int state;
time_t timestamp;
int sendfilestate;
@@ -231,28 +231,28 @@ int PICA_new_connection
const char *pkey_file,
const char *dh_param_file,
int (*password_cb)(char *buf, int size, int rwflag, void *userdata),
- struct PICA_conninfo **ci);
+ struct PICA_c2n **ci);
-int PICA_create_channel(struct PICA_conninfo *ci,const unsigned char *peer_id,struct PICA_chaninfo **chn);
-int PICA_read_c2n(struct PICA_conninfo *ci);
+int PICA_create_channel(struct PICA_c2n *ci,const unsigned char *peer_id,struct PICA_c2c **chn);
+int PICA_read_c2n(struct PICA_c2n *ci);
-int PICA_read(struct PICA_conninfo *ci,int timeout);
-int PICA_write(struct PICA_conninfo *ci);
+int PICA_read(struct PICA_c2n *ci,int timeout);
+int PICA_write(struct PICA_c2n *ci);
-int PICA_send_msg(struct PICA_chaninfo *chn, char *buf,unsigned int len);
-int PICA_read_msg(struct PICA_chaninfo *chn,char *buf,unsigned int *n);
+int PICA_send_msg(struct PICA_c2c *chn, char *buf,unsigned int len);
+int PICA_read_msg(struct PICA_c2c *chn,char *buf,unsigned int *n);
//filename - ASCII or UTF-8 encoded string
-int PICA_send_file(struct PICA_chaninfo *chn, const char *filepath);
-int PICA_accept_file(struct PICA_chaninfo *chan, char *filename, unsigned int filenamesize);
-int PICA_deny_file(struct PICA_chaninfo *chan);
+int PICA_send_file(struct PICA_c2c *chn, const char *filepath);
+int PICA_accept_file(struct PICA_c2c *chan, char *filename, unsigned int filenamesize);
+int PICA_deny_file(struct PICA_c2c *chan);
// if sending != 0 then pause sending file, else pause receiving of file
-int PICA_pause_file(struct PICA_chaninfo *chan, int sending);
-int PICA_resume_file(struct PICA_chaninfo *chan, int sending);
-int PICA_cancel_file(struct PICA_chaninfo *chan, int sending);
+int PICA_pause_file(struct PICA_c2c *chan, int sending);
+int PICA_resume_file(struct PICA_c2c *chan, int sending);
+int PICA_cancel_file(struct PICA_c2c *chan, int sending);
-void PICA_close_channel(struct PICA_chaninfo *chn);
-void PICA_close_connection(struct PICA_conninfo *cid);
+void PICA_close_channel(struct PICA_c2c *chn);
+void PICA_close_connection(struct PICA_c2n *cid);
#ifdef __cplusplus
}
diff --git a/pica-client/nodethread.cpp b/pica-client/nodethread.cpp
index 393c156..3850397 100644
--- a/pica-client/nodethread.cpp
+++ b/pica-client/nodethread.cpp
@@ -6,7 +6,7 @@
QMutex NodeThread::finished_mutex;
-NodeThread::NodeThread(Nodes::NodeRecord &addr, bool *completed, Accounts::AccountRecord &acc, PICA_conninfo **pica_conn, QMutex *wm) :
+NodeThread::NodeThread(Nodes::NodeRecord &addr, bool *completed, Accounts::AccountRecord &acc, PICA_c2n **pica_conn, QMutex *wm) :
QThread(0)
{
node_addr = addr;
diff --git a/pica-client/nodethread.h b/pica-client/nodethread.h
index 79de4d0..524688e 100644
--- a/pica-client/nodethread.h
+++ b/pica-client/nodethread.h
@@ -12,7 +12,7 @@ class NodeThread : public QThread
{
Q_OBJECT
public:
- explicit NodeThread( Nodes::NodeRecord &addr, bool *completed,Accounts::AccountRecord &acc,struct PICA_conninfo **pica_conn, QMutex *wm);
+ explicit NodeThread( Nodes::NodeRecord &addr, bool *completed,Accounts::AccountRecord &acc,struct PICA_c2n **pica_conn, QMutex *wm);
void CloseThread();
private:
void run();
@@ -22,9 +22,9 @@ private:
bool *finished_flag;
Nodes::NodeRecord node_addr;
- struct PICA_conninfo *ci;
+ struct PICA_c2n *ci;
Accounts::AccountRecord user_account;
- struct PICA_conninfo **connection;
+ struct PICA_c2n **connection;
int exit;
diff --git a/pica-client/skynet.cpp b/pica-client/skynet.cpp
index 54b1a85..fda9a31 100644
--- a/pica-client/skynet.cpp
+++ b/pica-client/skynet.cpp
@@ -89,7 +89,7 @@ void SkyNet::nodethread_connected(QString addr, quint16 port, NodeThread *thread
{
int ret;
write_mutex.lock();
- struct PICA_chaninfo *chan = NULL;
+ struct PICA_c2c *chan = NULL;
ret = PICA_create_channel(nodelink, (const unsigned char*)c2c_peer_ids[i].constData(), &chan);
@@ -181,7 +181,7 @@ void SkyNet::timerEvent(QTimerEvent *e)
{
int ret;
- struct PICA_chaninfo *chan = NULL;
+ struct PICA_c2c *chan = NULL;
ret = PICA_create_channel(nodelink, (const unsigned char*)c2c_peer_ids[i].constData(), &chan);
@@ -240,7 +240,7 @@ bool SkyNet::isSelfAware()
void SkyNet::SendFile(QByteArray to, QString filepath)
{
int ret = PICA_OK;
-struct PICA_chaninfo *iptr;
+struct PICA_c2c *iptr;
write_mutex.lock();//<<
@@ -263,7 +263,7 @@ if ( (iptr = find_active_chan(to)) )
}
else
{
- struct PICA_chaninfo *chan = NULL;
+ struct PICA_c2c *chan = NULL;
ret = PICA_create_channel(nodelink, (const unsigned char*)to.constData(), &chan);
@@ -283,7 +283,7 @@ write_mutex.unlock();//>>
void SkyNet::AcceptFile(QByteArray from, QString filepath)
{
int ret = PICA_OK;
-struct PICA_chaninfo *iptr;
+struct PICA_c2c *iptr;
write_mutex.lock();//<<
if ( (iptr = find_active_chan(from)) )
@@ -302,7 +302,7 @@ write_mutex.unlock();//>>
void SkyNet::DenyFile(QByteArray from)
{
int ret = PICA_OK;
-struct PICA_chaninfo *iptr;
+struct PICA_c2c *iptr;
write_mutex.lock();//<<
if ( (iptr = find_active_chan(from)) )
@@ -321,7 +321,7 @@ write_mutex.unlock();//>>
void SkyNet::PauseFile(QByteArray peer_id, bool pause_sending)
{
int ret = PICA_OK;
-struct PICA_chaninfo *iptr;
+struct PICA_c2c *iptr;
write_mutex.lock();//<<
if ( (iptr = find_active_chan(peer_id)) )
@@ -340,7 +340,7 @@ write_mutex.unlock();//>>
void SkyNet::ResumeFile(QByteArray peer_id, bool resume_sending)
{
int ret = PICA_OK;
-struct PICA_chaninfo *iptr;
+struct PICA_c2c *iptr;
write_mutex.lock();//<<
if ( (iptr = find_active_chan(peer_id)) )
@@ -358,7 +358,7 @@ write_mutex.unlock();//>>
void SkyNet::CancelFile(QByteArray peer_id, bool cancel_sending)
{
int ret = PICA_OK;
-struct PICA_chaninfo *iptr;
+struct PICA_c2c *iptr;
write_mutex.lock();//<<
if ( (iptr = find_active_chan(peer_id)) )
@@ -376,7 +376,7 @@ write_mutex.unlock();//>>
void SkyNet::SendMessage(QByteArray to, QString msg)
{
int ret = PICA_OK;
-struct PICA_chaninfo *iptr;
+struct PICA_c2c *iptr;
write_mutex.lock();//<<
@@ -399,7 +399,7 @@ if ( (iptr = find_active_chan(to)) )
}
else
{
- struct PICA_chaninfo *chan = NULL;
+ struct PICA_c2c *chan = NULL;
ret = PICA_create_channel(nodelink, (const unsigned char*)to.constData(), &chan);
@@ -418,7 +418,7 @@ write_mutex.unlock();//>>
void SkyNet::flush_queues(QByteArray to)
{
- struct PICA_chaninfo *chan;
+ struct PICA_c2c *chan;
int ret;
if (self_aware && (msgqueues.contains(to) || sndfilequeues.contains(to)))
@@ -466,12 +466,12 @@ void SkyNet::flush_queues(QByteArray to)
}
}
-struct PICA_chaninfo * SkyNet::find_active_chan(QByteArray peer_id)
+struct PICA_c2c * SkyNet::find_active_chan(QByteArray peer_id)
{
if (!nodelink)
return NULL;
-struct PICA_chaninfo *iptr = nodelink->chan_list_head;
+struct PICA_c2c *iptr = nodelink->chan_list_head;
while(iptr)
{
@@ -491,7 +491,7 @@ QList<QByteArray> SkyNet::filter_existing_chans(QList<QByteArray> peer_ids)
if (!nodelink)
return ret;
- struct PICA_chaninfo *iptr = nodelink->chan_list_head;
+ struct PICA_c2c *iptr = nodelink->chan_list_head;
while(iptr)
{
diff --git a/pica-client/skynet.h b/pica-client/skynet.h
index 5aeb332..a0f974b 100644
--- a/pica-client/skynet.h
+++ b/pica-client/skynet.h
@@ -62,7 +62,7 @@ private:
QList<NodeThread*> threads;
bool self_aware;
QString status;
- struct PICA_conninfo *nodelink;
+ struct PICA_c2n *nodelink;
Accounts::AccountRecord skynet_account;
QMutex write_mutex;
QMap<QByteArray, QList<QString> > msgqueues;
@@ -72,7 +72,7 @@ private:
void timerEvent(QTimerEvent * e);
void flush_queues(QByteArray to);
- struct PICA_chaninfo *find_active_chan(QByteArray peer_id);
+ struct PICA_c2c *find_active_chan(QByteArray peer_id);
QList<QByteArray> filter_existing_chans(QList<QByteArray> peer_ids);
void emit_MessageReceived(QByteArray from, QString msg);
diff --git a/tests/test_client.c b/tests/test_client.c
index f8ef157..9ea2de2 100755
--- a/tests/test_client.c
+++ b/tests/test_client.c
@@ -6,8 +6,8 @@
struct sockaddr_in a;
-struct PICA_conninfo *c;
-struct PICA_chaninfo *chn;
+struct PICA_c2n *c;
+struct PICA_c2c *chn;
int _outgoing_chnl=0;
@@ -124,7 +124,7 @@ PICA_client_init(&cbs);
printf("making connection...\n");
-//PICA_new_connection(const char *nodeaddr, unsigned int port, const char *CA_file, const char *cert_file, const char *pkey_file, const char* password, struct PICA_conninfo **ci)
+//PICA_new_connection(const char *nodeaddr, unsigned int port, const char *CA_file, const char *cert_file, const char *pkey_file, const char* password, struct PICA_c2n **ci)
ret=PICA_new_connection(argv[1], atoi(argv[2]), /*"trusted_CA.pem"*/ argv[3], argv[3],argv[3],NULL,&c);
ERR_print_errors_fp(stdout);