|
@@ -102,15 +102,20 @@ ConnectionReader::
|
|
|
ConnectionReader(ConnectionManager *manager, int num_threads) :
|
|
ConnectionReader(ConnectionManager *manager, int num_threads) :
|
|
|
_manager(manager)
|
|
_manager(manager)
|
|
|
{
|
|
{
|
|
|
-#if !defined(HAVE_THREADS) || defined(SIMPLE_THREADS)
|
|
|
|
|
|
|
+ if (!Thread::is_true_threads()) {
|
|
|
|
|
+ // There is no point in using threads for this kind of I/O unless
|
|
|
|
|
+ // we actually have real threads available (i.e. HAVE_THREADS is
|
|
|
|
|
+ // defined, and SIMPLE_THREADS is not).
|
|
|
#ifndef NDEBUG
|
|
#ifndef NDEBUG
|
|
|
- if (num_threads != 0) {
|
|
|
|
|
- net_cat.error()
|
|
|
|
|
- << "Threading support is not available.\n";
|
|
|
|
|
- }
|
|
|
|
|
|
|
+ if (num_threads != 0) {
|
|
|
|
|
+ if (net_cat.is_debug()) {
|
|
|
|
|
+ net_cat.debug()
|
|
|
|
|
+ << "Threading support is not available.\n";
|
|
|
|
|
+ }
|
|
|
|
|
+ }
|
|
|
#endif // NDEBUG
|
|
#endif // NDEBUG
|
|
|
- num_threads = 0;
|
|
|
|
|
-#endif // HAVE_THREADS
|
|
|
|
|
|
|
+ num_threads = 0;
|
|
|
|
|
+ }
|
|
|
|
|
|
|
|
_raw_mode = false;
|
|
_raw_mode = false;
|
|
|
_tcp_header_size = datagram_tcp16_header_size;
|
|
_tcp_header_size = datagram_tcp16_header_size;
|