11930294308

Committed 20 Nov 2024 09:17AM UTC coverage: 55.602% (+0.03%) from 55.57%

Build # 11930294308

Build Type

Pull #3586

github

Committed by

web-flow

Commit Message

Merge 90d04475a into 842fa5288

Pull Request Pull Request #3586: [Plugin LevelDB] Second step of 3414 - GC and Easy Management

Run Details

5903 of 9154 branches covered (64.49%)

Branch coverage included in aggregate %.

71 of 93 new or added lines in 8 files covered. (76.34%)

1 existing line in 1 file now uncovered.

21961 of 40959 relevant lines covered (53.62%)

84632.39 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

89.23

/src/Plugins/LevelDBStore/IO/Data/LevelDB/DB.cs

// Copyright (C) 2015-2024 The Neo Project.
//
// DB.cs file belongs to the neo project and is free
// software distributed under the MIT software license, see the
// accompanying file LICENSE in the main directory of the
// repository or http://www.opensource.org/licenses/mit-license.php
// for more details.
//
// Redistribution and use in source and binary forms with or without
// modifications are permitted.

using System;
using System.IO;

namespace Neo.IO.Data.LevelDB
{
    /// <summary>
    /// A DB is a persistent ordered map from keys to values.
    /// A DB is safe for concurrent access from multiple threads without any external synchronization.
    /// </summary>
    public class DB : LevelDBHandle
    {
        private DB(IntPtr handle)
        {
            Handle = handle;
        }

        protected override void FreeUnManagedObjects()
        {
            if (Handle != IntPtr.Zero)
            {
                Native.leveldb_close(Handle);
                Handle = IntPtr.Zero;
            }
        }

        /// <summary>
        /// Remove the database entry (if any) for "key".
        /// It is not an error if "key" did not exist in the database.
        /// Note: consider setting new WriteOptions{ Sync = true }.
        /// </summary>
        public void Delete(WriteOptions options, byte[] key)
        {
            Native.leveldb_delete(Handle, options.Handle, key, (UIntPtr)key.Length, out IntPtr error);
            NativeHelper.CheckError(error);
        }

        /// <summary>
        /// If the database contains an entry for "key" return the value,
        /// otherwise return null.
        /// </summary>
        public byte[] Get(ReadOptions options, byte[] key)
        {
            IntPtr value = Native.leveldb_get(Handle, options.Handle, key, (UIntPtr)key.Length, out UIntPtr length, out IntPtr error);
            try
            {
                NativeHelper.CheckError(error);
                return value.ToByteArray(length);
            }
            finally
            {
                if (value != IntPtr.Zero) Native.leveldb_free(value);
            }
        }

        public bool Contains(ReadOptions options, byte[] key)
        {
            IntPtr value = Native.leveldb_get(Handle, options.Handle, key, (UIntPtr)key.Length, out _, out IntPtr error);
            NativeHelper.CheckError(error);

            if (value != IntPtr.Zero)
            {
                Native.leveldb_free(value);
                return true;
            }

            return false;
        }

        public Snapshot GetSnapshot()
        {
            return new Snapshot(Handle);
        }

        public Iterator NewIterator(ReadOptions options)
        {
            return new Iterator(Native.leveldb_create_iterator(Handle, options.Handle));
        }

        public static DB Open(string name)
        {
            return Open(name, Options.Default);
        }

        public static DB Open(string name, Options options)
        {
            IntPtr Handle = Native.leveldb_open(options.Handle, Path.GetFullPath(name), out IntPtr error);
            NativeHelper.CheckError(error);
            return new DB(Handle);
        }

        /// <summary>
        /// Set the database entry for "key" to "value".
        /// Note: consider setting new WriteOptions{ Sync = true }.
        /// </summary>
        public void Put(WriteOptions options, byte[] key, byte[] value)
        {
            Native.leveldb_put(Handle, options.Handle, key, (UIntPtr)key.Length, value, (UIntPtr)value.Length, out IntPtr error);
            NativeHelper.CheckError(error);
        }

        /// <summary>
        /// If a DB cannot be opened, you may attempt to call this method to
        /// resurrect as much of the contents of the database as possible.
        /// Some data may be lost, so be careful when calling this function
        /// on a database that contains important information.
        /// </summary>
        public static void Repair(string name, Options options)
        {
            Native.leveldb_repair_db(options.Handle, Path.GetFullPath(name), out IntPtr error);
            NativeHelper.CheckError(error);
        }

        public void Write(WriteOptions options, WriteBatch write_batch)
        {
            Native.leveldb_write(Handle, options.Handle, write_batch.Handle, out IntPtr error);
            NativeHelper.CheckError(error);
        }
    }
}

