git.stg.codes
/
stg.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Fixed ServerInfo parser.
[stg.git]
/
projects
/
rscriptd
/
listener.cpp
diff --git
a/projects/rscriptd/listener.cpp
b/projects/rscriptd/listener.cpp
index ead5d33bdcebde8771e78cd2377c5c4b69ac9f49..cc2a05603c88666c9d421fbf752a0e95160563f6 100644
(file)
--- a/
projects/rscriptd/listener.cpp
+++ b/
projects/rscriptd/listener.cpp
@@
-49,10
+49,9
@@
LISTENER::LISTENER()
receiverStopped(true),
processorStopped(true),
userTimeout(0),
receiverStopped(true),
processorStopped(true),
userTimeout(0),
- listenSocket(0)
+ listenSocket(0),
+ version("rscriptd listener v.1.2")
{
{
-version = "rscriptd listener v.1.2";
-
pthread_mutex_init(&mutex, NULL);
}
//-----------------------------------------------------------------------------
pthread_mutex_init(&mutex, NULL);
}
//-----------------------------------------------------------------------------
@@
-312,7
+311,7
@@
else if (packetHead.packetType == RS_DISCONNECT_PACKET)
}
}
}
}
-STG_LOCKER lock(&mutex
, __FILE__, __LINE__
);
+STG_LOCKER lock(&mutex);
pending.push_back(data);
return false;
pending.push_back(data);
return false;
@@
-412,7
+411,7
@@
while (it != pending.end() && count < 256)
++it;
++count;
}
++it;
++count;
}
-STG_LOCKER lock(&mutex
, __FILE__, __LINE__
);
+STG_LOCKER lock(&mutex);
pending.erase(pending.begin(), it);
}
//-----------------------------------------------------------------------------
pending.erase(pending.begin(), it);
}
//-----------------------------------------------------------------------------