zerodds-cs 1.0.0-rc.1

C# P/Invoke, NativeAOT-compatible, IDL4-C# runtime
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97

// SPDX-License-Identifier: Apache-2.0
// Copyright 2026 ZeroDDS Contributors
//
// SubConditions.cs — ReadCondition + QueryCondition (Spec §7.5.10.6/7).

using System;
using System.Runtime.InteropServices;
using ZeroDDS.Cond;
using ZeroDDS.Core;
using ZeroDDS.Sub;

namespace ZeroDDS.SubCond;

/// <summary>ReadCondition&lt;T&gt; (Spec §7.5.10.6).</summary>
public sealed class ReadCondition<T> : Condition, IDisposable
{
    private IntPtr _reader;
    private bool _disposed;

    public ReadCondition(DataReader<T> dr, uint sampleStates, uint viewStates, uint instanceStates)
        : base(IntPtr.Zero)
    {
        Handle = Native.DrCreateReadCondition(dr.Handle, sampleStates, viewStates, instanceStates);
        if (Handle == IntPtr.Zero) throw new DdsError("ReadCondition::create failed");
        _reader = dr.Handle;
    }

    public void Dispose()
    {
        if (_disposed) return;
        _disposed = true;
        if (Handle != IntPtr.Zero)
        {
            Native.DrDeleteReadCondition(_reader, Handle);
            Handle = IntPtr.Zero;
        }
        GC.SuppressFinalize(this);
    }
    ~ReadCondition() { Dispose(); }
}

/// <summary>QueryCondition&lt;T&gt; (Spec §7.5.10.7).</summary>
public sealed class QueryCondition<T> : Condition, IDisposable
{
    private IntPtr _reader;
    private bool _disposed;

    public QueryCondition(DataReader<T> dr, uint sampleStates, uint viewStates,
        uint instanceStates, string expression, string[] parameters)
        : base(IntPtr.Zero)
    {
        IntPtr paramPtr = IntPtr.Zero;
        IntPtr[]? paramHandles = null;
        try
        {
            if (parameters != null && parameters.Length > 0)
            {
                paramHandles = new IntPtr[parameters.Length];
                for (int i = 0; i < parameters.Length; ++i)
                {
                    paramHandles[i] = Marshal.StringToHGlobalAnsi(parameters[i]);
                }
                paramPtr = Marshal.AllocHGlobal(IntPtr.Size * parameters.Length);
                Marshal.Copy(paramHandles, 0, paramPtr, parameters.Length);
            }
            Handle = Native.DrCreateQueryCondition(dr.Handle, sampleStates, viewStates,
                instanceStates, expression, paramPtr,
                (UIntPtr)(parameters?.Length ?? 0));
            if (Handle == IntPtr.Zero) throw new DdsError("QueryCondition::create failed");
            _reader = dr.Handle;
        }
        finally
        {
            if (paramPtr != IntPtr.Zero) Marshal.FreeHGlobal(paramPtr);
            if (paramHandles != null)
            {
                foreach (var h in paramHandles)
                {
                    if (h != IntPtr.Zero) Marshal.FreeHGlobal(h);
                }
            }
        }
    }

    public void Dispose()
    {
        if (_disposed) return;
        _disposed = true;
        if (Handle != IntPtr.Zero)
        {
            Native.DrDeleteReadCondition(_reader, Handle);
            Handle = IntPtr.Zero;
        }
        GC.SuppressFinalize(this);
    }
    ~QueryCondition() { Dispose(); }
}