00001
00002
00003
00004
00005
00006
00007
00008
00009
00010
00011
00012
00013
00014
00015
00016
00017
00018 #ifndef __PLSTREAMMANAGER_H_
00019 #define __PLSTREAMMANAGER_H_
00020
00021 class PLStreamManager;
00022
00023 #include <stdio.h>
00024
00025
00026 #include <iostream>
00027 using namespace std;
00028
00029
00030 #include "RioInterface.h"
00031 #include "RioError.h"
00032 #include "DataConversion.h"
00033
00034
00035
00036 class PLStreamManager
00037 {
00038 public:
00039
00040
00041
00042 PLStreamManager( char *LogsDirectory );
00043 ~PLStreamManager();
00044
00045 HRESULT OpenStreamRioServer( RioStreamTraffic Traffic,
00046 unsigned int *ResultSize,
00047 CRioStream *StreamRioServer,
00048 CRioSession *SessionRioServer,
00049 int *maxrequests );
00050 HRESULT CloseStreamRioServer( unsigned int *ResultSize,
00051 CRioStream *StreamRioServer );
00052
00053 HRESULT Open( char* ObjectName,
00054 RioAccess Access,
00055 CRioStream *StreamRioServer,
00056 CRioObject *ObjectRioServer );
00057
00058 HRESULT OpenCAC( char* ObjectName,
00059 RioAccess Access,
00060 struct timeval average_RTT,
00061 int BufferSize,
00062 CRioStream *StreamRioServer,
00063 unsigned int* ResultSize,
00064 CRioObject *ObjectRioServer);
00065
00066 HRESULT CanStart( CRioStream *StreamRioServer,
00067 unsigned int* ResultSize );
00068 private:
00069 ofstream m_log;
00070 };
00071
00072 #endif //__PLSTREAMMANAGER_H_