VirtualBox

Changeset 50538 in vbox for trunk/src/VBox/Main


Ignore:
Timestamp:
Feb 21, 2014 12:12:46 PM (11 years ago)
Author:
vboxsync
Message:

Main/EventImpl.cpp: coding style cleanup

File:
1 edited

Legend:

Unmodified
Added
Removed
  • trunk/src/VBox/Main/src-all/EventImpl.cpp

    r48295 r50538  
    55
    66/*
    7  * Copyright (C) 2010-2012 Oracle Corporation
     7 * Copyright (C) 2010-2014 Oracle Corporation
    88 *
    99 * This file is part of VirtualBox Open Source Edition (OSE), as
     
    121121            if (RT_FAILURE(vrc))
    122122            {
    123                 AssertFailed ();
     123                AssertFailed();
    124124                return setError(E_FAIL,
    125125                                tr("Internal error (%Rrc)"), vrc);
     
    156156
    157157    AutoCaller autoCaller(this);
    158     if (FAILED(autoCaller.rc())) return autoCaller.rc();
    159 
    160     // never  changes till event alive, no locking?
     158    if (FAILED(autoCaller.rc()))
     159        return autoCaller.rc();
     160
     161    // never changes while event alive, no locking
    161162    *aType = m->mType;
    162163    return S_OK;
    163164}
    164165
    165 STDMETHODIMP VBoxEvent::COMGETTER(Source)(IEventSource* *aSource)
     166STDMETHODIMP VBoxEvent::COMGETTER(Source)(IEventSource **aSource)
    166167{
    167168    CheckComArgOutPointerValid(aSource);
    168169
    169170    AutoCaller autoCaller(this);
    170     if (FAILED(autoCaller.rc())) return autoCaller.rc();
     171    if (FAILED(autoCaller.rc()))
     172        return autoCaller.rc();
    171173
    172174    m->mSource.queryInterfaceTo(aSource);
     
    179181
    180182    AutoCaller autoCaller(this);
    181     if (FAILED(autoCaller.rc())) return autoCaller.rc();
    182 
    183     // never  changes till event alive, no locking?
     183    if (FAILED(autoCaller.rc()))
     184        return autoCaller.rc();
     185
     186    // never changes while event alive, no locking
    184187    *aWaitable = m->mWaitable;
    185188    return S_OK;
     
    190193{
    191194    AutoCaller autoCaller(this);
    192     if (FAILED(autoCaller.rc())) return autoCaller.rc();
     195    if (FAILED(autoCaller.rc()))
     196        return autoCaller.rc();
    193197
    194198    AutoWriteLock alock(this COMMA_LOCKVAL_SRC_POS);
     
    210214
    211215    AutoCaller autoCaller(this);
    212     if (FAILED(autoCaller.rc())) return autoCaller.rc();
     216    if (FAILED(autoCaller.rc()))
     217        return autoCaller.rc();
    213218
    214219    {
     
    250255struct VBoxVetoEvent::Data
    251256{
    252     Data()
    253         :
     257    Data() :
    254258        mVetoed(FALSE)
    255259    {}
     
    282286    // all veto events are waitable
    283287    rc = VBoxEvent::init(aSource, aType, TRUE);
    284     if (FAILED(rc)) return rc;
     288    if (FAILED(rc))
     289        return rc;
    285290
    286291    m->mVetoed = FALSE;
     
    301306{
    302307    AutoCaller autoCaller(this);
    303     if (FAILED(autoCaller.rc())) return autoCaller.rc();
     308    if (FAILED(autoCaller.rc()))
     309        return autoCaller.rc();
    304310
    305311    AutoWriteLock alock(this COMMA_LOCKVAL_SRC_POS);
     
    313319}
    314320
    315 STDMETHODIMP VBoxVetoEvent::IsVetoed(BOOL * aResult)
     321STDMETHODIMP VBoxVetoEvent::IsVetoed(BOOL *aResult)
    316322{
    317323    CheckComArgOutPointerValid(aResult);
    318324
    319325    AutoCaller autoCaller(this);
    320     if (FAILED(autoCaller.rc())) return autoCaller.rc();
     326    if (FAILED(autoCaller.rc()))
     327        return autoCaller.rc();
    321328
    322329    AutoReadLock alock(this COMMA_LOCKVAL_SRC_POS);
     
    327334}
    328335
    329 STDMETHODIMP  VBoxVetoEvent::GetVetos(ComSafeArrayOut(BSTR, aVetos))
     336STDMETHODIMP VBoxVetoEvent::GetVetos(ComSafeArrayOut(BSTR, aVetos))
    330337{
    331338    if (ComSafeArrayOutIsNull(aVetos))
     
    333340
    334341    AutoCaller autoCaller(this);
    335     if (FAILED(autoCaller.rc())) return autoCaller.rc();
     342    if (FAILED(autoCaller.rc()))
     343        return autoCaller.rc();
    336344
    337345    AutoReadLock alock(this COMMA_LOCKVAL_SRC_POS);
     
    352360
    353361static const int FirstEvent = (int)VBoxEventType_LastWildcard + 1;
    354 static const int LastEvent  = (int)VBoxEventType_Last;
    355 static const int NumEvents  = LastEvent - FirstEvent;
     362static const int LastEvent = (int)VBoxEventType_Last;
     363static const int NumEvents = LastEvent - FirstEvent;
    356364
    357365/**
     
    368376     * till element removed, so we have to know our previous one to update its next
    369377     */
    370     EventMapRecord* mNext;
     378    EventMapRecord *mNext;
    371379    bool            mAlive;
    372380private:
    373     EventMapRecord* mPrev;
    374     ListenerRecord* mRef; /* must be weak reference */
     381    EventMapRecord *mPrev;
     382    ListenerRecord *mRef; /* must be weak reference */
    375383    int32_t         mRefCnt;
    376384
    377385public:
    378     EventMapRecord(ListenerRecord* aRef)
    379         :
    380         mNext(0),
    381         mAlive(true),
    382         mPrev(0),
    383         mRef(aRef),
    384         mRefCnt(1)
     386    EventMapRecord(ListenerRecord *aRef) :
     387        mNext(0), mAlive(true), mPrev(0), mRef(aRef), mRefCnt(1)
    385388    {}
    386389
    387     EventMapRecord(EventMapRecord& aOther)
     390    EventMapRecord(EventMapRecord &aOther)
    388391    {
    389392        mNext = aOther.mNext;
     
    419422    }
    420423
    421     ListenerRecord* ref()
     424    ListenerRecord *ref()
    422425    {
    423426        return mAlive ? mRef : 0;
     
    474477        while (pCur)
    475478        {
    476             EventMapRecord* aNext = pCur->mNext;
     479            EventMapRecord *aNext = pCur->mNext;
    477480            if (pCur->ref() == aRec)
    478481            {
     
    496499        EventMapRecord *mCur;
    497500
    498         iterator()
    499             : mCur(0)
     501        iterator() :
     502            mCur(0)
    500503        {}
    501504
    502505        explicit
    503         iterator(EventMapRecord *aCur)
    504             : mCur(aCur)
     506        iterator(EventMapRecord *aCur) :
     507            mCur(aCur)
    505508        {
    506509            // Prevent element removal, till we're at it
     
    540543
    541544        bool
    542         operator==(const EventMapList::iterator& aOther) const
     545        operator==(const EventMapList::iterator &aOther) const
    543546        {
    544547            return mCur == aOther.mCur;
     
    546549
    547550        bool
    548         operator!=(const EventMapList::iterator& aOther) const
     551        operator!=(const EventMapList::iterator &aOther) const
    549552        {
    550553            return mCur != aOther.mCur;
     
    564567
    565568typedef EventMapList EventMap[NumEvents];
    566 typedef std::map<IEvent*, int32_t> PendingEventsMap;
     569typedef std::map<IEvent *, int32_t> PendingEventsMap;
    567570typedef std::deque<ComPtr<IEvent> > PassiveQueue;
    568571
     
    572575    ComPtr<IEventListener>        mListener;
    573576    BOOL                          mActive;
    574     EventSource*                  mOwner;
     577    EventSource                  *mOwner;
    575578
    576579    RTSEMEVENT                    mQEvent;
     
    581584
    582585public:
    583     ListenerRecord(IEventListener*                    aListener,
    584                    com::SafeArray<VBoxEventType_T>&   aInterested,
    585                    BOOL                               aActive,
    586                    EventSource*                       aOwner);
     586    ListenerRecord(IEventListener *aListener,
     587                   com::SafeArray<VBoxEventType_T> &aInterested,
     588                   BOOL aActive,
     589                   EventSource *aOwner);
    587590    ~ListenerRecord();
    588591
    589     HRESULT process(IEvent* aEvent, BOOL aWaitable, PendingEventsMap::iterator& pit, AutoLockBase& alock);
    590     HRESULT enqueue(IEvent* aEvent);
    591     HRESULT dequeue(IEvent* *aEvent, LONG aTimeout, AutoLockBase& aAlock);
    592     HRESULT eventProcessed(IEvent * aEvent, PendingEventsMap::iterator& pit);
     592    HRESULT process(IEvent *aEvent, BOOL aWaitable, PendingEventsMap::iterator &pit, AutoLockBase &alock);
     593    HRESULT enqueue(IEvent *aEvent);
     594    HRESULT dequeue(IEvent **aEvent, LONG aTimeout, AutoLockBase &aAlock);
     595    HRESULT eventProcessed(IEvent *aEvent, PendingEventsMap::iterator &pit);
    593596    void addRef()
    594597    {
     
    597600    void release()
    598601    {
    599         if (ASMAtomicDecS32(&mRefCnt) <= 0) delete this;
     602        if (ASMAtomicDecS32(&mRefCnt) <= 0)
     603            delete this;
    600604    }
    601605    BOOL isActive()
     
    612616{
    613617public:
    614     RecordHolder(Held* lr)
    615     :
    616     held(lr)
     618    RecordHolder(Held *lr) :
     619        held(lr)
    617620    {
    618621        addref();
    619622    }
    620     RecordHolder(const RecordHolder& that)
    621     :
    622     held(that.held)
     623    RecordHolder(const RecordHolder &that) :
     624        held(that.held)
    623625    {
    624626        addref();
     
    634636    }
    635637
    636     Held* obj()
     638    Held *obj()
    637639    {
    638640        return held;
     
    645647    }
    646648private:
    647     Held* held;
     649    Held *held;
    648650
    649651    void addref()
     
    657659            held->release();
    658660    }
    659     void safe_assign (Held *that_p)
     661    void safe_assign(Held *that_p)
    660662    {
    661663        if (that_p)
     
    666668};
    667669
    668 typedef std::map<IEventListener*, RecordHolder<ListenerRecord> > Listeners;
     670typedef std::map<IEventListener *, RecordHolder<ListenerRecord> > Listeners;
    669671
    670672struct EventSource::Data
     
    686688            return TRUE;
    687689        case VBoxEventType_Vetoable:
    688             return     (what == VBoxEventType_OnExtraDataCanChange)
    689                     || (what == VBoxEventType_OnCanShowWindow);
     690            return    (what == VBoxEventType_OnExtraDataCanChange)
     691                   || (what == VBoxEventType_OnCanShowWindow);
    690692        case VBoxEventType_MachineEvent:
    691             return     (what == VBoxEventType_OnMachineStateChanged)
    692                     || (what == VBoxEventType_OnMachineDataChanged)
    693                     || (what == VBoxEventType_OnMachineRegistered)
    694                     || (what == VBoxEventType_OnSessionStateChanged)
    695                     || (what == VBoxEventType_OnGuestPropertyChanged);
     693            return    (what == VBoxEventType_OnMachineStateChanged)
     694                   || (what == VBoxEventType_OnMachineDataChanged)
     695                   || (what == VBoxEventType_OnMachineRegistered)
     696                   || (what == VBoxEventType_OnSessionStateChanged)
     697                   || (what == VBoxEventType_OnGuestPropertyChanged);
    696698        case VBoxEventType_SnapshotEvent:
    697             return     (what == VBoxEventType_OnSnapshotTaken)
    698                     || (what == VBoxEventType_OnSnapshotDeleted)
    699                     || (what == VBoxEventType_OnSnapshotChanged)
    700                     ;
     699            return    (what == VBoxEventType_OnSnapshotTaken)
     700                   || (what == VBoxEventType_OnSnapshotDeleted)
     701                   || (what == VBoxEventType_OnSnapshotChanged) ;
    701702        case VBoxEventType_InputEvent:
    702             return     (what == VBoxEventType_OnKeyboardLedsChanged)
    703                     || (what == VBoxEventType_OnMousePointerShapeChanged)
    704                     || (what == VBoxEventType_OnMouseCapabilityChanged)
    705                     ;
     703            return    (what == VBoxEventType_OnKeyboardLedsChanged)
     704                   || (what == VBoxEventType_OnMousePointerShapeChanged)
     705                   || (what == VBoxEventType_OnMouseCapabilityChanged);
    706706        case VBoxEventType_Invalid:
    707707            return FALSE;
     
    713713}
    714714
    715 ListenerRecord::ListenerRecord(IEventListener*                  aListener,
    716                                com::SafeArray<VBoxEventType_T>& aInterested,
    717                                BOOL                             aActive,
    718                                EventSource*                     aOwner)
    719     :
    720     mActive(aActive),
    721     mOwner(aOwner),
    722     mRefCnt(0)
     715ListenerRecord::ListenerRecord(IEventListener *aListener,
     716                               com::SafeArray<VBoxEventType_T> &aInterested,
     717                               BOOL aActive,
     718                               EventSource *aOwner) :
     719    mActive(aActive), mOwner(aOwner), mRefCnt(0)
    723720{
    724721    mListener = aListener;
    725     EventMap* aEvMap = &aOwner->m->mEvMap;
     722    EventMap *aEvMap = &aOwner->m->mEvMap;
    726723
    727724    for (size_t i = 0; i < aInterested.size(); ++i)
     
    741738    {
    742739        ::RTCritSectInit(&mcsQLock);
    743         ::RTSemEventCreate (&mQEvent);
     740        ::RTSemEventCreate(&mQEvent);
    744741        mLastRead = RTTimeMilliTS();
    745742    }
     
    755752{
    756753    /* Remove references to us from the event map */
    757     EventMap* aEvMap = &mOwner->m->mEvMap;
     754    EventMap *aEvMap = &mOwner->m->mEvMap;
    758755    for (int j = FirstEvent; j < LastEvent; j++)
    759756    {
     
    765762        // at this moment nobody could add elements to our queue, so we can safely
    766763        // clean it up, otherwise there will be pending events map elements
    767         PendingEventsMap* aPem = &mOwner->m->mPendingMap;
     764        PendingEventsMap *aPem = &mOwner->m->mPendingMap;
    768765        while (true)
    769766        {
     
    791788}
    792789
    793 HRESULT ListenerRecord::process(IEvent*                     aEvent,
    794                                 BOOL                        aWaitable,
    795                                 PendingEventsMap::iterator& pit,
    796                                 AutoLockBase&               aAlock)
     790HRESULT ListenerRecord::process(IEvent *aEvent,
     791                                BOOL aWaitable,
     792                                PendingEventsMap::iterator &pit,
     793                                AutoLockBase &aAlock)
    797794{
    798795    if (mActive)
     
    801798         * We release lock here to allow modifying ops on EventSource inside callback.
    802799         */
    803         HRESULT rc =  S_OK;
     800        HRESULT rc = S_OK;
    804801        if (mListener)
    805802        {
     
    819816
    820817
    821 HRESULT ListenerRecord::enqueue (IEvent* aEvent)
     818HRESULT ListenerRecord::enqueue(IEvent *aEvent)
    822819{
    823820    AssertMsg(!mActive, ("must be passive\n"));
     
    830827    uint64_t sinceRead = RTTimeMilliTS() - mLastRead;
    831828    size_t queueSize = mQueue.size();
    832     if ( (queueSize > 1000) || ((queueSize > 500) && (sinceRead > 60 * 1000)))
     829    if ((queueSize > 1000) || ((queueSize > 500) && (sinceRead > 60 * 1000)))
    833830    {
    834831        ::RTCritSectLeave(&mcsQLock);
     
    846843    ::RTCritSectLeave(&mcsQLock);
    847844
    848      // notify waiters
     845    // notify waiters
    849846    ::RTSemEventSignal(mQEvent);
    850847
     
    852849}
    853850
    854 HRESULT ListenerRecord::dequeue (IEvent*       *aEvent,
    855                                  LONG          aTimeout,
    856                                  AutoLockBase& aAlock)
     851HRESULT ListenerRecord::dequeue(IEvent **aEvent,
     852                                LONG aTimeout,
     853                                AutoLockBase &aAlock)
    857854{
    858855    if (mActive)
     
    866863    mLastRead = RTTimeMilliTS();
    867864
    868     if (mQueue.empty())    {
     865    if (mQueue.empty())
     866    {
    869867        ::RTCritSectLeave(&mcsQLock);
    870868        // Speed up common case
     
    894892}
    895893
    896 HRESULT ListenerRecord::eventProcessed (IEvent* aEvent, PendingEventsMap::iterator& pit)
     894HRESULT ListenerRecord::eventProcessed(IEvent *aEvent, PendingEventsMap::iterator &pit)
    897895{
    898896    if (--pit->second == 0)
     
    946944}
    947945
    948 STDMETHODIMP EventSource::RegisterListener(IEventListener * aListener,
     946STDMETHODIMP EventSource::RegisterListener(IEventListener *aListener,
    949947                                           ComSafeArrayIn(VBoxEventType_T, aInterested),
    950                                            BOOL             aActive)
     948                                           BOOL aActive)
    951949{
    952950    CheckComArgNotNull(aListener);
     
    954952
    955953    AutoCaller autoCaller(this);
    956     if (FAILED(autoCaller.rc())) return autoCaller.rc();
     954    if (FAILED(autoCaller.rc()))
     955        return autoCaller.rc();
    957956
    958957    {
     
    964963                            tr("This listener already registered"));
    965964
    966         com::SafeArray<VBoxEventType_T> interested(ComSafeArrayInArg (aInterested));
     965        com::SafeArray<VBoxEventType_T> interested(ComSafeArrayInArg(aInterested));
    967966        RecordHolder<ListenerRecord> lrh(new ListenerRecord(aListener, interested, aActive, this));
    968967        m->mListeners.insert(Listeners::value_type(aListener, lrh));
     
    976975}
    977976
    978 STDMETHODIMP EventSource::UnregisterListener(IEventListener * aListener)
     977STDMETHODIMP EventSource::UnregisterListener(IEventListener *aListener)
    979978{
    980979    CheckComArgNotNull(aListener);
    981980
    982981    AutoCaller autoCaller(this);
    983     if (FAILED(autoCaller.rc())) return autoCaller.rc();
     982    if (FAILED(autoCaller.rc()))
     983        return autoCaller.rc();
    984984
    985985    HRESULT rc;
     
    10121012}
    10131013
    1014 STDMETHODIMP EventSource::FireEvent(IEvent * aEvent,
    1015                                     LONG     aTimeout,
    1016                                     BOOL     *aProcessed)
     1014STDMETHODIMP EventSource::FireEvent(IEvent *aEvent,
     1015                                    LONG aTimeout,
     1016                                    BOOL *aProcessed)
    10171017{
    10181018    CheckComArgNotNull(aEvent);
     
    10201020
    10211021    AutoCaller autoCaller(this);
    1022     if (FAILED(autoCaller.rc())) return autoCaller.rc();
     1022    if (FAILED(autoCaller.rc()))
     1023        return autoCaller.rc();
    10231024
    10241025    HRESULT hrc;
     
    10911092
    10921093
    1093 STDMETHODIMP EventSource::GetEvent(IEventListener * aListener,
    1094                                    LONG             aTimeout,
    1095                                    IEvent  **       aEvent)
     1094STDMETHODIMP EventSource::GetEvent(IEventListener *aListener,
     1095                                   LONG aTimeout,
     1096                                   IEvent **aEvent)
    10961097{
    10971098
     
    10991100
    11001101    AutoCaller autoCaller(this);
    1101     if (FAILED(autoCaller.rc())) return autoCaller.rc();
     1102    if (FAILED(autoCaller.rc()))
     1103        return autoCaller.rc();
    11021104
    11031105    AutoReadLock alock(this COMMA_LOCKVAL_SRC_POS);
     
    11181120}
    11191121
    1120 STDMETHODIMP EventSource::EventProcessed(IEventListener * aListener,
    1121                                          IEvent *         aEvent)
     1122STDMETHODIMP EventSource::EventProcessed(IEventListener *aListener,
     1123                                         IEvent *aEvent)
    11221124{
    11231125    CheckComArgNotNull(aListener);
     
    11251127
    11261128    AutoCaller autoCaller(this);
    1127     if (FAILED(autoCaller.rc())) return autoCaller.rc();
     1129    if (FAILED(autoCaller.rc()))
     1130        return autoCaller.rc();
    11281131
    11291132    AutoReadLock alock(this COMMA_LOCKVAL_SRC_POS);
     
    11371140    if (it != m->mListeners.end())
    11381141    {
    1139         ListenerRecord* aRecord = it->second.obj();
     1142        ListenerRecord *aRecord = it->second.obj();
    11401143
    11411144        if (aRecord->isActive())
    11421145            return setError(E_INVALIDARG,
    1143                         tr("Only applicable to passive listeners"));
     1146                            tr("Only applicable to passive listeners"));
    11441147
    11451148        if (aWaitable)
     
    12471250    }
    12481251
    1249     HRESULT init(IEventSource* aSource)
     1252    HRESULT init(IEventSource *aSource)
    12501253    {
    12511254        mSource = aSource;
     
    12541257
    12551258    // IEventListener methods
    1256     STDMETHOD(HandleEvent)(IEvent * aEvent)
     1259    STDMETHOD(HandleEvent)(IEvent *aEvent)
    12571260    {
    12581261        BOOL fProcessed = FALSE;
     
    12701273    typedef std::list <ComPtr<IEventSource> > EventSourceList;
    12711274    /* key is weak reference */
    1272     typedef std::map<IEventListener*, ComPtr<IEventListener> > ProxyListenerMap;
     1275    typedef std::map<IEventListener *, ComPtr<IEventListener> > ProxyListenerMap;
    12731276
    12741277    EventSourceList           mEventSources;
     
    13091312
    13101313    // IEventSource methods
    1311     STDMETHOD(CreateListener)(IEventListener ** aListener);
    1312     STDMETHOD(CreateAggregator)(ComSafeArrayIn(IEventSource*, aSubordinates),
    1313                                 IEventSource **               aAggregator);
    1314     STDMETHOD(RegisterListener)(IEventListener * aListener,
     1314    STDMETHOD(CreateListener)(IEventListener **aListener);
     1315    STDMETHOD(CreateAggregator)(ComSafeArrayIn(IEventSource *, aSubordinates),
     1316                                IEventSource **aAggregator);
     1317    STDMETHOD(RegisterListener)(IEventListener *aListener,
    13151318                                ComSafeArrayIn(VBoxEventType_T, aInterested),
    1316                                 BOOL             aActive);
    1317     STDMETHOD(UnregisterListener)(IEventListener * aListener);
    1318     STDMETHOD(FireEvent)(IEvent * aEvent,
    1319                          LONG     aTimeout,
    1320                          BOOL     *aProcessed);
    1321     STDMETHOD(GetEvent)(IEventListener * aListener,
    1322                         LONG      aTimeout,
    1323                         IEvent  * *aEvent);
    1324     STDMETHOD(EventProcessed)(IEventListener * aListener,
    1325                               IEvent *         aEvent);
     1319                                BOOL aActive);
     1320    STDMETHOD(UnregisterListener)(IEventListener *aListener);
     1321    STDMETHOD(FireEvent)(IEvent *aEvent,
     1322                         LONG aTimeout,
     1323                         BOOL *aProcessed);
     1324    STDMETHOD(GetEvent)(IEventListener *aListener,
     1325                        LONG aTimeout,
     1326                        IEvent **aEvent);
     1327    STDMETHOD(EventProcessed)(IEventListener *aListener,
     1328                              IEvent *aEvent);
    13261329
    13271330  protected:
    1328     HRESULT createProxyListener(IEventListener * aListener,
    1329                                 IEventListener * *aProxy);
    1330     HRESULT getProxyListener   (IEventListener * aListener,
    1331                                 IEventListener * *aProxy);
    1332     HRESULT removeProxyListener(IEventListener * aListener);
     1331    HRESULT createProxyListener(IEventListener *aListener,
     1332                                IEventListener **aProxy);
     1333    HRESULT getProxyListener(IEventListener *aListener,
     1334                             IEventListener **aProxy);
     1335    HRESULT removeProxyListener(IEventListener *aListener);
    13331336};
    13341337
     
    13491352
    13501353
    1351 STDMETHODIMP EventSource::CreateListener(IEventListener ** aListener)
     1354STDMETHODIMP EventSource::CreateListener(IEventListener **aListener)
    13521355{
    13531356    CheckComArgOutPointerValid(aListener);
    13541357
    13551358    AutoCaller autoCaller(this);
    1356     if (FAILED(autoCaller.rc())) return autoCaller.rc();
     1359    if (FAILED(autoCaller.rc()))
     1360        return autoCaller.rc();
    13571361
    13581362    ComObjPtr<PassiveEventListener> listener;
     
    13661370
    13671371
    1368 STDMETHODIMP EventSource::CreateAggregator(ComSafeArrayIn(IEventSource*, aSubordinates),
    1369                                            IEventSource **               aResult)
     1372STDMETHODIMP EventSource::CreateAggregator(ComSafeArrayIn(IEventSource *, aSubordinates),
     1373                                           IEventSource **aResult)
    13701374{
    13711375    CheckComArgOutPointerValid(aResult);
    13721376
    13731377    AutoCaller autoCaller(this);
    1374     if (FAILED(autoCaller.rc())) return autoCaller.rc();
     1378    if (FAILED(autoCaller.rc()))
     1379        return autoCaller.rc();
    13751380
    13761381    ComObjPtr<EventSourceAggregator> agg;
     
    13841389        return rc;
    13851390
    1386 
    13871391    agg.queryInterfaceTo(aResult);
    13881392    return S_OK;
    13891393}
    13901394
    1391 HRESULT  EventSourceAggregator::init(ComSafeArrayIn(IEventSource*, aSourcesIn))
     1395HRESULT EventSourceAggregator::init(ComSafeArrayIn(IEventSource *, aSourcesIn))
    13921396{
    13931397    HRESULT rc;
     
    13991403    ComAssertMsgRet(SUCCEEDED(rc), ("Could not create source (%Rhrc)", rc),
    14001404                    E_FAIL);
    1401     rc = mSource->init((IEventSource*)this);
     1405    rc = mSource->init((IEventSource *)this);
    14021406    ComAssertMsgRet(SUCCEEDED(rc), ("Could not init source (%Rhrc)", rc),
    14031407                    E_FAIL);
     
    14191423}
    14201424
    1421 STDMETHODIMP EventSourceAggregator::CreateListener(IEventListener ** aListener)
     1425STDMETHODIMP EventSourceAggregator::CreateListener(IEventListener **aListener)
    14221426{
    14231427    return mSource->CreateListener(aListener);
    14241428}
    14251429
    1426 STDMETHODIMP EventSourceAggregator::CreateAggregator(ComSafeArrayIn(IEventSource*, aSubordinates),
    1427                                                      IEventSource **               aResult)
     1430STDMETHODIMP EventSourceAggregator::CreateAggregator(ComSafeArrayIn(IEventSource *, aSubordinates),
     1431                                                     IEventSource **aResult)
    14281432{
    14291433    return mSource->CreateAggregator(ComSafeArrayInArg(aSubordinates), aResult);
    14301434}
    14311435
    1432 STDMETHODIMP EventSourceAggregator::RegisterListener(IEventListener * aListener,
     1436STDMETHODIMP EventSourceAggregator::RegisterListener(IEventListener *aListener,
    14331437                                                     ComSafeArrayIn(VBoxEventType_T, aInterested),
    1434                                                      BOOL             aActive)
     1438                                                     BOOL aActive)
    14351439{
    14361440    CheckComArgNotNull(aListener);
     
    14381442
    14391443    AutoCaller autoCaller(this);
    1440     if (FAILED(autoCaller.rc())) return autoCaller.rc();
     1444    if (FAILED(autoCaller.rc()))
     1445        return autoCaller.rc();
    14411446
    14421447    HRESULT rc;
     
    14631468}
    14641469
    1465 STDMETHODIMP EventSourceAggregator::UnregisterListener(IEventListener * aListener)
     1470STDMETHODIMP EventSourceAggregator::UnregisterListener(IEventListener *aListener)
    14661471{
    14671472    CheckComArgNotNull(aListener);
    14681473
    14691474    AutoCaller autoCaller(this);
    1470     if (FAILED(autoCaller.rc())) return autoCaller.rc();
     1475    if (FAILED(autoCaller.rc()))
     1476        return autoCaller.rc();
    14711477
    14721478    HRESULT rc = S_OK;
     
    14911497}
    14921498
    1493 STDMETHODIMP EventSourceAggregator::FireEvent(IEvent * aEvent,
    1494                                               LONG     aTimeout,
    1495                                               BOOL     *aProcessed)
     1499STDMETHODIMP EventSourceAggregator::FireEvent(IEvent *aEvent,
     1500                                              LONG aTimeout,
     1501                                              BOOL *aProcessed)
    14961502{
    14971503    CheckComArgNotNull(aEvent);
     
    14991505
    15001506    AutoCaller autoCaller(this);
    1501     if (FAILED(autoCaller.rc())) return autoCaller.rc();
     1507    if (FAILED(autoCaller.rc()))
     1508        return autoCaller.rc();
    15021509
    15031510    HRESULT rc = S_OK;
    15041511    AutoWriteLock alock(this COMMA_LOCKVAL_SRC_POS);
    1505     /* Aggresgator event source shalln't have direct event firing, but we may
     1512    /* Aggregator event source shall not have direct event firing, but we may
    15061513       wish to support aggregation chains */
    15071514    for (EventSourceList::const_iterator it = mEventSources.begin(); it != mEventSources.end();
     
    15181525}
    15191526
    1520 STDMETHODIMP EventSourceAggregator::GetEvent(IEventListener * aListener,
    1521                                              LONG             aTimeout,
    1522                                              IEvent  **       aEvent)
     1527STDMETHODIMP EventSourceAggregator::GetEvent(IEventListener *aListener,
     1528                                             LONG aTimeout,
     1529                                             IEvent **aEvent)
    15231530{
    15241531    return mSource->GetEvent(aListener, aTimeout, aEvent);
    15251532}
    15261533
    1527 STDMETHODIMP EventSourceAggregator::EventProcessed(IEventListener * aListener,
    1528                                                    IEvent *         aEvent)
     1534STDMETHODIMP EventSourceAggregator::EventProcessed(IEventListener *aListener,
     1535                                                   IEvent *aEvent)
    15291536{
    15301537    return mSource->EventProcessed(aListener, aEvent);
    15311538}
    15321539
    1533 HRESULT EventSourceAggregator::createProxyListener(IEventListener * aListener,
    1534                                                    IEventListener * *aProxy)
     1540HRESULT EventSourceAggregator::createProxyListener(IEventListener *aListener,
     1541                                                   IEventListener **aProxy)
    15351542{
    15361543    ComObjPtr<ProxyEventListener> proxy;
     
    15551562}
    15561563
    1557 HRESULT EventSourceAggregator::getProxyListener(IEventListener * aListener,
    1558                                                 IEventListener * *aProxy)
     1564HRESULT EventSourceAggregator::getProxyListener(IEventListener *aListener,
     1565                                                IEventListener **aProxy)
    15591566{
    15601567    ProxyListenerMap::const_iterator it = mListenerProxies.find(aListener);
     
    15671574}
    15681575
    1569 HRESULT EventSourceAggregator::removeProxyListener(IEventListener * aListener)
     1576HRESULT EventSourceAggregator::removeProxyListener(IEventListener *aListener)
    15701577{
    15711578    ProxyListenerMap::iterator it = mListenerProxies.find(aListener);
Note: See TracChangeset for help on using the changeset viewer.

© 2024 Oracle Support Privacy / Do Not Sell My Info Terms of Use Trademark Policy Automated Access Etiquette