1	// Copyright (C) 2015-2024 The Neo Project.
2	//
3	// DB.cs file belongs to the neo project and is free
4	// software distributed under the MIT software license, see the
5	// accompanying file LICENSE in the main directory of the
6	// repository or http://www.opensource.org/licenses/mit-license.php
7	// for more details.
8	//
9	// Redistribution and use in source and binary forms with or without
10	// modifications are permitted.
11
12	using System;
13	using System.IO;
14
15	namespace Neo.IO.Data.LevelDB
16	{
17	/// <summary>
18	/// A DB is a persistent ordered map from keys to values.
19	/// A DB is safe for concurrent access from multiple threads without any external synchronization.
20	/// </summary>
21	public class DB : LevelDBHandle
22	{
23	private DB(IntPtr handle)	8✔
24	{	8✔
25	Handle = handle;	8✔
26	}	8✔
27
28	protected override void FreeUnManagedObjects()
29	{	8✔
30	if (Handle != IntPtr.Zero)	8✔
31	{	8✔
32	Native.leveldb_close(Handle);	8✔
33	Handle = IntPtr.Zero;	8✔
34	}	8✔
35	}	8✔
36
37	/// <summary>
38	/// Remove the database entry (if any) for "key".
39	/// It is not an error if "key" did not exist in the database.
40	/// Note: consider setting new WriteOptions{ Sync = true }.
41	/// </summary>
42	public void Delete(WriteOptions options, byte[] key)
43	{	9✔
44	Native.leveldb_delete(Handle, options.Handle, key, (UIntPtr)key.Length, out IntPtr error);	9✔
45	NativeHelper.CheckError(error);	9✔
46	}	9✔
47
48	/// <summary>
49	/// If the database contains an entry for "key" return the value,
50	/// otherwise return null.
51	/// </summary>
52	public byte[] Get(ReadOptions options, byte[] key)
53	{	15✔
54	IntPtr value = Native.leveldb_get(Handle, options.Handle, key, (UIntPtr)key.Length, out UIntPtr length, out IntPtr error);	15✔
55	try
56	{	15✔
57	NativeHelper.CheckError(error);	15✔
58	return value.ToByteArray(length);	15✔
59	}
60	finally
61	{	15✔
62	if (value != IntPtr.Zero) Native.leveldb_free(value);	21✔
63	}	15✔
64	}	15✔
65
66	public bool Contains(ReadOptions options, byte[] key)
67	{	7✔
68	IntPtr value = Native.leveldb_get(Handle, options.Handle, key, (UIntPtr)key.Length, out _, out IntPtr error);	7✔
69	NativeHelper.CheckError(error);	7✔
70
71	if (value != IntPtr.Zero)	7✔
72	{	3✔
73	Native.leveldb_free(value);	3✔
74	return true;	3✔
75	}
76
77	return false;	4✔
78	}	7✔
79
80	public Snapshot GetSnapshot()
81	{	3✔
82	return new Snapshot(Handle);	3✔
83	}	3✔
84
85	public Iterator NewIterator(ReadOptions options)
86	{	3✔
87	return new Iterator(Native.leveldb_create_iterator(Handle, options.Handle));	3✔
88	}	3✔
89
90	public static DB Open(string name)
91	{	×
92	return Open(name, Options.Default);	×
93	}	×
94
95	public static DB Open(string name, Options options)
96	{	8✔
97	IntPtr Handle = Native.leveldb_open(options.Handle, Path.GetFullPath(name), out IntPtr error);	8✔
98	NativeHelper.CheckError(error);	8✔
99	return new DB(Handle);	8✔
100	}	8✔
101
102	/// <summary>
103	/// Set the database entry for "key" to "value".
104	/// Note: consider setting new WriteOptions{ Sync = true }.
105	/// </summary>
106	public void Put(WriteOptions options, byte[] key, byte[] value)
107	{	10✔
108	Native.leveldb_put(Handle, options.Handle, key, (UIntPtr)key.Length, value, (UIntPtr)value.Length, out IntPtr error);	10✔
109	NativeHelper.CheckError(error);	10✔
110	}	10✔
111
112	/// <summary>
113	/// If a DB cannot be opened, you may attempt to call this method to
114	/// resurrect as much of the contents of the database as possible.
115	/// Some data may be lost, so be careful when calling this function
116	/// on a database that contains important information.
117	/// </summary>
118	public static void Repair(string name, Options options)
119	{	×
NEW 120	Native.leveldb_repair_db(options.Handle, Path.GetFullPath(name), out IntPtr error);	×
121	NativeHelper.CheckError(error);	×
122	}	×
123
124	public void Write(WriteOptions options, WriteBatch write_batch)
125	{	2✔
126	Native.leveldb_write(Handle, options.Handle, write_batch.Handle, out IntPtr error);	2✔
127	NativeHelper.CheckError(error);	2✔
128	}	2✔
129	}
130	}

neo-project / neo / 11930294308

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous