}
NTSTATUS TCPTranslateError( int OskitError ) {
- NTSTATUS Status = STATUS_UNSUCCESSFUL;
+ NTSTATUS Status;
switch( OskitError ) {
case 0: Status = STATUS_SUCCESS; break;
case OSK_ECONNRESET: Status = STATUS_REMOTE_NOT_LISTENING; break;
case OSK_EINPROGRESS:
case OSK_EAGAIN: Status = STATUS_PENDING; break;
- default: Status = STATUS_INVALID_CONNECTION; break;
+ default:
+ DbgPrint("OskitTCP returned unhandled error code: %d\n", OskitError);
+ Status = STATUS_INVALID_CONNECTION;
+ break;
}
TI_DbgPrint(DEBUG_TCP,("Error %d -> %x\n", OskitError, Status));
Status = TCPTranslateError
( OskitTCPBind( Connection->SocketContext,
- Connection,
&AddressToBind,
sizeof(AddressToBind) ) );
DrainSignals();
Status = TCPTranslateError( OskitTCPClose( Connection->SocketContext ) );
+ if (Status == STATUS_SUCCESS)
+ Connection->SocketContext = NULL;
TI_DbgPrint(DEBUG_TCP,("TCPClose finished %x\n", Status));
OSK_UINT LocalAddress, RemoteAddress;
OSK_UI16 LocalPort, RemotePort;
PTA_IP_ADDRESS AddressIP = (PTA_IP_ADDRESS)Address;
+ NTSTATUS Status;
ASSERT_LOCKED(&TCPLock);
- OskitTCPGetAddress
- ( Connection->SocketContext,
- &LocalAddress, &LocalPort,
- &RemoteAddress, &RemotePort );
+ Status = TCPTranslateError(OskitTCPGetAddress(Connection->SocketContext,
+ &LocalAddress, &LocalPort,
+ &RemoteAddress, &RemotePort));
+ if (!NT_SUCCESS(Status))
+ return Status;
AddressIP->TAAddressCount = 1;
AddressIP->Address[0].AddressLength = TDI_ADDRESS_LENGTH_IP;
AddressIP->Address[0].Address[0].sin_port = GetRemote ? RemotePort : LocalPort;
AddressIP->Address[0].Address[0].in_addr = GetRemote ? RemoteAddress : LocalAddress;
- return STATUS_SUCCESS;
+ return Status;
}
VOID TCPRemoveIRP( PCONNECTION_ENDPOINT Endpoint, PIRP Irp ) {
void RegisterOskitTCPEventHandlers( POSKITTCP_EVENT_HANDLERS EventHandlers ) {
memcpy( &OtcpEvent, EventHandlers, sizeof(OtcpEvent) );
- if( OtcpEvent.PacketSend )
- OS_DbgPrint(OSK_MID_TRACE,("SendPacket handler registered: %x\n",
- OtcpEvent.PacketSend));
}
void OskitDumpBuffer( OSK_PCHAR Data, OSK_UINT Len )
return error;
}
-int OskitTCPBind( void *socket, void *connection,
+int OskitTCPBind( void *socket,
void *nam, OSK_UINT namelen ) {
int error = EFAULT;
struct socket *so = socket;
OS_DbgPrint(OSK_MID_TRACE,("Called, socket = %08x\n", socket));
+ if (!socket)
+ return OSK_ESHUTDOWN;
+
if( nam )
addr = *((struct sockaddr *)nam);
}
int OskitTCPShutdown( void *socket, int disconn_type ) {
+ if (!socket)
+ return OSK_ESHUTDOWN;
+
return soshutdown( socket, disconn_type );
}
int OskitTCPClose( void *socket ) {
struct socket *so = socket;
+
+ if (!socket)
+ return OSK_ESHUTDOWN;
+
so->so_connection = 0;
soclose( so );
return 0;
struct uio uio;
struct iovec iov;
+ if (!socket)
+ return OSK_ESHUTDOWN;
+
iov.iov_len = Len;
iov.iov_base = (char *)Data;
uio.uio_iov = &iov;
struct inpcb *inp;
int namelen = 0, error = 0, s;
+ if (!socket)
+ return OSK_ESHUTDOWN;
+
+ if (!new_socket || !AddrOut)
+ return OSK_EINVAL;
+
OS_DbgPrint(OSK_MID_TRACE,("OSKITTCP: Doing accept (Finish %d)\n",
FinishAccepting));
{
struct mbuf *m;
+ if (!socket)
+ return OSK_ESHUTDOWN;
+
if (size >= MLEN)
return OSK_EINVAL;
int error, oldsize = *size;
struct mbuf *m;
+ if (!socket)
+ return OSK_ESHUTDOWN;
+
error = sogetopt(socket, level, optname, &m);
if (!error)
{
int OskitTCPListen( void *socket, int backlog ) {
int error;
+ if (!socket)
+ return OSK_ESHUTDOWN;
+
OS_DbgPrint(OSK_MID_TRACE,("Called, socket = %08x\n", socket));
error = solisten( socket, backlog );
OS_DbgPrint(OSK_MID_TRACE,("Ending: %08x\n", error));
return error;
}
-void OskitTCPSetAddress( void *socket,
+int OskitTCPSetAddress( void *socket,
OSK_UINT LocalAddress,
OSK_UI16 LocalPort,
OSK_UINT RemoteAddress,
OSK_UI16 RemotePort ) {
struct socket *so = socket;
- struct inpcb *inp = (struct inpcb *)so->so_pcb;
+ struct inpcb *inp;
+
+ if (!socket)
+ return OSK_ESHUTDOWN;
+
+ inp = (struct inpcb *)so->so_pcb;
inp->inp_laddr.s_addr = LocalAddress;
inp->inp_lport = LocalPort;
inp->inp_faddr.s_addr = RemoteAddress;
inp->inp_fport = RemotePort;
+
+ return 0;
}
-void OskitTCPGetAddress( void *socket,
+int OskitTCPGetAddress( void *socket,
OSK_UINT *LocalAddress,
OSK_UI16 *LocalPort,
OSK_UINT *RemoteAddress,
OSK_UI16 *RemotePort ) {
struct socket *so = socket;
- struct inpcb *inp = so ? (struct inpcb *)so->so_pcb : NULL;
- if( inp ) {
- *LocalAddress = inp->inp_laddr.s_addr;
- *LocalPort = inp->inp_lport;
- *RemoteAddress = inp->inp_faddr.s_addr;
- *RemotePort = inp->inp_fport;
- }
+ struct inpcb *inp;
+
+ if (!socket)
+ return OSK_ESHUTDOWN;
+
+ inp = (struct inpcb *)so->so_pcb;
+ *LocalAddress = inp->inp_laddr.s_addr;
+ *LocalPort = inp->inp_lport;
+ *RemoteAddress = inp->inp_faddr.s_addr;
+ *RemotePort = inp->inp_fport;
+
+ return 0;
}
struct ifaddr *ifa_iffind(struct sockaddr *addr, int type)