40 Commits
8.0.4 ... 8.0.7

Author SHA1 Message Date
Andrew Johnson
e069c699e9 Final commit for 8.0.7 2025-12-15 11:44:53 -06:00
Andrew Johnson
8963b2dba1 Add release notes for changes since 8.0.6
- Jeremy Lorelli
- Andrew Johnson
- Dirk Zimoch
- Chris Johns
- Michael Davidsaver
2025-12-15 11:37:47 -06:00
Michael Davidsaver
9ec9a526f5 revise Timer phase reset 2025-12-05 17:01:00 -08:00
Chris Johns
b4114589ff Skip any missed timer events updating the timer to now
This stops a timer calling the callback for every missed event if the
time jumps forward when corrected or moved.
2025-12-05 17:01:00 -08:00
6689c9ce1f Allow testing deprecated functions without causing compiler warnings 2025-12-03 16:47:55 -08:00
Andrew Johnson
0c1773f25d Clang warnings: sprintf() => epicsSnprintf() 2025-12-01 18:20:27 -08:00
Andrew Johnson
d0ff9a9592 CI: Final GHA config adjustments
Don't change the MSC C++ standard when building submodules!
2025-12-01 17:39:24 -06:00
JJL772
bf36070860 Allow Timer to be cancelled during callback execution
Useful for when e.g. a periodic timer needs to cancel itself
2025-11-19 08:49:41 -08:00
Andrew Johnson
5552773e5e CI: Rename and adjust jobs (#102)
* Update Appveyor and GHA CI build configurations to more closely match Base CI.

* Other CI script clean-up
2025-11-10 12:29:19 -06:00
Andrew Johnson
b3a1077270 CI: Update Ubuntu 20.04 to 22.04 2025-05-05 12:26:24 -05:00
Ralph Lange
1c5f75bcd6 Merge pull request #97 from ralphlange/fix-ci
ci: consistent AppVeyor job config for pvData/pvAccess
2024-12-25 09:09:33 +01:00
Ralph Lange
2455039594 ci: consistent AppVeyor job config for pvData/pvAccess 2024-12-24 17:19:59 +01:00
Ralph Lange
f47676c225 Merge pull request #96 from ralphlange/fix-ci
Fix CI issues
2024-12-19 14:42:15 +01:00
Ralph Lange
0881e0ed86 ci: update appveyor.yml from base 2024-12-19 08:48:41 +01:00
Ralph Lange
e457b60b30 ci: Update GHA workflow from base
- Run Fedora in containers
- Add Linux cross builds
2024-12-18 21:32:11 +01:00
Ralph Lange
a6746f8161 GHA: Update actions/upload-artifact to v4 2024-12-16 12:08:55 +01:00
Ralph Lange
144f0228cc ci: update ci-scripts to v3.4.1 2023-12-15 09:40:45 +01:00
Andrew Johnson
7300e6b0bd Set next development version 2023-12-13 14:52:07 -06:00
Andrew Johnson
0ef8a36172 Set version numbers for release 2023-12-13 14:46:12 -06:00
Andrew Johnson
c0be043aaf Replease UNRELEASED 2023-12-13 14:43:07 -06:00
Ralph Lange
dd74289eaf Silence warning about uninitialized local variable
found by static code analysis (cppcheck @ sonarqube)
(that doesn't realize ">>=" calls an overloaded operator)
2023-11-01 09:41:07 -05:00
thomasms
3da69257a0 Remove duplicate doxygen comment - see issue #75 2023-11-01 09:39:33 -05:00
Michael Davidsaver
13e4e577bb gha update 2023-10-22 16:24:15 -07:00
Michael Davidsaver
5387face45 rename print.cpp -> jprint.cpp
In GHA builder somehow print.cpp becomes PRINT.obj
instead of print.obj for mkmf.pl, which later fails
when print.obj is missing.  (apparently windows
filesystems are now case sensitive...)
2023-10-22 16:24:15 -07:00
JJL772
eac2a8e70f Fix use-after-destroy in epicsRefSnapshopCurrent 2023-08-06 21:30:32 -07:00
JJL772
04fcb7e38f Don't return local copy of std::string in AnyScalar::bufferUnsafe 2023-08-06 21:30:32 -07:00
Andrew Johnson
45018a2163 Generate JSON5 when available
Fixes lp: #2029482 / GitHub #92
2023-08-06 21:28:01 -07:00
Simon Rose
b7ad4478a4 Update debugPtr to work with EPICS base 7.0.7
There are at least two changes to EPICS base since the addition of
debugPtr:
* In pvAccess/**/dbdToPv.cpp, a write to an ostream was added (also in
  pvData/**/testSerialization.cpp) which does not resolve correctly when
  the operator<< overload is in the global namespace.
* In pvAccess/**/caChannel.cpp, weak_ptr->expired() was added

The interface to deal with each of these has been added.
2023-05-29 17:09:29 -07:00
Michael Davidsaver
c16f19c80e Flip #if logic for unaligned access
Assume only x86 can correctly/efficiently handle unaligned access.
2023-05-24 21:49:38 -07:00
Michael Davidsaver
87018882d1 ARM/Linux can fault on unaligned access
Sometimes SIGBUS results from unaligned access.
2023-05-24 20:44:32 -07:00
2547514abb fix for use-after-free warning 2023-02-28 09:04:58 -08:00
Michael Davidsaver
9447eacbd2 gha update 2022-11-26 11:15:37 -08:00
Michael Davidsaver
0b424a71ec isprint() wants value in range [-1, 255]
The MSVC impl. assert()s this
2022-11-26 10:52:03 -08:00
Andrew Johnson
45671faaea Set next development version 2022-09-07 10:51:29 -05:00
Andrew Johnson
016d1154fc Set module version number for release 2022-09-07 10:17:07 -05:00
Michael Davidsaver
f3911d5831 add 3.16 build 2022-01-27 09:44:54 -08:00
Michael Davidsaver
93e90c5a04 fix 3.16 2022-01-27 09:27:19 -08:00
Michael Davidsaver
8039c75b3e .ci: update 2022-01-27 07:51:17 -08:00
Michael Davidsaver
a647c8b174 printJSON() use yajl_gen 2022-01-19 10:27:09 -08:00
Michael Davidsaver
d3b4976ea2 Set next development version 2021-02-25 09:36:05 -08:00
29 changed files with 686 additions and 394 deletions

View File

@@ -1,33 +1,30 @@
# .appveyor.yml for use with EPICS Base ci-scripts # .appveyor.yml for use with EPICS Base ci-scripts
# (see: https://github.com/epics-base/ci-scripts) # (see: https://github.com/epics-base/ci-scripts)
# This is YAML - indentation levels are crucial
#---------------------------------#
# build cache #
#---------------------------------#
# The AppVeyor cache allowance is way too small (1GB per account across all
# projects, branches and jobs) to be used for the dependency builds.
cache: cache:
- C:\Users\appveyor\.tools - C:\Users\appveyor\.tools
#---------------------------------#
# additional packages #
#---------------------------------#
install:
# for the sequencer
- cinst re2c
- cmd: git submodule update --init --recursive
#---------------------------------# #---------------------------------#
# repository cloning # # repository cloning #
#---------------------------------# #---------------------------------#
init: init:
# Set autocrlf to make batch files work # Set autocrlf to make batch files work
- git config --global core.autocrlf true - cmd: git config --global core.autocrlf true
clone_depth: 50 clone_depth: 5
# Skipping commits affecting only specific files #---------------------------------#
skip_commits: # build matrix configuration #
files: #---------------------------------#
- 'documentation/*'
- '**/*.md'
# Build Configurations: dll/static, regular/debug # Build Configurations: dll/static, regular/debug
configuration: configuration:
@@ -40,47 +37,65 @@ configuration:
environment: environment:
# common / default variables for all jobs # common / default variables for all jobs
SETUP_PATH: .ci-local SETUP_PATH: .ci-local
EPICS_TEST_IMPRECISE_TIMING: YES
BASE: 7.0
matrix: matrix:
- APPVEYOR_BUILD_WORKER_IMAGE: Visual Studio 2019 - CMP: vs2019
CMP: vs2019
BASE: 7.0
- APPVEYOR_BUILD_WORKER_IMAGE: Visual Studio 2015
CMP: gcc
BASE: 7.0
- APPVEYOR_BUILD_WORKER_IMAGE: Visual Studio 2017
CMP: vs2017
BASE: 7.0
- APPVEYOR_BUILD_WORKER_IMAGE: Visual Studio 2019
CMP: vs2019
BASE: 3.15 BASE: 3.15
APPVEYOR_BUILD_WORKER_IMAGE: Visual Studio 2019
- CMP: vs2019
APPVEYOR_BUILD_WORKER_IMAGE: Visual Studio 2019
- CMP: vs2017
APPVEYOR_BUILD_WORKER_IMAGE: Visual Studio 2017
- CMP: vs2015
- CMP: gcc
APPVEYOR_BUILD_WORKER_IMAGE: Visual Studio 2019
# TODO: static linking w/ readline isn't working. Bypass auto-detect
COMMANDLINE_LIBRARY: EPICS
# Platform: processor architecture # Platform: processor architecture
platform: platform: x64
- x64
# Matrix configuration: exclude sets of jobs
matrix:
exclude:
# MinGW debug builds use the same libraries, unlike VS
- configuration: dynamic-debug
CMP: gcc
- configuration: static-debug
CMP: gcc
#---------------------------------# #---------------------------------#
# building & testing # # building & testing #
#---------------------------------# #---------------------------------#
build_script: install:
- cmd: git submodule update --init --recursive
- cmd: pip install git+https://github.com/mdavidsaver/ci-core-dumper#egg=ci-core-dumper
- cmd: python .ci/cue.py prepare - cmd: python .ci/cue.py prepare
build_script:
- cmd: python .ci/cue.py build - cmd: python .ci/cue.py build
test_script: test_script:
- cmd: python .ci/cue.py test - cmd: python -m ci_core_dumper install
- cmd: python .ci/cue.py -T 20M test
on_finish: on_finish:
- ps: Get-ChildItem *.tap -Recurse -Force | % { Push-AppveyorArtifact $_.FullName -FileName $_.Name } - ps: Get-ChildItem *.tap -Recurse -Force | % { Push-AppveyorArtifact $_.FullName -FileName $_.Name }
- cmd: python .ci/cue.py build test-results -s - cmd: python .ci/cue.py -T 5M test-results
on_failure:
- cmd: python -m ci_core_dumper report
#---------------------------------# #---------------------------------#
# debugging # # debugging #
#---------------------------------# #---------------------------------#
## if you want to connect by remote desktop to a failed build, uncomment these lines ## To connect by remote desktop to a failed build, uncomment the lines below.
## note that you will need to connect within the usual build timeout limit (60 minutes) ## You must connect within the usual build timeout limit (60 minutes),
## so you may want to adjust the build matrix above to just build the one of interest ## so adjust the build matrix above to just build the config of interest.
#on_failure: #on_failure:
# - ps: iex ((new-object net.webclient).DownloadString('https://raw.githubusercontent.com/appveyor/ci/master/scripts/enable-rdp.ps1')) # - ps: iex ((new-object net.webclient).DownloadString('https://raw.githubusercontent.com/appveyor/ci/master/scripts/enable-rdp.ps1'))
@@ -91,4 +106,8 @@ on_finish:
#---------------------------------# #---------------------------------#
notifications: notifications:
- provider: Email
to:
- core-talk@aps.anl.gov
on_build_success: false
- provider: GitHubPullRequest - provider: GitHubPullRequest

2
.ci

Submodule .ci updated: ad8dd4a136...20f8e05393

View File

@@ -3,7 +3,7 @@
# This is YAML - indentation levels are crucial # This is YAML - indentation levels are crucial
# Set the 'name:' properties to values that work for you (pvxs) # Workflow name, shared by all branches
name: pvData name: pvData
@@ -17,137 +17,285 @@ on:
env: env:
SETUP_PATH: .ci-local:.ci SETUP_PATH: .ci-local:.ci
EPICS_TEST_IMPRECISE_TIMING: YES EPICS_TEST_IMPRECISE_TIMING: YES
EPICS_TEST_TIMEOUT: 300 # 5 min
jobs: jobs:
build-base: native:
name: ${{ matrix.base }}/${{ matrix.os }}/${{ matrix.cmp }}/${{ matrix.configuration }}/${{ matrix.wine }}${{ matrix.rtems }}/${{ matrix.extra }} name: ${{ matrix.name }}
runs-on: ${{ matrix.os }} runs-on: ${{ matrix.os }}
# Set environment variables from matrix parameters # Set environment variables from matrix parameters
env: env:
# NB: PVA modules build against both BASE 7.0 and 3.15
BASE: ${{ matrix.base }} BASE: ${{ matrix.base }}
CMP: ${{ matrix.cmp }} CMP: ${{ matrix.cmp }}
BCFG: ${{ matrix.configuration }} BCFG: ${{ matrix.configuration }}
WINE: ${{ matrix.wine }} CI_CROSS_TARGETS: ${{ matrix.cross }}
RTEMS: ${{ matrix.rtems }}
EXTRA: ${{ matrix.extra }} EXTRA: ${{ matrix.extra }}
TEST: ${{ matrix.test }} TEST: ${{ matrix.test }}
strategy: strategy:
fail-fast: false fail-fast: false
matrix: matrix:
# Job names also name artifacts, character limitations apply
include: include:
- os: ubuntu-20.04 - name: "7.0 Ub gcc c++20 Werror"
base: "7.0"
os: ubuntu-latest
cmp: gcc cmp: gcc
configuration: default configuration: default
base: "7.0" # Turn all warnings into errors,
wine: "64" # except for those we could not fix (yet).
# Remove respective -Wno-error=... flag once it is fixed.
extra: "CMD_CXXFLAGS=-std=c++20
CMD_CPPFLAGS='-fdiagnostics-color
-fstack-protector-strong
-Wformat
-Werror
-Werror=format-security
-Wno-error=deprecated-declarations
-Wno-error=stringop-truncation
-Wno-error=restrict
-Wno-error=sizeof-pointer-memaccess
-Wno-error=nonnull
-Wno-error=dangling-pointer
-Wno-error=format-overflow
-Wno-error=stringop-overread
-U_FORTIFY_SOURCE -D_FORTIFY_SOURCE=3'
CMD_LDFLAGS=-Wl,-z,relro"
- os: ubuntu-20.04 - name: "7.0 Ub gcc C++11, static"
base: "7.0"
os: ubuntu-latest
cmp: gcc cmp: gcc
configuration: static configuration: static
base: "7.0" extra: "CMD_CXXFLAGS=-std=c++11"
wine: "64"
- os: ubuntu-20.04 - name: "7.0 Ub gcc u-char"
base: "7.0"
os: ubuntu-latest
cmp: gcc cmp: gcc
configuration: static
extra: "CMD_CFLAGS=-funsigned-char CMD_CXXFLAGS=-funsigned-char"
- name: "7.0 Ub clang"
base: "7.0"
os: ubuntu-latest
cmp: clang
configuration: default configuration: default
- name: "7.0 Ub clang C++11"
base: "7.0"
os: ubuntu-latest
cmp: clang
configuration: default
extra: "CMD_CXXFLAGS=-std=c++11"
- name: "7.0 MacOS clang"
base: "7.0"
os: macos-latest
cmp: clang
configuration: default
# Cross builds
- name: "3.15 Ub-22 gcc + MinGW"
base: "3.15" base: "3.15"
wine: "64" os: ubuntu-22.04
cmp: gcc
configuration: default
cross: "windows-x64-mingw"
- os: ubuntu-20.04 - name: "7.0 Ub gcc + linux-aarch64"
base: "7.0"
os: ubuntu-latest
cmp: gcc
configuration: default
cross: "linux-aarch64"
- name: "7.0 Ub gcc + linux-arm gnueabi"
base: "7.0"
os: ubuntu-latest
cmp: gcc
configuration: default
cross: "linux-arm@arm-linux-gnueabi"
- name: "7.0 Ub gcc + linux-arm gnueabihf"
base: "7.0"
os: ubuntu-latest
cmp: gcc
configuration: default
cross: "linux-arm@arm-linux-gnueabihf"
- name: "7.0 Ub gcc + MinGW"
base: "7.0"
os: ubuntu-latest
cmp: gcc
configuration: default
cross: "windows-x64-mingw"
- name: "7.0 Ub gcc + MinGW, static"
base: "7.0"
os: ubuntu-latest
cmp: gcc cmp: gcc
configuration: static configuration: static
base: "7.0" cross: "windows-x64-mingw"
extra: "CMD_CXXFLAGS=-std=c++11"
- os: ubuntu-16.04 - name: "7.0 Ub-22 gcc + RT-4.9 pc386"
cmp: clang
configuration: default
base: "7.0" base: "7.0"
os: ubuntu-22.04
- os: ubuntu-20.04
cmp: clang
configuration: default
base: "7.0"
extra: "CMD_CXXFLAGS=-std=c++11"
- os: ubuntu-20.04
cmp: gcc cmp: gcc
configuration: default configuration: default
base: "7.0" cross: "RTEMS-pc386-qemu@4.9"
rtems: "4.10"
- os: ubuntu-20.04 - name: "7.0 Ub-22 gcc + RT-4.10 pc386"
base: "7.0"
os: ubuntu-22.04
cmp: gcc cmp: gcc
configuration: default configuration: default
base: "7.0" cross: "RTEMS-pc386-qemu@4.10"
rtems: "4.9" test: NO
- os: ubuntu-16.04 - name: "7.0 Ub-22 gcc + RT-5.1 pc686"
cmp: gcc-4.8 base: "7.0"
utoolchain: true os: ubuntu-22.04
cmp: gcc
configuration: default configuration: default
base: "7.0" cross: "RTEMS-pc686-qemu@5"
- os: ubuntu-16.04 - name: "7.0 Ub-22 gcc + RT-5.1 beatnik,zynq_a9,uC5282"
cmp: gcc-4.9 base: "7.0"
utoolchain: true os: ubuntu-22.04
cmp: gcc
configuration: default configuration: default
base: "7.0" cross: "RTEMS-beatnik@5:RTEMS-xilinx_zynq_a9_qemu@5:RTEMS-uC5282@5"
test: NO
- os: ubuntu-20.04 # Windows builds
cmp: gcc-8
utoolchain: true - name: "7.0 Win-22 MSC-22"
base: "7.0"
os: windows-2022
cmp: vs2022
configuration: default configuration: default
base: "7.0"
- os: ubuntu-20.04 - name: "7.0 Win-22 MSC-22 static"
cmp: clang
configuration: default
base: "7.0" base: "7.0"
os: windows-2022
- os: macos-latest cmp: vs2022
cmp: clang
configuration: default
base: "7.0"
- os: windows-2019
cmp: vs2019
configuration: default
base: "7.0"
- os: windows-2019
cmp: vs2019
configuration: static configuration: static
- name: "7.0 Win-22 MSC-22 debug"
base: "7.0" base: "7.0"
os: windows-2022
cmp: vs2022
configuration: debug
extra: "CMD_CXXFLAGS=-analyze"
- name: "7.0 Win-22 MinGW"
base: "7.0"
os: windows-2022
cmp: gcc
configuration: default
steps: steps:
- uses: actions/checkout@v2 - uses: actions/checkout@v4
with: with:
submodules: true submodules: true
- name: Cache Dependencies - name: Automatic core dumper analysis
uses: actions/cache@v2
with:
path: ~/.cache
key: ${{ matrix.base }}/${{ matrix.os }}/${{ matrix.cmp }}/${{ matrix.configuration }}/${{ matrix.wine }}${{ matrix.rtems }}/${{ matrix.extra }}
- name: Automatic core dump analysis
uses: mdavidsaver/ci-core-dumper@master uses: mdavidsaver/ci-core-dumper@master
- name: "apt-get install" - name: "apt-get install"
run: | run: |
sudo apt-get update sudo apt-get update
sudo apt-get -y install qemu-system-x86 g++-mingw-w64-x86-64 gdb sudo apt-get -y install qemu-system-x86 g++-mingw-w64-x86-64 gdb
if: runner.os == 'Linux' if: runner.os == 'Linux'
- name: "apt-get install ${{ matrix.cmp }}"
run: |
sudo apt-get -y install software-properties-common
sudo add-apt-repository -y ppa:ubuntu-toolchain-r/test
sudo apt-get update
sudo apt-get -y install ${{ matrix.cmp }}
if: matrix.utoolchain
- name: Prepare and compile dependencies - name: Prepare and compile dependencies
run: python .ci/cue.py prepare run: python .ci/cue.py prepare
- name: Build main module - name: Build main module
run: python .ci/cue.py build run: python .ci/cue.py build
- name: Run main module tests - name: Run main module tests
run: python .ci/cue.py test run: python .ci/cue.py -T 60M test
- name: Upload tapfiles Artifact
if: ${{ always() }}
uses: actions/upload-artifact@v4
with:
name: tapfiles ${{ matrix.name }}
path: '**/O.*/*.tap'
if-no-files-found: ignore
- name: Collect and show test results - name: Collect and show test results
run: python .ci/cue.py test-results if: ${{ always() }}
run: python .ci/cue.py -T 5M test-results
docker:
name: ${{ matrix.name }}
runs-on: ubuntu-latest
container:
image: ${{ matrix.image }}
# Set environment variables from matrix parameters
env:
BASE: ${{ matrix.base }}
CMP: ${{ matrix.cmp }}
BCFG: ${{ matrix.configuration }}
EXTRA: ${{ matrix.extra }}
TEST: ${{ matrix.test }}
strategy:
fail-fast: false
matrix:
# Job names also name artifacts, character limitations apply
include:
- name: "7.0 CentOS-8 gcc"
base: "7.0"
image: centos:8
cmp: gcc
configuration: default
- name: "7.0 Rocky-9 gcc"
base: "7.0"
image: rockylinux:9
cmp: gcc
configuration: default
- name: "7.0 Fedora-33 gcc"
base: "7.0"
image: fedora:33
cmp: gcc
configuration: default
- name: "7.0 Fedora gcc"
base: "7.0"
image: fedora:latest
cmp: gcc
configuration: default
steps:
- name: "Fix repo URLs on CentOS-8"
# centos:8 is frozen, repos are in the vault
if: matrix.image=='centos:8'
run: |
sed -i -e "s|mirrorlist=|#mirrorlist=|" \
-e "s|#baseurl=http://mirror|baseurl=http://vault|" \
/etc/yum.repos.d/CentOS-Linux-{BaseOS,AppStream,Extras,Plus}.repo
- name: "Redhat setup"
run: |
dnf -y install python3 gdb make perl gcc-c++ glibc-devel readline-devel ncurses-devel perl-devel perl-Test-Simple
git --version || dnf -y install git
python3 --version
- uses: actions/checkout@v4
with:
submodules: true
- name: Automatic core dumper analysis
uses: mdavidsaver/ci-core-dumper@master
- name: Prepare and compile dependencies
run: python3 .ci/cue.py prepare
- name: Build main module
run: python3 .ci/cue.py build
- name: Run main module tests
run: python3 .ci/cue.py -T 20M test
- name: Upload tapfiles Artifact
if: ${{ always() }}
uses: actions/upload-artifact@v4
with:
name: tapfiles ${{ matrix.name }}
path: '**/O.*/*.tap'
if-no-files-found: ignore
- name: Collect and show test results
if: ${{ always() }}
run: python3 .ci/cue.py -T 5M test-results

View File

@@ -38,7 +38,7 @@ PROJECT_NAME = "PVData C++"
# could be handy for archiving the generated documentation or if some version # could be handy for archiving the generated documentation or if some version
# control system is used. # control system is used.
PROJECT_NUMBER = 8.0.4 PROJECT_NUMBER = 8.0.7
# Using the PROJECT_BRIEF tag one can provide an optional one line description # Using the PROJECT_BRIEF tag one can provide an optional one line description
# for a project that appears at the top of each page and should give viewer a # for a project that appears at the top of each page and should give viewer a

View File

@@ -2,7 +2,7 @@
EPICS_PVD_MAJOR_VERSION = 8 EPICS_PVD_MAJOR_VERSION = 8
EPICS_PVD_MINOR_VERSION = 0 EPICS_PVD_MINOR_VERSION = 0
EPICS_PVD_MAINTENANCE_VERSION = 4 EPICS_PVD_MAINTENANCE_VERSION = 7
# Development flag, set to zero for release versions # Development flag, set to zero for release versions

View File

@@ -38,7 +38,7 @@ PROJECT_NAME = "PVData C++"
# could be handy for archiving the generated documentation or if some version # could be handy for archiving the generated documentation or if some version
# control system is used. # control system is used.
PROJECT_NUMBER = 8.0.4 PROJECT_NUMBER = 8.0.7
# Using the PROJECT_BRIEF tag one can provide an optional one line description # Using the PROJECT_BRIEF tag one can provide an optional one line description
# for a project that appears at the top of each page and should give viewer a # for a project that appears at the top of each page and should give viewer a

View File

@@ -2,7 +2,28 @@
@page release_notes Release Notes @page release_notes Release Notes
Release 8.1.0 (Feb 2021) Release 8.0.7 (Dec 2025)
========================
- Compatible changes
- Allow epics::pvData::Timer to be cancelled during callback execution.
- Clang compiler warnings cleaned up.
- Limit periodic timers to one catch-up after missing many events.
Release 8.0.6 (Dec 2023)
========================
- Compatible changes
- Actually enable JSON-5 output in PVStructure::Formatter::JSON when available.
- Fix unaligned access issues for some ARM/Linux targets.
Release 8.0.5 (Sep 2022)
========================
- Compatible changes
- Internal changes to use the YAJL API for generating JSON and JSON-5 output.
Release 8.0.4 (Feb 2021)
======================== ========================
- Incompatible changes - Incompatible changes

View File

@@ -27,7 +27,7 @@ using std::string;
namespace epics { namespace pvData { namespace epics { namespace pvData {
static std::vector<string> split(string commaSeparatedList) { static std::vector<string> split(const string& commaSeparatedList) {
string::size_type numValues = 1; string::size_type numValues = 1;
string::size_type index=0; string::size_type index=0;
while(true) { while(true) {

View File

@@ -15,6 +15,7 @@
#include <sstream> #include <sstream>
#include <epicsString.h> #include <epicsString.h>
#include <epicsStdio.h>
#include <epicsMutex.h> #include <epicsMutex.h>
#include <epicsThread.h> #include <epicsThread.h>
@@ -378,7 +379,8 @@ BoundedScalarArray::BoundedScalarArray(ScalarType elementType, size_t size)
string BoundedScalarArray::getID() const string BoundedScalarArray::getID() const
{ {
char buffer[32]; char buffer[32];
sprintf(buffer, "%s<%zu>", ScalarTypeFunc::name(getElementType()), size); epicsSnprintf(buffer, sizeof(buffer), "%s<%lu>",
ScalarTypeFunc::name(getElementType()), (unsigned long) size);
return string(buffer); return string(buffer);
} }
@@ -403,7 +405,8 @@ FixedScalarArray::FixedScalarArray(ScalarType elementType, size_t size)
string FixedScalarArray::getID() const string FixedScalarArray::getID() const
{ {
char buffer[32]; char buffer[32];
sprintf(buffer, "%s[%zu]", ScalarTypeFunc::name(getElementType()), size); epicsSnprintf(buffer, sizeof(buffer), "%s[%lu]",
ScalarTypeFunc::name(getElementType()), (unsigned long) size);
return string(buffer); return string(buffer);
} }

View File

@@ -404,6 +404,9 @@ std::ostream& operator<<(std::ostream& strm, const PVStructure::Formatter& forma
if(format.xfmt==PVStructure::Formatter::JSON) { if(format.xfmt==PVStructure::Formatter::JSON) {
JSONPrintOptions opts; JSONPrintOptions opts;
opts.multiLine = false; opts.multiLine = false;
#if EPICS_VERSION_INT>=VERSION_INT(7,0,6,1)
opts.json5 = true;
#endif
printJSON(strm, format.xtop, format.xshow ? *format.xshow : BitSet().set(0), opts); printJSON(strm, format.xtop, format.xshow ? *format.xshow : BitSet().set(0), opts);
strm<<'\n'; strm<<'\n';
return strm; return strm;
@@ -497,7 +500,7 @@ std::ostream& operator<<(std::ostream& strm, const escape& Q)
case '\'': next = '\''; break; case '\'': next = '\''; break;
case '\"': next = '\"'; if(Q.S==escape::CSV) quote = '"'; break; case '\"': next = '\"'; if(Q.S==escape::CSV) quote = '"'; break;
default: default:
if(!isprint(C)) { if(!isprint((unsigned char)C)) {
// print three charator escape // print three charator escape
strm<<"\\x"<<hexdigit(C>>4)<<hexdigit(C); strm<<"\\x"<<hexdigit(C>>4)<<hexdigit(C);
} else { } else {
@@ -534,7 +537,7 @@ std::ostream& operator<<(std::ostream& strm, const maybeQuote& q)
esc = true; esc = true;
break; break;
default: default:
if(!isprint(q.s[i])) { if(!isprint((unsigned char)q.s[i])) {
esc = true; esc = true;
} }
break; break;

View File

@@ -7,4 +7,4 @@ INC += pv/json.h
LIBSRCS += parsehelper.cpp LIBSRCS += parsehelper.cpp
LIBSRCS += parseany.cpp LIBSRCS += parseany.cpp
LIBSRCS += parseinto.cpp LIBSRCS += parseinto.cpp
LIBSRCS += print.cpp LIBSRCS += jprint.cpp

305
src/json/jprint.cpp Normal file
View File

@@ -0,0 +1,305 @@
/*
* Copyright information and license terms for this software can be
* found in the file LICENSE that is included with the distribution
*/
#include <vector>
#include <sstream>
#include <errlog.h>
#include <yajl_gen.h>
#define epicsExportSharedSymbols
#include <pv/pvdVersion.h>
#include <pv/pvData.h>
#include <pv/valueBuilder.h>
#include <pv/bitSet.h>
#include "pv/json.h"
namespace pvd = epics::pvData;
namespace {
using namespace pvd::yajl;
void yg(yajl_gen_status sts) {
const char *msg = "<\?\?\?>";
switch(sts) {
case yajl_gen_status_ok:
case yajl_gen_generation_complete:
return;
#define CASE(STS) case STS: msg = #STS; break
CASE(yajl_gen_keys_must_be_strings);
CASE(yajl_gen_in_error_state);
CASE(yajl_gen_no_buf);
CASE(yajl_gen_invalid_number);
CASE(yajl_max_depth_exceeded);
#ifdef EPICS_YAJL_VERSION
CASE(yajl_gen_invalid_string);
#endif
#undef CASE
}
throw std::runtime_error(msg);
}
static
void stream_printer(void * ctx,
const char * str,
size_arg len)
{
std::ostream *strm = (std::ostream*)ctx;
strm->write(str, len);
}
struct args {
yajl_gen handle;
const pvd::JSONPrintOptions& opts;
std::string indent;
args(std::ostream& strm,
const pvd::JSONPrintOptions& opts)
:opts(opts)
,indent(opts.indent, ' ')
{
#ifndef EPICS_YAJL_VERSION
yajl_gen_config conf;
conf.beautify = opts.multiLine;
conf.indentString = indent.c_str();
if(!(handle = yajl_gen_alloc2(stream_printer, NULL, NULL, &strm)))
throw std::bad_alloc();
if(opts.json5) {
static bool warned;
if(!warned) {
warned = true;
errlogPrintf("Warning: Ignoring request to print JSON5. Update Base >= 7.0.6.1");
}
}
#else
if(!(handle = yajl_gen_alloc(NULL)))
throw std::bad_alloc();
if(opts.multiLine) {
yajl_gen_config(handle, yajl_gen_beautify, 1);
yajl_gen_config(handle, yajl_gen_indent_string, indent.c_str());
} else {
yajl_gen_config(handle, yajl_gen_beautify, 0);
}
# if EPICS_VERSION_INT>=VERSION_INT(7,0,6,1)
yajl_gen_config(handle, yajl_gen_json5, (int)opts.json5);
# else
if(opts.json5) {
static bool warned;
if(!warned) {
warned = true;
errlogPrintf("Warning: Ignoring request to print JSON5. Update Base >= 7.0.6.1");
}
}
# endif
yajl_gen_config(handle, yajl_gen_print_callback, stream_printer, &strm);
#endif
}
~args() {
yajl_gen_free(handle);
}
};
void yg_string(yajl_gen handle, const std::string& s) {
yg(yajl_gen_string(handle, (const unsigned char*)s.c_str(), s.size()));
}
void show_field(args& A, const pvd::PVField* fld, const pvd::BitSet *mask);
void show_struct(args& A, const pvd::PVStructure* fld, const pvd::BitSet *mask)
{
const pvd::StructureConstPtr& type = fld->getStructure();
const pvd::PVFieldPtrArray& children = fld->getPVFields();
const pvd::StringArray& names = type->getFieldNames();
yg(yajl_gen_map_open(A.handle));
for(size_t i=0, N=names.size(); i<N; i++)
{
if(mask && !mask->get(children[i]->getFieldOffset())) continue;
yg_string(A.handle, names[i]);
show_field(A, children[i].get(), mask);
}
yg(yajl_gen_map_close(A.handle));
}
void show_field(args& A, const pvd::PVField* fld, const pvd::BitSet *mask)
{
switch(fld->getField()->getType())
{
case pvd::scalar:
{
const pvd::PVScalar *scalar=static_cast<const pvd::PVScalar*>(fld);
switch(scalar->getScalar()->getScalarType()) {
case pvd::pvString: yg_string(A.handle, scalar->getAs<std::string>()); break;
case pvd::pvBoolean: yg(yajl_gen_bool(A.handle, scalar->getAs<pvd::boolean>())); break;
case pvd::pvDouble:
case pvd::pvFloat: yg(yajl_gen_double(A.handle, scalar->getAs<double>())); break;
// case pvd::pvULong: // can't always be exactly represented...
default:
yg(yajl_gen_integer(A.handle, scalar->getAs<pvd::int64>())); break;
}
}
return;
case pvd::scalarArray:
{
const pvd::PVScalarArray *scalar=static_cast<const pvd::PVScalarArray*>(fld);
pvd::shared_vector<const void> arr;
scalar->getAs<void>(arr);
yg(yajl_gen_array_open(A.handle));
switch(arr.original_type()) {
case pvd::pvString: {
pvd::shared_vector<const std::string> sarr(pvd::shared_vector_convert<const std::string>(arr));
for(size_t i=0, N=sarr.size(); i<N; i++) {
yg_string(A.handle, sarr[i]);
}
break;
}
case pvd::pvBoolean: {
pvd::shared_vector<const pvd::boolean> sarr(pvd::shared_vector_convert<const pvd::boolean>(arr));
for(size_t i=0, N=sarr.size(); i<N; i++) {
yg(yajl_gen_bool(A.handle, sarr[i]));
}
break;
}
case pvd::pvDouble:
case pvd::pvFloat: {
pvd::shared_vector<const double> sarr(pvd::shared_vector_convert<const double>(arr));
for(size_t i=0, N=sarr.size(); i<N; i++) {
yg(yajl_gen_double(A.handle, sarr[i]));
}
break;
}
default: {
pvd::shared_vector<const pvd::int64> sarr(pvd::shared_vector_convert<const pvd::int64>(arr));
for(size_t i=0, N=sarr.size(); i<N; i++) {
yg(yajl_gen_integer(A.handle, sarr[i]));
}
break;
}
}
yg(yajl_gen_array_close(A.handle));
}
return;
case pvd::structure:
show_struct(A, static_cast<const pvd::PVStructure*>(fld), mask);
return;
case pvd::structureArray:
{
pvd::PVStructureArray::const_svector arr(static_cast<const pvd::PVStructureArray*>(fld)->view());
yg(yajl_gen_array_open(A.handle));
for(size_t i=0, N=arr.size(); i<N; i++) {
if(arr[i])
show_struct(A, arr[i].get(), 0);
else
yg(yajl_gen_null(A.handle));
}
yg(yajl_gen_array_close(A.handle));
}
return;
case pvd::union_:
{
const pvd::PVUnion *U=static_cast<const pvd::PVUnion*>(fld);
const pvd::PVField::const_shared_pointer& C(U->get());
if(!C) {
yg(yajl_gen_null(A.handle));
} else {
show_field(A, C.get(), 0);
}
}
return;
case pvd::unionArray: {
const pvd::PVUnionArray *U=static_cast<const pvd::PVUnionArray*>(fld);
pvd::PVUnionArray::const_svector arr(U->view());
yg(yajl_gen_array_open(A.handle));
for(size_t i=0, N=arr.size(); i<N; i++) {
if(arr[i])
show_field(A, arr[i].get(), 0);
else
yg(yajl_gen_null(A.handle));
}
yg(yajl_gen_array_close(A.handle));
}
return;
}
// should not be reached
if(A.opts.ignoreUnprintable)
yg(yajl_gen_null(A.handle));
else
throw std::runtime_error("Encountered unprintable field type");
}
void expandBS(const pvd::PVStructure& top, pvd::BitSet& mask, bool parents) {
if(mask.get(0)) { // special handling because getSubField(0) not allowed
// wildcard
for(size_t idx=1, N=top.getNumberFields(); idx<N; idx++) {
mask.set(idx);
}
} else {
for(pvd::int32 idx = mask.nextSetBit(0), N=top.getNumberFields(); idx>=0 && idx<N; idx=mask.nextSetBit(idx+1)) {
pvd::PVField::const_shared_pointer fld = top.getSubFieldT(idx);
// look forward and mark all children
for(size_t i=idx+1, N=fld->getNextFieldOffset(); i<N; i++)
mask.set(i);
if(parents) {
// look back and mark all parents
// we've already stepped past all parents so siblings will not be automatically marked
for(const pvd::PVStructure *parent = fld->getParent(); parent; parent = parent->getParent()) {
mask.set(parent->getFieldOffset());
}
}
}
}
}
} // namespace
namespace epics{namespace pvData{
JSONPrintOptions::JSONPrintOptions()
:multiLine(true)
,ignoreUnprintable(true)
,indent(0)
,json5(false)
{}
void printJSON(std::ostream& strm,
const PVStructure& val,
const BitSet& mask,
const JSONPrintOptions& opts)
{
args A(strm, opts);
pvd::BitSet emask(mask);
expandBS(val, emask, true);
if(!emask.get(0)) return;
show_struct(A, &val, &emask);
}
void printJSON(std::ostream& strm,
const PVField& val,
const JSONPrintOptions& opts)
{
args A(strm, opts);
show_field(A, &val, 0);
}
}} // namespace epics::pvData

View File

@@ -1,231 +0,0 @@
/*
* Copyright information and license terms for this software can be
* found in the file LICENSE that is included with the distribution
*/
#include <vector>
#include <sstream>
#define epicsExportSharedSymbols
#include <pv/pvdVersion.h>
#include <pv/pvData.h>
#include <pv/valueBuilder.h>
#include <pv/bitSet.h>
#include "pv/json.h"
namespace pvd = epics::pvData;
namespace {
struct args {
std::ostream& strm;
const pvd::JSONPrintOptions& opts;
unsigned indent;
args(std::ostream& strm,
const pvd::JSONPrintOptions& opts)
:strm(strm)
,opts(opts)
,indent(opts.indent)
{}
void doIntent() {
if(!opts.multiLine) return;
strm.put('\n');
unsigned i=indent;
while(i--) strm.put(' ');
}
};
void show_field(args& A, const pvd::PVField* fld, const pvd::BitSet *mask);
void show_struct(args& A, const pvd::PVStructure* fld, const pvd::BitSet *mask)
{
const pvd::StructureConstPtr& type = fld->getStructure();
const pvd::PVFieldPtrArray& children = fld->getPVFields();
const pvd::StringArray& names = type->getFieldNames();
A.strm.put('{');
A.indent++;
bool first = true;
for(size_t i=0, N=names.size(); i<N; i++)
{
if(mask && !mask->get(children[i]->getFieldOffset())) continue;
if(first)
first = false;
else
A.strm.put(',');
A.doIntent();
A.strm<<'\"'<<names[i]<<"\": ";
show_field(A, children[i].get(), mask);
}
A.indent--;
A.doIntent();
A.strm.put('}');
}
void show_field(args& A, const pvd::PVField* fld, const pvd::BitSet *mask)
{
switch(fld->getField()->getType())
{
case pvd::scalar:
{
const pvd::PVScalar *scalar=static_cast<const pvd::PVScalar*>(fld);
if(scalar->getScalar()->getScalarType()==pvd::pvString) {
A.strm<<'\"'<<scalar->getAs<std::string>()<<'\"';
} else {
A.strm<<scalar->getAs<std::string>();
}
}
return;
case pvd::scalarArray:
{
const pvd::PVScalarArray *scalar=static_cast<const pvd::PVScalarArray*>(fld);
const bool isstring = scalar->getScalarArray()->getElementType()==pvd::pvString;
pvd::shared_vector<const void> arr;
scalar->getAs<void>(arr);
pvd::shared_vector<const std::string> sarr(pvd::shared_vector_convert<const std::string>(arr));
A.strm.put('[');
for(size_t i=0, N=sarr.size(); i<N; i++) {
if(i!=0)
A.strm.put(',');
if(isstring)
A.strm.put('\"');
A.strm<<sarr[i];
if(isstring)
A.strm.put('\"');
}
A.strm.put(']');
}
return;
case pvd::structure:
show_struct(A, static_cast<const pvd::PVStructure*>(fld), mask);
return;
case pvd::structureArray:
{
pvd::PVStructureArray::const_svector arr(static_cast<const pvd::PVStructureArray*>(fld)->view());
A.strm.put('[');
A.indent++;
for(size_t i=0, N=arr.size(); i<N; i++) {
if(i!=0)
A.strm.put(',');
A.doIntent();
if(arr[i])
show_struct(A, arr[i].get(), 0);
else
A.strm<<"NULL";
}
A.indent--;
A.doIntent();
A.strm.put(']');
}
return;
case pvd::union_:
{
const pvd::PVUnion *U=static_cast<const pvd::PVUnion*>(fld);
const pvd::PVField::const_shared_pointer& C(U->get());
if(!C) {
A.strm<<"null";
} else {
show_field(A, C.get(), 0);
}
}
return;
case pvd::unionArray: {
const pvd::PVUnionArray *U=static_cast<const pvd::PVUnionArray*>(fld);
pvd::PVUnionArray::const_svector arr(U->view());
A.strm.put('[');
A.indent++;
for(size_t i=0, N=arr.size(); i<N; i++) {
if(i!=0)
A.strm.put(',');
A.doIntent();
if(arr[i])
show_field(A, arr[i].get(), 0);
else
A.strm<<"NULL";
}
A.indent--;
A.doIntent();
A.strm.put(']');
}
return;
}
// should not be reached
if(A.opts.ignoreUnprintable)
A.strm<<"// unprintable field type";
else
throw std::runtime_error("Encountered unprintable field type");
}
void expandBS(const pvd::PVStructure& top, pvd::BitSet& mask, bool parents) {
if(mask.get(0)) { // special handling because getSubField(0) not allowed
// wildcard
for(size_t idx=1, N=top.getNumberFields(); idx<N; idx++) {
mask.set(idx);
}
} else {
for(pvd::int32 idx = mask.nextSetBit(0), N=top.getNumberFields(); idx>=0 && idx<N; idx=mask.nextSetBit(idx+1)) {
pvd::PVField::const_shared_pointer fld = top.getSubFieldT(idx);
// look forward and mark all children
for(size_t i=idx+1, N=fld->getNextFieldOffset(); i<N; i++)
mask.set(i);
if(parents) {
// look back and mark all parents
// we've already stepped past all parents so siblings will not be automatically marked
for(const pvd::PVStructure *parent = fld->getParent(); parent; parent = parent->getParent()) {
mask.set(parent->getFieldOffset());
}
}
}
}
}
} // namespace
namespace epics{namespace pvData{
JSONPrintOptions::JSONPrintOptions()
:multiLine(true)
,ignoreUnprintable(true)
,indent(0)
{}
void printJSON(std::ostream& strm,
const PVStructure& val,
const BitSet& mask,
const JSONPrintOptions& opts)
{
args A(strm, opts);
pvd::BitSet emask(mask);
expandBS(val, emask, true);
if(!emask.get(0)) return;
show_struct(A, &val, &emask);
}
void printJSON(std::ostream& strm,
const PVField& val,
const JSONPrintOptions& opts)
{
args A(strm, opts);
show_field(A, &val, 0);
}
}} // namespace epics::pvData

View File

@@ -44,6 +44,7 @@ struct epicsShareClass JSONPrintOptions
bool multiLine; //!< include new lines bool multiLine; //!< include new lines
bool ignoreUnprintable;//!< ignore union/union array when encountered bool ignoreUnprintable;//!< ignore union/union array when encountered
unsigned indent; //!< Initial indentation (# of spaces) unsigned indent; //!< Initial indentation (# of spaces)
bool json5; //!< Output extended JSON (eg. NaN). @since 8.1.0
JSONPrintOptions(); JSONPrintOptions();
}; };

View File

@@ -31,7 +31,7 @@ AnyScalar::AnyScalar(const AnyScalar& o)
} }
#if __cplusplus>=201103L #if __cplusplus>=201103L
AnyScalar::AnyScalar(AnyScalar&& o) AnyScalar::AnyScalar(AnyScalar&& o) noexcept
:_stype(o._stype) :_stype(o._stype)
{ {
typedef std::string string; typedef std::string string;
@@ -136,7 +136,7 @@ void AnyScalar::swap(AnyScalar& o) {
} }
const void* AnyScalar::bufferUnsafe() const { const void* AnyScalar::bufferUnsafe() const {
if(_stype==pvString) { if(_stype==pvString) {
return as<std::string>().c_str(); return ref<std::string>().c_str();
} else { } else {
return _wrap.blob; return _wrap.blob;
} }

View File

@@ -35,7 +35,7 @@ void shared_ptr_base::track_new()
} }
// create new tracker if ptr!=nullptr, otherwise clear // create new tracker if ptr!=nullptr, otherwise clear
void shared_ptr_base::track_new(void* ptr) void shared_ptr_base::track_new(const void* ptr)
{ {
track_clear(); track_clear();
if(ptr){ if(ptr){

View File

@@ -123,7 +123,7 @@ public:
AnyScalar(const AnyScalar& o); AnyScalar(const AnyScalar& o);
#if __cplusplus>=201103L #if __cplusplus>=201103L
AnyScalar(AnyScalar&& o); AnyScalar(AnyScalar&& o) noexcept;
#endif #endif
inline ~AnyScalar() {clear();} inline ~AnyScalar() {clear();}
@@ -140,7 +140,7 @@ public:
} }
#if __cplusplus>=201103L #if __cplusplus>=201103L
inline AnyScalar& operator=(AnyScalar&& o) { inline AnyScalar& operator=(AnyScalar&& o) noexcept {
clear(); clear();
swap(o); swap(o);
return *this; return *this;

View File

@@ -150,14 +150,17 @@ struct swap<8> {
#undef _PVA_swap64 #undef _PVA_swap64
/* PVD serialization doesn't pay attention to alignement, /* PVD serialization doesn't pay attention to alignement,
* which some targets really care about and treat unaligned * which some targets (ARM and powerpc) really care about and treat unaligned
* access as a fault, or with a heavy penalty (~= to a syscall). * access as a fault, or with a heavy penalty (~= to a syscall).
* *
* For those targets,, we will have to live with the increase * For those targets,, we will have to live with the increase
* in execution time and/or object code size of byte-wise copy. * in execution time and/or object code size of byte-wise copy.
*
* Treat x86 32/64 as an outlier, and assume all other targets
* need, or greatly benefit, from aligned access.
*/ */
#ifdef _ARCH_PPC #if !(defined(__x86_64__) || defined(_M_AMD64) || defined(__i386__) || defined(_M_IX86))
template<typename T> template<typename T>
union alignu { union alignu {

View File

@@ -78,7 +78,7 @@ protected:
// add ourselves to tracker // add ourselves to tracker
void track_new(); void track_new();
// create new tracker if ptr!=nullptr, otherwise clear // create new tracker if ptr!=nullptr, otherwise clear
void track_new(void* ptr); void track_new(const void* ptr);
// copy tracker and add ourself // copy tracker and add ourself
void track_assign(const shared_ptr_base& o); void track_assign(const shared_ptr_base& o);
void track_clear(); void track_clear();
@@ -286,6 +286,7 @@ public:
long use_count() const noexcept { return real.use_count(); } long use_count() const noexcept { return real.use_count(); }
bool unique() const noexcept { return real.unique(); } bool unique() const noexcept { return real.unique(); }
bool expired() const noexcept { return real.expired(); }
}; };
template<class Base> template<class Base>
@@ -316,13 +317,12 @@ do_enable_shared_from_this(const shared_ptr<Store>& dest,
self->xxInternalSelf = actual; self->xxInternalSelf = actual;
} }
}} // namespace epics::debug
template<typename T> template<typename T>
inline std::ostream& operator<<(std::ostream& strm, const epics::debug::shared_ptr<T>& ptr) inline std::ostream& operator<<(std::ostream& strm, const shared_ptr<T>& ptr)
{ {
strm<<ptr.get(); strm<<ptr.get();
return strm; return strm;
} }
}} // namespace epics::debug
#endif // DEBUGPTR_H #endif // DEBUGPTR_H

View File

@@ -434,11 +434,11 @@ public:
_E_non_const* temp=new _E_non_const[i]; _E_non_const* temp=new _E_non_const[i];
try{ try{
std::copy(begin(), begin()+new_count, temp); std::copy(begin(), begin()+new_count, temp);
this->m_sdata.reset(temp, detail::default_array_deleter<E*>());
}catch(...){ }catch(...){
delete[] temp; delete[] temp;
throw; throw;
} }
this->m_sdata.reset(temp, detail::default_array_deleter<E*>());
this->m_offset = 0; this->m_offset = 0;
this->m_count = new_count; this->m_count = new_count;
this->m_total = i; this->m_total = i;
@@ -481,11 +481,11 @@ public:
std::copy(begin(), std::copy(begin(),
begin()+n, begin()+n,
temp); temp);
this->m_sdata.reset(temp, detail::default_array_deleter<pointer>());
}catch(...){ }catch(...){
delete[] temp; delete[] temp;
throw; throw;
} }
this->m_sdata.reset(temp, detail::default_array_deleter<pointer>());
this->m_offset= 0; this->m_offset= 0;
this->m_count = i; this->m_count = i;
this->m_total = new_total; this->m_total = new_total;

View File

@@ -60,6 +60,8 @@ private:
epicsTime timeToRun; epicsTime timeToRun;
double period; double period;
bool onList; bool onList;
bool cancelled;
bool processing;
friend class Timer; friend class Timer;
struct IncreasingTime; struct IncreasingTime;
}; };

View File

@@ -271,10 +271,10 @@ char* epicsRefSnapshotCurrent()
snap.update(); snap.update();
std::ostringstream strm; std::ostringstream strm;
strm<<snap; strm<<snap;
const char *str = strm.str().c_str(); std::string str = strm.str();
char *ret = (char*)malloc(strlen(str)+1); char *ret = (char*)malloc(str.length()+1);
if(ret) if(ret)
strcpy(ret, str); strcpy(ret, str.c_str());
return ret; return ret;
}catch(std::exception& e){ }catch(std::exception& e){
return epicsStrDup(e.what()); return epicsStrDup(e.what());

View File

@@ -23,7 +23,9 @@ namespace epics { namespace pvData {
TimerCallback::TimerCallback() TimerCallback::TimerCallback()
: period(0.0), : period(0.0),
onList(false) onList(false),
cancelled(false),
processing(false)
{ {
} }
@@ -50,6 +52,7 @@ void Timer::addElement(TimerCallbackPtr const & timerCallback)
temp.push_back(timerCallback); temp.push_back(timerCallback);
timerCallback->onList = true; timerCallback->onList = true;
timerCallback->cancelled = false;
// merge sorted lists. // merge sorted lists.
// for us effectively insertion sort. // for us effectively insertion sort.
@@ -60,6 +63,11 @@ void Timer::addElement(TimerCallbackPtr const & timerCallback)
bool Timer::cancel(TimerCallbackPtr const &timerCallback) bool Timer::cancel(TimerCallbackPtr const &timerCallback)
{ {
Lock xx(mutex); Lock xx(mutex);
/* If we're processing, just set the cancel flag */
if (timerCallback->processing) {
timerCallback->cancelled = true;
return true;
}
if(!timerCallback->onList) return false; if(!timerCallback->onList) return false;
if(!alive) { if(!alive) {
timerCallback->onList = false; timerCallback->onList = false;
@@ -107,6 +115,7 @@ void Timer::run()
TimerCallbackPtr work; TimerCallbackPtr work;
work.swap(queue.front()); work.swap(queue.front());
work->onList = false; work->onList = false;
work->processing = true;
queue.pop_front(); queue.pop_front();
{ {
@@ -115,7 +124,15 @@ void Timer::run()
work->callback(); work->callback();
} }
if(work->period > 0.0 && alive) { work->processing = false;
if(work->period > 0.0 && alive && !work->cancelled) {
if(waitfor <= -work->period) {
// Periodic timer phase has fallen behind by at least one full period.
// Could be due to previous slow jobs, or a system time jump forward.
// Reset the phase.
work->timeToRun = now = epicsTime::getCurrent();
}
work->timeToRun += work->period; work->timeToRun += work->period;
addElement(work); addElement(work);
} }

View File

@@ -44,11 +44,6 @@ public:
//default constructors and destructor are OK //default constructors and destructor are OK
//returns (false,true) if pvField(is not, is) a valid alarm structure //returns (false,true) if pvField(is not, is) a valid alarm structure
//An automatic detach is issued if already attached. //An automatic detach is issued if already attached.
/*
* Attach to a field of a PVData object.
* @param pvField The pvField.
* @return (false,true) if the pvField (is not, is) an alarm structure.
*/
/* /*
* Attach to a field of a PVData object. * Attach to a field of a PVData object.
* @param pvField The pvField. * @param pvField The pvField.

View File

@@ -14,6 +14,11 @@
#include <cstring> #include <cstring>
#include <memory> #include <memory>
// allow to test deprecated functions without causing compiler warnings
#include <compilerDependencies.h>
#undef EPICS_DEPRECATED
#define EPICS_DEPRECATED
#include <testMain.h> #include <testMain.h>
#include <pv/pvUnitTest.h> #include <pv/pvUnitTest.h>

View File

@@ -123,7 +123,7 @@ const char bigtest[] =
" ,{\"a\":9, \"b\":10}\n" " ,{\"a\":9, \"b\":10}\n"
" ],\n" " ],\n"
" \"any\": \"4.2\",\n" " \"any\": \"4.2\",\n"
" \"almost\": \"hello\"\n" " \"almost\": \"long string /with\\\\ several \\\" and ' characters\\u001f\\u2705\"\n"
"}"; "}";
// intentionally not setting "extra" // intentionally not setting "extra"
@@ -204,7 +204,7 @@ void testInto()
} }
testFieldEqual<pvd::PVString>(val, "any", "4.2"); testFieldEqual<pvd::PVString>(val, "any", "4.2");
testFieldEqual<pvd::PVString>(val, "almost", "hello"); testFieldEqual<pvd::PVString>(val, "almost", "long string /with\\ several \" and ' characters\x1f\xe2\x9c\x85");
} }
void testroundtrip() void testroundtrip()
@@ -255,19 +255,19 @@ void testroundtrip()
round2 = strm.str(); round2 = strm.str();
} }
testEqual(round2, "{\"scalar\": 42," testEqual(round2, "{\"scalar\":42,"
"\"ivec\": [1,2,3]," "\"ivec\":[1,2,3],"
"\"svec\": [\"one\",\"two\"]," "\"svec\":[\"one\",\"two\"],"
"\"sub\": {" "\"sub\":{"
"\"x\": {" "\"x\":{"
"\"y\": 43" "\"y\":43"
"}}," "}},"
"\"extra\": 0," "\"extra\":0,"
"\"sarr\": [{\"a\": 5,\"b\": 6}," "\"sarr\":[{\"a\":5,\"b\":6},"
"{\"a\": 7,\"b\": 8}," "{\"a\":7,\"b\":8},"
"{\"a\": 9,\"b\": 10}]," "{\"a\":9,\"b\":10}],"
"\"any\": \"4.2\"," "\"any\":\"4.2\","
"\"almost\": \"hello\"" "\"almost\":\"long string /with\\\\ several \\\" and ' characters\\u001F\xe2\x9c\x85\""
"}"); "}");
} }

View File

@@ -247,7 +247,7 @@ void showNTTable()
iarr.push_back(42); // will not be shown iarr.push_back(42); // will not be shown
input->getSubFieldT<pvd::PVIntArray>("value.colA")->replace(pvd::freeze(iarr)); input->getSubFieldT<pvd::PVIntArray>("value.colA")->replace(pvd::freeze(iarr));
sarr.push_back("one\x7f"); sarr.push_back("one\x7f\x80");
sarr.push_back("two words"); sarr.push_back("two words");
sarr.push_back("A '\"'"); sarr.push_back("A '\"'");
input->getSubFieldT<pvd::PVStringArray>("value.colB")->replace(pvd::freeze(sarr)); input->getSubFieldT<pvd::PVStringArray>("value.colB")->replace(pvd::freeze(sarr));
@@ -255,7 +255,7 @@ void showNTTable()
testDiff("<undefined> \n" testDiff("<undefined> \n"
"labelA \"label B\"\n" "labelA \"label B\"\n"
" 1 one\\x7F\n" " 1 one\\x7F\\x80\n"
" 2 \"two words\"\n" " 2 \"two words\"\n"
" 3 \"A \\'\"\"\\'\"\n" " 3 \"A \\'\"\"\\'\"\n"
, print(input->stream()), , print(input->stream()),

View File

@@ -6,6 +6,7 @@
#include <testMain.h> #include <testMain.h>
#include <epicsUnitTest.h> #include <epicsUnitTest.h>
#include <epicsStdio.h>
#include <pv/current_function.h> #include <pv/current_function.h>
#include <pv/pvData.h> #include <pv/pvData.h>
@@ -54,7 +55,7 @@ void buildMiss()
for(size_t i=0; i<1000; i++) { for(size_t i=0; i<1000; i++) {
// unique name each time to (partially) defeat caching // unique name each time to (partially) defeat caching
char buf[10]; char buf[10];
sprintf(buf, "field%zu", i); epicsSnprintf(buf, sizeof(buf), "field%lu", (unsigned long) i);
record.start(); record.start();

View File

@@ -33,7 +33,7 @@ MAIN(testOperators)
PVDoublePtr pvValue = pvStructure->getSubField<PVDouble>("value"); PVDoublePtr pvValue = pvStructure->getSubField<PVDouble>("value");
*pvValue <<= testDV; *pvValue <<= testDV;
double dv; double dv = 0.;
*pvValue >>= dv; *pvValue >>= dv;
testOk1(testDV == dv); testOk1(testDV == dv);