diff options
Diffstat (limited to 'tests/IOStream_Test.cpp')
| -rw-r--r-- | tests/IOStream_Test.cpp | 479 |
1 files changed, 0 insertions, 479 deletions
diff --git a/tests/IOStream_Test.cpp b/tests/IOStream_Test.cpp deleted file mode 100644 index 45ff4c83ace..00000000000 --- a/tests/IOStream_Test.cpp +++ /dev/null @@ -1,479 +0,0 @@ -// $Id$ - -// ============================================================================ -// -// = LIBRARY -// tests -// -// = FILENAME -// IOStream_Test.cpp -// -// = DESCRIPTION -// This is a simple test of the IOStream class that illustrates -// how to use iostream operations on almost arbitrary I/O classes. -// -// = AUTHOR -// James CE Johnson <jcej@lads.com> -// -// ============================================================================ - -#include "test_config.h" -#include "ace/Thread.h" -#include "ace/Acceptor.h" -#include "ace/SOCK_Connector.h" -#include "ace/SOCK_Acceptor.h" -#include "ace/IOStream.h" - -ACE_RCSID(tests, IOStream_Test, "$Id$") - -#if defined(__BORLANDC__) && __BORLANDC__ >= 0x0530 -USELIB("..\ace\aced.lib"); -//--------------------------------------------------------------------------- -#endif /* defined(__BORLANDC__) && __BORLANDC__ >= 0x0530 */ - -#if !defined (ACE_LACKS_ACE_IOSTREAM) - -typedef ACE_IOStream<ACE_SOCK_Stream> ACE_SOCK_IOStream; - -/* The biggest drawback to an iostream is that it generally - eats up whitespace when performing a get (>>) operation. - - That may be good if you're reading non-textual data but - if you're trying to read a stream of words with embedded - whitespace, it isn't going to be pleasant. - - If you've been blessed with the GNU String class, I've - already provided a derived class, QuotedString, that - makes dealing with strings very easy. - - If you're stuck with an array of characters then you - will probably need somthing like I have below. - - - On the other hand, one of the biggest advantages to an - iostream is that it eats up whitespace :-) - - If you put (<<) your non-textual data to the iostream - with any number of whitespace between the data then - you can easily get (>>) the data from the iostream - without having to worry about delimeters and such. - - - The main thing to keep in mind when using an iostream - between peers is that you MUST keep the data "fields" - in sync. That is, if the "putter" puts an int followed - by a float followed by a double, you must make sure - that the "getter" will be attempting to get an int - then a float then a double. - */ - -// Since I can't rely on GNU's String class being everywhere (yet), -// here's a simple class that will work with quoted strings. Use at -// your own risk! It is very incomplete! - -class qchar -{ -public: - qchar (void) { c_ = '\0'; } - - qchar (char c) : c_(c) { }; - - operator char () const { return c_; } - - qchar operator= (char c) { return c_ = c; } - - int operator== (char c) { return c_ == c; } - - friend ACE_SOCK_IOStream &operator>> (ACE_SOCK_IOStream & stream, qchar * buf); - friend ACE_SOCK_IOStream &operator<< (ACE_SOCK_IOStream & stream, qchar * buf); - friend ostream &operator<< (ostream & stream, qchar * buf); - -private: - char c_; -}; - -// This is taken almost directly from the QuotedString object that has -// been derived from GNU's String class. The advantage to using -// QuotedString is that it is MUCH more robust than qchar will every -// be. - -ACE_SOCK_IOStream & -operator>> (ACE_SOCK_IOStream & stream, qchar *buf) -{ - char c; - - *buf = '\0'; // Initialize the string - - stream.get(c); - - if (!stream) // eat space up to the first char - return stream; - - // if we don't have a quote, append until we see space - if (c != '"') - for (*buf++ = c; -#ifdef CHORUS - stream.get(c) && !isspace(c); -#else - (void *) stream.get(c) && !isspace(c); -#endif - *buf++ = c) - continue; - else -#ifdef CHORUS - for (; stream.get(c) && c != '"'; *buf++ = c) -#else - for (; (void *) stream.get(c) && c != '"'; *buf++ = c) -#endif - if (c == '\\') - { - stream.get(c); - if (c != '"') - *buf++ = '\\'; - } - - *buf = '\0'; - - return stream; -} - -ACE_SOCK_IOStream & -operator<< (ACE_SOCK_IOStream &stream, qchar *buf) -{ - stream.put ('"'); - - while (*buf) - { - if (*buf == '"') - stream.put ('\\'); - - stream.put ((char) *buf++); - } - - stream.put ('"'); - - return stream; -} - -ostream & -operator<< (ostream &stream, qchar *buf) -{ - while (*buf) - stream.put ((char) *buf++); - - return stream; -} - -// Our client thread will initiate the test by sending some data to -// the server. - -static void * -client (void *arg = 0) -{ - ACE_UNUSED_ARG (arg); - - // We don't _need_ to dynamically allocate the ACE_SOCK_IOStream. - // But if we don't, it doesn't get destroyed on some platforms, - // e.g., g++ 2.7.2.1 and Sun C++ 4.2 on Solaris 2.5.1. (It does - // work on Linux, so the code seems fine.) If we manage the storage - // ourselves, we _will_ destroy it at the end of this function. - ACE_SOCK_IOStream server; - - ACE_INET_Addr *remote_addr = (ACE_INET_Addr *) arg; - ACE_INET_Addr addr (remote_addr->get_port_number (), - ACE_DEFAULT_SERVER_HOST); - ACE_SOCK_Connector connector; - - if (connector.connect (server, addr) == -1) - ACE_ERROR_RETURN ((LM_ERROR, - "(%t) %p\n", "Failed to connect to server thread"), - 0); - - // Send a string to the server which it can interpret as a qchar[] - const char *str = "\"This is a test string.\""; - ACE_DEBUG ((LM_DEBUG, "(%P|%t) Client Sending: (%s)\n", str)); - server << str << endl; - - // Allow the server to get the string and echo it to the user. (The - // iostream doesn't need this, but humans do :) - ACE_OS::sleep (2); - - // Send another string but this time the server will read it as a - // char[]. Notice how the server's output doesn't include all of - // the spaces sent by the client. - - str = "\"THIS IS A TEST STRING.\""; - ACE_DEBUG ((LM_DEBUG, "(%P|%t) Client Sending: (%s)\n", str)); - server << str << endl; - - // Again, give the server time to display the happenings to the - // user. - ACE_OS::sleep (2); - - // Read from the server an int, float, long, float double. The - // iostream will pull them out by using the whitespace provided by - // the server. - - ACE_DEBUG ((LM_DEBUG, "(%P|%t) Client Receiving\n")); - - ACE_Time_Value timeout (2); - ACE_Time_Value *timeoutp = &timeout; - - server >> timeoutp; - - int i; - float f1, f2; - long l; - double d; - - while (!(server >> i)) - { - int eof = server.eof (); - if (eof) - { - ACE_DEBUG ((LM_DEBUG, "(%P|%t) Unrecoverable stream error/eof\n")); - break; - } - else - { - ACE_DEBUG ((LM_DEBUG, "(%P|%t) Recoverable stream error/timed out)\n")); - server.clear (0); - } - } - - server >> f1; - server >> l; - server >> f2; - server >> d; - - ACE_DEBUG ((LM_DEBUG, - "(%P|%t) Client Received: int %d float %f long %d float %f double %f\n", - i, f1, (int) l, f2, d)); - - // Check for proper received values. - ACE_ASSERT (i == 1 && (f1 >= 0.123420 && f1 <= 0.123422) - && l == 666555444 && (f2 >= 23.44 && f2 <= 23.46) - && (d >= -47.1e+9 && d <= -45.9e+9)); - // Reset the precision to limit ourselves to two significant digits. - server.precision (2); - - // Now, make a little change & send 'em back. - i *= -1; server << i << " "; - f1 *= -1.0; server << f1 << " "; - l *= -1; server << l << " "; - f2 *= -1.0; server << f2 << " "; - d *= -1; server << d << " "; - server << endl; - - // Shut down the test. - server.close (); - - return 0; -} - -// Test the server's ability to receive data from the client and then -// begin a two-way conversation. - -static void * -server (void *arg = 0) -{ - // We don't _need_ to dynamically allocate the ACE_SOCK_IOStream. - // But if we don't, it doesn't get destroyed on some platforms, - // e.g., g++ 2.7.2.1 and Sun C++ 4.2 on Solaris 2.5.1. (It does - // work on Linux, so the code seems fine.) If we manage the storage - // ourselves, we _will_ destroy it at the end of this function. - ACE_SOCK_IOStream client_handler; - - ACE_INET_Addr server_addr; - ACE_SOCK_Acceptor *acceptor = (ACE_SOCK_Acceptor *) arg; - - if (acceptor->get_local_addr (server_addr) == -1) - ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "get_local_addr"), 0); - -#if defined (ACE_HAS_THREADS) - if (ACE_Thread_Manager::instance ()->spawn (ACE_THR_FUNC (client), - (void *) &server_addr, - THR_NEW_LWP | THR_DETACHED) == -1) - ACE_ERROR_RETURN ((LM_ERROR, - "(%t) %p\n", "spawing client thread"), - 0); -#endif /* ACE_HAS_THREADS */ - - if (acceptor->accept (client_handler) == -1) - ACE_ERROR_RETURN ((LM_ERROR, - "(%P|%t) Failed to accept new client_handler"), - 0); - - // Read a qbuf[] from the client. Notice that all of the client's - // whitespace is preserved. - qchar qbuf[BUFSIZ]; - ACE_OS::memset (qbuf, 0, sizeof qbuf); - client_handler >> qbuf; - - ACE_DEBUG ((LM_DEBUG, - "(%P|%t) Server Received: (\"%s\")\n", - qbuf)); - - // Give the client time to announce the next test to the user. - ACE_OS::sleep (2); - - // Now we try to use a char[] to get a string from the client. - // Compared to the method above, this is quite messy. Notice also - // that whitespace is lost. - -#if defined(ACE_HAS_STRING_CLASS) && defined (ACE_HAS_STANDARD_CPP_LIBRARY) - ACE_IOStream_String buf; - ACE_DEBUG ((LM_DEBUG, "(%P|%t) Server Received: (")); - - while (client_handler && - (buf.length() == 0 || buf[buf.length() - 1] != '"')) - { - if (!(client_handler >> buf)) - break; - - if (buf.length() > 0) - ACE_DEBUG ((LM_DEBUG, "%s ", buf.c_str())); - } - - ACE_DEBUG ((LM_DEBUG, ")\n")); - -#else - char buf[BUFSIZ]; - ACE_OS::memset (buf, 0, sizeof buf); - ACE_DEBUG ((LM_DEBUG, "(%P|%t) Server Received: (")); - - while (ACE_OS::strlen (buf) == 0 - || buf[ACE_OS::strlen (buf) - 1] != '"') - { - if (!(client_handler >> buf)) - break; - ACE_DEBUG ((LM_DEBUG, "%s ", buf)); - } - - ACE_DEBUG ((LM_DEBUG, ")\n")); -#endif /* ACE_HAS_STRING_CLASS */ - - // Send some non-textual data to the client. We use a single - // character to separate the fields but we could have used any valid - // whitespace. The data will be sent if the iostream's buffer gets - // filled or when we flush it with an explicit client.sync() command - // or the implicit <<endl. - - ACE_DEBUG ((LM_DEBUG, "(%P|%t) Server sleeping\n")); - ACE_OS::sleep (5); - - ACE_DEBUG ((LM_DEBUG, "(%P|%t) Server Sending: 1 .12342134 666555444 23.45 -46.5e9 \n")); - client_handler << 1 << " "; - client_handler << .12342134 << " "; - client_handler << 666555444 << " "; - client_handler << 23.45 << " "; - client_handler << -46.5e9 << " "; - client_handler << endl; - - // The client will have changed the sign of each data field and sent - // 'em all back to us. At the same time, the client used the - // precision() function to change the significant digits for - // non-integer values. - int i; - float f1, f2; - long l; - double d; - client_handler >> i >> f1 >> l >> f2 >> d; - - ACE_DEBUG ((LM_DEBUG, - "(%P|%t) Server Received: int %d float %g long %d float %g double %g\n", - i, f1, (int) l, f2, d)); - - // check for proper received values - ACE_ASSERT (i == -1 && (f1 >= -0.13 && f1 <= -0.11) - && l == -666555444 && (f2 >= -24.0 && f2 <= -22.0) - && (d >= 45e+9 && d <= 47e+9)); - - client_handler.close (); - - return 0; -} - -static int -spawn (void) -{ - // Acceptor; - ACE_SOCK_Acceptor acceptor; - - if (acceptor.open ((const ACE_INET_Addr &) ACE_Addr::sap_any) == -1) - ACE_ERROR_RETURN ((LM_ERROR, "(%P|%t) %p\n", "open"), -1); -#if defined (ACE_HAS_THREADS) - else if (ACE_Thread_Manager::instance ()->spawn (ACE_THR_FUNC (server), - &acceptor, - THR_NEW_LWP | THR_DETACHED) == -1) - ACE_ERROR_RETURN ((LM_ERROR, - "%p\n", "spawning server thread"), - -1); - - // Wait for the client and server thread to exit. - ACE_Thread_Manager::instance ()->wait (); - -#elif !defined (ACE_LACKS_FORK) - - switch (ACE_OS::fork ("child")) - { - case -1: - ACE_ERROR ((LM_ERROR, "%p\n%a", "fork failed")); - ACE_OS::_exit (-1); - case 0: // In child - { - ACE_APPEND_LOG ("IOStream_Test-children"); - ACE_INET_Addr server_addr; - - if (acceptor.get_local_addr (server_addr) == -1) - ACE_ERROR ((LM_ERROR, "%p\n", "get_local_addr")); - else - client ((void *) &server_addr); - ACE_END_LOG; - break; - } - default: // In parent - server (&acceptor); - - // Allow the client to exit, then remove the Process_Mutex. - ACE_OS::wait (); - break; - } -#else - ACE_ERROR_RETURN ((LM_ERROR, - "threads *and* processes not supported on this platform\n"), - -1); -#endif /* ACE_HAS_THREADS */ - - acceptor.close (); - - return 0; -} -#endif /* !ACE_LACKS_ACE_IOSTREAM */ - -int -main (int, char *[]) -{ - ACE_START_TEST ("IOStream_Test"); - -#if !defined (ACE_LACKS_ACE_IOSTREAM) - ACE_INIT_LOG ("IOStream_Test-children"); - spawn (); -#else - ACE_ERROR ((LM_ERROR, "ACE_IOSTREAM not supported on this platform\n")); -#endif /* !ACE_LACKS_ACE_IOSTREAM */ - ACE_END_TEST; - return 0; -} - - -#if !defined (ACE_LACKS_ACE_IOSTREAM) -#if defined (ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION) -template class ACE_IOStream<ACE_SOCK_Stream>; -template class ACE_Streambuf_T<ACE_SOCK_Stream>; -#elif defined (ACE_HAS_TEMPLATE_INSTANTIATION_PRAGMA) -#pragma instantiate ACE_IOStream<ACE_SOCK_Stream> -#pragma instantiate ACE_Streambuf_T<ACE_SOCK_Stream> -#endif /* ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION */ - -#endif /* !ACE_LACKS_ACE_IOSTREAM */ |