summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorStephen D. Huston <shuston@apache.org>2009-09-02 23:22:10 +0000
committerStephen D. Huston <shuston@apache.org>2009-09-02 23:22:10 +0000
commit8ecb8e5db18f0dc5ada1fce78587abf52b093c6c (patch)
tree47a813aa3369bfe818b75a9ebdc747da9633526a
parentc1aec31e3fdb19fabfe42a2cbe8c54591179da34 (diff)
downloadqpid-python-8ecb8e5db18f0dc5ada1fce78587abf52b093c6c.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/branches/0.5-release@810731 13f79535-47bb-0310-9956-ffa450edef68
-rw-r--r--qpid/cpp/src/qpid/sys/windows/AsynchIO.cpp11
1 files changed, 7 insertions, 4 deletions
diff --git a/qpid/cpp/src/qpid/sys/windows/AsynchIO.cpp b/qpid/cpp/src/qpid/sys/windows/AsynchIO.cpp
index 0a3c36452c..5575f8e5bf 100644
--- a/qpid/cpp/src/qpid/sys/windows/AsynchIO.cpp
+++ b/qpid/cpp/src/qpid/sys/windows/AsynchIO.cpp
@@ -50,12 +50,15 @@ namespace {
* recorded in each thread is about the same. If this turns out not to be the
* case we could rebalance the info occasionally.
*/
+#if 0
+ // These are never used and __declspec(thread) causes accvio on dynamic load
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
+#endif
/*
* The function pointers for AcceptEx and ConnectEx need to be looked up
@@ -642,12 +645,12 @@ void AsynchIO::close(void) {
}
void AsynchIO::readComplete(AsynchReadResult *result) {
- ++threadReadCount;
+ // ++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;
+ // threadReadTotal += bytes;
if (readCallback)
restartRead = readCallback(*this, result->getBuff());
if (restartRead)
@@ -674,10 +677,10 @@ void AsynchIO::writeComplete(AsynchWriteResult *result) {
size_t bytes = result->getTransferred();
AsynchIO::BufferBase *buff = result->getBuff();
if (buff != 0) {
- ++threadWriteCount;
+ // ++threadWriteCount;
writeInProgress = false;
if (status == 0 && bytes > 0) {
- threadWriteTotal += bytes;
+ // threadWriteTotal += bytes;
if (bytes < result->getRequested()) // Still more to go; resubmit
startWrite(buff);
else