blob: 47cb1a391fa5c5ae4206132ebdcbb13b699368ba [file] [log] [blame]
Alexey Bataev9959db52014-05-06 10:08:46 +00001//===----- CGOpenMPRuntime.cpp - Interface to OpenMP Runtimes -------------===//
2//
3// The LLVM Compiler Infrastructure
4//
5// This file is distributed under the University of Illinois Open Source
6// License. See LICENSE.TXT for details.
7//
8//===----------------------------------------------------------------------===//
9//
10// This provides a class for OpenMP runtime code generation.
11//
12//===----------------------------------------------------------------------===//
13
14#include "CGOpenMPRuntime.h"
15#include "CodeGenFunction.h"
Alexey Bataev36bf0112015-03-10 05:15:26 +000016#include "CGCleanup.h"
Alexey Bataev9959db52014-05-06 10:08:46 +000017#include "clang/AST/Decl.h"
Chandler Carruth0d9593d2015-01-14 11:29:14 +000018#include "clang/AST/StmtOpenMP.h"
Alexey Bataev9959db52014-05-06 10:08:46 +000019#include "llvm/ADT/ArrayRef.h"
Alexey Bataevd74d0602014-10-13 06:02:40 +000020#include "llvm/IR/CallSite.h"
Alexey Bataev9959db52014-05-06 10:08:46 +000021#include "llvm/IR/DerivedTypes.h"
22#include "llvm/IR/GlobalValue.h"
23#include "llvm/IR/Value.h"
24#include "llvm/Support/raw_ostream.h"
Alexey Bataev23b69422014-06-18 07:08:49 +000025#include <cassert>
Alexey Bataev9959db52014-05-06 10:08:46 +000026
27using namespace clang;
28using namespace CodeGen;
29
Benjamin Kramerc52193f2014-10-10 13:57:57 +000030namespace {
Alexey Bataev8cbe0a62015-02-26 10:27:34 +000031/// \brief Base class for handling code generation inside OpenMP regions.
Alexey Bataev18095712014-10-10 12:19:54 +000032class CGOpenMPRegionInfo : public CodeGenFunction::CGCapturedStmtInfo {
33public:
Alexey Bataev6f1ffc02015-04-10 04:50:10 +000034 /// \brief Kinds of OpenMP regions used in codegen.
35 enum CGOpenMPRegionKind {
36 /// \brief Region with outlined function for standalone 'parallel'
37 /// directive.
38 ParallelOutlinedRegion,
39 /// \brief Region with outlined function for standalone 'task' directive.
40 TaskOutlinedRegion,
41 /// \brief Region for constructs that do not require function outlining,
42 /// like 'for', 'sections', 'atomic' etc. directives.
43 InlinedRegion,
44 };
Alexey Bataev18095712014-10-10 12:19:54 +000045
Alexey Bataev6f1ffc02015-04-10 04:50:10 +000046 CGOpenMPRegionInfo(const CapturedStmt &CS,
47 const CGOpenMPRegionKind RegionKind,
48 const RegionCodeGenTy &CodeGen)
49 : CGCapturedStmtInfo(CS, CR_OpenMP), RegionKind(RegionKind),
50 CodeGen(CodeGen) {}
51
52 CGOpenMPRegionInfo(const CGOpenMPRegionKind RegionKind,
53 const RegionCodeGenTy &CodeGen)
54 : CGCapturedStmtInfo(CR_OpenMP), RegionKind(RegionKind),
55 CodeGen(CodeGen) {}
Alexey Bataev8cbe0a62015-02-26 10:27:34 +000056
57 /// \brief Get a variable or parameter for storing global thread id
Alexey Bataev18095712014-10-10 12:19:54 +000058 /// inside OpenMP construct.
Alexey Bataev8cbe0a62015-02-26 10:27:34 +000059 virtual const VarDecl *getThreadIDVariable() const = 0;
Alexey Bataev18095712014-10-10 12:19:54 +000060
Alexey Bataev6f1ffc02015-04-10 04:50:10 +000061 /// \brief Emit the captured statement body.
62 virtual void EmitBody(CodeGenFunction &CGF, const Stmt *S) override;
63
Alexey Bataev8cbe0a62015-02-26 10:27:34 +000064 /// \brief Get an LValue for the current ThreadID variable.
Alexey Bataev62b63b12015-03-10 07:28:44 +000065 /// \return LValue for thread id variable. This LValue always has type int32*.
66 virtual LValue getThreadIDVariableLValue(CodeGenFunction &CGF);
Alexey Bataev18095712014-10-10 12:19:54 +000067
Alexey Bataev6f1ffc02015-04-10 04:50:10 +000068 CGOpenMPRegionKind getRegionKind() const { return RegionKind; }
Alexey Bataev8cbe0a62015-02-26 10:27:34 +000069
Alexey Bataev18095712014-10-10 12:19:54 +000070 static bool classof(const CGCapturedStmtInfo *Info) {
71 return Info->getKind() == CR_OpenMP;
72 }
Alexey Bataev6f1ffc02015-04-10 04:50:10 +000073
Alexey Bataev8cbe0a62015-02-26 10:27:34 +000074protected:
Alexey Bataev6f1ffc02015-04-10 04:50:10 +000075 CGOpenMPRegionKind RegionKind;
76 const RegionCodeGenTy &CodeGen;
Alexey Bataev8cbe0a62015-02-26 10:27:34 +000077};
Alexey Bataev18095712014-10-10 12:19:54 +000078
Alexey Bataev8cbe0a62015-02-26 10:27:34 +000079/// \brief API for captured statement code generation in OpenMP constructs.
80class CGOpenMPOutlinedRegionInfo : public CGOpenMPRegionInfo {
81public:
Alexey Bataev6f1ffc02015-04-10 04:50:10 +000082 CGOpenMPOutlinedRegionInfo(const CapturedStmt &CS, const VarDecl *ThreadIDVar,
83 const RegionCodeGenTy &CodeGen)
84 : CGOpenMPRegionInfo(CS, ParallelOutlinedRegion, CodeGen),
85 ThreadIDVar(ThreadIDVar) {
Alexey Bataev8cbe0a62015-02-26 10:27:34 +000086 assert(ThreadIDVar != nullptr && "No ThreadID in OpenMP region.");
87 }
88 /// \brief Get a variable or parameter for storing global thread id
89 /// inside OpenMP construct.
Alexander Kornienko34eb2072015-04-11 02:00:23 +000090 const VarDecl *getThreadIDVariable() const override { return ThreadIDVar; }
Alexey Bataev6f1ffc02015-04-10 04:50:10 +000091
Alexey Bataev18095712014-10-10 12:19:54 +000092 /// \brief Get the name of the capture helper.
Benjamin Kramerc52193f2014-10-10 13:57:57 +000093 StringRef getHelperName() const override { return ".omp_outlined."; }
Alexey Bataev18095712014-10-10 12:19:54 +000094
Alexey Bataev6f1ffc02015-04-10 04:50:10 +000095 static bool classof(const CGCapturedStmtInfo *Info) {
96 return CGOpenMPRegionInfo::classof(Info) &&
97 cast<CGOpenMPRegionInfo>(Info)->getRegionKind() ==
98 ParallelOutlinedRegion;
99 }
100
Alexey Bataev18095712014-10-10 12:19:54 +0000101private:
102 /// \brief A variable or parameter storing global thread id for OpenMP
103 /// constructs.
104 const VarDecl *ThreadIDVar;
Alexey Bataev8cbe0a62015-02-26 10:27:34 +0000105};
106
Alexey Bataev62b63b12015-03-10 07:28:44 +0000107/// \brief API for captured statement code generation in OpenMP constructs.
108class CGOpenMPTaskOutlinedRegionInfo : public CGOpenMPRegionInfo {
109public:
Alexey Bataev6f1ffc02015-04-10 04:50:10 +0000110 CGOpenMPTaskOutlinedRegionInfo(const CapturedStmt &CS,
Alexey Bataev62b63b12015-03-10 07:28:44 +0000111 const VarDecl *ThreadIDVar,
Alexey Bataev6f1ffc02015-04-10 04:50:10 +0000112 const RegionCodeGenTy &CodeGen)
113 : CGOpenMPRegionInfo(CS, TaskOutlinedRegion, CodeGen),
114 ThreadIDVar(ThreadIDVar) {
Alexey Bataev62b63b12015-03-10 07:28:44 +0000115 assert(ThreadIDVar != nullptr && "No ThreadID in OpenMP region.");
116 }
117 /// \brief Get a variable or parameter for storing global thread id
118 /// inside OpenMP construct.
Alexander Kornienko34eb2072015-04-11 02:00:23 +0000119 const VarDecl *getThreadIDVariable() const override { return ThreadIDVar; }
Alexey Bataev62b63b12015-03-10 07:28:44 +0000120
121 /// \brief Get an LValue for the current ThreadID variable.
Alexander Kornienko34eb2072015-04-11 02:00:23 +0000122 LValue getThreadIDVariableLValue(CodeGenFunction &CGF) override;
Alexey Bataev62b63b12015-03-10 07:28:44 +0000123
Alexey Bataev62b63b12015-03-10 07:28:44 +0000124 /// \brief Get the name of the capture helper.
125 StringRef getHelperName() const override { return ".omp_outlined."; }
126
Alexey Bataev6f1ffc02015-04-10 04:50:10 +0000127 static bool classof(const CGCapturedStmtInfo *Info) {
128 return CGOpenMPRegionInfo::classof(Info) &&
129 cast<CGOpenMPRegionInfo>(Info)->getRegionKind() ==
130 TaskOutlinedRegion;
131 }
132
Alexey Bataev62b63b12015-03-10 07:28:44 +0000133private:
134 /// \brief A variable or parameter storing global thread id for OpenMP
135 /// constructs.
136 const VarDecl *ThreadIDVar;
Alexey Bataev62b63b12015-03-10 07:28:44 +0000137};
138
Alexey Bataev8cbe0a62015-02-26 10:27:34 +0000139/// \brief API for inlined captured statement code generation in OpenMP
140/// constructs.
141class CGOpenMPInlinedRegionInfo : public CGOpenMPRegionInfo {
142public:
Alexey Bataev6f1ffc02015-04-10 04:50:10 +0000143 CGOpenMPInlinedRegionInfo(CodeGenFunction::CGCapturedStmtInfo *OldCSI,
144 const RegionCodeGenTy &CodeGen)
145 : CGOpenMPRegionInfo(InlinedRegion, CodeGen), OldCSI(OldCSI),
Alexey Bataev8cbe0a62015-02-26 10:27:34 +0000146 OuterRegionInfo(dyn_cast_or_null<CGOpenMPRegionInfo>(OldCSI)) {}
147 // \brief Retrieve the value of the context parameter.
Alexander Kornienko34eb2072015-04-11 02:00:23 +0000148 llvm::Value *getContextValue() const override {
Alexey Bataev8cbe0a62015-02-26 10:27:34 +0000149 if (OuterRegionInfo)
150 return OuterRegionInfo->getContextValue();
151 llvm_unreachable("No context value for inlined OpenMP region");
152 }
Alexey Bataev6f1ffc02015-04-10 04:50:10 +0000153 virtual void setContextValue(llvm::Value *V) override {
154 if (OuterRegionInfo) {
155 OuterRegionInfo->setContextValue(V);
156 return;
157 }
158 llvm_unreachable("No context value for inlined OpenMP region");
159 }
Alexey Bataev8cbe0a62015-02-26 10:27:34 +0000160 /// \brief Lookup the captured field decl for a variable.
Alexander Kornienko34eb2072015-04-11 02:00:23 +0000161 const FieldDecl *lookup(const VarDecl *VD) const override {
Alexey Bataev8cbe0a62015-02-26 10:27:34 +0000162 if (OuterRegionInfo)
163 return OuterRegionInfo->lookup(VD);
Alexey Bataev69c62a92015-04-15 04:52:20 +0000164 // If there is no outer outlined region,no need to lookup in a list of
165 // captured variables, we can use the original one.
166 return nullptr;
Alexey Bataev8cbe0a62015-02-26 10:27:34 +0000167 }
Alexander Kornienko34eb2072015-04-11 02:00:23 +0000168 FieldDecl *getThisFieldDecl() const override {
Alexey Bataev8cbe0a62015-02-26 10:27:34 +0000169 if (OuterRegionInfo)
170 return OuterRegionInfo->getThisFieldDecl();
171 return nullptr;
172 }
173 /// \brief Get a variable or parameter for storing global thread id
174 /// inside OpenMP construct.
Alexander Kornienko34eb2072015-04-11 02:00:23 +0000175 const VarDecl *getThreadIDVariable() const override {
Alexey Bataev8cbe0a62015-02-26 10:27:34 +0000176 if (OuterRegionInfo)
177 return OuterRegionInfo->getThreadIDVariable();
178 return nullptr;
179 }
Alexey Bataev62b63b12015-03-10 07:28:44 +0000180
Alexey Bataev8cbe0a62015-02-26 10:27:34 +0000181 /// \brief Get the name of the capture helper.
Alexander Kornienko34eb2072015-04-11 02:00:23 +0000182 StringRef getHelperName() const override {
Alexey Bataev6f1ffc02015-04-10 04:50:10 +0000183 if (auto *OuterRegionInfo = getOldCSI())
184 return OuterRegionInfo->getHelperName();
Alexey Bataev8cbe0a62015-02-26 10:27:34 +0000185 llvm_unreachable("No helper name for inlined OpenMP construct");
186 }
187
188 CodeGenFunction::CGCapturedStmtInfo *getOldCSI() const { return OldCSI; }
189
Alexey Bataev6f1ffc02015-04-10 04:50:10 +0000190 static bool classof(const CGCapturedStmtInfo *Info) {
191 return CGOpenMPRegionInfo::classof(Info) &&
192 cast<CGOpenMPRegionInfo>(Info)->getRegionKind() == InlinedRegion;
193 }
194
Alexey Bataev8cbe0a62015-02-26 10:27:34 +0000195private:
196 /// \brief CodeGen info about outer OpenMP region.
197 CodeGenFunction::CGCapturedStmtInfo *OldCSI;
198 CGOpenMPRegionInfo *OuterRegionInfo;
Alexey Bataev18095712014-10-10 12:19:54 +0000199};
Alexey Bataev6f1ffc02015-04-10 04:50:10 +0000200
201/// \brief RAII for emitting code of OpenMP constructs.
202class InlinedOpenMPRegionRAII {
203 CodeGenFunction &CGF;
204
205public:
206 /// \brief Constructs region for combined constructs.
207 /// \param CodeGen Code generation sequence for combined directives. Includes
208 /// a list of functions used for code generation of implicitly inlined
209 /// regions.
210 InlinedOpenMPRegionRAII(CodeGenFunction &CGF, const RegionCodeGenTy &CodeGen)
211 : CGF(CGF) {
212 // Start emission for the construct.
213 CGF.CapturedStmtInfo =
214 new CGOpenMPInlinedRegionInfo(CGF.CapturedStmtInfo, CodeGen);
215 }
216 ~InlinedOpenMPRegionRAII() {
217 // Restore original CapturedStmtInfo only if we're done with code emission.
218 auto *OldCSI =
219 cast<CGOpenMPInlinedRegionInfo>(CGF.CapturedStmtInfo)->getOldCSI();
220 delete CGF.CapturedStmtInfo;
221 CGF.CapturedStmtInfo = OldCSI;
222 }
223};
224
Benjamin Kramerc52193f2014-10-10 13:57:57 +0000225} // namespace
Alexey Bataev18095712014-10-10 12:19:54 +0000226
227LValue CGOpenMPRegionInfo::getThreadIDVariableLValue(CodeGenFunction &CGF) {
228 return CGF.MakeNaturalAlignAddrLValue(
Alexey Bataev62b63b12015-03-10 07:28:44 +0000229 CGF.Builder.CreateAlignedLoad(
230 CGF.GetAddrOfLocalVar(getThreadIDVariable()),
231 CGF.PointerAlignInBytes),
232 getThreadIDVariable()
233 ->getType()
234 ->castAs<PointerType>()
235 ->getPointeeType());
Alexey Bataev18095712014-10-10 12:19:54 +0000236}
237
Alexey Bataev6f1ffc02015-04-10 04:50:10 +0000238void CGOpenMPRegionInfo::EmitBody(CodeGenFunction &CGF, const Stmt * /*S*/) {
239 // 1.2.2 OpenMP Language Terminology
240 // Structured block - An executable statement with a single entry at the
241 // top and a single exit at the bottom.
242 // The point of exit cannot be a branch out of the structured block.
243 // longjmp() and throw() must not violate the entry/exit criteria.
244 CGF.EHStack.pushTerminate();
245 {
246 CodeGenFunction::RunCleanupsScope Scope(CGF);
247 CodeGen(CGF);
248 }
249 CGF.EHStack.popTerminate();
Alexey Bataev4a5bb772014-10-08 14:01:46 +0000250}
251
Alexey Bataev62b63b12015-03-10 07:28:44 +0000252LValue CGOpenMPTaskOutlinedRegionInfo::getThreadIDVariableLValue(
253 CodeGenFunction &CGF) {
254 return CGF.MakeNaturalAlignAddrLValue(
255 CGF.GetAddrOfLocalVar(getThreadIDVariable()),
256 getThreadIDVariable()->getType());
257}
258
Alexey Bataev9959db52014-05-06 10:08:46 +0000259CGOpenMPRuntime::CGOpenMPRuntime(CodeGenModule &CGM)
Alexey Bataev62b63b12015-03-10 07:28:44 +0000260 : CGM(CGM), DefaultOpenMPPSource(nullptr), KmpRoutineEntryPtrTy(nullptr) {
Alexey Bataev9959db52014-05-06 10:08:46 +0000261 IdentTy = llvm::StructType::create(
262 "ident_t", CGM.Int32Ty /* reserved_1 */, CGM.Int32Ty /* flags */,
263 CGM.Int32Ty /* reserved_2 */, CGM.Int32Ty /* reserved_3 */,
Alexander Musmanfdfa8552014-09-11 08:10:57 +0000264 CGM.Int8PtrTy /* psource */, nullptr);
Alexey Bataev9959db52014-05-06 10:08:46 +0000265 // Build void (*kmpc_micro)(kmp_int32 *global_tid, kmp_int32 *bound_tid,...)
Alexey Bataev23b69422014-06-18 07:08:49 +0000266 llvm::Type *MicroParams[] = {llvm::PointerType::getUnqual(CGM.Int32Ty),
267 llvm::PointerType::getUnqual(CGM.Int32Ty)};
Alexey Bataev9959db52014-05-06 10:08:46 +0000268 Kmpc_MicroTy = llvm::FunctionType::get(CGM.VoidTy, MicroParams, true);
Alexey Bataev3a3bf0b2014-09-22 10:01:53 +0000269 KmpCriticalNameTy = llvm::ArrayType::get(CGM.Int32Ty, /*NumElements*/ 8);
Alexey Bataev9959db52014-05-06 10:08:46 +0000270}
271
Alexey Bataev91797552015-03-18 04:13:55 +0000272void CGOpenMPRuntime::clear() {
273 InternalVars.clear();
274}
275
Alexey Bataev9959db52014-05-06 10:08:46 +0000276llvm::Value *
Alexey Bataev6f1ffc02015-04-10 04:50:10 +0000277CGOpenMPRuntime::emitParallelOutlinedFunction(const OMPExecutableDirective &D,
278 const VarDecl *ThreadIDVar,
279 const RegionCodeGenTy &CodeGen) {
Alexey Bataev62b63b12015-03-10 07:28:44 +0000280 assert(ThreadIDVar->getType()->isPointerType() &&
281 "thread id variable must be of type kmp_int32 *");
Alexey Bataev18095712014-10-10 12:19:54 +0000282 const CapturedStmt *CS = cast<CapturedStmt>(D.getAssociatedStmt());
283 CodeGenFunction CGF(CGM, true);
Alexey Bataev6f1ffc02015-04-10 04:50:10 +0000284 CGOpenMPOutlinedRegionInfo CGInfo(*CS, ThreadIDVar, CodeGen);
Alexey Bataev18095712014-10-10 12:19:54 +0000285 CGF.CapturedStmtInfo = &CGInfo;
286 return CGF.GenerateCapturedStmtFunction(*CS);
287}
288
289llvm::Value *
Alexey Bataev62b63b12015-03-10 07:28:44 +0000290CGOpenMPRuntime::emitTaskOutlinedFunction(const OMPExecutableDirective &D,
291 const VarDecl *ThreadIDVar,
Alexey Bataev6f1ffc02015-04-10 04:50:10 +0000292 const RegionCodeGenTy &CodeGen) {
Alexey Bataev62b63b12015-03-10 07:28:44 +0000293 assert(!ThreadIDVar->getType()->isPointerType() &&
294 "thread id variable must be of type kmp_int32 for tasks");
295 auto *CS = cast<CapturedStmt>(D.getAssociatedStmt());
296 CodeGenFunction CGF(CGM, true);
Alexey Bataev6f1ffc02015-04-10 04:50:10 +0000297 CGOpenMPTaskOutlinedRegionInfo CGInfo(*CS, ThreadIDVar, CodeGen);
Alexey Bataev62b63b12015-03-10 07:28:44 +0000298 CGF.CapturedStmtInfo = &CGInfo;
299 return CGF.GenerateCapturedStmtFunction(*CS);
300}
301
302llvm::Value *
Alexey Bataev3eff5f42015-02-25 08:32:46 +0000303CGOpenMPRuntime::getOrCreateDefaultLocation(OpenMPLocationFlags Flags) {
Alexey Bataev15007ba2014-05-07 06:18:01 +0000304 llvm::Value *Entry = OpenMPDefaultLocMap.lookup(Flags);
Alexey Bataev9959db52014-05-06 10:08:46 +0000305 if (!Entry) {
306 if (!DefaultOpenMPPSource) {
307 // Initialize default location for psource field of ident_t structure of
308 // all ident_t objects. Format is ";file;function;line;column;;".
309 // Taken from
310 // http://llvm.org/svn/llvm-project/openmp/trunk/runtime/src/kmp_str.c
311 DefaultOpenMPPSource =
312 CGM.GetAddrOfConstantCString(";unknown;unknown;0;0;;");
313 DefaultOpenMPPSource =
314 llvm::ConstantExpr::getBitCast(DefaultOpenMPPSource, CGM.Int8PtrTy);
315 }
Alexey Bataev4a5bb772014-10-08 14:01:46 +0000316 auto DefaultOpenMPLocation = new llvm::GlobalVariable(
317 CGM.getModule(), IdentTy, /*isConstant*/ true,
318 llvm::GlobalValue::PrivateLinkage, /*Initializer*/ nullptr);
Alexey Bataev9959db52014-05-06 10:08:46 +0000319 DefaultOpenMPLocation->setUnnamedAddr(true);
Alexey Bataev9959db52014-05-06 10:08:46 +0000320
321 llvm::Constant *Zero = llvm::ConstantInt::get(CGM.Int32Ty, 0, true);
Alexey Bataev23b69422014-06-18 07:08:49 +0000322 llvm::Constant *Values[] = {Zero,
323 llvm::ConstantInt::get(CGM.Int32Ty, Flags),
324 Zero, Zero, DefaultOpenMPPSource};
Alexey Bataev9959db52014-05-06 10:08:46 +0000325 llvm::Constant *Init = llvm::ConstantStruct::get(IdentTy, Values);
326 DefaultOpenMPLocation->setInitializer(Init);
Alexey Bataev4a5bb772014-10-08 14:01:46 +0000327 OpenMPDefaultLocMap[Flags] = DefaultOpenMPLocation;
Alexey Bataev9959db52014-05-06 10:08:46 +0000328 return DefaultOpenMPLocation;
329 }
330 return Entry;
331}
332
Alexey Bataev3eff5f42015-02-25 08:32:46 +0000333llvm::Value *CGOpenMPRuntime::emitUpdateLocation(CodeGenFunction &CGF,
334 SourceLocation Loc,
335 OpenMPLocationFlags Flags) {
Alexey Bataev9959db52014-05-06 10:08:46 +0000336 // If no debug info is generated - return global default location.
337 if (CGM.getCodeGenOpts().getDebugInfo() == CodeGenOptions::NoDebugInfo ||
338 Loc.isInvalid())
Alexey Bataev3eff5f42015-02-25 08:32:46 +0000339 return getOrCreateDefaultLocation(Flags);
Alexey Bataev9959db52014-05-06 10:08:46 +0000340
341 assert(CGF.CurFn && "No function in current CodeGenFunction.");
342
Alexey Bataev9959db52014-05-06 10:08:46 +0000343 llvm::Value *LocValue = nullptr;
Alexey Bataev1e4b7132014-12-03 12:11:24 +0000344 auto I = OpenMPLocThreadIDMap.find(CGF.CurFn);
345 if (I != OpenMPLocThreadIDMap.end())
Alexey Bataev18095712014-10-10 12:19:54 +0000346 LocValue = I->second.DebugLoc;
Alexander Musmanc6388682014-12-15 07:07:06 +0000347 // OpenMPLocThreadIDMap may have null DebugLoc and non-null ThreadID, if
348 // GetOpenMPThreadID was called before this routine.
349 if (LocValue == nullptr) {
Alexey Bataev15007ba2014-05-07 06:18:01 +0000350 // Generate "ident_t .kmpc_loc.addr;"
351 llvm::AllocaInst *AI = CGF.CreateTempAlloca(IdentTy, ".kmpc_loc.addr");
Alexey Bataev9959db52014-05-06 10:08:46 +0000352 AI->setAlignment(CGM.getDataLayout().getPrefTypeAlignment(IdentTy));
Alexey Bataev18095712014-10-10 12:19:54 +0000353 auto &Elem = OpenMPLocThreadIDMap.FindAndConstruct(CGF.CurFn);
354 Elem.second.DebugLoc = AI;
Alexey Bataev9959db52014-05-06 10:08:46 +0000355 LocValue = AI;
356
357 CGBuilderTy::InsertPointGuard IPG(CGF.Builder);
358 CGF.Builder.SetInsertPoint(CGF.AllocaInsertPt);
Alexey Bataev3eff5f42015-02-25 08:32:46 +0000359 CGF.Builder.CreateMemCpy(LocValue, getOrCreateDefaultLocation(Flags),
Alexey Bataev9959db52014-05-06 10:08:46 +0000360 llvm::ConstantExpr::getSizeOf(IdentTy),
361 CGM.PointerAlignInBytes);
362 }
363
364 // char **psource = &.kmpc_loc_<flags>.addr.psource;
David Blaikie1ed728c2015-04-05 22:45:47 +0000365 auto *PSource = CGF.Builder.CreateConstInBoundsGEP2_32(IdentTy, LocValue, 0,
366 IdentField_PSource);
Alexey Bataev9959db52014-05-06 10:08:46 +0000367
Alexey Bataevf002aca2014-05-30 05:48:40 +0000368 auto OMPDebugLoc = OpenMPDebugLocMap.lookup(Loc.getRawEncoding());
369 if (OMPDebugLoc == nullptr) {
370 SmallString<128> Buffer2;
371 llvm::raw_svector_ostream OS2(Buffer2);
372 // Build debug location
373 PresumedLoc PLoc = CGF.getContext().getSourceManager().getPresumedLoc(Loc);
374 OS2 << ";" << PLoc.getFilename() << ";";
375 if (const FunctionDecl *FD =
376 dyn_cast_or_null<FunctionDecl>(CGF.CurFuncDecl)) {
377 OS2 << FD->getQualifiedNameAsString();
378 }
379 OS2 << ";" << PLoc.getLine() << ";" << PLoc.getColumn() << ";;";
380 OMPDebugLoc = CGF.Builder.CreateGlobalStringPtr(OS2.str());
381 OpenMPDebugLocMap[Loc.getRawEncoding()] = OMPDebugLoc;
Alexey Bataev9959db52014-05-06 10:08:46 +0000382 }
Alexey Bataev9959db52014-05-06 10:08:46 +0000383 // *psource = ";<File>;<Function>;<Line>;<Column>;;";
Alexey Bataevf002aca2014-05-30 05:48:40 +0000384 CGF.Builder.CreateStore(OMPDebugLoc, PSource);
385
Alexey Bataev9959db52014-05-06 10:08:46 +0000386 return LocValue;
387}
388
Alexey Bataev3eff5f42015-02-25 08:32:46 +0000389llvm::Value *CGOpenMPRuntime::getThreadID(CodeGenFunction &CGF,
390 SourceLocation Loc) {
Alexey Bataev9959db52014-05-06 10:08:46 +0000391 assert(CGF.CurFn && "No function in current CodeGenFunction.");
392
Alexey Bataev4a5bb772014-10-08 14:01:46 +0000393 llvm::Value *ThreadID = nullptr;
Alexey Bataev18095712014-10-10 12:19:54 +0000394 // Check whether we've already cached a load of the thread id in this
395 // function.
Alexey Bataev1e4b7132014-12-03 12:11:24 +0000396 auto I = OpenMPLocThreadIDMap.find(CGF.CurFn);
Alexey Bataev18095712014-10-10 12:19:54 +0000397 if (I != OpenMPLocThreadIDMap.end()) {
398 ThreadID = I->second.ThreadID;
Alexey Bataev03b340a2014-10-21 03:16:40 +0000399 if (ThreadID != nullptr)
400 return ThreadID;
401 }
402 if (auto OMPRegionInfo =
Alexey Bataev1e4b7132014-12-03 12:11:24 +0000403 dyn_cast_or_null<CGOpenMPRegionInfo>(CGF.CapturedStmtInfo)) {
Alexey Bataev62b63b12015-03-10 07:28:44 +0000404 if (OMPRegionInfo->getThreadIDVariable()) {
Alexey Bataev8cbe0a62015-02-26 10:27:34 +0000405 // Check if this an outlined function with thread id passed as argument.
406 auto LVal = OMPRegionInfo->getThreadIDVariableLValue(CGF);
Alexey Bataev8cbe0a62015-02-26 10:27:34 +0000407 ThreadID = CGF.EmitLoadOfLValue(LVal, Loc).getScalarVal();
408 // If value loaded in entry block, cache it and use it everywhere in
409 // function.
410 if (CGF.Builder.GetInsertBlock() == CGF.AllocaInsertPt->getParent()) {
411 auto &Elem = OpenMPLocThreadIDMap.FindAndConstruct(CGF.CurFn);
412 Elem.second.ThreadID = ThreadID;
413 }
414 return ThreadID;
Alexey Bataevd6c57552014-07-25 07:55:17 +0000415 }
Alexey Bataev9959db52014-05-06 10:08:46 +0000416 }
Alexey Bataev8cbe0a62015-02-26 10:27:34 +0000417
418 // This is not an outlined function region - need to call __kmpc_int32
419 // kmpc_global_thread_num(ident_t *loc).
420 // Generate thread id value and cache this value for use across the
421 // function.
422 CGBuilderTy::InsertPointGuard IPG(CGF.Builder);
423 CGF.Builder.SetInsertPoint(CGF.AllocaInsertPt);
424 ThreadID =
425 CGF.EmitRuntimeCall(createRuntimeFunction(OMPRTL__kmpc_global_thread_num),
426 emitUpdateLocation(CGF, Loc));
427 auto &Elem = OpenMPLocThreadIDMap.FindAndConstruct(CGF.CurFn);
428 Elem.second.ThreadID = ThreadID;
Alexey Bataev4a5bb772014-10-08 14:01:46 +0000429 return ThreadID;
Alexey Bataev9959db52014-05-06 10:08:46 +0000430}
431
Alexey Bataev3eff5f42015-02-25 08:32:46 +0000432void CGOpenMPRuntime::functionFinished(CodeGenFunction &CGF) {
Alexey Bataev9959db52014-05-06 10:08:46 +0000433 assert(CGF.CurFn && "No function in current CodeGenFunction.");
Alexey Bataev03b340a2014-10-21 03:16:40 +0000434 if (OpenMPLocThreadIDMap.count(CGF.CurFn))
435 OpenMPLocThreadIDMap.erase(CGF.CurFn);
Alexey Bataev9959db52014-05-06 10:08:46 +0000436}
437
438llvm::Type *CGOpenMPRuntime::getIdentTyPointerTy() {
439 return llvm::PointerType::getUnqual(IdentTy);
440}
441
442llvm::Type *CGOpenMPRuntime::getKmpc_MicroPointerTy() {
443 return llvm::PointerType::getUnqual(Kmpc_MicroTy);
444}
445
446llvm::Constant *
Alexey Bataev3eff5f42015-02-25 08:32:46 +0000447CGOpenMPRuntime::createRuntimeFunction(OpenMPRTLFunction Function) {
Alexey Bataev9959db52014-05-06 10:08:46 +0000448 llvm::Constant *RTLFn = nullptr;
449 switch (Function) {
450 case OMPRTL__kmpc_fork_call: {
451 // Build void __kmpc_fork_call(ident_t *loc, kmp_int32 argc, kmpc_micro
452 // microtask, ...);
Alexey Bataev23b69422014-06-18 07:08:49 +0000453 llvm::Type *TypeParams[] = {getIdentTyPointerTy(), CGM.Int32Ty,
454 getKmpc_MicroPointerTy()};
Alexey Bataev9959db52014-05-06 10:08:46 +0000455 llvm::FunctionType *FnTy =
Alexey Bataevd74d0602014-10-13 06:02:40 +0000456 llvm::FunctionType::get(CGM.VoidTy, TypeParams, /*isVarArg*/ true);
Alexey Bataev9959db52014-05-06 10:08:46 +0000457 RTLFn = CGM.CreateRuntimeFunction(FnTy, "__kmpc_fork_call");
458 break;
459 }
460 case OMPRTL__kmpc_global_thread_num: {
461 // Build kmp_int32 __kmpc_global_thread_num(ident_t *loc);
Alexey Bataev23b69422014-06-18 07:08:49 +0000462 llvm::Type *TypeParams[] = {getIdentTyPointerTy()};
Alexey Bataev9959db52014-05-06 10:08:46 +0000463 llvm::FunctionType *FnTy =
Alexey Bataevd74d0602014-10-13 06:02:40 +0000464 llvm::FunctionType::get(CGM.Int32Ty, TypeParams, /*isVarArg*/ false);
Alexey Bataev9959db52014-05-06 10:08:46 +0000465 RTLFn = CGM.CreateRuntimeFunction(FnTy, "__kmpc_global_thread_num");
466 break;
467 }
Alexey Bataev97720002014-11-11 04:05:39 +0000468 case OMPRTL__kmpc_threadprivate_cached: {
469 // Build void *__kmpc_threadprivate_cached(ident_t *loc,
470 // kmp_int32 global_tid, void *data, size_t size, void ***cache);
471 llvm::Type *TypeParams[] = {getIdentTyPointerTy(), CGM.Int32Ty,
472 CGM.VoidPtrTy, CGM.SizeTy,
473 CGM.VoidPtrTy->getPointerTo()->getPointerTo()};
474 llvm::FunctionType *FnTy =
475 llvm::FunctionType::get(CGM.VoidPtrTy, TypeParams, /*isVarArg*/ false);
476 RTLFn = CGM.CreateRuntimeFunction(FnTy, "__kmpc_threadprivate_cached");
477 break;
478 }
Alexey Bataev3a3bf0b2014-09-22 10:01:53 +0000479 case OMPRTL__kmpc_critical: {
Alexey Bataevf9472182014-09-22 12:32:31 +0000480 // Build void __kmpc_critical(ident_t *loc, kmp_int32 global_tid,
481 // kmp_critical_name *crit);
Alexey Bataev3a3bf0b2014-09-22 10:01:53 +0000482 llvm::Type *TypeParams[] = {
483 getIdentTyPointerTy(), CGM.Int32Ty,
484 llvm::PointerType::getUnqual(KmpCriticalNameTy)};
485 llvm::FunctionType *FnTy =
486 llvm::FunctionType::get(CGM.VoidTy, TypeParams, /*isVarArg*/ false);
487 RTLFn = CGM.CreateRuntimeFunction(FnTy, "__kmpc_critical");
488 break;
489 }
Alexey Bataev97720002014-11-11 04:05:39 +0000490 case OMPRTL__kmpc_threadprivate_register: {
491 // Build void __kmpc_threadprivate_register(ident_t *, void *data,
492 // kmpc_ctor ctor, kmpc_cctor cctor, kmpc_dtor dtor);
493 // typedef void *(*kmpc_ctor)(void *);
494 auto KmpcCtorTy =
495 llvm::FunctionType::get(CGM.VoidPtrTy, CGM.VoidPtrTy,
496 /*isVarArg*/ false)->getPointerTo();
497 // typedef void *(*kmpc_cctor)(void *, void *);
498 llvm::Type *KmpcCopyCtorTyArgs[] = {CGM.VoidPtrTy, CGM.VoidPtrTy};
499 auto KmpcCopyCtorTy =
500 llvm::FunctionType::get(CGM.VoidPtrTy, KmpcCopyCtorTyArgs,
501 /*isVarArg*/ false)->getPointerTo();
502 // typedef void (*kmpc_dtor)(void *);
503 auto KmpcDtorTy =
504 llvm::FunctionType::get(CGM.VoidTy, CGM.VoidPtrTy, /*isVarArg*/ false)
505 ->getPointerTo();
506 llvm::Type *FnTyArgs[] = {getIdentTyPointerTy(), CGM.VoidPtrTy, KmpcCtorTy,
507 KmpcCopyCtorTy, KmpcDtorTy};
508 auto FnTy = llvm::FunctionType::get(CGM.VoidTy, FnTyArgs,
509 /*isVarArg*/ false);
510 RTLFn = CGM.CreateRuntimeFunction(FnTy, "__kmpc_threadprivate_register");
511 break;
512 }
Alexey Bataev3a3bf0b2014-09-22 10:01:53 +0000513 case OMPRTL__kmpc_end_critical: {
Alexey Bataevf9472182014-09-22 12:32:31 +0000514 // Build void __kmpc_end_critical(ident_t *loc, kmp_int32 global_tid,
515 // kmp_critical_name *crit);
Alexey Bataev3a3bf0b2014-09-22 10:01:53 +0000516 llvm::Type *TypeParams[] = {
517 getIdentTyPointerTy(), CGM.Int32Ty,
518 llvm::PointerType::getUnqual(KmpCriticalNameTy)};
519 llvm::FunctionType *FnTy =
520 llvm::FunctionType::get(CGM.VoidTy, TypeParams, /*isVarArg*/ false);
521 RTLFn = CGM.CreateRuntimeFunction(FnTy, "__kmpc_end_critical");
522 break;
523 }
Alexey Bataev8f7c1b02014-12-05 04:09:23 +0000524 case OMPRTL__kmpc_cancel_barrier: {
525 // Build kmp_int32 __kmpc_cancel_barrier(ident_t *loc, kmp_int32
526 // global_tid);
Alexey Bataev4a5bb772014-10-08 14:01:46 +0000527 llvm::Type *TypeParams[] = {getIdentTyPointerTy(), CGM.Int32Ty};
528 llvm::FunctionType *FnTy =
Alexey Bataev8f7c1b02014-12-05 04:09:23 +0000529 llvm::FunctionType::get(CGM.Int32Ty, TypeParams, /*isVarArg*/ false);
530 RTLFn = CGM.CreateRuntimeFunction(FnTy, /*Name*/ "__kmpc_cancel_barrier");
Alexey Bataev4a5bb772014-10-08 14:01:46 +0000531 break;
532 }
Alexander Musmanc6388682014-12-15 07:07:06 +0000533 case OMPRTL__kmpc_for_static_fini: {
534 // Build void __kmpc_for_static_fini(ident_t *loc, kmp_int32 global_tid);
535 llvm::Type *TypeParams[] = {getIdentTyPointerTy(), CGM.Int32Ty};
536 llvm::FunctionType *FnTy =
537 llvm::FunctionType::get(CGM.VoidTy, TypeParams, /*isVarArg*/ false);
538 RTLFn = CGM.CreateRuntimeFunction(FnTy, "__kmpc_for_static_fini");
539 break;
540 }
Alexey Bataevb2059782014-10-13 08:23:51 +0000541 case OMPRTL__kmpc_push_num_threads: {
542 // Build void __kmpc_push_num_threads(ident_t *loc, kmp_int32 global_tid,
543 // kmp_int32 num_threads)
544 llvm::Type *TypeParams[] = {getIdentTyPointerTy(), CGM.Int32Ty,
545 CGM.Int32Ty};
546 llvm::FunctionType *FnTy =
547 llvm::FunctionType::get(CGM.VoidTy, TypeParams, /*isVarArg*/ false);
548 RTLFn = CGM.CreateRuntimeFunction(FnTy, "__kmpc_push_num_threads");
549 break;
550 }
Alexey Bataevd74d0602014-10-13 06:02:40 +0000551 case OMPRTL__kmpc_serialized_parallel: {
552 // Build void __kmpc_serialized_parallel(ident_t *loc, kmp_int32
553 // global_tid);
554 llvm::Type *TypeParams[] = {getIdentTyPointerTy(), CGM.Int32Ty};
555 llvm::FunctionType *FnTy =
556 llvm::FunctionType::get(CGM.VoidTy, TypeParams, /*isVarArg*/ false);
557 RTLFn = CGM.CreateRuntimeFunction(FnTy, "__kmpc_serialized_parallel");
558 break;
559 }
560 case OMPRTL__kmpc_end_serialized_parallel: {
561 // Build void __kmpc_end_serialized_parallel(ident_t *loc, kmp_int32
562 // global_tid);
563 llvm::Type *TypeParams[] = {getIdentTyPointerTy(), CGM.Int32Ty};
564 llvm::FunctionType *FnTy =
565 llvm::FunctionType::get(CGM.VoidTy, TypeParams, /*isVarArg*/ false);
566 RTLFn = CGM.CreateRuntimeFunction(FnTy, "__kmpc_end_serialized_parallel");
567 break;
568 }
Alexey Bataevcc37cc12014-11-20 04:34:54 +0000569 case OMPRTL__kmpc_flush: {
Alexey Bataevd76df6d2015-02-24 12:55:09 +0000570 // Build void __kmpc_flush(ident_t *loc);
Alexey Bataevcc37cc12014-11-20 04:34:54 +0000571 llvm::Type *TypeParams[] = {getIdentTyPointerTy()};
572 llvm::FunctionType *FnTy =
Alexey Bataevd76df6d2015-02-24 12:55:09 +0000573 llvm::FunctionType::get(CGM.VoidTy, TypeParams, /*isVarArg*/ false);
Alexey Bataevcc37cc12014-11-20 04:34:54 +0000574 RTLFn = CGM.CreateRuntimeFunction(FnTy, "__kmpc_flush");
575 break;
576 }
Alexey Bataev8d690652014-12-04 07:23:53 +0000577 case OMPRTL__kmpc_master: {
578 // Build kmp_int32 __kmpc_master(ident_t *loc, kmp_int32 global_tid);
579 llvm::Type *TypeParams[] = {getIdentTyPointerTy(), CGM.Int32Ty};
580 llvm::FunctionType *FnTy =
581 llvm::FunctionType::get(CGM.Int32Ty, TypeParams, /*isVarArg=*/false);
582 RTLFn = CGM.CreateRuntimeFunction(FnTy, /*Name=*/"__kmpc_master");
583 break;
584 }
585 case OMPRTL__kmpc_end_master: {
586 // Build void __kmpc_end_master(ident_t *loc, kmp_int32 global_tid);
587 llvm::Type *TypeParams[] = {getIdentTyPointerTy(), CGM.Int32Ty};
588 llvm::FunctionType *FnTy =
589 llvm::FunctionType::get(CGM.VoidTy, TypeParams, /*isVarArg=*/false);
590 RTLFn = CGM.CreateRuntimeFunction(FnTy, /*Name=*/"__kmpc_end_master");
591 break;
592 }
Alexey Bataev9f797f32015-02-05 05:57:51 +0000593 case OMPRTL__kmpc_omp_taskyield: {
594 // Build kmp_int32 __kmpc_omp_taskyield(ident_t *, kmp_int32 global_tid,
595 // int end_part);
596 llvm::Type *TypeParams[] = {getIdentTyPointerTy(), CGM.Int32Ty, CGM.IntTy};
597 llvm::FunctionType *FnTy =
598 llvm::FunctionType::get(CGM.Int32Ty, TypeParams, /*isVarArg=*/false);
599 RTLFn = CGM.CreateRuntimeFunction(FnTy, /*Name=*/"__kmpc_omp_taskyield");
600 break;
601 }
Alexey Bataev6956e2e2015-02-05 06:35:41 +0000602 case OMPRTL__kmpc_single: {
603 // Build kmp_int32 __kmpc_single(ident_t *loc, kmp_int32 global_tid);
604 llvm::Type *TypeParams[] = {getIdentTyPointerTy(), CGM.Int32Ty};
605 llvm::FunctionType *FnTy =
606 llvm::FunctionType::get(CGM.Int32Ty, TypeParams, /*isVarArg=*/false);
607 RTLFn = CGM.CreateRuntimeFunction(FnTy, /*Name=*/"__kmpc_single");
608 break;
609 }
610 case OMPRTL__kmpc_end_single: {
611 // Build void __kmpc_end_single(ident_t *loc, kmp_int32 global_tid);
612 llvm::Type *TypeParams[] = {getIdentTyPointerTy(), CGM.Int32Ty};
613 llvm::FunctionType *FnTy =
614 llvm::FunctionType::get(CGM.VoidTy, TypeParams, /*isVarArg=*/false);
615 RTLFn = CGM.CreateRuntimeFunction(FnTy, /*Name=*/"__kmpc_end_single");
616 break;
617 }
Alexey Bataev62b63b12015-03-10 07:28:44 +0000618 case OMPRTL__kmpc_omp_task_alloc: {
619 // Build kmp_task_t *__kmpc_omp_task_alloc(ident_t *, kmp_int32 gtid,
620 // kmp_int32 flags, size_t sizeof_kmp_task_t, size_t sizeof_shareds,
621 // kmp_routine_entry_t *task_entry);
622 assert(KmpRoutineEntryPtrTy != nullptr &&
623 "Type kmp_routine_entry_t must be created.");
624 llvm::Type *TypeParams[] = {getIdentTyPointerTy(), CGM.Int32Ty, CGM.Int32Ty,
625 CGM.SizeTy, CGM.SizeTy, KmpRoutineEntryPtrTy};
626 // Return void * and then cast to particular kmp_task_t type.
627 llvm::FunctionType *FnTy =
628 llvm::FunctionType::get(CGM.VoidPtrTy, TypeParams, /*isVarArg=*/false);
629 RTLFn = CGM.CreateRuntimeFunction(FnTy, /*Name=*/"__kmpc_omp_task_alloc");
630 break;
631 }
632 case OMPRTL__kmpc_omp_task: {
633 // Build kmp_int32 __kmpc_omp_task(ident_t *, kmp_int32 gtid, kmp_task_t
634 // *new_task);
635 llvm::Type *TypeParams[] = {getIdentTyPointerTy(), CGM.Int32Ty,
636 CGM.VoidPtrTy};
637 llvm::FunctionType *FnTy =
638 llvm::FunctionType::get(CGM.Int32Ty, TypeParams, /*isVarArg=*/false);
639 RTLFn = CGM.CreateRuntimeFunction(FnTy, /*Name=*/"__kmpc_omp_task");
640 break;
641 }
Alexey Bataeva63048e2015-03-23 06:18:07 +0000642 case OMPRTL__kmpc_copyprivate: {
643 // Build void __kmpc_copyprivate(ident_t *loc, kmp_int32 global_tid,
Alexey Bataev66beaa92015-04-30 03:47:32 +0000644 // size_t cpy_size, void *cpy_data, void(*cpy_func)(void *, void *),
Alexey Bataeva63048e2015-03-23 06:18:07 +0000645 // kmp_int32 didit);
646 llvm::Type *CpyTypeParams[] = {CGM.VoidPtrTy, CGM.VoidPtrTy};
647 auto *CpyFnTy =
648 llvm::FunctionType::get(CGM.VoidTy, CpyTypeParams, /*isVarArg=*/false);
Alexey Bataev66beaa92015-04-30 03:47:32 +0000649 llvm::Type *TypeParams[] = {getIdentTyPointerTy(), CGM.Int32Ty, CGM.SizeTy,
Alexey Bataeva63048e2015-03-23 06:18:07 +0000650 CGM.VoidPtrTy, CpyFnTy->getPointerTo(),
651 CGM.Int32Ty};
652 llvm::FunctionType *FnTy =
653 llvm::FunctionType::get(CGM.VoidTy, TypeParams, /*isVarArg=*/false);
654 RTLFn = CGM.CreateRuntimeFunction(FnTy, /*Name=*/"__kmpc_copyprivate");
655 break;
656 }
Alexey Bataev794ba0d2015-04-10 10:43:45 +0000657 case OMPRTL__kmpc_reduce: {
658 // Build kmp_int32 __kmpc_reduce(ident_t *loc, kmp_int32 global_tid,
659 // kmp_int32 num_vars, size_t reduce_size, void *reduce_data, void
660 // (*reduce_func)(void *lhs_data, void *rhs_data), kmp_critical_name *lck);
661 llvm::Type *ReduceTypeParams[] = {CGM.VoidPtrTy, CGM.VoidPtrTy};
662 auto *ReduceFnTy = llvm::FunctionType::get(CGM.VoidTy, ReduceTypeParams,
663 /*isVarArg=*/false);
664 llvm::Type *TypeParams[] = {
665 getIdentTyPointerTy(), CGM.Int32Ty, CGM.Int32Ty, CGM.SizeTy,
666 CGM.VoidPtrTy, ReduceFnTy->getPointerTo(),
667 llvm::PointerType::getUnqual(KmpCriticalNameTy)};
668 llvm::FunctionType *FnTy =
669 llvm::FunctionType::get(CGM.Int32Ty, TypeParams, /*isVarArg=*/false);
670 RTLFn = CGM.CreateRuntimeFunction(FnTy, /*Name=*/"__kmpc_reduce");
671 break;
672 }
673 case OMPRTL__kmpc_reduce_nowait: {
674 // Build kmp_int32 __kmpc_reduce_nowait(ident_t *loc, kmp_int32
675 // global_tid, kmp_int32 num_vars, size_t reduce_size, void *reduce_data,
676 // void (*reduce_func)(void *lhs_data, void *rhs_data), kmp_critical_name
677 // *lck);
678 llvm::Type *ReduceTypeParams[] = {CGM.VoidPtrTy, CGM.VoidPtrTy};
679 auto *ReduceFnTy = llvm::FunctionType::get(CGM.VoidTy, ReduceTypeParams,
680 /*isVarArg=*/false);
681 llvm::Type *TypeParams[] = {
682 getIdentTyPointerTy(), CGM.Int32Ty, CGM.Int32Ty, CGM.SizeTy,
683 CGM.VoidPtrTy, ReduceFnTy->getPointerTo(),
684 llvm::PointerType::getUnqual(KmpCriticalNameTy)};
685 llvm::FunctionType *FnTy =
686 llvm::FunctionType::get(CGM.Int32Ty, TypeParams, /*isVarArg=*/false);
687 RTLFn = CGM.CreateRuntimeFunction(FnTy, /*Name=*/"__kmpc_reduce_nowait");
688 break;
689 }
690 case OMPRTL__kmpc_end_reduce: {
691 // Build void __kmpc_end_reduce(ident_t *loc, kmp_int32 global_tid,
692 // kmp_critical_name *lck);
693 llvm::Type *TypeParams[] = {
694 getIdentTyPointerTy(), CGM.Int32Ty,
695 llvm::PointerType::getUnqual(KmpCriticalNameTy)};
696 llvm::FunctionType *FnTy =
697 llvm::FunctionType::get(CGM.VoidTy, TypeParams, /*isVarArg=*/false);
698 RTLFn = CGM.CreateRuntimeFunction(FnTy, /*Name=*/"__kmpc_end_reduce");
699 break;
700 }
701 case OMPRTL__kmpc_end_reduce_nowait: {
702 // Build __kmpc_end_reduce_nowait(ident_t *loc, kmp_int32 global_tid,
703 // kmp_critical_name *lck);
704 llvm::Type *TypeParams[] = {
705 getIdentTyPointerTy(), CGM.Int32Ty,
706 llvm::PointerType::getUnqual(KmpCriticalNameTy)};
707 llvm::FunctionType *FnTy =
708 llvm::FunctionType::get(CGM.VoidTy, TypeParams, /*isVarArg=*/false);
709 RTLFn =
710 CGM.CreateRuntimeFunction(FnTy, /*Name=*/"__kmpc_end_reduce_nowait");
711 break;
712 }
Alexey Bataev1d677132015-04-22 13:57:31 +0000713 case OMPRTL__kmpc_omp_task_begin_if0: {
714 // Build void __kmpc_omp_task(ident_t *, kmp_int32 gtid, kmp_task_t
715 // *new_task);
716 llvm::Type *TypeParams[] = {getIdentTyPointerTy(), CGM.Int32Ty,
717 CGM.VoidPtrTy};
718 llvm::FunctionType *FnTy =
719 llvm::FunctionType::get(CGM.VoidTy, TypeParams, /*isVarArg=*/false);
720 RTLFn =
721 CGM.CreateRuntimeFunction(FnTy, /*Name=*/"__kmpc_omp_task_begin_if0");
722 break;
723 }
724 case OMPRTL__kmpc_omp_task_complete_if0: {
725 // Build void __kmpc_omp_task(ident_t *, kmp_int32 gtid, kmp_task_t
726 // *new_task);
727 llvm::Type *TypeParams[] = {getIdentTyPointerTy(), CGM.Int32Ty,
728 CGM.VoidPtrTy};
729 llvm::FunctionType *FnTy =
730 llvm::FunctionType::get(CGM.VoidTy, TypeParams, /*isVarArg=*/false);
731 RTLFn = CGM.CreateRuntimeFunction(FnTy,
732 /*Name=*/"__kmpc_omp_task_complete_if0");
733 break;
734 }
Alexey Bataev98eb6e32015-04-22 11:15:40 +0000735 case OMPRTL__kmpc_ordered: {
736 // Build void __kmpc_ordered(ident_t *loc, kmp_int32 global_tid);
737 llvm::Type *TypeParams[] = {getIdentTyPointerTy(), CGM.Int32Ty};
738 llvm::FunctionType *FnTy =
739 llvm::FunctionType::get(CGM.VoidTy, TypeParams, /*isVarArg=*/false);
740 RTLFn = CGM.CreateRuntimeFunction(FnTy, "__kmpc_ordered");
741 break;
742 }
743 case OMPRTL__kmpc_end_ordered: {
744 // Build void __kmpc_ordered(ident_t *loc, kmp_int32 global_tid);
745 llvm::Type *TypeParams[] = {getIdentTyPointerTy(), CGM.Int32Ty};
746 llvm::FunctionType *FnTy =
747 llvm::FunctionType::get(CGM.VoidTy, TypeParams, /*isVarArg=*/false);
748 RTLFn = CGM.CreateRuntimeFunction(FnTy, "__kmpc_end_ordered");
749 break;
750 }
Alexey Bataev8b8e2022015-04-27 05:22:09 +0000751 case OMPRTL__kmpc_omp_taskwait: {
752 // Build kmp_int32 __kmpc_omp_taskwait(ident_t *loc, kmp_int32 global_tid);
753 llvm::Type *TypeParams[] = {getIdentTyPointerTy(), CGM.Int32Ty};
754 llvm::FunctionType *FnTy =
755 llvm::FunctionType::get(CGM.Int32Ty, TypeParams, /*isVarArg=*/false);
756 RTLFn = CGM.CreateRuntimeFunction(FnTy, "__kmpc_omp_taskwait");
757 break;
758 }
Alexey Bataev9959db52014-05-06 10:08:46 +0000759 }
760 return RTLFn;
761}
Alexey Bataev3a3bf0b2014-09-22 10:01:53 +0000762
Alexander Musman21212e42015-03-13 10:38:23 +0000763llvm::Constant *CGOpenMPRuntime::createForStaticInitFunction(unsigned IVSize,
764 bool IVSigned) {
765 assert((IVSize == 32 || IVSize == 64) &&
766 "IV size is not compatible with the omp runtime");
767 auto Name = IVSize == 32 ? (IVSigned ? "__kmpc_for_static_init_4"
768 : "__kmpc_for_static_init_4u")
769 : (IVSigned ? "__kmpc_for_static_init_8"
770 : "__kmpc_for_static_init_8u");
771 auto ITy = IVSize == 32 ? CGM.Int32Ty : CGM.Int64Ty;
772 auto PtrTy = llvm::PointerType::getUnqual(ITy);
773 llvm::Type *TypeParams[] = {
774 getIdentTyPointerTy(), // loc
775 CGM.Int32Ty, // tid
776 CGM.Int32Ty, // schedtype
777 llvm::PointerType::getUnqual(CGM.Int32Ty), // p_lastiter
778 PtrTy, // p_lower
779 PtrTy, // p_upper
780 PtrTy, // p_stride
781 ITy, // incr
782 ITy // chunk
783 };
784 llvm::FunctionType *FnTy =
785 llvm::FunctionType::get(CGM.VoidTy, TypeParams, /*isVarArg*/ false);
786 return CGM.CreateRuntimeFunction(FnTy, Name);
787}
788
Alexander Musman92bdaab2015-03-12 13:37:50 +0000789llvm::Constant *CGOpenMPRuntime::createDispatchInitFunction(unsigned IVSize,
790 bool IVSigned) {
791 assert((IVSize == 32 || IVSize == 64) &&
792 "IV size is not compatible with the omp runtime");
793 auto Name =
794 IVSize == 32
795 ? (IVSigned ? "__kmpc_dispatch_init_4" : "__kmpc_dispatch_init_4u")
796 : (IVSigned ? "__kmpc_dispatch_init_8" : "__kmpc_dispatch_init_8u");
797 auto ITy = IVSize == 32 ? CGM.Int32Ty : CGM.Int64Ty;
798 llvm::Type *TypeParams[] = { getIdentTyPointerTy(), // loc
799 CGM.Int32Ty, // tid
800 CGM.Int32Ty, // schedtype
801 ITy, // lower
802 ITy, // upper
803 ITy, // stride
804 ITy // chunk
805 };
806 llvm::FunctionType *FnTy =
807 llvm::FunctionType::get(CGM.VoidTy, TypeParams, /*isVarArg*/ false);
808 return CGM.CreateRuntimeFunction(FnTy, Name);
809}
810
Alexey Bataev98eb6e32015-04-22 11:15:40 +0000811llvm::Constant *CGOpenMPRuntime::createDispatchFiniFunction(unsigned IVSize,
812 bool IVSigned) {
813 assert((IVSize == 32 || IVSize == 64) &&
814 "IV size is not compatible with the omp runtime");
815 auto Name =
816 IVSize == 32
817 ? (IVSigned ? "__kmpc_dispatch_fini_4" : "__kmpc_dispatch_fini_4u")
818 : (IVSigned ? "__kmpc_dispatch_fini_8" : "__kmpc_dispatch_fini_8u");
819 llvm::Type *TypeParams[] = {
820 getIdentTyPointerTy(), // loc
821 CGM.Int32Ty, // tid
822 };
823 llvm::FunctionType *FnTy =
824 llvm::FunctionType::get(CGM.VoidTy, TypeParams, /*isVarArg=*/false);
825 return CGM.CreateRuntimeFunction(FnTy, Name);
826}
827
Alexander Musman92bdaab2015-03-12 13:37:50 +0000828llvm::Constant *CGOpenMPRuntime::createDispatchNextFunction(unsigned IVSize,
829 bool IVSigned) {
830 assert((IVSize == 32 || IVSize == 64) &&
831 "IV size is not compatible with the omp runtime");
832 auto Name =
833 IVSize == 32
834 ? (IVSigned ? "__kmpc_dispatch_next_4" : "__kmpc_dispatch_next_4u")
835 : (IVSigned ? "__kmpc_dispatch_next_8" : "__kmpc_dispatch_next_8u");
836 auto ITy = IVSize == 32 ? CGM.Int32Ty : CGM.Int64Ty;
837 auto PtrTy = llvm::PointerType::getUnqual(ITy);
838 llvm::Type *TypeParams[] = {
839 getIdentTyPointerTy(), // loc
840 CGM.Int32Ty, // tid
841 llvm::PointerType::getUnqual(CGM.Int32Ty), // p_lastiter
842 PtrTy, // p_lower
843 PtrTy, // p_upper
844 PtrTy // p_stride
845 };
846 llvm::FunctionType *FnTy =
847 llvm::FunctionType::get(CGM.Int32Ty, TypeParams, /*isVarArg*/ false);
848 return CGM.CreateRuntimeFunction(FnTy, Name);
849}
850
Alexey Bataev97720002014-11-11 04:05:39 +0000851llvm::Constant *
852CGOpenMPRuntime::getOrCreateThreadPrivateCache(const VarDecl *VD) {
853 // Lookup the entry, lazily creating it if necessary.
Alexey Bataev3eff5f42015-02-25 08:32:46 +0000854 return getOrCreateInternalVariable(CGM.Int8PtrPtrTy,
Alexey Bataev97720002014-11-11 04:05:39 +0000855 Twine(CGM.getMangledName(VD)) + ".cache.");
856}
857
Alexey Bataev3eff5f42015-02-25 08:32:46 +0000858llvm::Value *CGOpenMPRuntime::getAddrOfThreadPrivate(CodeGenFunction &CGF,
859 const VarDecl *VD,
860 llvm::Value *VDAddr,
861 SourceLocation Loc) {
Alexey Bataev97720002014-11-11 04:05:39 +0000862 auto VarTy = VDAddr->getType()->getPointerElementType();
Alexey Bataev3eff5f42015-02-25 08:32:46 +0000863 llvm::Value *Args[] = {emitUpdateLocation(CGF, Loc), getThreadID(CGF, Loc),
Alexey Bataev97720002014-11-11 04:05:39 +0000864 CGF.Builder.CreatePointerCast(VDAddr, CGM.Int8PtrTy),
865 CGM.getSize(CGM.GetTargetTypeStoreSize(VarTy)),
866 getOrCreateThreadPrivateCache(VD)};
867 return CGF.EmitRuntimeCall(
Alexey Bataev3eff5f42015-02-25 08:32:46 +0000868 createRuntimeFunction(OMPRTL__kmpc_threadprivate_cached), Args);
Alexey Bataev97720002014-11-11 04:05:39 +0000869}
870
Alexey Bataev3eff5f42015-02-25 08:32:46 +0000871void CGOpenMPRuntime::emitThreadPrivateVarInit(
Alexey Bataev97720002014-11-11 04:05:39 +0000872 CodeGenFunction &CGF, llvm::Value *VDAddr, llvm::Value *Ctor,
873 llvm::Value *CopyCtor, llvm::Value *Dtor, SourceLocation Loc) {
874 // Call kmp_int32 __kmpc_global_thread_num(&loc) to init OpenMP runtime
875 // library.
Alexey Bataev3eff5f42015-02-25 08:32:46 +0000876 auto OMPLoc = emitUpdateLocation(CGF, Loc);
877 CGF.EmitRuntimeCall(createRuntimeFunction(OMPRTL__kmpc_global_thread_num),
Alexey Bataev97720002014-11-11 04:05:39 +0000878 OMPLoc);
879 // Call __kmpc_threadprivate_register(&loc, &var, ctor, cctor/*NULL*/, dtor)
880 // to register constructor/destructor for variable.
881 llvm::Value *Args[] = {OMPLoc,
882 CGF.Builder.CreatePointerCast(VDAddr, CGM.VoidPtrTy),
883 Ctor, CopyCtor, Dtor};
Alexey Bataev1e4b7132014-12-03 12:11:24 +0000884 CGF.EmitRuntimeCall(
Alexey Bataev3eff5f42015-02-25 08:32:46 +0000885 createRuntimeFunction(OMPRTL__kmpc_threadprivate_register), Args);
Alexey Bataev97720002014-11-11 04:05:39 +0000886}
887
Alexey Bataev3eff5f42015-02-25 08:32:46 +0000888llvm::Function *CGOpenMPRuntime::emitThreadPrivateVarDefinition(
Alexey Bataev97720002014-11-11 04:05:39 +0000889 const VarDecl *VD, llvm::Value *VDAddr, SourceLocation Loc,
890 bool PerformInit, CodeGenFunction *CGF) {
891 VD = VD->getDefinition(CGM.getContext());
892 if (VD && ThreadPrivateWithDefinition.count(VD) == 0) {
893 ThreadPrivateWithDefinition.insert(VD);
894 QualType ASTTy = VD->getType();
895
896 llvm::Value *Ctor = nullptr, *CopyCtor = nullptr, *Dtor = nullptr;
897 auto Init = VD->getAnyInitializer();
898 if (CGM.getLangOpts().CPlusPlus && PerformInit) {
899 // Generate function that re-emits the declaration's initializer into the
900 // threadprivate copy of the variable VD
901 CodeGenFunction CtorCGF(CGM);
902 FunctionArgList Args;
903 ImplicitParamDecl Dst(CGM.getContext(), /*DC=*/nullptr, SourceLocation(),
904 /*Id=*/nullptr, CGM.getContext().VoidPtrTy);
905 Args.push_back(&Dst);
906
907 auto &FI = CGM.getTypes().arrangeFreeFunctionDeclaration(
908 CGM.getContext().VoidPtrTy, Args, FunctionType::ExtInfo(),
909 /*isVariadic=*/false);
910 auto FTy = CGM.getTypes().GetFunctionType(FI);
911 auto Fn = CGM.CreateGlobalInitOrDestructFunction(
912 FTy, ".__kmpc_global_ctor_.", Loc);
913 CtorCGF.StartFunction(GlobalDecl(), CGM.getContext().VoidPtrTy, Fn, FI,
914 Args, SourceLocation());
915 auto ArgVal = CtorCGF.EmitLoadOfScalar(
916 CtorCGF.GetAddrOfLocalVar(&Dst),
917 /*Volatile=*/false, CGM.PointerAlignInBytes,
918 CGM.getContext().VoidPtrTy, Dst.getLocation());
919 auto Arg = CtorCGF.Builder.CreatePointerCast(
920 ArgVal,
921 CtorCGF.ConvertTypeForMem(CGM.getContext().getPointerType(ASTTy)));
922 CtorCGF.EmitAnyExprToMem(Init, Arg, Init->getType().getQualifiers(),
923 /*IsInitializer=*/true);
924 ArgVal = CtorCGF.EmitLoadOfScalar(
925 CtorCGF.GetAddrOfLocalVar(&Dst),
926 /*Volatile=*/false, CGM.PointerAlignInBytes,
927 CGM.getContext().VoidPtrTy, Dst.getLocation());
928 CtorCGF.Builder.CreateStore(ArgVal, CtorCGF.ReturnValue);
929 CtorCGF.FinishFunction();
930 Ctor = Fn;
931 }
932 if (VD->getType().isDestructedType() != QualType::DK_none) {
933 // Generate function that emits destructor call for the threadprivate copy
934 // of the variable VD
935 CodeGenFunction DtorCGF(CGM);
936 FunctionArgList Args;
937 ImplicitParamDecl Dst(CGM.getContext(), /*DC=*/nullptr, SourceLocation(),
938 /*Id=*/nullptr, CGM.getContext().VoidPtrTy);
939 Args.push_back(&Dst);
940
941 auto &FI = CGM.getTypes().arrangeFreeFunctionDeclaration(
942 CGM.getContext().VoidTy, Args, FunctionType::ExtInfo(),
943 /*isVariadic=*/false);
944 auto FTy = CGM.getTypes().GetFunctionType(FI);
945 auto Fn = CGM.CreateGlobalInitOrDestructFunction(
946 FTy, ".__kmpc_global_dtor_.", Loc);
947 DtorCGF.StartFunction(GlobalDecl(), CGM.getContext().VoidTy, Fn, FI, Args,
948 SourceLocation());
949 auto ArgVal = DtorCGF.EmitLoadOfScalar(
950 DtorCGF.GetAddrOfLocalVar(&Dst),
951 /*Volatile=*/false, CGM.PointerAlignInBytes,
952 CGM.getContext().VoidPtrTy, Dst.getLocation());
953 DtorCGF.emitDestroy(ArgVal, ASTTy,
954 DtorCGF.getDestroyer(ASTTy.isDestructedType()),
955 DtorCGF.needsEHCleanup(ASTTy.isDestructedType()));
956 DtorCGF.FinishFunction();
957 Dtor = Fn;
958 }
959 // Do not emit init function if it is not required.
960 if (!Ctor && !Dtor)
961 return nullptr;
962
963 llvm::Type *CopyCtorTyArgs[] = {CGM.VoidPtrTy, CGM.VoidPtrTy};
964 auto CopyCtorTy =
965 llvm::FunctionType::get(CGM.VoidPtrTy, CopyCtorTyArgs,
966 /*isVarArg=*/false)->getPointerTo();
967 // Copying constructor for the threadprivate variable.
968 // Must be NULL - reserved by runtime, but currently it requires that this
969 // parameter is always NULL. Otherwise it fires assertion.
970 CopyCtor = llvm::Constant::getNullValue(CopyCtorTy);
971 if (Ctor == nullptr) {
972 auto CtorTy = llvm::FunctionType::get(CGM.VoidPtrTy, CGM.VoidPtrTy,
973 /*isVarArg=*/false)->getPointerTo();
974 Ctor = llvm::Constant::getNullValue(CtorTy);
975 }
976 if (Dtor == nullptr) {
977 auto DtorTy = llvm::FunctionType::get(CGM.VoidTy, CGM.VoidPtrTy,
978 /*isVarArg=*/false)->getPointerTo();
979 Dtor = llvm::Constant::getNullValue(DtorTy);
980 }
981 if (!CGF) {
982 auto InitFunctionTy =
983 llvm::FunctionType::get(CGM.VoidTy, /*isVarArg*/ false);
984 auto InitFunction = CGM.CreateGlobalInitOrDestructFunction(
985 InitFunctionTy, ".__omp_threadprivate_init_.");
986 CodeGenFunction InitCGF(CGM);
987 FunctionArgList ArgList;
988 InitCGF.StartFunction(GlobalDecl(), CGM.getContext().VoidTy, InitFunction,
989 CGM.getTypes().arrangeNullaryFunction(), ArgList,
990 Loc);
Alexey Bataev3eff5f42015-02-25 08:32:46 +0000991 emitThreadPrivateVarInit(InitCGF, VDAddr, Ctor, CopyCtor, Dtor, Loc);
Alexey Bataev97720002014-11-11 04:05:39 +0000992 InitCGF.FinishFunction();
993 return InitFunction;
994 }
Alexey Bataev3eff5f42015-02-25 08:32:46 +0000995 emitThreadPrivateVarInit(*CGF, VDAddr, Ctor, CopyCtor, Dtor, Loc);
Alexey Bataev97720002014-11-11 04:05:39 +0000996 }
997 return nullptr;
998}
999
Alexey Bataev1d677132015-04-22 13:57:31 +00001000/// \brief Emits code for OpenMP 'if' clause using specified \a CodeGen
1001/// function. Here is the logic:
1002/// if (Cond) {
1003/// ThenGen();
1004/// } else {
1005/// ElseGen();
1006/// }
1007static void emitOMPIfClause(CodeGenFunction &CGF, const Expr *Cond,
1008 const RegionCodeGenTy &ThenGen,
1009 const RegionCodeGenTy &ElseGen) {
1010 CodeGenFunction::LexicalScope ConditionScope(CGF, Cond->getSourceRange());
1011
1012 // If the condition constant folds and can be elided, try to avoid emitting
1013 // the condition and the dead arm of the if/else.
1014 bool CondConstant;
1015 if (CGF.ConstantFoldsToSimpleInteger(Cond, CondConstant)) {
1016 CodeGenFunction::RunCleanupsScope Scope(CGF);
1017 if (CondConstant) {
1018 ThenGen(CGF);
1019 } else {
1020 ElseGen(CGF);
1021 }
1022 return;
1023 }
1024
1025 // Otherwise, the condition did not fold, or we couldn't elide it. Just
1026 // emit the conditional branch.
1027 auto ThenBlock = CGF.createBasicBlock("omp_if.then");
1028 auto ElseBlock = CGF.createBasicBlock("omp_if.else");
1029 auto ContBlock = CGF.createBasicBlock("omp_if.end");
1030 CGF.EmitBranchOnBoolExpr(Cond, ThenBlock, ElseBlock, /*TrueCount=*/0);
1031
1032 // Emit the 'then' code.
1033 CGF.EmitBlock(ThenBlock);
1034 {
1035 CodeGenFunction::RunCleanupsScope ThenScope(CGF);
1036 ThenGen(CGF);
1037 }
1038 CGF.EmitBranch(ContBlock);
1039 // Emit the 'else' code if present.
1040 {
1041 // There is no need to emit line number for unconditional branch.
1042 auto NL = ApplyDebugLocation::CreateEmpty(CGF);
1043 CGF.EmitBlock(ElseBlock);
1044 }
1045 {
1046 CodeGenFunction::RunCleanupsScope ThenScope(CGF);
1047 ElseGen(CGF);
1048 }
1049 {
1050 // There is no need to emit line number for unconditional branch.
1051 auto NL = ApplyDebugLocation::CreateEmpty(CGF);
1052 CGF.EmitBranch(ContBlock);
1053 }
1054 // Emit the continuation block for code after the if.
1055 CGF.EmitBlock(ContBlock, /*IsFinished=*/true);
Alexey Bataev4a5bb772014-10-08 14:01:46 +00001056}
1057
Alexey Bataev1d677132015-04-22 13:57:31 +00001058void CGOpenMPRuntime::emitParallelCall(CodeGenFunction &CGF, SourceLocation Loc,
1059 llvm::Value *OutlinedFn,
1060 llvm::Value *CapturedStruct,
1061 const Expr *IfCond) {
1062 auto *RTLoc = emitUpdateLocation(CGF, Loc);
1063 auto &&ThenGen =
1064 [this, OutlinedFn, CapturedStruct, RTLoc](CodeGenFunction &CGF) {
1065 // Build call __kmpc_fork_call(loc, 1, microtask,
1066 // captured_struct/*context*/)
1067 llvm::Value *Args[] = {
1068 RTLoc,
1069 CGF.Builder.getInt32(
1070 1), // Number of arguments after 'microtask' argument
1071 // (there is only one additional argument - 'context')
1072 CGF.Builder.CreateBitCast(OutlinedFn, getKmpc_MicroPointerTy()),
1073 CGF.EmitCastToVoidPtr(CapturedStruct)};
1074 auto RTLFn = createRuntimeFunction(OMPRTL__kmpc_fork_call);
1075 CGF.EmitRuntimeCall(RTLFn, Args);
1076 };
1077 auto &&ElseGen = [this, OutlinedFn, CapturedStruct, RTLoc, Loc](
1078 CodeGenFunction &CGF) {
1079 auto ThreadID = getThreadID(CGF, Loc);
1080 // Build calls:
1081 // __kmpc_serialized_parallel(&Loc, GTid);
1082 llvm::Value *Args[] = {RTLoc, ThreadID};
1083 CGF.EmitRuntimeCall(createRuntimeFunction(OMPRTL__kmpc_serialized_parallel),
1084 Args);
Alexey Bataevd74d0602014-10-13 06:02:40 +00001085
Alexey Bataev1d677132015-04-22 13:57:31 +00001086 // OutlinedFn(&GTid, &zero, CapturedStruct);
1087 auto ThreadIDAddr = emitThreadIDAddress(CGF, Loc);
1088 auto Int32Ty = CGF.getContext().getIntTypeForBitwidth(/*DestWidth*/ 32,
1089 /*Signed*/ true);
1090 auto ZeroAddr = CGF.CreateMemTemp(Int32Ty, /*Name*/ ".zero.addr");
1091 CGF.InitTempAlloca(ZeroAddr, CGF.Builder.getInt32(/*C*/ 0));
1092 llvm::Value *OutlinedFnArgs[] = {ThreadIDAddr, ZeroAddr, CapturedStruct};
1093 CGF.EmitCallOrInvoke(OutlinedFn, OutlinedFnArgs);
Alexey Bataevd74d0602014-10-13 06:02:40 +00001094
Alexey Bataev1d677132015-04-22 13:57:31 +00001095 // __kmpc_end_serialized_parallel(&Loc, GTid);
1096 llvm::Value *EndArgs[] = {emitUpdateLocation(CGF, Loc), ThreadID};
1097 CGF.EmitRuntimeCall(
1098 createRuntimeFunction(OMPRTL__kmpc_end_serialized_parallel), EndArgs);
1099 };
1100 if (IfCond) {
1101 emitOMPIfClause(CGF, IfCond, ThenGen, ElseGen);
1102 } else {
1103 CodeGenFunction::RunCleanupsScope Scope(CGF);
1104 ThenGen(CGF);
1105 }
Alexey Bataevd74d0602014-10-13 06:02:40 +00001106}
1107
NAKAMURA Takumi59c74b222014-10-27 08:08:18 +00001108// If we're inside an (outlined) parallel region, use the region info's
Alexey Bataevd74d0602014-10-13 06:02:40 +00001109// thread-ID variable (it is passed in a first argument of the outlined function
1110// as "kmp_int32 *gtid"). Otherwise, if we're not inside parallel region, but in
1111// regular serial code region, get thread ID by calling kmp_int32
1112// kmpc_global_thread_num(ident_t *loc), stash this thread ID in a temporary and
1113// return the address of that temp.
Alexey Bataev3eff5f42015-02-25 08:32:46 +00001114llvm::Value *CGOpenMPRuntime::emitThreadIDAddress(CodeGenFunction &CGF,
Alexey Bataevd74d0602014-10-13 06:02:40 +00001115 SourceLocation Loc) {
1116 if (auto OMPRegionInfo =
1117 dyn_cast_or_null<CGOpenMPRegionInfo>(CGF.CapturedStmtInfo))
Alexey Bataev8cbe0a62015-02-26 10:27:34 +00001118 if (OMPRegionInfo->getThreadIDVariable())
Alexey Bataev62b63b12015-03-10 07:28:44 +00001119 return OMPRegionInfo->getThreadIDVariableLValue(CGF).getAddress();
Alexey Bataev8cbe0a62015-02-26 10:27:34 +00001120
Alexey Bataev3eff5f42015-02-25 08:32:46 +00001121 auto ThreadID = getThreadID(CGF, Loc);
Alexey Bataevd74d0602014-10-13 06:02:40 +00001122 auto Int32Ty =
1123 CGF.getContext().getIntTypeForBitwidth(/*DestWidth*/ 32, /*Signed*/ true);
1124 auto ThreadIDTemp = CGF.CreateMemTemp(Int32Ty, /*Name*/ ".threadid_temp.");
1125 CGF.EmitStoreOfScalar(ThreadID,
1126 CGF.MakeNaturalAlignAddrLValue(ThreadIDTemp, Int32Ty));
1127
1128 return ThreadIDTemp;
1129}
1130
Alexey Bataev97720002014-11-11 04:05:39 +00001131llvm::Constant *
Alexey Bataev3eff5f42015-02-25 08:32:46 +00001132CGOpenMPRuntime::getOrCreateInternalVariable(llvm::Type *Ty,
Alexey Bataev97720002014-11-11 04:05:39 +00001133 const llvm::Twine &Name) {
Alexey Bataev3a3bf0b2014-09-22 10:01:53 +00001134 SmallString<256> Buffer;
1135 llvm::raw_svector_ostream Out(Buffer);
Alexey Bataev97720002014-11-11 04:05:39 +00001136 Out << Name;
1137 auto RuntimeName = Out.str();
David Blaikie13156b62014-11-19 03:06:06 +00001138 auto &Elem = *InternalVars.insert(std::make_pair(RuntimeName, nullptr)).first;
1139 if (Elem.second) {
1140 assert(Elem.second->getType()->getPointerElementType() == Ty &&
Alexey Bataev97720002014-11-11 04:05:39 +00001141 "OMP internal variable has different type than requested");
David Blaikie13156b62014-11-19 03:06:06 +00001142 return &*Elem.second;
Alexey Bataev97720002014-11-11 04:05:39 +00001143 }
Alexey Bataev3a3bf0b2014-09-22 10:01:53 +00001144
David Blaikie13156b62014-11-19 03:06:06 +00001145 return Elem.second = new llvm::GlobalVariable(
1146 CGM.getModule(), Ty, /*IsConstant*/ false,
1147 llvm::GlobalValue::CommonLinkage, llvm::Constant::getNullValue(Ty),
1148 Elem.first());
Alexey Bataev97720002014-11-11 04:05:39 +00001149}
1150
Alexey Bataev3eff5f42015-02-25 08:32:46 +00001151llvm::Value *CGOpenMPRuntime::getCriticalRegionLock(StringRef CriticalName) {
Alexey Bataev97720002014-11-11 04:05:39 +00001152 llvm::Twine Name(".gomp_critical_user_", CriticalName);
Alexey Bataev3eff5f42015-02-25 08:32:46 +00001153 return getOrCreateInternalVariable(KmpCriticalNameTy, Name.concat(".var"));
Alexey Bataev3a3bf0b2014-09-22 10:01:53 +00001154}
1155
Alexey Bataev6f1ffc02015-04-10 04:50:10 +00001156namespace {
Alexey Bataeva744ff52015-05-05 09:24:37 +00001157template <size_t N> class CallEndCleanup : public EHScopeStack::Cleanup {
Alexey Bataev3e6124b2015-04-10 07:48:12 +00001158 llvm::Value *Callee;
Alexey Bataeva744ff52015-05-05 09:24:37 +00001159 llvm::Value *Args[N];
Alexey Bataev6f1ffc02015-04-10 04:50:10 +00001160
1161public:
Alexey Bataeva744ff52015-05-05 09:24:37 +00001162 CallEndCleanup(llvm::Value *Callee, ArrayRef<llvm::Value *> CleanupArgs)
1163 : Callee(Callee) {
1164 assert(CleanupArgs.size() == N);
1165 std::copy(CleanupArgs.begin(), CleanupArgs.end(), std::begin(Args));
1166 }
Alexey Bataev3e6124b2015-04-10 07:48:12 +00001167 void Emit(CodeGenFunction &CGF, Flags /*flags*/) override {
1168 CGF.EmitRuntimeCall(Callee, Args);
1169 }
Alexey Bataev6f1ffc02015-04-10 04:50:10 +00001170};
1171} // namespace
1172
1173void CGOpenMPRuntime::emitCriticalRegion(CodeGenFunction &CGF,
1174 StringRef CriticalName,
1175 const RegionCodeGenTy &CriticalOpGen,
1176 SourceLocation Loc) {
Alexey Bataev75ddfab2014-12-01 11:32:38 +00001177 // __kmpc_critical(ident_t *, gtid, Lock);
1178 // CriticalOpGen();
1179 // __kmpc_end_critical(ident_t *, gtid, Lock);
1180 // Prepare arguments and build a call to __kmpc_critical
Alexey Bataev6f1ffc02015-04-10 04:50:10 +00001181 {
1182 CodeGenFunction::RunCleanupsScope Scope(CGF);
Alexey Bataevd7614fb2015-04-10 06:33:45 +00001183 llvm::Value *Args[] = {emitUpdateLocation(CGF, Loc), getThreadID(CGF, Loc),
1184 getCriticalRegionLock(CriticalName)};
Alexey Bataev6f1ffc02015-04-10 04:50:10 +00001185 CGF.EmitRuntimeCall(createRuntimeFunction(OMPRTL__kmpc_critical), Args);
Alexey Bataev6f1ffc02015-04-10 04:50:10 +00001186 // Build a call to __kmpc_end_critical
Alexey Bataeva744ff52015-05-05 09:24:37 +00001187 CGF.EHStack.pushCleanup<CallEndCleanup<std::extent<decltype(Args)>::value>>(
Alexey Bataev3e6124b2015-04-10 07:48:12 +00001188 NormalAndEHCleanup, createRuntimeFunction(OMPRTL__kmpc_end_critical),
1189 llvm::makeArrayRef(Args));
Alexey Bataev794ba0d2015-04-10 10:43:45 +00001190 emitInlinedDirective(CGF, CriticalOpGen);
Alexey Bataev6f1ffc02015-04-10 04:50:10 +00001191 }
Alexey Bataev3a3bf0b2014-09-22 10:01:53 +00001192}
Alexey Bataev4a5bb772014-10-08 14:01:46 +00001193
Alexey Bataev3eff5f42015-02-25 08:32:46 +00001194static void emitIfStmt(CodeGenFunction &CGF, llvm::Value *IfCond,
Alexey Bataev6f1ffc02015-04-10 04:50:10 +00001195 const RegionCodeGenTy &BodyOpGen) {
Alexey Bataev8d690652014-12-04 07:23:53 +00001196 llvm::Value *CallBool = CGF.EmitScalarConversion(
1197 IfCond,
1198 CGF.getContext().getIntTypeForBitwidth(/*DestWidth=*/32, /*Signed=*/true),
1199 CGF.getContext().BoolTy);
1200
1201 auto *ThenBlock = CGF.createBasicBlock("omp_if.then");
1202 auto *ContBlock = CGF.createBasicBlock("omp_if.end");
1203 // Generate the branch (If-stmt)
1204 CGF.Builder.CreateCondBr(CallBool, ThenBlock, ContBlock);
1205 CGF.EmitBlock(ThenBlock);
Alexey Bataev6f1ffc02015-04-10 04:50:10 +00001206 CGF.CGM.getOpenMPRuntime().emitInlinedDirective(CGF, BodyOpGen);
Alexey Bataev8d690652014-12-04 07:23:53 +00001207 // Emit the rest of bblocks/branches
1208 CGF.EmitBranch(ContBlock);
1209 CGF.EmitBlock(ContBlock, true);
1210}
1211
Alexey Bataev3eff5f42015-02-25 08:32:46 +00001212void CGOpenMPRuntime::emitMasterRegion(CodeGenFunction &CGF,
Alexey Bataev6f1ffc02015-04-10 04:50:10 +00001213 const RegionCodeGenTy &MasterOpGen,
Alexey Bataev3eff5f42015-02-25 08:32:46 +00001214 SourceLocation Loc) {
Alexey Bataev8d690652014-12-04 07:23:53 +00001215 // if(__kmpc_master(ident_t *, gtid)) {
1216 // MasterOpGen();
1217 // __kmpc_end_master(ident_t *, gtid);
1218 // }
1219 // Prepare arguments and build a call to __kmpc_master
Alexey Bataevd7614fb2015-04-10 06:33:45 +00001220 llvm::Value *Args[] = {emitUpdateLocation(CGF, Loc), getThreadID(CGF, Loc)};
Alexey Bataev3eff5f42015-02-25 08:32:46 +00001221 auto *IsMaster =
1222 CGF.EmitRuntimeCall(createRuntimeFunction(OMPRTL__kmpc_master), Args);
Alexey Bataeva744ff52015-05-05 09:24:37 +00001223 typedef CallEndCleanup<std::extent<decltype(Args)>::value>
1224 MasterCallEndCleanup;
Alexey Bataev6f1ffc02015-04-10 04:50:10 +00001225 emitIfStmt(CGF, IsMaster, [&](CodeGenFunction &CGF) -> void {
1226 CodeGenFunction::RunCleanupsScope Scope(CGF);
Alexey Bataeva744ff52015-05-05 09:24:37 +00001227 CGF.EHStack.pushCleanup<MasterCallEndCleanup>(
Alexey Bataev3e6124b2015-04-10 07:48:12 +00001228 NormalAndEHCleanup, createRuntimeFunction(OMPRTL__kmpc_end_master),
1229 llvm::makeArrayRef(Args));
Alexey Bataev794ba0d2015-04-10 10:43:45 +00001230 MasterOpGen(CGF);
Alexey Bataev8d690652014-12-04 07:23:53 +00001231 });
1232}
1233
Alexey Bataev3eff5f42015-02-25 08:32:46 +00001234void CGOpenMPRuntime::emitTaskyieldCall(CodeGenFunction &CGF,
1235 SourceLocation Loc) {
Alexey Bataev9f797f32015-02-05 05:57:51 +00001236 // Build call __kmpc_omp_taskyield(loc, thread_id, 0);
1237 llvm::Value *Args[] = {
Alexey Bataev3eff5f42015-02-25 08:32:46 +00001238 emitUpdateLocation(CGF, Loc), getThreadID(CGF, Loc),
Alexey Bataev9f797f32015-02-05 05:57:51 +00001239 llvm::ConstantInt::get(CGM.IntTy, /*V=*/0, /*isSigned=*/true)};
Alexey Bataev3eff5f42015-02-25 08:32:46 +00001240 CGF.EmitRuntimeCall(createRuntimeFunction(OMPRTL__kmpc_omp_taskyield), Args);
Alexey Bataev9f797f32015-02-05 05:57:51 +00001241}
1242
Alexey Bataeva63048e2015-03-23 06:18:07 +00001243static llvm::Value *emitCopyprivateCopyFunction(
Alexey Bataev420d45b2015-04-14 05:11:24 +00001244 CodeGenModule &CGM, llvm::Type *ArgsType,
1245 ArrayRef<const Expr *> CopyprivateVars, ArrayRef<const Expr *> DestExprs,
1246 ArrayRef<const Expr *> SrcExprs, ArrayRef<const Expr *> AssignmentOps) {
Alexey Bataeva63048e2015-03-23 06:18:07 +00001247 auto &C = CGM.getContext();
1248 // void copy_func(void *LHSArg, void *RHSArg);
1249 FunctionArgList Args;
1250 ImplicitParamDecl LHSArg(C, /*DC=*/nullptr, SourceLocation(), /*Id=*/nullptr,
1251 C.VoidPtrTy);
1252 ImplicitParamDecl RHSArg(C, /*DC=*/nullptr, SourceLocation(), /*Id=*/nullptr,
1253 C.VoidPtrTy);
1254 Args.push_back(&LHSArg);
1255 Args.push_back(&RHSArg);
1256 FunctionType::ExtInfo EI;
1257 auto &CGFI = CGM.getTypes().arrangeFreeFunctionDeclaration(
1258 C.VoidTy, Args, EI, /*isVariadic=*/false);
1259 auto *Fn = llvm::Function::Create(
1260 CGM.getTypes().GetFunctionType(CGFI), llvm::GlobalValue::InternalLinkage,
1261 ".omp.copyprivate.copy_func", &CGM.getModule());
1262 CGM.SetLLVMFunctionAttributes(/*D=*/nullptr, CGFI, Fn);
1263 CodeGenFunction CGF(CGM);
1264 CGF.StartFunction(GlobalDecl(), C.VoidTy, Fn, CGFI, Args);
Alexey Bataev420d45b2015-04-14 05:11:24 +00001265 // Dest = (void*[n])(LHSArg);
Alexey Bataeva63048e2015-03-23 06:18:07 +00001266 // Src = (void*[n])(RHSArg);
1267 auto *LHS = CGF.Builder.CreatePointerBitCastOrAddrSpaceCast(
1268 CGF.Builder.CreateAlignedLoad(CGF.GetAddrOfLocalVar(&LHSArg),
1269 CGF.PointerAlignInBytes),
1270 ArgsType);
1271 auto *RHS = CGF.Builder.CreatePointerBitCastOrAddrSpaceCast(
1272 CGF.Builder.CreateAlignedLoad(CGF.GetAddrOfLocalVar(&RHSArg),
1273 CGF.PointerAlignInBytes),
1274 ArgsType);
1275 // *(Type0*)Dst[0] = *(Type0*)Src[0];
1276 // *(Type1*)Dst[1] = *(Type1*)Src[1];
1277 // ...
1278 // *(Typen*)Dst[n] = *(Typen*)Src[n];
Alexey Bataeva63048e2015-03-23 06:18:07 +00001279 for (unsigned I = 0, E = AssignmentOps.size(); I < E; ++I) {
Alexey Bataev420d45b2015-04-14 05:11:24 +00001280 auto *DestAddr = CGF.Builder.CreatePointerBitCastOrAddrSpaceCast(
1281 CGF.Builder.CreateAlignedLoad(
1282 CGF.Builder.CreateStructGEP(nullptr, LHS, I),
1283 CGM.PointerAlignInBytes),
1284 CGF.ConvertTypeForMem(C.getPointerType(SrcExprs[I]->getType())));
1285 auto *SrcAddr = CGF.Builder.CreatePointerBitCastOrAddrSpaceCast(
1286 CGF.Builder.CreateAlignedLoad(
1287 CGF.Builder.CreateStructGEP(nullptr, RHS, I),
1288 CGM.PointerAlignInBytes),
1289 CGF.ConvertTypeForMem(C.getPointerType(SrcExprs[I]->getType())));
1290 CGF.EmitOMPCopy(CGF, CopyprivateVars[I]->getType(), DestAddr, SrcAddr,
1291 cast<VarDecl>(cast<DeclRefExpr>(DestExprs[I])->getDecl()),
1292 cast<VarDecl>(cast<DeclRefExpr>(SrcExprs[I])->getDecl()),
1293 AssignmentOps[I]);
Alexey Bataeva63048e2015-03-23 06:18:07 +00001294 }
Alexey Bataeva63048e2015-03-23 06:18:07 +00001295 CGF.FinishFunction();
1296 return Fn;
1297}
1298
Alexey Bataev3eff5f42015-02-25 08:32:46 +00001299void CGOpenMPRuntime::emitSingleRegion(CodeGenFunction &CGF,
Alexey Bataev6f1ffc02015-04-10 04:50:10 +00001300 const RegionCodeGenTy &SingleOpGen,
Alexey Bataeva63048e2015-03-23 06:18:07 +00001301 SourceLocation Loc,
1302 ArrayRef<const Expr *> CopyprivateVars,
1303 ArrayRef<const Expr *> SrcExprs,
1304 ArrayRef<const Expr *> DstExprs,
1305 ArrayRef<const Expr *> AssignmentOps) {
1306 assert(CopyprivateVars.size() == SrcExprs.size() &&
1307 CopyprivateVars.size() == DstExprs.size() &&
1308 CopyprivateVars.size() == AssignmentOps.size());
1309 auto &C = CGM.getContext();
1310 // int32 did_it = 0;
Alexey Bataev6956e2e2015-02-05 06:35:41 +00001311 // if(__kmpc_single(ident_t *, gtid)) {
1312 // SingleOpGen();
1313 // __kmpc_end_single(ident_t *, gtid);
Alexey Bataeva63048e2015-03-23 06:18:07 +00001314 // did_it = 1;
Alexey Bataev6956e2e2015-02-05 06:35:41 +00001315 // }
Alexey Bataeva63048e2015-03-23 06:18:07 +00001316 // call __kmpc_copyprivate(ident_t *, gtid, <buf_size>, <copyprivate list>,
1317 // <copy_func>, did_it);
1318
1319 llvm::AllocaInst *DidIt = nullptr;
1320 if (!CopyprivateVars.empty()) {
1321 // int32 did_it = 0;
1322 auto KmpInt32Ty = C.getIntTypeForBitwidth(/*DestWidth=*/32, /*Signed=*/1);
1323 DidIt = CGF.CreateMemTemp(KmpInt32Ty, ".omp.copyprivate.did_it");
Alexey Bataev66beaa92015-04-30 03:47:32 +00001324 CGF.Builder.CreateAlignedStore(CGF.Builder.getInt32(0), DidIt,
1325 DidIt->getAlignment());
Alexey Bataeva63048e2015-03-23 06:18:07 +00001326 }
Alexey Bataev6956e2e2015-02-05 06:35:41 +00001327 // Prepare arguments and build a call to __kmpc_single
Alexey Bataevd7614fb2015-04-10 06:33:45 +00001328 llvm::Value *Args[] = {emitUpdateLocation(CGF, Loc), getThreadID(CGF, Loc)};
Alexey Bataev3eff5f42015-02-25 08:32:46 +00001329 auto *IsSingle =
1330 CGF.EmitRuntimeCall(createRuntimeFunction(OMPRTL__kmpc_single), Args);
Alexey Bataeva744ff52015-05-05 09:24:37 +00001331 typedef CallEndCleanup<std::extent<decltype(Args)>::value>
1332 SingleCallEndCleanup;
Alexey Bataev6f1ffc02015-04-10 04:50:10 +00001333 emitIfStmt(CGF, IsSingle, [&](CodeGenFunction &CGF) -> void {
1334 CodeGenFunction::RunCleanupsScope Scope(CGF);
Alexey Bataeva744ff52015-05-05 09:24:37 +00001335 CGF.EHStack.pushCleanup<SingleCallEndCleanup>(
Alexey Bataev794ba0d2015-04-10 10:43:45 +00001336 NormalAndEHCleanup, createRuntimeFunction(OMPRTL__kmpc_end_single),
1337 llvm::makeArrayRef(Args));
Alexey Bataev6f1ffc02015-04-10 04:50:10 +00001338 SingleOpGen(CGF);
Alexey Bataeva63048e2015-03-23 06:18:07 +00001339 if (DidIt) {
1340 // did_it = 1;
1341 CGF.Builder.CreateAlignedStore(CGF.Builder.getInt32(1), DidIt,
1342 DidIt->getAlignment());
1343 }
Alexey Bataev6956e2e2015-02-05 06:35:41 +00001344 });
Alexey Bataeva63048e2015-03-23 06:18:07 +00001345 // call __kmpc_copyprivate(ident_t *, gtid, <buf_size>, <copyprivate list>,
1346 // <copy_func>, did_it);
1347 if (DidIt) {
1348 llvm::APInt ArraySize(/*unsigned int numBits=*/32, CopyprivateVars.size());
1349 auto CopyprivateArrayTy =
1350 C.getConstantArrayType(C.VoidPtrTy, ArraySize, ArrayType::Normal,
1351 /*IndexTypeQuals=*/0);
1352 // Create a list of all private variables for copyprivate.
1353 auto *CopyprivateList =
1354 CGF.CreateMemTemp(CopyprivateArrayTy, ".omp.copyprivate.cpr_list");
1355 for (unsigned I = 0, E = CopyprivateVars.size(); I < E; ++I) {
David Blaikie1ed728c2015-04-05 22:45:47 +00001356 auto *Elem = CGF.Builder.CreateStructGEP(
1357 CopyprivateList->getAllocatedType(), CopyprivateList, I);
Alexey Bataeva63048e2015-03-23 06:18:07 +00001358 CGF.Builder.CreateAlignedStore(
1359 CGF.Builder.CreatePointerBitCastOrAddrSpaceCast(
1360 CGF.EmitLValue(CopyprivateVars[I]).getAddress(), CGF.VoidPtrTy),
1361 Elem, CGM.PointerAlignInBytes);
1362 }
1363 // Build function that copies private values from single region to all other
1364 // threads in the corresponding parallel region.
1365 auto *CpyFn = emitCopyprivateCopyFunction(
1366 CGM, CGF.ConvertTypeForMem(CopyprivateArrayTy)->getPointerTo(),
Alexey Bataev420d45b2015-04-14 05:11:24 +00001367 CopyprivateVars, SrcExprs, DstExprs, AssignmentOps);
Alexey Bataev66beaa92015-04-30 03:47:32 +00001368 auto *BufSize = llvm::ConstantInt::get(
1369 CGM.SizeTy, C.getTypeSizeInChars(CopyprivateArrayTy).getQuantity());
Alexey Bataeva63048e2015-03-23 06:18:07 +00001370 auto *CL = CGF.Builder.CreatePointerBitCastOrAddrSpaceCast(CopyprivateList,
1371 CGF.VoidPtrTy);
1372 auto *DidItVal =
1373 CGF.Builder.CreateAlignedLoad(DidIt, CGF.PointerAlignInBytes);
1374 llvm::Value *Args[] = {
1375 emitUpdateLocation(CGF, Loc), // ident_t *<loc>
1376 getThreadID(CGF, Loc), // i32 <gtid>
Alexey Bataev66beaa92015-04-30 03:47:32 +00001377 BufSize, // size_t <buf_size>
Alexey Bataeva63048e2015-03-23 06:18:07 +00001378 CL, // void *<copyprivate list>
1379 CpyFn, // void (*) (void *, void *) <copy_func>
1380 DidItVal // i32 did_it
1381 };
1382 CGF.EmitRuntimeCall(createRuntimeFunction(OMPRTL__kmpc_copyprivate), Args);
1383 }
Alexey Bataev6956e2e2015-02-05 06:35:41 +00001384}
1385
Alexey Bataev98eb6e32015-04-22 11:15:40 +00001386void CGOpenMPRuntime::emitOrderedRegion(CodeGenFunction &CGF,
1387 const RegionCodeGenTy &OrderedOpGen,
1388 SourceLocation Loc) {
1389 // __kmpc_ordered(ident_t *, gtid);
1390 // OrderedOpGen();
1391 // __kmpc_end_ordered(ident_t *, gtid);
1392 // Prepare arguments and build a call to __kmpc_ordered
1393 {
1394 CodeGenFunction::RunCleanupsScope Scope(CGF);
1395 llvm::Value *Args[] = {emitUpdateLocation(CGF, Loc), getThreadID(CGF, Loc)};
1396 CGF.EmitRuntimeCall(createRuntimeFunction(OMPRTL__kmpc_ordered), Args);
1397 // Build a call to __kmpc_end_ordered
Alexey Bataeva744ff52015-05-05 09:24:37 +00001398 CGF.EHStack.pushCleanup<CallEndCleanup<std::extent<decltype(Args)>::value>>(
Alexey Bataev98eb6e32015-04-22 11:15:40 +00001399 NormalAndEHCleanup, createRuntimeFunction(OMPRTL__kmpc_end_ordered),
1400 llvm::makeArrayRef(Args));
1401 emitInlinedDirective(CGF, OrderedOpGen);
1402 }
1403}
1404
Alexey Bataev3eff5f42015-02-25 08:32:46 +00001405void CGOpenMPRuntime::emitBarrierCall(CodeGenFunction &CGF, SourceLocation Loc,
Alexey Bataevf2685682015-03-30 04:30:22 +00001406 OpenMPDirectiveKind Kind) {
Alexey Bataev8f7c1b02014-12-05 04:09:23 +00001407 // Build call __kmpc_cancel_barrier(loc, thread_id);
Alexey Bataevf2685682015-03-30 04:30:22 +00001408 OpenMPLocationFlags Flags = OMP_IDENT_KMPC;
1409 if (Kind == OMPD_for) {
1410 Flags =
1411 static_cast<OpenMPLocationFlags>(Flags | OMP_IDENT_BARRIER_IMPL_FOR);
1412 } else if (Kind == OMPD_sections) {
1413 Flags = static_cast<OpenMPLocationFlags>(Flags |
1414 OMP_IDENT_BARRIER_IMPL_SECTIONS);
1415 } else if (Kind == OMPD_single) {
1416 Flags =
1417 static_cast<OpenMPLocationFlags>(Flags | OMP_IDENT_BARRIER_IMPL_SINGLE);
1418 } else if (Kind == OMPD_barrier) {
1419 Flags = static_cast<OpenMPLocationFlags>(Flags | OMP_IDENT_BARRIER_EXPL);
1420 } else {
1421 Flags = static_cast<OpenMPLocationFlags>(Flags | OMP_IDENT_BARRIER_IMPL);
1422 }
Alexey Bataev8f7c1b02014-12-05 04:09:23 +00001423 // Build call __kmpc_cancel_barrier(loc, thread_id);
1424 // Replace __kmpc_barrier() function by __kmpc_cancel_barrier() because this
1425 // one provides the same functionality and adds initial support for
1426 // cancellation constructs introduced in OpenMP 4.0. __kmpc_cancel_barrier()
1427 // is provided default by the runtime library so it safe to make such
1428 // replacement.
Alexey Bataev3eff5f42015-02-25 08:32:46 +00001429 llvm::Value *Args[] = {emitUpdateLocation(CGF, Loc, Flags),
1430 getThreadID(CGF, Loc)};
1431 CGF.EmitRuntimeCall(createRuntimeFunction(OMPRTL__kmpc_cancel_barrier), Args);
Alexey Bataev4a5bb772014-10-08 14:01:46 +00001432}
1433
Alexander Musmanc6388682014-12-15 07:07:06 +00001434/// \brief Schedule types for 'omp for' loops (these enumerators are taken from
1435/// the enum sched_type in kmp.h).
1436enum OpenMPSchedType {
1437 /// \brief Lower bound for default (unordered) versions.
1438 OMP_sch_lower = 32,
1439 OMP_sch_static_chunked = 33,
1440 OMP_sch_static = 34,
1441 OMP_sch_dynamic_chunked = 35,
1442 OMP_sch_guided_chunked = 36,
1443 OMP_sch_runtime = 37,
1444 OMP_sch_auto = 38,
1445 /// \brief Lower bound for 'ordered' versions.
1446 OMP_ord_lower = 64,
1447 /// \brief Lower bound for 'nomerge' versions.
1448 OMP_nm_lower = 160,
1449};
1450
1451/// \brief Map the OpenMP loop schedule to the runtime enumeration.
1452static OpenMPSchedType getRuntimeSchedule(OpenMPScheduleClauseKind ScheduleKind,
1453 bool Chunked) {
1454 switch (ScheduleKind) {
1455 case OMPC_SCHEDULE_static:
1456 return Chunked ? OMP_sch_static_chunked : OMP_sch_static;
1457 case OMPC_SCHEDULE_dynamic:
1458 return OMP_sch_dynamic_chunked;
1459 case OMPC_SCHEDULE_guided:
1460 return OMP_sch_guided_chunked;
1461 case OMPC_SCHEDULE_auto:
1462 return OMP_sch_auto;
1463 case OMPC_SCHEDULE_runtime:
1464 return OMP_sch_runtime;
1465 case OMPC_SCHEDULE_unknown:
1466 assert(!Chunked && "chunk was specified but schedule kind not known");
1467 return OMP_sch_static;
1468 }
1469 llvm_unreachable("Unexpected runtime schedule");
1470}
1471
1472bool CGOpenMPRuntime::isStaticNonchunked(OpenMPScheduleClauseKind ScheduleKind,
1473 bool Chunked) const {
1474 auto Schedule = getRuntimeSchedule(ScheduleKind, Chunked);
1475 return Schedule == OMP_sch_static;
1476}
1477
Alexander Musmandf7a8e22015-01-22 08:49:35 +00001478bool CGOpenMPRuntime::isDynamic(OpenMPScheduleClauseKind ScheduleKind) const {
1479 auto Schedule = getRuntimeSchedule(ScheduleKind, /* Chunked */ false);
1480 assert(Schedule != OMP_sch_static_chunked && "cannot be chunked here");
1481 return Schedule != OMP_sch_static;
1482}
1483
Alexey Bataev3eff5f42015-02-25 08:32:46 +00001484void CGOpenMPRuntime::emitForInit(CodeGenFunction &CGF, SourceLocation Loc,
1485 OpenMPScheduleClauseKind ScheduleKind,
1486 unsigned IVSize, bool IVSigned,
1487 llvm::Value *IL, llvm::Value *LB,
1488 llvm::Value *UB, llvm::Value *ST,
1489 llvm::Value *Chunk) {
Alexander Musmanc6388682014-12-15 07:07:06 +00001490 OpenMPSchedType Schedule = getRuntimeSchedule(ScheduleKind, Chunk != nullptr);
Alexander Musman92bdaab2015-03-12 13:37:50 +00001491 if (Schedule != OMP_sch_static && Schedule != OMP_sch_static_chunked) {
1492 // Call __kmpc_dispatch_init(
1493 // ident_t *loc, kmp_int32 tid, kmp_int32 schedule,
1494 // kmp_int[32|64] lower, kmp_int[32|64] upper,
1495 // kmp_int[32|64] stride, kmp_int[32|64] chunk);
Alexander Musmanc6388682014-12-15 07:07:06 +00001496
Alexander Musman92bdaab2015-03-12 13:37:50 +00001497 // If the Chunk was not specified in the clause - use default value 1.
1498 if (Chunk == nullptr)
1499 Chunk = CGF.Builder.getIntN(IVSize, 1);
1500 llvm::Value *Args[] = { emitUpdateLocation(CGF, Loc, OMP_IDENT_KMPC),
1501 getThreadID(CGF, Loc),
1502 CGF.Builder.getInt32(Schedule), // Schedule type
1503 CGF.Builder.getIntN(IVSize, 0), // Lower
1504 UB, // Upper
1505 CGF.Builder.getIntN(IVSize, 1), // Stride
1506 Chunk // Chunk
1507 };
1508 CGF.EmitRuntimeCall(createDispatchInitFunction(IVSize, IVSigned), Args);
1509 } else {
1510 // Call __kmpc_for_static_init(
1511 // ident_t *loc, kmp_int32 tid, kmp_int32 schedtype,
1512 // kmp_int32 *p_lastiter, kmp_int[32|64] *p_lower,
1513 // kmp_int[32|64] *p_upper, kmp_int[32|64] *p_stride,
1514 // kmp_int[32|64] incr, kmp_int[32|64] chunk);
1515 if (Chunk == nullptr) {
1516 assert(Schedule == OMP_sch_static &&
1517 "expected static non-chunked schedule");
1518 // If the Chunk was not specified in the clause - use default value 1.
1519 Chunk = CGF.Builder.getIntN(IVSize, 1);
1520 } else
1521 assert(Schedule == OMP_sch_static_chunked &&
1522 "expected static chunked schedule");
1523 llvm::Value *Args[] = { emitUpdateLocation(CGF, Loc, OMP_IDENT_KMPC),
1524 getThreadID(CGF, Loc),
1525 CGF.Builder.getInt32(Schedule), // Schedule type
1526 IL, // &isLastIter
1527 LB, // &LB
1528 UB, // &UB
1529 ST, // &Stride
1530 CGF.Builder.getIntN(IVSize, 1), // Incr
1531 Chunk // Chunk
1532 };
Alexander Musman21212e42015-03-13 10:38:23 +00001533 CGF.EmitRuntimeCall(createForStaticInitFunction(IVSize, IVSigned), Args);
Alexander Musman92bdaab2015-03-12 13:37:50 +00001534 }
Alexander Musmanc6388682014-12-15 07:07:06 +00001535}
1536
Alexey Bataev98eb6e32015-04-22 11:15:40 +00001537void CGOpenMPRuntime::emitForStaticFinish(CodeGenFunction &CGF,
1538 SourceLocation Loc) {
Alexander Musmanc6388682014-12-15 07:07:06 +00001539 // Call __kmpc_for_static_fini(ident_t *loc, kmp_int32 tid);
Alexey Bataev3eff5f42015-02-25 08:32:46 +00001540 llvm::Value *Args[] = {emitUpdateLocation(CGF, Loc, OMP_IDENT_KMPC),
1541 getThreadID(CGF, Loc)};
1542 CGF.EmitRuntimeCall(createRuntimeFunction(OMPRTL__kmpc_for_static_fini),
1543 Args);
Alexander Musmanc6388682014-12-15 07:07:06 +00001544}
1545
Alexey Bataev98eb6e32015-04-22 11:15:40 +00001546void CGOpenMPRuntime::emitForOrderedDynamicIterationEnd(CodeGenFunction &CGF,
1547 SourceLocation Loc,
1548 unsigned IVSize,
1549 bool IVSigned) {
1550 // Call __kmpc_for_dynamic_fini_(4|8)[u](ident_t *loc, kmp_int32 tid);
1551 llvm::Value *Args[] = {emitUpdateLocation(CGF, Loc, OMP_IDENT_KMPC),
1552 getThreadID(CGF, Loc)};
1553 CGF.EmitRuntimeCall(createDispatchFiniFunction(IVSize, IVSigned), Args);
1554}
1555
Alexander Musman92bdaab2015-03-12 13:37:50 +00001556llvm::Value *CGOpenMPRuntime::emitForNext(CodeGenFunction &CGF,
1557 SourceLocation Loc, unsigned IVSize,
1558 bool IVSigned, llvm::Value *IL,
1559 llvm::Value *LB, llvm::Value *UB,
1560 llvm::Value *ST) {
1561 // Call __kmpc_dispatch_next(
1562 // ident_t *loc, kmp_int32 tid, kmp_int32 *p_lastiter,
1563 // kmp_int[32|64] *p_lower, kmp_int[32|64] *p_upper,
1564 // kmp_int[32|64] *p_stride);
1565 llvm::Value *Args[] = {
1566 emitUpdateLocation(CGF, Loc, OMP_IDENT_KMPC), getThreadID(CGF, Loc),
1567 IL, // &isLastIter
1568 LB, // &Lower
1569 UB, // &Upper
1570 ST // &Stride
1571 };
1572 llvm::Value *Call =
1573 CGF.EmitRuntimeCall(createDispatchNextFunction(IVSize, IVSigned), Args);
1574 return CGF.EmitScalarConversion(
1575 Call, CGF.getContext().getIntTypeForBitwidth(32, /* Signed */ true),
1576 CGF.getContext().BoolTy);
1577}
1578
Alexey Bataev3eff5f42015-02-25 08:32:46 +00001579void CGOpenMPRuntime::emitNumThreadsClause(CodeGenFunction &CGF,
1580 llvm::Value *NumThreads,
1581 SourceLocation Loc) {
Alexey Bataevb2059782014-10-13 08:23:51 +00001582 // Build call __kmpc_push_num_threads(&loc, global_tid, num_threads)
1583 llvm::Value *Args[] = {
Alexey Bataev3eff5f42015-02-25 08:32:46 +00001584 emitUpdateLocation(CGF, Loc), getThreadID(CGF, Loc),
Alexey Bataevb2059782014-10-13 08:23:51 +00001585 CGF.Builder.CreateIntCast(NumThreads, CGF.Int32Ty, /*isSigned*/ true)};
Alexey Bataev3eff5f42015-02-25 08:32:46 +00001586 CGF.EmitRuntimeCall(createRuntimeFunction(OMPRTL__kmpc_push_num_threads),
1587 Args);
Alexey Bataevb2059782014-10-13 08:23:51 +00001588}
1589
Alexey Bataev3eff5f42015-02-25 08:32:46 +00001590void CGOpenMPRuntime::emitFlush(CodeGenFunction &CGF, ArrayRef<const Expr *>,
1591 SourceLocation Loc) {
Alexey Bataevd76df6d2015-02-24 12:55:09 +00001592 // Build call void __kmpc_flush(ident_t *loc)
Alexey Bataev3eff5f42015-02-25 08:32:46 +00001593 CGF.EmitRuntimeCall(createRuntimeFunction(OMPRTL__kmpc_flush),
1594 emitUpdateLocation(CGF, Loc));
Alexey Bataevcc37cc12014-11-20 04:34:54 +00001595}
Alexey Bataev3eff5f42015-02-25 08:32:46 +00001596
Alexey Bataev62b63b12015-03-10 07:28:44 +00001597namespace {
1598/// \brief Indexes of fields for type kmp_task_t.
1599enum KmpTaskTFields {
1600 /// \brief List of shared variables.
1601 KmpTaskTShareds,
1602 /// \brief Task routine.
1603 KmpTaskTRoutine,
1604 /// \brief Partition id for the untied tasks.
1605 KmpTaskTPartId,
1606 /// \brief Function with call of destructors for private variables.
1607 KmpTaskTDestructors,
1608};
1609} // namespace
1610
1611void CGOpenMPRuntime::emitKmpRoutineEntryT(QualType KmpInt32Ty) {
1612 if (!KmpRoutineEntryPtrTy) {
1613 // Build typedef kmp_int32 (* kmp_routine_entry_t)(kmp_int32, void *); type.
1614 auto &C = CGM.getContext();
1615 QualType KmpRoutineEntryTyArgs[] = {KmpInt32Ty, C.VoidPtrTy};
1616 FunctionProtoType::ExtProtoInfo EPI;
1617 KmpRoutineEntryPtrQTy = C.getPointerType(
1618 C.getFunctionType(KmpInt32Ty, KmpRoutineEntryTyArgs, EPI));
1619 KmpRoutineEntryPtrTy = CGM.getTypes().ConvertType(KmpRoutineEntryPtrQTy);
1620 }
1621}
1622
1623static void addFieldToRecordDecl(ASTContext &C, DeclContext *DC,
1624 QualType FieldTy) {
1625 auto *Field = FieldDecl::Create(
1626 C, DC, SourceLocation(), SourceLocation(), /*Id=*/nullptr, FieldTy,
1627 C.getTrivialTypeSourceInfo(FieldTy, SourceLocation()),
1628 /*BW=*/nullptr, /*Mutable=*/false, /*InitStyle=*/ICIS_NoInit);
1629 Field->setAccess(AS_public);
1630 DC->addDecl(Field);
1631}
1632
Alexey Bataev36c1eb92015-04-30 06:51:57 +00001633namespace {
Alexey Bataev9e034042015-05-05 04:05:12 +00001634struct PrivateHelpersTy {
1635 PrivateHelpersTy(const VarDecl *Original, const VarDecl *PrivateCopy,
1636 const VarDecl *PrivateElemInit)
1637 : Original(Original), PrivateCopy(PrivateCopy),
1638 PrivateElemInit(PrivateElemInit) {}
1639 const VarDecl *Original;
1640 const VarDecl *PrivateCopy;
1641 const VarDecl *PrivateElemInit;
1642};
1643typedef std::pair<CharUnits /*Align*/, PrivateHelpersTy> PrivateDataTy;
Alexey Bataev36c1eb92015-04-30 06:51:57 +00001644} // namespace
1645
Alexey Bataev9e034042015-05-05 04:05:12 +00001646static RecordDecl *
1647createPrivatesRecordDecl(CodeGenModule &CGM,
1648 const ArrayRef<PrivateDataTy> Privates) {
Alexey Bataev36c1eb92015-04-30 06:51:57 +00001649 if (!Privates.empty()) {
1650 auto &C = CGM.getContext();
1651 // Build struct .kmp_privates_t. {
1652 // /* private vars */
1653 // };
1654 auto *RD = C.buildImplicitRecord(".kmp_privates.t");
1655 RD->startDefinition();
1656 for (auto &&Pair : Privates) {
Alexey Bataev9e034042015-05-05 04:05:12 +00001657 addFieldToRecordDecl(
1658 C, RD, Pair.second.Original->getType().getNonReferenceType());
Alexey Bataev36c1eb92015-04-30 06:51:57 +00001659 }
Alexey Bataev36c1eb92015-04-30 06:51:57 +00001660 RD->completeDefinition();
1661 return RD;
1662 }
1663 return nullptr;
1664}
1665
Alexey Bataev9e034042015-05-05 04:05:12 +00001666static RecordDecl *
1667createKmpTaskTRecordDecl(CodeGenModule &CGM, QualType KmpInt32Ty,
Alexey Bataev8fc69dc2015-05-18 07:54:53 +00001668 QualType KmpRoutineEntryPointerQTy) {
Alexey Bataev62b63b12015-03-10 07:28:44 +00001669 auto &C = CGM.getContext();
1670 // Build struct kmp_task_t {
1671 // void * shareds;
1672 // kmp_routine_entry_t routine;
1673 // kmp_int32 part_id;
1674 // kmp_routine_entry_t destructors;
Alexey Bataev62b63b12015-03-10 07:28:44 +00001675 // };
1676 auto *RD = C.buildImplicitRecord("kmp_task_t");
1677 RD->startDefinition();
1678 addFieldToRecordDecl(C, RD, C.VoidPtrTy);
1679 addFieldToRecordDecl(C, RD, KmpRoutineEntryPointerQTy);
1680 addFieldToRecordDecl(C, RD, KmpInt32Ty);
1681 addFieldToRecordDecl(C, RD, KmpRoutineEntryPointerQTy);
Alexey Bataev8fc69dc2015-05-18 07:54:53 +00001682 RD->completeDefinition();
1683 return RD;
1684}
1685
1686static RecordDecl *
1687createKmpTaskTWithPrivatesRecordDecl(CodeGenModule &CGM, QualType KmpTaskTQTy,
1688 const ArrayRef<PrivateDataTy> Privates) {
1689 auto &C = CGM.getContext();
1690 // Build struct kmp_task_t_with_privates {
1691 // kmp_task_t task_data;
1692 // .kmp_privates_t. privates;
1693 // };
1694 auto *RD = C.buildImplicitRecord("kmp_task_t_with_privates");
1695 RD->startDefinition();
1696 addFieldToRecordDecl(C, RD, KmpTaskTQTy);
Alexey Bataev36c1eb92015-04-30 06:51:57 +00001697 if (auto *PrivateRD = createPrivatesRecordDecl(CGM, Privates)) {
1698 addFieldToRecordDecl(C, RD, C.getRecordType(PrivateRD));
1699 }
Alexey Bataev62b63b12015-03-10 07:28:44 +00001700 RD->completeDefinition();
Alexey Bataev36c1eb92015-04-30 06:51:57 +00001701 return RD;
Alexey Bataev62b63b12015-03-10 07:28:44 +00001702}
1703
1704/// \brief Emit a proxy function which accepts kmp_task_t as the second
1705/// argument.
1706/// \code
1707/// kmp_int32 .omp_task_entry.(kmp_int32 gtid, kmp_task_t *tt) {
1708/// TaskFunction(gtid, tt->part_id, tt->shareds);
1709/// return 0;
1710/// }
1711/// \endcode
1712static llvm::Value *
1713emitProxyTaskFunction(CodeGenModule &CGM, SourceLocation Loc,
Alexey Bataev8fc69dc2015-05-18 07:54:53 +00001714 QualType KmpInt32Ty, QualType KmpTaskTWithPrivatesPtrQTy,
1715 QualType KmpTaskTWithPrivatesQTy, QualType KmpTaskTQTy,
1716 QualType SharedsPtrTy, llvm::Value *TaskFunction) {
Alexey Bataev62b63b12015-03-10 07:28:44 +00001717 auto &C = CGM.getContext();
1718 FunctionArgList Args;
1719 ImplicitParamDecl GtidArg(C, /*DC=*/nullptr, Loc, /*Id=*/nullptr, KmpInt32Ty);
1720 ImplicitParamDecl TaskTypeArg(C, /*DC=*/nullptr, Loc,
Alexey Bataev8fc69dc2015-05-18 07:54:53 +00001721 /*Id=*/nullptr, KmpTaskTWithPrivatesPtrQTy);
Alexey Bataev62b63b12015-03-10 07:28:44 +00001722 Args.push_back(&GtidArg);
1723 Args.push_back(&TaskTypeArg);
1724 FunctionType::ExtInfo Info;
1725 auto &TaskEntryFnInfo =
1726 CGM.getTypes().arrangeFreeFunctionDeclaration(KmpInt32Ty, Args, Info,
1727 /*isVariadic=*/false);
1728 auto *TaskEntryTy = CGM.getTypes().GetFunctionType(TaskEntryFnInfo);
1729 auto *TaskEntry =
1730 llvm::Function::Create(TaskEntryTy, llvm::GlobalValue::InternalLinkage,
1731 ".omp_task_entry.", &CGM.getModule());
1732 CGM.SetLLVMFunctionAttributes(/*D=*/nullptr, TaskEntryFnInfo, TaskEntry);
1733 CodeGenFunction CGF(CGM);
1734 CGF.disableDebugInfo();
1735 CGF.StartFunction(GlobalDecl(), KmpInt32Ty, TaskEntry, TaskEntryFnInfo, Args);
1736
Alexey Bataev8fc69dc2015-05-18 07:54:53 +00001737 // TaskFunction(gtid, tt->task_data.part_id, tt->task_data.shareds);
Alexey Bataev62b63b12015-03-10 07:28:44 +00001738 auto *GtidParam = CGF.EmitLoadOfScalar(
1739 CGF.GetAddrOfLocalVar(&GtidArg), /*Volatile=*/false,
1740 C.getTypeAlignInChars(KmpInt32Ty).getQuantity(), KmpInt32Ty, Loc);
Alexey Bataev8fc69dc2015-05-18 07:54:53 +00001741 auto *TaskTypeArgAddr = CGF.Builder.CreateAlignedLoad(
1742 CGF.GetAddrOfLocalVar(&TaskTypeArg), CGM.PointerAlignInBytes);
1743 LValue Base =
1744 CGF.MakeNaturalAlignAddrLValue(TaskTypeArgAddr, KmpTaskTWithPrivatesQTy);
1745 auto *KmpTaskTWithPrivatesQTyRD =
1746 cast<RecordDecl>(KmpTaskTWithPrivatesQTy->getAsTagDecl());
1747 Base =
1748 CGF.EmitLValueForField(Base, *KmpTaskTWithPrivatesQTyRD->field_begin());
1749 auto *KmpTaskTQTyRD = cast<RecordDecl>(KmpTaskTQTy->getAsTagDecl());
1750 auto PartIdFI = std::next(KmpTaskTQTyRD->field_begin(), KmpTaskTPartId);
1751 auto PartIdLVal = CGF.EmitLValueForField(Base, *PartIdFI);
1752 auto *PartidParam = CGF.EmitLoadOfLValue(PartIdLVal, Loc).getScalarVal();
1753
1754 auto SharedsFI = std::next(KmpTaskTQTyRD->field_begin(), KmpTaskTShareds);
1755 auto SharedsLVal = CGF.EmitLValueForField(Base, *SharedsFI);
Alexey Bataev36c1eb92015-04-30 06:51:57 +00001756 auto *SharedsParam = CGF.Builder.CreatePointerBitCastOrAddrSpaceCast(
Alexey Bataev8fc69dc2015-05-18 07:54:53 +00001757 CGF.EmitLoadOfLValue(SharedsLVal, Loc).getScalarVal(),
Alexey Bataev36c1eb92015-04-30 06:51:57 +00001758 CGF.ConvertTypeForMem(SharedsPtrTy));
1759
1760 llvm::Value *CallArgs[] = {GtidParam, PartidParam, SharedsParam};
Alexey Bataev62b63b12015-03-10 07:28:44 +00001761 CGF.EmitCallOrInvoke(TaskFunction, CallArgs);
1762 CGF.EmitStoreThroughLValue(
1763 RValue::get(CGF.Builder.getInt32(/*C=*/0)),
1764 CGF.MakeNaturalAlignAddrLValue(CGF.ReturnValue, KmpInt32Ty));
1765 CGF.FinishFunction();
1766 return TaskEntry;
1767}
1768
Alexey Bataev8fc69dc2015-05-18 07:54:53 +00001769static llvm::Value *emitDestructorsFunction(CodeGenModule &CGM,
1770 SourceLocation Loc,
1771 QualType KmpInt32Ty,
1772 QualType KmpTaskTWithPrivatesPtrQTy,
1773 QualType KmpTaskTWithPrivatesQTy) {
Alexey Bataev62b63b12015-03-10 07:28:44 +00001774 auto &C = CGM.getContext();
Alexey Bataev36c1eb92015-04-30 06:51:57 +00001775 FunctionArgList Args;
1776 ImplicitParamDecl GtidArg(C, /*DC=*/nullptr, Loc, /*Id=*/nullptr, KmpInt32Ty);
1777 ImplicitParamDecl TaskTypeArg(C, /*DC=*/nullptr, Loc,
Alexey Bataev8fc69dc2015-05-18 07:54:53 +00001778 /*Id=*/nullptr, KmpTaskTWithPrivatesPtrQTy);
Alexey Bataev36c1eb92015-04-30 06:51:57 +00001779 Args.push_back(&GtidArg);
1780 Args.push_back(&TaskTypeArg);
1781 FunctionType::ExtInfo Info;
1782 auto &DestructorFnInfo =
1783 CGM.getTypes().arrangeFreeFunctionDeclaration(KmpInt32Ty, Args, Info,
1784 /*isVariadic=*/false);
1785 auto *DestructorFnTy = CGM.getTypes().GetFunctionType(DestructorFnInfo);
1786 auto *DestructorFn =
1787 llvm::Function::Create(DestructorFnTy, llvm::GlobalValue::InternalLinkage,
1788 ".omp_task_destructor.", &CGM.getModule());
1789 CGM.SetLLVMFunctionAttributes(/*D=*/nullptr, DestructorFnInfo, DestructorFn);
1790 CodeGenFunction CGF(CGM);
1791 CGF.disableDebugInfo();
1792 CGF.StartFunction(GlobalDecl(), KmpInt32Ty, DestructorFn, DestructorFnInfo,
1793 Args);
1794
Alexey Bataev8fc69dc2015-05-18 07:54:53 +00001795 auto *TaskTypeArgAddr = CGF.Builder.CreateAlignedLoad(
1796 CGF.GetAddrOfLocalVar(&TaskTypeArg), CGM.PointerAlignInBytes);
1797 LValue Base =
1798 CGF.MakeNaturalAlignAddrLValue(TaskTypeArgAddr, KmpTaskTWithPrivatesQTy);
1799 auto *KmpTaskTWithPrivatesQTyRD =
1800 cast<RecordDecl>(KmpTaskTWithPrivatesQTy->getAsTagDecl());
1801 auto FI = std::next(KmpTaskTWithPrivatesQTyRD->field_begin());
Alexey Bataev36c1eb92015-04-30 06:51:57 +00001802 Base = CGF.EmitLValueForField(Base, *FI);
1803 for (auto *Field :
1804 cast<RecordDecl>(FI->getType()->getAsTagDecl())->fields()) {
1805 if (auto DtorKind = Field->getType().isDestructedType()) {
1806 auto FieldLValue = CGF.EmitLValueForField(Base, Field);
1807 CGF.pushDestroy(DtorKind, FieldLValue.getAddress(), Field->getType());
1808 }
1809 }
1810 CGF.FinishFunction();
1811 return DestructorFn;
1812}
1813
Alexey Bataev9e034042015-05-05 04:05:12 +00001814static int array_pod_sort_comparator(const PrivateDataTy *P1,
1815 const PrivateDataTy *P2) {
Alexey Bataev36c1eb92015-04-30 06:51:57 +00001816 return P1->first < P2->first ? 1 : (P2->first < P1->first ? -1 : 0);
1817}
1818
1819void CGOpenMPRuntime::emitTaskCall(
1820 CodeGenFunction &CGF, SourceLocation Loc, const OMPExecutableDirective &D,
1821 bool Tied, llvm::PointerIntPair<llvm::Value *, 1, bool> Final,
1822 llvm::Value *TaskFunction, QualType SharedsTy, llvm::Value *Shareds,
1823 const Expr *IfCond, const ArrayRef<const Expr *> PrivateVars,
Alexey Bataev9e034042015-05-05 04:05:12 +00001824 const ArrayRef<const Expr *> PrivateCopies,
1825 const ArrayRef<const Expr *> FirstprivateVars,
1826 const ArrayRef<const Expr *> FirstprivateCopies,
1827 const ArrayRef<const Expr *> FirstprivateInits) {
Alexey Bataev36c1eb92015-04-30 06:51:57 +00001828 auto &C = CGM.getContext();
Alexey Bataev9e034042015-05-05 04:05:12 +00001829 llvm::SmallVector<PrivateDataTy, 8> Privates;
Alexey Bataev36c1eb92015-04-30 06:51:57 +00001830 // Aggeregate privates and sort them by the alignment.
Alexey Bataev9e034042015-05-05 04:05:12 +00001831 auto I = PrivateCopies.begin();
Alexey Bataev36c1eb92015-04-30 06:51:57 +00001832 for (auto *E : PrivateVars) {
1833 auto *VD = cast<VarDecl>(cast<DeclRefExpr>(E)->getDecl());
1834 Privates.push_back(std::make_pair(
1835 C.getTypeAlignInChars(VD->getType()),
Alexey Bataev9e034042015-05-05 04:05:12 +00001836 PrivateHelpersTy(VD, cast<VarDecl>(cast<DeclRefExpr>(*I)->getDecl()),
1837 /*PrivateElemInit=*/nullptr)));
Alexey Bataev36c1eb92015-04-30 06:51:57 +00001838 ++I;
1839 }
Alexey Bataev9e034042015-05-05 04:05:12 +00001840 I = FirstprivateCopies.begin();
1841 auto IElemInitRef = FirstprivateInits.begin();
1842 for (auto *E : FirstprivateVars) {
1843 auto *VD = cast<VarDecl>(cast<DeclRefExpr>(E)->getDecl());
1844 Privates.push_back(std::make_pair(
1845 C.getTypeAlignInChars(VD->getType()),
1846 PrivateHelpersTy(
1847 VD, cast<VarDecl>(cast<DeclRefExpr>(*I)->getDecl()),
1848 cast<VarDecl>(cast<DeclRefExpr>(*IElemInitRef)->getDecl()))));
1849 ++I, ++IElemInitRef;
1850 }
Alexey Bataev36c1eb92015-04-30 06:51:57 +00001851 llvm::array_pod_sort(Privates.begin(), Privates.end(),
1852 array_pod_sort_comparator);
Alexey Bataev62b63b12015-03-10 07:28:44 +00001853 auto KmpInt32Ty = C.getIntTypeForBitwidth(/*DestWidth=*/32, /*Signed=*/1);
1854 // Build type kmp_routine_entry_t (if not built yet).
1855 emitKmpRoutineEntryT(KmpInt32Ty);
Alexey Bataev8fc69dc2015-05-18 07:54:53 +00001856 // Build type kmp_task_t (if not built yet).
1857 if (KmpTaskTQTy.isNull()) {
1858 KmpTaskTQTy = C.getRecordType(
1859 createKmpTaskTRecordDecl(CGM, KmpInt32Ty, KmpRoutineEntryPtrQTy));
1860 }
1861 auto *KmpTaskTQTyRD = cast<RecordDecl>(KmpTaskTQTy->getAsTagDecl());
Alexey Bataev62b63b12015-03-10 07:28:44 +00001862 // Build particular struct kmp_task_t for the given task.
Alexey Bataev8fc69dc2015-05-18 07:54:53 +00001863 auto *KmpTaskTWithPrivatesQTyRD =
1864 createKmpTaskTWithPrivatesRecordDecl(CGM, KmpTaskTQTy, Privates);
1865 auto KmpTaskTWithPrivatesQTy = C.getRecordType(KmpTaskTWithPrivatesQTyRD);
1866 QualType KmpTaskTWithPrivatesPtrQTy =
1867 C.getPointerType(KmpTaskTWithPrivatesQTy);
1868 auto *KmpTaskTWithPrivatesTy = CGF.ConvertType(KmpTaskTWithPrivatesQTy);
1869 auto *KmpTaskTWithPrivatesPtrTy = KmpTaskTWithPrivatesTy->getPointerTo();
1870 auto KmpTaskTWithPrivatesTySize =
1871 CGM.getSize(C.getTypeSizeInChars(KmpTaskTWithPrivatesQTy));
Alexey Bataev62b63b12015-03-10 07:28:44 +00001872 QualType SharedsPtrTy = C.getPointerType(SharedsTy);
1873
1874 // Build a proxy function kmp_int32 .omp_task_entry.(kmp_int32 gtid,
1875 // kmp_task_t *tt);
Alexey Bataev8fc69dc2015-05-18 07:54:53 +00001876 auto *TaskEntry = emitProxyTaskFunction(
1877 CGM, Loc, KmpInt32Ty, KmpTaskTWithPrivatesPtrQTy, KmpTaskTWithPrivatesQTy,
1878 KmpTaskTQTy, SharedsPtrTy, TaskFunction);
Alexey Bataev62b63b12015-03-10 07:28:44 +00001879
1880 // Build call kmp_task_t * __kmpc_omp_task_alloc(ident_t *, kmp_int32 gtid,
1881 // kmp_int32 flags, size_t sizeof_kmp_task_t, size_t sizeof_shareds,
1882 // kmp_routine_entry_t *task_entry);
1883 // Task flags. Format is taken from
1884 // http://llvm.org/svn/llvm-project/openmp/trunk/runtime/src/kmp.h,
1885 // description of kmp_tasking_flags struct.
1886 const unsigned TiedFlag = 0x1;
1887 const unsigned FinalFlag = 0x2;
1888 unsigned Flags = Tied ? TiedFlag : 0;
1889 auto *TaskFlags =
1890 Final.getPointer()
1891 ? CGF.Builder.CreateSelect(Final.getPointer(),
1892 CGF.Builder.getInt32(FinalFlag),
1893 CGF.Builder.getInt32(/*C=*/0))
1894 : CGF.Builder.getInt32(Final.getInt() ? FinalFlag : 0);
1895 TaskFlags = CGF.Builder.CreateOr(TaskFlags, CGF.Builder.getInt32(Flags));
1896 auto SharedsSize = C.getTypeSizeInChars(SharedsTy);
Alexey Bataev8fc69dc2015-05-18 07:54:53 +00001897 llvm::Value *AllocArgs[] = {
1898 emitUpdateLocation(CGF, Loc), getThreadID(CGF, Loc), TaskFlags,
1899 KmpTaskTWithPrivatesTySize, CGM.getSize(SharedsSize),
1900 CGF.Builder.CreatePointerBitCastOrAddrSpaceCast(TaskEntry,
1901 KmpRoutineEntryPtrTy)};
Alexey Bataev62b63b12015-03-10 07:28:44 +00001902 auto *NewTask = CGF.EmitRuntimeCall(
1903 createRuntimeFunction(OMPRTL__kmpc_omp_task_alloc), AllocArgs);
Alexey Bataev8fc69dc2015-05-18 07:54:53 +00001904 auto *NewTaskNewTaskTTy = CGF.Builder.CreatePointerBitCastOrAddrSpaceCast(
1905 NewTask, KmpTaskTWithPrivatesPtrTy);
1906 LValue Base = CGF.MakeNaturalAlignAddrLValue(NewTaskNewTaskTTy,
1907 KmpTaskTWithPrivatesQTy);
1908 LValue TDBase =
1909 CGF.EmitLValueForField(Base, *KmpTaskTWithPrivatesQTyRD->field_begin());
Alexey Bataev62b63b12015-03-10 07:28:44 +00001910 // Fill the data in the resulting kmp_task_t record.
1911 // Copy shareds if there are any.
Alexey Bataev8fc69dc2015-05-18 07:54:53 +00001912 llvm::Value *KmpTaskSharedsPtr = nullptr;
1913 if (!SharedsTy->getAsStructureType()->getDecl()->field_empty()) {
1914 KmpTaskSharedsPtr = CGF.EmitLoadOfScalar(
1915 CGF.EmitLValueForField(
1916 TDBase, *std::next(KmpTaskTQTyRD->field_begin(), KmpTaskTShareds)),
1917 Loc);
Alexey Bataev36c1eb92015-04-30 06:51:57 +00001918 CGF.EmitAggregateCopy(KmpTaskSharedsPtr, Shareds, SharedsTy);
Alexey Bataev8fc69dc2015-05-18 07:54:53 +00001919 }
Alexey Bataev36c1eb92015-04-30 06:51:57 +00001920 // Emit initial values for private copies (if any).
1921 bool NeedsCleanup = false;
1922 if (!Privates.empty()) {
Alexey Bataev8fc69dc2015-05-18 07:54:53 +00001923 auto FI = std::next(KmpTaskTWithPrivatesQTyRD->field_begin());
1924 auto PrivatesBase = CGF.EmitLValueForField(Base, *FI);
Alexey Bataev36c1eb92015-04-30 06:51:57 +00001925 FI = cast<RecordDecl>(FI->getType()->getAsTagDecl())->field_begin();
1926 LValue SharedsBase = CGF.MakeNaturalAlignAddrLValue(
1927 CGF.Builder.CreatePointerBitCastOrAddrSpaceCast(
1928 KmpTaskSharedsPtr, CGF.ConvertTypeForMem(SharedsPtrTy)),
1929 SharedsTy);
1930 CodeGenFunction::CGCapturedStmtInfo CapturesInfo(
1931 cast<CapturedStmt>(*D.getAssociatedStmt()));
1932 for (auto &&Pair : Privates) {
Alexey Bataev9e034042015-05-05 04:05:12 +00001933 auto *VD = Pair.second.PrivateCopy;
Alexey Bataev36c1eb92015-04-30 06:51:57 +00001934 auto *Init = VD->getAnyInitializer();
Alexey Bataev8fc69dc2015-05-18 07:54:53 +00001935 LValue PrivateLValue = CGF.EmitLValueForField(PrivatesBase, *FI);
Alexey Bataev36c1eb92015-04-30 06:51:57 +00001936 if (Init) {
Alexey Bataev9e034042015-05-05 04:05:12 +00001937 if (auto *Elem = Pair.second.PrivateElemInit) {
1938 auto *OriginalVD = Pair.second.Original;
1939 auto *SharedField = CapturesInfo.lookup(OriginalVD);
1940 auto SharedRefLValue =
1941 CGF.EmitLValueForField(SharedsBase, SharedField);
1942 if (OriginalVD->getType()->isArrayType()) {
1943 // Initialize firstprivate array.
1944 if (!isa<CXXConstructExpr>(Init) ||
1945 CGF.isTrivialInitializer(Init)) {
1946 // Perform simple memcpy.
1947 CGF.EmitAggregateAssign(PrivateLValue.getAddress(),
1948 SharedRefLValue.getAddress(),
1949 OriginalVD->getType());
1950 } else {
1951 // Initialize firstprivate array using element-by-element
1952 // intialization.
1953 CGF.EmitOMPAggregateAssign(
1954 PrivateLValue.getAddress(), SharedRefLValue.getAddress(),
1955 OriginalVD->getType(),
1956 [&CGF, Elem, Init, &CapturesInfo](llvm::Value *DestElement,
1957 llvm::Value *SrcElement) {
1958 // Clean up any temporaries needed by the initialization.
1959 CodeGenFunction::OMPPrivateScope InitScope(CGF);
1960 InitScope.addPrivate(Elem, [SrcElement]() -> llvm::Value *{
1961 return SrcElement;
1962 });
1963 (void)InitScope.Privatize();
1964 // Emit initialization for single element.
1965 auto *OldCapturedStmtInfo = CGF.CapturedStmtInfo;
1966 CGF.CapturedStmtInfo = &CapturesInfo;
1967 CGF.EmitAnyExprToMem(Init, DestElement,
1968 Init->getType().getQualifiers(),
1969 /*IsInitializer=*/false);
1970 CGF.CapturedStmtInfo = OldCapturedStmtInfo;
1971 });
1972 }
1973 } else {
1974 CodeGenFunction::OMPPrivateScope InitScope(CGF);
1975 InitScope.addPrivate(Elem, [SharedRefLValue]() -> llvm::Value *{
1976 return SharedRefLValue.getAddress();
1977 });
1978 (void)InitScope.Privatize();
1979 auto *OldCapturedStmtInfo = CGF.CapturedStmtInfo;
1980 CGF.CapturedStmtInfo = &CapturesInfo;
1981 CGF.EmitExprAsInit(Init, VD, PrivateLValue,
1982 /*capturedByInit=*/false);
1983 CGF.CapturedStmtInfo = OldCapturedStmtInfo;
1984 }
1985 } else {
1986 CGF.EmitExprAsInit(Init, VD, PrivateLValue, /*capturedByInit=*/false);
1987 }
Alexey Bataev36c1eb92015-04-30 06:51:57 +00001988 }
1989 NeedsCleanup = NeedsCleanup || FI->getType().isDestructedType();
1990 // Copy addresses of privates to corresponding references in the list of
1991 // captured variables.
1992 // ...
1993 // tt->shareds.var_addr = &tt->privates.private_var;
1994 // ...
Alexey Bataev9e034042015-05-05 04:05:12 +00001995 auto *OriginalVD = Pair.second.Original;
Alexey Bataev36c1eb92015-04-30 06:51:57 +00001996 auto *SharedField = CapturesInfo.lookup(OriginalVD);
1997 auto SharedRefLValue =
1998 CGF.EmitLValueForFieldInitialization(SharedsBase, SharedField);
1999 CGF.EmitStoreThroughLValue(RValue::get(PrivateLValue.getAddress()),
2000 SharedRefLValue);
2001 ++FI, ++I;
2002 }
2003 }
Alexey Bataev62b63b12015-03-10 07:28:44 +00002004 // Provide pointer to function with destructors for privates.
Alexey Bataev36c1eb92015-04-30 06:51:57 +00002005 llvm::Value *DestructorFn =
Alexey Bataev8fc69dc2015-05-18 07:54:53 +00002006 NeedsCleanup ? emitDestructorsFunction(CGM, Loc, KmpInt32Ty,
2007 KmpTaskTWithPrivatesPtrQTy,
2008 KmpTaskTWithPrivatesQTy)
2009 : llvm::ConstantPointerNull::get(
2010 cast<llvm::PointerType>(KmpRoutineEntryPtrTy));
2011 LValue Destructor = CGF.EmitLValueForField(
2012 TDBase, *std::next(KmpTaskTQTyRD->field_begin(), KmpTaskTDestructors));
2013 CGF.EmitStoreOfScalar(CGF.Builder.CreatePointerBitCastOrAddrSpaceCast(
2014 DestructorFn, KmpRoutineEntryPtrTy),
2015 Destructor);
Alexey Bataev62b63b12015-03-10 07:28:44 +00002016 // NOTE: routine and part_id fields are intialized by __kmpc_omp_task_alloc()
2017 // libcall.
2018 // Build kmp_int32 __kmpc_omp_task(ident_t *, kmp_int32 gtid, kmp_task_t
2019 // *new_task);
Alexey Bataev1d677132015-04-22 13:57:31 +00002020 auto *ThreadID = getThreadID(CGF, Loc);
2021 llvm::Value *TaskArgs[] = {emitUpdateLocation(CGF, Loc), ThreadID, NewTask};
2022 auto &&ThenCodeGen = [this, &TaskArgs](CodeGenFunction &CGF) {
2023 // TODO: add check for untied tasks.
2024 CGF.EmitRuntimeCall(createRuntimeFunction(OMPRTL__kmpc_omp_task), TaskArgs);
2025 };
Alexey Bataeva744ff52015-05-05 09:24:37 +00002026 typedef CallEndCleanup<std::extent<decltype(TaskArgs)>::value>
2027 IfCallEndCleanup;
Alexey Bataev1d677132015-04-22 13:57:31 +00002028 auto &&ElseCodeGen =
2029 [this, &TaskArgs, ThreadID, NewTaskNewTaskTTy, TaskEntry](
2030 CodeGenFunction &CGF) {
2031 CodeGenFunction::RunCleanupsScope LocalScope(CGF);
2032 CGF.EmitRuntimeCall(
2033 createRuntimeFunction(OMPRTL__kmpc_omp_task_begin_if0), TaskArgs);
2034 // Build void __kmpc_omp_task_complete_if0(ident_t *, kmp_int32 gtid,
2035 // kmp_task_t *new_task);
Alexey Bataeva744ff52015-05-05 09:24:37 +00002036 CGF.EHStack.pushCleanup<IfCallEndCleanup>(
Alexey Bataev1d677132015-04-22 13:57:31 +00002037 NormalAndEHCleanup,
2038 createRuntimeFunction(OMPRTL__kmpc_omp_task_complete_if0),
2039 llvm::makeArrayRef(TaskArgs));
2040
2041 // Call proxy_task_entry(gtid, new_task);
2042 llvm::Value *OutlinedFnArgs[] = {ThreadID, NewTaskNewTaskTTy};
2043 CGF.EmitCallOrInvoke(TaskEntry, OutlinedFnArgs);
2044 };
2045 if (IfCond) {
2046 emitOMPIfClause(CGF, IfCond, ThenCodeGen, ElseCodeGen);
2047 } else {
2048 CodeGenFunction::RunCleanupsScope Scope(CGF);
2049 ThenCodeGen(CGF);
2050 }
Alexey Bataev62b63b12015-03-10 07:28:44 +00002051}
2052
Alexey Bataev794ba0d2015-04-10 10:43:45 +00002053static llvm::Value *emitReductionFunction(CodeGenModule &CGM,
2054 llvm::Type *ArgsType,
2055 ArrayRef<const Expr *> LHSExprs,
2056 ArrayRef<const Expr *> RHSExprs,
2057 ArrayRef<const Expr *> ReductionOps) {
2058 auto &C = CGM.getContext();
2059
2060 // void reduction_func(void *LHSArg, void *RHSArg);
2061 FunctionArgList Args;
2062 ImplicitParamDecl LHSArg(C, /*DC=*/nullptr, SourceLocation(), /*Id=*/nullptr,
2063 C.VoidPtrTy);
2064 ImplicitParamDecl RHSArg(C, /*DC=*/nullptr, SourceLocation(), /*Id=*/nullptr,
2065 C.VoidPtrTy);
2066 Args.push_back(&LHSArg);
2067 Args.push_back(&RHSArg);
2068 FunctionType::ExtInfo EI;
2069 auto &CGFI = CGM.getTypes().arrangeFreeFunctionDeclaration(
2070 C.VoidTy, Args, EI, /*isVariadic=*/false);
2071 auto *Fn = llvm::Function::Create(
2072 CGM.getTypes().GetFunctionType(CGFI), llvm::GlobalValue::InternalLinkage,
2073 ".omp.reduction.reduction_func", &CGM.getModule());
2074 CGM.SetLLVMFunctionAttributes(/*D=*/nullptr, CGFI, Fn);
2075 CodeGenFunction CGF(CGM);
2076 CGF.StartFunction(GlobalDecl(), C.VoidTy, Fn, CGFI, Args);
2077
2078 // Dst = (void*[n])(LHSArg);
2079 // Src = (void*[n])(RHSArg);
2080 auto *LHS = CGF.Builder.CreatePointerBitCastOrAddrSpaceCast(
2081 CGF.Builder.CreateAlignedLoad(CGF.GetAddrOfLocalVar(&LHSArg),
2082 CGF.PointerAlignInBytes),
2083 ArgsType);
2084 auto *RHS = CGF.Builder.CreatePointerBitCastOrAddrSpaceCast(
2085 CGF.Builder.CreateAlignedLoad(CGF.GetAddrOfLocalVar(&RHSArg),
2086 CGF.PointerAlignInBytes),
2087 ArgsType);
2088
2089 // ...
2090 // *(Type<i>*)lhs[i] = RedOp<i>(*(Type<i>*)lhs[i], *(Type<i>*)rhs[i]);
2091 // ...
2092 CodeGenFunction::OMPPrivateScope Scope(CGF);
2093 for (unsigned I = 0, E = ReductionOps.size(); I < E; ++I) {
2094 Scope.addPrivate(
2095 cast<VarDecl>(cast<DeclRefExpr>(RHSExprs[I])->getDecl()),
2096 [&]() -> llvm::Value *{
2097 return CGF.Builder.CreatePointerBitCastOrAddrSpaceCast(
2098 CGF.Builder.CreateAlignedLoad(
2099 CGF.Builder.CreateStructGEP(/*Ty=*/nullptr, RHS, I),
2100 CGM.PointerAlignInBytes),
2101 CGF.ConvertTypeForMem(C.getPointerType(RHSExprs[I]->getType())));
2102 });
2103 Scope.addPrivate(
2104 cast<VarDecl>(cast<DeclRefExpr>(LHSExprs[I])->getDecl()),
2105 [&]() -> llvm::Value *{
2106 return CGF.Builder.CreatePointerBitCastOrAddrSpaceCast(
2107 CGF.Builder.CreateAlignedLoad(
2108 CGF.Builder.CreateStructGEP(/*Ty=*/nullptr, LHS, I),
2109 CGM.PointerAlignInBytes),
2110 CGF.ConvertTypeForMem(C.getPointerType(LHSExprs[I]->getType())));
2111 });
2112 }
2113 Scope.Privatize();
2114 for (auto *E : ReductionOps) {
2115 CGF.EmitIgnoredExpr(E);
2116 }
2117 Scope.ForceCleanup();
2118 CGF.FinishFunction();
2119 return Fn;
2120}
2121
2122void CGOpenMPRuntime::emitReduction(CodeGenFunction &CGF, SourceLocation Loc,
2123 ArrayRef<const Expr *> LHSExprs,
2124 ArrayRef<const Expr *> RHSExprs,
2125 ArrayRef<const Expr *> ReductionOps,
2126 bool WithNowait) {
2127 // Next code should be emitted for reduction:
2128 //
2129 // static kmp_critical_name lock = { 0 };
2130 //
2131 // void reduce_func(void *lhs[<n>], void *rhs[<n>]) {
2132 // *(Type0*)lhs[0] = ReductionOperation0(*(Type0*)lhs[0], *(Type0*)rhs[0]);
2133 // ...
2134 // *(Type<n>-1*)lhs[<n>-1] = ReductionOperation<n>-1(*(Type<n>-1*)lhs[<n>-1],
2135 // *(Type<n>-1*)rhs[<n>-1]);
2136 // }
2137 //
2138 // ...
2139 // void *RedList[<n>] = {&<RHSExprs>[0], ..., &<RHSExprs>[<n>-1]};
2140 // switch (__kmpc_reduce{_nowait}(<loc>, <gtid>, <n>, sizeof(RedList),
2141 // RedList, reduce_func, &<lock>)) {
2142 // case 1:
2143 // ...
2144 // <LHSExprs>[i] = RedOp<i>(*<LHSExprs>[i], *<RHSExprs>[i]);
2145 // ...
2146 // __kmpc_end_reduce{_nowait}(<loc>, <gtid>, &<lock>);
2147 // break;
2148 // case 2:
2149 // ...
2150 // Atomic(<LHSExprs>[i] = RedOp<i>(*<LHSExprs>[i], *<RHSExprs>[i]));
2151 // ...
Alexey Bataev69a47792015-05-07 03:54:03 +00002152 // [__kmpc_end_reduce(<loc>, <gtid>, &<lock>);]
Alexey Bataev794ba0d2015-04-10 10:43:45 +00002153 // break;
2154 // default:;
2155 // }
2156
2157 auto &C = CGM.getContext();
2158
2159 // 1. Build a list of reduction variables.
2160 // void *RedList[<n>] = {<ReductionVars>[0], ..., <ReductionVars>[<n>-1]};
2161 llvm::APInt ArraySize(/*unsigned int numBits=*/32, RHSExprs.size());
2162 QualType ReductionArrayTy =
2163 C.getConstantArrayType(C.VoidPtrTy, ArraySize, ArrayType::Normal,
2164 /*IndexTypeQuals=*/0);
2165 auto *ReductionList =
2166 CGF.CreateMemTemp(ReductionArrayTy, ".omp.reduction.red_list");
2167 for (unsigned I = 0, E = RHSExprs.size(); I < E; ++I) {
2168 auto *Elem = CGF.Builder.CreateStructGEP(/*Ty=*/nullptr, ReductionList, I);
2169 CGF.Builder.CreateAlignedStore(
2170 CGF.Builder.CreatePointerBitCastOrAddrSpaceCast(
2171 CGF.EmitLValue(RHSExprs[I]).getAddress(), CGF.VoidPtrTy),
2172 Elem, CGM.PointerAlignInBytes);
2173 }
2174
2175 // 2. Emit reduce_func().
2176 auto *ReductionFn = emitReductionFunction(
2177 CGM, CGF.ConvertTypeForMem(ReductionArrayTy)->getPointerTo(), LHSExprs,
2178 RHSExprs, ReductionOps);
2179
2180 // 3. Create static kmp_critical_name lock = { 0 };
2181 auto *Lock = getCriticalRegionLock(".reduction");
2182
2183 // 4. Build res = __kmpc_reduce{_nowait}(<loc>, <gtid>, <n>, sizeof(RedList),
2184 // RedList, reduce_func, &<lock>);
2185 auto *IdentTLoc = emitUpdateLocation(
2186 CGF, Loc,
2187 static_cast<OpenMPLocationFlags>(OMP_IDENT_KMPC | OMP_ATOMIC_REDUCE));
2188 auto *ThreadId = getThreadID(CGF, Loc);
2189 auto *ReductionArrayTySize = llvm::ConstantInt::get(
2190 CGM.SizeTy, C.getTypeSizeInChars(ReductionArrayTy).getQuantity());
2191 auto *RL = CGF.Builder.CreatePointerBitCastOrAddrSpaceCast(ReductionList,
2192 CGF.VoidPtrTy);
2193 llvm::Value *Args[] = {
2194 IdentTLoc, // ident_t *<loc>
2195 ThreadId, // i32 <gtid>
2196 CGF.Builder.getInt32(RHSExprs.size()), // i32 <n>
2197 ReductionArrayTySize, // size_type sizeof(RedList)
2198 RL, // void *RedList
2199 ReductionFn, // void (*) (void *, void *) <reduce_func>
2200 Lock // kmp_critical_name *&<lock>
2201 };
2202 auto Res = CGF.EmitRuntimeCall(
2203 createRuntimeFunction(WithNowait ? OMPRTL__kmpc_reduce_nowait
2204 : OMPRTL__kmpc_reduce),
2205 Args);
2206
2207 // 5. Build switch(res)
2208 auto *DefaultBB = CGF.createBasicBlock(".omp.reduction.default");
2209 auto *SwInst = CGF.Builder.CreateSwitch(Res, DefaultBB, /*NumCases=*/2);
2210
2211 // 6. Build case 1:
2212 // ...
2213 // <LHSExprs>[i] = RedOp<i>(*<LHSExprs>[i], *<RHSExprs>[i]);
2214 // ...
2215 // __kmpc_end_reduce{_nowait}(<loc>, <gtid>, &<lock>);
2216 // break;
2217 auto *Case1BB = CGF.createBasicBlock(".omp.reduction.case1");
2218 SwInst->addCase(CGF.Builder.getInt32(1), Case1BB);
2219 CGF.EmitBlock(Case1BB);
2220
2221 {
2222 CodeGenFunction::RunCleanupsScope Scope(CGF);
2223 // Add emission of __kmpc_end_reduce{_nowait}(<loc>, <gtid>, &<lock>);
2224 llvm::Value *EndArgs[] = {
2225 IdentTLoc, // ident_t *<loc>
2226 ThreadId, // i32 <gtid>
2227 Lock // kmp_critical_name *&<lock>
2228 };
Alexey Bataeva744ff52015-05-05 09:24:37 +00002229 CGF.EHStack
2230 .pushCleanup<CallEndCleanup<std::extent<decltype(EndArgs)>::value>>(
2231 NormalAndEHCleanup,
2232 createRuntimeFunction(WithNowait ? OMPRTL__kmpc_end_reduce_nowait
2233 : OMPRTL__kmpc_end_reduce),
2234 llvm::makeArrayRef(EndArgs));
Alexey Bataev794ba0d2015-04-10 10:43:45 +00002235 for (auto *E : ReductionOps) {
2236 CGF.EmitIgnoredExpr(E);
2237 }
2238 }
2239
2240 CGF.EmitBranch(DefaultBB);
2241
2242 // 7. Build case 2:
2243 // ...
2244 // Atomic(<LHSExprs>[i] = RedOp<i>(*<LHSExprs>[i], *<RHSExprs>[i]));
2245 // ...
2246 // break;
2247 auto *Case2BB = CGF.createBasicBlock(".omp.reduction.case2");
2248 SwInst->addCase(CGF.Builder.getInt32(2), Case2BB);
2249 CGF.EmitBlock(Case2BB);
2250
2251 {
2252 CodeGenFunction::RunCleanupsScope Scope(CGF);
Alexey Bataev69a47792015-05-07 03:54:03 +00002253 if (!WithNowait) {
2254 // Add emission of __kmpc_end_reduce(<loc>, <gtid>, &<lock>);
2255 llvm::Value *EndArgs[] = {
2256 IdentTLoc, // ident_t *<loc>
2257 ThreadId, // i32 <gtid>
2258 Lock // kmp_critical_name *&<lock>
2259 };
2260 CGF.EHStack
2261 .pushCleanup<CallEndCleanup<std::extent<decltype(EndArgs)>::value>>(
2262 NormalAndEHCleanup,
2263 createRuntimeFunction(OMPRTL__kmpc_end_reduce),
2264 llvm::makeArrayRef(EndArgs));
2265 }
Alexey Bataev794ba0d2015-04-10 10:43:45 +00002266 auto I = LHSExprs.begin();
2267 for (auto *E : ReductionOps) {
2268 const Expr *XExpr = nullptr;
2269 const Expr *EExpr = nullptr;
2270 const Expr *UpExpr = nullptr;
2271 BinaryOperatorKind BO = BO_Comma;
Alexey Bataev794ba0d2015-04-10 10:43:45 +00002272 if (auto *BO = dyn_cast<BinaryOperator>(E)) {
2273 if (BO->getOpcode() == BO_Assign) {
2274 XExpr = BO->getLHS();
2275 UpExpr = BO->getRHS();
2276 }
2277 }
Alexey Bataev69a47792015-05-07 03:54:03 +00002278 // Try to emit update expression as a simple atomic.
2279 auto *RHSExpr = UpExpr;
2280 if (RHSExpr) {
2281 // Analyze RHS part of the whole expression.
2282 if (auto *ACO = dyn_cast<AbstractConditionalOperator>(
2283 RHSExpr->IgnoreParenImpCasts())) {
2284 // If this is a conditional operator, analyze its condition for
2285 // min/max reduction operator.
2286 RHSExpr = ACO->getCond();
2287 }
Alexey Bataev794ba0d2015-04-10 10:43:45 +00002288 if (auto *BORHS =
Alexey Bataev69a47792015-05-07 03:54:03 +00002289 dyn_cast<BinaryOperator>(RHSExpr->IgnoreParenImpCasts())) {
Alexey Bataev794ba0d2015-04-10 10:43:45 +00002290 EExpr = BORHS->getRHS();
2291 BO = BORHS->getOpcode();
2292 }
2293 }
2294 if (XExpr) {
2295 auto *VD = cast<VarDecl>(cast<DeclRefExpr>(*I)->getDecl());
2296 LValue X = CGF.EmitLValue(XExpr);
2297 RValue E;
2298 if (EExpr)
2299 E = CGF.EmitAnyExpr(EExpr);
2300 CGF.EmitOMPAtomicSimpleUpdateExpr(
2301 X, E, BO, /*IsXLHSInRHSPart=*/true, llvm::Monotonic, Loc,
2302 [&CGF, UpExpr, VD](RValue XRValue) {
2303 CodeGenFunction::OMPPrivateScope PrivateScope(CGF);
2304 PrivateScope.addPrivate(
2305 VD, [&CGF, VD, XRValue]() -> llvm::Value *{
2306 auto *LHSTemp = CGF.CreateMemTemp(VD->getType());
2307 CGF.EmitStoreThroughLValue(
2308 XRValue,
2309 CGF.MakeNaturalAlignAddrLValue(LHSTemp, VD->getType()));
2310 return LHSTemp;
2311 });
2312 (void)PrivateScope.Privatize();
2313 return CGF.EmitAnyExpr(UpExpr);
2314 });
2315 } else {
2316 // Emit as a critical region.
2317 emitCriticalRegion(CGF, ".atomic_reduction", [E](CodeGenFunction &CGF) {
2318 CGF.EmitIgnoredExpr(E);
2319 }, Loc);
2320 }
2321 ++I;
2322 }
2323 }
2324
2325 CGF.EmitBranch(DefaultBB);
2326 CGF.EmitBlock(DefaultBB, /*IsFinished=*/true);
2327}
2328
Alexey Bataev8b8e2022015-04-27 05:22:09 +00002329void CGOpenMPRuntime::emitTaskwaitCall(CodeGenFunction &CGF,
2330 SourceLocation Loc) {
2331 // Build call kmp_int32 __kmpc_omp_taskwait(ident_t *loc, kmp_int32
2332 // global_tid);
2333 llvm::Value *Args[] = {emitUpdateLocation(CGF, Loc), getThreadID(CGF, Loc)};
2334 // Ignore return result until untied tasks are supported.
2335 CGF.EmitRuntimeCall(createRuntimeFunction(OMPRTL__kmpc_omp_taskwait), Args);
2336}
2337
Alexey Bataev6f1ffc02015-04-10 04:50:10 +00002338void CGOpenMPRuntime::emitInlinedDirective(CodeGenFunction &CGF,
2339 const RegionCodeGenTy &CodeGen) {
2340 InlinedOpenMPRegionRAII Region(CGF, CodeGen);
2341 CGF.CapturedStmtInfo->EmitBody(CGF, /*S=*/nullptr);
Alexey Bataev8cbe0a62015-02-26 10:27:34 +00002342}
2343