aboutsummaryrefslogtreecommitdiff
path: root/net
diff options
context:
space:
mode:
Diffstat (limited to 'net')
-rw-r--r--net/tcpclient.c9
1 files changed, 6 insertions, 3 deletions
diff --git a/net/tcpclient.c b/net/tcpclient.c
index 98d6bec..f32f910 100644
--- a/net/tcpclient.c
+++ b/net/tcpclient.c
@@ -70,7 +70,7 @@ static char objName[] = "tcpclient";
typedef struct _tcpclient_sender_params
{
char x_sendbuf[MAX_TCPCLIENT_SEND_BUF]; /* possibly allocate this dynamically for space over speed */
- int x_buf_len;
+ size_t x_buf_len;
int x_sendresult;
pthread_t sendthreadid;
int threadisvalid; /* non-zero if sendthreadid is an active thread */
@@ -383,8 +383,11 @@ static void *tcpclient_child_send(void *w)
{
t_tcpclient_sender_params *tsp = (t_tcpclient_sender_params*) w;
- tsp->x_sendresult = send(tsp->x_x->x_fd, tsp->x_sendbuf, tsp->x_buf_len, 0);
- clock_delay(tsp->x_x->x_sendclock, 0); // calls tcpclient_sent when it's safe to do so
+ if (tsp->x_x->x_fd >= 0)
+ {
+ tsp->x_sendresult = send(tsp->x_x->x_fd, tsp->x_sendbuf, tsp->x_buf_len, 0);
+ clock_delay(tsp->x_x->x_sendclock, 0); // calls tcpclient_sent when it's safe to do so
+ }
tsp->threadisvalid = 0; /* this thread is over */
return(tsp);
}