C:/knet/include/kNet/TCPMessageConnection.h
Go to the documentation of this file.
00001 /* Copyright 2010 Jukka Jylänki 00002 00003 Licensed under the Apache License, Version 2.0 (the "License"); 00004 you may not use this file except in compliance with the License. 00005 You may obtain a copy of the License at 00006 00007 http://www.apache.org/licenses/LICENSE-2.0 00008 00009 Unless required by applicable law or agreed to in writing, software 00010 distributed under the License is distributed on an "AS IS" BASIS, 00011 WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 00012 See the License for the specific language governing permissions and 00013 limitations under the License. */ 00014 #pragma once 00015 00019 #include "MessageConnection.h" 00020 #include "RingBuffer.h" 00021 00022 /* 00023 TCP stream format: 00024 .Message. 00025 .Message. 00026 ... 00027 .Message. 00028 00029 Message format: 00030 u8-u32 Whole Message length (including MessageID + ContentData, but not this field itself) VLE-encoded 1.7/1.7/16 00031 u8-u32 MessageID VLE-encoded 1.7/1.7/16 00032 N bytes Content data 00033 00034 */ 00035 00036 namespace kNet 00037 { 00038 00039 class TCPMessageConnection : public MessageConnection 00040 { 00041 public: 00042 TCPMessageConnection(Network *owner, NetworkServer *ownerServer, Socket *socket, ConnectionState startingState); 00043 00044 private: 00046 RingBuffer tcpInboundSocketData; 00047 00049 SocketReadResult ReadSocket(size_t &bytesRead); 00050 00051 PacketSendResult SendOutPacket(); 00052 void SendOutPackets(); 00053 00054 unsigned long TimeUntilCanSendPacket() const; 00055 00057 void ExtractMessages(); 00058 00059 // The following are temporary data structures used by various internal routines for processing. 00060 std::vector<NetworkMessage*> serializedMessages; // MessageConnection::TCPSendOutPacket() 00061 00062 void PerformDisconnection(); 00063 }; 00064 00065 } // ~kNet
