11704343264

Committed 06 Nov 2024 01:17PM UTC coverage: 55.893% (-0.001%) from 55.894%

Build # 11704343264

Build Type

Pull #3414

github

Committed by

web-flow

Commit Message

Merge 1281fdc0d into 42f0efdd0

Pull Request Pull Request #3414: `[Fix]` Part-1 - LevelDbStore

Run Details

5796 of 8962 branches covered (64.67%)

Branch coverage included in aggregate %.

179 of 261 new or added lines in 12 files covered. (68.58%)

21 existing lines in 7 files now uncovered.

21796 of 40404 relevant lines covered (53.95%)

85884.25 hits per line

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

79.41

/src/Plugins/LevelDBStore/Plugins/Storage/Store.cs

// Copyright (C) 2015-2024 The Neo Project.
//
// Store.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 Neo.IO.Storage.LevelDB;
using Neo.Persistence;
using System.Collections;
using System.Collections.Generic;

namespace Neo.Plugins.Storage
{
    internal class Store : IStore, IEnumerable<KeyValuePair<byte[], byte[]>>
    {
        private readonly DB _db;

        public Store(string dir)
        {
            _db = new(dir, new()
            {
                CreateIfMissing = true,
                // Keep whole blockchain open plus future files
                // at lease up to block index 10_000_000
                MaxOpenFiles = 4096,
                FilterPolicy = 10,
                CompressionLevel = CompressionType.SnappyCompression,
            });
        }

        public Store(string dir, Options options)
        {
            _db = new DB(dir, options);
        }

        public void Dispose() =>
            _db.Dispose();

        public ISnapshot GetSnapshot() =>
            new Snapshot(_db);

        public void Delete(byte[] key) =>
            _db.Delete(key, WriteOptions.Default);

        public void Put(byte[] key, byte[] value) =>
            _db.Put(key, value, WriteOptions.Default);

        public void PutSync(byte[] key, byte[] value) =>
            _db.Put(key, value, WriteOptions.SyncWrite);

        public bool Contains(byte[] key) =>
            _db.Contains(key, ReadOptions.Default);

        public byte[] TryGet(byte[] key) =>
            _db.Get(key, ReadOptions.Default);

        public bool TryGet(byte[] key, out byte[] value)
        {
            value = _db.Get(key, ReadOptions.Default);
            return value != null;
        }

        public IEnumerable<(byte[], byte[])> Seek(byte[] prefix, SeekDirection direction = SeekDirection.Forward) =>
            direction == SeekDirection.Forward
                ? _db.Seek(prefix, ReadOptions.Default)
                : _db.SeekPrev(prefix, ReadOptions.Default);

        public IEnumerator<KeyValuePair<byte[], byte[]>> GetEnumerator() =>
            _db.GetEnumerator();

        IEnumerator IEnumerable.GetEnumerator() =>
            GetEnumerator();
    }
}

1	// Copyright (C) 2015-2024 The Neo Project.
2	//
3	// Store.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 Neo.IO.Storage.LevelDB;
13	using Neo.Persistence;
14	using System.Collections;
15	using System.Collections.Generic;
16
17	namespace Neo.Plugins.Storage
18	{
19	internal class Store : IStore, IEnumerable<KeyValuePair<byte[], byte[]>>
20	{
21	private readonly DB _db;
22
23	public Store(string dir)	8✔
24	{	8✔
25	_db = new(dir, new()	8✔
26	{	8✔
27	CreateIfMissing = true,	8✔
28	// Keep whole blockchain open plus future files	8✔
29	// at lease up to block index 10_000_000	8✔
30	MaxOpenFiles = 4096,	8✔
31	FilterPolicy = 10,	8✔
32	CompressionLevel = CompressionType.SnappyCompression,	8✔
33	});	8✔
34	}	8✔
35
NEW 36	public Store(string dir, Options options)	×
UNCOV 37	{	×
NEW 38	_db = new DB(dir, options);	×
UNCOV 39	}	×
40
41	public void Dispose() =>
42	_db.Dispose();	8✔
43
44	public ISnapshot GetSnapshot() =>
45	new Snapshot(_db);	3✔
46
47	public void Delete(byte[] key) =>
48	_db.Delete(key, WriteOptions.Default);	9✔
49
50	public void Put(byte[] key, byte[] value) =>
51	_db.Put(key, value, WriteOptions.Default);	10✔
52
53	public void PutSync(byte[] key, byte[] value) =>
NEW 54	_db.Put(key, value, WriteOptions.SyncWrite);	×
55
56	public bool Contains(byte[] key) =>
57	_db.Contains(key, ReadOptions.Default);	5✔
58
59	public byte[] TryGet(byte[] key) =>
60	_db.Get(key, ReadOptions.Default);	8✔
61
62	public bool TryGet(byte[] key, out byte[] value)
63	{	1✔
64	value = _db.Get(key, ReadOptions.Default);	1✔
65	return value != null;	1✔
66	}	1✔
67
68	public IEnumerable<(byte[], byte[])> Seek(byte[] prefix, SeekDirection direction = SeekDirection.Forward) =>
69	direction == SeekDirection.Forward	3✔
70	? _db.Seek(prefix, ReadOptions.Default)	3✔
71	: _db.SeekPrev(prefix, ReadOptions.Default);	3✔
72
73	public IEnumerator<KeyValuePair<byte[], byte[]>> GetEnumerator() =>
NEW 74	_db.GetEnumerator();	×
75
76	IEnumerator IEnumerable.GetEnumerator() =>
NEW 77	GetEnumerator();	×
78	}
79	}

neo-project / neo / 11704343264

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