// === PROTOTYPES ===
void TCP_Initialise();
void TCP_StartConnection(tTCPConnection *Conn);
+void TCP_SendPacket( tTCPConnection *Conn, size_t Length, tTCPHeader *Data );
void TCP_GetPacket(tInterface *Interface, void *Address, int Length, void *Buffer);
void TCP_INT_HandleConnectionPacket(tTCPConnection *Connection, tTCPHeader *Header);
Uint16 TCP_GetUnusedPort();
void TCP_StartConnection(tTCPConnection *Conn)
{
tTCPHeader hdr;
-
- hdr->SourcePort = Conn->LocalPort;
- hdr->DestPort = Conn->RemotePort;
- hdr->SequenceNumber = rand();
- hdr->DataOffset = (sizeof(tTCPHeader)+3)/4;
- hdr->Flags = TCP_FLAG_SYN;
+
+ hdr.SourcePort = Conn->LocalPort;
+ hdr.DestPort = Conn->RemotePort;
+ Conn->NextSequenceSend = rand();
+ hdr.SequenceNumber = Conn->NextSequenceSend;
+ hdr.DataOffset = (sizeof(tTCPHeader)+3)/4;
+ hdr.Flags = TCP_FLAG_SYN;
+ hdr.WindowSize = 0; // TODO
+ hdr.Checksum = 0; // TODO
+ hdr.UrgentPointer = 0;
// SEND PACKET
- // Send a TCP SYN to the target to open the connection
+ TCP_SendPacket( Conn, sizeof(tTCPHeader), &hdr );
return ;
}
+/**
+ * \brief Sends a packet from the specified connection, calculating the checksums
+ * \param Conn Connection
+ * \param Length Length of data
+ * \param Data Packet data
+ */
+void TCP_SendPacket( tTCPConnection *Conn, size_t Length, tTCPHeader *Data )
+{
+ size_t buflen;
+ Uint32 *buf;
+ switch( Conn->Interface->Type )
+ {
+ case 4: // Append IPv4 Pseudo Header
+ buflen = 4 + 4 + 4 + ((Length+1)&1);
+ buf = malloc( buflen );
+ buf[0] = Conn->Interface->IP4.Address.L;
+ buf[1] = Conn->RemoteIP.v4.L;
+ buf[2] = (htons(Length)<<16) | (6<<8) | 0;
+ Data->Checksum = 0;
+ memcpy( &buf[3], Data, Length );
+ Data->Checksum = IPv4_Checksum( buf, buflen );
+ free(buf);
+ IPv4_SendPacket(Conn->Interface, Conn->RemoteIP.v4, IP4PROT_TCP, 0, buflen, buf);
+ break;
+ }
+}
+
/**
* \fn void TCP_GetPacket(tInterface *Interface, void *Address, int Length, void *Buffer)
* \brief Handles a packet from the IP Layer
tTCPHeader *hdr = Buffer;
tTCPListener *srv;
tTCPConnection *conn;
-
+
Log("[TCP ] sizeof(tTCPHeader) = %i", sizeof(tTCPHeader));
Log("[TCP ] DestPort = %i", ntohs(hdr->DestPort));
Log("[TCP ] DestPort = %i", ntohs(hdr->DestPort));
Log("[TCP ] WindowSize = %i", htons(hdr->WindowSize));
Log("[TCP ] Checksum = 0x%x", htons(hdr->Checksum));
Log("[TCP ] UrgentPointer = 0x%x", htons(hdr->UrgentPointer));
-
+
// Check Servers
{
for( srv = gTCP_Listeners; srv; srv = srv->Next )
if(srv->Interface && srv->Interface != Interface) continue;
// Check the destination port
if(srv->Port != hdr->DestPort) continue;
-
+
// Is this in an established connection?
for( conn = srv->Connections; conn; conn = conn->Next )
{
// Check that it is coming in on the same interface
if(conn->Interface != Interface) continue;
-
+
// Check Source Port
if(conn->RemotePort != hdr->SourcePort) continue;
-
+
// Check Source IP
if(conn->Interface->Type == 6 && !IP6_EQU(conn->RemoteIP.v6, *(tIPv6*)Address))
continue;
if(conn->Interface->Type == 4 && !IP4_EQU(conn->RemoteIP.v4, *(tIPv4*)Address))
continue;
-
+
// We have a response!
- TCP_INT_HandleConnectionPacket(conn, hdr)
-
+ TCP_INT_HandleConnectionPacket(conn, hdr);
+
return;
}
-
+
// Open a new connection (well, check that it's a SYN)
//TODO
-
+
break;
}
}
-
-
+
+
// Check Open Connections
{
for( conn = gTCP_OutbountCons; conn; conn = conn->Next )
{
// Check that it is coming in on the same interface
if(conn->Interface != Interface) continue;
-
+
// Check Source Port
if(conn->RemotePort != hdr->SourcePort) continue;
-
+
// Check Source IP
if(conn->Interface->Type == 6 && !IP6_EQU(conn->RemoteIP.v6, *(tIPv6*)Address))
continue;
if(conn->Interface->Type == 4 && !IP4_EQU(conn->RemoteIP.v4, *(tIPv4*)Address))
continue;
-
- TCP_INT_HandleConnectionPacket(conn, hdr)
+
+ TCP_INT_HandleConnectionPacket(conn, hdr);
}
}
}
*/
void TCP_INT_HandleConnectionPacket(tTCPConnection *Connection, tTCPHeader *Header)
{
-
+
}
/**
Uint16 TCP_GetUnusedPort()
{
Uint16 ret;
-
+
// Get Next outbound port
ret = giTCP_NextOutPort++;
while( gaTCP_PortBitmap[ret/32] & (1 << (ret%32)) )
ret = giTCP_NextOutPort = TCP_MIN_DYNPORT;
}
}
-
+
// Mark the new port as used
gaTCP_PortBitmap[ret/32] |= 1 << (ret%32);
-
+
return ret;
}
// Check if the port has already been allocated
if( gaTCP_PortBitmap[Port/32] & (1 << (Port%32)) )
return 0;
-
+
// Allocate
gaTCP_PortBitmap[Port/32] |= 1 << (Port%32);
-
+
return 1;
}
// Check if the port has already been allocated
if( !(gaTCP_PortBitmap[Port/32] & (1 << (Port%32))) )
return 0;
-
+
// Allocate
gaTCP_PortBitmap[Port/32] &= ~(1 << (Port%32));
-
+
return 1;
}
tVFS_Node *TCP_Server_Init(tInterface *Interface)
{
tTCPListener *srv = malloc( sizeof(tTCPListener) );
-
+
srv->Interface = Interface;
srv->Port = 0;
srv->NextID = 0;
srv->Node.FindDir = TCP_Server_FindDir;
srv->Node.IOCtl = TCP_Server_IOCtl;
srv->Node.Close = TCP_Server_Close;
-
+
LOCK(&glTCP_Listeners);
srv->Next = gTCP_Listeners;
gTCP_Listeners = srv;
RELEASE(&glTCP_Listeners);
-
+
return &srv->Node;
}
tTCPListener *srv = Node->ImplPtr;
tTCPConnection *conn;
char *ret;
-
+
while( srv->NewConnections == NULL ) Threads_Yield();
-
+
conn = srv->NewConnections;
srv->NewConnections = conn->Next;
-
+
ret = malloc(9);
- itoa(ret, conn->ImplInt, 16, '0', 8);
+ itoa(ret, Node->ImplInt, 16, '0', 8);
return ret;
}
int TCP_Server_IOCtl(tVFS_Node *Node, int ID, void *Data)
{
tTCPListener *srv = Node->ImplPtr;
-
+
switch(ID)
{
case 4: // Get/Set Port
if(!Data) // Get Port
return srv->Port;
-
+
if(srv->Port) // Wait, you can't CHANGE the port
return -1;
-
+
if(!CheckMem(Data, sizeof(Uint16))) // Sanity check
return -1;
-
+
// Permissions check
if(Threads_GetUID() != 0
&& *(Uint16*)Data != 0
&& *(Uint16*)Data < 1024)
return -1;
-
+
// TODO: Check if a port is in use
-
+
// Set Port
srv->Port = *(Uint16*)Data;
if(srv->Port == 0) // Allocate a random port
tVFS_Node *TCP_Client_Init(tInterface *Interface)
{
tTCPConnection *conn = malloc( sizeof(tTCPConnection) );
-
+
conn->State = TCP_ST_CLOSED;
conn->Interface = Interface;
conn->LocalPort = 0;
conn->RemotePort = 0;
memset( &conn->RemoteIP, 0, sizeof(conn->RemoteIP) );
-
+
conn->Node.ImplPtr = conn;
conn->Node.NumACLs = 1;
conn->Node.ACLs = &gVFS_ACL_EveryoneRW;
conn->Node.Write = TCP_Client_Write;
conn->Node.IOCtl = TCP_Client_IOCtl;
conn->Node.Close = TCP_Client_Close;
-
+
LOCK(&glTCP_OutbountCons);
conn->Next = gTCP_OutbountCons;
gTCP_OutbountCons = conn;
RELEASE(&glTCP_OutbountCons);
-
+
return &conn->Node;
}
return 0;
}
+/**
+ * \brief Control a client socket
+ */
int TCP_Client_IOCtl(tVFS_Node *Node, int ID, void *Data)
{
tTCPConnection *conn = Node->ImplPtr;
-
+
switch(ID)
{
case 4: // Get/Set local port
return -1;
if(!CheckMem(Data, sizeof(Uint16)))
return -1;
-
+
if(Threads_GetUID() != 0 && *(Uint16*)Data < 1024)
return -1;
-
+
conn->LocalPort = *(Uint16*)Data;
return 0;
-
+
case 5: // Get/Set remote port
if(!Data) return conn->RemotePort;
if(conn->State != TCP_ST_CLOSED) return -1;
if(!CheckMem(Data, sizeof(Uint16))) return -1;
conn->RemotePort = *(Uint16*)Data;
return 0;
-
+
case 6: // Set Remote IP
if( conn->State != TCP_ST_CLOSED )
return -1;
conn->RemoteIP.v6 = *(tIPv6*)Data;
}
return 0;
-
+
case 7: // Connect
if(conn->LocalPort == -1)
conn->LocalPort = TCP_GetUnusedPort();
if(conn->RemotePort == -1)
return 0;
-
+
TCP_StartConnection(conn);
return 1;
}
-
+
return 0;
}
git.ucc.asn.au / tpg / acess2.git / blobdiff
UCC git Repository :: git.ucc.asn.au