diff options
Diffstat (limited to 'cpp/src/Freeze/MapI.cpp')
| -rw-r--r-- | cpp/src/Freeze/MapI.cpp | 35 |
1 files changed, 35 insertions, 0 deletions
diff --git a/cpp/src/Freeze/MapI.cpp b/cpp/src/Freeze/MapI.cpp index b108b6c1b7c..0ce27824a86 100644 --- a/cpp/src/Freeze/MapI.cpp +++ b/cpp/src/Freeze/MapI.cpp @@ -698,6 +698,13 @@ Freeze::MapHelperI::find(const Key& k, bool readOnly) const } else { + if(_connection->deadlockWarning()) + { + Warning out(_connection->communicator()->getLogger()); + out << "Deadlock in Freeze::MapHelperI::find on Map \"" + << _dbName << "\"; retrying ..."; + } + // // Ignored, try again // @@ -749,6 +756,13 @@ Freeze::MapHelperI::put(const Key& key, const Value& value) } else { + if(_connection->deadlockWarning()) + { + Warning out(_connection->communicator()->getLogger()); + out << "Deadlock in Freeze::MapHelperI::put on Map \"" + << _dbName << "\"; retrying ..."; + } + // // Ignored, try again // @@ -805,6 +819,13 @@ Freeze::MapHelperI::erase(const Key& key) } else { + if(_connection->deadlockWarning()) + { + Warning out(_connection->communicator()->getLogger()); + out << "Deadlock in Freeze::MapHelperI::erase on Map \"" + << _dbName << "\"; retrying ..."; + } + // // Ignored, try again // @@ -861,6 +882,13 @@ Freeze::MapHelperI::count(const Key& key) const } else { + if(_connection->deadlockWarning()) + { + Warning out(_connection->communicator()->getLogger()); + out << "Deadlock in Freeze::MapHelperI::count on Map \"" + << _dbName << "\"; retrying ..."; + } + // // Ignored, try again // @@ -904,6 +932,13 @@ Freeze::MapHelperI::clear() } else { + if(_connection->deadlockWarning()) + { + Warning out(_connection->communicator()->getLogger()); + out << "Deadlock in Freeze::MapHelperI::clear on Map \"" + << _dbName << "\"; retrying ..."; + } + // // Ignored, try again // |