diff options
| -rw-r--r-- | ACE/examples/ASX/UPIPE_Event_Server/event_server.cpp | 39 | ||||
| -rw-r--r-- | TAO/tests/DII_AMI_Forward/server.cpp | 6 | ||||
| -rw-r--r-- | TAO/tests/ForwardOnceUponException/client.cpp | 8 | ||||
| -rw-r--r-- | TAO/tests/ForwardUponObjectNotExist/client.cpp | 58 |
4 files changed, 60 insertions, 51 deletions
diff --git a/ACE/examples/ASX/UPIPE_Event_Server/event_server.cpp b/ACE/examples/ASX/UPIPE_Event_Server/event_server.cpp index 969c2a02a96..06319b23c7e 100644 --- a/ACE/examples/ASX/UPIPE_Event_Server/event_server.cpp +++ b/ACE/examples/ASX/UPIPE_Event_Server/event_server.cpp @@ -85,23 +85,28 @@ consumer (void *) par1 = currsec; - while (done == 0 - && (c_stream.recv (mb_p) != -1)) - if (mb_p->length () > 1) - { - cnt++; - if (verb) - cout << " consumer received message !!!!!! " - << mb_p->rd_ptr () << endl; - } - else - { - if (verb) - cout << "consumer got last mb" - << (char) * (mb_p->rd_ptr ()) << endl; - c_stream.close (); - done = 1; - } + while (done == 0 && (c_stream.recv (mb_p) != -1)) + { + if (mb_p->length () > 1) + { + cnt++; + if (verb) + { + cout << " consumer received message !!!!!! " + << mb_p->rd_ptr () << endl; + } + } + else + { + if (verb) + { + cout << "consumer got last mb" + << (char) * (mb_p->rd_ptr ()) << endl; + } + c_stream.close (); + done = 1; + } + } ACE_OS::time (&currsec); par2 = currsec; diff --git a/TAO/tests/DII_AMI_Forward/server.cpp b/TAO/tests/DII_AMI_Forward/server.cpp index 9e62dcf8532..9ba3fd91155 100644 --- a/TAO/tests/DII_AMI_Forward/server.cpp +++ b/TAO/tests/DII_AMI_Forward/server.cpp @@ -18,6 +18,7 @@ parse_args (int argc, ACE_TCHAR *argv[]) int c; while ((c = get_opts ()) != -1) + { switch (c) { case 'o': @@ -32,8 +33,9 @@ parse_args (int argc, ACE_TCHAR *argv[]) argv [0]), -1); } - // Indicates successful parsing of the command line - return 0; + } + // Indicates successful parsing of the command line + return 0; } int diff --git a/TAO/tests/ForwardOnceUponException/client.cpp b/TAO/tests/ForwardOnceUponException/client.cpp index 4d744d68c2a..2a0223db73b 100644 --- a/TAO/tests/ForwardOnceUponException/client.cpp +++ b/TAO/tests/ForwardOnceUponException/client.cpp @@ -55,10 +55,10 @@ parse_args (int argc, ACE_TCHAR *argv[]) -1); } - if (ACE_OS::strncmp (ior, - corbaloc_prefix, - ACE_OS::strlen(corbaloc_prefix)) != 0) - return 1; + if (ACE_OS::strncmp (ior, + corbaloc_prefix, + ACE_OS::strlen(corbaloc_prefix)) != 0) + return 1; // Indicates successful parsing of the command line return 0; diff --git a/TAO/tests/ForwardUponObjectNotExist/client.cpp b/TAO/tests/ForwardUponObjectNotExist/client.cpp index 3e4948b7c89..fe0f24b6c99 100644 --- a/TAO/tests/ForwardUponObjectNotExist/client.cpp +++ b/TAO/tests/ForwardUponObjectNotExist/client.cpp @@ -15,35 +15,37 @@ parse_args (int argc, ACE_TCHAR *argv[]) int c; while ((c = get_opts ()) != -1) - switch (c) - { - case 'x': - do_shutdown = true; - break; - - case 'k': - ior = get_opts.opt_arg (); - break; - - case 'e': - expected_object_not_exist = ACE_OS::atoi (get_opts.opt_arg ()); - break; - - case '?': - default: - ACE_ERROR_RETURN ((LM_ERROR, - "usage: %s " - "-k <ior> -x " - "-e <expected_object_not_exist> " - "\n", - argv [0]), - -1); - } + { + switch (c) + { + case 'x': + do_shutdown = true; + break; + + case 'k': + ior = get_opts.opt_arg (); + break; + + case 'e': + expected_object_not_exist = ACE_OS::atoi (get_opts.opt_arg ()); + break; + + case '?': + default: + ACE_ERROR_RETURN ((LM_ERROR, + "usage: %s " + "-k <ior> -x " + "-e <expected_object_not_exist> " + "\n", + argv [0]), + -1); + } + } - if (ACE_OS::strncmp (ior, - corbaloc_prefix, - ACE_OS::strlen (corbaloc_prefix)) != 0) - return 1; + if (ACE_OS::strncmp (ior, + corbaloc_prefix, + ACE_OS::strlen (corbaloc_prefix)) != 0) + return 1; // Indicates successful parsing of the command line return 0; |