Compare commits

..

4 Commits

Author SHA1 Message Date
Bronek Kozicki
d3f4720091 Merge branch 'develop' into Bronek/fortify_pseudo_account 2025-03-27 21:57:02 +00:00
Bronek Kozicki
0dc4c452f1 Add fixPseudoAccount 2025-03-27 21:42:31 +00:00
Bronek Kozicki
b96abfc230 Minor 2025-03-27 19:59:22 +00:00
Bronek Kozicki
f7720b08ec Factor out createPseudoAccount away from AMM 2025-03-27 15:13:13 +00:00
582 changed files with 18158 additions and 40847 deletions

View File

@@ -94,4 +94,3 @@ SpacesInSquareBrackets: false
Standard: Cpp11 Standard: Cpp11
TabWidth: 8 TabWidth: 8
UseTab: Never UseTab: Never
QualifierAlignment: Right

View File

@@ -7,13 +7,13 @@ comment:
show_carryforward_flags: false show_carryforward_flags: false
coverage: coverage:
range: "70..85" range: "60..80"
precision: 1 precision: 1
round: nearest round: nearest
status: status:
project: project:
default: default:
target: 75% target: 60%
threshold: 2% threshold: 2%
patch: patch:
default: default:

8
.github/CODEOWNERS vendored
View File

@@ -1,8 +0,0 @@
# Allow anyone to review any change by default.
*
# Require the rpc-reviewers team to review changes to the rpc code.
include/xrpl/protocol/ @xrplf/rpc-reviewers
src/libxrpl/protocol/ @xrplf/rpc-reviewers
src/xrpld/rpc/ @xrplf/rpc-reviewers
src/xrpld/app/misc/ @xrplf/rpc-reviewers

View File

@@ -6,29 +6,36 @@ inputs:
runs: runs:
using: composite using: composite
steps: steps:
- name: unlock Conan
shell: bash
run: conan remove --locks
- name: export custom recipes - name: export custom recipes
shell: bash shell: bash
run: | run: |
conan export --version 1.1.10 external/snappy conan config set general.revisions_enabled=1
conan export --version 4.0.3 external/soci conan export external/snappy snappy/1.1.10@
conan export external/rocksdb rocksdb/9.7.3@
conan export external/soci soci/4.0.3@
conan export external/nudb nudb/2.0.8@
- name: add Ripple Conan remote - name: add Ripple Conan remote
if: env.CONAN_URL != ''
shell: bash shell: bash
run: | run: |
if conan remote list | grep -q "ripple"; then conan remote list
conan remote remove ripple conan remote remove ripple || true
echo "Removed conan remote ripple" # Do not quote the URL. An empty string will be accepted (with
fi # a non-fatal warning), but a missing argument will not.
conan remote add --index 0 ripple "${CONAN_URL}" conan remote add ripple ${{ env.CONAN_URL }} --insert 0
echo "Added conan remote ripple at ${CONAN_URL}"
- name: try to authenticate to Ripple Conan remote - name: try to authenticate to Ripple Conan remote
if: env.CONAN_LOGIN_USERNAME_RIPPLE != '' && env.CONAN_PASSWORD_RIPPLE != ''
id: remote id: remote
shell: bash shell: bash
run: | run: |
echo "Authenticating to ripple remote..." # `conan user` implicitly uses the environment variables
conan remote auth ripple --force # CONAN_LOGIN_USERNAME_<REMOTE> and CONAN_PASSWORD_<REMOTE>.
conan remote list-users # https://docs.conan.io/1/reference/commands/misc/user.html#using-environment-variables
# https://docs.conan.io/1/reference/env_vars.html#conan-login-username-conan-login-username-remote-name
# https://docs.conan.io/1/reference/env_vars.html#conan-password-conan-password-remote-name
echo outcome=$(conan user --remote ripple --password >&2 \
&& echo success || echo failure) | tee ${GITHUB_OUTPUT}
- name: list missing binaries - name: list missing binaries
id: binaries id: binaries
shell: bash shell: bash
@@ -44,7 +51,7 @@ runs:
conan install \ conan install \
--output-folder . \ --output-folder . \
--build missing \ --build missing \
--options:host "&:tests=True" \ --options tests=True \
--options:host "&:xrpld=True" \ --options xrpld=True \
--settings:all build_type=${{ inputs.configuration }} \ --settings build_type=${{ inputs.configuration }} \
.. ..

View File

@@ -1,33 +1,28 @@
name: clang-format name: clang-format
on: on: [push, pull_request]
push:
pull_request:
types: [opened, reopened, synchronize, ready_for_review]
jobs: jobs:
check: check:
if: ${{ github.event_name == 'push' || github.event.pull_request.draft != true || contains(github.event.pull_request.labels.*.name, 'DraftRunCI') }} runs-on: ubuntu-24.04
runs-on: [self-hosted, Linux, X64, devbox] env:
container: ghcr.io/xrplf/ci/tools-rippled-clang-format CLANG_VERSION: 18
steps: steps:
# For jobs running in containers, $GITHUB_WORKSPACE and ${{ github.workspace }} might not be the
# same directory. The actions/checkout step is *supposed* to checkout into $GITHUB_WORKSPACE and
# then add it to safe.directory (see instructions at https://github.com/actions/checkout)
# but that's apparently not happening for some container images. We can't be sure what is actually
# happening, so let's pre-emptively add both directories to safe.directory. There's a
# Github issue opened in 2022 and not resolved in 2025 https://github.com/actions/runner/issues/2058 ¯\_(ツ)_/¯
- run: |
git config --global --add safe.directory $GITHUB_WORKSPACE
git config --global --add safe.directory ${{ github.workspace }}
- uses: actions/checkout@v4 - uses: actions/checkout@v4
- name: Format first-party sources - name: Install clang-format
run: | run: |
clang-format --version codename=$( lsb_release --codename --short )
find include src tests -type f \( -name '*.cpp' -o -name '*.hpp' -o -name '*.h' -o -name '*.ipp' \) -exec clang-format -i {} + sudo tee /etc/apt/sources.list.d/llvm.list >/dev/null <<EOF
deb http://apt.llvm.org/${codename}/ llvm-toolchain-${codename}-${CLANG_VERSION} main
deb-src http://apt.llvm.org/${codename}/ llvm-toolchain-${codename}-${CLANG_VERSION} main
EOF
wget -O - https://apt.llvm.org/llvm-snapshot.gpg.key | sudo apt-key add
sudo apt-get update
sudo apt-get install clang-format-${CLANG_VERSION}
- name: Format first-party sources
run: find include src tests -type f \( -name '*.cpp' -o -name '*.hpp' -o -name '*.h' -o -name '*.ipp' \) -exec clang-format-${CLANG_VERSION} -i {} +
- name: Check for differences - name: Check for differences
id: assert id: assert
shell: bash
run: | run: |
set -o pipefail set -o pipefail
git diff --exit-code | tee "clang-format.patch" git diff --exit-code | tee "clang-format.patch"
@@ -59,6 +54,6 @@ jobs:
in your repo, commit, and push. in your repo, commit, and push.
run: | run: |
echo "${PREAMBLE}" echo "${PREAMBLE}"
clang-format --version clang-format-${CLANG_VERSION} --version
echo "${SUGGESTION}" echo "${SUGGESTION}"
exit 1 exit 1

View File

@@ -10,11 +10,11 @@ concurrency:
cancel-in-progress: true cancel-in-progress: true
jobs: jobs:
documentation: job:
runs-on: ubuntu-latest runs-on: ubuntu-latest
permissions: permissions:
contents: write contents: write
container: ghcr.io/xrplf/rippled-build-ubuntu:aaf5e3e container: rippleci/rippled-build-ubuntu:aaf5e3e
steps: steps:
- name: checkout - name: checkout
uses: actions/checkout@v4 uses: actions/checkout@v4

View File

@@ -1,13 +1,9 @@
name: levelization name: levelization
on: on: [push, pull_request]
push:
pull_request:
types: [opened, reopened, synchronize, ready_for_review]
jobs: jobs:
check: check:
if: ${{ github.event_name == 'push' || github.event.pull_request.draft != true || contains(github.event.pull_request.labels.*.name, 'DraftRunCI') }}
runs-on: ubuntu-latest runs-on: ubuntu-latest
env: env:
CLANG_VERSION: 10 CLANG_VERSION: 10

View File

@@ -1,6 +1,6 @@
name: Check libXRPL compatibility with Clio name: Check libXRPL compatibility with Clio
env: env:
CONAN_URL: http://18.143.149.228:8081/artifactory/api/conan/dev CONAN_URL: http://18.143.149.228:8081/artifactory/api/conan/conan-non-prod
CONAN_LOGIN_USERNAME_RIPPLE: ${{ secrets.CONAN_USERNAME }} CONAN_LOGIN_USERNAME_RIPPLE: ${{ secrets.CONAN_USERNAME }}
CONAN_PASSWORD_RIPPLE: ${{ secrets.CONAN_TOKEN }} CONAN_PASSWORD_RIPPLE: ${{ secrets.CONAN_TOKEN }}
on: on:
@@ -8,21 +8,19 @@ on:
paths: paths:
- 'src/libxrpl/protocol/BuildInfo.cpp' - 'src/libxrpl/protocol/BuildInfo.cpp'
- '.github/workflows/libxrpl.yml' - '.github/workflows/libxrpl.yml'
types: [opened, reopened, synchronize, ready_for_review]
concurrency: concurrency:
group: ${{ github.workflow }}-${{ github.ref }} group: ${{ github.workflow }}-${{ github.ref }}
cancel-in-progress: true cancel-in-progress: true
jobs: jobs:
publish: publish:
if: ${{ github.event_name == 'push' || github.event.pull_request.draft != true || contains(github.event.pull_request.labels.*.name, 'DraftRunCI') }}
name: Publish libXRPL name: Publish libXRPL
outputs: outputs:
outcome: ${{ steps.upload.outputs.outcome }} outcome: ${{ steps.upload.outputs.outcome }}
version: ${{ steps.version.outputs.version }} version: ${{ steps.version.outputs.version }}
channel: ${{ steps.channel.outputs.channel }} channel: ${{ steps.channel.outputs.channel }}
runs-on: [self-hosted, heavy] runs-on: [self-hosted, heavy]
container: ghcr.io/xrplf/rippled-build-ubuntu:aaf5e3e container: rippleci/rippled-build-ubuntu:aaf5e3e
steps: steps:
- name: Wait for essential checks to succeed - name: Wait for essential checks to succeed
uses: lewagon/wait-on-check-action@v1.3.4 uses: lewagon/wait-on-check-action@v1.3.4

View File

@@ -1,7 +1,6 @@
name: macos name: macos
on: on:
pull_request: pull_request:
types: [opened, reopened, synchronize, ready_for_review]
push: push:
# If the branches list is ever changed, be sure to change it on all # If the branches list is ever changed, be sure to change it on all
# build/test jobs (nix, macos, windows, instrumentation) # build/test jobs (nix, macos, windows, instrumentation)
@@ -15,23 +14,10 @@ on:
concurrency: concurrency:
group: ${{ github.workflow }}-${{ github.ref }} group: ${{ github.workflow }}-${{ github.ref }}
cancel-in-progress: true cancel-in-progress: true
# This part of Conan configuration is specific to this workflow only; we do not want
# to pollute conan/profiles directory with settings which might not work for others
env:
CONAN_URL: http://18.143.149.228:8081/artifactory/api/conan/dev
CONAN_LOGIN_USERNAME_RIPPLE: ${{ secrets.CONAN_USERNAME }}
CONAN_PASSWORD_RIPPLE: ${{ secrets.CONAN_TOKEN }}
CONAN_GLOBAL_CONF: |
core.download:parallel={{os.cpu_count()}}
core.upload:parallel={{os.cpu_count()}}
tools.build:jobs={{ (os.cpu_count() * 4/5) | int }}
tools.build:verbosity=verbose
tools.compilation:verbosity=verbose
jobs: jobs:
test: test:
if: ${{ github.event_name == 'push' || github.event.pull_request.draft != true || contains(github.event.pull_request.labels.*.name, 'DraftRunCI') }}
strategy: strategy:
matrix: matrix:
platform: platform:
@@ -40,22 +26,23 @@ jobs:
- Ninja - Ninja
configuration: configuration:
- Release - Release
runs-on: [self-hosted, macOS, devbox] runs-on: [self-hosted, macOS]
env: env:
# The `build` action requires these variables. # The `build` action requires these variables.
build_dir: .build build_dir: .build
NUM_PROCESSORS: 12 NUM_PROCESSORS: 12
steps: steps:
- name: checkout - name: checkout
uses: actions/checkout@11bd71901bbe5b1630ceea73d27597364c9af683 uses: actions/checkout@v4
- name: install Conan - name: install Conan
run: | run: |
brew install conan brew install conan@1
echo '/opt/homebrew/opt/conan@1/bin' >> $GITHUB_PATH
- name: install Ninja - name: install Ninja
if: matrix.generator == 'Ninja' if: matrix.generator == 'Ninja'
run: brew install ninja run: brew install ninja
- name: install python - name: install python
run: | run: |
if which python > /dev/null 2>&1; then if which python > /dev/null 2>&1; then
echo "Python executable exists" echo "Python executable exists"
else else
@@ -82,31 +69,16 @@ jobs:
nproc --version nproc --version
echo -n "nproc returns: " echo -n "nproc returns: "
nproc nproc
system_profiler SPHardwareDataType
sysctl -n hw.logicalcpu
clang --version
- name: configure Conan - name: configure Conan
run : | run : |
echo "${CONAN_GLOBAL_CONF}" >> $(conan config home)/global.conf conan profile new default --detect || true
conan config install conan/profiles/ -tf $(conan config home)/profiles/ conan profile update settings.compiler.cppstd=20 default
conan profile show
- name: export custom recipes
shell: bash
run: |
conan export --version 1.1.10 external/snappy
conan export --version 4.0.3 external/soci
- name: add Ripple Conan remote
if: env.CONAN_URL != ''
shell: bash
run: |
if conan remote list | grep -q "ripple"; then
conan remote remove ripple
echo "Removed conan remote ripple"
fi
conan remote add --index 0 ripple "${CONAN_URL}"
echo "Added conan remote ripple at ${CONAN_URL}"
- name: build dependencies - name: build dependencies
uses: ./.github/actions/dependencies uses: ./.github/actions/dependencies
env:
CONAN_URL: http://18.143.149.228:8081/artifactory/api/conan/conan-non-prod
CONAN_LOGIN_USERNAME_RIPPLE: ${{ secrets.CONAN_USERNAME }}
CONAN_PASSWORD_RIPPLE: ${{ secrets.CONAN_TOKEN }}
with: with:
configuration: ${{ matrix.configuration }} configuration: ${{ matrix.configuration }}
- name: build - name: build
@@ -119,7 +91,4 @@ jobs:
run: | run: |
n=$(nproc) n=$(nproc)
echo "Using $n test jobs" echo "Using $n test jobs"
${build_dir}/rippled --unittest --unittest-jobs $n
cd ${build_dir}
./rippled --unittest --unittest-jobs $n
ctest -j $n --output-on-failure

View File

