/* remember start time for call in case we have hard dead time limit */
call->queueTime = queueTime;
clock_GetTime(&call->startTime);
- call->bytesSent = 0;
- call->bytesRcvd = 0;
+ call->app.bytesSent = 0;
+ call->app.bytesRcvd = 0;
/* Turn on busy protocol. */
rxi_KeepAliveOn(call);
#endif
call->state = RX_STATE_PRECALL;
clock_GetTime(&call->queueTime);
- call->bytesSent = 0;
- call->bytesRcvd = 0;
+ call->app.bytesSent = 0;
+ call->app.bytesRcvd = 0;
/*
* If the number of queued calls exceeds the overload
* threshold then abort this call.
#endif
call->state = RX_STATE_PRECALL;
clock_GetTime(&call->queueTime);
- call->bytesSent = 0;
- call->bytesRcvd = 0;
+ call->app.bytesSent = 0;
+ call->app.bytesRcvd = 0;
/*
* If the number of queued calls exceeds the overload
* threshold then abort this call.
clock_Sub(&queue, &call->queueTime);
rxi_IncrementTimeAndCount(call->conn->peer, rxInterface, currentFunc,
- totalFunc, &queue, &exec, call->bytesSent,
- call->bytesRcvd, 1);
+ totalFunc, &queue, &exec, call->app.bytesSent,
+ call->app.bytesRcvd, 1);
}
char *curpos; /* current position in curvec */
int mode; /* Mode of call */
int padding; /* Pad to double word */
+ afs_uint64 bytesSent; /* Number bytes sent */
+ afs_uint64 bytesRcvd; /* Number bytes received */
};
/* Call structure: only instantiated for active calls and dallying
* well as state shared with other calls associated with this
* connection) is maintained in the connection structure. */
-
#ifdef KDUMP_RX_LOCK
struct rx_call_rx_lock {
#else
struct clock queueTime; /* time call was queued */
struct clock startTime; /* time call was started */
- afs_uint64 bytesSent; /* Number bytes sent */
- afs_uint64 bytesRcvd; /* Number bytes received */
+
u_short tqWaiters;
struct rx_packet *xmitList[RX_MAXACKS]; /* Can't xmit more than we ack */
call->conn->securityHeaderSize;
call->app.nLeft = call->app.currentPacket->length;
- call->bytesRcvd += call->app.currentPacket->length;
+ call->app.bytesRcvd += call->app.currentPacket->length;
call->nHardAcks++;
* there will be others. PrepareSendPacket may
* alter the packet length by up to
* conn->securityMaxTrailerSize */
- call->bytesSent += call->app.currentPacket->length;
+ call->app.bytesSent += call->app.currentPacket->length;
rxi_PrepareSendPacket(call, call->app.currentPacket, 0);
#ifdef AFS_GLOBAL_RXLOCK_KERNEL
/* PrepareSendPacket drops the call lock */
* there will be others. PrepareSendPacket may
* alter the packet length by up to
* conn->securityMaxTrailerSize */
- call->bytesSent += call->app.currentPacket->length;
+ call->app.bytesSent += call->app.currentPacket->length;
rxi_PrepareSendPacket(call, call->app.currentPacket, 0);
#ifdef AFS_GLOBAL_RXLOCK_KERNEL
/* PrepareSendPacket drops the call lock */
}
/* The 1 specifies that this is the last packet */
- call->bytesSent += cp->length;
+ call->app.bytesSent += cp->length;
rxi_PrepareSendPacket(call, cp, 1);
#ifdef AFS_GLOBAL_RXLOCK_KERNEL
/* PrepareSendPacket drops the call lock */