mirror of
https://git.openafs.org/openafs.git
synced 2025-02-01 14:07:39 +00:00
STABLE14-kill-struct-osisocket-20050415
FIXES 18079 more complete version of what's in the patch, kill all refs to struct osi_socket in favor of just osi_socket from psomogyi@gamax.hu (cherry picked from commit 2dc87bcf1e632444b163eea94172b77e7d376d5c)
This commit is contained in:
parent
a01b7fee7b
commit
0816ea0142
@ -416,7 +416,7 @@ rxi_GetIFInfo()
|
|||||||
|
|
||||||
#ifdef AFS_SGI65_ENV
|
#ifdef AFS_SGI65_ENV
|
||||||
osi_NetSend(asocket, addr, dvec, nvec, asize, istack)
|
osi_NetSend(asocket, addr, dvec, nvec, asize, istack)
|
||||||
register struct osi_socket *asocket;
|
register osi_socket *asocket;
|
||||||
struct iovec *dvec;
|
struct iovec *dvec;
|
||||||
int nvec;
|
int nvec;
|
||||||
register afs_int32 asize;
|
register afs_int32 asize;
|
||||||
|
@ -29,7 +29,7 @@ RCSID
|
|||||||
/* rxk_NewSocket
|
/* rxk_NewSocket
|
||||||
* open and bind RX socket
|
* open and bind RX socket
|
||||||
*/
|
*/
|
||||||
struct osi_socket *
|
osi_socket *
|
||||||
rxk_NewSocketHost(afs_uint32 ahost, short aport)
|
rxk_NewSocketHost(afs_uint32 ahost, short aport)
|
||||||
{
|
{
|
||||||
struct socket *sockp;
|
struct socket *sockp;
|
||||||
@ -70,10 +70,10 @@ rxk_NewSocketHost(afs_uint32 ahost, short aport)
|
|||||||
sockp->ops->setsockopt(sockp, SOL_IP, IP_MTU_DISCOVER, (char *)&pmtu,
|
sockp->ops->setsockopt(sockp, SOL_IP, IP_MTU_DISCOVER, (char *)&pmtu,
|
||||||
sizeof(pmtu));
|
sizeof(pmtu));
|
||||||
TO_KERNEL_SPACE();
|
TO_KERNEL_SPACE();
|
||||||
return (struct osi_socket *)sockp;
|
return (osi_socket *)sockp;
|
||||||
}
|
}
|
||||||
|
|
||||||
struct osi_socket *
|
osi_socket *
|
||||||
rxk_NewSocket(short aport)
|
rxk_NewSocket(short aport)
|
||||||
{
|
{
|
||||||
return rxk_NewSocketHost(htonl(INADDR_ANY), aport);
|
return rxk_NewSocketHost(htonl(INADDR_ANY), aport);
|
||||||
|
@ -221,7 +221,7 @@ rxi_FindIfMTU(afs_uint32 addr)
|
|||||||
struct sockaddr_in rx_sockaddr;
|
struct sockaddr_in rx_sockaddr;
|
||||||
|
|
||||||
/* Allocate a new socket at specified port in network byte order. */
|
/* Allocate a new socket at specified port in network byte order. */
|
||||||
struct osi_socket *
|
osi_socket *
|
||||||
rxk_NewSocketHost(afs_uint32 ahost, short aport)
|
rxk_NewSocketHost(afs_uint32 ahost, short aport)
|
||||||
{
|
{
|
||||||
vnode_t *accessvp;
|
vnode_t *accessvp;
|
||||||
@ -315,17 +315,17 @@ rxk_NewSocketHost(afs_uint32 ahost, short aport)
|
|||||||
return NULL;
|
return NULL;
|
||||||
}
|
}
|
||||||
|
|
||||||
return (struct osi_socket *)so;
|
return (osi_socket *)so;
|
||||||
}
|
}
|
||||||
|
|
||||||
struct osi_socket *
|
osi_socket *
|
||||||
rxk_NewSocket(short aport)
|
rxk_NewSocket(short aport)
|
||||||
{
|
{
|
||||||
return rxk_NewSocketHost(htonl(INADDR_ANY), aport);
|
return rxk_NewSocketHost(htonl(INADDR_ANY), aport);
|
||||||
}
|
}
|
||||||
|
|
||||||
int
|
int
|
||||||
osi_FreeSocket(register struct osi_socket *asocket)
|
osi_FreeSocket(register osi_socket *asocket)
|
||||||
{
|
{
|
||||||
extern int rxk_ListenerPid;
|
extern int rxk_ListenerPid;
|
||||||
struct sonode *so = (struct sonode *)asocket;
|
struct sonode *so = (struct sonode *)asocket;
|
||||||
@ -509,7 +509,7 @@ rxi_GetIFInfo()
|
|||||||
dev_t afs_udp_rdev = (dev_t) 0;
|
dev_t afs_udp_rdev = (dev_t) 0;
|
||||||
|
|
||||||
/* Allocate a new socket at specified port in network byte order. */
|
/* Allocate a new socket at specified port in network byte order. */
|
||||||
struct osi_socket *
|
osi_socket *
|
||||||
rxk_NewSocketHost(afs_uint32 ahost, short aport)
|
rxk_NewSocketHost(afs_uint32 ahost, short aport)
|
||||||
{
|
{
|
||||||
TIUSER *udp_tiptr;
|
TIUSER *udp_tiptr;
|
||||||
@ -523,7 +523,7 @@ rxk_NewSocketHost(afs_uint32 ahost, short aport)
|
|||||||
afs_udp_rdev = makedevice(11 /*CLONE*/, ddi_name_to_major("udp"));
|
afs_udp_rdev = makedevice(11 /*CLONE*/, ddi_name_to_major("udp"));
|
||||||
code = t_kopen(NULL, afs_udp_rdev, FREAD | FWRITE, &udp_tiptr, CRED());
|
code = t_kopen(NULL, afs_udp_rdev, FREAD | FWRITE, &udp_tiptr, CRED());
|
||||||
if (code) {
|
if (code) {
|
||||||
return (struct osi_socket *)0;
|
return (osi_socket *)0;
|
||||||
}
|
}
|
||||||
|
|
||||||
code = t_kalloc(udp_tiptr, T_BIND, T_ADDR, (char **)&reqp);
|
code = t_kalloc(udp_tiptr, T_BIND, T_ADDR, (char **)&reqp);
|
||||||
@ -534,7 +534,7 @@ rxk_NewSocketHost(afs_uint32 ahost, short aport)
|
|||||||
if (code) {
|
if (code) {
|
||||||
t_kfree(udp_tiptr, (char *)reqp, T_BIND);
|
t_kfree(udp_tiptr, (char *)reqp, T_BIND);
|
||||||
t_kclose(udp_tiptr, 0);
|
t_kclose(udp_tiptr, 0);
|
||||||
return (struct osi_socket *)0;
|
return (osi_socket *)0;
|
||||||
}
|
}
|
||||||
|
|
||||||
reqp->addr.len = sizeof(struct sockaddr_in);
|
reqp->addr.len = sizeof(struct sockaddr_in);
|
||||||
@ -548,13 +548,13 @@ rxk_NewSocketHost(afs_uint32 ahost, short aport)
|
|||||||
t_kfree(udp_tiptr, (char *)reqp, T_BIND);
|
t_kfree(udp_tiptr, (char *)reqp, T_BIND);
|
||||||
t_kfree(udp_tiptr, (char *)rspp, T_BIND);
|
t_kfree(udp_tiptr, (char *)rspp, T_BIND);
|
||||||
t_kclose(udp_tiptr, 0);
|
t_kclose(udp_tiptr, 0);
|
||||||
return (struct osi_socket *)0;
|
return (osi_socket *)0;
|
||||||
}
|
}
|
||||||
if (memcmp(reqp->addr.buf, rspp->addr.buf, rspp->addr.len)) {
|
if (memcmp(reqp->addr.buf, rspp->addr.buf, rspp->addr.len)) {
|
||||||
t_kfree(udp_tiptr, (char *)reqp, T_BIND);
|
t_kfree(udp_tiptr, (char *)reqp, T_BIND);
|
||||||
t_kfree(udp_tiptr, (char *)rspp, T_BIND);
|
t_kfree(udp_tiptr, (char *)rspp, T_BIND);
|
||||||
t_kclose(udp_tiptr, 0);
|
t_kclose(udp_tiptr, 0);
|
||||||
return (struct osi_socket *)0;
|
return (osi_socket *)0;
|
||||||
}
|
}
|
||||||
t_kfree(udp_tiptr, (char *)reqp, T_BIND);
|
t_kfree(udp_tiptr, (char *)reqp, T_BIND);
|
||||||
t_kfree(udp_tiptr, (char *)rspp, T_BIND);
|
t_kfree(udp_tiptr, (char *)rspp, T_BIND);
|
||||||
@ -568,17 +568,17 @@ rxk_NewSocketHost(afs_uint32 ahost, short aport)
|
|||||||
q->q_next->q_hiwat = rx_UdpBufSize;
|
q->q_next->q_hiwat = rx_UdpBufSize;
|
||||||
RD(q)->q_hiwat = rx_UdpBufSize;
|
RD(q)->q_hiwat = rx_UdpBufSize;
|
||||||
|
|
||||||
return (struct osi_socket *)udp_tiptr;
|
return (osi_socket *)udp_tiptr;
|
||||||
}
|
}
|
||||||
|
|
||||||
struct osi_socket *
|
osi_socket *
|
||||||
rxk_NewSocket(short aport)
|
rxk_NewSocket(short aport)
|
||||||
{
|
{
|
||||||
return rxk_NewSocketHost(htonl(INADDR_ANY), aport);
|
return rxk_NewSocketHost(htonl(INADDR_ANY), aport);
|
||||||
}
|
}
|
||||||
|
|
||||||
int
|
int
|
||||||
osi_FreeSocket(register struct osi_socket *asocket)
|
osi_FreeSocket(register osi_socket *asocket)
|
||||||
{
|
{
|
||||||
extern int rxk_ListenerPid;
|
extern int rxk_ListenerPid;
|
||||||
TIUSER *udp_tiptr = (TIUSER *) asocket;
|
TIUSER *udp_tiptr = (TIUSER *) asocket;
|
||||||
@ -681,7 +681,7 @@ osi_NetSend(osi_socket asocket, struct sockaddr_in *addr, struct iovec *dvec,
|
|||||||
|
|
||||||
|
|
||||||
int
|
int
|
||||||
osi_NetReceive(struct osi_socket *asocket, struct sockaddr_in *addr,
|
osi_NetReceive(osi_socket *asocket, struct sockaddr_in *addr,
|
||||||
struct iovec *dvec, int nvecs, int *alength)
|
struct iovec *dvec, int nvecs, int *alength)
|
||||||
{
|
{
|
||||||
int i;
|
int i;
|
||||||
|
@ -169,7 +169,7 @@ rx_ServerProc(void)
|
|||||||
* routines. Allocate the socket buffer here, but don't open it until
|
* routines. Allocate the socket buffer here, but don't open it until
|
||||||
* we start the receiver threads.
|
* we start the receiver threads.
|
||||||
*/
|
*/
|
||||||
struct osi_socket *
|
osi_socket *
|
||||||
rxk_NewSocketHost(afs_uint32 ahost, short aport)
|
rxk_NewSocketHost(afs_uint32 ahost, short aport)
|
||||||
{
|
{
|
||||||
struct usr_socket *usockp;
|
struct usr_socket *usockp;
|
||||||
@ -179,10 +179,10 @@ rxk_NewSocketHost(afs_uint32 ahost, short aport)
|
|||||||
|
|
||||||
usockp->sock = -1;
|
usockp->sock = -1;
|
||||||
|
|
||||||
return (struct osi_socket *)usockp;
|
return (osi_socket *)usockp;
|
||||||
}
|
}
|
||||||
|
|
||||||
struct osi_socket *
|
osi_socket *
|
||||||
rxk_NewSocket(short aport)
|
rxk_NewSocket(short aport)
|
||||||
{
|
{
|
||||||
return rxk_NewSocketHost(htonl(INADDR_ANY), aport);
|
return rxk_NewSocketHost(htonl(INADDR_ANY), aport);
|
||||||
|
@ -30,7 +30,7 @@ int (*rxk_PacketArrivalProc) (register struct rx_packet * ahandle, register stru
|
|||||||
int (*rxk_GetPacketProc) (char **ahandle, int asize);
|
int (*rxk_GetPacketProc) (char **ahandle, int asize);
|
||||||
#endif
|
#endif
|
||||||
|
|
||||||
struct osi_socket *rxk_NewSocketHost(afs_uint32 ahost, short aport);
|
osi_socket *rxk_NewSocketHost(afs_uint32 ahost, short aport);
|
||||||
extern struct interfaceAddr afs_cb_interface;
|
extern struct interfaceAddr afs_cb_interface;
|
||||||
|
|
||||||
rxk_ports_t rxk_ports;
|
rxk_ports_t rxk_ports;
|
||||||
@ -105,9 +105,9 @@ rxk_shutdownPorts(void)
|
|||||||
osi_socket
|
osi_socket
|
||||||
rxi_GetHostUDPSocket(u_int host, u_short port)
|
rxi_GetHostUDPSocket(u_int host, u_short port)
|
||||||
{
|
{
|
||||||
struct osi_socket *sockp;
|
osi_socket *sockp;
|
||||||
sockp = (struct osi_socket *)rxk_NewSocketHost(host, port);
|
sockp = (osi_socket *)rxk_NewSocketHost(host, port);
|
||||||
if (sockp == (struct osi_socket *)0)
|
if (sockp == (osi_socket *)0)
|
||||||
return OSI_NULLSOCKET;
|
return OSI_NULLSOCKET;
|
||||||
rxk_AddPort(port, (char *)sockp);
|
rxk_AddPort(port, (char *)sockp);
|
||||||
return (osi_socket) sockp;
|
return (osi_socket) sockp;
|
||||||
@ -761,7 +761,7 @@ rxi_FindIfnet(afs_uint32 addr, afs_uint32 * maskp)
|
|||||||
/* rxk_NewSocket creates a new socket on the specified port. The port is
|
/* rxk_NewSocket creates a new socket on the specified port. The port is
|
||||||
* in network byte order.
|
* in network byte order.
|
||||||
*/
|
*/
|
||||||
struct osi_socket *
|
osi_socket *
|
||||||
rxk_NewSocketHost(afs_uint32 ahost, short aport)
|
rxk_NewSocketHost(afs_uint32 ahost, short aport)
|
||||||
{
|
{
|
||||||
register afs_int32 code;
|
register afs_int32 code;
|
||||||
@ -905,17 +905,17 @@ rxk_NewSocketHost(afs_uint32 ahost, short aport)
|
|||||||
#if defined(AFS_DARWIN_ENV) && defined(KERNEL_FUNNEL)
|
#if defined(AFS_DARWIN_ENV) && defined(KERNEL_FUNNEL)
|
||||||
thread_funnel_switch(NETWORK_FUNNEL, KERNEL_FUNNEL);
|
thread_funnel_switch(NETWORK_FUNNEL, KERNEL_FUNNEL);
|
||||||
#endif
|
#endif
|
||||||
return (struct osi_socket *)newSocket;
|
return (osi_socket *)newSocket;
|
||||||
|
|
||||||
bad:
|
bad:
|
||||||
AFS_GLOCK();
|
AFS_GLOCK();
|
||||||
#if defined(AFS_DARWIN_ENV) && defined(KERNEL_FUNNEL)
|
#if defined(AFS_DARWIN_ENV) && defined(KERNEL_FUNNEL)
|
||||||
thread_funnel_switch(NETWORK_FUNNEL, KERNEL_FUNNEL);
|
thread_funnel_switch(NETWORK_FUNNEL, KERNEL_FUNNEL);
|
||||||
#endif
|
#endif
|
||||||
return (struct osi_socket *)0;
|
return (osi_socket *)0;
|
||||||
}
|
}
|
||||||
|
|
||||||
struct osi_socket *
|
osi_socket *
|
||||||
rxk_NewSocket(short aport)
|
rxk_NewSocket(short aport)
|
||||||
{
|
{
|
||||||
return rxk_NewSocketHost(0, aport);
|
return rxk_NewSocketHost(0, aport);
|
||||||
|
@ -335,7 +335,7 @@ extern int rxi_GetIFInfo(void);
|
|||||||
extern int rxk_FreeSocket(register struct socket *asocket);
|
extern int rxk_FreeSocket(register struct socket *asocket);
|
||||||
#endif
|
#endif
|
||||||
#ifndef AFS_NT40_ENV
|
#ifndef AFS_NT40_ENV
|
||||||
extern struct osi_socket *rxk_NewSocket(short aport);
|
extern osi_socket *rxk_NewSocket(short aport);
|
||||||
#endif
|
#endif
|
||||||
#endif
|
#endif
|
||||||
extern int rxk_ReadPacket(osi_socket so, struct rx_packet *p, int *host,
|
extern int rxk_ReadPacket(osi_socket so, struct rx_packet *p, int *host,
|
||||||
|
Loading…
x
Reference in New Issue
Block a user