- Notifications
You must be signed in to change notification settings - Fork 10.5k
/
Copy pathThreadLocalStorage.swift
94 lines (80 loc) · 2.81 KB
/
ThreadLocalStorage.swift
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
92
93
94
//===--- ThreadLocalStorage.swift -----------------------------------------===//
//
// This source file is part of the Swift.org open source project
//
// Copyright (c) 2014 - 2021 Apple Inc. and the Swift project authors
// Licensed under Apache License v2.0 with Runtime Library Exception
//
// See https://swift.org/LICENSE.txt for license information
// See https://swift.org/CONTRIBUTORS.txt for the list of Swift project authors
//
//===----------------------------------------------------------------------===//
import SwiftShims
// For testing purposes, a thread-safe counter to guarantee that destructors get
// called by pthread.
#if INTERNAL_CHECKS_ENABLED
internalclass_TLSAtomicInt{
internalvarvalue:Int
internalinit(){self.value =0}
internalvarvaluePtr:UnsafeMutablePointer<Int>{
return unsafe _getUnsafePointerToStoredProperties(self).assumingMemoryBound(
to:Int.self)
}
internalfunc increment(){
_ =unsafe _swift_stdlib_atomicFetchAddInt(
object: valuePtr,
operand:1)
}
internalfunc load()->Int{
returnunsafe _swift_stdlib_atomicLoadInt(object: valuePtr)
}
}
internallet_destroyTLSCounter=_TLSAtomicInt()
public // @testable
func _loadDestroyTLSCounter()->Int{
return _destroyTLSCounter.load()
}
#endif
// Thread local storage for all of the Swift standard library
//
// @moveonly/@pointeronly: shouldn't be used as a value, only through its
// pointer. Similarly, shouldn't be created, except by
// _initializeThreadLocalStorage.
//
internalstruct_ThreadLocalStorage{
// private: Should only be called by _initializeThreadLocalStorage
internalinit(){}
// Get the current thread's TLS pointer. On first call for a given thread,
// creates and initializes a new one.
internalstaticfunc getPointer()
->UnsafeMutablePointer<_ThreadLocalStorage>
{
returnunsafe _swift_stdlib_threadLocalStorageGet().assumingMemoryBound(
to: _ThreadLocalStorage.self)
}
}
// Destructor to register with pthreads. Responsible for deallocating any memory
// owned.
@_silgen_name("_stdlib_destroyTLS")
internalfunc _destroyTLS(_ ptr:UnsafeMutableRawPointer?){
unsafe _internalInvariant(ptr !=nil,
"_destroyTLS was called, but with nil...")
lettlsPtr=unsafe ptr!.assumingMemoryBound(to: _ThreadLocalStorage.self)
unsafe tlsPtr.deinitialize(count:1)
unsafe tlsPtr.deallocate()
#if INTERNAL_CHECKS_ENABLED
// Log the fact we've destroyed our storage
_destroyTLSCounter.increment()
#endif
}
@_silgen_name("_stdlib_createTLS")
internalfunc _createThreadLocalStorage()
->UnsafeMutablePointer<_ThreadLocalStorage>
{
lettlsPtr:UnsafeMutablePointer<_ThreadLocalStorage>
= UnsafeMutablePointer<_ThreadLocalStorage>.allocate(
capacity:1
)
unsafe tlsPtr.initialize(to:_ThreadLocalStorage())
return unsafe tlsPtr
}