• Main Page
  • Related Pages
  • Modules
  • Namespaces
  • Classes
  • Files
  • File List
  • File Members

spl/net/UdpServer.h

00001 /*
00002  *   This file is part of the Standard Portable Library (SPL).
00003  *
00004  *   SPL is free software: you can redistribute it and/or modify
00005  *   it under the terms of the GNU General Public License as published by
00006  *   the Free Software Foundation, either version 3 of the License, or
00007  *   (at your option) any later version.
00008  *
00009  *   SPL is distributed in the hope that it will be useful,
00010  *   but WITHOUT ANY WARRANTY; without even the implied warranty of
00011  *   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
00012  *   GNU General Public License for more details.
00013  *
00014  *   You should have received a copy of the GNU General Public License
00015  *   along with SPL.  If not, see <http://www.gnu.org/licenses/>.
00016  */
00017 #ifndef _udpserver_h
00018 #define _udpserver_h
00019 
00020 #include <spl/Memory.h>
00021 #include <spl/collection/Array.h>
00022 #include <spl/Delegate.h>
00023 #include <spl/threading/ThreadStartDelegate.h>
00024 #include <spl/net/UdpSocket.h>
00025 #include <spl/threading/Thread.h>
00026 
00027 class UdpServer;
00028 typedef RefCountPtr<UdpServer> UdpServerPtr;
00029 typedef WeakReference<UdpServer, UdpServerPtr> UdpServerRef;
00030 
00035 class UdpServer : public IMemoryValidate
00036 {
00037 private:
00038         inline UdpServer(const UdpServer& s) : m_sock(0) {}
00039         inline UdpServer& operator =(const UdpServer& s) {}
00040 
00041         void Run();
00042         
00043 protected:
00044         ThreadStartDelegate<UdpServer> m_thread;
00045         UdpSocket m_sock;
00046         RefCountPtr<IDelegateThreeParameter<UdpSocket&, Array<byte>&, int> > m_callback;
00047         volatile bool m_running;
00048         int m_bufSize;
00049         
00050 public:
00051         UdpServer(int port, RefCountPtr<IDelegateThreeParameter<UdpSocket&, Array<byte>&, int> > callback, int bufferSize = 512);
00052         virtual ~UdpServer();
00053         
00054         void Close();
00055         
00056         void Join();
00057         
00058 #if defined(DEBUG) || defined(_DEBUG)
00059         virtual void CheckMem() const;
00060         virtual void ValidateMem() const;
00061 #endif
00062 };
00063 
00064 #endif