www.pudn.com > helix.src.0812.rar > audio_svr_cntxt.cpp

/* ***** BEGIN LICENSE BLOCK *****  
 * Version: RCSL 1.0/RPSL 1.0  
 *   
 * Portions Copyright (c) 1995-2003 RealNetworks, Inc. All Rights Reserved.  
 *       
 * The contents of this file, and the files included with this file, are  
 * subject to the current version of the RealNetworks Public Source License  
 * Version 1.0 (the "RPSL") available at  
 * http://www.helixcommunity.org/content/rpsl unless you have licensed  
 * the file under the RealNetworks Community Source License Version 1.0  
 * (the "RCSL") available at http://www.helixcommunity.org/content/rcsl,  
 * in which case the RCSL will apply. You may also obtain the license terms  
 * directly from RealNetworks.  You may not use this file except in  
 * compliance with the RPSL or, if you have a valid RCSL with RealNetworks  
 * applicable to this file, the RCSL.  Please see the applicable RPSL or  
 * RCSL for the rights, obligations and limitations governing use of the  
 * contents of the file.   
 *   
 * This file is part of the Helix DNA Technology. RealNetworks is the  
 * developer of the Original Code and owns the copyrights in the portions  
 * it created.  
 *   
 * This file, and the files included with this file, is distributed and made  
 * available on an 'AS IS' basis, WITHOUT WARRANTY OF ANY KIND, EITHER  
 * EXPRESS OR IMPLIED, AND REALNETWORKS HEREBY DISCLAIMS ALL SUCH WARRANTIES,  
 * INCLUDING WITHOUT LIMITATION, ANY WARRANTIES OF MERCHANTABILITY, FITNESS  
 * FOR A PARTICULAR PURPOSE, QUIET ENJOYMENT OR NON-INFRINGEMENT.  
 *  
 * Technology Compatibility Kit Test Suite(s) Location:  
 *    http://www.helixcommunity.org/content/tck  
 *  
 * Contributor(s):  
 *   
 * ***** END LICENSE BLOCK ***** */  
  
/* 
 *  Description:  
 * 
 *  This file contains the implimentation of the HXSymbianAudioServerContext 
 *  class. This class specialized bsThread and provides an exection 
 *  context for the Audio Server. 
 * 
 */ 
#include "hlxclib/stdlib.h" 
#include "audio_svr_cntxt.h" 
#include "audio_svr.h" 
 
 
_LIT(kHXSymbianAudioServer, "HelixAudioServer"); 
static const TInt kDefaultStack = 0x4000; 
 
// 
// HXSymbianAudioServerContext::ctor 
//  
HXSymbianAudioServerContext::HXSymbianAudioServerContext() 
    : m_pServer(0), 
      m_running(false), 
      m_handleOpen(false) 
{} 
 
// 
// HXSymbianAudioServerContext::dtor 
// 
HXSymbianAudioServerContext::~HXSymbianAudioServerContext() 
{ 
				// make sure server is stopped 
    Stop(); 
 
    m_handle.Close(); 
    m_startSem.Close(); 
} 
 
 
 
// 
// HXSymbianAudioServerContext::Start 
// 
// This call wraps the normal thread startup call (Run()) in order to 
// wait on a startup semaphore. This ensures the server thread is  
// fully started before the calling thread proceeds. 
// 
void HXSymbianAudioServerContext::Start() 
{ 
    if (!m_running) 
    { 
	m_startSem.CreateLocal(0); 
	this->Run(); 
	m_startSem.Wait(); 
    } 
} 
 
// 
// HXSymbianAudioServerContext::Stop 
// 
//  
// 
void HXSymbianAudioServerContext::Stop() 
{ 
    if (m_running) 
    { 
	m_startSem.Wait(); 
	m_running = false; 
    } 
} 
 
bool HXSymbianAudioServerContext::Running() 
{ 
    return m_running; 
} 
 
TInt HXSymbianAudioServerContext::Run() 
{ 
    if (!m_running) 
    { 
	// close handle if previously opened 
	if (m_handleOpen) 
	    m_handle.Close(); 
 
	if (KErrNone == m_handle.Create(kHXSymbianAudioServer, 
					HXSymbianAudioServerContext::_Main, 
					kDefaultStack,  
					NULL, this, EOwnerThread)) 
	{ 
	    m_handleOpen = true; 
	    m_handle.Resume(); 
	    m_running = true; 
	} 
    } 
 
    return m_running ? KErrNone : KErrGeneral; 
} 
 
// 
// HXSymbianAudioServerContext::Main 
// 
// This is the entry point for the new execution context. The call to 
// StartServerL() blocks until the server shuts down. 
// 
void* HXSymbianAudioServerContext::Main() 
{ 
    TRAPD(leaveCode, StartServerL()); 
 
    if (leaveCode != KErrNone) 
    { 
	User::Panic(_L("HXSymbianAudioServerContext"), leaveCode); 
    } 
 
    return (void*)0; 
}     
 
// 
// HXSymbianAudioServerContext::StartServerL 
//  
// Create and start the server object and active scheduler. This call 
// runs within the new execution context. 
// 
void HXSymbianAudioServerContext::StartServerL() 
{ 
    HBufC* pName = HXSymbianAudioServer::AllocServerName(); 
 
    if (pName) 
    { 
	m_pServer = new HXSymbianAudioServer; 
 
	m_pServer->StartL(*pName); 
 
	// signal waiter that server has started 
	m_startSem.Signal(); 
 
	CActiveScheduler::Start(); 
     
	delete pName; 
    } 
 
    // signal waiter that server has exited 
    m_startSem.Signal(); 
 
    delete m_pServer; 
    m_pServer = 0; 
} 
 
TInt HXSymbianAudioServerContext::_Main (TAny* obj) 
{ 
    void* pstatus = 0; 
    HXSymbianAudioServerContext* impl = (HXSymbianAudioServerContext*)obj; 
 
    // increase the priority of the audio thread 
    RThread().SetPriority(EPriorityMore); 
 
    // allocate a cleanup trap for use on this thread 
    CTrapCleanup* pCleanupTrap = CTrapCleanup::New(); 
 
    // install active scheduler 
    CActiveScheduler::Install(new CActiveScheduler); 
 
    pstatus = impl->Main(); 
 
    // fall out of main body 
    // 
    delete CActiveScheduler::Current(); 
    delete pCleanupTrap; 
 
    // clean up memory allocated by stdlib functions 
    CloseSTDLIB(); 
 
    // reset thread members in case this thread is restarted 
    impl->m_running = false; 
 
    return ((TInt)pstatus); 
}