diff options
| author | Uros Majstorovic <majstor@majstor.org> | 2017-09-06 18:19:00 +0200 |
|---|---|---|
| committer | Uros Majstorovic <majstor@majstor.org> | 2017-09-06 18:19:00 +0200 |
| commit | c129b10bf7c851d94002767aa09e06c526cacb7d (patch) | |
| tree | a0ca2c8d603a233c43c888dddb4ee541d4ba34e5 /code/core/rbuf_send.c | |
| parent | b83e58e21ea7dda57ddfda47bd1539d15abe687f (diff) | |
frad/defrag implemented
Diffstat (limited to 'code/core/rbuf_send.c')
| -rw-r--r-- | code/core/rbuf_send.c | 9 |
1 files changed, 5 insertions, 4 deletions
diff --git a/code/core/rbuf_send.c b/code/core/rbuf_send.c index d582e67..685280d 100644 --- a/code/core/rbuf_send.c +++ b/code/core/rbuf_send.c @@ -307,9 +307,10 @@ ssize_t ecp_rbuf_pkt_send(ECPRBSend *buf, ECPSocket *sock, ECPNetAddr *addr, ECP if (buf->flags & ECP_RBUF_FLAG_CCONTROL) { int _rv = ECP_OK; - #ifdef ECP_WITH_PTHREAD + +#ifdef ECP_WITH_PTHREAD pthread_mutex_lock(&buf->mutex); - #endif +#endif if (ECP_SEQ_LT(buf->rbuf.seq_max, seq)) buf->rbuf.seq_max = seq; @@ -337,9 +338,9 @@ ssize_t ecp_rbuf_pkt_send(ECPRBSend *buf, ECPSocket *sock, ECPNetAddr *addr, ECP buf->in_transit++; } - #ifdef ECP_WITH_PTHREAD +#ifdef ECP_WITH_PTHREAD pthread_mutex_unlock(&buf->mutex); - #endif +#endif if (_rv) return _rv; } |