repositories
/
deb_libnfs.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Add a call to find the queue-length so we can see how many I/O we have in flight...
[deb_libnfs.git]
/
lib
/
socket.c
diff --git
a/lib/socket.c
b/lib/socket.c
index 760da2f352a2983480485eb903966ef6ded46a3a..d93acd80b717c9f4be0fab8168862bab3bdf6dbc 100644
(file)
--- a/
lib/socket.c
+++ b/
lib/socket.c
@@
-315,7
+315,7
@@
int rpc_service(struct rpc_context *rpc, int revents)
if (revents & POLLIN) {
if (rpc_read_from_socket(rpc) != 0) {
if (revents & POLLIN) {
if (rpc_read_from_socket(rpc) != 0) {
- rpc_disconnect_requeue(rpc);
+ rpc_disconnect_requeue(rpc);
return 0;
}
}
return 0;
}
}
@@
-514,3
+514,17
@@
struct sockaddr *rpc_get_recv_sockaddr(struct rpc_context *rpc)
{
return (struct sockaddr *)&rpc->udp_src;
}
{
return (struct sockaddr *)&rpc->udp_src;
}
+
+int rpc_queue_length(struct rpc_context *rpc)
+{
+ int i=0;
+ struct rpc_pdu *pdu;
+
+ for(pdu = rpc->outqueue; pdu; pdu = pdu->next) {
+ i++;
+ }
+ for(pdu = rpc->waitpdu; pdu; pdu = pdu->next) {
+ i++;
+ }
+ return i;
+}