Skip to content
Projects
Groups
Snippets
Help
This project
Loading...
Sign in / Register
Toggle navigation
N
nx-libs
Project
Project
Details
Activity
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
1
Issues
1
List
Board
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Charts
Wiki
Wiki
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
dimbor
nx-libs
Commits
b8c92977
Commit
b8c92977
authored
Dec 02, 2017
by
Ulrich Sibiller
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
nxcomp: use lowercase abbreviations for seconds and milliseconds
parent
3bd7e03e
Hide whitespace changes
Inline
Side-by-side
Showing
9 changed files
with
71 additions
and
71 deletions
+71
-71
Channel.cpp
nxcomp/src/Channel.cpp
+2
-2
Children.cpp
nxcomp/src/Children.cpp
+4
-4
ClientChannel.cpp
nxcomp/src/ClientChannel.cpp
+1
-1
Loop.cpp
nxcomp/src/Loop.cpp
+30
-30
Proxy.cpp
nxcomp/src/Proxy.cpp
+19
-19
ServerChannel.cpp
nxcomp/src/ServerChannel.cpp
+7
-7
Statistics.cpp
nxcomp/src/Statistics.cpp
+3
-3
Timestamp.h
nxcomp/src/Timestamp.h
+2
-2
Transport.cpp
nxcomp/src/Transport.cpp
+3
-3
No files found.
nxcomp/src/Channel.cpp
View file @
b8c92977
...
@@ -1238,7 +1238,7 @@ int Channel::handleWait(int timeout)
...
@@ -1238,7 +1238,7 @@ int Channel::handleWait(int timeout)
}
}
#ifdef TEST
#ifdef TEST
*
logofs
<<
"handleWait: Waiting "
<<
remaining
<<
"
M
s "
*
logofs
<<
"handleWait: Waiting "
<<
remaining
<<
"
m
s "
<<
"for a new message on FD#"
<<
fd_
<<
"for a new message on FD#"
<<
fd_
<<
".
\n
"
<<
logofs_flush
;
<<
".
\n
"
<<
logofs_flush
;
#endif
#endif
...
@@ -1306,7 +1306,7 @@ int Channel::handleDrain(int limit, int timeout)
...
@@ -1306,7 +1306,7 @@ int Channel::handleDrain(int limit, int timeout)
#ifdef TEST
#ifdef TEST
*
logofs
<<
"handleDrain: Trying to write to FD#"
*
logofs
<<
"handleDrain: Trying to write to FD#"
<<
fd_
<<
" with "
<<
remaining
<<
"
M
s "
<<
fd_
<<
" with "
<<
remaining
<<
"
m
s "
<<
"remaining.
\n
"
<<
logofs_flush
;
<<
"remaining.
\n
"
<<
logofs_flush
;
#endif
#endif
...
...
nxcomp/src/Children.cpp
View file @
b8c92977
...
@@ -628,7 +628,7 @@ int NXTransWatchdog(int timeout)
...
@@ -628,7 +628,7 @@ int NXTransWatchdog(int timeout)
{
{
#ifdef TEST
#ifdef TEST
*
logofs
<<
"NXTransWatchdog: Timeout of "
<<
timeout
*
logofs
<<
"NXTransWatchdog: Timeout of "
<<
timeout
<<
"
M
s raised in watchdog.
\n
"
<<
logofs_flush
;
<<
"
m
s raised in watchdog.
\n
"
<<
logofs_flush
;
#endif
#endif
//
//
...
@@ -645,7 +645,7 @@ int NXTransWatchdog(int timeout)
...
@@ -645,7 +645,7 @@ int NXTransWatchdog(int timeout)
{
{
#ifdef TEST
#ifdef TEST
*
logofs
<<
"NXTransWatchdog: Waiting for the timeout "
*
logofs
<<
"NXTransWatchdog: Waiting for the timeout "
<<
"with "
<<
timeout
-
diffTs
<<
"
M
s to run.
\n
"
<<
"with "
<<
timeout
-
diffTs
<<
"
m
s to run.
\n
"
<<
logofs_flush
;
<<
logofs_flush
;
#endif
#endif
...
@@ -847,7 +847,7 @@ int NXTransKeeper(int caches, int images, const char *root)
...
@@ -847,7 +847,7 @@ int NXTransKeeper(int caches, int images, const char *root)
#ifdef TEST
#ifdef TEST
*
logofs
<<
"NXTransKeeper: Going to sleep for "
*
logofs
<<
"NXTransKeeper: Going to sleep for "
<<
timeout
/
20
<<
"
M
s.
\n
"
<<
logofs_flush
;
<<
timeout
/
20
<<
"
m
s.
\n
"
<<
logofs_flush
;
#endif
#endif
usleep
(
timeout
/
20
*
1000
);
usleep
(
timeout
/
20
*
1000
);
...
@@ -937,7 +937,7 @@ int NXTransKeeper(int caches, int images, const char *root)
...
@@ -937,7 +937,7 @@ int NXTransKeeper(int caches, int images, const char *root)
#ifdef TEST
#ifdef TEST
*
logofs
<<
"NXTransKeeper: Going to sleep for "
<<
timeout
*
logofs
<<
"NXTransKeeper: Going to sleep for "
<<
timeout
<<
"
M
s.
\n
"
<<
logofs_flush
;
<<
"
m
s.
\n
"
<<
logofs_flush
;
#endif
#endif
usleep
(
timeout
*
1000
);
usleep
(
timeout
*
1000
);
...
...
nxcomp/src/ClientChannel.cpp
View file @
b8c92977
...
@@ -5782,7 +5782,7 @@ int ClientChannel::handleSplitEvent(DecodeBuffer &decodeBuffer)
...
@@ -5782,7 +5782,7 @@ int ClientChannel::handleSplitEvent(DecodeBuffer &decodeBuffer)
#if defined(TEST) || defined(SPLIT)
#if defined(TEST) || defined(SPLIT)
*
logofs
<<
"handleSplitEvent: SPLIT! Spent "
*
logofs
<<
"handleSplitEvent: SPLIT! Spent "
<<
diffTimestamp
(
startTs
,
getTimestamp
())
<<
"
M
s "
<<
diffTimestamp
(
startTs
,
getTimestamp
())
<<
"
m
s "
<<
"handling abort split events for FD#"
<<
fd_
<<
"handling abort split events for FD#"
<<
fd_
<<
".
\n
"
<<
logofs_flush
;
<<
".
\n
"
<<
logofs_flush
;
#endif
#endif
...
...
nxcomp/src/Loop.cpp
View file @
b8c92977
...
@@ -2578,15 +2578,15 @@ int NXTransPrepare(int *setFDs, fd_set *readSet,
...
@@ -2578,15 +2578,15 @@ int NXTransPrepare(int *setFDs, fd_set *readSet,
if
(
isTimestamp
(
*
selectTs
)
==
0
)
if
(
isTimestamp
(
*
selectTs
)
==
0
)
{
{
nxinfo
<<
"Loop: WARNING! Preparing the select with requested "
nxinfo
<<
"Loop: WARNING! Preparing the select with requested "
<<
"timeout of "
<<
selectTs
->
tv_sec
<<
"
S
and "
<<
"timeout of "
<<
selectTs
->
tv_sec
<<
"
s
and "
<<
(
double
)
selectTs
->
tv_usec
/
1000
<<
"
M
s.
\n
"
<<
(
double
)
selectTs
->
tv_usec
/
1000
<<
"
m
s.
\n
"
<<
std
::
flush
;
<<
std
::
flush
;
}
}
else
else
{
{
nxinfo
<<
"Loop: Preparing the select with requested "
nxinfo
<<
"Loop: Preparing the select with requested "
<<
"timeout of "
<<
selectTs
->
tv_sec
<<
"
S
and "
<<
"timeout of "
<<
selectTs
->
tv_sec
<<
"
s
and "
<<
(
double
)
selectTs
->
tv_usec
/
1000
<<
"
M
s.
\n
"
<<
(
double
)
selectTs
->
tv_usec
/
1000
<<
"
m
s.
\n
"
<<
std
::
flush
;
<<
std
::
flush
;
}
}
...
@@ -2632,7 +2632,7 @@ int NXTransPrepare(int *setFDs, fd_set *readSet,
...
@@ -2632,7 +2632,7 @@ int NXTransPrepare(int *setFDs, fd_set *readSet,
int
diffTs
=
diffTimestamp
(
startTs
,
nowTs
);
int
diffTs
=
diffTimestamp
(
startTs
,
nowTs
);
nxinfo
<<
"Loop: Mark - 0 - at "
<<
strMsTimestamp
()
nxinfo
<<
"Loop: Mark - 0 - at "
<<
strMsTimestamp
()
<<
" with "
<<
diffTs
<<
"
M
s elapsed.
\n
"
<<
" with "
<<
diffTs
<<
"
m
s elapsed.
\n
"
<<
std
::
flush
;
<<
std
::
flush
;
//
//
...
@@ -2701,7 +2701,7 @@ int NXTransSelect(int *resultFDs, int *errorFDs, int *setFDs, fd_set *readSet,
...
@@ -2701,7 +2701,7 @@ int NXTransSelect(int *resultFDs, int *errorFDs, int *setFDs, fd_set *readSet,
if
(
diffTs
>
20
)
if
(
diffTs
>
20
)
{
{
nxdbg
<<
"Loop: TIME! Spent "
<<
diffTs
nxdbg
<<
"Loop: TIME! Spent "
<<
diffTs
<<
"
M
s handling messages for proxy FD#"
<<
"
m
s handling messages for proxy FD#"
<<
proxyFD
<<
".
\n
"
<<
std
::
flush
;
<<
proxyFD
<<
".
\n
"
<<
std
::
flush
;
}
}
...
@@ -2711,8 +2711,8 @@ int NXTransSelect(int *resultFDs, int *errorFDs, int *setFDs, fd_set *readSet,
...
@@ -2711,8 +2711,8 @@ int NXTransSelect(int *resultFDs, int *errorFDs, int *setFDs, fd_set *readSet,
if
(
isTimestamp
(
*
selectTs
)
==
0
)
if
(
isTimestamp
(
*
selectTs
)
==
0
)
{
{
nxinfo
<<
"Loop: WARNING! Executing the select with requested "
nxinfo
<<
"Loop: WARNING! Executing the select with requested "
<<
"timeout of "
<<
selectTs
->
tv_sec
<<
"
S
and "
<<
"timeout of "
<<
selectTs
->
tv_sec
<<
"
s
and "
<<
(
double
)
selectTs
->
tv_usec
/
1000
<<
"
M
s.
\n
"
<<
(
double
)
selectTs
->
tv_usec
/
1000
<<
"
m
s.
\n
"
<<
std
::
flush
;
<<
std
::
flush
;
}
}
else
if
(
proxy
!=
NULL
&&
proxy
->
getFlushable
(
proxyFD
)
>
0
)
else
if
(
proxy
!=
NULL
&&
proxy
->
getFlushable
(
proxyFD
)
>
0
)
...
@@ -2720,8 +2720,8 @@ int NXTransSelect(int *resultFDs, int *errorFDs, int *setFDs, fd_set *readSet,
...
@@ -2720,8 +2720,8 @@ int NXTransSelect(int *resultFDs, int *errorFDs, int *setFDs, fd_set *readSet,
nxinfo
<<
"Loop: WARNING! Proxy FD#"
<<
proxyFD
nxinfo
<<
"Loop: WARNING! Proxy FD#"
<<
proxyFD
<<
" has "
<<
proxy
->
getFlushable
(
proxyFD
)
<<
" has "
<<
proxy
->
getFlushable
(
proxyFD
)
<<
" bytes to write but timeout is "
<<
" bytes to write but timeout is "
<<
selectTs
->
tv_sec
<<
"
S
and "
<<
selectTs
->
tv_sec
<<
"
s
and "
<<
selectTs
->
tv_usec
/
1000
<<
"
M
s.
\n
"
<<
selectTs
->
tv_usec
/
1000
<<
"
m
s.
\n
"
<<
std
::
flush
;
<<
std
::
flush
;
}
}
...
@@ -2742,7 +2742,7 @@ int NXTransSelect(int *resultFDs, int *errorFDs, int *setFDs, fd_set *readSet,
...
@@ -2742,7 +2742,7 @@ int NXTransSelect(int *resultFDs, int *errorFDs, int *setFDs, fd_set *readSet,
if
(
diffTs
>
100
)
if
(
diffTs
>
100
)
{
{
nxdbg
<<
"Loop: TIME! Spent "
<<
diffTs
nxdbg
<<
"Loop: TIME! Spent "
<<
diffTs
<<
"
M
s waiting for new data for proxy FD#"
<<
"
m
s waiting for new data for proxy FD#"
<<
proxyFD
<<
".
\n
"
<<
std
::
flush
;
<<
proxyFD
<<
".
\n
"
<<
std
::
flush
;
}
}
...
@@ -2767,7 +2767,7 @@ int NXTransSelect(int *resultFDs, int *errorFDs, int *setFDs, fd_set *readSet,
...
@@ -2767,7 +2767,7 @@ int NXTransSelect(int *resultFDs, int *errorFDs, int *setFDs, fd_set *readSet,
diffTs
=
diffTimestamp
(
startTs
,
nowTs
);
diffTs
=
diffTimestamp
(
startTs
,
nowTs
);
nxinfo
<<
"Loop: Out of select after "
<<
diffTs
<<
"
M
s "
nxinfo
<<
"Loop: Out of select after "
<<
diffTs
<<
"
m
s "
<<
"at "
<<
strMsTimestamp
(
nowTs
)
<<
" with result "
<<
"at "
<<
strMsTimestamp
(
nowTs
)
<<
" with result "
<<
*
resultFDs
<<
".
\n
"
<<
std
::
flush
;
<<
*
resultFDs
<<
".
\n
"
<<
std
::
flush
;
...
@@ -2874,7 +2874,7 @@ int NXTransExecute(int *resultFDs, int *errorFDs, int *setFDs, fd_set *readSet,
...
@@ -2874,7 +2874,7 @@ int NXTransExecute(int *resultFDs, int *errorFDs, int *setFDs, fd_set *readSet,
nxinfo
<<
"Loop: Mark - 1 - at "
<<
strMsTimestamp
()
nxinfo
<<
"Loop: Mark - 1 - at "
<<
strMsTimestamp
()
<<
" with "
<<
diffTimestamp
(
startTs
,
getTimestamp
())
<<
" with "
<<
diffTimestamp
(
startTs
,
getTimestamp
())
<<
"
M
s elapsed.
\n
"
<<
std
::
flush
;
<<
"
m
s elapsed.
\n
"
<<
std
::
flush
;
//
//
// Rotate the channel that will be handled
// Rotate the channel that will be handled
...
@@ -2891,7 +2891,7 @@ int NXTransExecute(int *resultFDs, int *errorFDs, int *setFDs, fd_set *readSet,
...
@@ -2891,7 +2891,7 @@ int NXTransExecute(int *resultFDs, int *errorFDs, int *setFDs, fd_set *readSet,
nxinfo
<<
"Loop: Mark - 2 - at "
<<
strMsTimestamp
()
nxinfo
<<
"Loop: Mark - 2 - at "
<<
strMsTimestamp
()
<<
" with "
<<
diffTimestamp
(
startTs
,
getTimestamp
())
<<
" with "
<<
diffTimestamp
(
startTs
,
getTimestamp
())
<<
"
M
s elapsed.
\n
"
<<
std
::
flush
;
<<
"
m
s elapsed.
\n
"
<<
std
::
flush
;
//
//
// Check if any socket has become readable.
// Check if any socket has become readable.
...
@@ -2901,7 +2901,7 @@ int NXTransExecute(int *resultFDs, int *errorFDs, int *setFDs, fd_set *readSet,
...
@@ -2901,7 +2901,7 @@ int NXTransExecute(int *resultFDs, int *errorFDs, int *setFDs, fd_set *readSet,
nxinfo
<<
"Loop: Mark - 3 - at "
<<
strMsTimestamp
()
nxinfo
<<
"Loop: Mark - 3 - at "
<<
strMsTimestamp
()
<<
" with "
<<
diffTimestamp
(
startTs
,
getTimestamp
())
<<
" with "
<<
diffTimestamp
(
startTs
,
getTimestamp
())
<<
"
M
s elapsed.
\n
"
<<
std
::
flush
;
<<
"
m
s elapsed.
\n
"
<<
std
::
flush
;
//
//
// Handle the scheduled events on channels.
// Handle the scheduled events on channels.
...
@@ -2923,7 +2923,7 @@ int NXTransExecute(int *resultFDs, int *errorFDs, int *setFDs, fd_set *readSet,
...
@@ -2923,7 +2923,7 @@ int NXTransExecute(int *resultFDs, int *errorFDs, int *setFDs, fd_set *readSet,
nxinfo
<<
"Loop: Mark - 4 - at "
<<
strMsTimestamp
()
nxinfo
<<
"Loop: Mark - 4 - at "
<<
strMsTimestamp
()
<<
" with "
<<
diffTimestamp
(
startTs
,
getTimestamp
())
<<
" with "
<<
diffTimestamp
(
startTs
,
getTimestamp
())
<<
"
M
s elapsed.
\n
"
<<
std
::
flush
;
<<
"
m
s elapsed.
\n
"
<<
std
::
flush
;
//
//
// Check if user sent a signal to produce
// Check if user sent a signal to produce
...
@@ -2946,7 +2946,7 @@ int NXTransExecute(int *resultFDs, int *errorFDs, int *setFDs, fd_set *readSet,
...
@@ -2946,7 +2946,7 @@ int NXTransExecute(int *resultFDs, int *errorFDs, int *setFDs, fd_set *readSet,
nxinfo
<<
"Loop: Mark - 5 - at "
<<
strMsTimestamp
()
nxinfo
<<
"Loop: Mark - 5 - at "
<<
strMsTimestamp
()
<<
" with "
<<
diffTimestamp
(
startTs
,
getTimestamp
())
<<
" with "
<<
diffTimestamp
(
startTs
,
getTimestamp
())
<<
"
M
s elapsed.
\n
"
<<
std
::
flush
;
<<
"
m
s elapsed.
\n
"
<<
std
::
flush
;
//
//
// Check if there is any data to flush.
// Check if there is any data to flush.
...
@@ -2958,7 +2958,7 @@ int NXTransExecute(int *resultFDs, int *errorFDs, int *setFDs, fd_set *readSet,
...
@@ -2958,7 +2958,7 @@ int NXTransExecute(int *resultFDs, int *errorFDs, int *setFDs, fd_set *readSet,
nxinfo
<<
"Loop: Mark - 6 - at "
<<
strMsTimestamp
()
nxinfo
<<
"Loop: Mark - 6 - at "
<<
strMsTimestamp
()
<<
" with "
<<
diffTimestamp
(
startTs
,
getTimestamp
())
<<
" with "
<<
diffTimestamp
(
startTs
,
getTimestamp
())
<<
"
M
s elapsed.
\n
"
<<
std
::
flush
;
<<
"
m
s elapsed.
\n
"
<<
std
::
flush
;
}
}
//
//
...
@@ -2991,7 +2991,7 @@ int NXTransExecute(int *resultFDs, int *errorFDs, int *setFDs, fd_set *readSet,
...
@@ -2991,7 +2991,7 @@ int NXTransExecute(int *resultFDs, int *errorFDs, int *setFDs, fd_set *readSet,
nxinfo
<<
"Loop: Mark - 7 - at "
<<
strMsTimestamp
()
nxinfo
<<
"Loop: Mark - 7 - at "
<<
strMsTimestamp
()
<<
" with "
<<
diffTimestamp
(
startTs
,
getTimestamp
())
<<
" with "
<<
diffTimestamp
(
startTs
,
getTimestamp
())
<<
"
M
s elapsed.
\n
"
<<
std
::
flush
;
<<
"
m
s elapsed.
\n
"
<<
std
::
flush
;
}
}
//
//
...
@@ -3360,7 +3360,7 @@ int InitAfterNegotiation()
...
@@ -3360,7 +3360,7 @@ int InitAfterNegotiation()
nxinfo
<<
"Loop: INIT! Completed initialization at "
nxinfo
<<
"Loop: INIT! Completed initialization at "
<<
strMsTimestamp
(
nowTs
)
<<
" with "
<<
strMsTimestamp
(
nowTs
)
<<
" with "
<<
diffTimestamp
(
initTs
,
nowTs
)
<<
"
M
s "
<<
diffTimestamp
(
initTs
,
nowTs
)
<<
"
m
s "
<<
"since the init mark.
\n
"
<<
std
::
flush
;
<<
"since the init mark.
\n
"
<<
std
::
flush
;
initTs
=
getNewTimestamp
();
initTs
=
getNewTimestamp
();
...
@@ -6077,8 +6077,8 @@ void SetTimer(int value)
...
@@ -6077,8 +6077,8 @@ void SetTimer(int value)
timer
.
it_value
=
lastTimer
.
next
;
timer
.
it_value
=
lastTimer
.
next
;
nxinfo
<<
"Loop: Timer set to "
<<
lastTimer
.
next
.
tv_sec
nxinfo
<<
"Loop: Timer set to "
<<
lastTimer
.
next
.
tv_sec
<<
"
S
and "
<<
lastTimer
.
next
.
tv_usec
/
1000
<<
"
s
and "
<<
lastTimer
.
next
.
tv_usec
/
1000
<<
"
M
s at "
<<
strMsTimestamp
()
<<
" in process "
<<
"
m
s at "
<<
strMsTimestamp
()
<<
" in process "
<<
"with pid '"
<<
getpid
()
<<
"'.
\n
"
<<
"with pid '"
<<
getpid
()
<<
"'.
\n
"
<<
std
::
flush
;
<<
std
::
flush
;
...
@@ -6600,7 +6600,7 @@ int ConnectToRemote(ChannelEndPoint &socketAddress)
...
@@ -6600,7 +6600,7 @@ int ConnectToRemote(ChannelEndPoint &socketAddress)
{
{
nxdbg
<<
"Loop: Timer set to "
<<
connectTimeout
/
1000
nxdbg
<<
"Loop: Timer set to "
<<
connectTimeout
/
1000
<<
"
S
"
<<
"with retry set to "
<<
retryConnect
<<
"
s
"
<<
"with retry set to "
<<
retryConnect
<<
" in process with pid '"
<<
getpid
()
<<
" in process with pid '"
<<
getpid
()
<<
"'.
\n
"
<<
std
::
flush
;
<<
"'.
\n
"
<<
std
::
flush
;
...
@@ -13799,7 +13799,7 @@ static void handleCheckSessionInLoop()
...
@@ -13799,7 +13799,7 @@ static void handleCheckSessionInLoop()
}
}
nxinfo
<<
"Loop: Starting watchdog process with timeout "
nxinfo
<<
"Loop: Starting watchdog process with timeout "
<<
"of "
<<
timeout
<<
"
M
s.
\n
"
<<
"of "
<<
timeout
<<
"
m
s.
\n
"
<<
std
::
flush
;
<<
std
::
flush
;
}
}
else
else
...
@@ -14064,9 +14064,9 @@ static void handleCheckSelectInLoop(int &setFDs, fd_set &readSet,
...
@@ -14064,9 +14064,9 @@ static void handleCheckSelectInLoop(int &setFDs, fd_set &readSet,
}
}
nxinfo
<<
"Loop: Select timeout is "
nxinfo
<<
"Loop: Select timeout is "
<<
selectTs
.
tv_sec
<<
"
S
and "
<<
selectTs
.
tv_sec
<<
"
s
and "
<<
(
double
)
selectTs
.
tv_usec
/
1000
<<
(
double
)
selectTs
.
tv_usec
/
1000
<<
"
M
s.
\n
"
<<
std
::
flush
;
<<
"
m
s.
\n
"
<<
std
::
flush
;
}
}
static
void
handleCheckResultInLoop
(
int
&
resultFDs
,
int
&
errorFDs
,
int
&
setFDs
,
fd_set
&
readSet
,
static
void
handleCheckResultInLoop
(
int
&
resultFDs
,
int
&
errorFDs
,
int
&
setFDs
,
fd_set
&
readSet
,
...
@@ -14082,14 +14082,14 @@ static void handleCheckResultInLoop(int &resultFDs, int &errorFDs, int &setFDs,
...
@@ -14082,14 +14082,14 @@ static void handleCheckResultInLoop(int &resultFDs, int &errorFDs, int &setFDs,
nxinfo
<<
"Loop: Select result is ["
<<
resultFDs
nxinfo
<<
"Loop: Select result is ["
<<
resultFDs
<<
"] at "
<<
strMsTimestamp
()
<<
" with no "
<<
"] at "
<<
strMsTimestamp
()
<<
" with no "
<<
"communication within "
<<
diffTs
<<
"communication within "
<<
diffTs
<<
"
M
s.
\n
"
<<
std
::
flush
;
<<
"
m
s.
\n
"
<<
std
::
flush
;
}
}
else
else
{
{
nxinfo
<<
"Loop: Select result is ["
<<
resultFDs
nxinfo
<<
"Loop: Select result is ["
<<
resultFDs
<<
"] error is ["
<<
errorFDs
<<
"] at "
<<
"] error is ["
<<
errorFDs
<<
"] at "
<<
strMsTimestamp
()
<<
" after "
<<
diffTs
<<
strMsTimestamp
()
<<
" after "
<<
diffTs
<<
"
M
s.
\n
"
<<
std
::
flush
;
<<
"
m
s.
\n
"
<<
std
::
flush
;
}
}
...
@@ -14524,8 +14524,8 @@ static void handleNegotiationInLoop(int &setFDs, fd_set &readSet,
...
@@ -14524,8 +14524,8 @@ static void handleNegotiationInLoop(int &setFDs, fd_set &readSet,
setMinTimestamp
(
selectTs
,
control
->
PingTimeout
);
setMinTimestamp
(
selectTs
,
control
->
PingTimeout
);
nxinfo
<<
"Loop: Selected proxy FD#"
<<
proxyFD
<<
" in negotiation "
nxinfo
<<
"Loop: Selected proxy FD#"
<<
proxyFD
<<
" in negotiation "
<<
"phase with timeout of "
<<
selectTs
.
tv_sec
<<
"
S
and "
<<
"phase with timeout of "
<<
selectTs
.
tv_sec
<<
"
s
and "
<<
selectTs
.
tv_usec
<<
"
M
s.
\n
"
<<
std
::
flush
;
<<
selectTs
.
tv_usec
<<
"
m
s.
\n
"
<<
std
::
flush
;
return
;
return
;
...
...
nxcomp/src/Proxy.cpp
View file @
b8c92977
...
@@ -410,8 +410,8 @@ int Proxy::setReadDescriptors(fd_set *fdSet, int &fdMax, T_timestamp &tsMax)
...
@@ -410,8 +410,8 @@ int Proxy::setReadDescriptors(fd_set *fdSet, int &fdMax, T_timestamp &tsMax)
#ifdef TEST
#ifdef TEST
*
logofs
<<
"Proxy: Initial timeout is "
<<
tsMax
.
tv_sec
*
logofs
<<
"Proxy: Initial timeout is "
<<
tsMax
.
tv_sec
<<
"
S
and "
<<
(
double
)
tsMax
.
tv_usec
/
<<
"
s
and "
<<
(
double
)
tsMax
.
tv_usec
/
1000
<<
"
M
s with congestion "
1000
<<
"
m
s with congestion "
<<
statistics
->
getCongestionInFrame
()
<<
statistics
->
getCongestionInFrame
()
<<
".
\n
"
<<
logofs_flush
;
<<
".
\n
"
<<
logofs_flush
;
#endif
#endif
...
@@ -422,8 +422,8 @@ int Proxy::setReadDescriptors(fd_set *fdSet, int &fdMax, T_timestamp &tsMax)
...
@@ -422,8 +422,8 @@ int Proxy::setReadDescriptors(fd_set *fdSet, int &fdMax, T_timestamp &tsMax)
#ifdef TEST
#ifdef TEST
*
logofs
<<
"Proxy: Initial timeout is "
<<
tsMax
.
tv_sec
*
logofs
<<
"Proxy: Initial timeout is "
<<
tsMax
.
tv_sec
<<
"
S
and "
<<
(
double
)
tsMax
.
tv_usec
/
<<
"
s
and "
<<
(
double
)
tsMax
.
tv_usec
/
1000
<<
"
M
s.
\n
"
<<
logofs_flush
;
1000
<<
"
m
s.
\n
"
<<
logofs_flush
;
#endif
#endif
}
}
...
@@ -449,12 +449,12 @@ int Proxy::setReadDescriptors(fd_set *fdSet, int &fdMax, T_timestamp &tsMax)
...
@@ -449,12 +449,12 @@ int Proxy::setReadDescriptors(fd_set *fdSet, int &fdMax, T_timestamp &tsMax)
{
{
*
logofs
<<
"Proxy: FLUSH! SPLIT! WARNING! Running with "
*
logofs
<<
"Proxy: FLUSH! SPLIT! WARNING! Running with "
<<
diffTimestamp
(
timeouts_
.
splitTs
,
getTimestamp
())
<<
diffTimestamp
(
timeouts_
.
splitTs
,
getTimestamp
())
<<
"
M
s elapsed since the last split.
\n
"
<<
"
m
s elapsed since the last split.
\n
"
<<
logofs_flush
;
<<
logofs_flush
;
}
}
*
logofs
<<
"Proxy: FLUSH! SPLIT! Requesting timeout of "
*
logofs
<<
"Proxy: FLUSH! SPLIT! Requesting timeout of "
<<
diffTs
<<
"
M
s as there are splits to send.
\n
"
<<
diffTs
<<
"
m
s as there are splits to send.
\n
"
<<
logofs_flush
;
<<
logofs_flush
;
#endif
#endif
...
@@ -525,12 +525,12 @@ int Proxy::setReadDescriptors(fd_set *fdSet, int &fdMax, T_timestamp &tsMax)
...
@@ -525,12 +525,12 @@ int Proxy::setReadDescriptors(fd_set *fdSet, int &fdMax, T_timestamp &tsMax)
{
{
*
logofs
<<
"Proxy: FLUSH! WARNING! Running with "
*
logofs
<<
"Proxy: FLUSH! WARNING! Running with "
<<
diffTimestamp
(
timeouts_
.
motionTs
,
getTimestamp
())
<<
diffTimestamp
(
timeouts_
.
motionTs
,
getTimestamp
())
<<
"
M
s elapsed since the last motion.
\n
"
<<
"
m
s elapsed since the last motion.
\n
"
<<
logofs_flush
;
<<
logofs_flush
;
}
}
*
logofs
<<
"Proxy: FLUSH! Requesting timeout of "
*
logofs
<<
"Proxy: FLUSH! Requesting timeout of "
<<
diffTs
<<
"
M
s as FD#"
<<
fd
<<
" has motion "
<<
diffTs
<<
"
m
s as FD#"
<<
fd
<<
" has motion "
<<
"events to send.
\n
"
<<
logofs_flush
;
<<
"events to send.
\n
"
<<
logofs_flush
;
#endif
#endif
...
@@ -1946,7 +1946,7 @@ int Proxy::handleEvents()
...
@@ -1946,7 +1946,7 @@ int Proxy::handleEvents()
*
logofs
<<
"Proxy: FLUSH! Motion timeout expired after "
*
logofs
<<
"Proxy: FLUSH! Motion timeout expired after "
<<
diffTimestamp
(
timeouts_
.
motionTs
,
getTimestamp
())
<<
diffTimestamp
(
timeouts_
.
motionTs
,
getTimestamp
())
<<
"
M
s.
\n
"
<<
logofs_flush
;
<<
"
m
s.
\n
"
<<
logofs_flush
;
#endif
#endif
...
@@ -1972,7 +1972,7 @@ int Proxy::handleEvents()
...
@@ -1972,7 +1972,7 @@ int Proxy::handleEvents()
{
{
*
logofs
<<
"Proxy: Running with "
*
logofs
<<
"Proxy: Running with "
<<
diffTimestamp
(
timeouts_
.
motionTs
,
getTimestamp
())
<<
diffTimestamp
(
timeouts_
.
motionTs
,
getTimestamp
())
<<
"
M
s elapsed since the last motion.
\n
"
<<
"
m
s elapsed since the last motion.
\n
"
<<
logofs_flush
;
<<
logofs_flush
;
}
}
#endif
#endif
...
@@ -1990,7 +1990,7 @@ int Proxy::handleEvents()
...
@@ -1990,7 +1990,7 @@ int Proxy::handleEvents()
#if defined(TEST) || defined(INFO) || defined(SPLIT)
#if defined(TEST) || defined(INFO) || defined(SPLIT)
*
logofs
<<
"Proxy: SPLIT! Split timeout expired after "
*
logofs
<<
"Proxy: SPLIT! Split timeout expired after "
<<
diffTimestamp
(
timeouts_
.
splitTs
,
getTimestamp
())
<<
diffTimestamp
(
timeouts_
.
splitTs
,
getTimestamp
())
<<
"
M
s.
\n
"
<<
logofs_flush
;
<<
"
m
s.
\n
"
<<
logofs_flush
;
#endif
#endif
#if defined(TEST) || defined(INFO) || defined(SPLIT)
#if defined(TEST) || defined(INFO) || defined(SPLIT)
...
@@ -2033,7 +2033,7 @@ int Proxy::handleEvents()
...
@@ -2033,7 +2033,7 @@ int Proxy::handleEvents()
{
{
*
logofs
<<
"Proxy: SPLIT! Running with "
*
logofs
<<
"Proxy: SPLIT! Running with "
<<
diffTimestamp
(
timeouts_
.
splitTs
,
getTimestamp
())
<<
diffTimestamp
(
timeouts_
.
splitTs
,
getTimestamp
())
<<
"
M
s elapsed since the last split.
\n
"
<<
"
m
s elapsed since the last split.
\n
"
<<
logofs_flush
;
<<
logofs_flush
;
}
}
#endif
#endif
...
@@ -2252,7 +2252,7 @@ int Proxy::handleFrame(T_frame_type type)
...
@@ -2252,7 +2252,7 @@ int Proxy::handleFrame(T_frame_type type)
<<
" new "
<<
outputLength
<<
" flushable "
<<
transport_
->
<<
" new "
<<
outputLength
<<
" flushable "
<<
transport_
->
flushable
()
<<
" tokens "
<<
tokens_
[
token_control
].
remaining
flushable
()
<<
" tokens "
<<
tokens_
[
token_control
].
remaining
<<
" after "
<<
diffTimestamp
(
timeouts_
.
writeTs
,
nowTs
)
<<
" after "
<<
diffTimestamp
(
timeouts_
.
writeTs
,
nowTs
)
<<
"
M
s.
\n
"
<<
logofs_flush
;
<<
"
m
s.
\n
"
<<
logofs_flush
;
*
logofs
<<
"Proxy: FLUSH! Immediate flush to proxy FD#"
<<
fd_
*
logofs
<<
"Proxy: FLUSH! Immediate flush to proxy FD#"
<<
fd_
<<
" of "
<<
outputLength
<<
" bytes at "
<<
strMsTimestamp
()
<<
" of "
<<
outputLength
<<
" bytes at "
<<
strMsTimestamp
()
...
@@ -2276,7 +2276,7 @@ int Proxy::handleFrame(T_frame_type type)
...
@@ -2276,7 +2276,7 @@ int Proxy::handleFrame(T_frame_type type)
*
logofs
<<
"Proxy: WARNING! TIME! Data written to proxy FD#"
*
logofs
<<
"Proxy: WARNING! TIME! Data written to proxy FD#"
<<
fd_
<<
" at "
<<
strMsTimestamp
()
<<
" after "
<<
fd_
<<
" at "
<<
strMsTimestamp
()
<<
" after "
<<
diffTimestamp
(
timeouts_
.
writeTs
,
nowTs
)
<<
diffTimestamp
(
timeouts_
.
writeTs
,
nowTs
)
<<
"
M
s.
\n
"
<<
logofs_flush
;
<<
"
m
s.
\n
"
<<
logofs_flush
;
}
}
#endif
#endif
...
@@ -2533,7 +2533,7 @@ int Proxy::handleDrain()
...
@@ -2533,7 +2533,7 @@ int Proxy::handleDrain()
*
logofs
<<
"Proxy: Timeout raised while draining "
*
logofs
<<
"Proxy: Timeout raised while draining "
<<
"FD#"
<<
fd_
<<
" at "
<<
strMsTimestamp
()
<<
"FD#"
<<
fd_
<<
" at "
<<
strMsTimestamp
()
<<
" after "
<<
diffTimestamp
(
startTs
,
nowTs
)
<<
" after "
<<
diffTimestamp
(
startTs
,
nowTs
)
<<
"
M
s.
\n
"
<<
logofs_flush
;
<<
"
m
s.
\n
"
<<
logofs_flush
;
#endif
#endif
result
=
0
;
result
=
0
;
...
@@ -2547,7 +2547,7 @@ int Proxy::handleDrain()
...
@@ -2547,7 +2547,7 @@ int Proxy::handleDrain()
*
logofs
<<
"Proxy: Trying to write to FD#"
<<
fd_
*
logofs
<<
"Proxy: Trying to write to FD#"
<<
fd_
<<
" at "
<<
strMsTimestamp
()
<<
" with length "
<<
" at "
<<
strMsTimestamp
()
<<
" with length "
<<
transport_
->
length
()
<<
" and "
<<
transport_
->
length
()
<<
" and "
<<
remaining
<<
"
M
s remaining.
\n
"
<<
remaining
<<
"
m
s remaining.
\n
"
<<
logofs_flush
;
<<
logofs_flush
;
#endif
#endif
...
@@ -2590,7 +2590,7 @@ int Proxy::handleDrain()
...
@@ -2590,7 +2590,7 @@ int Proxy::handleDrain()
#if defined(TEST) || defined(INFO)
#if defined(TEST) || defined(INFO)
*
logofs
<<
"Proxy: Waiting for more data from proxy "
*
logofs
<<
"Proxy: Waiting for more data from proxy "
<<
"FD#"
<<
fd_
<<
" at "
<<
strMsTimestamp
()
<<
"FD#"
<<
fd_
<<
" at "
<<
strMsTimestamp
()
<<
" with "
<<
remaining
<<
"
M
s remaining.
\n
"
<<
" with "
<<
remaining
<<
"
m
s remaining.
\n
"
<<
logofs_flush
;
<<
logofs_flush
;
#endif
#endif
...
@@ -2633,7 +2633,7 @@ int Proxy::handleDrain()
...
@@ -2633,7 +2633,7 @@ int Proxy::handleDrain()
*
logofs
<<
"Proxy: Got decongestion for proxy FD#"
*
logofs
<<
"Proxy: Got decongestion for proxy FD#"
<<
fd_
<<
" at "
<<
strMsTimestamp
()
<<
" after "
<<
fd_
<<
" at "
<<
strMsTimestamp
()
<<
" after "
<<
diffTimestamp
(
startTs
,
getTimestamp
())
<<
diffTimestamp
(
startTs
,
getTimestamp
())
<<
"
M
s.
\n
"
<<
logofs_flush
;
<<
"
m
s.
\n
"
<<
logofs_flush
;
#endif
#endif
result
=
1
;
result
=
1
;
...
@@ -3599,7 +3599,7 @@ int Proxy::handlePing()
...
@@ -3599,7 +3599,7 @@ int Proxy::handlePing()
#if defined(TEST) || defined(INFO)
#if defined(TEST) || defined(INFO)
*
logofs
<<
"Proxy: WARNING! No data received from "
*
logofs
<<
"Proxy: WARNING! No data received from "
<<
"remote proxy on FD#"
<<
fd_
<<
" since "
<<
"remote proxy on FD#"
<<
fd_
<<
" since "
<<
diffIn
<<
"
M
s.
\n
"
<<
logofs_flush
;
<<
diffIn
<<
"
m
s.
\n
"
<<
logofs_flush
;
#endif
#endif
if
(
control
->
ProxyTimeout
>
0
&&
if
(
control
->
ProxyTimeout
>
0
&&
...
...
nxcomp/src/ServerChannel.cpp
View file @
b8c92977
...
@@ -4628,7 +4628,7 @@ int ServerChannel::handleSplit(DecodeBuffer &decodeBuffer, MessageStore *store,
...
@@ -4628,7 +4628,7 @@ int ServerChannel::handleSplit(DecodeBuffer &decodeBuffer, MessageStore *store,
#if defined(TEST) || defined(SPLIT)
#if defined(TEST) || defined(SPLIT)
*
logofs
<<
"handleSplit: SPLIT! Spent "
*
logofs
<<
"handleSplit: SPLIT! Spent "
<<
diffTimestamp
(
startTs
,
getTimestamp
())
<<
"
M
s "
<<
diffTimestamp
(
startTs
,
getTimestamp
())
<<
"
m
s "
<<
"handling abort split events for FD#"
<<
fd_
<<
"handling abort split events for FD#"
<<
fd_
<<
".
\n
"
<<
logofs_flush
;
<<
".
\n
"
<<
logofs_flush
;
...
@@ -4790,7 +4790,7 @@ int ServerChannel::handleSplit(DecodeBuffer &decodeBuffer)
...
@@ -4790,7 +4790,7 @@ int ServerChannel::handleSplit(DecodeBuffer &decodeBuffer)
#if defined(TEST) || defined(SPLIT)
#if defined(TEST) || defined(SPLIT)
*
logofs
<<
"handleSplit: WARNING! SPLIT! Spent "
*
logofs
<<
"handleSplit: WARNING! SPLIT! Spent "
<<
diffTimestamp
(
startTs
,
getTimestamp
())
<<
"
M
s "
<<
diffTimestamp
(
startTs
,
getTimestamp
())
<<
"
m
s "
<<
"handling asynchronous abort split events for "
<<
"handling asynchronous abort split events for "
<<
"FD#"
<<
fd_
<<
".
\n
"
<<
logofs_flush
;
<<
"FD#"
<<
fd_
<<
".
\n
"
<<
logofs_flush
;
...
@@ -5835,7 +5835,7 @@ int ServerChannel::handleAsyncEvents()
...
@@ -5835,7 +5835,7 @@ int ServerChannel::handleAsyncEvents()
#if defined(TEST) || defined(INFO)
#if defined(TEST) || defined(INFO)
*
logofs
<<
"handleAsyncEvents: Spent "
<<
diffTimestamp
(
startTs
,
*
logofs
<<
"handleAsyncEvents: Spent "
<<
diffTimestamp
(
startTs
,
getTimestamp
())
<<
"
M
s handling events for FD#"
getTimestamp
())
<<
"
m
s handling events for FD#"
<<
fd_
<<
".
\n
"
<<
logofs_flush
;
<<
fd_
<<
".
\n
"
<<
logofs_flush
;
#endif
#endif
...
@@ -7268,7 +7268,7 @@ int ServerChannel::handleShmem(unsigned char &opcode, unsigned char *&buffer,
...
@@ -7268,7 +7268,7 @@ int ServerChannel::handleShmem(unsigned char &opcode, unsigned char *&buffer,
#if defined(TEST) || defined(INFO)
#if defined(TEST) || defined(INFO)
*
logofs
<<
"handleShmem: WARNING! Missing completion "
*
logofs
<<
"handleShmem: WARNING! Missing completion "
<<
"after "
<<
diffTimestamp
(
shmemState_
->
last
,
<<
"after "
<<
diffTimestamp
(
shmemState_
->
last
,
getTimestamp
())
<<
"
M
s for shared memory "
getTimestamp
())
<<
"
m
s for shared memory "
<<
"for FD#"
<<
fd_
<<
".
\n
"
<<
logofs_flush
;
<<
"for FD#"
<<
fd_
<<
".
\n
"
<<
logofs_flush
;
#endif
#endif
...
@@ -7402,7 +7402,7 @@ int ServerChannel::handleShmemEvent()
...
@@ -7402,7 +7402,7 @@ int ServerChannel::handleShmemEvent()
{
{
#if defined(TEST) || defined(INFO)
#if defined(TEST) || defined(INFO)
*
logofs
<<
"handleShmemEvent: Spent "
*
logofs
<<
"handleShmemEvent: Spent "
<<
diffTimestamp
(
startTs
,
getTimestamp
())
<<
"
M
s "
<<
diffTimestamp
(
startTs
,
getTimestamp
())
<<
"
m
s "
<<
"waiting for shared memory sequence for FD#"
<<
"waiting for shared memory sequence for FD#"
<<
fd_
<<
".
\n
"
<<
logofs_flush
;
<<
fd_
<<
".
\n
"
<<
logofs_flush
;
#endif
#endif
...
@@ -7414,7 +7414,7 @@ int ServerChannel::handleShmemEvent()
...
@@ -7414,7 +7414,7 @@ int ServerChannel::handleShmemEvent()
*
logofs
<<
"handleShmemEvent: WARNING! Can't reset shared "
*
logofs
<<
"handleShmemEvent: WARNING! Can't reset shared "
<<
"memory sequence for FD#"
<<
fd_
<<
" after "
<<
"memory sequence for FD#"
<<
fd_
<<
" after "
<<
diffTimestamp
(
shmemState_
->
last
,
getTimestamp
())
<<
diffTimestamp
(
shmemState_
->
last
,
getTimestamp
())
<<
"
M
s.
\n
"
<<
logofs_flush
;
<<
"
m
s.
\n
"
<<
logofs_flush
;
#endif
#endif
return
0
;
return
0
;
...
@@ -7430,7 +7430,7 @@ int ServerChannel::checkShmemEvent(unsigned char event, unsigned short sequence,
...
@@ -7430,7 +7430,7 @@ int ServerChannel::checkShmemEvent(unsigned char event, unsigned short sequence,
*
logofs
<<
"checkShmemEvent: Reset shared memory sequence "
*
logofs
<<
"checkShmemEvent: Reset shared memory sequence "
<<
shmemState_
->
sequence
<<
" for FD#"
<<
fd_
<<
shmemState_
->
sequence
<<
" for FD#"
<<
fd_
<<
" after "
<<
diffTimestamp
(
shmemState_
->
last
,
<<
" after "
<<
diffTimestamp
(
shmemState_
->
last
,
getTimestamp
())
<<
"
M
s.
\n
"
<<
logofs_flush
;
getTimestamp
())
<<
"
m
s.
\n
"
<<
logofs_flush
;
#endif
#endif
shmemState_
->
sequence
=
0
;
shmemState_
->
sequence
=
0
;
...
...
nxcomp/src/Statistics.cpp
View file @
b8c92977
...
@@ -361,14 +361,14 @@ void Statistics::updateBitrate(int bytes)
...
@@ -361,14 +361,14 @@ void Statistics::updateBitrate(int bytes)
#ifdef DEBUG
#ifdef DEBUG
*
logofs
<<
"Statistics: Difference since previous timestamp is "
*
logofs
<<
"Statistics: Difference since previous timestamp is "
<<
diffFramesInMs
<<
"
M
s.
\n
"
<<
logofs_flush
;
<<
diffFramesInMs
<<
"
m
s.
\n
"
<<
logofs_flush
;
#endif
#endif
if
(
diffFramesInMs
>
0
)
if
(
diffFramesInMs
>
0
)
{
{
#ifdef DEBUG
#ifdef DEBUG
*
logofs
<<
"Statistics: Removing "
<<
diffFramesInMs
*
logofs
<<
"Statistics: Removing "
<<
diffFramesInMs
<<
"
M
s in short and long time frame.
\n
"
<<
"
m
s in short and long time frame.
\n
"
<<
logofs_flush
;
<<
logofs_flush
;
#endif
#endif
...
@@ -1751,7 +1751,7 @@ int Statistics::getTimeStats(int type, char *&buffer)
...
@@ -1751,7 +1751,7 @@ int Statistics::getTimeStats(int type, char *&buffer)
char
format
[
FORMAT_LENGTH
];
char
format
[
FORMAT_LENGTH
];
sprintf
(
format
,
"
\n
time: %.0f
Ms idle, %.0f Ms (%.0f Ms in read, %.0f M
s in write) running.
\n\n
"
,
sprintf
(
format
,
"
\n
time: %.0f
ms idle, %.0fms (%.0f ms in read, %.0f m
s in write) running.
\n\n
"
,
transportData
->
idleTime_
,
transportData
->
readTime_
,
transportData
->
idleTime_
,
transportData
->
readTime_
,
transportData
->
readTime_
-
transportData
->
writeTime_
,
transportData
->
readTime_
-
transportData
->
writeTime_
,
transportData
->
writeTime_
);
transportData
->
writeTime_
);
...
...
nxcomp/src/Timestamp.h
View file @
b8c92977
...
@@ -135,7 +135,7 @@ inline T_timestamp getTimestamp()
...
@@ -135,7 +135,7 @@ inline T_timestamp getTimestamp()
if
(
diffTs
>
DRIFT_TIMESTAMP
)
if
(
diffTs
>
DRIFT_TIMESTAMP
)
{
{
*
logofs
<<
"Timestamp: WARNING! Time difference since the "
*
logofs
<<
"Timestamp: WARNING! Time difference since the "
<<
"current timestamp is "
<<
diffTs
<<
"
M
s.
\n
"
<<
"current timestamp is "
<<
diffTs
<<
"
m
s.
\n
"
<<
logofs_flush
;
<<
logofs_flush
;
}
}
...
@@ -293,7 +293,7 @@ inline T_timestamp getNewTimestamp()
...
@@ -293,7 +293,7 @@ inline T_timestamp getNewTimestamp()
if
(
diffTs
>
DRIFT_TIMESTAMP
)
if
(
diffTs
>
DRIFT_TIMESTAMP
)
{
{
*
logofs
<<
"Timestamp: WARNING! Time difference since the "
*
logofs
<<
"Timestamp: WARNING! Time difference since the "
<<
"old timestamp is "
<<
diffTs
<<
"
M
s.
\n
"
<<
"old timestamp is "
<<
diffTs
<<
"
m
s.
\n
"
<<
logofs_flush
;
<<
logofs_flush
;
}
}
...
...
nxcomp/src/Transport.cpp
View file @
b8c92977
...
@@ -868,7 +868,7 @@ int Transport::wait(int timeout) const
...
@@ -868,7 +868,7 @@ int Transport::wait(int timeout) const
#ifdef TEST
#ifdef TEST
*
logofs
<<
"Transport: There are "
<<
available
*
logofs
<<
"Transport: There are "
<<
available
<<
" bytes on FD#"
<<
fd_
<<
" after "
<<
" bytes on FD#"
<<
fd_
<<
" after "
<<
diffTs
<<
"
M
s.
\n
"
<<
logofs_flush
;
<<
diffTs
<<
"
m
s.
\n
"
<<
logofs_flush
;
#endif
#endif
return
available
;
return
available
;
...
@@ -933,13 +933,13 @@ int Transport::wait(int timeout) const
...
@@ -933,13 +933,13 @@ int Transport::wait(int timeout) const
{
{
*
logofs
<<
"Transport: No data available on FD#"
<<
fd_
*
logofs
<<
"Transport: No data available on FD#"
<<
fd_
<<
" after "
<<
diffTimestamp
(
startTs
,
nowTs
)
<<
" after "
<<
diffTimestamp
(
startTs
,
nowTs
)
<<
"
M
s.
\n
"
<<
logofs_flush
;
<<
"
m
s.
\n
"
<<
logofs_flush
;
}
}
else
else
{
{
*
logofs
<<
"Transport: Data became available on FD#"
<<
fd_
*
logofs
<<
"Transport: Data became available on FD#"
<<
fd_
<<
" after "
<<
diffTimestamp
(
startTs
,
nowTs
)
<<
" after "
<<
diffTimestamp
(
startTs
,
nowTs
)
<<
"
M
s.
\n
"
<<
logofs_flush
;
<<
"
m
s.
\n
"
<<
logofs_flush
;
}
}
#endif
#endif
}
}
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment