First cut at patches to make appletalk compile again

after the dissapearance of the USRREQ() entrypoint.

1 files changed, 186 insertions, 107 deletions

diff --git a/sys/netatalk/ddp_usrreq.c b/sys/netatalk/ddp_usrreq.c
index 985cf40..371e12a 100644
--- a/sys/netatalk/ddp_usrreq.c
+++ b/sys/netatalk/ddp_usrreq.c
@@ -36,152 +36,187 @@ struct ddpcb	*ddpcb = NULL;
 u_long		ddp_sendspace = DDP_MAXSZ; /* Max ddp size + 1 (ddp_type) */
 u_long		ddp_recvspace = 10 * ( 587 + sizeof( struct sockaddr_at ));
 
-/*ARGSUSED*/
-int
-ddp_usrreq( struct socket *so, int req, struct mbuf *m,
-		struct mbuf  *addr, struct mbuf *rights)
-{
-    struct proc *p = curproc;           /* XXX */
-    struct ddpcb	*ddp;
-    int			error = 0;
-
-    ddp = sotoddpcb( so );
-
-    if ( req == PRU_CONTROL ) {
-	return( at_control( (int) m, (caddr_t) addr,
-		(struct ifnet *) rights, (struct proc *)p ));
-    }
 
-    if ( rights && rights->m_len ) {
-	error = EINVAL;
-	goto release;
-    }
-
-    if ( ddp == NULL && req != PRU_ATTACH ) {
-	error = EINVAL;
-	goto release;
-    }
+static int
+ddp_attach(struct socket *so, int proto, struct proc *p)
+{
+	struct ddpcb	*ddp;
+	int		error = 0;
+	int		s;
+	
 
-    switch ( req ) {
-    case PRU_ATTACH :
+	ddp = sotoddpcb( so );
 	if ( ddp != NULL ) {
-	    error = EINVAL;
-	    break;
+	    return( EINVAL);
 	}
-	if (( error = at_pcballoc( so )) != 0 ) {
-	    break;
+
+	s = splnet();
+	error = at_pcballoc( so );
+	splx(s);
+	if (error) {
+	    return (error);
 	}
-	error = soreserve( so, ddp_sendspace, ddp_recvspace );
-	break;
+	return (soreserve( so, ddp_sendspace, ddp_recvspace ));
+}
 
-    case PRU_DETACH :
+static int
+ddp_detach(struct socket *so)
+{
+	struct ddpcb	*ddp;
+	int		error = 0;
+	int		s;
+	
+	ddp = sotoddpcb( so );
+	if ( ddp == NULL ) {
+	    return( EINVAL);
+	}
+	s = splnet();
 	at_pcbdetach( so, ddp );
-	break;
+	splx(s);
+	return(0);
+}
 
-    case PRU_BIND :
-	error = at_pcbsetaddr( ddp, addr, p );
-	break;
+static int      
+ddp_bind(struct socket *so, struct mbuf *nam, struct proc *p)
+{
+	struct ddpcb	*ddp;
+	int		error = 0;
+	int		s;
+	
+	ddp = sotoddpcb( so );
+	if ( ddp == NULL ) {
+	    return( EINVAL);
+	}
+	s = splnet();
+	error = at_pcbsetaddr( ddp, nam, p );
+	splx(s);
+	return (error);
+}
     
-    case PRU_SOCKADDR :
-	at_sockaddr( ddp, addr );
-	break;
+static int
+ddp_connect(struct socket *so, struct mbuf *nam, struct proc *p)
+{
+	struct ddpcb	*ddp;
+	int		error = 0;
+	int		s;
+	
+	ddp = sotoddpcb( so );
+	if ( ddp == NULL ) {
+	    return( EINVAL);
+	}
 
-    case PRU_CONNECT:
 	if ( ddp->ddp_fsat.sat_port != ATADDR_ANYPORT ) {
-	    error = EISCONN;
-	    break;
+	    return(EISCONN);
 	}
 
-	error = at_pcbconnect( ddp, addr, p );
+	s = splnet();
+	error = at_pcbconnect( ddp, nam, p );
+	splx(s);
 	if ( error == 0 )
 	    soisconnected( so );
-	break;
+	return(error);
+}
 
-    case PRU_DISCONNECT:
+static int
+ddp_disconnect(struct socket *so)
+{
+
+	struct ddpcb	*ddp;
+	int		error = 0;
+	int		s;
+	
+	ddp = sotoddpcb( so );
+	if ( ddp == NULL ) {
+	    return( EINVAL);
+	}
 	if ( ddp->ddp_fsat.sat_addr.s_node == ATADDR_ANYNODE ) {
-	    error = ENOTCONN;
-	    break;
+	    return(ENOTCONN);
 	}
+
+	s = splnet();
 	at_pcbdisconnect( ddp );
+	ddp->ddp_fsat.sat_addr.s_node = ATADDR_ANYNODE;
+	splx(s);
 	soisdisconnected( so );
-	break;
+	return(0);
+}
 
-    case PRU_SHUTDOWN:
+static int
+ddp_shutdown(struct socket *so)
+{
+	struct ddpcb	*ddp;
+	int		error = 0;
+	int		s;
+	
+	ddp = sotoddpcb( so );
+	if ( ddp == NULL ) {
+		return( EINVAL);
+	}
 	socantsendmore( so );
-	break;
+	return(0);
+}
 
-    case PRU_SEND: {
-	int	s = 0;
+static int
+ddp_send(struct socket *so, int flags, struct mbuf *m, struct mbuf *addr,
+            struct mbuf *control, struct proc *p)
+{
+	struct ddpcb	*ddp;
+	int		error = 0;
+	int		s;
+	
+	ddp = sotoddpcb( so );
+	if ( ddp == NULL ) {
+		return(EINVAL);
+	}
+
+    	if ( control && control->m_len ) {
+		return(EINVAL);
+    	}
 
 	if ( addr ) {
-	    if ( ddp->ddp_fsat.sat_port != ATADDR_ANYPORT ) {
-		error = EISCONN;
-		break;
-	    }
+		if ( ddp->ddp_fsat.sat_port != ATADDR_ANYPORT ) {
+			return(EISCONN);
+		}
 
-	    s = splnet();
-	    error = at_pcbconnect( ddp, addr, p );
-	    if ( error ) {
+		s = splnet();
+		error = at_pcbconnect( ddp, addr, p );
 		splx( s );
-		break;
-	    }
+		if ( error ) {
+			return(error);
+		}
 	} else {
-	    if ( ddp->ddp_fsat.sat_port == ATADDR_ANYPORT ) {
-		error = ENOTCONN;
-		break;
-	    }
+		if ( ddp->ddp_fsat.sat_port == ATADDR_ANYPORT ) {
+			return(ENOTCONN);
+		}
 	}
 
+	s = splnet();
 	error = ddp_output( m, so );
-	m = NULL;
 	if ( addr ) {
 	    at_pcbdisconnect( ddp );
-	    splx( s );
 	}
-	}
-	break;
+	splx(s);
+	return(error);
+}
 
-    case PRU_ABORT:
+static int
+ddp_abort(struct socket *so)
+{
+	struct ddpcb	*ddp;
+	int		s;
+	
+	ddp = sotoddpcb( so );
+	if ( ddp == NULL ) {
+		return(EINVAL);
+	}
 	soisdisconnected( so );
+	s = splnet();
 	at_pcbdetach( so, ddp );
-	break;
-
-    case PRU_LISTEN:
-    case PRU_CONNECT2:
-    case PRU_ACCEPT:
-    case PRU_SENDOOB:
-    case PRU_FASTTIMO:
-    case PRU_SLOWTIMO:
-    case PRU_PROTORCV:
-    case PRU_PROTOSEND:
-	error = EOPNOTSUPP;
-	break;
-
-    case PRU_RCVD:
-    case PRU_RCVOOB:
-	/*
-	 * Don't mfree. Good architecture...
-	 */
-	return( EOPNOTSUPP );
-
-    case PRU_SENSE:
-	/*
-	 * 1. Don't return block size.
-	 * 2. Don't mfree.
-	 */
-	return( 0 );
-
-    default:
-	error = EOPNOTSUPP;
-    }
-
-release:
-    if ( m != NULL ) {
-	m_freem( m );
-    }
-    return( error );
+	splx(s);
+	return(0);
 }
 
+
 static void
 at_sockaddr( struct ddpcb *ddp, struct mbuf *addr)
 {
@@ -505,6 +540,27 @@ ddp_search( struct sockaddr_at *from, struct sockaddr_at *to,
     }
     return( ddp );
 }
+static int
+at_setpeeraddr(struct socket *so, struct mbuf *nam)
+{
+	return(EOPNOTSUPP);
+}
+
+static int
+at_setsockaddr(struct socket *so, struct mbuf *nam)
+{
+	struct ddpcb	*ddp;
+	int		error = 0;
+	int		s;
+	
+	ddp = sotoddpcb( so );
+	if ( ddp == NULL ) {
+	    return( EINVAL);
+	}
+	at_sockaddr( ddp, nam );
+	return(0);
+}
+
 
 void 
 ddp_init(void )
@@ -524,3 +580,26 @@ ddp_clean(void )
     }
 }
 #endif
+
+struct pr_usrreqs ddp_usrreqs = {
+	ddp_abort,
+	pru_accept_notsupp,
+	ddp_attach,
+	ddp_bind,
+	ddp_connect,
+	pru_connect2_notsupp,
+	at_control,
+	ddp_detach,
+	ddp_disconnect,
+	pru_listen_notsupp,
+	at_setpeeraddr,
+	pru_rcvd_notsupp,
+	pru_rcvoob_notsupp,
+	ddp_send,
+	pru_sense_null,
+	ddp_shutdown,
+	at_setsockaddr,
+	sosend,
+	soreceive,
+	soselect
+};