summaryrefslogtreecommitdiff
path: root/cpp
diff options
context:
space:
mode:
authorStephen D. Huston <shuston@apache.org>2009-08-14 22:15:04 +0000
committerStephen D. Huston <shuston@apache.org>2009-08-14 22:15:04 +0000
commita0fdaab822f22d8c505edae36ca15d7b1999c3c9 (patch)
tree51823e57c02aadc0ffd0ef2eec5af4a20118f8c6 /cpp
parentef430200213331edc8f28f115e996d376c15be67 (diff)
downloadqpid-python-a0fdaab822f22d8c505edae36ca15d7b1999c3c9.tar.gz
Removed TSS variables that tracked I/O counts; not used. Part of fix for QPID-1868
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@804394 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp')
-rw-r--r--cpp/src/qpid/sys/windows/AsynchIO.cpp17
1 files changed, 0 insertions, 17 deletions
diff --git a/cpp/src/qpid/sys/windows/AsynchIO.cpp b/cpp/src/qpid/sys/windows/AsynchIO.cpp
index dcd2f71a65..8905b87838 100644
--- a/cpp/src/qpid/sys/windows/AsynchIO.cpp
+++ b/cpp/src/qpid/sys/windows/AsynchIO.cpp
@@ -45,19 +45,6 @@ namespace {
typedef qpid::sys::ScopedLock<qpid::sys::Mutex> QLock;
/*
- * We keep per thread state to avoid locking overhead. The assumption is that
- * on average all the connections are serviced by all the threads so the state
- * recorded in each thread is about the same. If this turns out not to be the
- * case we could rebalance the info occasionally.
- */
-QPID_TSS int threadReadTotal = 0;
-QPID_TSS int threadMaxRead = 0;
-QPID_TSS int threadReadCount = 0;
-QPID_TSS int threadWriteTotal = 0;
-QPID_TSS int threadWriteCount = 0;
-QPID_TSS int64_t threadMaxReadTimeNs = 2 * 1000000; // start at 2ms
-
-/*
* The function pointers for AcceptEx and ConnectEx need to be looked up
* at run time. Make sure this is done only once.
*/
@@ -642,12 +629,10 @@ void AsynchIO::close(void) {
}
void AsynchIO::readComplete(AsynchReadResult *result) {
- ++threadReadCount;
int status = result->getStatus();
size_t bytes = result->getTransferred();
if (status == 0 && bytes > 0) {
bool restartRead = true; // May not if receiver doesn't want more
- threadReadTotal += bytes;
if (readCallback)
restartRead = readCallback(*this, result->getBuff());
if (restartRead)
@@ -674,10 +659,8 @@ void AsynchIO::writeComplete(AsynchWriteResult *result) {
size_t bytes = result->getTransferred();
AsynchIO::BufferBase *buff = result->getBuff();
if (buff != 0) {
- ++threadWriteCount;
writeInProgress = false;
if (status == 0 && bytes > 0) {
- threadWriteTotal += bytes;
if (bytes < result->getRequested()) // Still more to go; resubmit
startWrite(buff);
else