Initial commit

.buckjavaargs

@@ -0,0 +1,2 @@
+-Dfile.encoding=UTF-8
+-Dsun.jnu.encoding=UTF-8

.github/CONTRIBUTING.md

@@ -0,0 +1,11 @@
+If you are submitting a feature request, please preface the title with [feature request].
+If you are submitting a bug report, please fill in the following details.
+
+## Issue description
+
+Provide a short description.
+
+## Code example
+
+Please try to provide a minimal example to repro the bug.
+Error messages and stack traces are also helpful.

.github/ISSUE_TEMPLATE/bug-report.md

@@ -0,0 +1,36 @@
+---
+name: "\U0001F41B Bug Report"
+about: Submit a bug report to help us improve LabGraph
+
+---
+
+## 🐛 Bug
+
+<!-- A clear and concise description of what the bug is. -->
+
+## To Reproduce
+
+Steps to reproduce the behavior:
+
+1.
+1.
+1.
+
+<!-- If you have a code sample, error messages, stack traces, please provide it here as well -->
+
+## Expected behavior
+
+<!-- A clear and concise description of what you expected to happen. -->
+
+## Environment
+
+```
+
+ - LabGraph Version (e.g., 1.0):
+ - OS (e.g., Linux/Mac/Windows):
+ - Python version:
+ - Any other relevant information:
+
+## Additional context
+
+<!-- Add any other context about the problem here. -->

.github/ISSUE_TEMPLATE/documentation.md

@@ -0,0 +1,9 @@
+---
+name: "\U0001F4DA Documentation"
+about: Report an issue related to https://github.com/facebookresearch/labgraph/tree/master/docs
+
+---
+
+## 📚 Documentation
+
+<!-- A clear and concise description of what content in https://github.com/facebookresearch/labgraph/tree/master/docs is an issue.  -->

.github/ISSUE_TEMPLATE/feature-request.md

@@ -0,0 +1,24 @@
+---
+name: "\U0001F680Feature Request"
+about: Submit a proposal/request for a new LabGraph feature
+
+---
+
+## 🚀 Feature
+<!-- A clear and concise description of the feature proposal -->
+
+## Motivation
+
+<!-- Please outline the motivation for the proposal. Is your feature request related to a problem? e.g., I'm always frustrated when [...]. If this is related to another GitHub issue, please link here too -->
+
+## Pitch
+
+<!-- A clear and concise description of what you want to happen. -->
+
+## Alternatives
+
+<!-- A clear and concise description of any alternative solutions or features you've considered, if any. -->
+
+## Additional context
+
+<!-- Add any other context or screenshots about the feature request here. -->

.github/ISSUE_TEMPLATE/questions-help-support.md

@@ -0,0 +1,7 @@
+---
+name: "❓Questions/Help/Support"
+about: Do you need support? We have resources.
+
+---
+
+## ❓ Questions and Help

.github/PULL_REQUEST_TEMPLATE.md

@@ -0,0 +1,33 @@
+## Description
+
+Please include a summary of the feature or issue being fixed. Please also include relevant motivation and context. List any dependencies that are required for this change.
+
+Fixes #(issue)
+
+## Type of change
+
+Please delete options that are not relevant.
+
+- [ ] Bug fix (non-breaking change which fixes an issue)
+- [ ] New feature (non-breaking change which adds functionality)
+- [ ] Breaking change (fix or feature that would cause existing functionality to not work as expected)
+- [ ] This change requires a documentation update
+
+## Feature/Issue validation/testing
+
+Please describe the tests [UT/IT] that you ran to verify your changes and relevent result summary. Provide instructions so it can be reproduced.
+Please also list any relevant details for your test configuration.
+
+- [ ] Test A
+- [ ] Test B
+
+- Unit Test / Integration Test (UT/IT) execution results
+
+- Logs
+
+## Checklist:
+
+- [ ] Have you added tests that prove your fix is effective or that this feature works?
+- [ ] New and existing unit tests pass locally with these changes?
+- [ ] Has code been commented, particularly in hard-to-understand areas?
+- [ ] Have you made corresponding changes to the documentation?

BUCK

@@ -0,0 +1,264 @@
+#!/usr/bin/env python3
+# Copyright 2004-present Facebook. All Rights Reserved.
+
+load("//:DEFS", "PLATFORM")
+
+cthulhu_srcs = [
+    "Cthulhu/src/Aligner.cpp",
+    "Cthulhu/src/AlignerMeta.cpp",
+    "Cthulhu/src/BufferTypes.cpp",
+    "Cthulhu/src/Clock.cpp",
+    "Cthulhu/src/Context.cpp",
+    "Cthulhu/src/Dispatcher.cpp",
+    "Cthulhu/src/MemoryPoolLocalImpl.cpp",
+    "Cthulhu/src/QueueingAligner.cpp",
+    "Cthulhu/src/PerformanceMonitor.cpp",
+    "Cthulhu/src/RawDynamic.cpp",
+    "Cthulhu/src/Serialization.cpp",
+    "Cthulhu/src/StreamConfigEquality.cpp",
+    "Cthulhu/src/StreamInterface.cpp",
+    "Cthulhu/src/StreamType.cpp",
+    "Cthulhu/src/SubAligner.cpp",
+    "Cthulhu/src/SubAlignerImpl.cpp",
+    "Cthulhu/src/TypeHelpers.cpp",
+]
+
+cthulhu_public_hdrs = [
+    "Cthulhu/include/cthulhu/Aligner.h",
+    "Cthulhu/include/cthulhu/AlignerMeta.h",
+    "Cthulhu/include/cthulhu/BufferTypes.h",
+    "Cthulhu/include/cthulhu/Clock.h",
+    "Cthulhu/include/cthulhu/ClockManagerInterface.h",
+    "Cthulhu/include/cthulhu/Context.h",
+    "Cthulhu/include/cthulhu/ContextImpl.h",
+    "Cthulhu/include/cthulhu/ContextImpl_details.h",
+    "Cthulhu/include/cthulhu/ContextRegistryInterface.h",
+    "Cthulhu/include/cthulhu/Dispatcher.h",
+    "Cthulhu/include/cthulhu/FieldData.h",
+    "Cthulhu/include/cthulhu/ForceCleanable.h",
+    "Cthulhu/include/cthulhu/Framework.h",
+    "Cthulhu/include/cthulhu/FrameworkBase.h",
+    "Cthulhu/include/cthulhu/LogDisabling.h",
+    "Cthulhu/include/cthulhu/MemoryPoolInterface.h",
+    "Cthulhu/include/cthulhu/PerformanceMonitor.h",
+    "Cthulhu/include/cthulhu/QueueingAligner.h",
+    "Cthulhu/include/cthulhu/RawDynamic.h",
+    "Cthulhu/include/cthulhu/Serialization.h",
+    "Cthulhu/include/cthulhu/StreamConfigEquality.h",
+    "Cthulhu/include/cthulhu/StreamInterface.h",
+    "Cthulhu/include/cthulhu/StreamRegistryInterface.h",
+    "Cthulhu/include/cthulhu/StreamType.h",
+    "Cthulhu/include/cthulhu/SubAligner.h",
+    "Cthulhu/include/cthulhu/TypeHelpers.h",
+    "Cthulhu/include/cthulhu/TypeRegistryInterface.h",
+    "Cthulhu/include/cthulhu/VulkanUtil.h",
+]
+
+cxx_library(
+    name="CthulhuCore",
+    preferred_linkage="static",
+    srcs=cthulhu_srcs,
+    public_include_directories=["Cthulhu/include"],
+    exported_headers=cthulhu_public_hdrs,
+    deps=[
+        "//logging:logging",
+        "//third-party/boost:boost",
+    ],
+    link_whole=True,
+    visibility=["PUBLIC"],
+)
+
+cxx_library(
+    name="CthulhuVulkanUtilStub",
+    preferred_linkage="static",
+    srcs=["Cthulhu/src/VulkanUtil.cpp"],
+    deps=[":CthulhuCore"],
+)
+
+cthulhu_private_local_hdrs = [
+    "Cthulhu/src/ClockLocal.h",
+    "Cthulhu/src/ClockManagerLocal.h",
+    "Cthulhu/src/ContextRegistryLocal.h",
+    "Cthulhu/src/MemoryPoolLocal.h",
+    "Cthulhu/src/StreamRegistryLocal.h",
+    "Cthulhu/src/TypeRegistryLocal.h",
+]
+
+cthulhu_local_srcs = [
+    "Cthulhu/src/ClockLocal.cpp",
+    "Cthulhu/src/ClockManagerLocal.cpp",
+    "Cthulhu/src/ContextRegistryLocal.cpp",
+    "Cthulhu/src/MemoryPoolLocal.cpp",
+    "Cthulhu/src/StreamRegistryLocal.cpp",
+    "Cthulhu/src/TypeRegistryLocal.cpp",
+]
+
+cxx_library(
+    name="CthulhuLocalComponents",
+    preferred_linkage="static",
+    srcs=cthulhu_local_srcs,
+    public_include_directories=["Cthulhu/include"],
+    link_whole=True,
+    raw_headers=cthulhu_private_local_hdrs,
+    deps=[":CthulhuCore", ":CthulhuVulkanUtilStub"],
+)
+
+cthulhu_private_ipc_hdrs = [
+    "Cthulhu/src/AuditorIPC.h",
+    "Cthulhu/src/ClockIPC.h",
+    "Cthulhu/src/ClockManagerIPC.h",
+    "Cthulhu/src/ContextRegistryIPC.h",
+    "Cthulhu/src/IPCEssentials.h",
+    "Cthulhu/src/MemoryPoolIPC.h",
+    "Cthulhu/src/MemoryPoolIPCHybrid.h",
+    "Cthulhu/src/StreamInterfaceIPC.h",
+    "Cthulhu/src/StreamRegistryIPC.h",
+    "Cthulhu/src/StreamRegistryIPCHybrid.h",
+    "Cthulhu/src/TypeRegistryIPC.h",
+    "Cthulhu/src/boost/interprocess/android_shared_memory.hpp",
+    "Cthulhu/src/boost/interprocess/managed_android_shared_memory.hpp",
+    "Cthulhu/src/boost/interprocess/detail/managed_open_or_create_impl_ashmem.hpp",
+]
+
+cthulhu_ipc_srcs = [
+    "Cthulhu/src/AuditorIPC.cpp",
+    "Cthulhu/src/ClockIPC.cpp",
+    "Cthulhu/src/ClockManagerIPC.cpp",
+    "Cthulhu/src/ContextRegistryIPC.cpp",
+    "Cthulhu/src/FrameworkIPCHybrid.cpp",
+    "Cthulhu/src/MemoryPoolIPC.cpp",
+    "Cthulhu/src/MemoryPoolIPCHybrid.cpp",
+    "Cthulhu/src/StreamInterfaceIPC.cpp",
+    "Cthulhu/src/StreamRegistryIPCHybrid.cpp",
+    "Cthulhu/src/TypeRegistryIPC.cpp",
+]
+
+cxx_library(
+    name="CthulhuIPCHybridBase",
+    preferred_linkage="static",
+    srcs=cthulhu_ipc_srcs,
+    include_directories=["Cthulhu"],
+    link_whole=True,
+    exported_preprocessor_flags=["-DCTHULHU_FRAMEWORK_IPCHYBRID"],
+    raw_headers=cthulhu_private_ipc_hdrs,
+    deps=[
+        ":CthulhuCore",
+        ":CthulhuLocalComponents",
+        "//third-party/boost:boost",
+        "//third-party/boost:boost_date_time",
+        "//third-party/boost:boost_thread",
+    ],
+)
+
+cxx_library(
+    name="CthulhuIPCHybrid",
+    preferred_linkage="static",
+    link_whole=True,
+    srcs=[
+        "Cthulhu/src/FrameworkInstance.cpp",
+    ],
+    exported_linker_flags={
+        "linux": ["-lrt", "-lpthread"],
+        "win": ["/IGNORE:4217"],
+    }.get(PLATFORM, []),
+    deps=[":CthulhuIPCHybridBase"],
+    visibility=["PUBLIC"],
+)
+
+cxx_library(
+    name="bindings_core",
+    preferred_linkage="static",
+    srcs=[
+        "Cthulhu/modules/pythonbindings/core.cpp",
+        "Cthulhu/modules/pythonbindings/cuda_util.cpp",
+    ],
+    public_include_directories=["Cthulhu/modules/pythonbindings/include"],
+    raw_headers=[
+        "Cthulhu/modules/pythonbindings/include/cthulhu/bindings/core.h",
+        "Cthulhu/modules/pythonbindings/include/cthulhu/bindings/cuda_util.h",
+    ],
+    deps=[
+        ":CthulhuCore",
+        "//third-party/pybind11:pybind11",
+    ],
+)
+
+cxx_library(
+    name="cthulhubindings",
+    preferred_linkage="shared",
+    srcs=["Cthulhu/modules/pythonbindings/module.cpp"],
+    compiler_flags=["-fvisibility=hidden", "-DCTHULHU_EXTERNAL=1"],
+    deps=[
+        ":bindings_core",
+        ":CthulhuIPCHybrid",
+        "//third-party/pybind11:pybind11",
+    ],
+)
+
+cxx_library(
+    name="labgraph_cpp",
+    preferred_linkage="static",
+    srcs=[
+        "labgraph/cpp/Node.cpp",
+    ],
+    public_include_directories=["labgraph/cpp/include"],
+    exported_headers=[
+        "labgraph/cpp/include/labgraph/bindings.h",
+        "labgraph/cpp/include/labgraph/Node.h",
+        "labgraph/cpp/include/labgraph/NodeImpl.h",
+    ],
+    deps=[
+        ":CthulhuCore",
+        "//third-party/pybind11:pybind11",
+    ],
+    link_whole=True,
+    visibility=["PUBLIC"],
+)
+
+cxx_library(
+    name="labgraph_cpp_bindings",
+    preferred_linkage="shared",
+    srcs=["labgraph/cpp/bindings.cpp"],
+    public_include_directories=["labgraph/cpp/include"],
+    exported_headers=[
+        "labgraph/cpp/include/labgraph/bindings.h",
+    ],
+    deps=[
+        "//third-party/pybind11:pybind11",
+        ":labgraph_cpp",
+        ":CthulhuIPCHybrid",
+    ],
+    link_style="static" if PLATFORM == "win" else "static_pic",
+    visibility=["PUBLIC"],
+    compiler_flags=["-fvisibility=hidden"],
+    soname="labgraph_cpp.$(ext)",
+)
+
+cxx_library(
+    name="MyCPPNodes",
+    srcs=[
+        "labgraph/cpp/tests/MyCPPSink.cpp",
+        "labgraph/cpp/tests/MyCPPSource.cpp",
+        "labgraph/cpp/tests/bindings.cpp",
+    ],
+    headers=[
+        "labgraph/cpp/tests/MyCPPSink.h",
+        "labgraph/cpp/tests/MyCPPSource.h",
+        "labgraph/cpp/tests/TestSample.h",
+    ],
+    deps=[
+        ":labgraph_cpp",
+        ":CthulhuCore",
+        ":CthulhuIPCHybrid",
+        "//third-party/pybind11:pybind11",
+    ],
+    soname="MyCPPNodes.$(ext)",
+    compiler_flags=["-fvisibility=hidden"],
+    link_style="static" if PLATFORM == "win" else "static_pic",
+)
+
+cxx_binary(
+    name="CthulhuIPCClean",
+    srcs=["Cthulhu/ipc_cleanup.cpp"],
+    deps=[":CthulhuIPCHybrid"],
+)