@@ -1,7 +1,6 @@
name: nix name: nix
on: on:
pull_request: pull_request:
types: [opened, reopened, synchronize, ready_for_review]
push: push:
# If the branches list is ever changed, be sure to change it on all # If the branches list is ever changed, be sure to change it on all
# build/test jobs (nix, macos, windows) # build/test jobs (nix, macos, windows)
@@ -16,19 +15,6 @@ concurrency:
group: ${{ github.workflow }}-${{ github.ref }} group: ${{ github.workflow }}-${{ github.ref }}
cancel-in-progress: true cancel-in-progress: true
# This part of Conan configuration is specific to this workflow only; we do not want
# to pollute conan/profiles directory with settings which might not work for others
env:
CONAN_URL: http://18.143.149.228:8081/artifactory/api/conan/dev
CONAN_LOGIN_USERNAME_RIPPLE: ${{ secrets.CONAN_USERNAME }}
CONAN_PASSWORD_RIPPLE: ${{ secrets.CONAN_TOKEN }}
CONAN_GLOBAL_CONF: |
core.download:parallel={{ os.cpu_count() }}
core.upload:parallel={{ os.cpu_count() }}
tools.build:jobs={{ (os.cpu_count() * 4/5) | int }}
tools.build:verbosity=verbose
tools.compilation:verbosity=verbose
# This workflow has multiple job matrixes. # This workflow has multiple job matrixes.
# They can be considered phases because most of the matrices ("test", # They can be considered phases because most of the matrices ("test",
# "coverage", "conan", ) depend on the first ("dependencies"). # "coverage", "conan", ) depend on the first ("dependencies").
@@ -53,7 +39,6 @@ env:
jobs: jobs:
dependencies: dependencies:
if: ${{ github.event_name == 'push' || github.event.pull_request.draft != true || contains(github.event.pull_request.labels.*.name, 'DraftRunCI') }}
strategy: strategy:
fail-fast: false fail-fast: false
matrix: matrix:
@@ -67,45 +52,59 @@ jobs:
- Release - Release
include: include:
- compiler: gcc - compiler: gcc
compiler_version: 12 profile:
distro: ubuntu version: 11
codename: jammy cc: /usr/bin/gcc
cxx: /usr/bin/g++
- compiler: clang - compiler: clang
compiler_version: 16 profile:
distro: debian version: 14
codename: bookworm cc: /usr/bin/clang-14
runs-on: [self-hosted, Linux, X64, devbox] cxx: /usr/bin/clang++-14
container: ghcr.io/xrplf/ci/${{ matrix.distro }}-${{ matrix.codename }}:${{ matrix.compiler }}-${{ matrix.compiler_version }} runs-on: [self-hosted, heavy]
container: rippleci/rippled-build-ubuntu:aaf5e3e
env: env:
build_dir: .build build_dir: .build
steps: steps:
- name: upgrade conan
run: |
pip install --upgrade "conan<2"
- name: checkout - name: checkout
uses: actions/checkout@11bd71901bbe5b1630ceea73d27597364c9af683 uses: actions/checkout@v4
- name: check environment - name: check environment
run: | run: |
echo ${PATH} | tr ':' '\n' echo ${PATH} | tr ':' '\n'
lsb_release -a || true lsb_release -a || true
${{ matrix.compiler }}-${{ matrix.compiler_version }} --version ${{ matrix.profile.cc }} --version
conan --version conan --version
cmake --version cmake --version
env | sort env | sort
- name: configure Conan - name: configure Conan
run: | run: |
echo "${CONAN_GLOBAL_CONF}" >> $(conan config home)/global.conf conan profile new default --detect
conan config install conan/profiles/ -tf $(conan config home)/profiles/ conan profile update settings.compiler.cppstd=20 default
conan profile show conan profile update settings.compiler=${{ matrix.compiler }} default
conan profile update settings.compiler.version=${{ matrix.profile.version }} default
conan profile update settings.compiler.libcxx=libstdc++11 default
conan profile update env.CC=${{ matrix.profile.cc }} default
conan profile update env.CXX=${{ matrix.profile.cxx }} default
conan profile update conf.tools.build:compiler_executables='{"c": "${{ matrix.profile.cc }}", "cpp": "${{ matrix.profile.cxx }}"}' default
- name: archive profile - name: archive profile
# Create this archive before dependencies are added to the local cache. # Create this archive before dependencies are added to the local cache.
run: tar -czf conan.tar.gz -C ${CONAN_HOME} . run: tar -czf conan.tar -C ~/.conan .
- name: build dependencies - name: build dependencies
uses: ./.github/actions/dependencies uses: ./.github/actions/dependencies
env:
CONAN_URL: http://18.143.149.228:8081/artifactory/api/conan/conan-non-prod
CONAN_LOGIN_USERNAME_RIPPLE: ${{ secrets.CONAN_USERNAME }}
CONAN_PASSWORD_RIPPLE: ${{ secrets.CONAN_TOKEN }}
with: with:
configuration: ${{ matrix.configuration }} configuration: ${{ matrix.configuration }}
- name: upload archive - name: upload archive
uses: actions/upload-artifact@ea165f8d65b6e75b540449e92b4886f43607fa02 uses: actions/upload-artifact@v4
with: with:
name: ${{ matrix.platform }}-${{ matrix.compiler }}-${{ matrix.configuration }} name: ${{ matrix.platform }}-${{ matrix.compiler }}-${{ matrix.configuration }}
path: conan.tar.gz path: conan.tar
if-no-files-found: error if-no-files-found: error
test: test:
@@ -120,32 +119,26 @@ jobs:
configuration: configuration:
- Debug - Debug
- Release - Release
include:
- compiler: gcc
compiler_version: 12
distro: ubuntu
codename: jammy
- compiler: clang
compiler_version: 16
distro: debian
codename: bookworm
cmake-args: cmake-args:
- -
- "-Dunity=ON" - "-Dunity=ON"
needs: dependencies needs: dependencies
runs-on: [self-hosted, Linux, X64, devbox] runs-on: [self-hosted, heavy]
container: ghcr.io/xrplf/ci/${{ matrix.distro }}-${{ matrix.codename }}:${{ matrix.compiler }}-${{ matrix.compiler_version }} container: rippleci/rippled-build-ubuntu:aaf5e3e
env: env:
build_dir: .build build_dir: .build
steps: steps:
- name: upgrade conan
run: |
pip install --upgrade "conan<2"
- name: download cache - name: download cache
uses: actions/download-artifact@d3f86a106a0bac45b974a628896c90dbdf5c8093 uses: actions/download-artifact@v4
with: with:
name: ${{ matrix.platform }}-${{ matrix.compiler }}-${{ matrix.configuration }} name: ${{ matrix.platform }}-${{ matrix.compiler }}-${{ matrix.configuration }}
- name: extract cache - name: extract cache
run: | run: |
mkdir -p ${CONAN_HOME} mkdir -p ~/.conan
tar -xzf conan.tar.gz -C ${CONAN_HOME} tar -xzf conan.tar -C ~/.conan
- name: check environment - name: check environment
run: | run: |
env | sort env | sort
@@ -153,70 +146,11 @@ jobs:
conan --version conan --version
cmake --version cmake --version
- name: checkout - name: checkout
uses: actions/checkout@11bd71901bbe5b1630ceea73d27597364c9af683 uses: actions/checkout@v4
- name: dependencies
uses: ./.github/actions/dependencies
with:
configuration: ${{ matrix.configuration }}
- name: build
uses: ./.github/actions/build
with:
generator: Ninja
configuration: ${{ matrix.configuration }}
cmake-args: "-Dassert=TRUE -Dwerr=TRUE ${{ matrix.cmake-args }}"
- name: check linking
run: |
cd ${build_dir}
ldd ./rippled
if [ "$(ldd ./rippled | grep -E '(libstdc\+\+|libgcc)' | wc -l)" -eq 0 ]; then
echo 'The binary is statically linked.'
else
echo 'The binary is dynamically linked.'
exit 1
fi
- name: test
run: |
cd ${build_dir}
./rippled --unittest --unittest-jobs $(nproc)
ctest -j $(nproc) --output-on-failure
reference-fee-test:
strategy:
fail-fast: false
matrix:
platform:
- linux
compiler:
- gcc
configuration:
- Debug
cmake-args:
- "-DUNIT_TEST_REFERENCE_FEE=200"
- "-DUNIT_TEST_REFERENCE_FEE=1000"
needs: dependencies
runs-on: [self-hosted, Linux, X64, devbox]
container: ghcr.io/xrplf/ci/ubuntu-jammy:gcc-12
env:
build_dir: .build
steps:
- name: download cache
uses: actions/download-artifact@d3f86a106a0bac45b974a628896c90dbdf5c8093
with:
name: ${{ matrix.platform }}-${{ matrix.compiler }}-${{ matrix.configuration }}
- name: extract cache
run: |
mkdir -p ${CONAN_HOME}
tar -xzf conan.tar.gz -C ${CONAN_HOME}
- name: check environment
run: |
env | sort
echo ${PATH} | tr ':' '\n'
conan --version
cmake --version
- name: checkout
uses: actions/checkout@11bd71901bbe5b1630ceea73d27597364c9af683
- name: dependencies - name: dependencies
uses: ./.github/actions/dependencies uses: ./.github/actions/dependencies
env:
CONAN_URL: http://18.143.149.228:8081/artifactory/api/conan/conan-non-prod
with: with:
configuration: ${{ matrix.configuration }} configuration: ${{ matrix.configuration }}
- name: build - name: build
@@ -227,9 +161,7 @@ jobs:
cmake-args: "-Dassert=TRUE -Dwerr=TRUE ${{ matrix.cmake-args }}" cmake-args: "-Dassert=TRUE -Dwerr=TRUE ${{ matrix.cmake-args }}"
- name: test - name: test
run: | run: |
cd ${build_dir} ${build_dir}/rippled --unittest --unittest-jobs $(nproc)
./rippled --unittest --unittest-jobs $(nproc)
ctest -j $(nproc) --output-on-failure
coverage: coverage:
strategy: strategy:
@@ -242,19 +174,24 @@ jobs:
configuration: configuration:
- Debug - Debug
needs: dependencies needs: dependencies
runs-on: [self-hosted, Linux, X64, devbox] runs-on: [self-hosted, heavy]
container: ghcr.io/xrplf/ci/ubuntu-jammy:gcc-12 container: rippleci/rippled-build-ubuntu:aaf5e3e
env: env:
build_dir: .build build_dir: .build
steps: steps:
- name: upgrade conan
run: |
pip install --upgrade "conan<2"
- name: download cache - name: download cache
uses: actions/download-artifact@d3f86a106a0bac45b974a628896c90dbdf5c8093 uses: actions/download-artifact@v4
with: with:
name: ${{ matrix.platform }}-${{ matrix.compiler }}-${{ matrix.configuration }} name: ${{ matrix.platform }}-${{ matrix.compiler }}-${{ matrix.configuration }}
- name: extract cache - name: extract cache
run: | run: |
mkdir -p ${CONAN_HOME} mkdir -p ~/.conan
tar -xzf conan.tar.gz -C ${CONAN_HOME} tar -xzf conan.tar -C ~/.conan
- name: install gcovr
run: pip install "gcovr>=7,<8"
- name: check environment - name: check environment
run: | run: |
echo ${PATH} | tr ':' '\n' echo ${PATH} | tr ':' '\n'
@@ -262,11 +199,13 @@ jobs:
cmake --version cmake --version
gcovr --version gcovr --version
env | sort env | sort
ls ${CONAN_HOME} ls ~/.conan
- name: checkout - name: checkout
uses: actions/checkout@11bd71901bbe5b1630ceea73d27597364c9af683 uses: actions/checkout@v4
- name: dependencies - name: dependencies
uses: ./.github/actions/dependencies uses: ./.github/actions/dependencies
env:
CONAN_URL: http://18.143.149.228:8081/artifactory/api/conan/conan-non-prod
with: with:
configuration: ${{ matrix.configuration }} configuration: ${{ matrix.configuration }}
- name: build - name: build
@@ -288,7 +227,7 @@ jobs:
run: | run: |
mv "${build_dir}/coverage.xml" ./ mv "${build_dir}/coverage.xml" ./
- name: archive coverage report - name: archive coverage report
uses: actions/upload-artifact@ea165f8d65b6e75b540449e92b4886f43607fa02 uses: actions/upload-artifact@v4
with: with:
name: coverage.xml name: coverage.xml
path: coverage.xml path: coverage.xml
@@ -309,24 +248,23 @@ jobs:
conan: conan:
needs: dependencies needs: dependencies
runs-on: [self-hosted, Linux, X64, devbox] runs-on: [self-hosted, heavy]
container: container: rippleci/rippled-build-ubuntu:aaf5e3e
image: ghcr.io/xrplf/ci/ubuntu-jammy:gcc-12
env: env:
build_dir: .build build_dir: .build
platform: linux
compiler: gcc
compiler_version: 12
configuration: Release configuration: Release
steps: steps:
- name: upgrade conan
run: |
pip install --upgrade "conan<2"
- name: download cache - name: download cache
uses: actions/download-artifact@d3f86a106a0bac45b974a628896c90dbdf5c8093 uses: actions/download-artifact@v4
with: with:
name: ${{ env.platform }}-${{ env.compiler }}-${{ env.configuration }} name: linux-gcc-${{ env.configuration }}
- name: extract cache - name: extract cache
run: | run: |
mkdir -p ${CONAN_HOME} mkdir -p ~/.conan
tar -xzf conan.tar.gz -C ${CONAN_HOME} tar -xzf conan.tar -C ~/.conan
- name: check environment - name: check environment
run: | run: |
env | sort env | sort
@@ -334,66 +272,94 @@ jobs:
conan --version conan --version
cmake --version cmake --version
- name: checkout - name: checkout
uses: actions/checkout@11bd71901bbe5b1630ceea73d27597364c9af683 uses: actions/checkout@v4
- name: dependencies - name: dependencies
uses: ./.github/actions/dependencies uses: ./.github/actions/dependencies
env:
CONAN_URL: http://18.143.149.228:8081/artifactory/api/conan/conan-non-prod
with: with:
configuration: ${{ env.configuration }} configuration: ${{ env.configuration }}
- name: export - name: export
run: | run: |
conan export . --version head version=$(conan inspect --raw version .)
reference="xrpl/${version}@local/test"
conan remove -f ${reference} || true
conan export . local/test
echo "reference=${reference}" >> "${GITHUB_ENV}"
- name: build - name: build
run: | run: |
cd tests/conan cd tests/conan
mkdir ${build_dir} && cd ${build_dir} mkdir ${build_dir}
conan install .. \ cd ${build_dir}
--settings:all build_type=${configuration} \ conan install .. --output-folder . \
--output-folder . \ --require-override ${reference} --build missing
--build missing
cmake .. \ cmake .. \
-DCMAKE_TOOLCHAIN_FILE:FILEPATH=./build/${configuration}/generators/conan_toolchain.cmake \ -DCMAKE_TOOLCHAIN_FILE:FILEPATH=./build/${configuration}/generators/conan_toolchain.cmake \
-DCMAKE_BUILD_TYPE=${configuration} -DCMAKE_BUILD_TYPE=${configuration}
cmake --build . cmake --build .
./example | grep '^[[:digit:]]\+\.[[:digit:]]\+\.[[:digit:]]\+' ./example | grep '^[[:digit:]]\+\.[[:digit:]]\+\.[[:digit:]]\+'
# NOTE we are not using dependencies built above because it lags with
# compiler versions. Instrumentation requires clang version 16 or
# later
instrumentation-build: instrumentation-build:
needs: dependencies
runs-on: [self-hosted, Linux, X64, devbox]
container: ghcr.io/xrplf/ci/debian-bookworm:clang-16
env: env:
build_dir: .build CLANG_RELEASE: 16
strategy:
fail-fast: false
runs-on: [self-hosted, heavy]
container: debian:bookworm
steps: steps:
- name: download cache - name: install prerequisites
uses: actions/download-artifact@d3f86a106a0bac45b974a628896c90dbdf5c8093 env:
with: DEBIAN_FRONTEND: noninteractive
name: linux-clang-Debug
- name: extract cache
run: | run: |
mkdir -p ${CONAN_HOME} apt-get update
tar -xzf conan.tar.gz -C ${CONAN_HOME} apt-get install --yes --no-install-recommends \
clang-${CLANG_RELEASE} clang++-${CLANG_RELEASE} \
- name: check environment python3-pip python-is-python3 make cmake git wget
run: | apt-get clean
echo ${PATH} | tr ':' '\n' update-alternatives --install \
conan --version /usr/bin/clang clang /usr/bin/clang-${CLANG_RELEASE} 100 \
cmake --version --slave /usr/bin/clang++ clang++ /usr/bin/clang++-${CLANG_RELEASE}
env | sort update-alternatives --auto clang
ls ${CONAN_HOME} pip install --no-cache --break-system-packages "conan<2"
- name: checkout - name: checkout
uses: actions/checkout@11bd71901bbe5b1630ceea73d27597364c9af683 uses: actions/checkout@v4
- name: dependencies
uses: ./.github/actions/dependencies
with:
configuration: Debug
- name: prepare environment - name: prepare environment
run: | run: |
mkdir -p ${build_dir} mkdir ${GITHUB_WORKSPACE}/.build
echo "SOURCE_DIR=$(pwd)" >> $GITHUB_ENV echo "SOURCE_DIR=$GITHUB_WORKSPACE" >> $GITHUB_ENV
echo "BUILD_DIR=$(pwd)/${build_dir}" >> $GITHUB_ENV echo "BUILD_DIR=$GITHUB_WORKSPACE/.build" >> $GITHUB_ENV
echo "CC=/usr/bin/clang" >> $GITHUB_ENV
echo "CXX=/usr/bin/clang++" >> $GITHUB_ENV
- name: configure Conan
run: |
conan profile new --detect default
conan profile update settings.compiler=clang default
conan profile update settings.compiler.version=${CLANG_RELEASE} default
conan profile update settings.compiler.libcxx=libstdc++11 default
conan profile update settings.compiler.cppstd=20 default
conan profile update options.rocksdb=False default
conan profile update \
'conf.tools.build:compiler_executables={"c": "/usr/bin/clang", "cpp": "/usr/bin/clang++"}' default
conan profile update 'env.CXXFLAGS="-DBOOST_ASIO_DISABLE_CONCEPTS"' default
conan profile update 'conf.tools.build:cxxflags+=["-DBOOST_ASIO_DISABLE_CONCEPTS"]' default
conan export external/snappy snappy/1.1.10@
conan export external/soci soci/4.0.3@
- name: build dependencies
run: |
cd ${BUILD_DIR}
conan install ${SOURCE_DIR} \
--output-folder ${BUILD_DIR} \
--install-folder ${BUILD_DIR} \
--build missing \
--settings build_type=Debug
- name: build with instrumentation - name: build with instrumentation
run: | run: |
@@ -418,4 +384,3 @@ jobs:
run: | run: |
cd ${BUILD_DIR} cd ${BUILD_DIR}
./rippled -u --unittest-jobs $(( $(nproc)/4 )) ./rippled -u --unittest-jobs $(( $(nproc)/4 ))
ctest -j $(nproc) --output-on-failure

View File

@@ -2,7 +2,6 @@ name: windows
on: on:
pull_request: pull_request:
types: [opened, reopened, synchronize, ready_for_review]
push: push:
# If the branches list is ever changed, be sure to change it on all # If the branches list is ever changed, be sure to change it on all
# build/test jobs (nix, macos, windows, instrumentation) # build/test jobs (nix, macos, windows, instrumentation)
@@ -18,29 +17,16 @@ on:
concurrency: concurrency:
group: ${{ github.workflow }}-${{ github.ref }} group: ${{ github.workflow }}-${{ github.ref }}
cancel-in-progress: true cancel-in-progress: true
# This part of Conan configuration is specific to this workflow only; we do not want
# to pollute conan/profiles directory with settings which might not work for others
env:
CONAN_URL: http://18.143.149.228:8081/artifactory/api/conan/dev
CONAN_LOGIN_USERNAME_RIPPLE: ${{ secrets.CONAN_USERNAME }}
CONAN_PASSWORD_RIPPLE: ${{ secrets.CONAN_TOKEN }}
CONAN_GLOBAL_CONF: |
core.download:parallel={{os.cpu_count()}}
core.upload:parallel={{os.cpu_count()}}
tools.build:jobs=24
tools.build:verbosity=verbose
tools.compilation:verbosity=verbose
jobs: jobs:
test: test:
if: ${{ github.event_name == 'push' || github.event.pull_request.draft != true || contains(github.event.pull_request.labels.*.name, 'DraftRunCI') }}
strategy: strategy:
fail-fast: false fail-fast: false
matrix: matrix:
version: version:
- generator: Visual Studio 17 2022 - generator: Visual Studio 17 2022
runs-on: [self-hosted, Windows, devbox] runs-on: windows-2022
configuration: configuration:
- type: Release - type: Release
tests: true tests: true
@@ -54,11 +40,11 @@ jobs:
build_dir: .build build_dir: .build
steps: steps:
- name: checkout - name: checkout
uses: actions/checkout@11bd71901bbe5b1630ceea73d27597364c9af683 uses: actions/checkout@v4
- name: choose Python - name: choose Python
uses: actions/setup-python@a26af69be951a213d495a4c3e4e4022e16d87065 uses: actions/setup-python@v5
with: with:
python-version: 3.13 python-version: 3.9
- name: learn Python cache directory - name: learn Python cache directory
id: pip-cache id: pip-cache
shell: bash shell: bash
@@ -66,12 +52,12 @@ jobs:
python -m pip install --upgrade pip python -m pip install --upgrade pip
echo "dir=$(pip cache dir)" | tee ${GITHUB_OUTPUT} echo "dir=$(pip cache dir)" | tee ${GITHUB_OUTPUT}
- name: restore Python cache directory - name: restore Python cache directory
uses: actions/cache@5a3ec84eff668545956fd18022155c47e93e2684 uses: actions/cache@v4
with: with:
path: ${{ steps.pip-cache.outputs.dir }} path: ${{ steps.pip-cache.outputs.dir }}
key: ${{ runner.os }}-${{ hashFiles('.github/workflows/windows.yml') }} key: ${{ runner.os }}-${{ hashFiles('.github/workflows/windows.yml') }}
- name: install Conan - name: install Conan
run: pip install wheel conan run: pip install wheel 'conan<2'
- name: check environment - name: check environment
run: | run: |
dir env: dir env:
@@ -82,26 +68,17 @@ jobs:
- name: configure Conan - name: configure Conan
shell: bash shell: bash
run: | run: |
echo "${CONAN_GLOBAL_CONF}" >> $(conan config home)/global.conf conan profile new default --detect
conan config install conan/profiles/ -tf $(conan config home)/profiles/ conan profile update settings.compiler.cppstd=20 default
conan profile show conan profile update \
- name: export custom recipes settings.compiler.runtime=MT${{ matrix.configuration.runtime }} \
shell: bash default
run: |
conan export --version 1.1.10 external/snappy
conan export --version 4.0.3 external/soci
- name: add Ripple Conan remote
if: env.CONAN_URL != ''
shell: bash
run: |
if conan remote list | grep -q "ripple"; then
conan remote remove ripple
echo "Removed conan remote ripple"
fi
conan remote add --index 0 ripple "${CONAN_URL}"
echo "Added conan remote ripple at ${CONAN_URL}"
- name: build dependencies - name: build dependencies
uses: ./.github/actions/dependencies uses: ./.github/actions/dependencies
env:
CONAN_URL: http://18.143.149.228:8081/artifactory/api/conan/conan-non-prod
CONAN_LOGIN_USERNAME_RIPPLE: ${{ secrets.CONAN_USERNAME }}
CONAN_PASSWORD_RIPPLE: ${{ secrets.CONAN_TOKEN }}
with: with:
configuration: ${{ matrix.configuration.type }} configuration: ${{ matrix.configuration.type }}
- name: build - name: build
@@ -116,6 +93,5 @@ jobs:
shell: bash shell: bash
if: ${{ matrix.configuration.tests }} if: ${{ matrix.configuration.tests }}
run: | run: |
cd ${build_dir}/${{ matrix.configuration.type }} ${build_dir}/${{ matrix.configuration.type }}/rippled --unittest \
./rippled --unittest --unittest-jobs $(nproc) --unittest-jobs $(nproc)
ctest -j $(nproc) --output-on-failure

View File

