// qtractorAtomic.h

//

/****************************************************************************

   Copyright (C) 2005-2007, rncbc aka Rui Nuno Capela. All rights reserved.



   This program is free software; you can redistribute it and/or

   modify it under the terms of the GNU General Public License

   as published by the Free Software Foundation; either version 2

   of the License, or (at your option) any later version.



   This program is distributed in the hope that it will be useful,

   but WITHOUT ANY WARRANTY; without even the implied warranty of

   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

   GNU General Public License for more details.



   You should have received a copy of the GNU General Public License along

   with this program; if not, write to the Free Software Foundation, Inc.,

   51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.



*****************************************************************************/



#ifndef __qtractorAtomic_h

#define __qtractorAtomic_h



#ifndef HAVE_QATOMIC_H

#define HAVE_QATOMIC_H

#endif



#if defined(HAVE_QATOMIC_H)

#   include 

#endif





#if defined(__cplusplus)

extern "C" {

#endif





#if defined(HAVE_QATOMIC_H)



static inline int ATOMIC_CAS ( volatile int *pAddr,

      int iOldValue, int iNewValue )

{

      return q_atomic_test_and_set_int(pAddr, iOldValue, iNewValue);

}



#elif defined(__GNUC__)



#if defined(powerpc) || defined(__ppc__)



static inline int ATOMIC_CAS ( volatile int *pAddr,

      int iOldValue, int iNewValue )

{

      register int result;

      asm volatile (

            "# ATOMIC_CAS                 n"

            "     lwarx r0, 0, %1   n"

            "     cmpw  r0, %2            n"

            "     bne-  1f                n"

            "     sync                    n"

            "     stwcx.      %3, 0, %1   n"

            "     bne-  1f                n"

            "     li          %0, 1       n"

            "     b           2f                n"

            "1:                                 n"

            "     li          %0, 0       n"

            "2:                                 n"

            : "=r" (result)

            : "r" (pValue), "r" (iOldValue), "r" (iNewValue)

            : "r0"

      );

      return result;

}



#elif defined(__i386__) || defined(__x86_64__)



static inline int ATOMIC_CAS ( volatile int *pValue,

      int iOldValue, int iNewValue )

{

      register char result;

      asm volatile (

            "# ATOMIC_CAS                 n"

            "lock ; cmpxchgl %2, %3 n"

            "sete %1                      n"

            : "=a" (iNewValue), "=qm" (result)

            : "r" (iNewValue), "m" (*pValue), "0" (iOldValue)

            : "memory"

      );

      return result;

}



#else

#   error "qtractorAtomic.h: unsupported target compiler processor (GNUC)."

#endif



#elif defined(WIN32) || defined(__WIN32__) || defined(_WIN32)



static inline int ATOMIC_CAS ( volatile int *pValue,

      int iOldValue, int iNewValue )

{

      register char result;

      __asm {

            push  ebx

            push  esi

            mov         esi, pValue

            mov         eax, iOldValue

            mov         ebx, iNewValue

            lock  cmpxchg dword ptr [esi], ebx

            sete  result

            pop         esi

            pop         ebx

      }

      return result;

}



#else

#   error "qtractorAtomic.h: unsupported target compiler processor (WIN32)."

#endif





typedef struct { volatile int value; } qtractorAtomic;



#define ATOMIC_GET(a)   ((a)->value)

#define ATOMIC_SET(a,v) ((a)->value = (v))



static inline int ATOMIC_TAS ( qtractorAtomic *pVal )

{

      return ATOMIC_CAS(&(pVal->value), 0, 1);

}



static inline int ATOMIC_ADD ( qtractorAtomic *pVal, int iAddValue )

{

      volatile int iOldValue, iNewValue;

      do {

            iOldValue = pVal->value;

            iNewValue = iOldValue + iAddValue;

      } while (!ATOMIC_CAS(&(pVal->value), iOldValue, iNewValue));

      return iNewValue;

}



#define ATOMIC_INC(a) ATOMIC_ADD((a), (+1))

#define ATOMIC_DEC(a) ATOMIC_ADD((a), (-1))





#if defined(__cplusplus)

}

#endif





#endif // __qtractorAtomic_h



// end of qtractorAtomic.h

static inline int atomic_cmpxchg(atomic_t *ptr, int old, int new)

{

    unsigned long oldval, res;



    do {

        __asm__ __volatile__("@ atomic_cmpxchgn"

        "ldrex    %1, [%2]n"

        "mov    %0, #0n"

        "teq    %1, %3n"

        "strexeq %0, %4, [%2]n"

            : "=&r" (res), "=&r" (oldval)

            : "r" (&ptr->counter), "Ir" (old), "r" (new)

            : "cc");

    } while (res);



    return oldval;

}

您可能感兴趣的文章: