11949197020

Committed 21 Nov 2024 08:15AM UTC coverage: 55.567% (+0.005%) from 55.562%

Build # 11949197020

Build Type

push

github

Committed by

web-flow

Commit Message

[Plugin LevelDB] Second step of 3414 - GC and Easy Management (#3586)

* second part of the pr 3414

* Apply suggestions from code review

* Update src/Plugins/LevelDBStore/IO/Data/LevelDB/LevelDBHandle.cs

* Fix Handle access

---------

Co-authored-by: Shargon <shargon@gmail.com>

Run Details

5903 of 9160 branches covered (64.44%)

Branch coverage included in aggregate %.

55 of 79 new or added lines in 8 files covered. (69.62%)

1 existing line in 1 file now uncovered.

21934 of 40936 relevant lines covered (53.58%)

84677.0 hits per line

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

88.52

/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) : base(handle) { }

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

        /// <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 var 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)
        {
            var value = Native.leveldb_get(Handle, options.Handle, key, (UIntPtr)key.Length, out var length, out var 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)
        {
            var value = Native.leveldb_get(Handle, options.Handle, key, (UIntPtr)key.Length, out _, out var 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)
        {
            var Handle = Native.leveldb_open(options.Handle, Path.GetFullPath(name), out var 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 var 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 var error);
            NativeHelper.CheckError(error);
        }

        public void Write(WriteOptions options, WriteBatch write_batch)
        {
            Native.leveldb_write(Handle, options.Handle, write_batch.Handle, out var 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) : base(handle) { }	24✔
24
25	protected override void FreeUnManagedObjects()
26	{	8✔
27	if (Handle != IntPtr.Zero)	8✔
28	{	8✔
29	Native.leveldb_close(Handle);	8✔
30	}	8✔
31	}	8✔
32
33	/// <summary>
34	/// Remove the database entry (if any) for "key".
35	/// It is not an error if "key" did not exist in the database.
36	/// Note: consider setting new WriteOptions{ Sync = true }.
37	/// </summary>
38	public void Delete(WriteOptions options, byte[] key)
39	{	9✔
40	Native.leveldb_delete(Handle, options.Handle, key, (UIntPtr)key.Length, out var error);	9✔
41	NativeHelper.CheckError(error);	9✔
42	}	9✔
43
44	/// <summary>
45	/// If the database contains an entry for "key" return the value,
46	/// otherwise return null.
47	/// </summary>
48	public byte[] Get(ReadOptions options, byte[] key)
49	{	15✔
50	var value = Native.leveldb_get(Handle, options.Handle, key, (UIntPtr)key.Length, out var length, out var error);	15✔
51	try
52	{	15✔
53	NativeHelper.CheckError(error);	15✔
54	return value.ToByteArray(length);	15✔
55	}
56	finally
57	{	15✔
58	if (value != IntPtr.Zero) Native.leveldb_free(value);	21✔
59	}	15✔
60	}	15✔
61
62	public bool Contains(ReadOptions options, byte[] key)
63	{	7✔
64	var value = Native.leveldb_get(Handle, options.Handle, key, (UIntPtr)key.Length, out _, out var error);	7✔
65	NativeHelper.CheckError(error);	7✔
66
67	if (value != IntPtr.Zero)	7✔
68	{	3✔
69	Native.leveldb_free(value);	3✔
70	return true;	3✔
71	}
72
73	return false;	4✔
74	}	7✔
75
76	public Snapshot GetSnapshot()
77	{	3✔
78	return new Snapshot(Handle);	3✔
79	}	3✔
80
81	public Iterator NewIterator(ReadOptions options)
82	{	3✔
83	return new Iterator(Native.leveldb_create_iterator(Handle, options.Handle));	3✔
84	}	3✔
85
86	public static DB Open(string name)
87	{	×
88	return Open(name, Options.Default);	×
89	}	×
90
91	public static DB Open(string name, Options options)
92	{	8✔
93	var Handle = Native.leveldb_open(options.Handle, Path.GetFullPath(name), out var error);	8✔
94	NativeHelper.CheckError(error);	8✔
95	return new DB(Handle);	8✔
96	}	8✔
97
98	/// <summary>
99	/// Set the database entry for "key" to "value".
100	/// Note: consider setting new WriteOptions{ Sync = true }.
101	/// </summary>
102	public void Put(WriteOptions options, byte[] key, byte[] value)
103	{	10✔
104	Native.leveldb_put(Handle, options.Handle, key, (UIntPtr)key.Length, value, (UIntPtr)value.Length, out var error);	10✔
105	NativeHelper.CheckError(error);	10✔
106	}	10✔
107
108	/// <summary>
109	/// If a DB cannot be opened, you may attempt to call this method to
110	/// resurrect as much of the contents of the database as possible.
111	/// Some data may be lost, so be careful when calling this function
112	/// on a database that contains important information.
113	/// </summary>
114	public static void Repair(string name, Options options)
115	{	×
NEW 116	Native.leveldb_repair_db(options.Handle, Path.GetFullPath(name), out var error);	×
117	NativeHelper.CheckError(error);	×
118	}	×
119
120	public void Write(WriteOptions options, WriteBatch write_batch)
121	{	2✔
122	Native.leveldb_write(Handle, options.Handle, write_batch.Handle, out var error);	2✔
123	NativeHelper.CheckError(error);	2✔
124	}	2✔
125	}
126	}

neo-project / neo / 11949197020

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