#include <sys/errno.h>
#include <sys/types.h>
#include <sys/param.h>
#include <machine/spl.h>
#include <sys/systm.h>
#include <sys/kernel.h>
#include <sys/proc.h>
#include <sys/filedesc.h>
#include <sys/fcntl.h>
#include <sys/mbuf.h>
#include <sys/socket.h>
#include <sys/socketvar.h>
#include <net/if.h>
#include <netat/sysglue.h>
#include <netat/appletalk.h>
#include <netat/at_var.h>
#include <netat/routing_tables.h>
#include <netat/at_pcb.h>
#include <netat/aurp.h>
#include <netat/debug.h>
void AURPsndTickle(state)
aurp_state_t *state;
{
int msize;
gbuf_t *m;
aurp_hdr_t *hdrp;
boolean_t funnel_state;
funnel_state = thread_funnel_set(network_flock, TRUE);
if (state->rcv_state == AURPSTATE_Unconnected) {
(void) thread_funnel_set(network_flock, FALSE);
return;
}
if (++state->tickle_retry > AURP_MaxTickleRetry) {
dPrintf(D_M_AURP, D_L_WARNING,
("AURPsndTickle: no response, %d\n", state->rem_node));
state->snd_state = AURPSTATE_Unconnected;
state->rcv_state = AURPSTATE_Unconnected;
state->tickle_retry = 0;
AURPcleanup(state);
AURPpurgeri(state->rem_node);
(void) thread_funnel_set(network_flock, FALSE);
return;
}
if (state->tickle_retry > 1) {
msize = sizeof(aurp_hdr_t);
if ((m = (gbuf_t *)gbuf_alloc(msize, PRI_MED)) != 0) {
gbuf_wset(m,msize);
hdrp = (aurp_hdr_t *)gbuf_rptr(m);
hdrp->connection_id = state->rcv_connection_id;
hdrp->sequence_number = 0;
hdrp->command_code = AURPCMD_Tickle;
hdrp->flags = 0;
AURPsend(m, AUD_AURP, state->rem_node);
}
}
timeout(AURPsndTickle, state, AURP_TickleRetryInterval*HZ);
(void) thread_funnel_set(network_flock, FALSE);
}
void AURPrcvTickle(state, m)
aurp_state_t *state;
gbuf_t *m;
{
aurp_hdr_t *hdrp = (aurp_hdr_t *)gbuf_rptr(m);
if (state->snd_state == AURPSTATE_Unconnected) {
dPrintf(D_M_AURP, D_L_WARNING,
("AURPrcvTickle: unexpected request\n"));
gbuf_freem(m);
return;
}
gbuf_wset(m,sizeof(aurp_hdr_t));
hdrp->command_code = AURPCMD_TickleAck;
hdrp->flags = 0;
AURPsend(m, AUD_AURP, state->rem_node);
}
void AURPrcvTickleAck(state, m)
aurp_state_t *state;
gbuf_t *m;
{
aurp_hdr_t *hdrp = (aurp_hdr_t *)gbuf_rptr(m);
if (state->rcv_state == AURPSTATE_Unconnected) {
dPrintf(D_M_AURP, D_L_WARNING,
("AURPrcvTickleAck: unexpected response\n"));
gbuf_freem(m);
return;
}
if (hdrp->connection_id != state->rcv_connection_id) {
dPrintf(D_M_AURP, D_L_WARNING,
("AURPrcvTickleAck: invalid connection id, r=%d, m=%d\n",
hdrp->connection_id, state->rcv_connection_id));
gbuf_freem(m);
return;
}
gbuf_freem(m);
state->tickle_retry = 0;
}