projects
/
swifty.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Add counters for MPTP buffers and syscalls.
[swifty.git]
/
src
/
libswift
/
channel.cpp
diff --git
a/src/libswift/channel.cpp
b/src/libswift/channel.cpp
index
e06d83f
..
c05ec03
100644
(file)
--- a/
src/libswift/channel.cpp
+++ b/
src/libswift/channel.cpp
@@
-27,7
+27,9
@@
tint Channel::start = now_t::now;
tint Channel::epoch = now_t::now/360000000LL*360000000LL; // make logs mergeable
uint64_t Channel::global_dgrams_up=0, Channel::global_dgrams_down=0,
Channel::global_raw_bytes_up=0, Channel::global_raw_bytes_down=0,
tint Channel::epoch = now_t::now/360000000LL*360000000LL; // make logs mergeable
uint64_t Channel::global_dgrams_up=0, Channel::global_dgrams_down=0,
Channel::global_raw_bytes_up=0, Channel::global_raw_bytes_down=0,
- Channel::global_bytes_up=0, Channel::global_bytes_down=0;
+ Channel::global_bytes_up=0, Channel::global_bytes_down=0,
+ Channel::global_buffers_up=0, Channel::global_syscalls_up=0,
+ Channel::global_buffers_down=0, Channel::global_syscalls_down=0;
sckrwecb_t Channel::sock_open[] = {};
int Channel::sock_count = 0;
swift::tint Channel::last_tick = 0;
sckrwecb_t Channel::sock_open[] = {};
int Channel::sock_count = 0;
swift::tint Channel::last_tick = 0;
@@
-281,6
+283,8
@@
int Channel::SendTo (evutil_socket_t sock, const Address& addr, struct evbuffer
for (int i=0; i<count; ++i)
evbuffer_drain(evb[i], addr.addr->dests[i].bytes);
global_dgrams_up+=count;
for (int i=0; i<count; ++i)
evbuffer_drain(evb[i], addr.addr->dests[i].bytes);
global_dgrams_up+=count;
+ global_buffers_up+=count;
+ global_syscalls_up++;
for (int i=0; i<count; ++i)
global_raw_bytes_up+=lengths[i];
Time();
for (int i=0; i<count; ++i)
global_raw_bytes_up+=lengths[i];
Time();
@@
-338,6
+342,8
@@
int Channel::RecvFrom (evutil_socket_t sock, Address& addr, struct evbuffer **ev
}
}
global_dgrams_down+=addr.addr->count;
}
}
global_dgrams_down+=addr.addr->count;
+ global_buffers_down+=addr.addr->count;
+ global_syscalls_down++;
global_raw_bytes_down+=length;
Time();
return length;
global_raw_bytes_down+=length;
Time();
return length;