@@ -1,6 +1,6 @@
# .pre-commit-config.yaml # .pre-commit-config.yaml
repos: repos:
- repo: https://github.com/pre-commit/mirrors-clang-format - repo: https://github.com/pre-commit/mirrors-clang-format
rev: v18.1.8 rev: v18.1.3
hooks: hooks:
- id: clang-format - id: clang-format

View File

@@ -83,17 +83,9 @@ The [commandline](https://xrpl.org/docs/references/http-websocket-apis/api-conve
The `network_id` field was added in the `server_info` response in version 1.5.0 (2019), but it is not returned in [reporting mode](https://xrpl.org/rippled-server-modes.html#reporting-mode). However, use of reporting mode is now discouraged, in favor of using [Clio](https://github.com/XRPLF/clio) instead. The `network_id` field was added in the `server_info` response in version 1.5.0 (2019), but it is not returned in [reporting mode](https://xrpl.org/rippled-server-modes.html#reporting-mode). However, use of reporting mode is now discouraged, in favor of using [Clio](https://github.com/XRPLF/clio) instead.
## XRP Ledger server version 2.5.0
As of 2025-04-04, version 2.5.0 is in development. You can use a pre-release version by building from source or [using the `nightly` package](https://xrpl.org/docs/infrastructure/installation/install-rippled-on-ubuntu).
### Additions and bugfixes in 2.5.0
- `channel_authorize`: If `signing_support` is not enabled in the config, the RPC is disabled.
## XRP Ledger server version 2.4.0 ## XRP Ledger server version 2.4.0
[Version 2.4.0](https://github.com/XRPLF/rippled/releases/tag/2.4.0) was released on March 4, 2025. As of 2025-01-28, version 2.4.0 is in development. You can use a pre-release version by building from source or [using the `nightly` package](https://xrpl.org/docs/infrastructure/installation/install-rippled-on-ubuntu).
### Additions and bugfixes in 2.4.0 ### Additions and bugfixes in 2.4.0

View File

@@ -167,18 +167,43 @@ It does not explicitly link the C++ standard library,
which allows you to statically link it with GCC, if you want. which allows you to statically link it with GCC, if you want.
``` ```
# Conan 1.x
conan export external/snappy snappy/1.1.10@
# Conan 2.x # Conan 2.x
conan export --version 1.1.10 external/snappy conan export --version 1.1.10 external/snappy
``` ```
Export our [Conan recipe for RocksDB](./external/rocksdb).
It does not override paths to dependencies when building with Visual Studio.
```
# Conan 1.x
conan export external/rocksdb rocksdb/9.7.3@
# Conan 2.x
conan export --version 9.7.3 external/rocksdb
```
Export our [Conan recipe for SOCI](./external/soci). Export our [Conan recipe for SOCI](./external/soci).
It patches their CMake to correctly import its dependencies. It patches their CMake to correctly import its dependencies.
``` ```
# Conan 1.x
conan export external/soci soci/4.0.3@
# Conan 2.x # Conan 2.x
conan export --version 4.0.3 external/soci conan export --version 4.0.3 external/soci
``` ```
Export our [Conan recipe for NuDB](./external/nudb).
It fixes some source files to add missing `#include`s.
```
# Conan 1.x
conan export external/nudb nudb/2.0.8@
# Conan 2.x
conan export --version 2.0.8 external/nudb
```
### Build and Test ### Build and Test
1. Create a build directory and move into it. 1. Create a build directory and move into it.
@@ -263,7 +288,7 @@ It patches their CMake to correctly import its dependencies.
Single-config generators: Single-config generators:
``` ```
cmake --build . -j $(nproc) cmake --build .
``` ```
Multi-config generators: Multi-config generators:

View File

@@ -132,7 +132,6 @@ test.shamap > xrpl.protocol
test.toplevel > test.csf test.toplevel > test.csf
test.toplevel > xrpl.json test.toplevel > xrpl.json
test.unit_test > xrpl.basics test.unit_test > xrpl.basics
tests.libxrpl > xrpl.basics
xrpl.json > xrpl.basics xrpl.json > xrpl.basics
xrpl.protocol > xrpl.basics xrpl.protocol > xrpl.basics
xrpl.protocol > xrpl.json xrpl.protocol > xrpl.json

View File

@@ -90,11 +90,6 @@ set_target_properties(OpenSSL::SSL PROPERTIES
INTERFACE_COMPILE_DEFINITIONS OPENSSL_NO_SSL2 INTERFACE_COMPILE_DEFINITIONS OPENSSL_NO_SSL2
) )
set(SECP256K1_INSTALL TRUE) set(SECP256K1_INSTALL TRUE)
set(SECP256K1_BUILD_BENCHMARK FALSE)
set(SECP256K1_BUILD_TESTS FALSE)
set(SECP256K1_BUILD_EXHAUSTIVE_TESTS FALSE)
set(SECP256K1_BUILD_CTIME_TESTS FALSE)
set(SECP256K1_BUILD_EXAMPLES FALSE)
add_subdirectory(external/secp256k1) add_subdirectory(external/secp256k1)
add_library(secp256k1::secp256k1 ALIAS secp256k1) add_library(secp256k1::secp256k1 ALIAS secp256k1)
add_subdirectory(external/ed25519-donna) add_subdirectory(external/ed25519-donna)
@@ -149,8 +144,3 @@ set(PROJECT_EXPORT_SET RippleExports)
include(RippledCore) include(RippledCore)
include(RippledInstall) include(RippledInstall)
include(RippledValidatorKeys) include(RippledValidatorKeys)
if(tests)
include(CTest)
add_subdirectory(src/tests/libxrpl)
endif()

View File

@@ -1,5 +1,3 @@
[![codecov](https://codecov.io/gh/XRPLF/rippled/graph/badge.svg?token=WyFr5ajq3O)](https://codecov.io/gh/XRPLF/rippled)
# The XRP Ledger # The XRP Ledger
The [XRP Ledger](https://xrpl.org/) is a decentralized cryptographic ledger powered by a network of peer-to-peer nodes. The XRP Ledger uses a novel Byzantine Fault Tolerant consensus algorithm to settle and record transactions in a secure distributed database without a central operator. The [XRP Ledger](https://xrpl.org/) is a decentralized cryptographic ledger powered by a network of peer-to-peer nodes. The XRP Ledger uses a novel Byzantine Fault Tolerant consensus algorithm to settle and record transactions in a secure distributed database without a central operator.

4817
RELEASENOTES.md Normal file

File diff suppressed because it is too large Load Diff

View File

@@ -83,7 +83,7 @@ To report a qualifying bug, please send a detailed report to:
|Long Key ID | `0xCD49A0AFC57929BE` | |Long Key ID | `0xCD49A0AFC57929BE` |
|Fingerprint | `24E6 3B02 37E0 FA9C 5E96 8974 CD49 A0AF C579 29BE` | |Fingerprint | `24E6 3B02 37E0 FA9C 5E96 8974 CD49 A0AF C579 29BE` |
The full PGP key for this address, which is also available on several key servers (e.g. on [keyserver.ubuntu.com](https://keyserver.ubuntu.com)), is: The full PGP key for this address, which is also available on several key servers (e.g. on [keys.gnupg.net](https://keys.gnupg.net)), is:
``` ```
-----BEGIN PGP PUBLIC KEY BLOCK----- -----BEGIN PGP PUBLIC KEY BLOCK-----
mQINBFUwGHYBEAC0wpGpBPkd8W1UdQjg9+cEFzeIEJRaoZoeuJD8mofwI5Ejnjdt mQINBFUwGHYBEAC0wpGpBPkd8W1UdQjg9+cEFzeIEJRaoZoeuJD8mofwI5Ejnjdt

View File

@@ -26,7 +26,7 @@
# #
# Examples: # Examples:
# https://vl.ripple.com # https://vl.ripple.com
# https://unl.xrplf.org # https://vl.xrplf.org
# http://127.0.0.1:8000 # http://127.0.0.1:8000
# file:///etc/opt/ripple/vl.txt # file:///etc/opt/ripple/vl.txt
# #

View File

@@ -98,9 +98,6 @@
# 2024-04-03, Bronek Kozicki # 2024-04-03, Bronek Kozicki
# - add support for output formats: jacoco, clover, lcov # - add support for output formats: jacoco, clover, lcov
# #
# 2025-05-12, Jingchen Wu
# - add -fprofile-update=atomic to ensure atomic profile generation
#
# USAGE: # USAGE:
# #
# 1. Copy this file into your cmake modules path. # 1. Copy this file into your cmake modules path.
@@ -203,27 +200,15 @@ set(COVERAGE_COMPILER_FLAGS "-g --coverage"
CACHE INTERNAL "") CACHE INTERNAL "")
if(CMAKE_CXX_COMPILER_ID MATCHES "(GNU|Clang)") if(CMAKE_CXX_COMPILER_ID MATCHES "(GNU|Clang)")
include(CheckCXXCompilerFlag) include(CheckCXXCompilerFlag)
include(CheckCCompilerFlag)
check_cxx_compiler_flag(-fprofile-abs-path HAVE_cxx_fprofile_abs_path) check_cxx_compiler_flag(-fprofile-abs-path HAVE_cxx_fprofile_abs_path)
if(HAVE_cxx_fprofile_abs_path) if(HAVE_cxx_fprofile_abs_path)
set(COVERAGE_CXX_COMPILER_FLAGS "${COVERAGE_COMPILER_FLAGS} -fprofile-abs-path") set(COVERAGE_CXX_COMPILER_FLAGS "${COVERAGE_COMPILER_FLAGS} -fprofile-abs-path")
endif() endif()
include(CheckCCompilerFlag)
check_c_compiler_flag(-fprofile-abs-path HAVE_c_fprofile_abs_path) check_c_compiler_flag(-fprofile-abs-path HAVE_c_fprofile_abs_path)
if(HAVE_c_fprofile_abs_path) if(HAVE_c_fprofile_abs_path)
set(COVERAGE_C_COMPILER_FLAGS "${COVERAGE_COMPILER_FLAGS} -fprofile-abs-path") set(COVERAGE_C_COMPILER_FLAGS "${COVERAGE_COMPILER_FLAGS} -fprofile-abs-path")
endif() endif()
check_cxx_compiler_flag(-fprofile-update HAVE_cxx_fprofile_update)
if(HAVE_cxx_fprofile_update)
set(COVERAGE_CXX_COMPILER_FLAGS "${COVERAGE_COMPILER_FLAGS} -fprofile-update=atomic")
endif()
check_c_compiler_flag(-fprofile-update HAVE_c_fprofile_update)
if(HAVE_c_fprofile_update)
set(COVERAGE_C_COMPILER_FLAGS "${COVERAGE_COMPILER_FLAGS} -fprofile-update=atomic")
endif()
endif() endif()
set(CMAKE_Fortran_FLAGS_COVERAGE set(CMAKE_Fortran_FLAGS_COVERAGE

View File

@@ -136,9 +136,6 @@ if(xrpld)
add_executable(rippled) add_executable(rippled)
if(tests) if(tests)
target_compile_definitions(rippled PUBLIC ENABLE_TESTS) target_compile_definitions(rippled PUBLIC ENABLE_TESTS)
target_compile_definitions(rippled PRIVATE
UNIT_TEST_REFERENCE_FEE=${UNIT_TEST_REFERENCE_FEE}
)
endif() endif()
target_include_directories(rippled target_include_directories(rippled
PRIVATE PRIVATE

View File

@@ -53,9 +53,9 @@ set(download_script "${CMAKE_BINARY_DIR}/docs/download-cppreference.cmake")
file(WRITE file(WRITE
"${download_script}" "${download_script}"
"file(DOWNLOAD \ "file(DOWNLOAD \
https://github.com/PeterFeicht/cppreference-doc/releases/download/v20250209/html-book-20250209.zip \ http://upload.cppreference.com/mwiki/images/b/b2/html_book_20190607.zip \
${CMAKE_BINARY_DIR}/docs/cppreference.zip \ ${CMAKE_BINARY_DIR}/docs/cppreference.zip \
EXPECTED_HASH MD5=bda585f72fbca4b817b29a3d5746567b \ EXPECTED_HASH MD5=82b3a612d7d35a83e3cb1195a63689ab \
)\n \ )\n \
execute_process( \ execute_process( \
COMMAND \"${CMAKE_COMMAND}\" -E tar -xf cppreference.zip \ COMMAND \"${CMAKE_COMMAND}\" -E tar -xf cppreference.zip \

View File

@@ -2,6 +2,16 @@
convenience variables and sanity checks convenience variables and sanity checks
#]===================================================================] #]===================================================================]
include(ProcessorCount)
if (NOT ep_procs)
ProcessorCount(ep_procs)
if (ep_procs GREATER 1)
# never use more than half of cores for EP builds
math (EXPR ep_procs "${ep_procs} / 2")
message (STATUS "Using ${ep_procs} cores for ExternalProject builds.")
endif ()
endif ()
get_property(is_multiconfig GLOBAL PROPERTY GENERATOR_IS_MULTI_CONFIG) get_property(is_multiconfig GLOBAL PROPERTY GENERATOR_IS_MULTI_CONFIG)
set (CMAKE_CONFIGURATION_TYPES "Debug;Release" CACHE STRING "" FORCE) set (CMAKE_CONFIGURATION_TYPES "Debug;Release" CACHE STRING "" FORCE)

View File

@@ -11,14 +11,8 @@ option(assert "Enables asserts, even in release builds" OFF)
option(xrpld "Build xrpld" ON) option(xrpld "Build xrpld" ON)
option(tests "Build tests" ON) option(tests "Build tests" ON)
if(tests)
# This setting allows making a separate workflow to test fees other than default 10
if(NOT UNIT_TEST_REFERENCE_FEE)
set(UNIT_TEST_REFERENCE_FEE "10" CACHE STRING "")
endif()
endif()
option(unity "Creates a build using UNITY support in cmake." OFF) option(unity "Creates a build using UNITY support in cmake. This is the default" ON)
if(unity) if(unity)
if(NOT is_ci) if(NOT is_ci)
set(CMAKE_UNITY_BUILD_BATCH_SIZE 15 CACHE STRING "") set(CMAKE_UNITY_BUILD_BATCH_SIZE 15 CACHE STRING "")

View File

@@ -2,6 +2,7 @@ find_package(Boost 1.82 REQUIRED
COMPONENTS COMPONENTS
chrono chrono
container container
context
coroutine coroutine
date_time date_time
filesystem filesystem
@@ -23,7 +24,7 @@ endif()
target_link_libraries(ripple_boost target_link_libraries(ripple_boost
INTERFACE INTERFACE
Boost::headers Boost::boost
Boost::chrono Boost::chrono
Boost::container Boost::container
Boost::coroutine Boost::coroutine

View File

@@ -1,41 +0,0 @@
include(isolate_headers)
function(xrpl_add_test name)
set(target ${PROJECT_NAME}.test.${name})
file(GLOB_RECURSE sources CONFIGURE_DEPENDS
"${CMAKE_CURRENT_SOURCE_DIR}/${name}/*.cpp"
"${CMAKE_CURRENT_SOURCE_DIR}/${name}.cpp"
)
add_executable(${target} EXCLUDE_FROM_ALL ${ARGN} ${sources})
isolate_headers(
${target}
"${CMAKE_SOURCE_DIR}"
"${CMAKE_SOURCE_DIR}/tests/${name}"
PRIVATE
)
# Make sure the test isn't optimized away in unity builds
set_target_properties(${target} PROPERTIES
UNITY_BUILD_MODE GROUP
UNITY_BUILD_BATCH_SIZE 0) # Adjust as needed
add_test(NAME ${target} COMMAND ${target})
set_tests_properties(
${target} PROPERTIES
FIXTURES_REQUIRED ${target}_fixture
)
add_test(
NAME ${target}.build
COMMAND
${CMAKE_COMMAND}
--build ${CMAKE_BINARY_DIR}
--config $<CONFIG>
--target ${target}
)
set_tests_properties(${target}.build PROPERTIES
FIXTURES_SETUP ${target}_fixture
)
endfunction()

View File

@@ -1,37 +0,0 @@
{% set os = detect_api.detect_os() %}
{% set arch = detect_api.detect_arch() %}
{% set compiler, version, compiler_exe = detect_api.detect_default_compiler() %}
{% set compiler_version = version %}
{% if os == "Linux" %}
{% set compiler_version = detect_api.default_compiler_version(compiler, version) %}
{% endif %}
[settings]
os={{ os }}
arch={{ arch }}
build_type=Debug
compiler={{compiler}}
compiler.version={{ compiler_version }}
compiler.cppstd=20
{% if os == "Windows" %}
compiler.runtime=static
{% else %}
compiler.libcxx={{detect_api.detect_libcxx(compiler, version, compiler_exe)}}
{% endif %}
[conf]
{% if compiler == "clang" and compiler_version >= 19 %}
tools.build:cxxflags=['-Wno-missing-template-arg-list-after-template-kw']
{% endif %}
{% if compiler == "apple-clang" and compiler_version >= 17 %}
tools.build:cxxflags=['-Wno-missing-template-arg-list-after-template-kw']
{% endif %}
{% if compiler == "clang" and compiler_version == 16 %}
tools.build:cxxflags=['-DBOOST_ASIO_DISABLE_CONCEPTS']
{% endif %}
{% if compiler == "gcc" and compiler_version < 13 %}
tools.build:cxxflags=['-Wno-restrict']
{% endif %}
[tool_requires]
!cmake/*: cmake/[>=3 <4]

View File

@@ -1,4 +1,4 @@
from conan import ConanFile, __version__ as conan_version from conan import ConanFile
from conan.tools.cmake import CMake, CMakeToolchain, cmake_layout from conan.tools.cmake import CMake, CMakeToolchain, cmake_layout
import re import re
@@ -24,20 +24,18 @@ class Xrpl(ConanFile):
} }
requires = [ requires = [
'date/3.0.3',
'grpc/1.50.1', 'grpc/1.50.1',
'libarchive/3.8.1', 'libarchive/3.7.6',
'nudb/2.0.9', 'nudb/2.0.8',
'openssl/1.1.1w', 'openssl/1.1.1v',
'soci/4.0.3', 'soci/4.0.3',
'xxhash/0.8.2',
'zlib/1.3.1', 'zlib/1.3.1',
] ]
test_requires = [
'doctest/2.4.11',
]
tool_requires = [ tool_requires = [
'protobuf/3.21.12', 'protobuf/3.21.9',
] ]
default_options = { default_options = {
@@ -89,31 +87,26 @@ class Xrpl(ConanFile):
} }
def set_version(self): def set_version(self):
if self.version is None: path = f'{self.recipe_folder}/src/libxrpl/protocol/BuildInfo.cpp'
path = f'{self.recipe_folder}/src/libxrpl/protocol/BuildInfo.cpp' regex = r'versionString\s?=\s?\"(.*)\"'
regex = r'versionString\s?=\s?\"(.*)\"' with open(path, 'r') as file:
with open(path, encoding='utf-8') as file: matches = (re.search(regex, line) for line in file)
matches = (re.search(regex, line) for line in file) match = next(m for m in matches if m)
match = next(m for m in matches if m) self.version = match.group(1)
self.version = match.group(1)
def configure(self): def configure(self):
if self.settings.compiler == 'apple-clang': if self.settings.compiler == 'apple-clang':
self.options['boost'].visibility = 'global' self.options['boost'].visibility = 'global'
def requirements(self): def requirements(self):
# Conan 2 requires transitive headers to be specified self.requires('boost/1.83.0', force=True)
transitive_headers_opt = {'transitive_headers': True} if conan_version.split('.')[0] == '2' else {}
self.requires('boost/1.83.0', force=True, **transitive_headers_opt)
self.requires('date/3.0.4', **transitive_headers_opt)
self.requires('lz4/1.10.0', force=True) self.requires('lz4/1.10.0', force=True)
self.requires('protobuf/3.21.12', force=True) self.requires('protobuf/3.21.9', force=True)
self.requires('sqlite3/3.49.1', force=True) self.requires('sqlite3/3.47.0', force=True)
if self.options.jemalloc: if self.options.jemalloc:
self.requires('jemalloc/5.3.0') self.requires('jemalloc/5.3.0')
if self.options.rocksdb: if self.options.rocksdb:
self.requires('rocksdb/10.0.1') self.requires('rocksdb/9.7.3')
self.requires('xxhash/0.8.3', **transitive_headers_opt)
exports_sources = ( exports_sources = (
'CMakeLists.txt', 'CMakeLists.txt',
@@ -168,17 +161,7 @@ class Xrpl(ConanFile):
# `include/`, not `include/ripple/proto/`. # `include/`, not `include/ripple/proto/`.
libxrpl.includedirs = ['include', 'include/ripple/proto'] libxrpl.includedirs = ['include', 'include/ripple/proto']
libxrpl.requires = [ libxrpl.requires = [
'boost::headers', 'boost::boost',
'boost::chrono',
'boost::container',
'boost::coroutine',
'boost::date_time',
'boost::filesystem',
'boost::json',
'boost::program_options',
'boost::regex',
'boost::system',
'boost::thread',
'date::date', 'date::date',
'grpc::grpc++', 'grpc::grpc++',
'libarchive::libarchive', 'libarchive::libarchive',

View File

@@ -23,7 +23,7 @@ direction.
``` ```
apt update apt update
apt install --yes curl git libssl-dev pipx python3.10-dev python3-pip make g++-11 libprotobuf-dev protobuf-compiler apt install --yes curl git libssl-dev python3.10-dev python3-pip make g++-11 libprotobuf-dev protobuf-compiler
curl --location --remote-name \ curl --location --remote-name \
"https://github.com/Kitware/CMake/releases/download/v3.25.1/cmake-3.25.1.tar.gz" "https://github.com/Kitware/CMake/releases/download/v3.25.1/cmake-3.25.1.tar.gz"
@@ -35,8 +35,7 @@ make --jobs $(nproc)
make install make install
cd .. cd ..
pipx install 'conan<2' pip3 install 'conan<2'
pipx ensurepath
``` ```
[1]: https://github.com/thejohnfreeman/rippled-docker/blob/master/ubuntu-22.04/install.sh [1]: https://github.com/thejohnfreeman/rippled-docker/blob/master/ubuntu-22.04/install.sh

View File

@@ -1,4 +1,4 @@
cmake_minimum_required(VERSION 3.18) cmake_minimum_required(VERSION 3.25)
# Note, version set explicitly by rippled project # Note, version set explicitly by rippled project
project(antithesis-sdk-cpp VERSION 0.4.4 LANGUAGES CXX) project(antithesis-sdk-cpp VERSION 0.4.4 LANGUAGES CXX)

10
external/nudb/conandata.yml vendored Normal file
View File

@@ -0,0 +1,10 @@
sources:
"2.0.8":
url: "https://github.com/CPPAlliance/NuDB/archive/2.0.8.tar.gz"
sha256: "9b71903d8ba111cd893ab064b9a8b6ac4124ed8bd6b4f67250205bc43c7f13a8"
patches:
"2.0.8":
- patch_file: "patches/2.0.8-0001-add-include-stdexcept-for-msvc.patch"
patch_description: "Fix build for MSVC by including stdexcept"
patch_type: "portability"
patch_source: "https://github.com/cppalliance/NuDB/pull/100/files"

72
external/nudb/conanfile.py vendored Normal file
View File

@@ -0,0 +1,72 @@
import os
from conan import ConanFile
from conan.tools.build import check_min_cppstd
from conan.tools.files import apply_conandata_patches, copy, export_conandata_patches, get
from conan.tools.layout import basic_layout
required_conan_version = ">=1.52.0"
class NudbConan(ConanFile):
name = "nudb"
description = "A fast key/value insert-only database for SSD drives in C++11"
license = "BSL-1.0"
url = "https://github.com/conan-io/conan-center-index"
homepage = "https://github.com/CPPAlliance/NuDB"
topics = ("header-only", "KVS", "insert-only")
package_type = "header-library"
settings = "os", "arch", "compiler", "build_type"
no_copy_source = True
@property
def _min_cppstd(self):
return 11
def export_sources(self):
export_conandata_patches(self)
def layout(self):
basic_layout(self, src_folder="src")
def requirements(self):
self.requires("boost/1.83.0")
def package_id(self):
self.info.clear()
def validate(self):
if self.settings.compiler.cppstd:
check_min_cppstd(self, self._min_cppstd)
def source(self):
get(self, **self.conan_data["sources"][self.version], strip_root=True)
def build(self):
apply_conandata_patches(self)
def package(self):
copy(self, "LICENSE*",
dst=os.path.join(self.package_folder, "licenses"),
src=self.source_folder)
copy(self, "*",
dst=os.path.join(self.package_folder, "include"),
src=os.path.join(self.source_folder, "include"))
def package_info(self):
self.cpp_info.bindirs = []
self.cpp_info.libdirs = []
self.cpp_info.set_property("cmake_target_name", "NuDB")
self.cpp_info.set_property("cmake_target_aliases", ["NuDB::nudb"])
self.cpp_info.set_property("cmake_find_mode", "both")
self.cpp_info.components["core"].set_property("cmake_target_name", "nudb")
self.cpp_info.components["core"].names["cmake_find_package"] = "nudb"
self.cpp_info.components["core"].names["cmake_find_package_multi"] = "nudb"
self.cpp_info.components["core"].requires = ["boost::thread", "boost::system"]
# TODO: to remove in conan v2 once cmake_find_package_* generators removed
self.cpp_info.names["cmake_find_package"] = "NuDB"
self.cpp_info.names["cmake_find_package_multi"] = "NuDB"

View File

@@ -0,0 +1,24 @@
diff --git a/include/nudb/detail/stream.hpp b/include/nudb/detail/stream.hpp
index 6c07bf1..e0ce8ed 100644
--- a/include/nudb/detail/stream.hpp
+++ b/include/nudb/detail/stream.hpp
@@ -14,6 +14,7 @@
#include <cstdint>
#include <cstring>
#include <memory>
+#include <stdexcept>
namespace nudb {
namespace detail {
diff --git a/include/nudb/impl/context.ipp b/include/nudb/impl/context.ipp
index beb7058..ffde0b3 100644
--- a/include/nudb/impl/context.ipp
+++ b/include/nudb/impl/context.ipp
@@ -9,6 +9,7 @@
#define NUDB_IMPL_CONTEXT_IPP
#include <nudb/detail/store_base.hpp>
+#include <stdexcept>
namespace nudb {

12
external/rocksdb/conandata.yml vendored Normal file
View File

@@ -0,0 +1,12 @@
sources:
"9.7.3":
url: "https://github.com/facebook/rocksdb/archive/refs/tags/v9.7.3.tar.gz"
sha256: "acfabb989cbfb5b5c4d23214819b059638193ec33dad2d88373c46448d16d38b"
patches:
"9.7.3":
- patch_file: "patches/9.x.x-0001-exclude-thirdparty.patch"
patch_description: "Do not include thirdparty.inc"
patch_type: "portability"
- patch_file: "patches/9.7.3-0001-memory-leak.patch"
patch_description: "Fix a leak of obsolete blob files left open until DB::Close()"
patch_type: "portability"

235
external/rocksdb/conanfile.py vendored Normal file
View File

@@ -0,0 +1,235 @@
import os
import glob
import shutil
from conan import ConanFile
from conan.errors import ConanInvalidConfiguration
from conan.tools.build import check_min_cppstd
from conan.tools.cmake import CMake, CMakeDeps, CMakeToolchain, cmake_layout
from conan.tools.files import apply_conandata_patches, collect_libs, copy, export_conandata_patches, get, rm, rmdir
from conan.tools.microsoft import check_min_vs, is_msvc, is_msvc_static_runtime
from conan.tools.scm import Version
required_conan_version = ">=1.53.0"
class RocksDBConan(ConanFile):
name = "rocksdb"
description = "A library that provides an embeddable, persistent key-value store for fast storage"
license = ("GPL-2.0-only", "Apache-2.0")
url = "https://github.com/conan-io/conan-center-index"
homepage = "https://github.com/facebook/rocksdb"
topics = ("database", "leveldb", "facebook", "key-value")
package_type = "library"
settings = "os", "arch", "compiler", "build_type"
options = {
"shared": [True, False],
"fPIC": [True, False],
"lite": [True, False],
"with_gflags": [True, False],
"with_snappy": [True, False],
"with_lz4": [True, False],
"with_zlib": [True, False],
"with_zstd": [True, False],
"with_tbb": [True, False],
"with_jemalloc": [True, False],
"enable_sse": [False, "sse42", "avx2"],
"use_rtti": [True, False],
}
default_options = {
"shared": False,
"fPIC": True,
"lite": False,
"with_snappy": False,
"with_lz4": False,
"with_zlib": False,
"with_zstd": False,
"with_gflags": False,
"with_tbb": False,
"with_jemalloc": False,
"enable_sse": False,
"use_rtti": False,
}
@property
def _min_cppstd(self):
return "11" if Version(self.version) < "8.8.1" else "17"
@property
def _compilers_minimum_version(self):
return {} if self._min_cppstd == "11" else {
"apple-clang": "10",
"clang": "7",
"gcc": "7",
"msvc": "191",
"Visual Studio": "15",
}
def export_sources(self):
export_conandata_patches(self)
def config_options(self):
if self.settings.os == "Windows":
del self.options.fPIC
if self.settings.arch != "x86_64":
del self.options.with_tbb
if self.settings.build_type == "Debug":
self.options.use_rtti = True # Rtti are used in asserts for debug mode...
def configure(self):
if self.options.shared:
self.options.rm_safe("fPIC")
def layout(self):
cmake_layout(self, src_folder="src")
def requirements(self):
if self.options.with_gflags:
self.requires("gflags/2.2.2")
if self.options.with_snappy:
self.requires("snappy/1.1.10")
if self.options.with_lz4:
self.requires("lz4/1.10.0")
if self.options.with_zlib:
self.requires("zlib/[>=1.2.11 <2]")
if self.options.with_zstd:
self.requires("zstd/1.5.6")
if self.options.get_safe("with_tbb"):
self.requires("onetbb/2021.12.0")
if self.options.with_jemalloc:
self.requires("jemalloc/5.3.0")
def validate(self):
if self.settings.compiler.get_safe("cppstd"):
check_min_cppstd(self, self._min_cppstd)
minimum_version = self._compilers_minimum_version.get(str(self.settings.compiler), False)
if minimum_version and Version(self.settings.compiler.version) < minimum_version:
raise ConanInvalidConfiguration(
f"{self.ref} requires C++{self._min_cppstd}, which your compiler does not support."
)
if self.settings.arch not in ["x86_64", "ppc64le", "ppc64", "mips64", "armv8"]:
raise ConanInvalidConfiguration("Rocksdb requires 64 bits")
check_min_vs(self, "191")
if self.version == "6.20.3" and \
self.settings.os == "Linux" and \
self.settings.compiler == "gcc" and \
Version(self.settings.compiler.version) < "5":
raise ConanInvalidConfiguration("Rocksdb 6.20.3 is not compilable with gcc <5.") # See https://github.com/facebook/rocksdb/issues/3522
def source(self):
get(self, **self.conan_data["sources"][self.version], strip_root=True)
def generate(self):
tc = CMakeToolchain(self)
tc.variables["FAIL_ON_WARNINGS"] = False
tc.variables["WITH_TESTS"] = False
tc.variables["WITH_TOOLS"] = False
tc.variables["WITH_CORE_TOOLS"] = False
tc.variables["WITH_BENCHMARK_TOOLS"] = False
tc.variables["WITH_FOLLY_DISTRIBUTED_MUTEX"] = False
if is_msvc(self):
tc.variables["WITH_MD_LIBRARY"] = not is_msvc_static_runtime(self)
tc.variables["ROCKSDB_INSTALL_ON_WINDOWS"] = self.settings.os == "Windows"
tc.variables["ROCKSDB_LITE"] = self.options.lite
tc.variables["WITH_GFLAGS"] = self.options.with_gflags
tc.variables["WITH_SNAPPY"] = self.options.with_snappy
tc.variables["WITH_LZ4"] = self.options.with_lz4
tc.variables["WITH_ZLIB"] = self.options.with_zlib
tc.variables["WITH_ZSTD"] = self.options.with_zstd
tc.variables["WITH_TBB"] = self.options.get_safe("with_tbb", False)
tc.variables["WITH_JEMALLOC"] = self.options.with_jemalloc
tc.variables["ROCKSDB_BUILD_SHARED"] = self.options.shared
tc.variables["ROCKSDB_LIBRARY_EXPORTS"] = self.settings.os == "Windows" and self.options.shared
tc.variables["ROCKSDB_DLL" ] = self.settings.os == "Windows" and self.options.shared
tc.variables["USE_RTTI"] = self.options.use_rtti
if not bool(self.options.enable_sse):
tc.variables["PORTABLE"] = True
tc.variables["FORCE_SSE42"] = False
elif self.options.enable_sse == "sse42":
tc.variables["PORTABLE"] = True
tc.variables["FORCE_SSE42"] = True
elif self.options.enable_sse == "avx2":
tc.variables["PORTABLE"] = False
tc.variables["FORCE_SSE42"] = False
# not available yet in CCI
tc.variables["WITH_NUMA"] = False
tc.generate()
deps = CMakeDeps(self)
if self.options.with_jemalloc:
deps.set_property("jemalloc", "cmake_file_name", "JeMalloc")
deps.set_property("jemalloc", "cmake_target_name", "JeMalloc::JeMalloc")
if self.options.with_zstd:
deps.set_property("zstd", "cmake_target_name", "zstd::zstd")
deps.generate()
def build(self):
apply_conandata_patches(self)
cmake = CMake(self)
cmake.configure()
cmake.build()
def _remove_static_libraries(self):
rm(self, "rocksdb.lib", os.path.join(self.package_folder, "lib"))
for lib in glob.glob(os.path.join(self.package_folder, "lib", "*.a")):
if not lib.endswith(".dll.a"):
os.remove(lib)
def _remove_cpp_headers(self):
for path in glob.glob(os.path.join(self.package_folder, "include", "rocksdb", "*")):
if path != os.path.join(self.package_folder, "include", "rocksdb", "c.h"):
if os.path.isfile(path):
os.remove(path)
else:
shutil.rmtree(path)
def package(self):
copy(self, "COPYING", src=self.source_folder, dst=os.path.join(self.package_folder, "licenses"))
copy(self, "LICENSE*", src=self.source_folder, dst=os.path.join(self.package_folder, "licenses"))
cmake = CMake(self)
cmake.install()
if self.options.shared:
self._remove_static_libraries()
self._remove_cpp_headers() # Force stable ABI for shared libraries
rmdir(self, os.path.join(self.package_folder, "lib", "cmake"))
rmdir(self, os.path.join(self.package_folder, "lib", "pkgconfig"))
def package_info(self):
cmake_target = "rocksdb-shared" if self.options.shared else "rocksdb"
self.cpp_info.set_property("cmake_file_name", "RocksDB")
self.cpp_info.set_property("cmake_target_name", f"RocksDB::{cmake_target}")
# TODO: back to global scope in conan v2 once cmake_find_package* generators removed
self.cpp_info.components["librocksdb"].libs = collect_libs(self)
if self.settings.os == "Windows":
self.cpp_info.components["librocksdb"].system_libs = ["shlwapi", "rpcrt4"]
if self.options.shared:
self.cpp_info.components["librocksdb"].defines = ["ROCKSDB_DLL"]
elif self.settings.os in ["Linux", "FreeBSD"]:
self.cpp_info.components["librocksdb"].system_libs = ["pthread", "m"]
if self.options.lite:
self.cpp_info.components["librocksdb"].defines.append("ROCKSDB_LITE")
# TODO: to remove in conan v2 once cmake_find_package* generators removed
self.cpp_info.names["cmake_find_package"] = "RocksDB"
self.cpp_info.names["cmake_find_package_multi"] = "RocksDB"
self.cpp_info.components["librocksdb"].names["cmake_find_package"] = cmake_target
self.cpp_info.components["librocksdb"].names["cmake_find_package_multi"] = cmake_target
self.cpp_info.components["librocksdb"].set_property("cmake_target_name", f"RocksDB::{cmake_target}")
if self.options.with_gflags:
self.cpp_info.components["librocksdb"].requires.append("gflags::gflags")
if self.options.with_snappy:
self.cpp_info.components["librocksdb"].requires.append("snappy::snappy")
if self.options.with_lz4:
self.cpp_info.components["librocksdb"].requires.append("lz4::lz4")
if self.options.with_zlib:
self.cpp_info.components["librocksdb"].requires.append("zlib::zlib")
if self.options.with_zstd:
self.cpp_info.components["librocksdb"].requires.append("zstd::zstd")
if self.options.get_safe("with_tbb"):
self.cpp_info.components["librocksdb"].requires.append("onetbb::onetbb")
if self.options.with_jemalloc:
self.cpp_info.components["librocksdb"].requires.append("jemalloc::jemalloc")

View File

@@ -0,0 +1,319 @@
diff --git a/HISTORY.md b/HISTORY.md
index 36d472229..05ad1a202 100644
--- a/HISTORY.md
+++ b/HISTORY.md
@@ -1,6 +1,10 @@
# Rocksdb Change Log
> NOTE: Entries for next release do not go here. Follow instructions in `unreleased_history/README.txt`
+## 9.7.4 (10/31/2024)
+### Bug Fixes
+* Fix a leak of obsolete blob files left open until DB::Close(). This bug was introduced in version 9.4.0.
+
## 9.7.3 (10/16/2024)
### Behavior Changes
* OPTIONS file to be loaded by remote worker is now preserved so that it does not get purged by the primary host. A similar technique as how we are preserving new SST files from getting purged is used for this. min_options_file_numbers_ is tracked like pending_outputs_ is tracked.
diff --git a/db/blob/blob_file_cache.cc b/db/blob/blob_file_cache.cc
index 5f340aadf..1b9faa238 100644
--- a/db/blob/blob_file_cache.cc
+++ b/db/blob/blob_file_cache.cc
@@ -42,6 +42,7 @@ Status BlobFileCache::GetBlobFileReader(
assert(blob_file_reader);
assert(blob_file_reader->IsEmpty());
+ // NOTE: sharing same Cache with table_cache
const Slice key = GetSliceForKey(&blob_file_number);
assert(cache_);
@@ -98,4 +99,13 @@ Status BlobFileCache::GetBlobFileReader(
return Status::OK();
}
+void BlobFileCache::Evict(uint64_t blob_file_number) {
+ // NOTE: sharing same Cache with table_cache
+ const Slice key = GetSliceForKey(&blob_file_number);
+
+ assert(cache_);
+
+ cache_.get()->Erase(key);
+}
+
} // namespace ROCKSDB_NAMESPACE
diff --git a/db/blob/blob_file_cache.h b/db/blob/blob_file_cache.h
index 740e67ada..6858d012b 100644
--- a/db/blob/blob_file_cache.h
+++ b/db/blob/blob_file_cache.h
@@ -36,6 +36,15 @@ class BlobFileCache {
uint64_t blob_file_number,
CacheHandleGuard<BlobFileReader>* blob_file_reader);
+ // Called when a blob file is obsolete to ensure it is removed from the cache
+ // to avoid effectively leaking the open file and assicated memory
+ void Evict(uint64_t blob_file_number);
+
+ // Used to identify cache entries for blob files (not normally useful)
+ static const Cache::CacheItemHelper* GetHelper() {
+ return CacheInterface::GetBasicHelper();
+ }
+
private:
using CacheInterface =
BasicTypedCacheInterface<BlobFileReader, CacheEntryRole::kMisc>;
diff --git a/db/column_family.h b/db/column_family.h
index e4b7adde8..86637736a 100644
--- a/db/column_family.h
+++ b/db/column_family.h
@@ -401,6 +401,7 @@ class ColumnFamilyData {
SequenceNumber earliest_seq);
TableCache* table_cache() const { return table_cache_.get(); }
+ BlobFileCache* blob_file_cache() const { return blob_file_cache_.get(); }
BlobSource* blob_source() const { return blob_source_.get(); }
// See documentation in compaction_picker.h
diff --git a/db/db_impl/db_impl.cc b/db/db_impl/db_impl.cc
index 261593423..06573ac2e 100644
--- a/db/db_impl/db_impl.cc
+++ b/db/db_impl/db_impl.cc
@@ -659,8 +659,9 @@ Status DBImpl::CloseHelper() {
// We need to release them before the block cache is destroyed. The block
// cache may be destroyed inside versions_.reset(), when column family data
// list is destroyed, so leaving handles in table cache after
- // versions_.reset() may cause issues.
- // Here we clean all unreferenced handles in table cache.
+ // versions_.reset() may cause issues. Here we clean all unreferenced handles
+ // in table cache, and (for certain builds/conditions) assert that no obsolete
+ // files are hanging around unreferenced (leak) in the table/blob file cache.
// Now we assume all user queries have finished, so only version set itself
// can possibly hold the blocks from block cache. After releasing unreferenced
// handles here, only handles held by version set left and inside
@@ -668,6 +669,9 @@ Status DBImpl::CloseHelper() {
// time a handle is released, we erase it from the cache too. By doing that,
// we can guarantee that after versions_.reset(), table cache is empty
// so the cache can be safely destroyed.
+#ifndef NDEBUG
+ TEST_VerifyNoObsoleteFilesCached(/*db_mutex_already_held=*/true);
+#endif // !NDEBUG
table_cache_->EraseUnRefEntries();
for (auto& txn_entry : recovered_transactions_) {
@@ -3227,6 +3231,8 @@ Status DBImpl::MultiGetImpl(
s = Status::Aborted();
break;
}
+ // This could be a long-running operation
+ ROCKSDB_THREAD_YIELD_HOOK();
}
// Post processing (decrement reference counts and record statistics)
diff --git a/db/db_impl/db_impl.h b/db/db_impl/db_impl.h
index 5e4fa310b..ccc0abfa7 100644
--- a/db/db_impl/db_impl.h
+++ b/db/db_impl/db_impl.h
@@ -1241,9 +1241,14 @@ class DBImpl : public DB {
static Status TEST_ValidateOptions(const DBOptions& db_options) {
return ValidateOptions(db_options);
}
-
#endif // NDEBUG
+ // In certain configurations, verify that the table/blob file cache only
+ // contains entries for live files, to check for effective leaks of open
+ // files. This can only be called when purging of obsolete files has
+ // "settled," such as during parts of DB Close().
+ void TEST_VerifyNoObsoleteFilesCached(bool db_mutex_already_held) const;
+
// persist stats to column family "_persistent_stats"
void PersistStats();
diff --git a/db/db_impl/db_impl_debug.cc b/db/db_impl/db_impl_debug.cc
index 790a50d7a..67f5b4aaf 100644
--- a/db/db_impl/db_impl_debug.cc
+++ b/db/db_impl/db_impl_debug.cc
@@ -9,6 +9,7 @@
#ifndef NDEBUG
+#include "db/blob/blob_file_cache.h"
#include "db/column_family.h"
#include "db/db_impl/db_impl.h"
#include "db/error_handler.h"
@@ -328,5 +329,49 @@ size_t DBImpl::TEST_EstimateInMemoryStatsHistorySize() const {
InstrumentedMutexLock l(&const_cast<DBImpl*>(this)->stats_history_mutex_);
return EstimateInMemoryStatsHistorySize();
}
+
+void DBImpl::TEST_VerifyNoObsoleteFilesCached(
+ bool db_mutex_already_held) const {
+ // This check is somewhat expensive and obscure to make a part of every
+ // unit test in every build variety. Thus, we only enable it for ASAN builds.
+ if (!kMustFreeHeapAllocations) {
+ return;
+ }
+
+ std::optional<InstrumentedMutexLock> l;
+ if (db_mutex_already_held) {
+ mutex_.AssertHeld();
+ } else {
+ l.emplace(&mutex_);
+ }
+
+ std::vector<uint64_t> live_files;
+ for (auto cfd : *versions_->GetColumnFamilySet()) {
+ if (cfd->IsDropped()) {
+ continue;
+ }
+ // Sneakily add both SST and blob files to the same list
+ cfd->current()->AddLiveFiles(&live_files, &live_files);
+ }
+ std::sort(live_files.begin(), live_files.end());
+
+ auto fn = [&live_files](const Slice& key, Cache::ObjectPtr, size_t,
+ const Cache::CacheItemHelper* helper) {
+ if (helper != BlobFileCache::GetHelper()) {
+ // Skip non-blob files for now
+ // FIXME: diagnose and fix the leaks of obsolete SST files revealed in
+ // unit tests.
+ return;
+ }
+ // See TableCache and BlobFileCache
+ assert(key.size() == sizeof(uint64_t));
+ uint64_t file_number;
+ GetUnaligned(reinterpret_cast<const uint64_t*>(key.data()), &file_number);
+ // Assert file is in sorted live_files
+ assert(
+ std::binary_search(live_files.begin(), live_files.end(), file_number));
+ };
+ table_cache_->ApplyToAllEntries(fn, {});
+}
} // namespace ROCKSDB_NAMESPACE
#endif // NDEBUG
diff --git a/db/db_iter.cc b/db/db_iter.cc
index e02586377..bf4749eb9 100644
--- a/db/db_iter.cc
+++ b/db/db_iter.cc
@@ -540,6 +540,8 @@ bool DBIter::FindNextUserEntryInternal(bool skipping_saved_key,
} else {
iter_.Next();
}
+ // This could be a long-running operation due to tombstones, etc.
+ ROCKSDB_THREAD_YIELD_HOOK();
} while (iter_.Valid());
valid_ = false;
diff --git a/db/table_cache.cc b/db/table_cache.cc
index 71fc29c32..8a5be75e8 100644
--- a/db/table_cache.cc
+++ b/db/table_cache.cc
@@ -164,6 +164,7 @@ Status TableCache::GetTableReader(
}
Cache::Handle* TableCache::Lookup(Cache* cache, uint64_t file_number) {
+ // NOTE: sharing same Cache with BlobFileCache
Slice key = GetSliceForFileNumber(&file_number);
return cache->Lookup(key);
}
@@ -179,6 +180,7 @@ Status TableCache::FindTable(
size_t max_file_size_for_l0_meta_pin, Temperature file_temperature) {
PERF_TIMER_GUARD_WITH_CLOCK(find_table_nanos, ioptions_.clock);
uint64_t number = file_meta.fd.GetNumber();
+ // NOTE: sharing same Cache with BlobFileCache
Slice key = GetSliceForFileNumber(&number);
*handle = cache_.Lookup(key);
TEST_SYNC_POINT_CALLBACK("TableCache::FindTable:0",
diff --git a/db/version_builder.cc b/db/version_builder.cc
index ed8ab8214..c98f53f42 100644
--- a/db/version_builder.cc
+++ b/db/version_builder.cc
@@ -24,6 +24,7 @@
#include <vector>
#include "cache/cache_reservation_manager.h"
+#include "db/blob/blob_file_cache.h"
#include "db/blob/blob_file_meta.h"
#include "db/dbformat.h"
#include "db/internal_stats.h"
@@ -744,12 +745,9 @@ class VersionBuilder::Rep {
return Status::Corruption("VersionBuilder", oss.str());
}
- // Note: we use C++11 for now but in C++14, this could be done in a more
- // elegant way using generalized lambda capture.
- VersionSet* const vs = version_set_;
- const ImmutableCFOptions* const ioptions = ioptions_;
-
- auto deleter = [vs, ioptions](SharedBlobFileMetaData* shared_meta) {
+ auto deleter = [vs = version_set_, ioptions = ioptions_,
+ bc = cfd_ ? cfd_->blob_file_cache()
+ : nullptr](SharedBlobFileMetaData* shared_meta) {
if (vs) {
assert(ioptions);
assert(!ioptions->cf_paths.empty());
@@ -758,6 +756,9 @@ class VersionBuilder::Rep {
vs->AddObsoleteBlobFile(shared_meta->GetBlobFileNumber(),
ioptions->cf_paths.front().path);
}
+ if (bc) {
+ bc->Evict(shared_meta->GetBlobFileNumber());
+ }
delete shared_meta;
};
@@ -766,7 +767,7 @@ class VersionBuilder::Rep {
blob_file_number, blob_file_addition.GetTotalBlobCount(),
blob_file_addition.GetTotalBlobBytes(),
blob_file_addition.GetChecksumMethod(),
- blob_file_addition.GetChecksumValue(), deleter);
+ blob_file_addition.GetChecksumValue(), std::move(deleter));
mutable_blob_file_metas_.emplace(
blob_file_number, MutableBlobFileMetaData(std::move(shared_meta)));
diff --git a/db/version_set.h b/db/version_set.h
index 9336782b1..024f869e7 100644
--- a/db/version_set.h
+++ b/db/version_set.h
@@ -1514,7 +1514,6 @@ class VersionSet {
void GetLiveFilesMetaData(std::vector<LiveFileMetaData>* metadata);
void AddObsoleteBlobFile(uint64_t blob_file_number, std::string path) {
- // TODO: Erase file from BlobFileCache?
obsolete_blob_files_.emplace_back(blob_file_number, std::move(path));
}
diff --git a/include/rocksdb/version.h b/include/rocksdb/version.h
index 2a19796b8..0afa2cab1 100644
--- a/include/rocksdb/version.h
+++ b/include/rocksdb/version.h
@@ -13,7 +13,7 @@
// minor or major version number planned for release.
#define ROCKSDB_MAJOR 9
#define ROCKSDB_MINOR 7
-#define ROCKSDB_PATCH 3
+#define ROCKSDB_PATCH 4
// Do not use these. We made the mistake of declaring macros starting with
// double underscore. Now we have to live with our choice. We'll deprecate these
diff --git a/port/port.h b/port/port.h
index 13aa56d47..141716e5b 100644
--- a/port/port.h
+++ b/port/port.h
@@ -19,3 +19,19 @@
#elif defined(OS_WIN)
#include "port/win/port_win.h"
#endif
+
+#ifdef OS_LINUX
+// A temporary hook into long-running RocksDB threads to support modifying their
+// priority etc. This should become a public API hook once the requirements
+// are better understood.
+extern "C" void RocksDbThreadYield() __attribute__((__weak__));
+#define ROCKSDB_THREAD_YIELD_HOOK() \
+ { \
+ if (RocksDbThreadYield) { \
+ RocksDbThreadYield(); \
+ } \
+ }
+#else
+#define ROCKSDB_THREAD_YIELD_HOOK() \
+ {}
+#endif

View File

@@ -0,0 +1,30 @@
diff --git a/CMakeLists.txt b/CMakeLists.txt
index 93b884d..b715cb6 100644
--- a/CMakeLists.txt
+++ b/CMakeLists.txt
@@ -106,14 +106,9 @@ endif()
include(CMakeDependentOption)
if(MSVC)
- option(WITH_GFLAGS "build with GFlags" OFF)
option(WITH_XPRESS "build with windows built in compression" OFF)
- option(ROCKSDB_SKIP_THIRDPARTY "skip thirdparty.inc" OFF)
-
- if(NOT ROCKSDB_SKIP_THIRDPARTY)
- include(${CMAKE_CURRENT_SOURCE_DIR}/thirdparty.inc)
- endif()
-else()
+endif()
+if(TRUE)
if(CMAKE_SYSTEM_NAME MATCHES "FreeBSD" AND NOT CMAKE_SYSTEM_NAME MATCHES "kFreeBSD")
# FreeBSD has jemalloc as default malloc
# but it does not have all the jemalloc files in include/...
@@ -126,7 +121,7 @@ else()
endif()
endif()
- if(MINGW)
+ if(MSVC OR MINGW)
option(WITH_GFLAGS "build with GFlags" OFF)
else()
option(WITH_GFLAGS "build with GFlags" ON)

View File

@@ -367,7 +367,7 @@ get(Section const& section,
} }
inline std::string inline std::string
get(Section const& section, std::string const& name, char const* defaultValue) get(Section const& section, std::string const& name, const char* defaultValue)
{ {
try try
{ {

View File

@@ -25,7 +25,6 @@
#include <cstdint> #include <cstdint>
#include <cstring> #include <cstring>
#include <memory>
namespace ripple { namespace ripple {

View File

@@ -55,7 +55,7 @@ lz4Compress(void const* in, std::size_t inSize, BufferFactory&& bf)
auto compressed = bf(outCapacity); auto compressed = bf(outCapacity);
auto compressedSize = LZ4_compress_default( auto compressedSize = LZ4_compress_default(
reinterpret_cast<char const*>(in), reinterpret_cast<const char*>(in),
reinterpret_cast<char*>(compressed), reinterpret_cast<char*>(compressed),
inSize, inSize,
outCapacity); outCapacity);
@@ -89,7 +89,7 @@ lz4Decompress(
Throw<std::runtime_error>("lz4Decompress: integer overflow (output)"); Throw<std::runtime_error>("lz4Decompress: integer overflow (output)");
if (LZ4_decompress_safe( if (LZ4_decompress_safe(
reinterpret_cast<char const*>(in), reinterpret_cast<const char*>(in),
reinterpret_cast<char*>(decompressed), reinterpret_cast<char*>(decompressed),
inSize, inSize,
decompressedSize) != decompressedSize) decompressedSize) != decompressedSize)

View File

@@ -22,18 +22,8 @@
#include <xrpl/basics/contract.h> #include <xrpl/basics/contract.h>
#if defined(__clang__)
#pragma clang diagnostic push
#pragma clang diagnostic ignored "-Wdeprecated"
#pragma clang diagnostic ignored "-Wdeprecated-declarations"
#endif
#include <boost/outcome.hpp> #include <boost/outcome.hpp>
#if defined(__clang__)
#pragma clang diagnostic pop
#endif
#include <stdexcept> #include <stdexcept>
namespace ripple { namespace ripple {
@@ -103,7 +93,7 @@ public:
{ {
} }
constexpr E const& constexpr const E&
value() const& value() const&
{ {
return val_; return val_;
@@ -121,7 +111,7 @@ public:
return std::move(val_); return std::move(val_);
} }
constexpr E const&& constexpr const E&&
value() const&& value() const&&
{ {
return std::move(val_); return std::move(val_);

View File

@@ -294,7 +294,7 @@ IntrusiveRefCounts::releaseStrongRef() const
} }
if (refCounts.compare_exchange_weak( if (refCounts.compare_exchange_weak(
prevIntVal, nextIntVal, std::memory_order_acq_rel)) prevIntVal, nextIntVal, std::memory_order_release))
{ {
// Can't be in partial destroy because only decrementing the strong // Can't be in partial destroy because only decrementing the strong
// count to zero can start a partial destroy, and that can't happen // count to zero can start a partial destroy, and that can't happen
@@ -351,7 +351,7 @@ IntrusiveRefCounts::addWeakReleaseStrongRef() const
} }
} }
if (refCounts.compare_exchange_weak( if (refCounts.compare_exchange_weak(
prevIntVal, nextIntVal, std::memory_order_acq_rel)) prevIntVal, nextIntVal, std::memory_order_release))
{ {
XRPL_ASSERT( XRPL_ASSERT(
(!(prevIntVal & partialDestroyStartedMask)), (!(prevIntVal & partialDestroyStartedMask)),
@@ -374,7 +374,7 @@ IntrusiveRefCounts::releaseWeakRef() const
// This case should only be hit if the partialDestroyStartedBit is // This case should only be hit if the partialDestroyStartedBit is
// set non-atomically (and even then very rarely). The code is kept // set non-atomically (and even then very rarely). The code is kept
// in case we need to set the flag non-atomically for perf reasons. // in case we need to set the flag non-atomically for perf reasons.
refCounts.wait(prevIntVal, std::memory_order_acquire); refCounts.wait(prevIntVal, std::memory_order_acq_rel);
prevIntVal = refCounts.load(std::memory_order_acquire); prevIntVal = refCounts.load(std::memory_order_acquire);
prev = RefCountPair{prevIntVal}; prev = RefCountPair{prevIntVal};
} }
@@ -382,7 +382,7 @@ IntrusiveRefCounts::releaseWeakRef() const
{ {
// partial destroy MUST finish before running a full destroy (when // partial destroy MUST finish before running a full destroy (when
// using weak pointers) // using weak pointers)
refCounts.wait(prevIntVal - weakDelta, std::memory_order_acquire); refCounts.wait(prevIntVal - weakDelta, std::memory_order_acq_rel);
} }
return ReleaseWeakRefAction::destroy; return ReleaseWeakRefAction::destroy;
} }
@@ -396,7 +396,7 @@ IntrusiveRefCounts::checkoutStrongRefFromWeak() const noexcept
auto desiredValue = RefCountPair{2, 1}.combinedValue(); auto desiredValue = RefCountPair{2, 1}.combinedValue();
while (!refCounts.compare_exchange_weak( while (!refCounts.compare_exchange_weak(
curValue, desiredValue, std::memory_order_acq_rel)) curValue, desiredValue, std::memory_order_release))
{ {
RefCountPair const prev{curValue}; RefCountPair const prev{curValue};
if (!prev.strong) if (!prev.strong)

View File

@@ -29,6 +29,7 @@
#include <array> #include <array>
#include <cstdint> #include <cstdint>
#include <optional> #include <optional>
#include <sstream>
#include <string> #include <string>
namespace ripple { namespace ripple {

View File

@@ -115,7 +115,7 @@ public:
sweep(); sweep();
bool bool
del(key_type const& key, bool valid); del(const key_type& key, bool valid);
public: public:
/** Replace aliased objects with originals. /** Replace aliased objects with originals.
@@ -134,20 +134,20 @@ public:
template <class R> template <class R>
bool bool
canonicalize( canonicalize(
key_type const& key, const key_type& key,
SharedPointerType& data, SharedPointerType& data,
R&& replaceCallback); R&& replaceCallback);
bool bool
canonicalize_replace_cache( canonicalize_replace_cache(
key_type const& key, const key_type& key,
SharedPointerType const& data); SharedPointerType const& data);
bool bool
canonicalize_replace_client(key_type const& key, SharedPointerType& data); canonicalize_replace_client(const key_type& key, SharedPointerType& data);
SharedPointerType SharedPointerType
fetch(key_type const& key); fetch(const key_type& key);
/** Insert the element into the container. /** Insert the element into the container.
If the key already exists, nothing happens. If the key already exists, nothing happens.
@@ -168,7 +168,7 @@ public:
// simply return an iterator. // simply return an iterator.
// //
bool bool
retrieve(key_type const& key, T& data); retrieve(const key_type& key, T& data);
mutex_type& mutex_type&
peekMutex(); peekMutex();
@@ -322,10 +322,10 @@ private:
std::string m_name; std::string m_name;
// Desired number of cache entries (0 = ignore) // Desired number of cache entries (0 = ignore)
int const m_target_size; const int m_target_size;
// Desired maximum cache age // Desired maximum cache age
clock_type::duration const m_target_age; const clock_type::duration m_target_age;
// Number of items cached // Number of items cached
int m_cache_count; int m_cache_count;

View File

@@ -365,7 +365,7 @@ TaggedCache<
SharedPointerType, SharedPointerType,
Hash, Hash,
KeyEqual, KeyEqual,
Mutex>::del(key_type const& key, bool valid) Mutex>::del(const key_type& key, bool valid)
{ {
// Remove from cache, if !valid, remove from map too. Returns true if // Remove from cache, if !valid, remove from map too. Returns true if
// removed from cache // removed from cache
@@ -414,7 +414,7 @@ TaggedCache<
KeyEqual, KeyEqual,
Mutex>:: Mutex>::
canonicalize( canonicalize(
key_type const& key, const key_type& key,
SharedPointerType& data, SharedPointerType& data,
R&& replaceCallback) R&& replaceCallback)
{ {
@@ -509,7 +509,7 @@ TaggedCache<
KeyEqual, KeyEqual,
Mutex>:: Mutex>::
canonicalize_replace_cache( canonicalize_replace_cache(
key_type const& key, const key_type& key,
SharedPointerType const& data) SharedPointerType const& data)
{ {
return canonicalize( return canonicalize(
@@ -535,7 +535,7 @@ TaggedCache<
Hash, Hash,
KeyEqual, KeyEqual,
Mutex>:: Mutex>::
canonicalize_replace_client(key_type const& key, SharedPointerType& data) canonicalize_replace_client(const key_type& key, SharedPointerType& data)
{ {
return canonicalize(key, data, []() { return false; }); return canonicalize(key, data, []() { return false; });
} }
@@ -558,7 +558,7 @@ TaggedCache<
SharedPointerType, SharedPointerType,
Hash, Hash,
KeyEqual, KeyEqual,
Mutex>::fetch(key_type const& key) Mutex>::fetch(const key_type& key)
{ {
std::lock_guard<mutex_type> l(m_mutex); std::lock_guard<mutex_type> l(m_mutex);
auto ret = initialFetch(key, l); auto ret = initialFetch(key, l);
@@ -656,7 +656,7 @@ TaggedCache<
SharedPointerType, SharedPointerType,
Hash, Hash,
KeyEqual, KeyEqual,
Mutex>::retrieve(key_type const& key, T& data) Mutex>::retrieve(const key_type& key, T& data)
{ {
// retrieve the value of the stored data // retrieve the value of the stored data
auto entry = fetch(key); auto entry = fetch(key);

View File

@@ -20,6 +20,7 @@
#ifndef RIPPLE_ALGORITHM_H_INCLUDED #ifndef RIPPLE_ALGORITHM_H_INCLUDED
#define RIPPLE_ALGORITHM_H_INCLUDED #define RIPPLE_ALGORITHM_H_INCLUDED
#include <iterator>
#include <utility> #include <utility>
namespace ripple { namespace ripple {

View File

@@ -374,7 +374,7 @@ public:
} }
base_uint& base_uint&
operator^=(base_uint const& b) operator^=(const base_uint& b)
{ {
for (int i = 0; i < WIDTH; i++) for (int i = 0; i < WIDTH; i++)
data_[i] ^= b.data_[i]; data_[i] ^= b.data_[i];
@@ -383,7 +383,7 @@ public:
} }
base_uint& base_uint&
operator&=(base_uint const& b) operator&=(const base_uint& b)
{ {
for (int i = 0; i < WIDTH; i++) for (int i = 0; i < WIDTH; i++)
data_[i] &= b.data_[i]; data_[i] &= b.data_[i];
@@ -392,7 +392,7 @@ public:
} }
base_uint& base_uint&
operator|=(base_uint const& b) operator|=(const base_uint& b)
{ {
for (int i = 0; i < WIDTH; i++) for (int i = 0; i < WIDTH; i++)
data_[i] |= b.data_[i]; data_[i] |= b.data_[i];
@@ -415,11 +415,11 @@ public:
return *this; return *this;
} }
base_uint const const base_uint
operator++(int) operator++(int)
{ {
// postfix operator // postfix operator
base_uint const ret = *this; const base_uint ret = *this;
++(*this); ++(*this);
return ret; return ret;
@@ -441,11 +441,11 @@ public:
return *this; return *this;
} }
base_uint const const base_uint
operator--(int) operator--(int)
{ {
// postfix operator // postfix operator
base_uint const ret = *this; const base_uint ret = *this;
--(*this); --(*this);
return ret; return ret;
@@ -466,7 +466,7 @@ public:
} }
base_uint& base_uint&
operator+=(base_uint const& b) operator+=(const base_uint& b)
{ {
std::uint64_t carry = 0; std::uint64_t carry = 0;
@@ -511,7 +511,7 @@ public:
} }
[[nodiscard]] constexpr bool [[nodiscard]] constexpr bool
parseHex(char const* str) parseHex(const char* str)
{ {
return parseHex(std::string_view{str}); return parseHex(std::string_view{str});
} }

View File

@@ -43,7 +43,7 @@ struct less
using result_type = bool; using result_type = bool;
constexpr bool constexpr bool
operator()(T const& left, T const& right) const operator()(const T& left, const T& right) const
{ {
return std::less<T>()(left, right); return std::less<T>()(left, right);
} }
@@ -55,7 +55,7 @@ struct equal_to
using result_type = bool; using result_type = bool;
constexpr bool constexpr bool
operator()(T const& left, T const& right) const operator()(const T& left, const T& right) const
{ {
return std::equal_to<T>()(left, right); return std::equal_to<T>()(left, right);
} }

View File

@@ -24,8 +24,12 @@
#include <xrpl/beast/hash/xxhasher.h> #include <xrpl/beast/hash/xxhasher.h>
#include <cstdint> #include <cstdint>
#include <functional>
#include <mutex> #include <mutex>
#include <random> #include <random>
#include <type_traits>
#include <unordered_map>
#include <unordered_set>
#include <utility> #include <utility>
namespace ripple { namespace ripple {

View File

@@ -23,6 +23,7 @@
#include <cstdint> #include <cstdint>
#include <limits> #include <limits>
#include <optional> #include <optional>
#include <utility>
namespace ripple { namespace ripple {
auto constexpr muldiv_max = std::numeric_limits<std::uint64_t>::max(); auto constexpr muldiv_max = std::numeric_limits<std::uint64_t>::max();

View File

@@ -52,7 +52,7 @@ template <
typename Value, typename Value,
typename Hash, typename Hash,
typename Pred = std::equal_to<Key>, typename Pred = std::equal_to<Key>,
typename Alloc = std::allocator<std::pair<Key const, Value>>> typename Alloc = std::allocator<std::pair<const Key, Value>>>
class partitioned_unordered_map class partitioned_unordered_map
{ {
std::size_t partitions_; std::size_t partitions_;

View File

@@ -24,8 +24,10 @@
#include <boost/operators.hpp> #include <boost/operators.hpp>
#include <functional>
#include <iostream> #include <iostream>
#include <type_traits> #include <type_traits>
#include <utility>
namespace ripple { namespace ripple {
@@ -74,13 +76,13 @@ public:
} }
bool bool
operator<(tagged_integer const& rhs) const noexcept operator<(const tagged_integer& rhs) const noexcept
{ {
return m_value < rhs.m_value; return m_value < rhs.m_value;
} }
bool bool
operator==(tagged_integer const& rhs) const noexcept operator==(const tagged_integer& rhs) const noexcept
{ {
return m_value == rhs.m_value; return m_value == rhs.m_value;
} }
@@ -142,14 +144,14 @@ public:
} }
tagged_integer& tagged_integer&
operator<<=(tagged_integer const& rhs) noexcept operator<<=(const tagged_integer& rhs) noexcept
{ {
m_value <<= rhs.m_value; m_value <<= rhs.m_value;
return *this; return *this;
} }
tagged_integer& tagged_integer&
operator>>=(tagged_integer const& rhs) noexcept operator>>=(const tagged_integer& rhs) noexcept
{ {
m_value >>= rhs.m_value; m_value >>= rhs.m_value;
return *this; return *this;

View File

@@ -20,6 +20,9 @@
#ifndef BEAST_CHRONO_ABSTRACT_CLOCK_H_INCLUDED #ifndef BEAST_CHRONO_ABSTRACT_CLOCK_H_INCLUDED
#define BEAST_CHRONO_ABSTRACT_CLOCK_H_INCLUDED #define BEAST_CHRONO_ABSTRACT_CLOCK_H_INCLUDED
#include <chrono>
#include <string>
namespace beast { namespace beast {
/** Abstract interface to a clock. /** Abstract interface to a clock.

View File

@@ -23,8 +23,6 @@
#include <xrpl/beast/clock/abstract_clock.h> #include <xrpl/beast/clock/abstract_clock.h>
#include <xrpl/beast/utility/instrumentation.h> #include <xrpl/beast/utility/instrumentation.h>
#include <chrono>
namespace beast { namespace beast {
/** Manual clock implementation. /** Manual clock implementation.

View File

@@ -22,7 +22,6 @@
#include <xrpl/beast/container/aged_container.h> #include <xrpl/beast/container/aged_container.h>
#include <chrono>
#include <type_traits> #include <type_traits>
namespace beast { namespace beast {

View File

@@ -20,6 +20,8 @@
#ifndef BEAST_CONTAINER_DETAIL_AGED_ASSOCIATIVE_CONTAINER_H_INCLUDED #ifndef BEAST_CONTAINER_DETAIL_AGED_ASSOCIATIVE_CONTAINER_H_INCLUDED
#define BEAST_CONTAINER_DETAIL_AGED_ASSOCIATIVE_CONTAINER_H_INCLUDED #define BEAST_CONTAINER_DETAIL_AGED_ASSOCIATIVE_CONTAINER_H_INCLUDED
#include <type_traits>
namespace beast { namespace beast {
namespace detail { namespace detail {

View File

@@ -33,6 +33,7 @@
#include <algorithm> #include <algorithm>
#include <functional> #include <functional>
#include <initializer_list> #include <initializer_list>
#include <iterator>
#include <memory> #include <memory>
#include <type_traits> #include <type_traits>
#include <utility> #include <utility>

View File

@@ -29,9 +29,11 @@
#include <charconv> #include <charconv>
#include <cstdlib> #include <cstdlib>
#include <iterator> #include <iterator>
#include <limits>
#include <string> #include <string>
#include <type_traits> #include <type_traits>
#include <typeinfo> #include <typeinfo>
#include <utility>
namespace beast { namespace beast {

View File

@@ -24,36 +24,14 @@
#include <boost/container/flat_set.hpp> #include <boost/container/flat_set.hpp>
#include <boost/endian/conversion.hpp> #include <boost/endian/conversion.hpp>
/*
Workaround for overzealous clang warning, which trips on libstdc++ headers
In file included from
/usr/lib/gcc/x86_64-linux-gnu/12/../../../../include/c++/12/bits/stl_algo.h:61:
/usr/lib/gcc/x86_64-linux-gnu/12/../../../../include/c++/12/bits/stl_tempbuf.h:263:8:
error: 'get_temporary_buffer<std::pair<ripple::Quality, const
std::vector<std::unique_ptr<ripple::Step>> *>>' is deprecated
[-Werror,-Wdeprecated-declarations] 263 |
std::get_temporary_buffer<value_type>(_M_original_len));
^
*/
#if defined(__clang__)
#pragma clang diagnostic push
#pragma clang diagnostic ignored "-Wdeprecated"
#pragma clang diagnostic ignored "-Wdeprecated-declarations"
#endif
#include <functional>
#if defined(__clang__)
#pragma clang diagnostic pop
#endif
#include <array> #include <array>
#include <chrono> #include <chrono>
#include <cstdint>
#include <cstring> #include <cstring>
#include <functional>
#include <map>
#include <memory> #include <memory>
#include <set>
#include <string> #include <string>
#include <system_error> #include <system_error>
#include <tuple> #include <tuple>

View File

@@ -30,7 +30,7 @@ namespace beast {
template <class Hasher = xxhasher> template <class Hasher = xxhasher>
struct uhash struct uhash
{ {
uhash() = default; explicit uhash() = default;
using result_type = typename Hasher::result_type; using result_type = typename Hasher::result_type;

View File

@@ -29,7 +29,11 @@
#include <boost/asio/ip/address.hpp> #include <boost/asio/ip/address.hpp>
#include <boost/functional/hash.hpp> #include <boost/functional/hash.hpp>
#include <cstdint>
#include <ios>
#include <sstream>
#include <string> #include <string>
#include <typeinfo>
//------------------------------------------------------------------------------ //------------------------------------------------------------------------------

View File

@@ -24,6 +24,12 @@
#include <boost/asio/ip/address_v4.hpp> #include <boost/asio/ip/address_v4.hpp>
#include <cstdint>
#include <functional>
#include <ios>
#include <string>
#include <utility>
namespace beast { namespace beast {
namespace IP { namespace IP {

View File

@@ -24,6 +24,12 @@
#include <boost/asio/ip/address_v6.hpp> #include <boost/asio/ip/address_v6.hpp>
#include <cstdint>
#include <functional>
#include <ios>
#include <string>
#include <utility>
namespace beast { namespace beast {
namespace IP { namespace IP {

View File

@@ -25,6 +25,7 @@
#include <xrpl/beast/net/IPAddress.h> #include <xrpl/beast/net/IPAddress.h>
#include <cstdint> #include <cstdint>
#include <ios>
#include <optional> #include <optional>
#include <string> #include <string>
@@ -214,7 +215,7 @@ namespace std {
template <> template <>
struct hash<::beast::IP::Endpoint> struct hash<::beast::IP::Endpoint>
{ {
hash() = default; explicit hash() = default;
std::size_t std::size_t
operator()(::beast::IP::Endpoint const& endpoint) const operator()(::beast::IP::Endpoint const& endpoint) const
@@ -229,7 +230,7 @@ namespace boost {
template <> template <>
struct hash<::beast::IP::Endpoint> struct hash<::beast::IP::Endpoint>
{ {
hash() = default; explicit hash() = default;
std::size_t std::size_t
operator()(::beast::IP::Endpoint const& endpoint) const operator()(::beast::IP::Endpoint const& endpoint) const

View File

@@ -28,8 +28,10 @@
#include <algorithm> #include <algorithm>
#include <cctype> #include <cctype>
#include <cstdint>
#include <iterator> #include <iterator>
#include <string> #include <string>
#include <utility>
#include <vector> #include <vector>
namespace beast { namespace beast {

View File

@@ -13,6 +13,7 @@
#include <boost/optional.hpp> #include <boost/optional.hpp>
#include <condition_variable> #include <condition_variable>
#include <functional>
#include <mutex> #include <mutex>
#include <thread> #include <thread>
#include <vector> #include <vector>

View File

@@ -16,6 +16,7 @@
#include <algorithm> #include <algorithm>
#include <chrono> #include <chrono>
#include <functional>
#include <iomanip> #include <iomanip>
#include <iostream> #include <iostream>
#include <sstream> #include <sstream>

View File

@@ -13,6 +13,7 @@
#include <boost/assert.hpp> #include <boost/assert.hpp>
#include <mutex> #include <mutex>
#include <ostream>
#include <string> #include <string>
namespace beast { namespace beast {

View File

@@ -31,28 +31,36 @@ namespace beast {
template <class Generator> template <class Generator>
void void
rngfill(void* const buffer, std::size_t const bytes, Generator& g) rngfill(void* buffer, std::size_t bytes, Generator& g)
{ {
using result_type = typename Generator::result_type; using result_type = typename Generator::result_type;
constexpr std::size_t result_size = sizeof(result_type);
std::uint8_t* const buffer_start = static_cast<std::uint8_t*>(buffer); while (bytes >= sizeof(result_type))
std::size_t const complete_iterations = bytes / result_size;
std::size_t const bytes_remaining = bytes % result_size;
for (std::size_t count = 0; count < complete_iterations; ++count)
{ {
result_type const v = g(); auto const v = g();
std::size_t const offset = count * result_size; std::memcpy(buffer, &v, sizeof(v));
std::memcpy(buffer_start + offset, &v, result_size); buffer = reinterpret_cast<std::uint8_t*>(buffer) + sizeof(v);
bytes -= sizeof(v);
} }
if (bytes_remaining > 0) XRPL_ASSERT(
bytes < sizeof(result_type), "beast::rngfill(void*) : maximum bytes");
#ifdef __GNUC__
// gcc 11.1 (falsely) warns about an array-bounds overflow in release mode.
#pragma GCC diagnostic push
#pragma GCC diagnostic ignored "-Warray-bounds"
#endif
if (bytes > 0)
{ {
result_type const v = g(); auto const v = g();
std::size_t const offset = complete_iterations * result_size; std::memcpy(buffer, &v, bytes);
std::memcpy(buffer_start + offset, &v, bytes_remaining);
} }
#ifdef __GNUC__
#pragma GCC diagnostic pop
#endif
} }
template < template <

View File

@@ -37,9 +37,9 @@ class temp_dir
public: public:
#if !GENERATING_DOCS #if !GENERATING_DOCS
temp_dir(temp_dir const&) = delete; temp_dir(const temp_dir&) = delete;
temp_dir& temp_dir&
operator=(temp_dir const&) = delete; operator=(const temp_dir&) = delete;
#endif #endif
/// Construct a temporary directory. /// Construct a temporary directory.

View File

@@ -39,7 +39,7 @@ class Reader
{ {
public: public:
using Char = char; using Char = char;
using Location = Char const*; using Location = const Char*;
/** \brief Constructs a Reader allowing all features /** \brief Constructs a Reader allowing all features
* for parsing. * for parsing.
@@ -64,7 +64,7 @@ public:
* error occurred. * error occurred.
*/ */
bool bool
parse(char const* beginDoc, char const* endDoc, Value& root); parse(const char* beginDoc, const char* endDoc, Value& root);
/// \brief Parse from input stream. /// \brief Parse from input stream.
/// \see Json::operator>>(std::istream&, Json::Value&). /// \see Json::operator>>(std::istream&, Json::Value&).
@@ -133,7 +133,7 @@ private:
using Errors = std::deque<ErrorInfo>; using Errors = std::deque<ErrorInfo>;
bool bool
expectToken(TokenType type, Token& token, char const* message); expectToken(TokenType type, Token& token, const char* message);
bool bool
readToken(Token& token); readToken(Token& token);
void void

View File

@@ -20,7 +20,6 @@
#ifndef RIPPLE_JSON_JSON_VALUE_H_INCLUDED #ifndef RIPPLE_JSON_JSON_VALUE_H_INCLUDED
#define RIPPLE_JSON_JSON_VALUE_H_INCLUDED #define RIPPLE_JSON_JSON_VALUE_H_INCLUDED
#include <xrpl/basics/Number.h>
#include <xrpl/json/json_forwards.h> #include <xrpl/json/json_forwards.h>
#include <cstring> #include <cstring>
@@ -62,24 +61,24 @@ enum ValueType {
class StaticString class StaticString
{ {
public: public:
constexpr explicit StaticString(char const* czstring) : str_(czstring) constexpr explicit StaticString(const char* czstring) : str_(czstring)
{ {
} }
constexpr constexpr
operator char const*() const operator const char*() const
{ {
return str_; return str_;
} }
constexpr char const* constexpr const char*
c_str() const c_str() const
{ {
return str_; return str_;
} }
private: private:
char const* str_; const char* str_;
}; };
inline bool inline bool
@@ -157,10 +156,10 @@ public:
using Int = Json::Int; using Int = Json::Int;
using ArrayIndex = UInt; using ArrayIndex = UInt;
static Value const null; static const Value null;
static Int const minInt; static const Int minInt;
static Int const maxInt; static const Int maxInt;
static UInt const maxUInt; static const UInt maxUInt;
private: private:
class CZString class CZString
@@ -172,24 +171,24 @@ private:
duplicateOnCopy duplicateOnCopy
}; };
CZString(int index); CZString(int index);
CZString(char const* cstr, DuplicationPolicy allocate); CZString(const char* cstr, DuplicationPolicy allocate);
CZString(CZString const& other); CZString(const CZString& other);
~CZString(); ~CZString();
CZString& CZString&
operator=(CZString const& other) = delete; operator=(const CZString& other) = delete;
bool bool
operator<(CZString const& other) const; operator<(const CZString& other) const;
bool bool
operator==(CZString const& other) const; operator==(const CZString& other) const;
int int
index() const; index() const;
char const* const char*
c_str() const; c_str() const;
bool bool
isStaticString() const; isStaticString() const;
private: private:
char const* cstr_; const char* cstr_;
int index_; int index_;
}; };
@@ -216,8 +215,7 @@ public:
Value(Int value); Value(Int value);
Value(UInt value); Value(UInt value);
Value(double value); Value(double value);
Value(char const* value); Value(const char* value);
Value(ripple::Number const& value);
/** \brief Constructs a value from a static string. /** \brief Constructs a value from a static string.
* Like other value string constructor but do not duplicate the string for * Like other value string constructor but do not duplicate the string for
@@ -229,10 +227,10 @@ public:
* Json::Value aValue( StaticString("some text") ); * Json::Value aValue( StaticString("some text") );
* \endcode * \endcode
*/ */
Value(StaticString const& value); Value(const StaticString& value);
Value(std::string const& value); Value(std::string const& value);
Value(bool value); Value(bool value);
Value(Value const& other); Value(const Value& other);
~Value(); ~Value();
Value& Value&
@@ -249,7 +247,7 @@ public:
ValueType ValueType
type() const; type() const;
char const* const char*
asCString() const; asCString() const;
/** Returns the unquoted string value. */ /** Returns the unquoted string value. */
std::string std::string
@@ -319,12 +317,12 @@ public:
/// Access an array element (zero based index ) /// Access an array element (zero based index )
/// (You may need to say 'value[0u]' to get your compiler to distinguish /// (You may need to say 'value[0u]' to get your compiler to distinguish
/// this from the operator[] which takes a string.) /// this from the operator[] which takes a string.)
Value const& const Value&
operator[](UInt index) const; operator[](UInt index) const;
/// If the array contains at least index+1 elements, returns the element /// If the array contains at least index+1 elements, returns the element
/// value, otherwise returns defaultValue. /// value, otherwise returns defaultValue.
Value Value
get(UInt index, Value const& defaultValue) const; get(UInt index, const Value& defaultValue) const;
/// Return true if index < size(). /// Return true if index < size().
bool bool
isValidIndex(UInt index) const; isValidIndex(UInt index) const;
@@ -332,25 +330,25 @@ public:
/// ///
/// Equivalent to jsonvalue[jsonvalue.size()] = value; /// Equivalent to jsonvalue[jsonvalue.size()] = value;
Value& Value&
append(Value const& value); append(const Value& value);
Value& Value&
append(Value&& value); append(Value&& value);
/// Access an object value by name, create a null member if it does not /// Access an object value by name, create a null member if it does not
/// exist. /// exist.
Value& Value&
operator[](char const* key); operator[](const char* key);
/// Access an object value by name, returns null if there is no member with /// Access an object value by name, returns null if there is no member with
/// that name. /// that name.
Value const& const Value&
operator[](char const* key) const; operator[](const char* key) const;
/// Access an object value by name, create a null member if it does not /// Access an object value by name, create a null member if it does not
/// exist. /// exist.
Value& Value&
operator[](std::string const& key); operator[](std::string const& key);
/// Access an object value by name, returns null if there is no member with /// Access an object value by name, returns null if there is no member with
/// that name. /// that name.
Value const& const Value&
operator[](std::string const& key) const; operator[](std::string const& key) const;
/** \brief Access an object value by name, create a null member if it does /** \brief Access an object value by name, create a null member if it does
not exist. not exist.
@@ -366,16 +364,14 @@ public:
* \endcode * \endcode
*/ */
Value& Value&
operator[](StaticString const& key); operator[](const StaticString& key);
Value const&
operator[](StaticString const& key) const;
/// Return the member named key if it exist, defaultValue otherwise. /// Return the member named key if it exist, defaultValue otherwise.
Value Value
get(char const* key, Value const& defaultValue) const; get(const char* key, const Value& defaultValue) const;
/// Return the member named key if it exist, defaultValue otherwise. /// Return the member named key if it exist, defaultValue otherwise.
Value Value
get(std::string const& key, Value const& defaultValue) const; get(std::string const& key, const Value& defaultValue) const;
/// \brief Remove and return the named member. /// \brief Remove and return the named member.
/// ///
@@ -384,14 +380,14 @@ public:
/// \pre type() is objectValue or nullValue /// \pre type() is objectValue or nullValue
/// \post type() is unchanged /// \post type() is unchanged
Value Value
removeMember(char const* key); removeMember(const char* key);
/// Same as removeMember(const char*) /// Same as removeMember(const char*)
Value Value
removeMember(std::string const& key); removeMember(std::string const& key);
/// Return true if the object has a member named key. /// Return true if the object has a member named key.
bool bool
isMember(char const* key) const; isMember(const char* key) const;
/// Return true if the object has a member named key. /// Return true if the object has a member named key.
bool bool
isMember(std::string const& key) const; isMember(std::string const& key) const;
@@ -418,13 +414,13 @@ public:
end(); end();
friend bool friend bool
operator==(Value const&, Value const&); operator==(const Value&, const Value&);
friend bool friend bool
operator<(Value const&, Value const&); operator<(const Value&, const Value&);
private: private:
Value& Value&
resolveReference(char const* key, bool isStatic); resolveReference(const char* key, bool isStatic);
private: private:
union ValueHolder union ValueHolder
@@ -440,38 +436,32 @@ private:
int allocated_ : 1; // Notes: if declared as bool, bitfield is useless. int allocated_ : 1; // Notes: if declared as bool, bitfield is useless.
}; };
inline Value
to_json(ripple::Number const& number)
{
return to_string(number);
}
bool bool
operator==(Value const&, Value const&); operator==(const Value&, const Value&);
inline bool inline bool
operator!=(Value const& x, Value const& y) operator!=(const Value& x, const Value& y)
{ {
return !(x == y); return !(x == y);
} }
bool bool
operator<(Value const&, Value const&); operator<(const Value&, const Value&);
inline bool inline bool
operator<=(Value const& x, Value const& y) operator<=(const Value& x, const Value& y)
{ {
return !(y < x); return !(y < x);
} }
inline bool inline bool
operator>(Value const& x, Value const& y) operator>(const Value& x, const Value& y)
{ {
return y < x; return y < x;
} }
inline bool inline bool
operator>=(Value const& x, Value const& y) operator>=(const Value& x, const Value& y)
{ {
return !(x < y); return !(x < y);
} }
@@ -492,11 +482,11 @@ public:
virtual ~ValueAllocator() = default; virtual ~ValueAllocator() = default;
virtual char* virtual char*
makeMemberName(char const* memberName) = 0; makeMemberName(const char* memberName) = 0;
virtual void virtual void
releaseMemberName(char* memberName) = 0; releaseMemberName(char* memberName) = 0;
virtual char* virtual char*
duplicateStringValue(char const* value, unsigned int length = unknown) = 0; duplicateStringValue(const char* value, unsigned int length = unknown) = 0;
virtual void virtual void
releaseStringValue(char* value) = 0; releaseStringValue(char* value) = 0;
}; };
@@ -513,16 +503,16 @@ public:
ValueIteratorBase(); ValueIteratorBase();
explicit ValueIteratorBase(Value::ObjectValues::iterator const& current); explicit ValueIteratorBase(const Value::ObjectValues::iterator& current);
bool bool
operator==(SelfType const& other) const operator==(const SelfType& other) const
{ {
return isEqual(other); return isEqual(other);
} }
bool bool
operator!=(SelfType const& other) const operator!=(const SelfType& other) const
{ {
return !isEqual(other); return !isEqual(other);
} }
@@ -538,7 +528,7 @@ public:
/// Return the member name of the referenced Value. "" if it is not an /// Return the member name of the referenced Value. "" if it is not an
/// objectValue. /// objectValue.
char const* const char*
memberName() const; memberName() const;
protected: protected:
@@ -552,13 +542,13 @@ protected:
decrement(); decrement();
difference_type difference_type
computeDistance(SelfType const& other) const; computeDistance(const SelfType& other) const;
bool bool
isEqual(SelfType const& other) const; isEqual(const SelfType& other) const;
void void
copy(SelfType const& other); copy(const SelfType& other);
private: private:
Value::ObjectValues::iterator current_; Value::ObjectValues::iterator current_;
@@ -576,8 +566,8 @@ class ValueConstIterator : public ValueIteratorBase
public: public:
using size_t = unsigned int; using size_t = unsigned int;
using difference_type = int; using difference_type = int;
using reference = Value const&; using reference = const Value&;
using pointer = Value const*; using pointer = const Value*;
using SelfType = ValueConstIterator; using SelfType = ValueConstIterator;
ValueConstIterator() = default; ValueConstIterator() = default;
@@ -585,11 +575,11 @@ public:
private: private:
/*! \internal Use by Value to create an iterator. /*! \internal Use by Value to create an iterator.
*/ */
explicit ValueConstIterator(Value::ObjectValues::iterator const& current); explicit ValueConstIterator(const Value::ObjectValues::iterator& current);
public: public:
SelfType& SelfType&
operator=(ValueIteratorBase const& other); operator=(const ValueIteratorBase& other);
SelfType SelfType
operator++(int) operator++(int)
@@ -642,17 +632,17 @@ public:
using SelfType = ValueIterator; using SelfType = ValueIterator;
ValueIterator() = default; ValueIterator() = default;
ValueIterator(ValueConstIterator const& other); ValueIterator(const ValueConstIterator& other);
ValueIterator(ValueIterator const& other); ValueIterator(const ValueIterator& other);
private: private:
/*! \internal Use by Value to create an iterator. /*! \internal Use by Value to create an iterator.
*/ */
explicit ValueIterator(Value::ObjectValues::iterator const& current); explicit ValueIterator(const Value::ObjectValues::iterator& current);
public: public:
SelfType& SelfType&
operator=(SelfType const& other); operator=(const SelfType& other);
SelfType SelfType
operator++(int) operator++(int)

View File

@@ -39,7 +39,7 @@ public:
{ {
} }
virtual std::string virtual std::string
write(Value const& root) = 0; write(const Value& root) = 0;
}; };
/** \brief Outputs a Value in <a HREF="http://www.json.org">JSON</a> format /** \brief Outputs a Value in <a HREF="http://www.json.org">JSON</a> format
@@ -60,11 +60,11 @@ public:
public: // overridden from Writer public: // overridden from Writer
std::string std::string
write(Value const& root) override; write(const Value& root) override;
private: private:
void void
writeValue(Value const& value); writeValue(const Value& value);
std::string document_; std::string document_;
}; };
@@ -101,15 +101,15 @@ public: // overridden from Writer
* JSON document that represents the root value. * JSON document that represents the root value.
*/ */
std::string std::string
write(Value const& root) override; write(const Value& root) override;
private: private:
void void
writeValue(Value const& value); writeValue(const Value& value);
void void
writeArrayValue(Value const& value); writeArrayValue(const Value& value);
bool bool
isMultineArray(Value const& value); isMultineArray(const Value& value);
void void
pushValue(std::string const& value); pushValue(std::string const& value);
void void
@@ -168,15 +168,15 @@ public:
* return a value. * return a value.
*/ */
void void
write(std::ostream& out, Value const& root); write(std::ostream& out, const Value& root);
private: private:
void void
writeValue(Value const& value); writeValue(const Value& value);
void void
writeArrayValue(Value const& value); writeArrayValue(const Value& value);
bool bool
isMultineArray(Value const& value); isMultineArray(const Value& value);
void void
pushValue(std::string const& value); pushValue(std::string const& value);
void void
@@ -207,12 +207,12 @@ valueToString(double value);
std::string std::string
valueToString(bool value); valueToString(bool value);
std::string std::string
valueToQuotedString(char const* value); valueToQuotedString(const char* value);
/// \brief Output using the StyledStreamWriter. /// \brief Output using the StyledStreamWriter.
/// \see Json::operator>>() /// \see Json::operator>>()
std::ostream& std::ostream&
operator<<(std::ostream&, Value const& root); operator<<(std::ostream&, const Value& root);
//------------------------------------------------------------------------------ //------------------------------------------------------------------------------

View File

@@ -37,7 +37,7 @@ pretty(Value const&);
/** Output using the StyledStreamWriter. @see Json::operator>>(). */ /** Output using the StyledStreamWriter. @see Json::operator>>(). */
std::ostream& std::ostream&
operator<<(std::ostream&, Value const& root); operator<<(std::ostream&, const Value& root);
} // namespace Json } // namespace Json

View File

@@ -29,6 +29,7 @@
#include <xrpl/protocol/json_get_or_throw.h> #include <xrpl/protocol/json_get_or_throw.h>
#include <cstddef> #include <cstddef>
#include <mutex>
#include <optional> #include <optional>
#include <string> #include <string>
@@ -148,7 +149,7 @@ namespace std {
template <> template <>
struct hash<ripple::AccountID> : ripple::AccountID::hasher struct hash<ripple::AccountID> : ripple::AccountID::hasher
{ {
hash() = default; explicit hash() = default;
}; };
} // namespace std } // namespace std

View File

@@ -20,6 +20,7 @@
#ifndef RIPPLE_PROTOCOL_APIVERSION_H_INCLUDED #ifndef RIPPLE_PROTOCOL_APIVERSION_H_INCLUDED
#define RIPPLE_PROTOCOL_APIVERSION_H_INCLUDED #define RIPPLE_PROTOCOL_APIVERSION_H_INCLUDED
#include <functional>
#include <type_traits> #include <type_traits>
#include <utility> #include <utility>

View File

@@ -20,7 +20,6 @@
#ifndef RIPPLE_PROTOCOL_ASSET_H_INCLUDED #ifndef RIPPLE_PROTOCOL_ASSET_H_INCLUDED
#define RIPPLE_PROTOCOL_ASSET_H_INCLUDED #define RIPPLE_PROTOCOL_ASSET_H_INCLUDED
#include <xrpl/basics/Number.h>
#include <xrpl/basics/base_uint.h> #include <xrpl/basics/base_uint.h>
#include <xrpl/protocol/Issue.h> #include <xrpl/protocol/Issue.h>
#include <xrpl/protocol/MPTIssue.h> #include <xrpl/protocol/MPTIssue.h>
@@ -28,7 +27,6 @@
namespace ripple { namespace ripple {
class Asset; class Asset;
class STAmount;
template <typename TIss> template <typename TIss>
concept ValidIssueType = concept ValidIssueType =
@@ -94,9 +92,6 @@ public:
void void
setJson(Json::Value& jv) const; setJson(Json::Value& jv) const;
STAmount
operator()(Number const&) const;
bool bool
native() const native() const
{ {
@@ -119,14 +114,6 @@ public:
equalTokens(Asset const& lhs, Asset const& rhs); equalTokens(Asset const& lhs, Asset const& rhs);
}; };
inline Json::Value
to_json(Asset const& asset)
{
Json::Value jv;
asset.setJson(jv);
return jv;
}
template <ValidIssueType TIss> template <ValidIssueType TIss>
constexpr bool constexpr bool
Asset::holds() const Asset::holds() const
@@ -232,6 +219,9 @@ validJSONAsset(Json::Value const& jv);
Asset Asset
assetFromJson(Json::Value const& jv); assetFromJson(Json::Value const& jv);
Json::Value
to_json(Asset const& asset);
} // namespace ripple } // namespace ripple
#endif // RIPPLE_PROTOCOL_ASSET_H_INCLUDED #endif // RIPPLE_PROTOCOL_ASSET_H_INCLUDED

View File

@@ -1,37 +0,0 @@
//------------------------------------------------------------------------------
/*
This file is part of rippled: https://github.com/ripple/rippled
Copyright (c) 2024 Ripple Labs Inc.
Permission to use, copy, modify, and/or distribute this software for any
purpose with or without fee is hereby granted, provided that the above
copyright notice and this permission notice appear in all copies.
THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
ANY SPECIAL , DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
*/
//==============================================================================
#include <xrpl/protocol/HashPrefix.h>
#include <xrpl/protocol/STVector256.h>
#include <xrpl/protocol/Serializer.h>
namespace ripple {
inline void
serializeBatch(
Serializer& msg,
std::uint32_t const& flags,
std::vector<uint256> const& txids)
{
msg.add32(HashPrefix::batch);
msg.add32(flags);
msg.add32(std::uint32_t(txids.size()));
for (auto const& txid : txids)
msg.addBitString(txid);
}
} // namespace ripple

View File

@@ -21,7 +21,6 @@
#define RIPPLE_PROTOCOL_BOOK_H_INCLUDED #define RIPPLE_PROTOCOL_BOOK_H_INCLUDED
#include <xrpl/basics/CountedObject.h> #include <xrpl/basics/CountedObject.h>
#include <xrpl/basics/base_uint.h>
#include <xrpl/protocol/Issue.h> #include <xrpl/protocol/Issue.h>
#include <boost/utility/base_from_member.hpp> #include <boost/utility/base_from_member.hpp>
@@ -37,17 +36,12 @@ class Book final : public CountedObject<Book>
public: public:
Issue in; Issue in;
Issue out; Issue out;
std::optional<uint256> domain;
Book() Book()
{ {
} }
Book( Book(Issue const& in_, Issue const& out_) : in(in_), out(out_)
Issue const& in_,
Issue const& out_,
std::optional<uint256> const& domain_)
: in(in_), out(out_), domain(domain_)
{ {
} }
}; };
@@ -67,8 +61,6 @@ hash_append(Hasher& h, Book const& b)
{ {
using beast::hash_append; using beast::hash_append;
hash_append(h, b.in, b.out); hash_append(h, b.in, b.out);
if (b.domain)
hash_append(h, *(b.domain));
} }
Book Book
@@ -79,8 +71,7 @@ reversed(Book const& book);
[[nodiscard]] inline constexpr bool [[nodiscard]] inline constexpr bool
operator==(Book const& lhs, Book const& rhs) operator==(Book const& lhs, Book const& rhs)
{ {
return (lhs.in == rhs.in) && (lhs.out == rhs.out) && return (lhs.in == rhs.in) && (lhs.out == rhs.out);
(lhs.domain == rhs.domain);
} }
/** @} */ /** @} */
@@ -91,18 +82,7 @@ operator<=>(Book const& lhs, Book const& rhs)
{ {
if (auto const c{lhs.in <=> rhs.in}; c != 0) if (auto const c{lhs.in <=> rhs.in}; c != 0)
return c; return c;
if (auto const c{lhs.out <=> rhs.out}; c != 0) return lhs.out <=> rhs.out;
return c;
// Manually compare optionals
if (lhs.domain && rhs.domain)
return *lhs.domain <=> *rhs.domain; // Compare values if both exist
if (!lhs.domain && rhs.domain)
return std::weak_ordering::less; // Empty is considered less
if (lhs.domain && !rhs.domain)
return std::weak_ordering::greater; // Non-empty is greater
return std::weak_ordering::equivalent; // Both are empty
} }
/** @} */ /** @} */
@@ -124,7 +104,7 @@ private:
boost::base_from_member<std::hash<ripple::AccountID>, 1>; boost::base_from_member<std::hash<ripple::AccountID>, 1>;
public: public:
hash() = default; explicit hash() = default;
using value_type = std::size_t; using value_type = std::size_t;
using argument_type = ripple::Issue; using argument_type = ripple::Issue;
@@ -146,14 +126,12 @@ template <>
struct hash<ripple::Book> struct hash<ripple::Book>
{ {
private: private:
using issue_hasher = std::hash<ripple::Issue>; using hasher = std::hash<ripple::Issue>;
using uint256_hasher = ripple::uint256::hasher;
issue_hasher m_issue_hasher; hasher m_hasher;
uint256_hasher m_uint256_hasher;
public: public:
hash() = default; explicit hash() = default;
using value_type = std::size_t; using value_type = std::size_t;
using argument_type = ripple::Book; using argument_type = ripple::Book;
@@ -161,12 +139,8 @@ public:
value_type value_type
operator()(argument_type const& value) const operator()(argument_type const& value) const
{ {
value_type result(m_issue_hasher(value.in)); value_type result(m_hasher(value.in));
boost::hash_combine(result, m_issue_hasher(value.out)); boost::hash_combine(result, m_hasher(value.out));
if (value.domain)
boost::hash_combine(result, m_uint256_hasher(*value.domain));
return result; return result;
} }
}; };
@@ -180,7 +154,7 @@ namespace boost {
template <> template <>
struct hash<ripple::Issue> : std::hash<ripple::Issue> struct hash<ripple::Issue> : std::hash<ripple::Issue>
{ {
hash() = default; explicit hash() = default;
using Base = std::hash<ripple::Issue>; using Base = std::hash<ripple::Issue>;
// VFALCO NOTE broken in vs2012 // VFALCO NOTE broken in vs2012
@@ -190,7 +164,7 @@ struct hash<ripple::Issue> : std::hash<ripple::Issue>
template <> template <>
struct hash<ripple::Book> : std::hash<ripple::Book> struct hash<ripple::Book> : std::hash<ripple::Book>
{ {
hash() = default; explicit hash() = default;
using Base = std::hash<ripple::Book>; using Base = std::hash<ripple::Book>;
// VFALCO NOTE broken in vs2012 // VFALCO NOTE broken in vs2012

View File

@@ -120,7 +120,7 @@ enum error_code_i {
rpcSRC_ACT_MALFORMED = 65, rpcSRC_ACT_MALFORMED = 65,
rpcSRC_ACT_MISSING = 66, rpcSRC_ACT_MISSING = 66,
rpcSRC_ACT_NOT_FOUND = 67, rpcSRC_ACT_NOT_FOUND = 67,
rpcDELEGATE_ACT_NOT_FOUND = 68, // unused 68,
rpcSRC_CUR_MALFORMED = 69, rpcSRC_CUR_MALFORMED = 69,
rpcSRC_ISR_MALFORMED = 70, rpcSRC_ISR_MALFORMED = 70,
rpcSTREAM_MALFORMED = 71, rpcSTREAM_MALFORMED = 71,
@@ -154,10 +154,7 @@ enum error_code_i {
// Simulate // Simulate
rpcTX_SIGNED = 96, rpcTX_SIGNED = 96,
// Pathfinding rpcLAST = rpcTX_SIGNED // rpcLAST should always equal the last code.
rpcDOMAIN_MALFORMED = 97,
rpcLAST = rpcDOMAIN_MALFORMED // rpcLAST should always equal the last code.
}; };
/** Codes returned in the `warnings` array of certain RPC commands. /** Codes returned in the `warnings` array of certain RPC commands.
@@ -169,8 +166,6 @@ enum warning_code_i {
warnRPC_AMENDMENT_BLOCKED = 1002, warnRPC_AMENDMENT_BLOCKED = 1002,
warnRPC_EXPIRED_VALIDATOR_LIST = 1003, warnRPC_EXPIRED_VALIDATOR_LIST = 1003,
// unused = 1004 // unused = 1004
warnRPC_FIELDS_DEPRECATED = 2004, // rippled needs to maintain
// compatibility with Clio on this code.
}; };
//------------------------------------------------------------------------------ //------------------------------------------------------------------------------

View File

@@ -24,6 +24,7 @@
#include <boost/container/flat_map.hpp> #include <boost/container/flat_map.hpp>
#include <array>
#include <bitset> #include <bitset>
#include <map> #include <map>
#include <optional> #include <optional>
@@ -53,18 +54,6 @@
* then change the macro parameter in features.macro to * then change the macro parameter in features.macro to
* `VoteBehavior::DefaultYes`. The communication process is beyond * `VoteBehavior::DefaultYes`. The communication process is beyond
* the scope of these instructions. * the scope of these instructions.
* 5) If a supported feature (`Supported::yes`) was _ever_ in a released
* version, it can never be changed back to `Supported::no`, because
* it _may_ still become enabled at any time. This would cause newer
* versions of `rippled` to become amendment blocked.
* Instead, to prevent newer versions from voting on the feature, use
* `VoteBehavior::Obsolete`. Obsolete features can not be voted for
* by any versions of `rippled` built with that setting, but will still
* work correctly if they get enabled. If a feature remains obsolete
* for long enough that _all_ clients that could vote for it are
* amendment blocked, the feature can be removed from the code
* as if it was unsupported.
* *
* *
* When a feature has been enabled for several years, the conditional code * When a feature has been enabled for several years, the conditional code

View File

@@ -27,9 +27,14 @@
#include <boost/multiprecision/cpp_int.hpp> #include <boost/multiprecision/cpp_int.hpp>
#include <boost/operators.hpp> #include <boost/operators.hpp>
#include <cmath>
#include <ios>
#include <iosfwd> #include <iosfwd>
#include <limits> #include <limits>
#include <optional> #include <optional>
#include <sstream>
#include <string>
#include <utility>
namespace ripple { namespace ripple {
@@ -331,7 +336,7 @@ public:
// Output Fees as just their numeric value. // Output Fees as just their numeric value.
template <class Char, class Traits, class UnitTag, class T> template <class Char, class Traits, class UnitTag, class T>
std::basic_ostream<Char, Traits>& std::basic_ostream<Char, Traits>&
operator<<(std::basic_ostream<Char, Traits>& os, TaggedFee<UnitTag, T> const& q) operator<<(std::basic_ostream<Char, Traits>& os, const TaggedFee<UnitTag, T>& q)
{ {
return os << q.value(); return os << q.value();
} }

View File

@@ -88,9 +88,6 @@ enum class HashPrefix : std::uint32_t {
/** Credentials signature */ /** Credentials signature */
credential = detail::make_hash_prefix('C', 'R', 'D'), credential = detail::make_hash_prefix('C', 'R', 'D'),
/** Batch */
batch = detail::make_hash_prefix('B', 'C', 'H'),
}; };
template <class Hasher> template <class Hasher>

View File

@@ -28,6 +28,7 @@
#include <cstdint> #include <cstdint>
#include <string> #include <string>
#include <utility>
namespace ripple { namespace ripple {
@@ -98,12 +99,6 @@ public:
static IOUAmount static IOUAmount
minPositiveAmount(); minPositiveAmount();
friend std::ostream&
operator<<(std::ostream& os, IOUAmount const& x)
{
return os << to_string(x);
}
}; };
inline IOUAmount::IOUAmount(beast::Zero) inline IOUAmount::IOUAmount(beast::Zero)

View File

@@ -32,7 +32,6 @@
#include <xrpl/protocol/jss.h> #include <xrpl/protocol/jss.h>
#include <cstdint> #include <cstdint>
#include <set>
namespace ripple { namespace ripple {
@@ -280,10 +279,6 @@ amm(Asset const& issue1, Asset const& issue2) noexcept;
Keylet Keylet
amm(uint256 const& amm) noexcept; amm(uint256 const& amm) noexcept;
/** A keylet for Delegate object */
Keylet
delegate(AccountID const& account, AccountID const& authorizedAccount) noexcept;
Keylet Keylet
bridge(STXChainBridge const& bridge, STXChainBridge::ChainType chainType); bridge(STXChainBridge const& bridge, STXChainBridge::ChainType chainType);
@@ -335,15 +330,6 @@ mptoken(uint256 const& mptokenKey)
Keylet Keylet
mptoken(uint256 const& issuanceKey, AccountID const& holder) noexcept; mptoken(uint256 const& issuanceKey, AccountID const& holder) noexcept;
Keylet
vault(AccountID const& owner, std::uint32_t seq) noexcept;
inline Keylet
vault(uint256 const& vaultKey)
{
return {ltVAULT, vaultKey};
}
Keylet Keylet
permissionedDomain(AccountID const& account, std::uint32_t seq) noexcept; permissionedDomain(AccountID const& account, std::uint32_t seq) noexcept;

View File

@@ -24,6 +24,9 @@
#include <xrpl/json/json_value.h> #include <xrpl/json/json_value.h>
#include <xrpl/protocol/UintTypes.h> #include <xrpl/protocol/UintTypes.h>
#include <functional>
#include <type_traits>
namespace ripple { namespace ripple {
/** A currency issued by an account. /** A currency issued by an account.

View File

@@ -132,7 +132,7 @@ enum LedgerSpecificFlags {
lsfNoFreeze = 0x00200000, // True, cannot freeze ripple states lsfNoFreeze = 0x00200000, // True, cannot freeze ripple states
lsfGlobalFreeze = 0x00400000, // True, all assets frozen lsfGlobalFreeze = 0x00400000, // True, all assets frozen
lsfDefaultRipple = lsfDefaultRipple =
0x00800000, // True, incoming trust lines allow rippling by default 0x00800000, // True, trust lines allow rippling by default
lsfDepositAuth = 0x01000000, // True, all deposits require authorization lsfDepositAuth = 0x01000000, // True, all deposits require authorization
/* // reserved for Hooks amendment /* // reserved for Hooks amendment
lsfTshCollect = 0x02000000, // True, allow TSH collect-calls to acc hooks lsfTshCollect = 0x02000000, // True, allow TSH collect-calls to acc hooks
@@ -145,15 +145,13 @@ enum LedgerSpecificFlags {
0x10000000, // True, reject new paychans 0x10000000, // True, reject new paychans
lsfDisallowIncomingTrustline = lsfDisallowIncomingTrustline =
0x20000000, // True, reject new trustlines (only if no issued assets) 0x20000000, // True, reject new trustlines (only if no issued assets)
lsfAllowTrustLineLocking = // 0x40000000 is available
0x40000000, // True, enable trustline locking
lsfAllowTrustLineClawback = lsfAllowTrustLineClawback =
0x80000000, // True, enable clawback 0x80000000, // True, enable clawback
// ltOFFER // ltOFFER
lsfPassive = 0x00010000, lsfPassive = 0x00010000,
lsfSell = 0x00020000, // True, offer was placed as a sell. lsfSell = 0x00020000, // True, offer was placed as a sell.
lsfHybrid = 0x00040000, // True, offer is hybrid.
// ltRIPPLE_STATE // ltRIPPLE_STATE
lsfLowReserve = 0x00010000, // True, if entry counts toward reserve. lsfLowReserve = 0x00010000, // True, if entry counts toward reserve.
@@ -193,9 +191,6 @@ enum LedgerSpecificFlags {
// ltCREDENTIAL // ltCREDENTIAL
lsfAccepted = 0x00010000, lsfAccepted = 0x00010000,
// ltVAULT
lsfVaultPrivate = 0x00010000,
}; };
//------------------------------------------------------------------------------ //------------------------------------------------------------------------------

View File

@@ -24,12 +24,15 @@
#include <xrpl/basics/contract.h> #include <xrpl/basics/contract.h>
#include <xrpl/basics/safe_cast.h> #include <xrpl/basics/safe_cast.h>
#include <xrpl/beast/utility/Zero.h> #include <xrpl/beast/utility/Zero.h>
#include <xrpl/json/json_value.h>
#include <boost/multiprecision/cpp_int.hpp> #include <boost/multiprecision/cpp_int.hpp>
#include <boost/operators.hpp> #include <boost/operators.hpp>
#include <cstdint> #include <cstdint>
#include <optional>
#include <string> #include <string>
#include <type_traits>
namespace ripple { namespace ripple {

View File

@@ -42,11 +42,8 @@ public:
AccountID const& AccountID const&
getIssuer() const; getIssuer() const;
constexpr MPTID const& MPTID const&
getMptID() const getMptID() const;
{
return mptID_;
}
std::string std::string
getText() const; getText() const;

View File

@@ -28,6 +28,7 @@
#include <concepts> #include <concepts>
#include <cstdlib> #include <cstdlib>
#include <functional> #include <functional>
#include <limits>
#include <type_traits> #include <type_traits>
#include <utility> #include <utility>
@@ -79,7 +80,7 @@ struct MultiApiJson
} }
void void
set(char const* key, auto const& v) set(const char* key, auto const& v)
requires std::constructible_from<Json::Value, decltype(v)> requires std::constructible_from<Json::Value, decltype(v)>
{ {
for (auto& a : this->val) for (auto& a : this->val)
@@ -90,7 +91,7 @@ struct MultiApiJson
enum IsMemberResult : int { none = 0, some, all }; enum IsMemberResult : int { none = 0, some, all };
[[nodiscard]] IsMemberResult [[nodiscard]] IsMemberResult
isMember(char const* key) const isMember(const char* key) const
{ {
int count = 0; int count = 0;
for (auto& a : this->val) for (auto& a : this->val)

View File

@@ -28,8 +28,6 @@
namespace ripple { namespace ripple {
namespace RPC {
/** /**
Adds common synthetic fields to transaction-related JSON responses Adds common synthetic fields to transaction-related JSON responses
@@ -42,7 +40,6 @@ insertNFTSyntheticInJson(
TxMeta const&); TxMeta const&);
/** @} */ /** @} */
} // namespace RPC
} // namespace ripple } // namespace ripple
#endif #endif

View File

@@ -1,96 +0,0 @@
//------------------------------------------------------------------------------
/*
This file is part of rippled: https://github.com/ripple/rippled
Copyright (c) 2025 Ripple Labs Inc.
Permission to use, copy, modify, and/or distribute this software for any
purpose with or without fee is hereby granted, provided that the above
copyright notice and this permission notice appear in all copies.
THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
ANY SPECIAL , DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
*/
//==============================================================================
#ifndef RIPPLE_PROTOCOL_PERMISSION_H_INCLUDED
#define RIPPLE_PROTOCOL_PERMISSION_H_INCLUDED
#include <xrpl/protocol/TxFormats.h>
#include <optional>
#include <string>
#include <unordered_map>
namespace ripple {
/**
* We have both transaction type permissions and granular type permissions.
* Since we will reuse the TransactionFormats to parse the Transaction
* Permissions, only the GranularPermissionType is defined here. To prevent
* conflicts with TxType, the GranularPermissionType is always set to a value
* greater than the maximum value of uint16.
*/
enum GranularPermissionType : std::uint32_t {
#pragma push_macro("PERMISSION")
#undef PERMISSION
#define PERMISSION(type, txType, value) type = value,
#include <xrpl/protocol/detail/permissions.macro>
#undef PERMISSION
#pragma pop_macro("PERMISSION")
};
enum Delegation { delegatable, notDelegatable };
class Permission
{
private:
Permission();
std::unordered_map<std::uint16_t, Delegation> delegatableTx_;
std::unordered_map<std::string, GranularPermissionType>
granularPermissionMap_;
std::unordered_map<GranularPermissionType, std::string> granularNameMap_;
std::unordered_map<GranularPermissionType, TxType> granularTxTypeMap_;
public:
static Permission const&
getInstance();
Permission(Permission const&) = delete;
Permission&
operator=(Permission const&) = delete;
std::optional<std::uint32_t>
getGranularValue(std::string const& name) const;
std::optional<std::string>
getGranularName(GranularPermissionType const& value) const;
std::optional<TxType>
getGranularTxType(GranularPermissionType const& gpType) const;
bool
isDelegatable(std::uint32_t const& permissionValue) const;
// for tx level permission, permission value is equal to tx type plus one
uint32_t
txToPermissionType(TxType const& type) const;
// tx type value is permission value minus one
TxType
permissionToTxType(uint32_t const& value) const;
};
} // namespace ripple
#endif

View File

@@ -116,16 +116,6 @@ std::size_t constexpr maxMPTokenMetadataLength = 1024;
/** The maximum amount of MPTokenIssuance */ /** The maximum amount of MPTokenIssuance */
std::uint64_t constexpr maxMPTokenAmount = 0x7FFF'FFFF'FFFF'FFFFull; std::uint64_t constexpr maxMPTokenAmount = 0x7FFF'FFFF'FFFF'FFFFull;
/** The maximum length of Data payload */
std::size_t constexpr maxDataPayloadLength = 256;
/** Vault withdrawal policies */
std::uint8_t constexpr vaultStrategyFirstComeFirstServe = 1;
/** Maximum recursion depth for vault shares being put as an asset inside
* another vault; counted from 0 */
std::uint8_t constexpr maxAssetCheckDepth = 5;
/** A ledger index. */ /** A ledger index. */
using LedgerIndex = std::uint32_t; using LedgerIndex = std::uint32_t;
@@ -165,13 +155,6 @@ std::size_t constexpr maxPriceScale = 20;
*/ */
std::size_t constexpr maxTrim = 25; std::size_t constexpr maxTrim = 25;
/** The maximum number of delegate permissions an account can grant
*/
std::size_t constexpr permissionMaxSize = 10;
/** The maximum number of transactions that can be in a batch. */
std::size_t constexpr maxBatchTxCount = 8;
} // namespace ripple } // namespace ripple
#endif #endif

View File

@@ -32,6 +32,7 @@
#include <cstring> #include <cstring>
#include <optional> #include <optional>
#include <ostream> #include <ostream>
#include <utility>
namespace ripple { namespace ripple {

View File

@@ -113,8 +113,8 @@ public:
// have lower unsigned integer representations. // have lower unsigned integer representations.
using value_type = std::uint64_t; using value_type = std::uint64_t;
static int const minTickSize = 3; static const int minTickSize = 3;
static int const maxTickSize = 16; static const int maxTickSize = 16;
private: private:
// This has the same representation as STAmount, see the comment on the // This has the same representation as STAmount, see the comment on the

View File

@@ -28,9 +28,6 @@
namespace ripple { namespace ripple {
bool
isFeatureEnabled(uint256 const& feature);
class DigestAwareReadView; class DigestAwareReadView;
/** Rules controlling protocol behavior. */ /** Rules controlling protocol behavior. */

View File

@@ -25,6 +25,7 @@
#include <cstdint> #include <cstdint>
#include <map> #include <map>
#include <utility>
namespace ripple { namespace ripple {
@@ -181,22 +182,22 @@ public:
private_access_tag_t, private_access_tag_t,
SerializedTypeID tid, SerializedTypeID tid,
int fv, int fv,
char const* fn, const char* fn,
int meta = sMD_Default, int meta = sMD_Default,
IsSigning signing = IsSigning::yes); IsSigning signing = IsSigning::yes);
explicit SField(private_access_tag_t, int fc); explicit SField(private_access_tag_t, int fc);
static SField const& static const SField&
getField(int fieldCode); getField(int fieldCode);
static SField const& static const SField&
getField(std::string const& fieldName); getField(std::string const& fieldName);
static SField const& static const SField&
getField(int type, int value) getField(int type, int value)
{ {
return getField(field_code(type, value)); return getField(field_code(type, value));
} }
static SField const& static const SField&
getField(SerializedTypeID type, int value) getField(SerializedTypeID type, int value)
{ {
return getField(field_code(type, value)); return getField(field_code(type, value));
@@ -283,19 +284,19 @@ public:
} }
bool bool
operator==(SField const& f) const operator==(const SField& f) const
{ {
return fieldCode == f.fieldCode; return fieldCode == f.fieldCode;
} }
bool bool
operator!=(SField const& f) const operator!=(const SField& f) const
{ {
return fieldCode != f.fieldCode; return fieldCode != f.fieldCode;
} }
static int static int
compare(SField const& f1, SField const& f2); compare(const SField& f1, const SField& f2);
static std::map<int, SField const*> const& static std::map<int, SField const*> const&
getKnownCodeToField() getKnownCodeToField()

View File

@@ -25,6 +25,7 @@
#include <functional> #include <functional>
#include <initializer_list> #include <initializer_list>
#include <memory>
#include <stdexcept> #include <stdexcept>
namespace ripple { namespace ripple {

View File

@@ -58,7 +58,7 @@ public:
add(Serializer& s) const override; add(Serializer& s) const override;
bool bool
isEquivalent(STBase const& t) const override; isEquivalent(const STBase& t) const override;
bool bool
isDefault() const override; isDefault() const override;

Some files were not shown because too many files have changed in this diff Show More