| /* ------------------------------------------------------------------ |
| * Copyright (C) 1998-2009 PacketVideo |
| * |
| * Licensed under the Apache License, Version 2.0 (the "License"); |
| * you may not use this file except in compliance with the License. |
| * You may obtain a copy of the License at |
| * |
| * http://www.apache.org/licenses/LICENSE-2.0 |
| * |
| * Unless required by applicable law or agreed to in writing, software |
| * distributed under the License is distributed on an "AS IS" BASIS, |
| * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either |
| * express or implied. |
| * See the License for the specific language governing permissions |
| * and limitations under the License. |
| * ------------------------------------------------------------------- |
| */ |
| #ifndef TEST_BASE_H_INCLUDED |
| #include "test_base.h" |
| #endif |
| |
| #ifndef PV_LOGGER_IMPL_H_INCLUDED |
| #include "pv_logger_impl.h" |
| #endif |
| |
| |
| #if defined(__linux__) || defined(linux) |
| #define CONFIG_FILE_PATH _STRLIT("../../../pvlogger/config/") |
| #endif |
| |
| #define LOG_FILE_NAME _STRLIT("pvlog.txt") |
| |
| void test_base::H324MConfigCommandCompletedL(PVMFCmdResp& aResponse) |
| { |
| OSCL_UNUSED_ARG(aResponse); |
| } |
| |
| void test_base::H324MConfigHandleInformationalEventL(PVMFAsyncEvent& aNotification) |
| { |
| OSCL_UNUSED_ARG(aNotification); |
| } |
| |
| void test_base::CreateH324Component(bool aCreateH324) |
| { |
| OSCL_UNUSED_ARG(aCreateH324); |
| |
| |
| // get TSC node |
| iQueryInterfaceCmdId = terminal->QueryInterface(PVH324MConfigUuid, iTempH324MConfigIterface); |
| |
| } |
| |
| void test_base::QueryInterfaceSucceeded() |
| { |
| if (iH324MConfig) |
| { |
| iH324MConfig->SetObserver(this); |
| |
| { |
| PVInterface *componentInterface; |
| |
| iH324MConfig->queryInterface(PVUuidH324ComponentInterface, (PVInterface*&)componentInterface); |
| } |
| } |
| // now we have created the component, we can do init. |
| Init(); |
| } |
| |
| bool test_base::Init() |
| { |
| int32 error = 0; |
| OSCL_FastString aStr; |
| |
| // Clear formats from prev call if any |
| iSdkInitInfo.iIncomingAudioFormats.clear(); |
| iSdkInitInfo.iOutgoingAudioFormats.clear(); |
| iSdkInitInfo.iIncomingVideoFormats.clear(); |
| iSdkInitInfo.iOutgoingVideoFormats.clear(); |
| |
| |
| iSdkInitInfo.iIncomingAudioFormats.push_back(iAudSinkFormatType.getMIMEStrPtr()); |
| |
| iSdkInitInfo.iOutgoingAudioFormats.push_back(iAudSrcFormatType.getMIMEStrPtr()); |
| |
| iSdkInitInfo.iIncomingVideoFormats.push_back(iVidSinkFormatType.getMIMEStrPtr()); |
| |
| iSdkInitInfo.iOutgoingVideoFormats.push_back(iVidSrcFormatType.getMIMEStrPtr()); |
| |
| |
| OSCL_TRY(error, iInitCmdId = terminal->Init(iSdkInitInfo)); |
| if (error) |
| { |
| test_is_true(false); |
| |
| if (iUseProxy) |
| { |
| CPV2WayProxyFactory::DeleteTerminal(terminal); |
| } |
| else |
| { |
| CPV2WayEngineFactory::DeleteTerminal(terminal); |
| } |
| |
| terminal = NULL; |
| return false; |
| } |
| return true; |
| } |
| |
| |
| void test_base::InitSucceeded() |
| { |
| connect(); |
| } |
| |
| void test_base::InitFailed() |
| { |
| timer->Cancel(); |
| RunIfNotReady(); |
| } |
| void test_base::InitCancelled() |
| { |
| InitFailed(); |
| } |
| void test_base::EncoderIFSucceeded() |
| { |
| } |
| |
| void test_base::EncoderIFFailed() |
| { |
| } |
| |
| void test_base::ConnectSucceeded() |
| { |
| disconnect(); |
| } |
| |
| void test_base::ConnectFailed() |
| { |
| test_is_true(false); |
| reset(); |
| } |
| |
| void test_base::ConnectCancelled() |
| { |
| ConnectFailed(); |
| } |
| |
| void test_base::CancelCmdCompleted() |
| { |
| test_is_true(true); |
| RunIfNotReady(); |
| } |
| |
| void test_base::RstCmdCompleted() |
| { |
| destroy_sink_source(); |
| RunIfNotReady(); |
| } |
| |
| void test_base::DisCmdSucceeded() |
| { |
| reset(); |
| } |
| |
| void test_base::DisCmdFailed() |
| { |
| reset(); |
| } |
| |
| void test_base::AudioAddSinkCompleted() |
| { |
| iAudioSinkAdded = true; |
| if (iAudioSourceAdded) |
| timer->RunIfNotReady(TEST_DURATION); |
| } |
| |
| void test_base::AudioAddSourceCompleted() |
| { |
| iAudioSourceAdded = true; |
| if (iAudioSinkAdded) |
| timer->RunIfNotReady(TEST_DURATION); |
| } |
| |
| void test_base::AudioRemoveSourceCompleted() |
| { |
| iAudioSourceAdded = false; |
| if (!iAudioSinkAdded) |
| disconnect(); |
| } |
| |
| void test_base::AudioRemoveSinkCompleted() |
| { |
| iAudioSinkAdded = false; |
| if (!iAudioSourceAdded) |
| disconnect(); |
| } |
| |
| void test_base::VideoAddSinkSucceeded() |
| { |
| } |
| void test_base::VideoAddSinkFailed() |
| { |
| test_is_true(false); |
| disconnect(); |
| } |
| void test_base::VideoAddSourceSucceeded() |
| { |
| } |
| void test_base::VideoAddSourceFailed() |
| { |
| } |
| void test_base::VideoRemoveSourceCompleted() |
| { |
| int error = 0; |
| iVideoSourceAdded = false; |
| if (iSelVideoSink != NULL) |
| { |
| OSCL_TRY(error, iVideoRemoveSinkId = terminal->RemoveDataSink(*iSelVideoSink)); |
| } |
| if (error) |
| { |
| test_is_true(false); |
| disconnect(); |
| } |
| } |
| void test_base::VideoRemoveSinkCompleted() |
| { |
| iVideoSinkAdded = false; |
| if (!iVideoSourceAdded) |
| disconnect(); |
| } |
| |
| |
| void test_base::CommandCompleted(const PVCmdResponse& aResponse) |
| { |
| PVCommandId cmdId = aResponse.GetCmdId(); |
| iTestStatus &= (aResponse.GetCmdStatus() == PVMFSuccess) ? true : false; |
| |
| if (iQueryInterfaceCmdId == cmdId) |
| { |
| if (aResponse.GetCmdStatus() == PVMFSuccess) |
| { |
| if (iTempH324MConfigIterface) |
| { |
| iH324MConfig = OSCL_STATIC_CAST(H324MConfigInterface*, iTempH324MConfigIterface); |
| iTempH324MConfigIterface = NULL; |
| QueryInterfaceSucceeded(); |
| } |
| |
| } |
| } |
| else if (iInitCmdId == cmdId) |
| { |
| if (aResponse.GetCmdStatus() == PVMFSuccess) |
| { |
| InitSucceeded(); |
| } |
| else if (aResponse.GetCmdStatus() == PVMFErrCancelled) |
| { |
| InitCancelled(); |
| } |
| else |
| { |
| InitFailed(); |
| } |
| } |
| else if (iEncoderIFCommandId == cmdId) |
| { |
| if (aResponse.GetCmdStatus() != PVMFSuccess) |
| { |
| EncoderIFFailed(); |
| } |
| else |
| { |
| EncoderIFSucceeded(); |
| } |
| } |
| else if (iConnectCmdId == cmdId) |
| { |
| if (aResponse.GetCmdStatus() == PVMFSuccess) |
| { |
| ConnectSucceeded(); |
| } |
| else if (aResponse.GetCmdStatus() == PVMFErrCancelled) |
| { |
| ConnectCancelled(); |
| } |
| else |
| { |
| ConnectFailed(); |
| } |
| } |
| else if (iDisCmdId == cmdId) |
| { |
| if (aResponse.GetCmdStatus() != PVMFSuccess) |
| { |
| DisCmdFailed(); |
| } |
| else |
| { |
| DisCmdSucceeded(); |
| } |
| } |
| else if (iRstCmdId == cmdId) |
| { |
| RstCmdCompleted(); |
| } |
| else if (iAudioAddSinkId == cmdId) |
| { |
| AudioAddSinkCompleted(); |
| } |
| else if (iAudioAddSourceId == cmdId) |
| { |
| AudioAddSourceCompleted(); |
| } |
| else if (iAudioRemoveSourceId == cmdId) |
| { |
| AudioRemoveSourceCompleted(); |
| } |
| else if (iAudioRemoveSinkId == cmdId) |
| { |
| AudioRemoveSinkCompleted(); |
| } |
| else if (iVideoAddSinkId == cmdId) |
| { |
| if (aResponse.GetCmdStatus() == PVMFSuccess) |
| { |
| VideoAddSinkSucceeded(); |
| } |
| else |
| { |
| VideoAddSinkFailed(); |
| } |
| } |
| else if (iVideoAddSourceId == cmdId) |
| { |
| if (aResponse.GetCmdStatus() == PVMFSuccess) |
| { |
| VideoAddSourceSucceeded(); |
| } |
| else |
| { |
| VideoAddSourceFailed(); |
| } |
| } |
| else if (iVideoRemoveSourceId == cmdId) |
| { |
| VideoRemoveSourceCompleted(); |
| } |
| else if (iVideoRemoveSinkId == cmdId) |
| { |
| VideoRemoveSinkCompleted(); |
| } |
| else if (iCancelCmdId == cmdId) |
| { |
| CancelCmdCompleted(); |
| } |
| } |
| |
| |
| void test_base::InitializeLogs() |
| { |
| uint32 error = 0; |
| PVLoggerConfigFile obj; |
| obj.SetConfigFilePath(CONFIG_FILE_PATH); |
| error = 0; |
| if (obj.IsLoggerConfigFilePresent()) |
| { |
| error = obj.SetLoggerSettings(terminal, LOG_FILE_NAME); |
| if (0 != error) |
| { |
| printf("Error Occured in PVLoggerConfigFile::SetLoggerSettings() \n"); |
| } |
| else |
| { |
| //sucess able to set logger settings |
| return; |
| } |
| } |
| |
| PVLoggerAppender *lLoggerAppender = 0; |
| OsclRefCounter *refCounter = NULL; |
| bool logfile = true; |
| if (logfile) |
| { |
| //File Log |
| const uint32 TEXT_FILE_APPENDER_CACHE_SIZE = 1024; |
| lLoggerAppender = TextFileAppender<TimeAndIdLayout, 1024>::CreateAppender(LOG_FILE_NAME, |
| TEXT_FILE_APPENDER_CACHE_SIZE); |
| OsclRefCounter *appenderRefCounter = new OsclRefCounterSA<AppenderDestructDealloc<TextFileAppender<TimeAndIdLayout, 1024> > >(lLoggerAppender); |
| refCounter = appenderRefCounter; |
| } |
| else |
| { |
| //Console Log |
| lLoggerAppender = new StdErrAppender<TimeAndIdLayout, 1024>(); |
| OsclRefCounter *appenderRefCounter = new OsclRefCounterSA<AppenderDestructDealloc<StdErrAppender<TimeAndIdLayout, 1024> > >(lLoggerAppender); |
| refCounter = appenderRefCounter; |
| } |
| OsclSharedPtr<PVLoggerAppender> appenderPtr(lLoggerAppender, refCounter); |
| terminal->SetLogLevel("", PVLOGMSG_DEBUG, true); |
| terminal->SetLogAppender("", appenderPtr); |
| |
| } |
| |
| bool test_base::start_async_test() |
| { |
| int error = 0; |
| if (iUseProxy) |
| { |
| OSCL_TRY(error, terminal = CPV2WayProxyFactory::CreateTerminal(PV_324M, |
| (PVCommandStatusObserver *) this, |
| (PVInformationalEventObserver *) this, |
| (PVErrorEventObserver *) this)); |
| } |
| else |
| { |
| OSCL_TRY(error, terminal = CPV2WayEngineFactory::CreateTerminal(iSIP ? PV_SIP : PV_324M, |
| (PVCommandStatusObserver *) this, |
| (PVInformationalEventObserver *) this, |
| (PVErrorEventObserver *) this)); |
| } |
| |
| if (error) |
| { |
| test_is_true(false); |
| return false; |
| } |
| |
| InitializeLogs(); |
| |
| create_sink_source(); |
| iInitCmdId = -1; |
| iQueryInterfaceCmdId = -1; |
| CreateH324Component(); |
| return true; |
| } |
| |
