[PATCH] WL#3704 mgmapi timeouts: Rename inputstream timeout

Index: ndb-work/storage/ndb/include/util/InputStream.hpp
===================================================================
parent 36888199
...@@ -48,10 +48,10 @@ extern FileInputStream Stdin; ...@@ -48,10 +48,10 @@ extern FileInputStream Stdin;
class SocketInputStream : public InputStream { class SocketInputStream : public InputStream {
NDB_SOCKET_TYPE m_socket; NDB_SOCKET_TYPE m_socket;
unsigned m_timeout; unsigned m_timeout_ms;
bool m_startover; bool m_startover;
public: public:
SocketInputStream(NDB_SOCKET_TYPE socket, unsigned readTimeout = 1000); SocketInputStream(NDB_SOCKET_TYPE socket, unsigned read_timeout_ms = 1000);
virtual ~SocketInputStream() {} virtual ~SocketInputStream() {}
char* gets(char * buf, int bufLen); char* gets(char * buf, int bufLen);
}; };
......
...@@ -34,10 +34,10 @@ FileInputStream::gets(char * buf, int bufLen){ ...@@ -34,10 +34,10 @@ FileInputStream::gets(char * buf, int bufLen){
} }
SocketInputStream::SocketInputStream(NDB_SOCKET_TYPE socket, SocketInputStream::SocketInputStream(NDB_SOCKET_TYPE socket,
unsigned readTimeout) unsigned read_timeout_ms)
: m_socket(socket) { : m_socket(socket) {
m_startover= true; m_startover= true;
m_timeout = readTimeout; m_timeout_ms = read_timeout_ms;
} }
char* char*
...@@ -52,7 +52,7 @@ SocketInputStream::gets(char * buf, int bufLen) { ...@@ -52,7 +52,7 @@ SocketInputStream::gets(char * buf, int bufLen) {
else else
offset= strlen(buf); offset= strlen(buf);
int res = readln_socket(m_socket, m_timeout, buf+offset, bufLen-offset, m_mutex); int res = readln_socket(m_socket, m_timeout_ms, buf+offset, bufLen-offset, m_mutex);
if(res == 0) if(res == 0)
{ {
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment