1 | //===- MLIRContext.cpp - MLIR Type Classes --------------------------------===// |
2 | // |
3 | // Part of the LLVM Project, under the Apache License v2.0 with LLVM Exceptions. |
4 | // See https://llvm.org/LICENSE.txt for license information. |
5 | // SPDX-License-Identifier: Apache-2.0 WITH LLVM-exception |
6 | // |
7 | //===----------------------------------------------------------------------===// |
8 | |
9 | #include "mlir/IR/MLIRContext.h" |
10 | #include "AffineExprDetail.h" |
11 | #include "AffineMapDetail.h" |
12 | #include "AttributeDetail.h" |
13 | #include "IntegerSetDetail.h" |
14 | #include "TypeDetail.h" |
15 | #include "mlir/IR/Action.h" |
16 | #include "mlir/IR/AffineExpr.h" |
17 | #include "mlir/IR/AffineMap.h" |
18 | #include "mlir/IR/Attributes.h" |
19 | #include "mlir/IR/BuiltinAttributes.h" |
20 | #include "mlir/IR/BuiltinDialect.h" |
21 | #include "mlir/IR/Diagnostics.h" |
22 | #include "mlir/IR/Dialect.h" |
23 | #include "mlir/IR/ExtensibleDialect.h" |
24 | #include "mlir/IR/IntegerSet.h" |
25 | #include "mlir/IR/Location.h" |
26 | #include "mlir/IR/OpImplementation.h" |
27 | #include "mlir/IR/OperationSupport.h" |
28 | #include "mlir/IR/Types.h" |
29 | #include "llvm/ADT/DenseMap.h" |
30 | #include "llvm/ADT/DenseSet.h" |
31 | #include "llvm/ADT/SmallString.h" |
32 | #include "llvm/ADT/StringSet.h" |
33 | #include "llvm/ADT/Twine.h" |
34 | #include "llvm/Support/Allocator.h" |
35 | #include "llvm/Support/CommandLine.h" |
36 | #include "llvm/Support/Compiler.h" |
37 | #include "llvm/Support/Debug.h" |
38 | #include "llvm/Support/Mutex.h" |
39 | #include "llvm/Support/RWMutex.h" |
40 | #include "llvm/Support/ThreadPool.h" |
41 | #include "llvm/Support/raw_ostream.h" |
42 | #include <memory> |
43 | #include <optional> |
44 | |
45 | #define DEBUG_TYPE "mlircontext" |
46 | |
47 | using namespace mlir; |
48 | using namespace mlir::detail; |
49 | |
50 | //===----------------------------------------------------------------------===// |
51 | // MLIRContext CommandLine Options |
52 | //===----------------------------------------------------------------------===// |
53 | |
54 | namespace { |
55 | /// This struct contains command line options that can be used to initialize |
56 | /// various bits of an MLIRContext. This uses a struct wrapper to avoid the need |
57 | /// for global command line options. |
58 | struct MLIRContextOptions { |
59 | llvm::cl::opt<bool> disableThreading{ |
60 | "mlir-disable-threading" , |
61 | llvm::cl::desc("Disable multi-threading within MLIR, overrides any " |
62 | "further call to MLIRContext::enableMultiThreading()" )}; |
63 | |
64 | llvm::cl::opt<bool> printOpOnDiagnostic{ |
65 | "mlir-print-op-on-diagnostic" , |
66 | llvm::cl::desc("When a diagnostic is emitted on an operation, also print " |
67 | "the operation as an attached note" ), |
68 | llvm::cl::init(Val: true)}; |
69 | |
70 | llvm::cl::opt<bool> printStackTraceOnDiagnostic{ |
71 | "mlir-print-stacktrace-on-diagnostic" , |
72 | llvm::cl::desc("When a diagnostic is emitted, also print the stack trace " |
73 | "as an attached note" )}; |
74 | }; |
75 | } // namespace |
76 | |
77 | static llvm::ManagedStatic<MLIRContextOptions> clOptions; |
78 | |
79 | static bool isThreadingGloballyDisabled() { |
80 | #if LLVM_ENABLE_THREADS != 0 |
81 | return clOptions.isConstructed() && clOptions->disableThreading; |
82 | #else |
83 | return true; |
84 | #endif |
85 | } |
86 | |
87 | /// Register a set of useful command-line options that can be used to configure |
88 | /// various flags within the MLIRContext. These flags are used when constructing |
89 | /// an MLIR context for initialization. |
90 | void mlir::registerMLIRContextCLOptions() { |
91 | // Make sure that the options struct has been initialized. |
92 | *clOptions; |
93 | } |
94 | |
95 | //===----------------------------------------------------------------------===// |
96 | // Locking Utilities |
97 | //===----------------------------------------------------------------------===// |
98 | |
99 | namespace { |
100 | /// Utility writer lock that takes a runtime flag that specifies if we really |
101 | /// need to lock. |
102 | struct ScopedWriterLock { |
103 | ScopedWriterLock(llvm::sys::SmartRWMutex<true> &mutexParam, bool shouldLock) |
104 | : mutex(shouldLock ? &mutexParam : nullptr) { |
105 | if (mutex) |
106 | mutex->lock(); |
107 | } |
108 | ~ScopedWriterLock() { |
109 | if (mutex) |
110 | mutex->unlock(); |
111 | } |
112 | llvm::sys::SmartRWMutex<true> *mutex; |
113 | }; |
114 | } // namespace |
115 | |
116 | //===----------------------------------------------------------------------===// |
117 | // MLIRContextImpl |
118 | //===----------------------------------------------------------------------===// |
119 | |
120 | namespace mlir { |
121 | /// This is the implementation of the MLIRContext class, using the pImpl idiom. |
122 | /// This class is completely private to this file, so everything is public. |
123 | class MLIRContextImpl { |
124 | public: |
125 | //===--------------------------------------------------------------------===// |
126 | // Debugging |
127 | //===--------------------------------------------------------------------===// |
128 | |
129 | /// An action handler for handling actions that are dispatched through this |
130 | /// context. |
131 | std::function<void(function_ref<void()>, const tracing::Action &)> |
132 | actionHandler; |
133 | |
134 | //===--------------------------------------------------------------------===// |
135 | // Diagnostics |
136 | //===--------------------------------------------------------------------===// |
137 | DiagnosticEngine diagEngine; |
138 | |
139 | //===--------------------------------------------------------------------===// |
140 | // Options |
141 | //===--------------------------------------------------------------------===// |
142 | |
143 | /// In most cases, creating operation in unregistered dialect is not desired |
144 | /// and indicate a misconfiguration of the compiler. This option enables to |
145 | /// detect such use cases |
146 | bool allowUnregisteredDialects = false; |
147 | |
148 | /// Enable support for multi-threading within MLIR. |
149 | bool threadingIsEnabled = true; |
150 | |
151 | /// Track if we are currently executing in a threaded execution environment |
152 | /// (like the pass-manager): this is only a debugging feature to help reducing |
153 | /// the chances of data races one some context APIs. |
154 | #ifndef NDEBUG |
155 | std::atomic<int> multiThreadedExecutionContext{0}; |
156 | #endif |
157 | |
158 | /// If the operation should be attached to diagnostics printed via the |
159 | /// Operation::emit methods. |
160 | bool printOpOnDiagnostic = true; |
161 | |
162 | /// If the current stack trace should be attached when emitting diagnostics. |
163 | bool printStackTraceOnDiagnostic = false; |
164 | |
165 | //===--------------------------------------------------------------------===// |
166 | // Other |
167 | //===--------------------------------------------------------------------===// |
168 | |
169 | /// This points to the ThreadPool used when processing MLIR tasks in parallel. |
170 | /// It can't be nullptr when multi-threading is enabled. Otherwise if |
171 | /// multi-threading is disabled, and the threadpool wasn't externally provided |
172 | /// using `setThreadPool`, this will be nullptr. |
173 | llvm::ThreadPoolInterface *threadPool = nullptr; |
174 | |
175 | /// In case where the thread pool is owned by the context, this ensures |
176 | /// destruction with the context. |
177 | std::unique_ptr<llvm::ThreadPoolInterface> ownedThreadPool; |
178 | |
179 | /// An allocator used for AbstractAttribute and AbstractType objects. |
180 | llvm::BumpPtrAllocator abstractDialectSymbolAllocator; |
181 | |
182 | /// This is a mapping from operation name to the operation info describing it. |
183 | llvm::StringMap<std::unique_ptr<OperationName::Impl>> operations; |
184 | |
185 | /// A vector of operation info specifically for registered operations. |
186 | llvm::DenseMap<TypeID, RegisteredOperationName> registeredOperations; |
187 | llvm::StringMap<RegisteredOperationName> registeredOperationsByName; |
188 | |
189 | /// This is a sorted container of registered operations for a deterministic |
190 | /// and efficient `getRegisteredOperations` implementation. |
191 | SmallVector<RegisteredOperationName, 0> sortedRegisteredOperations; |
192 | |
193 | /// This is a list of dialects that are created referring to this context. |
194 | /// The MLIRContext owns the objects. These need to be declared after the |
195 | /// registered operations to ensure correct destruction order. |
196 | DenseMap<StringRef, std::unique_ptr<Dialect>> loadedDialects; |
197 | DialectRegistry dialectsRegistry; |
198 | |
199 | /// A mutex used when accessing operation information. |
200 | llvm::sys::SmartRWMutex<true> operationInfoMutex; |
201 | |
202 | //===--------------------------------------------------------------------===// |
203 | // Affine uniquing |
204 | //===--------------------------------------------------------------------===// |
205 | |
206 | // Affine expression, map and integer set uniquing. |
207 | StorageUniquer affineUniquer; |
208 | |
209 | //===--------------------------------------------------------------------===// |
210 | // Type uniquing |
211 | //===--------------------------------------------------------------------===// |
212 | |
213 | DenseMap<TypeID, AbstractType *> registeredTypes; |
214 | StorageUniquer typeUniquer; |
215 | |
216 | /// This is a mapping from type name to the abstract type describing it. |
217 | /// It is used by `AbstractType::lookup` to get an `AbstractType` from a name. |
218 | /// As this map needs to be populated before `StringAttr` is loaded, we |
219 | /// cannot use `StringAttr` as the key. The context does not take ownership |
220 | /// of the key, so the `StringRef` must outlive the context. |
221 | llvm::DenseMap<StringRef, AbstractType *> nameToType; |
222 | |
223 | /// Cached Type Instances. |
224 | BFloat16Type bf16Ty; |
225 | Float16Type f16Ty; |
226 | FloatTF32Type tf32Ty; |
227 | Float32Type f32Ty; |
228 | Float64Type f64Ty; |
229 | Float80Type f80Ty; |
230 | Float128Type f128Ty; |
231 | IndexType indexTy; |
232 | IntegerType int1Ty, int8Ty, int16Ty, int32Ty, int64Ty, int128Ty; |
233 | NoneType noneType; |
234 | |
235 | //===--------------------------------------------------------------------===// |
236 | // Attribute uniquing |
237 | //===--------------------------------------------------------------------===// |
238 | |
239 | DenseMap<TypeID, AbstractAttribute *> registeredAttributes; |
240 | StorageUniquer attributeUniquer; |
241 | |
242 | /// This is a mapping from attribute name to the abstract attribute describing |
243 | /// it. It is used by `AbstractType::lookup` to get an `AbstractType` from a |
244 | /// name. |
245 | /// As this map needs to be populated before `StringAttr` is loaded, we |
246 | /// cannot use `StringAttr` as the key. The context does not take ownership |
247 | /// of the key, so the `StringRef` must outlive the context. |
248 | llvm::DenseMap<StringRef, AbstractAttribute *> nameToAttribute; |
249 | |
250 | /// Cached Attribute Instances. |
251 | BoolAttr falseAttr, trueAttr; |
252 | UnitAttr unitAttr; |
253 | UnknownLoc unknownLocAttr; |
254 | DictionaryAttr emptyDictionaryAttr; |
255 | StringAttr emptyStringAttr; |
256 | |
257 | /// Map of string attributes that may reference a dialect, that are awaiting |
258 | /// that dialect to be loaded. |
259 | llvm::sys::SmartMutex<true> dialectRefStrAttrMutex; |
260 | DenseMap<StringRef, SmallVector<StringAttrStorage *>> |
261 | dialectReferencingStrAttrs; |
262 | |
263 | /// A distinct attribute allocator that allocates every time since the |
264 | /// address of the distinct attribute storage serves as unique identifier. The |
265 | /// allocator is thread safe and frees the allocated storage after its |
266 | /// destruction. |
267 | DistinctAttributeAllocator distinctAttributeAllocator; |
268 | |
269 | public: |
270 | MLIRContextImpl(bool threadingIsEnabled) |
271 | : threadingIsEnabled(threadingIsEnabled) { |
272 | if (threadingIsEnabled) { |
273 | ownedThreadPool = std::make_unique<llvm::DefaultThreadPool>(); |
274 | threadPool = ownedThreadPool.get(); |
275 | } |
276 | } |
277 | ~MLIRContextImpl() { |
278 | for (auto typeMapping : registeredTypes) |
279 | typeMapping.second->~AbstractType(); |
280 | for (auto attrMapping : registeredAttributes) |
281 | attrMapping.second->~AbstractAttribute(); |
282 | } |
283 | }; |
284 | } // namespace mlir |
285 | |
286 | MLIRContext::MLIRContext(Threading setting) |
287 | : MLIRContext(DialectRegistry(), setting) {} |
288 | |
289 | MLIRContext::MLIRContext(const DialectRegistry ®istry, Threading setting) |
290 | : impl(new MLIRContextImpl(setting == Threading::ENABLED && |
291 | !isThreadingGloballyDisabled())) { |
292 | // Initialize values based on the command line flags if they were provided. |
293 | if (clOptions.isConstructed()) { |
294 | printOpOnDiagnostic(enable: clOptions->printOpOnDiagnostic); |
295 | printStackTraceOnDiagnostic(enable: clOptions->printStackTraceOnDiagnostic); |
296 | } |
297 | |
298 | // Pre-populate the registry. |
299 | registry.appendTo(destination&: impl->dialectsRegistry); |
300 | |
301 | // Ensure the builtin dialect is always pre-loaded. |
302 | getOrLoadDialect<BuiltinDialect>(); |
303 | |
304 | // Initialize several common attributes and types to avoid the need to lock |
305 | // the context when accessing them. |
306 | |
307 | //// Types. |
308 | /// Floating-point Types. |
309 | impl->bf16Ty = TypeUniquer::get<BFloat16Type>(this); |
310 | impl->f16Ty = TypeUniquer::get<Float16Type>(this); |
311 | impl->tf32Ty = TypeUniquer::get<FloatTF32Type>(this); |
312 | impl->f32Ty = TypeUniquer::get<Float32Type>(this); |
313 | impl->f64Ty = TypeUniquer::get<Float64Type>(this); |
314 | impl->f80Ty = TypeUniquer::get<Float80Type>(this); |
315 | impl->f128Ty = TypeUniquer::get<Float128Type>(this); |
316 | /// Index Type. |
317 | impl->indexTy = TypeUniquer::get<IndexType>(this); |
318 | /// Integer Types. |
319 | impl->int1Ty = TypeUniquer::get<IntegerType>(this, 1, IntegerType::Signless); |
320 | impl->int8Ty = TypeUniquer::get<IntegerType>(this, 8, IntegerType::Signless); |
321 | impl->int16Ty = |
322 | TypeUniquer::get<IntegerType>(this, 16, IntegerType::Signless); |
323 | impl->int32Ty = |
324 | TypeUniquer::get<IntegerType>(this, 32, IntegerType::Signless); |
325 | impl->int64Ty = |
326 | TypeUniquer::get<IntegerType>(this, 64, IntegerType::Signless); |
327 | impl->int128Ty = |
328 | TypeUniquer::get<IntegerType>(this, 128, IntegerType::Signless); |
329 | /// None Type. |
330 | impl->noneType = TypeUniquer::get<NoneType>(this); |
331 | |
332 | //// Attributes. |
333 | //// Note: These must be registered after the types as they may generate one |
334 | //// of the above types internally. |
335 | /// Unknown Location Attribute. |
336 | impl->unknownLocAttr = AttributeUniquer::get<UnknownLoc>(this); |
337 | /// Bool Attributes. |
338 | impl->falseAttr = IntegerAttr::getBoolAttrUnchecked(impl->int1Ty, false); |
339 | impl->trueAttr = IntegerAttr::getBoolAttrUnchecked(impl->int1Ty, true); |
340 | /// Unit Attribute. |
341 | impl->unitAttr = AttributeUniquer::get<UnitAttr>(this); |
342 | /// The empty dictionary attribute. |
343 | impl->emptyDictionaryAttr = DictionaryAttr::getEmptyUnchecked(this); |
344 | /// The empty string attribute. |
345 | impl->emptyStringAttr = StringAttr::getEmptyStringAttrUnchecked(this); |
346 | |
347 | // Register the affine storage objects with the uniquer. |
348 | impl->affineUniquer |
349 | .registerParametricStorageType<AffineBinaryOpExprStorage>(); |
350 | impl->affineUniquer |
351 | .registerParametricStorageType<AffineConstantExprStorage>(); |
352 | impl->affineUniquer.registerParametricStorageType<AffineDimExprStorage>(); |
353 | impl->affineUniquer.registerParametricStorageType<AffineMapStorage>(); |
354 | impl->affineUniquer.registerParametricStorageType<IntegerSetStorage>(); |
355 | } |
356 | |
357 | MLIRContext::~MLIRContext() = default; |
358 | |
359 | /// Copy the specified array of elements into memory managed by the provided |
360 | /// bump pointer allocator. This assumes the elements are all PODs. |
361 | template <typename T> |
362 | static ArrayRef<T> copyArrayRefInto(llvm::BumpPtrAllocator &allocator, |
363 | ArrayRef<T> elements) { |
364 | auto result = allocator.Allocate<T>(elements.size()); |
365 | llvm::uninitialized_copy(elements, result); |
366 | return ArrayRef<T>(result, elements.size()); |
367 | } |
368 | |
369 | //===----------------------------------------------------------------------===// |
370 | // Action Handling |
371 | //===----------------------------------------------------------------------===// |
372 | |
373 | void MLIRContext::registerActionHandler(HandlerTy handler) { |
374 | getImpl().actionHandler = std::move(handler); |
375 | } |
376 | |
377 | /// Dispatch the provided action to the handler if any, or just execute it. |
378 | void MLIRContext::executeActionInternal(function_ref<void()> actionFn, |
379 | const tracing::Action &action) { |
380 | assert(getImpl().actionHandler); |
381 | getImpl().actionHandler(actionFn, action); |
382 | } |
383 | |
384 | bool MLIRContext::hasActionHandler() { return (bool)getImpl().actionHandler; } |
385 | |
386 | //===----------------------------------------------------------------------===// |
387 | // Diagnostic Handlers |
388 | //===----------------------------------------------------------------------===// |
389 | |
390 | /// Returns the diagnostic engine for this context. |
391 | DiagnosticEngine &MLIRContext::getDiagEngine() { return getImpl().diagEngine; } |
392 | |
393 | //===----------------------------------------------------------------------===// |
394 | // Dialect and Operation Registration |
395 | //===----------------------------------------------------------------------===// |
396 | |
397 | void MLIRContext::appendDialectRegistry(const DialectRegistry ®istry) { |
398 | if (registry.isSubsetOf(rhs: impl->dialectsRegistry)) |
399 | return; |
400 | |
401 | assert(impl->multiThreadedExecutionContext == 0 && |
402 | "appending to the MLIRContext dialect registry while in a " |
403 | "multi-threaded execution context" ); |
404 | registry.appendTo(destination&: impl->dialectsRegistry); |
405 | |
406 | // For the already loaded dialects, apply any possible extensions immediately. |
407 | registry.applyExtensions(ctx: this); |
408 | } |
409 | |
410 | const DialectRegistry &MLIRContext::getDialectRegistry() { |
411 | return impl->dialectsRegistry; |
412 | } |
413 | |
414 | /// Return information about all registered IR dialects. |
415 | std::vector<Dialect *> MLIRContext::getLoadedDialects() { |
416 | std::vector<Dialect *> result; |
417 | result.reserve(n: impl->loadedDialects.size()); |
418 | for (auto &dialect : impl->loadedDialects) |
419 | result.push_back(x: dialect.second.get()); |
420 | llvm::array_pod_sort(Start: result.begin(), End: result.end(), |
421 | Compare: [](Dialect *const *lhs, Dialect *const *rhs) -> int { |
422 | return (*lhs)->getNamespace() < (*rhs)->getNamespace(); |
423 | }); |
424 | return result; |
425 | } |
426 | std::vector<StringRef> MLIRContext::getAvailableDialects() { |
427 | std::vector<StringRef> result; |
428 | for (auto dialect : impl->dialectsRegistry.getDialectNames()) |
429 | result.push_back(x: dialect); |
430 | return result; |
431 | } |
432 | |
433 | /// Get a registered IR dialect with the given namespace. If none is found, |
434 | /// then return nullptr. |
435 | Dialect *MLIRContext::getLoadedDialect(StringRef name) { |
436 | // Dialects are sorted by name, so we can use binary search for lookup. |
437 | auto it = impl->loadedDialects.find(Val: name); |
438 | return (it != impl->loadedDialects.end()) ? it->second.get() : nullptr; |
439 | } |
440 | |
441 | Dialect *MLIRContext::getOrLoadDialect(StringRef name) { |
442 | Dialect *dialect = getLoadedDialect(name); |
443 | if (dialect) |
444 | return dialect; |
445 | DialectAllocatorFunctionRef allocator = |
446 | impl->dialectsRegistry.getDialectAllocator(name); |
447 | return allocator ? allocator(this) : nullptr; |
448 | } |
449 | |
450 | /// Get a dialect for the provided namespace and TypeID: abort the program if a |
451 | /// dialect exist for this namespace with different TypeID. Returns a pointer to |
452 | /// the dialect owned by the context. |
453 | Dialect * |
454 | MLIRContext::getOrLoadDialect(StringRef dialectNamespace, TypeID dialectID, |
455 | function_ref<std::unique_ptr<Dialect>()> ctor) { |
456 | auto &impl = getImpl(); |
457 | // Get the correct insertion position sorted by namespace. |
458 | auto dialectIt = impl.loadedDialects.try_emplace(Key: dialectNamespace, Args: nullptr); |
459 | |
460 | if (dialectIt.second) { |
461 | LLVM_DEBUG(llvm::dbgs() |
462 | << "Load new dialect in Context " << dialectNamespace << "\n" ); |
463 | #ifndef NDEBUG |
464 | if (impl.multiThreadedExecutionContext != 0) |
465 | llvm::report_fatal_error( |
466 | reason: "Loading a dialect (" + dialectNamespace + |
467 | ") while in a multi-threaded execution context (maybe " |
468 | "the PassManager): this can indicate a " |
469 | "missing `dependentDialects` in a pass for example." ); |
470 | #endif // NDEBUG |
471 | // loadedDialects entry is initialized to nullptr, indicating that the |
472 | // dialect is currently being loaded. Re-lookup the address in |
473 | // loadedDialects because the table might have been rehashed by recursive |
474 | // dialect loading in ctor(). |
475 | std::unique_ptr<Dialect> &dialectOwned = |
476 | impl.loadedDialects[dialectNamespace] = ctor(); |
477 | Dialect *dialect = dialectOwned.get(); |
478 | assert(dialect && "dialect ctor failed" ); |
479 | |
480 | // Refresh all the identifiers dialect field, this catches cases where a |
481 | // dialect may be loaded after identifier prefixed with this dialect name |
482 | // were already created. |
483 | auto stringAttrsIt = impl.dialectReferencingStrAttrs.find(Val: dialectNamespace); |
484 | if (stringAttrsIt != impl.dialectReferencingStrAttrs.end()) { |
485 | for (StringAttrStorage *storage : stringAttrsIt->second) |
486 | storage->referencedDialect = dialect; |
487 | impl.dialectReferencingStrAttrs.erase(I: stringAttrsIt); |
488 | } |
489 | |
490 | // Apply any extensions to this newly loaded dialect. |
491 | impl.dialectsRegistry.applyExtensions(dialect); |
492 | return dialect; |
493 | } |
494 | |
495 | #ifndef NDEBUG |
496 | if (dialectIt.first->second == nullptr) |
497 | llvm::report_fatal_error( |
498 | reason: "Loading (and getting) a dialect (" + dialectNamespace + |
499 | ") while the same dialect is still loading: use loadDialect instead " |
500 | "of getOrLoadDialect." ); |
501 | #endif // NDEBUG |
502 | |
503 | // Abort if dialect with namespace has already been registered. |
504 | std::unique_ptr<Dialect> &dialect = dialectIt.first->second; |
505 | if (dialect->getTypeID() != dialectID) |
506 | llvm::report_fatal_error(reason: "a dialect with namespace '" + dialectNamespace + |
507 | "' has already been registered" ); |
508 | |
509 | return dialect.get(); |
510 | } |
511 | |
512 | bool MLIRContext::isDialectLoading(StringRef dialectNamespace) { |
513 | auto it = getImpl().loadedDialects.find(Val: dialectNamespace); |
514 | // nullptr indicates that the dialect is currently being loaded. |
515 | return it != getImpl().loadedDialects.end() && it->second == nullptr; |
516 | } |
517 | |
518 | DynamicDialect *MLIRContext::getOrLoadDynamicDialect( |
519 | StringRef dialectNamespace, function_ref<void(DynamicDialect *)> ctor) { |
520 | auto &impl = getImpl(); |
521 | // Get the correct insertion position sorted by namespace. |
522 | auto dialectIt = impl.loadedDialects.find(Val: dialectNamespace); |
523 | |
524 | if (dialectIt != impl.loadedDialects.end()) { |
525 | if (auto *dynDialect = dyn_cast<DynamicDialect>(Val: dialectIt->second.get())) |
526 | return dynDialect; |
527 | llvm::report_fatal_error(reason: "a dialect with namespace '" + dialectNamespace + |
528 | "' has already been registered" ); |
529 | } |
530 | |
531 | LLVM_DEBUG(llvm::dbgs() << "Load new dynamic dialect in Context " |
532 | << dialectNamespace << "\n" ); |
533 | #ifndef NDEBUG |
534 | if (impl.multiThreadedExecutionContext != 0) |
535 | llvm::report_fatal_error( |
536 | reason: "Loading a dynamic dialect (" + dialectNamespace + |
537 | ") while in a multi-threaded execution context (maybe " |
538 | "the PassManager): this can indicate a " |
539 | "missing `dependentDialects` in a pass for example." ); |
540 | #endif |
541 | |
542 | auto name = StringAttr::get(this, dialectNamespace); |
543 | auto *dialect = new DynamicDialect(name, this); |
544 | (void)getOrLoadDialect(name, dialect->getTypeID(), [dialect, ctor]() { |
545 | ctor(dialect); |
546 | return std::unique_ptr<DynamicDialect>(dialect); |
547 | }); |
548 | // This is the same result as `getOrLoadDialect` (if it didn't failed), |
549 | // since it has the same TypeID, and TypeIDs are unique. |
550 | return dialect; |
551 | } |
552 | |
553 | void MLIRContext::loadAllAvailableDialects() { |
554 | for (StringRef name : getAvailableDialects()) |
555 | getOrLoadDialect(name); |
556 | } |
557 | |
558 | llvm::hash_code MLIRContext::getRegistryHash() { |
559 | llvm::hash_code hash(0); |
560 | // Factor in number of loaded dialects, attributes, operations, types. |
561 | hash = llvm::hash_combine(args: hash, args: impl->loadedDialects.size()); |
562 | hash = llvm::hash_combine(args: hash, args: impl->registeredAttributes.size()); |
563 | hash = llvm::hash_combine(args: hash, args: impl->registeredOperations.size()); |
564 | hash = llvm::hash_combine(args: hash, args: impl->registeredTypes.size()); |
565 | return hash; |
566 | } |
567 | |
568 | bool MLIRContext::allowsUnregisteredDialects() { |
569 | return impl->allowUnregisteredDialects; |
570 | } |
571 | |
572 | void MLIRContext::allowUnregisteredDialects(bool allowing) { |
573 | assert(impl->multiThreadedExecutionContext == 0 && |
574 | "changing MLIRContext `allow-unregistered-dialects` configuration " |
575 | "while in a multi-threaded execution context" ); |
576 | impl->allowUnregisteredDialects = allowing; |
577 | } |
578 | |
579 | /// Return true if multi-threading is enabled by the context. |
580 | bool MLIRContext::isMultithreadingEnabled() { |
581 | return impl->threadingIsEnabled && llvm::llvm_is_multithreaded(); |
582 | } |
583 | |
584 | /// Set the flag specifying if multi-threading is disabled by the context. |
585 | void MLIRContext::disableMultithreading(bool disable) { |
586 | // This API can be overridden by the global debugging flag |
587 | // --mlir-disable-threading |
588 | if (isThreadingGloballyDisabled()) |
589 | return; |
590 | assert(impl->multiThreadedExecutionContext == 0 && |
591 | "changing MLIRContext `disable-threading` configuration while " |
592 | "in a multi-threaded execution context" ); |
593 | |
594 | impl->threadingIsEnabled = !disable; |
595 | |
596 | // Update the threading mode for each of the uniquers. |
597 | impl->affineUniquer.disableMultithreading(disable); |
598 | impl->attributeUniquer.disableMultithreading(disable); |
599 | impl->typeUniquer.disableMultithreading(disable); |
600 | |
601 | // Destroy thread pool (stop all threads) if it is no longer needed, or create |
602 | // a new one if multithreading was re-enabled. |
603 | if (disable) { |
604 | // If the thread pool is owned, explicitly set it to nullptr to avoid |
605 | // keeping a dangling pointer around. If the thread pool is externally |
606 | // owned, we don't do anything. |
607 | if (impl->ownedThreadPool) { |
608 | assert(impl->threadPool); |
609 | impl->threadPool = nullptr; |
610 | impl->ownedThreadPool.reset(); |
611 | } |
612 | } else if (!impl->threadPool) { |
613 | // The thread pool isn't externally provided. |
614 | assert(!impl->ownedThreadPool); |
615 | impl->ownedThreadPool = std::make_unique<llvm::DefaultThreadPool>(); |
616 | impl->threadPool = impl->ownedThreadPool.get(); |
617 | } |
618 | } |
619 | |
620 | void MLIRContext::setThreadPool(llvm::ThreadPoolInterface &pool) { |
621 | assert(!isMultithreadingEnabled() && |
622 | "expected multi-threading to be disabled when setting a ThreadPool" ); |
623 | impl->threadPool = &pool; |
624 | impl->ownedThreadPool.reset(); |
625 | enableMultithreading(); |
626 | } |
627 | |
628 | unsigned MLIRContext::getNumThreads() { |
629 | if (isMultithreadingEnabled()) { |
630 | assert(impl->threadPool && |
631 | "multi-threading is enabled but threadpool not set" ); |
632 | return impl->threadPool->getMaxConcurrency(); |
633 | } |
634 | // No multithreading or active thread pool. Return 1 thread. |
635 | return 1; |
636 | } |
637 | |
638 | llvm::ThreadPoolInterface &MLIRContext::getThreadPool() { |
639 | assert(isMultithreadingEnabled() && |
640 | "expected multi-threading to be enabled within the context" ); |
641 | assert(impl->threadPool && |
642 | "multi-threading is enabled but threadpool not set" ); |
643 | return *impl->threadPool; |
644 | } |
645 | |
646 | void MLIRContext::enterMultiThreadedExecution() { |
647 | #ifndef NDEBUG |
648 | ++impl->multiThreadedExecutionContext; |
649 | #endif |
650 | } |
651 | void MLIRContext::exitMultiThreadedExecution() { |
652 | #ifndef NDEBUG |
653 | --impl->multiThreadedExecutionContext; |
654 | #endif |
655 | } |
656 | |
657 | /// Return true if we should attach the operation to diagnostics emitted via |
658 | /// Operation::emit. |
659 | bool MLIRContext::shouldPrintOpOnDiagnostic() { |
660 | return impl->printOpOnDiagnostic; |
661 | } |
662 | |
663 | /// Set the flag specifying if we should attach the operation to diagnostics |
664 | /// emitted via Operation::emit. |
665 | void MLIRContext::printOpOnDiagnostic(bool enable) { |
666 | assert(impl->multiThreadedExecutionContext == 0 && |
667 | "changing MLIRContext `print-op-on-diagnostic` configuration while in " |
668 | "a multi-threaded execution context" ); |
669 | impl->printOpOnDiagnostic = enable; |
670 | } |
671 | |
672 | /// Return true if we should attach the current stacktrace to diagnostics when |
673 | /// emitted. |
674 | bool MLIRContext::shouldPrintStackTraceOnDiagnostic() { |
675 | return impl->printStackTraceOnDiagnostic; |
676 | } |
677 | |
678 | /// Set the flag specifying if we should attach the current stacktrace when |
679 | /// emitting diagnostics. |
680 | void MLIRContext::printStackTraceOnDiagnostic(bool enable) { |
681 | assert(impl->multiThreadedExecutionContext == 0 && |
682 | "changing MLIRContext `print-stacktrace-on-diagnostic` configuration " |
683 | "while in a multi-threaded execution context" ); |
684 | impl->printStackTraceOnDiagnostic = enable; |
685 | } |
686 | |
687 | /// Return information about all registered operations. |
688 | ArrayRef<RegisteredOperationName> MLIRContext::getRegisteredOperations() { |
689 | return impl->sortedRegisteredOperations; |
690 | } |
691 | |
692 | /// Return information for registered operations by dialect. |
693 | ArrayRef<RegisteredOperationName> |
694 | MLIRContext::getRegisteredOperationsByDialect(StringRef dialectName) { |
695 | auto lowerBound = llvm::lower_bound( |
696 | Range&: impl->sortedRegisteredOperations, Value&: dialectName, C: [](auto &lhs, auto &rhs) { |
697 | return lhs.getDialect().getNamespace().compare(rhs); |
698 | }); |
699 | |
700 | if (lowerBound == impl->sortedRegisteredOperations.end() || |
701 | lowerBound->getDialect().getNamespace() != dialectName) |
702 | return ArrayRef<RegisteredOperationName>(); |
703 | |
704 | auto upperBound = |
705 | std::upper_bound(first: lowerBound, last: impl->sortedRegisteredOperations.end(), |
706 | val: dialectName, comp: [](auto &lhs, auto &rhs) { |
707 | return lhs.compare(rhs.getDialect().getNamespace()); |
708 | }); |
709 | |
710 | size_t count = std::distance(first: lowerBound, last: upperBound); |
711 | return ArrayRef(&*lowerBound, count); |
712 | } |
713 | |
714 | bool MLIRContext::isOperationRegistered(StringRef name) { |
715 | return RegisteredOperationName::lookup(name, ctx: this).has_value(); |
716 | } |
717 | |
718 | void Dialect::addType(TypeID typeID, AbstractType &&typeInfo) { |
719 | auto &impl = context->getImpl(); |
720 | assert(impl.multiThreadedExecutionContext == 0 && |
721 | "Registering a new type kind while in a multi-threaded execution " |
722 | "context" ); |
723 | auto *newInfo = |
724 | new (impl.abstractDialectSymbolAllocator.Allocate<AbstractType>()) |
725 | AbstractType(std::move(typeInfo)); |
726 | if (!impl.registeredTypes.insert(KV: {typeID, newInfo}).second) |
727 | llvm::report_fatal_error(reason: "Dialect Type already registered." ); |
728 | if (!impl.nameToType.insert(KV: {newInfo->getName(), newInfo}).second) |
729 | llvm::report_fatal_error(reason: "Dialect Type with name " + newInfo->getName() + |
730 | " is already registered." ); |
731 | } |
732 | |
733 | void Dialect::addAttribute(TypeID typeID, AbstractAttribute &&attrInfo) { |
734 | auto &impl = context->getImpl(); |
735 | assert(impl.multiThreadedExecutionContext == 0 && |
736 | "Registering a new attribute kind while in a multi-threaded execution " |
737 | "context" ); |
738 | auto *newInfo = |
739 | new (impl.abstractDialectSymbolAllocator.Allocate<AbstractAttribute>()) |
740 | AbstractAttribute(std::move(attrInfo)); |
741 | if (!impl.registeredAttributes.insert(KV: {typeID, newInfo}).second) |
742 | llvm::report_fatal_error(reason: "Dialect Attribute already registered." ); |
743 | if (!impl.nameToAttribute.insert(KV: {newInfo->getName(), newInfo}).second) |
744 | llvm::report_fatal_error(reason: "Dialect Attribute with name " + |
745 | newInfo->getName() + " is already registered." ); |
746 | } |
747 | |
748 | //===----------------------------------------------------------------------===// |
749 | // AbstractAttribute |
750 | //===----------------------------------------------------------------------===// |
751 | |
752 | /// Get the dialect that registered the attribute with the provided typeid. |
753 | const AbstractAttribute &AbstractAttribute::lookup(TypeID typeID, |
754 | MLIRContext *context) { |
755 | const AbstractAttribute *abstract = lookupMutable(typeID, context); |
756 | if (!abstract) |
757 | llvm::report_fatal_error(reason: "Trying to create an Attribute that was not " |
758 | "registered in this MLIRContext." ); |
759 | return *abstract; |
760 | } |
761 | |
762 | AbstractAttribute *AbstractAttribute::lookupMutable(TypeID typeID, |
763 | MLIRContext *context) { |
764 | auto &impl = context->getImpl(); |
765 | return impl.registeredAttributes.lookup(Val: typeID); |
766 | } |
767 | |
768 | std::optional<std::reference_wrapper<const AbstractAttribute>> |
769 | AbstractAttribute::lookup(StringRef name, MLIRContext *context) { |
770 | MLIRContextImpl &impl = context->getImpl(); |
771 | const AbstractAttribute *type = impl.nameToAttribute.lookup(Val: name); |
772 | |
773 | if (!type) |
774 | return std::nullopt; |
775 | return {*type}; |
776 | } |
777 | |
778 | //===----------------------------------------------------------------------===// |
779 | // OperationName |
780 | //===----------------------------------------------------------------------===// |
781 | |
782 | OperationName::Impl::Impl(StringRef name, Dialect *dialect, TypeID typeID, |
783 | detail::InterfaceMap interfaceMap) |
784 | : Impl(StringAttr::get(dialect->getContext(), name), dialect, typeID, |
785 | std::move(interfaceMap)) {} |
786 | |
787 | OperationName::OperationName(StringRef name, MLIRContext *context) { |
788 | MLIRContextImpl &ctxImpl = context->getImpl(); |
789 | |
790 | // Check for an existing name in read-only mode. |
791 | bool isMultithreadingEnabled = context->isMultithreadingEnabled(); |
792 | if (isMultithreadingEnabled) { |
793 | // Check the registered info map first. In the overwhelmingly common case, |
794 | // the entry will be in here and it also removes the need to acquire any |
795 | // locks. |
796 | auto registeredIt = ctxImpl.registeredOperationsByName.find(Key: name); |
797 | if (LLVM_LIKELY(registeredIt != ctxImpl.registeredOperationsByName.end())) { |
798 | impl = registeredIt->second.impl; |
799 | return; |
800 | } |
801 | |
802 | llvm::sys::SmartScopedReader<true> contextLock(ctxImpl.operationInfoMutex); |
803 | auto it = ctxImpl.operations.find(Key: name); |
804 | if (it != ctxImpl.operations.end()) { |
805 | impl = it->second.get(); |
806 | return; |
807 | } |
808 | } |
809 | |
810 | // Acquire a writer-lock so that we can safely create the new instance. |
811 | ScopedWriterLock lock(ctxImpl.operationInfoMutex, isMultithreadingEnabled); |
812 | |
813 | auto it = ctxImpl.operations.try_emplace(Key: name); |
814 | if (it.second) { |
815 | auto nameAttr = StringAttr::get(context, name); |
816 | it.first->second = std::make_unique<UnregisteredOpModel>( |
817 | nameAttr, nameAttr.getReferencedDialect(), TypeID::get<void>(), |
818 | detail::InterfaceMap()); |
819 | } |
820 | impl = it.first->second.get(); |
821 | } |
822 | |
823 | StringRef OperationName::getDialectNamespace() const { |
824 | if (Dialect *dialect = getDialect()) |
825 | return dialect->getNamespace(); |
826 | return getStringRef().split(Separator: '.').first; |
827 | } |
828 | |
829 | LogicalResult |
830 | OperationName::UnregisteredOpModel::foldHook(Operation *, ArrayRef<Attribute>, |
831 | SmallVectorImpl<OpFoldResult> &) { |
832 | return failure(); |
833 | } |
834 | void OperationName::UnregisteredOpModel::getCanonicalizationPatterns( |
835 | RewritePatternSet &, MLIRContext *) {} |
836 | bool OperationName::UnregisteredOpModel::hasTrait(TypeID) { return false; } |
837 | |
838 | OperationName::ParseAssemblyFn |
839 | OperationName::UnregisteredOpModel::getParseAssemblyFn() { |
840 | llvm::report_fatal_error(reason: "getParseAssemblyFn hook called on unregistered op" ); |
841 | } |
842 | void OperationName::UnregisteredOpModel::populateDefaultAttrs( |
843 | const OperationName &, NamedAttrList &) {} |
844 | void OperationName::UnregisteredOpModel::printAssembly( |
845 | Operation *op, OpAsmPrinter &p, StringRef defaultDialect) { |
846 | p.printGenericOp(op); |
847 | } |
848 | LogicalResult |
849 | OperationName::UnregisteredOpModel::verifyInvariants(Operation *) { |
850 | return success(); |
851 | } |
852 | LogicalResult |
853 | OperationName::UnregisteredOpModel::verifyRegionInvariants(Operation *) { |
854 | return success(); |
855 | } |
856 | |
857 | std::optional<Attribute> |
858 | OperationName::UnregisteredOpModel::getInherentAttr(Operation *op, |
859 | StringRef name) { |
860 | auto dict = dyn_cast_or_null<DictionaryAttr>(getPropertiesAsAttr(op)); |
861 | if (!dict) |
862 | return std::nullopt; |
863 | if (Attribute attr = dict.get(name)) |
864 | return attr; |
865 | return std::nullopt; |
866 | } |
867 | void OperationName::UnregisteredOpModel::setInherentAttr(Operation *op, |
868 | StringAttr name, |
869 | Attribute value) { |
870 | auto dict = dyn_cast_or_null<DictionaryAttr>(getPropertiesAsAttr(op)); |
871 | assert(dict); |
872 | NamedAttrList attrs(dict); |
873 | attrs.set(name, value); |
874 | *op->getPropertiesStorage().as<Attribute *>() = |
875 | attrs.getDictionary(op->getContext()); |
876 | } |
877 | void OperationName::UnregisteredOpModel::populateInherentAttrs( |
878 | Operation *op, NamedAttrList &attrs) {} |
879 | LogicalResult OperationName::UnregisteredOpModel::verifyInherentAttrs( |
880 | OperationName opName, NamedAttrList &attributes, |
881 | function_ref<InFlightDiagnostic()> emitError) { |
882 | return success(); |
883 | } |
884 | int OperationName::UnregisteredOpModel::getOpPropertyByteSize() { |
885 | return sizeof(Attribute); |
886 | } |
887 | void OperationName::UnregisteredOpModel::initProperties( |
888 | OperationName opName, OpaqueProperties storage, OpaqueProperties init) { |
889 | new (storage.as<Attribute *>()) Attribute(); |
890 | } |
891 | void OperationName::UnregisteredOpModel::deleteProperties( |
892 | OpaqueProperties prop) { |
893 | prop.as<Attribute *>()->~Attribute(); |
894 | } |
895 | void OperationName::UnregisteredOpModel::populateDefaultProperties( |
896 | OperationName opName, OpaqueProperties properties) {} |
897 | LogicalResult OperationName::UnregisteredOpModel::setPropertiesFromAttr( |
898 | OperationName opName, OpaqueProperties properties, Attribute attr, |
899 | function_ref<InFlightDiagnostic()> emitError) { |
900 | *properties.as<Attribute *>() = attr; |
901 | return success(); |
902 | } |
903 | Attribute |
904 | OperationName::UnregisteredOpModel::getPropertiesAsAttr(Operation *op) { |
905 | return *op->getPropertiesStorage().as<Attribute *>(); |
906 | } |
907 | void OperationName::UnregisteredOpModel::copyProperties(OpaqueProperties lhs, |
908 | OpaqueProperties rhs) { |
909 | *lhs.as<Attribute *>() = *rhs.as<Attribute *>(); |
910 | } |
911 | bool OperationName::UnregisteredOpModel::compareProperties( |
912 | OpaqueProperties lhs, OpaqueProperties rhs) { |
913 | return *lhs.as<Attribute *>() == *rhs.as<Attribute *>(); |
914 | } |
915 | llvm::hash_code |
916 | OperationName::UnregisteredOpModel::hashProperties(OpaqueProperties prop) { |
917 | return llvm::hash_combine(args: *prop.as<Attribute *>()); |
918 | } |
919 | |
920 | //===----------------------------------------------------------------------===// |
921 | // RegisteredOperationName |
922 | //===----------------------------------------------------------------------===// |
923 | |
924 | std::optional<RegisteredOperationName> |
925 | RegisteredOperationName::lookup(TypeID typeID, MLIRContext *ctx) { |
926 | auto &impl = ctx->getImpl(); |
927 | auto it = impl.registeredOperations.find(Val: typeID); |
928 | if (it != impl.registeredOperations.end()) |
929 | return it->second; |
930 | return std::nullopt; |
931 | } |
932 | |
933 | std::optional<RegisteredOperationName> |
934 | RegisteredOperationName::lookup(StringRef name, MLIRContext *ctx) { |
935 | auto &impl = ctx->getImpl(); |
936 | auto it = impl.registeredOperationsByName.find(Key: name); |
937 | if (it != impl.registeredOperationsByName.end()) |
938 | return it->getValue(); |
939 | return std::nullopt; |
940 | } |
941 | |
942 | void RegisteredOperationName::insert( |
943 | std::unique_ptr<RegisteredOperationName::Impl> ownedImpl, |
944 | ArrayRef<StringRef> attrNames) { |
945 | RegisteredOperationName::Impl *impl = ownedImpl.get(); |
946 | MLIRContext *ctx = impl->getDialect()->getContext(); |
947 | auto &ctxImpl = ctx->getImpl(); |
948 | assert(ctxImpl.multiThreadedExecutionContext == 0 && |
949 | "registering a new operation kind while in a multi-threaded execution " |
950 | "context" ); |
951 | |
952 | // Register the attribute names of this operation. |
953 | MutableArrayRef<StringAttr> cachedAttrNames; |
954 | if (!attrNames.empty()) { |
955 | cachedAttrNames = MutableArrayRef<StringAttr>( |
956 | ctxImpl.abstractDialectSymbolAllocator.Allocate<StringAttr>( |
957 | Num: attrNames.size()), |
958 | attrNames.size()); |
959 | for (unsigned i : llvm::seq<unsigned>(0, attrNames.size())) |
960 | new (&cachedAttrNames[i]) StringAttr(StringAttr::get(ctx, attrNames[i])); |
961 | impl->attributeNames = cachedAttrNames; |
962 | } |
963 | StringRef name = impl->getName().strref(); |
964 | // Insert the operation info if it doesn't exist yet. |
965 | ctxImpl.operations[name] = std::move(ownedImpl); |
966 | |
967 | // Update the registered info for this operation. |
968 | auto emplaced = ctxImpl.registeredOperations.try_emplace( |
969 | Key: impl->getTypeID(), Args: RegisteredOperationName(impl)); |
970 | assert(emplaced.second && "operation name registration must be successful" ); |
971 | auto emplacedByName = ctxImpl.registeredOperationsByName.try_emplace( |
972 | Key: name, Args: RegisteredOperationName(impl)); |
973 | (void)emplacedByName; |
974 | assert(emplacedByName.second && |
975 | "operation name registration must be successful" ); |
976 | |
977 | // Add emplaced operation name to the sorted operations container. |
978 | RegisteredOperationName &value = emplaced.first->second; |
979 | ctxImpl.sortedRegisteredOperations.insert( |
980 | I: llvm::upper_bound(Range&: ctxImpl.sortedRegisteredOperations, Value&: value, |
981 | C: [](auto &lhs, auto &rhs) { |
982 | return lhs.getIdentifier().compare( |
983 | rhs.getIdentifier()); |
984 | }), |
985 | Elt: value); |
986 | } |
987 | |
988 | //===----------------------------------------------------------------------===// |
989 | // AbstractType |
990 | //===----------------------------------------------------------------------===// |
991 | |
992 | const AbstractType &AbstractType::lookup(TypeID typeID, MLIRContext *context) { |
993 | const AbstractType *type = lookupMutable(typeID, context); |
994 | if (!type) |
995 | llvm::report_fatal_error( |
996 | reason: "Trying to create a Type that was not registered in this MLIRContext." ); |
997 | return *type; |
998 | } |
999 | |
1000 | AbstractType *AbstractType::lookupMutable(TypeID typeID, MLIRContext *context) { |
1001 | auto &impl = context->getImpl(); |
1002 | return impl.registeredTypes.lookup(Val: typeID); |
1003 | } |
1004 | |
1005 | std::optional<std::reference_wrapper<const AbstractType>> |
1006 | AbstractType::lookup(StringRef name, MLIRContext *context) { |
1007 | MLIRContextImpl &impl = context->getImpl(); |
1008 | const AbstractType *type = impl.nameToType.lookup(Val: name); |
1009 | |
1010 | if (!type) |
1011 | return std::nullopt; |
1012 | return {*type}; |
1013 | } |
1014 | |
1015 | //===----------------------------------------------------------------------===// |
1016 | // Type uniquing |
1017 | //===----------------------------------------------------------------------===// |
1018 | |
1019 | /// Returns the storage uniquer used for constructing type storage instances. |
1020 | /// This should not be used directly. |
1021 | StorageUniquer &MLIRContext::getTypeUniquer() { return getImpl().typeUniquer; } |
1022 | |
1023 | BFloat16Type BFloat16Type::get(MLIRContext *context) { |
1024 | return context->getImpl().bf16Ty; |
1025 | } |
1026 | Float16Type Float16Type::get(MLIRContext *context) { |
1027 | return context->getImpl().f16Ty; |
1028 | } |
1029 | FloatTF32Type FloatTF32Type::get(MLIRContext *context) { |
1030 | return context->getImpl().tf32Ty; |
1031 | } |
1032 | Float32Type Float32Type::get(MLIRContext *context) { |
1033 | return context->getImpl().f32Ty; |
1034 | } |
1035 | Float64Type Float64Type::get(MLIRContext *context) { |
1036 | return context->getImpl().f64Ty; |
1037 | } |
1038 | Float80Type Float80Type::get(MLIRContext *context) { |
1039 | return context->getImpl().f80Ty; |
1040 | } |
1041 | Float128Type Float128Type::get(MLIRContext *context) { |
1042 | return context->getImpl().f128Ty; |
1043 | } |
1044 | |
1045 | /// Get an instance of the IndexType. |
1046 | IndexType IndexType::get(MLIRContext *context) { |
1047 | return context->getImpl().indexTy; |
1048 | } |
1049 | |
1050 | /// Return an existing integer type instance if one is cached within the |
1051 | /// context. |
1052 | static IntegerType |
1053 | getCachedIntegerType(unsigned width, |
1054 | IntegerType::SignednessSemantics signedness, |
1055 | MLIRContext *context) { |
1056 | if (signedness != IntegerType::Signless) |
1057 | return IntegerType(); |
1058 | |
1059 | switch (width) { |
1060 | case 1: |
1061 | return context->getImpl().int1Ty; |
1062 | case 8: |
1063 | return context->getImpl().int8Ty; |
1064 | case 16: |
1065 | return context->getImpl().int16Ty; |
1066 | case 32: |
1067 | return context->getImpl().int32Ty; |
1068 | case 64: |
1069 | return context->getImpl().int64Ty; |
1070 | case 128: |
1071 | return context->getImpl().int128Ty; |
1072 | default: |
1073 | return IntegerType(); |
1074 | } |
1075 | } |
1076 | |
1077 | IntegerType IntegerType::get(MLIRContext *context, unsigned width, |
1078 | IntegerType::SignednessSemantics signedness) { |
1079 | if (auto cached = getCachedIntegerType(width, signedness, context)) |
1080 | return cached; |
1081 | return Base::get(context, width, signedness); |
1082 | } |
1083 | |
1084 | IntegerType |
1085 | IntegerType::getChecked(function_ref<InFlightDiagnostic()> emitError, |
1086 | MLIRContext *context, unsigned width, |
1087 | SignednessSemantics signedness) { |
1088 | if (auto cached = getCachedIntegerType(width, signedness, context)) |
1089 | return cached; |
1090 | return Base::getChecked(emitError, context, width, signedness); |
1091 | } |
1092 | |
1093 | /// Get an instance of the NoneType. |
1094 | NoneType NoneType::get(MLIRContext *context) { |
1095 | if (NoneType cachedInst = context->getImpl().noneType) |
1096 | return cachedInst; |
1097 | // Note: May happen when initializing the singleton attributes of the builtin |
1098 | // dialect. |
1099 | return Base::get(context); |
1100 | } |
1101 | |
1102 | //===----------------------------------------------------------------------===// |
1103 | // Attribute uniquing |
1104 | //===----------------------------------------------------------------------===// |
1105 | |
1106 | /// Returns the storage uniquer used for constructing attribute storage |
1107 | /// instances. This should not be used directly. |
1108 | StorageUniquer &MLIRContext::getAttributeUniquer() { |
1109 | return getImpl().attributeUniquer; |
1110 | } |
1111 | |
1112 | /// Initialize the given attribute storage instance. |
1113 | void AttributeUniquer::initializeAttributeStorage(AttributeStorage *storage, |
1114 | MLIRContext *ctx, |
1115 | TypeID attrID) { |
1116 | storage->initializeAbstractAttribute(abstractAttr: AbstractAttribute::lookup(typeID: attrID, context: ctx)); |
1117 | } |
1118 | |
1119 | BoolAttr BoolAttr::get(MLIRContext *context, bool value) { |
1120 | return value ? context->getImpl().trueAttr : context->getImpl().falseAttr; |
1121 | } |
1122 | |
1123 | UnitAttr UnitAttr::get(MLIRContext *context) { |
1124 | return context->getImpl().unitAttr; |
1125 | } |
1126 | |
1127 | UnknownLoc UnknownLoc::get(MLIRContext *context) { |
1128 | return context->getImpl().unknownLocAttr; |
1129 | } |
1130 | |
1131 | DistinctAttrStorage * |
1132 | detail::DistinctAttributeUniquer::allocateStorage(MLIRContext *context, |
1133 | Attribute referencedAttr) { |
1134 | return context->getImpl().distinctAttributeAllocator.allocate(referencedAttr); |
1135 | } |
1136 | |
1137 | /// Return empty dictionary. |
1138 | DictionaryAttr DictionaryAttr::getEmpty(MLIRContext *context) { |
1139 | return context->getImpl().emptyDictionaryAttr; |
1140 | } |
1141 | |
1142 | void StringAttrStorage::initialize(MLIRContext *context) { |
1143 | // Check for a dialect namespace prefix, if there isn't one we don't need to |
1144 | // do any additional initialization. |
1145 | auto dialectNamePair = value.split(Separator: '.'); |
1146 | if (dialectNamePair.first.empty() || dialectNamePair.second.empty()) |
1147 | return; |
1148 | |
1149 | // If one exists, we check to see if this dialect is loaded. If it is, we set |
1150 | // the dialect now, if it isn't we record this storage for initialization |
1151 | // later if the dialect ever gets loaded. |
1152 | if ((referencedDialect = context->getLoadedDialect(name: dialectNamePair.first))) |
1153 | return; |
1154 | |
1155 | MLIRContextImpl &impl = context->getImpl(); |
1156 | llvm::sys::SmartScopedLock<true> lock(impl.dialectRefStrAttrMutex); |
1157 | impl.dialectReferencingStrAttrs[dialectNamePair.first].push_back(Elt: this); |
1158 | } |
1159 | |
1160 | /// Return an empty string. |
1161 | StringAttr StringAttr::get(MLIRContext *context) { |
1162 | return context->getImpl().emptyStringAttr; |
1163 | } |
1164 | |
1165 | //===----------------------------------------------------------------------===// |
1166 | // AffineMap uniquing |
1167 | //===----------------------------------------------------------------------===// |
1168 | |
1169 | StorageUniquer &MLIRContext::getAffineUniquer() { |
1170 | return getImpl().affineUniquer; |
1171 | } |
1172 | |
1173 | AffineMap AffineMap::getImpl(unsigned dimCount, unsigned symbolCount, |
1174 | ArrayRef<AffineExpr> results, |
1175 | MLIRContext *context) { |
1176 | auto &impl = context->getImpl(); |
1177 | auto *storage = impl.affineUniquer.get<AffineMapStorage>( |
1178 | initFn: [&](AffineMapStorage *storage) { storage->context = context; }, args&: dimCount, |
1179 | args&: symbolCount, args&: results); |
1180 | return AffineMap(storage); |
1181 | } |
1182 | |
1183 | /// Check whether the arguments passed to the AffineMap::get() are consistent. |
1184 | /// This method checks whether the highest index of dimensional identifier |
1185 | /// present in result expressions is less than `dimCount` and the highest index |
1186 | /// of symbolic identifier present in result expressions is less than |
1187 | /// `symbolCount`. |
1188 | LLVM_ATTRIBUTE_UNUSED static bool |
1189 | willBeValidAffineMap(unsigned dimCount, unsigned symbolCount, |
1190 | ArrayRef<AffineExpr> results) { |
1191 | int64_t maxDimPosition = -1; |
1192 | int64_t maxSymbolPosition = -1; |
1193 | getMaxDimAndSymbol(exprsList: ArrayRef<ArrayRef<AffineExpr>>(results), maxDim&: maxDimPosition, |
1194 | maxSym&: maxSymbolPosition); |
1195 | if ((maxDimPosition >= dimCount) || (maxSymbolPosition >= symbolCount)) { |
1196 | LLVM_DEBUG( |
1197 | llvm::dbgs() |
1198 | << "maximum dimensional identifier position in result expression must " |
1199 | "be less than `dimCount` and maximum symbolic identifier position " |
1200 | "in result expression must be less than `symbolCount`\n" ); |
1201 | return false; |
1202 | } |
1203 | return true; |
1204 | } |
1205 | |
1206 | AffineMap AffineMap::get(MLIRContext *context) { |
1207 | return getImpl(/*dimCount=*/0, /*symbolCount=*/0, /*results=*/{}, context); |
1208 | } |
1209 | |
1210 | AffineMap AffineMap::get(unsigned dimCount, unsigned symbolCount, |
1211 | MLIRContext *context) { |
1212 | return getImpl(dimCount, symbolCount, /*results=*/{}, context); |
1213 | } |
1214 | |
1215 | AffineMap AffineMap::get(unsigned dimCount, unsigned symbolCount, |
1216 | AffineExpr result) { |
1217 | assert(willBeValidAffineMap(dimCount, symbolCount, {result})); |
1218 | return getImpl(dimCount, symbolCount, results: {result}, context: result.getContext()); |
1219 | } |
1220 | |
1221 | AffineMap AffineMap::get(unsigned dimCount, unsigned symbolCount, |
1222 | ArrayRef<AffineExpr> results, MLIRContext *context) { |
1223 | assert(willBeValidAffineMap(dimCount, symbolCount, results)); |
1224 | return getImpl(dimCount, symbolCount, results, context); |
1225 | } |
1226 | |
1227 | //===----------------------------------------------------------------------===// |
1228 | // Integer Sets: these are allocated into the bump pointer, and are immutable. |
1229 | // Unlike AffineMap's, these are uniqued only if they are small. |
1230 | //===----------------------------------------------------------------------===// |
1231 | |
1232 | IntegerSet IntegerSet::get(unsigned dimCount, unsigned symbolCount, |
1233 | ArrayRef<AffineExpr> constraints, |
1234 | ArrayRef<bool> eqFlags) { |
1235 | // The number of constraints can't be zero. |
1236 | assert(!constraints.empty()); |
1237 | assert(constraints.size() == eqFlags.size()); |
1238 | |
1239 | auto &impl = constraints[0].getContext()->getImpl(); |
1240 | auto *storage = impl.affineUniquer.get<IntegerSetStorage>( |
1241 | initFn: [](IntegerSetStorage *) {}, args&: dimCount, args&: symbolCount, args&: constraints, args&: eqFlags); |
1242 | return IntegerSet(storage); |
1243 | } |
1244 | |
1245 | //===----------------------------------------------------------------------===// |
1246 | // StorageUniquerSupport |
1247 | //===----------------------------------------------------------------------===// |
1248 | |
1249 | /// Utility method to generate a callback that can be used to generate a |
1250 | /// diagnostic when checking the construction invariants of a storage object. |
1251 | /// This is defined out-of-line to avoid the need to include Location.h. |
1252 | llvm::unique_function<InFlightDiagnostic()> |
1253 | mlir::detail::getDefaultDiagnosticEmitFn(MLIRContext *ctx) { |
1254 | return [ctx] { return emitError(UnknownLoc::get(ctx)); }; |
1255 | } |
1256 | llvm::unique_function<InFlightDiagnostic()> |
1257 | mlir::detail::getDefaultDiagnosticEmitFn(const Location &loc) { |
1258 | return [=] { return emitError(loc); }; |
1259 | } |
1260 | |