11388216978

Committed 17 Oct 2024 03:32PM UTC coverage: 55.915% (+0.005%) from 55.91%

Build # 11388216978

Build Type

Pull #3528

github

Committed by

web-flow

Commit Message

Merge 254c60941 into bb71676fd

Pull Request Pull Request #3528: [OpCode Benchmark] add benchmark files

Run Details

5778 of 8916 branches covered (64.8%)

Branch coverage included in aggregate %.

28 of 43 new or added lines in 5 files covered. (65.12%)

36 existing lines in 5 files now uncovered.

21746 of 40309 relevant lines covered (53.95%)

86394.22 hits per line

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

91.3

/src/Plugins/RocksDBStore/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.Persistence;
using RocksDbSharp;
using System;
using System.Collections.Generic;
using System.IO;

namespace Neo.Plugins.Storage
{
    internal class Store : IStore
    {
        private readonly RocksDb db;

        public Store(string path)
        {
            db = RocksDb.Open(Options.Default, Path.GetFullPath(path));
        }

        public void Dispose()
        {
            db.Dispose();
        }

        public ISnapshot GetSnapshot()
        {
            return new Snapshot(db);
        }

        public IEnumerable<(byte[] Key, byte[] Value)> Seek(byte[] keyOrPrefix, SeekDirection direction = SeekDirection.Forward)
        {
            if (keyOrPrefix == null) keyOrPrefix = Array.Empty<byte>();

            using var it = db.NewIterator();
            if (direction == SeekDirection.Forward)
                for (it.Seek(keyOrPrefix); it.Valid(); it.Next())
                    yield return (it.Key(), it.Value());
            else
                for (it.SeekForPrev(keyOrPrefix); it.Valid(); it.Prev())
                    yield return (it.Key(), it.Value());
        }

        public bool Contains(byte[] key)
        {
            return db.Get(key, Array.Empty<byte>(), 0, 0) >= 0;
        }

        public byte[] TryGet(byte[] key)
        {
            return db.Get(key);
        }

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

        public void Delete(byte[] key)
        {
            db.Remove(key);
        }

        public void Put(byte[] key, byte[] value)
        {
            db.Put(key, value);
        }

        public void PutSync(byte[] key, byte[] value)
        {
            db.Put(key, value, writeOptions: Options.WriteDefaultSync);
        }
    }
}

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.Persistence;
13	using RocksDbSharp;
14	using System;
15	using System.Collections.Generic;
16	using System.IO;
17
18	namespace Neo.Plugins.Storage
19	{
20	internal class Store : IStore
21	{
22	private readonly RocksDb db;
23
24	public Store(string path)	9✔
25	{	9✔
26	db = RocksDb.Open(Options.Default, Path.GetFullPath(path));	9✔
27	}	9✔
28
29	public void Dispose()
30	{	8✔
31	db.Dispose();	8✔
32	}	8✔
33
34	public ISnapshot GetSnapshot()
35	{	21✔
36	return new Snapshot(db);	21✔
37	}	21✔
38
39	public IEnumerable<(byte[] Key, byte[] Value)> Seek(byte[] keyOrPrefix, SeekDirection direction = SeekDirection.Forward)
40	{	3✔
41	if (keyOrPrefix == null) keyOrPrefix = Array.Empty<byte>();	3!
42
43	using var it = db.NewIterator();	3✔
44	if (direction == SeekDirection.Forward)	3✔
45	for (it.Seek(keyOrPrefix); it.Valid(); it.Next())	8✔
46	yield return (it.Key(), it.Value());	3✔
47	else
48	for (it.SeekForPrev(keyOrPrefix); it.Valid(); it.Prev())	14✔
49	yield return (it.Key(), it.Value());	5✔
50	}	3✔
51
52	public bool Contains(byte[] key)
53	{	5✔
54	return db.Get(key, Array.Empty<byte>(), 0, 0) >= 0;	5✔
55	}	5✔
56
57	public byte[] TryGet(byte[] key)
58	{	9✔
59	return db.Get(key);	9✔
60	}	9✔
61
62	public bool TryGet(byte[] key, out byte[] value)
63	{	2✔
64	value = db.Get(key);	2✔
65	return value != null;	2✔
66	}	2✔
67
68	public void Delete(byte[] key)
69	{	9✔
70	db.Remove(key);	9✔
71	}	9✔
72
73	public void Put(byte[] key, byte[] value)
74	{	10✔
75	db.Put(key, value);	10✔
76	}	10✔
77
78	public void PutSync(byte[] key, byte[] value)
UNCOV 79	{	×
UNCOV 80	db.Put(key, value, writeOptions: Options.WriteDefaultSync);	×
UNCOV 81	}	×
82	}
83	}

neo-project / neo / 11388216978

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