summaryrefslogtreecommitdiff
path: root/ACE/performance-tests
diff options
context:
space:
mode:
Diffstat (limited to 'ACE/performance-tests')
-rw-r--r--ACE/performance-tests/RPC/client.cpp1
-rw-r--r--ACE/performance-tests/SCTP/Options_Manager.cpp10
-rw-r--r--ACE/performance-tests/SCTP/Options_Manager.h2
-rw-r--r--ACE/performance-tests/SCTP/SOCK_SEQPACK_Association_Test.cpp13
-rw-r--r--ACE/performance-tests/SCTP/SOCK_SEQPACK_clt.cpp6
-rw-r--r--ACE/performance-tests/SCTP/SOCK_SEQPACK_srv.cpp7
-rw-r--r--ACE/performance-tests/SCTP/SOCK_STREAM_clt.cpp7
-rw-r--r--ACE/performance-tests/SCTP/SOCK_STREAM_srv.cpp7
-rw-r--r--ACE/performance-tests/SCTP/hist.cpp2
-rw-r--r--ACE/performance-tests/SCTP/hist.h1
-rw-r--r--ACE/performance-tests/Server_Concurrency/Leader_Follower/RT_CORBA_Leader_Follower.cpp4
-rw-r--r--ACE/performance-tests/Server_Concurrency/Leader_Follower/RT_CORBA_Leader_Follower.h2
-rw-r--r--ACE/performance-tests/Server_Concurrency/Queue_Based_Workers/RT_CORBA_Workers.cpp3
-rw-r--r--ACE/performance-tests/Server_Concurrency/Queue_Based_Workers/RT_CORBA_Workers.h5
-rw-r--r--ACE/performance-tests/Synch-Benchmarks/Synch_Lib/Benchmark_Base.cpp1
-rw-r--r--ACE/performance-tests/TTCP/ACE-C++/wrapper-new-ttcp.cpp3
-rw-r--r--ACE/performance-tests/TTCP/C/new-ttcp.cpp2
17 files changed, 0 insertions, 76 deletions
diff --git a/ACE/performance-tests/RPC/client.cpp b/ACE/performance-tests/RPC/client.cpp
index c55671bf358..5481f774054 100644
--- a/ACE/performance-tests/RPC/client.cpp
+++ b/ACE/performance-tests/RPC/client.cpp
@@ -58,7 +58,6 @@ int ACE_TMAIN (int argc, ACE_TCHAR* argv[])
throughput.sample (end - test_start,
end - start);
-
}
ACE_DEBUG ((LM_DEBUG, "Calibrating high resolution timer . . ."));
diff --git a/ACE/performance-tests/SCTP/Options_Manager.cpp b/ACE/performance-tests/SCTP/Options_Manager.cpp
index acba6c08253..acd9373de2c 100644
--- a/ACE/performance-tests/SCTP/Options_Manager.cpp
+++ b/ACE/performance-tests/SCTP/Options_Manager.cpp
@@ -149,7 +149,6 @@ Options_Manager::Options_Manager(int argc, ACE_TCHAR **argv, ACE_TCHAR const * c
client_port = ACE_OS::atoi(get_opt->opt_arg ());
break;
case 'i':{
-
// The argument to this option is a comma-separated list
// of dotted-decimal ipv4 addresses.
@@ -177,7 +176,6 @@ Options_Manager::Options_Manager(int argc, ACE_TCHAR **argv, ACE_TCHAR const * c
// If this representation was not obtained, terminate with
// an error.
if (!aton_retval) {
-
ACE_TCHAR error_message[Options_Manager::string_len + 100];
ACE_OS::strcpy
(error_message,
@@ -214,7 +212,6 @@ Options_Manager::Options_Manager(int argc, ACE_TCHAR **argv, ACE_TCHAR const * c
while (next_secondary_addr &&
num_secondary_connect_addrs <
max_num_secondary_connect_addrs) {
-
// Get a pointer to the next comma in the list.
ACE_TCHAR *next_next_secondary_addr = ACE_OS::strchr(next_secondary_addr, ',');
@@ -240,7 +237,6 @@ Options_Manager::Options_Manager(int argc, ACE_TCHAR **argv, ACE_TCHAR const * c
secondary_connect_addrs[num_secondary_connect_addrs++] =
ntohl(foo.s_addr);
} else {
-
ACE_TCHAR error_message[Options_Manager::string_len + 100];
ACE_OS::strcpy
(error_message,
@@ -266,7 +262,6 @@ Options_Manager::Options_Manager(int argc, ACE_TCHAR **argv, ACE_TCHAR const * c
server_port = ACE_OS::atoi(get_opt->opt_arg ());
break;
case 'a':{
-
// The argument to this option is a comma-separated list
// of dotted-decimal ipv4 addresses.
@@ -294,7 +289,6 @@ Options_Manager::Options_Manager(int argc, ACE_TCHAR **argv, ACE_TCHAR const * c
// If this representation was not obtained, terminate with
// an error.
if (!aton_retval) {
-
ACE_TCHAR error_message[Options_Manager::string_len + 100];
ACE_OS::strcpy
(error_message,
@@ -331,7 +325,6 @@ Options_Manager::Options_Manager(int argc, ACE_TCHAR **argv, ACE_TCHAR const * c
while (next_secondary_addr &&
num_secondary_accept_addrs <
max_num_secondary_accept_addrs) {
-
// Get a pointer to the next comma in the list.
ACE_TCHAR *next_next_secondary_addr = ACE_OS::strchr(next_secondary_addr, ',');
@@ -357,7 +350,6 @@ Options_Manager::Options_Manager(int argc, ACE_TCHAR **argv, ACE_TCHAR const * c
secondary_accept_addrs[num_secondary_accept_addrs++] =
ntohl(foo.s_addr);
} else {
-
ACE_TCHAR error_message[Options_Manager::string_len + 100];
ACE_OS::strcpy
(error_message,
@@ -509,7 +501,6 @@ void Options_Manager::_show_usage(FILE* out, ACE_TCHAR const * const opts_set)
ACE_OS::fprintf (out, " -h none help\n");
ACE_OS::fprintf (out, "\n");
-
} else if (!ACE_OS::strcmp(ACE_TEXT ("server-opts"), opts_set)){
ACE_OS::fprintf (out, " Flag Args Option-Name Default\n"
" -n none test-enable-nagle NO NAGLING\n");
@@ -533,7 +524,6 @@ void Options_Manager::_show_usage(FILE* out, ACE_TCHAR const * const opts_set)
ACE_OS::fprintf (out, " -h none help\n");
ACE_OS::fprintf (out, "\n");
-
} else {
ACE_OS::fprintf (out, "Invalid options set specified.\n");
}
diff --git a/ACE/performance-tests/SCTP/Options_Manager.h b/ACE/performance-tests/SCTP/Options_Manager.h
index 7239d7aae68..b26e168a250 100644
--- a/ACE/performance-tests/SCTP/Options_Manager.h
+++ b/ACE/performance-tests/SCTP/Options_Manager.h
@@ -16,7 +16,6 @@
class Options_Manager
{
public:
-
Options_Manager(int argc, ACE_TCHAR **argv, ACE_TCHAR const * const opts_set);
// constant string size
@@ -59,7 +58,6 @@ public:
private:
static ACE_CDR::Boolean __initialized;
static ACE_TCHAR __program_name[string_len];
-
};
#endif /* OPTIONS_MANAGER_H */
diff --git a/ACE/performance-tests/SCTP/SOCK_SEQPACK_Association_Test.cpp b/ACE/performance-tests/SCTP/SOCK_SEQPACK_Association_Test.cpp
index 3fdfa90ed9c..c677a757f0f 100644
--- a/ACE/performance-tests/SCTP/SOCK_SEQPACK_Association_Test.cpp
+++ b/ACE/performance-tests/SCTP/SOCK_SEQPACK_Association_Test.cpp
@@ -37,27 +37,20 @@ int ACE_TMAIN (int argc, ACE_TCHAR *argv[])
ACE_INET_Addr serverAddr;
if (argc < 2) {
-
ACE_ERROR ((LM_ERROR,
ACE_TEXT ("Usage: SOCK_SEQPACK_Association_Test hostname:port\n")));
status = 1;
-
} else if (serverAddr.set(argv[1])) {
-
ACE_ERROR ((LM_ERROR,
ACE_TEXT ("%p\n"),
ACE_TEXT ("ACE_INET_Addr::set")));
status = 1;
-
} else if (connector.connect (dataStream, serverAddr)) {
-
ACE_ERROR ((LM_ERROR,
ACE_TEXT ("%p\n"),
ACE_TEXT ("ACE_SOCK_SEQPACK_Connector::connect")));
status = 1;
-
} else {
-
ACE_DEBUG ((LM_DEBUG,
ACE_TEXT ("Connected to server at %s\n"),
argv[1]));
@@ -84,7 +77,6 @@ void dump_names(const ACE_SOCK_SEQPACK_Association& assoc)
// Get local addresses of the association
if (assoc.get_local_addrs(in_out, in_out_size)) {
-
ACE_ERROR((LM_ERROR,
"%p\n",
"get_local_addrs"));
@@ -95,9 +87,7 @@ void dump_names(const ACE_SOCK_SEQPACK_Association& assoc)
// Print individual results of get_local_addrs
for (i = 0; i < in_out_size; ++i) {
-
if (in_out[i].addr_to_string(outbuf, outbuf_size)) {
-
ACE_ERROR((LM_ERROR,
"%p\n",
"addr_to_string"));
@@ -115,7 +105,6 @@ void dump_names(const ACE_SOCK_SEQPACK_Association& assoc)
// Get remote addresses of the association
if (assoc.get_remote_addrs(in_out, in_out_size)) {
-
ACE_ERROR((LM_ERROR,
"%p\n",
"get_remote_addrs"));
@@ -126,9 +115,7 @@ void dump_names(const ACE_SOCK_SEQPACK_Association& assoc)
// Print individual results of get_remote_addrs
for (i = 0; i < in_out_size; ++i) {
-
if (in_out[i].addr_to_string(outbuf, outbuf_size)) {
-
ACE_ERROR((LM_ERROR,
"%p\n",
"addr_to_string"));
diff --git a/ACE/performance-tests/SCTP/SOCK_SEQPACK_clt.cpp b/ACE/performance-tests/SCTP/SOCK_SEQPACK_clt.cpp
index f218a31cf44..dfeff21fbac 100644
--- a/ACE/performance-tests/SCTP/SOCK_SEQPACK_clt.cpp
+++ b/ACE/performance-tests/SCTP/SOCK_SEQPACK_clt.cpp
@@ -42,7 +42,6 @@ ACE_High_Res_Timer::global_scale_factor_type const microsec_clock_scale_factor
ACE_SCTP::HIST runTest(ACE_SOCK_SEQPACK_Association &);
int ACE_TMAIN (int argc, ACE_TCHAR **argv){
-
// Initialize the options manager
Options_Manager optsMgr(argc, argv, ACE_TEXT ("client-opts"));
@@ -135,7 +134,6 @@ ACE_SCTP::HIST createHistogram(ACE_CDR::ULong messageSize){
// send the test header (only contains number of iterations)
int sendHeader(ACE_SOCK_SEQPACK_Association & stream) {
-
// create an ACE CDR output stream and place the header information
// into it
ACE_OutputCDR hdrCDR;
@@ -155,7 +153,6 @@ int sendHeader(ACE_SOCK_SEQPACK_Association & stream) {
// conduct the UnMarshalled Octet performance test using separate
// send_n calls with Nagle's algorithm disabled
ACE_SCTP::HIST runUnmarshalledOctetTest(ACE_CDR::Octet *buf, size_t seqLen, ACE_SOCK_SEQPACK_Association & stream){
-
ACE_CDR::ULong const testIterations = Options_Manager::test_iterations;
size_t bt;
@@ -181,7 +178,6 @@ ACE_SCTP::HIST runUnmarshalledOctetTest(ACE_CDR::Octet *buf, size_t seqLen, ACE_
// prime the client and server before starting the test
for(cnt=0;cnt<primerIterations;++cnt){
-
// send message size
// TODO : The message length should be CDR encoded
ACE_CDR::ULong msgLenExpressed = ACE_HTONL(msgLen);
@@ -219,7 +215,6 @@ ACE_SCTP::HIST runUnmarshalledOctetTest(ACE_CDR::Octet *buf, size_t seqLen, ACE_
iovec iov[2];
// PERFORMANCE TEST LOOP
for (cnt = 0; cnt < testIterations; ++cnt){
-
// get the start time
startTime = ACE_OS::gethrtime();
if (!startTime)
@@ -289,7 +284,6 @@ ACE_SCTP::HIST runTest(ACE_SOCK_SEQPACK_Association & stream)
msgLen *= 2;
-
// send a header to the server that contains test parameters
if (sendHeader(stream) < 0)
ACE_ERROR_RETURN((LM_ERROR,
diff --git a/ACE/performance-tests/SCTP/SOCK_SEQPACK_srv.cpp b/ACE/performance-tests/SCTP/SOCK_SEQPACK_srv.cpp
index f2d91c0082c..6cd98f45771 100644
--- a/ACE/performance-tests/SCTP/SOCK_SEQPACK_srv.cpp
+++ b/ACE/performance-tests/SCTP/SOCK_SEQPACK_srv.cpp
@@ -42,7 +42,6 @@ struct ArgStruct {
// thread function that serves the client for the UnMarshalled Octet
// test
static ACE_THR_FUNC_RETURN unmarshalledOctetServer (void *arg){
-
// unbundle the arguments
ArgStruct * args = reinterpret_cast<ArgStruct *> (arg);
ACE_SOCK_SEQPACK_Association * dataModeStream = args->stream;
@@ -51,7 +50,6 @@ static ACE_THR_FUNC_RETURN unmarshalledOctetServer (void *arg){
// serve the client for numIterations synchronous invocations
do {
-
// READ A MESSAGE FROM THE CLIENT
size_t bt;
@@ -89,7 +87,6 @@ static ACE_THR_FUNC_RETURN unmarshalledOctetServer (void *arg){
ACE_TEXT ("%p\n"),
ACE_TEXT ("send_n")),
0);
-
} while (--numIterations);
// close and destroy the stream
@@ -216,7 +213,6 @@ static void run_server (ACE_HANDLE handle)
int ACE_TMAIN (int argc, ACE_TCHAR **argv){
-
Options_Manager optsMgr(argc, argv, ACE_TEXT ("server-opts"));
// show usage is requested
@@ -306,7 +302,6 @@ int ACE_TMAIN (int argc, ACE_TCHAR **argv){
handle_set.set_bit(acceptor_socket.get_handle());
for (;;){
-
ACE_Time_Value timeout(ACE_DEFAULT_TIMEOUT);
ACE_Handle_Set temp = handle_set;
@@ -330,7 +325,6 @@ int ACE_TMAIN (int argc, ACE_TCHAR **argv){
else if (result == 0){
ACE_DEBUG ((LM_DEBUG,
ACE_TEXT ("(%P|%t) select timed out\n")));
-
}
else { // case where a file descriptor was actually set
if (!(temp.is_set(acceptor_socket.get_handle()))){
@@ -349,7 +343,6 @@ int ACE_TMAIN (int argc, ACE_TCHAR **argv){
else{
ACE_DEBUG ((LM_DEBUG,
ACE_TEXT ("(%P|%t) spawning server\n")));
-
}
// Run the server.
run_server (new_stream.get_handle ());
diff --git a/ACE/performance-tests/SCTP/SOCK_STREAM_clt.cpp b/ACE/performance-tests/SCTP/SOCK_STREAM_clt.cpp
index 967a7838a8d..858ba407a7d 100644
--- a/ACE/performance-tests/SCTP/SOCK_STREAM_clt.cpp
+++ b/ACE/performance-tests/SCTP/SOCK_STREAM_clt.cpp
@@ -43,7 +43,6 @@ ACE_High_Res_Timer::global_scale_factor_type const microsec_clock_scale_factor =
ACE_SCTP::HIST runTest(ACE_SOCK_Stream &);
int ACE_TMAIN (int argc, ACE_TCHAR **argv){
-
// Initialize the options manager
Options_Manager optsMgr(argc, argv, ACE_TEXT ("client-opts"));
@@ -110,7 +109,6 @@ int ACE_TMAIN (int argc, ACE_TCHAR **argv){
// create a histogram to store test results
ACE_SCTP::HIST createHistogram(ACE_CDR::ULong messageSize){
-
// The histogram created below lives beyond the scope of this
// function. So the memory allocated here cannot be cleaned up when
// this function goes out of scope. Unfortunately the histogram
@@ -135,7 +133,6 @@ int ACE_TMAIN (int argc, ACE_TCHAR **argv){
// send the test header (only contains number of iterations)
int sendHeader(ACE_SOCK_Stream & stream) {
-
// create an ACE CDR output stream and place the header information
// into it
ACE_OutputCDR hdrCDR;
@@ -155,7 +152,6 @@ int sendHeader(ACE_SOCK_Stream & stream) {
// conduct the UnMarshalled Octet performance test using separate
// send_n calls with Nagle's algorithm disabled
ACE_SCTP::HIST runUnmarshalledOctetTest(ACE_CDR::Octet *buf, size_t seqLen, ACE_SOCK_Stream & stream){
-
ACE_CDR::ULong const testIterations = Options_Manager::test_iterations;
size_t bt;
@@ -191,7 +187,6 @@ ACE_SCTP::HIST runUnmarshalledOctetTest(ACE_CDR::Octet *buf, size_t seqLen, ACE_
// prime the client and server before starting the test
for(cnt=0;cnt<primerIterations;++cnt){
-
// send message size
// TODO : The message length should be CDR encoded
ACE_CDR::ULong msgLenExpressed = ACE_HTONL(msgLen);
@@ -229,7 +224,6 @@ ACE_SCTP::HIST runUnmarshalledOctetTest(ACE_CDR::Octet *buf, size_t seqLen, ACE_
iovec iov[2];
// PERFORMANCE TEST LOOP
for (cnt = 0; cnt < testIterations; ++cnt){
-
// get the start time
startTime = ACE_OS::gethrtime();
if (!startTime)
@@ -294,7 +288,6 @@ ACE_SCTP::HIST runUnmarshalledOctetTest(ACE_CDR::Octet *buf, size_t seqLen, ACE_
// function.
ACE_SCTP::HIST runTest(ACE_SOCK_Stream & stream)
{
-
size_t msgLen = 1;
for (int i=1; i <= Options_Manager::payload_size_power_of_2; i++)
msgLen *= 2;
diff --git a/ACE/performance-tests/SCTP/SOCK_STREAM_srv.cpp b/ACE/performance-tests/SCTP/SOCK_STREAM_srv.cpp
index 72a23b6cce9..cfffabcb2d7 100644
--- a/ACE/performance-tests/SCTP/SOCK_STREAM_srv.cpp
+++ b/ACE/performance-tests/SCTP/SOCK_STREAM_srv.cpp
@@ -40,7 +40,6 @@ struct ArgStruct {
// thread function that serves the client for the UnMarshalled Octet
// test
static ACE_THR_FUNC_RETURN unmarshalledOctetServer (void *arg){
-
// unbundle the arguments
ArgStruct * args = reinterpret_cast<ArgStruct *> (arg);
ACE_SOCK_Stream * dataModeStream = args->stream;
@@ -49,7 +48,6 @@ static ACE_THR_FUNC_RETURN unmarshalledOctetServer (void *arg){
// serve the client for numIterations synchronous invocations
do {
-
// READ A MESSAGE FROM THE CLIENT
size_t bt;
@@ -87,7 +85,6 @@ static ACE_THR_FUNC_RETURN unmarshalledOctetServer (void *arg){
ACE_TEXT ("%p\n"),
ACE_TEXT ("send_n")),
0);
-
} while (--numIterations);
// close and destroy the stream
@@ -221,7 +218,6 @@ static void run_server (ACE_HANDLE handle)
}
int ACE_TMAIN (int argc, ACE_TCHAR **argv){
-
Options_Manager optsMgr(argc, argv, ACE_TEXT ("server-opts"));
// show usage is requested
@@ -301,7 +297,6 @@ int ACE_TMAIN (int argc, ACE_TCHAR **argv){
handle_set.set_bit(acceptor_socket.get_handle());
for (;;){
-
ACE_Time_Value timeout(ACE_DEFAULT_TIMEOUT);
ACE_Handle_Set temp = handle_set;
@@ -325,7 +320,6 @@ int ACE_TMAIN (int argc, ACE_TCHAR **argv){
else if (result == 0){
ACE_DEBUG ((LM_DEBUG,
ACE_TEXT ("(%P|%t) select timed out\n")));
-
}
else { // case where a file descriptor was actually set
if (!(temp.is_set(acceptor_socket.get_handle()))){
@@ -344,7 +338,6 @@ int ACE_TMAIN (int argc, ACE_TCHAR **argv){
else{
ACE_DEBUG ((LM_DEBUG,
ACE_TEXT ("(%P|%t) spawning server\n")));
-
}
// Run the server.
run_server (new_stream.get_handle ());
diff --git a/ACE/performance-tests/SCTP/hist.cpp b/ACE/performance-tests/SCTP/hist.cpp
index 7dff4e8b0b7..bcda96c0029 100644
--- a/ACE/performance-tests/SCTP/hist.cpp
+++ b/ACE/performance-tests/SCTP/hist.cpp
@@ -31,7 +31,6 @@
#include "hist.h"
namespace ACE_SCTP
{
-
hist_t *head_hist, *tail_hist;
hist_t *histogram(char *name, unsigned int num_bins, double first,
@@ -299,7 +298,6 @@ void add_histogram(HIST dest, HIST source) {
}
double histfloor (double x) {
-
#ifdef WIN32
return ACE_OS::floor(x);
#else
diff --git a/ACE/performance-tests/SCTP/hist.h b/ACE/performance-tests/SCTP/hist.h
index 2e3844ec5af..4aae40379c9 100644
--- a/ACE/performance-tests/SCTP/hist.h
+++ b/ACE/performance-tests/SCTP/hist.h
@@ -4,7 +4,6 @@
namespace ACE_SCTP
{
-
struct optheader {
char *key;
char *value;
diff --git a/ACE/performance-tests/Server_Concurrency/Leader_Follower/RT_CORBA_Leader_Follower.cpp b/ACE/performance-tests/Server_Concurrency/Leader_Follower/RT_CORBA_Leader_Follower.cpp
index 1ab919b1b2a..4274659d253 100644
--- a/ACE/performance-tests/Server_Concurrency/Leader_Follower/RT_CORBA_Leader_Follower.cpp
+++ b/ACE/performance-tests/Server_Concurrency/Leader_Follower/RT_CORBA_Leader_Follower.cpp
@@ -1,7 +1,6 @@
#include "RT_CORBA_Leader_Follower.h"
-
#if defined (ACE_HAS_THREADS)
// We need the following only if we have threads enabled..
@@ -38,7 +37,6 @@ ACE_High_Res_Timer test_timer;
-
/*******************************************************************/
// Constructor for Synchronisers
Synchronisers::Synchronisers (void)
@@ -67,7 +65,6 @@ Synchronisers::start_synchronization (void)
if (ready_threads == number_of_threads)
{
-
// Reset the ready_threads so that we can wait at the end of
// runs
ready_threads = 0;
@@ -109,7 +106,6 @@ Synchronisers::end_synchronization (void)
if (ready_threads == number_of_threads)
{
-
// Reset the ready_threads so that we can wait at the end of
// runs
ready_threads = 0;
diff --git a/ACE/performance-tests/Server_Concurrency/Leader_Follower/RT_CORBA_Leader_Follower.h b/ACE/performance-tests/Server_Concurrency/Leader_Follower/RT_CORBA_Leader_Follower.h
index f8512655a8e..ff2d42aec5d 100644
--- a/ACE/performance-tests/Server_Concurrency/Leader_Follower/RT_CORBA_Leader_Follower.h
+++ b/ACE/performance-tests/Server_Concurrency/Leader_Follower/RT_CORBA_Leader_Follower.h
@@ -53,7 +53,6 @@ public:
int end_synchronization (void);
private:
-
/// The mutex and condition variable that is used for
/// synchronisation.
ACE_SYNCH_MUTEX mutex_;
@@ -79,7 +78,6 @@ private:
class Leader_Follower_Task : public ACE_Task_Base
{
public:
-
/// Ctor with a mutex and a condition variable
Leader_Follower_Task (Synchronisers &synch);
diff --git a/ACE/performance-tests/Server_Concurrency/Queue_Based_Workers/RT_CORBA_Workers.cpp b/ACE/performance-tests/Server_Concurrency/Queue_Based_Workers/RT_CORBA_Workers.cpp
index 6c604f70d8d..5204a996263 100644
--- a/ACE/performance-tests/Server_Concurrency/Queue_Based_Workers/RT_CORBA_Workers.cpp
+++ b/ACE/performance-tests/Server_Concurrency/Queue_Based_Workers/RT_CORBA_Workers.cpp
@@ -519,7 +519,6 @@ ACE_TMAIN (int argc, ACE_TCHAR *argv[])
}
-
// Activate the input and output threads
result = input_task.activate (flags,
1,
@@ -530,7 +529,6 @@ ACE_TMAIN (int argc, ACE_TCHAR *argv[])
return result;
-
// Activate the workers.
result = output_task.activate (flags,
1,
@@ -541,7 +539,6 @@ ACE_TMAIN (int argc, ACE_TCHAR *argv[])
return result;
-
// Wait for all threads to terminate.
result = ACE_Thread_Manager::instance ()->wait ();
diff --git a/ACE/performance-tests/Server_Concurrency/Queue_Based_Workers/RT_CORBA_Workers.h b/ACE/performance-tests/Server_Concurrency/Queue_Based_Workers/RT_CORBA_Workers.h
index 3fc194cdd2b..3b796e8d72b 100644
--- a/ACE/performance-tests/Server_Concurrency/Queue_Based_Workers/RT_CORBA_Workers.h
+++ b/ACE/performance-tests/Server_Concurrency/Queue_Based_Workers/RT_CORBA_Workers.h
@@ -63,7 +63,6 @@ public:
int end_synchronization (void);
private:
-
/// The mutex that is used for synchronisation.
ACE_SYNCH_MUTEX mutex_;
@@ -91,7 +90,6 @@ public:
int svc (void);
private:
-
/// Our referance to Synchronisers
Synchronisers &synch_;
};
@@ -118,7 +116,6 @@ public:
virtual int put (ACE_Message_Block *, ACE_Time_Value * = 0);
private:
-
/// Our referance to Synchronisers
Synchronisers &synch_;
};
@@ -145,7 +142,6 @@ public:
/// Processed messages
int processed (void);
private:
-
/// Our referance to Synchronisers
Synchronisers &synch_;
@@ -155,7 +151,6 @@ private:
-
#endif /*ACE_HAS_THREADS*/
#include /**/ "ace/post.h"
diff --git a/ACE/performance-tests/Synch-Benchmarks/Synch_Lib/Benchmark_Base.cpp b/ACE/performance-tests/Synch-Benchmarks/Synch_Lib/Benchmark_Base.cpp
index ff537684317..f7e77a834d7 100644
--- a/ACE/performance-tests/Synch-Benchmarks/Synch_Lib/Benchmark_Base.cpp
+++ b/ACE/performance-tests/Synch-Benchmarks/Synch_Lib/Benchmark_Base.cpp
@@ -53,7 +53,6 @@ Benchmark_Method_Base::exec (ACE_Service_Repository_Iterator *sri)
if (this->valid_test_object (bp))
{
-
ACE_DEBUG ((LM_DEBUG, "\nstarting up %s\n", sr->name ()));
int notused = this->pre_run_test (bp) == 0 && this->run_test () == 0 &&
diff --git a/ACE/performance-tests/TTCP/ACE-C++/wrapper-new-ttcp.cpp b/ACE/performance-tests/TTCP/ACE-C++/wrapper-new-ttcp.cpp
index e06e86cd021..b84300798a8 100644
--- a/ACE/performance-tests/TTCP/ACE-C++/wrapper-new-ttcp.cpp
+++ b/ACE/performance-tests/TTCP/ACE-C++/wrapper-new-ttcp.cpp
@@ -713,7 +713,6 @@ read_timer (char *str, int len)
{
perror ("Getting 'itimer' REAL failed");
return (0.0);
-
}
fprintf(stdout, "End transaction time = %d sec and %d usec\n", itimedol.it_value.tv_sec, itimedol.it_value.tv_usec);
prusage (&ru0, &ru1, &itime0.it_value, &itimedol.it_value, line);
@@ -851,7 +850,6 @@ prusage (register struct rusage *r0, struct rusage *r1,
static void
tvadd (struct timeval *tsum, struct timeval *t0, struct timeval *t1)
{
-
tsum->tv_sec = t0->tv_sec + t1->tv_sec;
tsum->tv_usec = t0->tv_usec + t1->tv_usec;
if (tsum->tv_usec > 1000000)
@@ -861,7 +859,6 @@ tvadd (struct timeval *tsum, struct timeval *t0, struct timeval *t1)
static void
tvsub (struct timeval *tdiff, struct timeval *t1, struct timeval *t0)
{
-
tdiff->tv_sec = t1->tv_sec - t0->tv_sec;
tdiff->tv_usec = t1->tv_usec - t0->tv_usec;
if (tdiff->tv_usec < 0)
diff --git a/ACE/performance-tests/TTCP/C/new-ttcp.cpp b/ACE/performance-tests/TTCP/C/new-ttcp.cpp
index bd5038ceaa8..cafde7cb170 100644
--- a/ACE/performance-tests/TTCP/C/new-ttcp.cpp
+++ b/ACE/performance-tests/TTCP/C/new-ttcp.cpp
@@ -871,7 +871,6 @@ prusage (register struct rusage *r0, struct rusage *r1,
static void
tvadd (struct timeval *tsum, struct timeval *t0, struct timeval *t1)
{
-
tsum->tv_sec = t0->tv_sec + t1->tv_sec;
tsum->tv_usec = t0->tv_usec + t1->tv_usec;
if (tsum->tv_usec > 1000000)
@@ -881,7 +880,6 @@ tvadd (struct timeval *tsum, struct timeval *t0, struct timeval *t1)
static void
tvsub (struct timeval *tdiff, struct timeval *t1, struct timeval *t0)
{
-
tdiff->tv_sec = t1->tv_sec - t0->tv_sec;
tdiff->tv_usec = t1->tv_usec - t0->tv_usec;
if (tdiff->tv_usec < 0)