00001
00002
00003
00004
00005
00006
00007
00008
00009
00010
00011
00012
00013
00014
00015
00016
00017
00018
00019
00020 #ifndef __STREAMMANAGER_H_
00021 #define __STREAMMANAGER_H_
00022
00023 #include "RioTCP.h"
00024
00025 #ifndef WINDOWS
00026
00027 #include <sys/time.h>
00028 #endif
00029
00030
00031 class CStreamManager
00032 {
00033 public:
00034 CStreamManager(CRioTCP* TCPconnection);
00035 ~CStreamManager();
00036 HRESULT Close( const RioStreamId Stream);
00037 HRESULT OpenObject( const RioStreamId Stream,
00038 const char* ObjectName,
00039 const RioAccess Access,
00040 ObjectHandle *Handle);
00041 HRESULT MaxRequests(RioStreamId Stream );
00042 #ifdef WINDOWS
00043 HRESULT OpenObject( const RioStreamId Stream,
00044 const char* ObjectName,
00045 const RioAccess Access,
00046 struct _SYSTEMTIME RTT_average,
00047 int BufferSize,
00048 ObjectHandle *Handle,
00049 RioObjectSize *Size,
00050 int *m_PID);
00051 #else
00052 HRESULT OpenObject( const RioStreamId Stream,
00053 const char* ObjectName,
00054 const RioAccess Access,
00055 struct timeval RTT_average,
00056 int BufferSize,
00057 ObjectHandle *Handle,
00058 RioObjectSize *Size,
00059 int *m_FlagRequests,
00060 int *m_PID);
00061 #endif
00062
00063 HRESULT CanStart( const RioStreamId Stream );
00064 private:
00065 CRioTCP* m_TCPconnection;
00066 };
00067
00068 #endif // __STREAMMANAGER_H_