summaryrefslogtreecommitdiff
path: root/tests/tcpflood.c
diff options
context:
space:
mode:
authorMichael Biebl <biebl@debian.org>2013-03-18 15:39:58 +0100
committerMichael Biebl <biebl@debian.org>2013-03-18 15:39:58 +0100
commit86831d7a4f485e19befa8cc500d17766798ad07c (patch)
tree67b3cc93fcf2734e594c4e0c11609eaf1359e0f8 /tests/tcpflood.c
parentac1a840d0afd724fa614eed5d64112a9ecf097f8 (diff)
downloadrsyslog-86831d7a4f485e19befa8cc500d17766798ad07c.tar.gz
Imported Upstream version 7.3.8upstream/7.3.8
Diffstat (limited to 'tests/tcpflood.c')
-rw-r--r--tests/tcpflood.c12
1 files changed, 6 insertions, 6 deletions
diff --git a/tests/tcpflood.c b/tests/tcpflood.c
index 4a3199c..b3cef2e 100644
--- a/tests/tcpflood.c
+++ b/tests/tcpflood.c
@@ -258,7 +258,7 @@ int openConnections(void)
return setupUDP();
if(bShowProgress)
- write(1, " open connections", sizeof(" open connections")-1);
+ if(write(1, " open connections", sizeof(" open connections")-1)){}
# ifdef ENABLE_GNUTLS
sessArray = calloc(numConnections, sizeof(gnutls_session_t));
# endif
@@ -278,7 +278,7 @@ int openConnections(void)
}
if(bShowProgress) {
lenMsg = sprintf(msgBuf, "\r%5.5d open connections\n", i);
- write(1, msgBuf, lenMsg);
+ if(write(1, msgBuf, lenMsg)) {}
}
return 0;
@@ -303,12 +303,12 @@ void closeConnections(void)
return;
if(bShowProgress)
- write(1, " close connections", sizeof(" close connections")-1);
+ if(write(1, " close connections", sizeof(" close connections")-1)){}
for(i = 0 ; i < numConnections ; ++i) {
if(i % 10 == 0) {
if(bShowProgress) {
lenMsg = sprintf(msgBuf, "\r%5.5d", i);
- write(1, msgBuf, lenMsg);
+ if(write(1, msgBuf, lenMsg)){}
}
}
if(sockArray[i] != -1) {
@@ -325,7 +325,7 @@ void closeConnections(void)
}
if(bShowProgress) {
lenMsg = sprintf(msgBuf, "\r%5.5d close connections\n", i);
- write(1, msgBuf, lenMsg);
+ if(write(1, msgBuf, lenMsg)){}
}
}
@@ -347,7 +347,7 @@ genMsg(char *buf, size_t maxBuf, int *pLenBuf, struct instdata *inst)
/* get message from file */
do {
done = 1;
- *pLenBuf = fread(buf, 1, 1024, dataFP);
+ *pLenBuf = fread(buf, 1, MAX_EXTRADATA_LEN + 1024, dataFP);
if(*pLenBuf == 0) {
if(--numFileIterations > 0) {
rewind(dataFP);