put span

Author: tkstanczak

RocksDbSharp/Native.Wrap.cs

@@ -44,6 +44,26 @@ public void rocksdb_put(
             if (errptr != IntPtr.Zero)
                 throw new RocksDbException(errptr);
         }
+        
+        public unsafe void rocksdb_put(
+            IntPtr db,
+            IntPtr writeOptions,
+            byte* key,
+            long keyLength,
+            byte* value,
+            long valueLength,
+            ColumnFamilyHandle cf)
+        {
+            IntPtr errptr;
+            UIntPtr sklength = (UIntPtr)keyLength;
+            UIntPtr svlength = (UIntPtr)valueLength;
+            if (cf == null)
+                rocksdb_put(db, writeOptions, key, sklength, value, svlength, out errptr);
+            else
+                rocksdb_put_cf(db, writeOptions, cf.Handle, key, sklength, value, svlength, out errptr);
+            if (errptr != IntPtr.Zero)
+                throw new RocksDbException(errptr);
+        }
 
 
         public string rocksdb_get(

RocksDbSharp/RocksDb.cs

@@ -225,11 +225,24 @@ public void Put(byte[] key, byte[] value, ColumnFamilyHandle cf = null, WriteOpt
         {
             Put(key, key.GetLongLength(0), value, value.GetLongLength(0), cf, writeOptions);
         }
+        
+        public void Put(Span<byte> key, Span<byte> value, ColumnFamilyHandle cf = null, WriteOptions writeOptions = null)
+        {
+            Put(key, key.Length, value, value.Length, cf, writeOptions);
+        }
 
         public void Put(byte[] key, long keyLength, byte[] value, long valueLength, ColumnFamilyHandle cf = null, WriteOptions writeOptions = null)
         {
             Native.Instance.rocksdb_put(Handle, (writeOptions ?? DefaultWriteOptions).Handle, key, keyLength, value, valueLength, cf);
         }
+        
+        public unsafe void Put(Span<byte> key, long keyLength, Span<byte> value, long valueLength, ColumnFamilyHandle cf = null, WriteOptions writeOptions = null)
+        {
+            fixed (byte* keyPtr = &MemoryMarshal.GetReference(key), valuePtr = &MemoryMarshal.GetReference(value))
+            {
+                Native.Instance.rocksdb_put(Handle, (writeOptions ?? DefaultWriteOptions).Handle, keyPtr, keyLength, valuePtr, valueLength, cf);
+            }
+        }
 
         public Iterator NewIterator(ColumnFamilyHandle cf = null, ReadOptions readOptions = null)
         {