What's new? | Help | Directory | Sign in
Google
             
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
// Copyright 2003, Google Inc.
//
// Redistribution and use in source and binary forms, with or without
// modification, are permitted provided that the following conditions are met:
//
// 1. Redistributions of source code must retain the above copyright notice,
// this list of conditions and the following disclaimer.
// 2. Redistributions in binary form must reproduce the above copyright notice,
// this list of conditions and the following disclaimer in the documentation
// and/or other materials provided with the distribution.
// 3. Neither the name of Google Inc. nor the names of its contributors may be
// used to endorse or promote products derived from this software without
// specific prior written permission.
//
// THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR IMPLIED
// WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
// MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO
// EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
// SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,
// PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS;
// OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY,
// WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR
// OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF
// ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
//
// Implementation of atomic operations for x86 on msvc. This file should not
// be included directly. Clients should instead include "atomicops.h".

#ifndef GEARS_BASE_COMMON_ATOMIC_OPS_WIN32_H__
#define GEARS_BASE_COMMON_ATOMIC_OPS_WIN32_H__

#include <windows.h>
#include <crtdefs.h> // for intptr_t on WINCE

typedef intptr_t AtomicWord;
#ifdef _WIN64
typedef LONG Atomic32;
#else
typedef AtomicWord Atomic32;
#endif

// TODO(aa): we don't have COMPILE_ASSERT in Gears.
// COMPILE_ASSERT(sizeof(AtomicWord) == sizeof(PVOID), atomic_word_is_atomic);

inline AtomicWord CompareAndSwap(volatile AtomicWord* ptr,
AtomicWord old_value,
AtomicWord new_value) {
PVOID result = InterlockedCompareExchangePointer(
reinterpret_cast<volatile PVOID*>(ptr),
reinterpret_cast<PVOID>(new_value), reinterpret_cast<PVOID>(old_value));
return reinterpret_cast<AtomicWord>(result);
}

inline AtomicWord AtomicExchange(volatile AtomicWord* ptr,
AtomicWord new_value) {
PVOID result = InterlockedExchangePointer(
const_cast<PVOID*>(reinterpret_cast<volatile PVOID*>(ptr)),
reinterpret_cast<PVOID>(new_value));
return reinterpret_cast<AtomicWord>(result);
}

#ifdef _WIN64
inline Atomic32 AtomicIncrement(volatile Atomic32* ptr, Atomic32 increment) {
// InterlockedExchangeAdd returns *ptr before being incremented
// and we must return nonzero iff *ptr is nonzero after being
// incremented.
return InterlockedExchangeAdd(ptr, increment) + increment;
}

inline AtomicWord AtomicIncrement(volatile AtomicWord* ptr,
AtomicWord increment) {
return InterlockedExchangeAdd64(
reinterpret_cast<volatile LONGLONG*>(ptr),
static_cast<LONGLONG>(increment)) + increment;
}
#else
inline AtomicWord AtomicIncrement(volatile AtomicWord* ptr,
AtomicWord increment) {
return InterlockedExchangeAdd(
#ifdef WINCE
// It seems that for WinCE InterlockedExchangeAdd takes LONG* as its first
// parameter. The const_cast is required to remove the volatile modifier.
const_cast<LONG*>(reinterpret_cast<volatile LONG*>(ptr)),
#else
reinterpret_cast<volatile LONG*>(ptr),
#endif
static_cast<LONG>(increment)) + increment;
}
#endif

#endif // GEARS_BASE_COMMON_ATOMIC_OPS_WIN32_H__
Show details Hide details

Change log

r1193 by gears.daemon on Mar 12, 2008   Diff
[Author: bpm]

- Add a smart pointer and convenience
classes for implementing reference
counting.
- Make BlobInterface ref-counted.
- Remove Clone from BlobInterface.
- Pass "BlobInterface" instead of "const
BlobInterface" to allow ref-counting.
There are no undesired side effects, since
BlobInterface contains no mutating
methods.
...
Go to: 
Project members, sign in to write a code review

Older revisions

r597 by gears.daemon on Dec 14, 2007   Diff
[Author: michaeln]

Fix atomic_ops_xxx.h build problems,
now including system headers required.

...
r470 by gears.daemon on Nov 22, 2007   Diff
[Author: steveblock]

Implements worker pool for WinCE.
Includes many changes which aren't
required for Worker Pool
...
r140 by gears.daemon on Jul 12, 2007   Diff
[Author: aa]

Implement ref-counting for lifetime
management of PoolsThreadManager.

...
All revisions of this file

File info

Size: 3874 bytes, 91 lines