diff options
Diffstat (limited to 'common/trans.c')
| -rw-r--r-- | common/trans.c | 47 |
1 files changed, 22 insertions, 25 deletions
diff --git a/common/trans.c b/common/trans.c index f77f959d..d73764de 100644 --- a/common/trans.c +++ b/common/trans.c @@ -31,7 +31,7 @@ #define MAX_SBYTES 0 /*****************************************************************************/ -int APP_CC +int trans_tls_recv(struct trans *self, char *ptr, int len) { if (self->tls == NULL) @@ -42,7 +42,7 @@ trans_tls_recv(struct trans *self, char *ptr, int len) } /*****************************************************************************/ -int APP_CC +int trans_tls_send(struct trans *self, const char *data, int len) { if (self->tls == NULL) @@ -53,7 +53,7 @@ trans_tls_send(struct trans *self, const char *data, int len) } /*****************************************************************************/ -int APP_CC +int trans_tls_can_recv(struct trans *self, int sck, int millis) { if (self->tls == NULL) @@ -64,21 +64,21 @@ trans_tls_can_recv(struct trans *self, int sck, int millis) } /*****************************************************************************/ -int APP_CC +int trans_tcp_recv(struct trans *self, char *ptr, int len) { return g_tcp_recv(self->sck, ptr, len, 0); } /*****************************************************************************/ -int APP_CC +int trans_tcp_send(struct trans *self, const char *data, int len) { return g_tcp_send(self->sck, data, len, 0); } /*****************************************************************************/ -int APP_CC +int trans_tcp_can_recv(struct trans *self, int sck, int millis) { return g_sck_can_recv(sck, millis); @@ -86,7 +86,6 @@ trans_tcp_can_recv(struct trans *self, int sck, int millis) /*****************************************************************************/ struct trans * -APP_CC trans_create(int mode, int in_size, int out_size) { struct trans *self = (struct trans *) NULL; @@ -111,7 +110,7 @@ trans_create(int mode, int in_size, int out_size) } /*****************************************************************************/ -void APP_CC +void trans_delete(struct trans *self) { if (self == 0) @@ -144,7 +143,7 @@ trans_delete(struct trans *self) } /*****************************************************************************/ -int APP_CC +int trans_get_wait_objs(struct trans *self, tbus *objs, int *count) { if (self == 0) @@ -173,7 +172,7 @@ trans_get_wait_objs(struct trans *self, tbus *objs, int *count) } /*****************************************************************************/ -int APP_CC +int trans_get_wait_objs_rw(struct trans *self, tbus *robjs, int *rcount, tbus *wobjs, int *wcount, int *timeout) { @@ -208,7 +207,7 @@ trans_get_wait_objs_rw(struct trans *self, tbus *robjs, int *rcount, } /*****************************************************************************/ -int APP_CC +int trans_send_waiting(struct trans *self, int block) { struct stream *temp_s; @@ -276,7 +275,7 @@ trans_send_waiting(struct trans *self, int block) } /*****************************************************************************/ -int APP_CC +int trans_check_wait_objs(struct trans *self) { tbus in_sck = (tbus) 0; @@ -430,7 +429,7 @@ trans_check_wait_objs(struct trans *self) } /*****************************************************************************/ -int APP_CC +int trans_force_read_s(struct trans *self, struct stream *in_s, int size) { int rcvd; @@ -488,14 +487,14 @@ trans_force_read_s(struct trans *self, struct stream *in_s, int size) } /*****************************************************************************/ -int APP_CC +int trans_force_read(struct trans *self, int size) { return trans_force_read_s(self, self->in_s, size); } /*****************************************************************************/ -int APP_CC +int trans_force_write_s(struct trans *self, struct stream *out_s) { int size; @@ -556,14 +555,14 @@ trans_force_write_s(struct trans *self, struct stream *out_s) } /*****************************************************************************/ -int APP_CC +int trans_force_write(struct trans *self) { return trans_force_write_s(self, self->out_s); } /*****************************************************************************/ -int APP_CC +int trans_write_copy_s(struct trans *self, struct stream *out_s) { int size; @@ -646,14 +645,14 @@ trans_write_copy_s(struct trans *self, struct stream *out_s) } /*****************************************************************************/ -int APP_CC +int trans_write_copy(struct trans* self) { return trans_write_copy_s(self, self->out_s); } /*****************************************************************************/ -int APP_CC +int trans_connect(struct trans *self, const char *server, const char *port, int timeout) { @@ -781,7 +780,7 @@ trans_connect(struct trans *self, const char *server, const char *port, /** * @return 0 on success, 1 on failure */ -int APP_CC +int trans_listen_address(struct trans *self, char *port, const char *address) { if (self->sck != 0) @@ -837,7 +836,7 @@ trans_listen_address(struct trans *self, char *port, const char *address) } /*****************************************************************************/ -int APP_CC +int trans_listen(struct trans *self, char *port) { return trans_listen_address(self, port, "0.0.0.0"); @@ -845,7 +844,6 @@ trans_listen(struct trans *self, char *port) /*****************************************************************************/ struct stream * -APP_CC trans_get_in_s(struct trans *self) { struct stream *rv = (struct stream *) NULL; @@ -864,7 +862,6 @@ trans_get_in_s(struct trans *self) /*****************************************************************************/ struct stream * -APP_CC trans_get_out_s(struct trans *self, int size) { struct stream *rv = (struct stream *) NULL; @@ -884,7 +881,7 @@ trans_get_out_s(struct trans *self, int size) /*****************************************************************************/ /* returns error */ -int APP_CC +int trans_set_tls_mode(struct trans *self, const char *key, const char *cert, long ssl_protocols, const char *tls_ciphers) { @@ -914,7 +911,7 @@ trans_set_tls_mode(struct trans *self, const char *key, const char *cert, /*****************************************************************************/ /* returns error */ -int APP_CC +int trans_shutdown_tls_mode(struct trans *self) { if (self->tls != NULL) |