REVIEW

.github/workflows/ci.yml

@@ -0,0 +1,39 @@
+name: Build master
+
+on:
+  pull_request:
+    branches:
+      - 'master'
+  push:
+    branches:
+      - "master"
+      - "ci"
+
+env:
+  OPAMROOT: /home/opam/.opam
+  OPAMYES: true
+  OPAMCONFIRMLEVEL: unsafe-yes
+
+jobs:
+  build:
+    runs-on: ubuntu-latest
+    container:
+      image: ghcr.io/shimat/opencvsharp/ubuntu22-dotnet6sdk-opencv4.7.0:20230114
+
+    steps:
+
+      - name: Checkout code
+        uses: actions/checkout@v4
+        with:
+          fetch-depth: 1
+
+      - name: look_around 
+        run: ls
+
+      - name: build
+        run: dotnet build
+
+      - name: run_tests 
+        run: |
+          cd ./Tests
+          dotnet run

Bench/Bench.fs

@@ -0,0 +1,197 @@
+open Conv
+open System.IO
+open BenchmarkDotNet.Attributes
+open BenchmarkDotNet.Running
+open OpenCvSharp
+open System.Runtime.CompilerServices
+open System.Runtime.InteropServices
+open ReadConvWrite
+
+
+let kernel = new Mat([| 3; 3 |], MatType.CV_32FC1, Scalar -1.)
+~~~ (ind_fl kernel).set_Item 1 1 @@ float32 8
+
+
+[<MemoryDiagnoser>]
+type PartitionConvComparision() =
+
+    [<Params("../small.jpg", "../big.jpg")>]
+    member val file = "" with get, set
+
+    member self.getPath([<CallerFilePath; Optional; DefaultParameterValue("")>] path: string) =
+        Path.GetDirectoryName path
+
+    member self.Src =
+        let path = Path.Combine [| self.getPath (); self.file |]
+        let src = new Mat(path, ImreadModes.Grayscale)
+        src
+
+    member self.Dest = new Mat(self.Src.Height, self.Src.Width, self.Src.Type())
+
+
+    [<Benchmark>]
+    member self.Seql() = conv self.Src self.Dest kernel Seql
+
+    [<Benchmark>]
+    member self.ByPixel() = conv self.Src self.Dest kernel ByPixel
+
+    [<Benchmark>]
+    member self.ByRow() = conv self.Src self.Dest kernel ByRow
+
+    [<Benchmark>]
+    member self.ByColumn() = conv self.Src self.Dest kernel ByColumn
+
+    [<Benchmark>]
+    member self.ByRect1x1() =
+        conv self.Src self.Dest kernel @@ ByRect(Limited 1, Limited 1)
+
+    [<Benchmark>]
+    member self.ByRect1ker() =
+        conv self.Src self.Dest kernel
+        @@ ByRect(Limited kernel.Width, Limited kernel.Height)
+
+    [<Benchmark>]
+    member self.ByRect5ker() =
+        conv self.Src self.Dest kernel
+        @@ ByRect(Limited @@ ( * ) 5 kernel.Width, Limited @@ ( * ) 5 kernel.Height)
+
+    [<Benchmark>]
+    member self.ByRect10ker() =
+        conv self.Src self.Dest kernel
+        @@ ByRect(Limited @@ ( * ) 10 kernel.Width, Limited @@ ( * ) 10 kernel.Height)
+
+    [<Benchmark>]
+    member self.ByRect15ker() =
+        conv self.Src self.Dest kernel
+        @@ ByRect(Limited @@ ( * ) 15 kernel.Width, Limited @@ ( * ) 15 kernel.Height)
+
+
+    [<Benchmark>]
+    member self.By1KerHeightRows() =
+        conv self.Src self.Dest kernel @@ ByRect(UnLimited, Limited kernel.Height)
+
+    [<Benchmark>]
+    member self.By3KerHeightRows() =
+        conv self.Src self.Dest kernel
+        @@ ByRect(UnLimited, Limited @@ ( * ) 3 kernel.Height)
+
+    [<Benchmark>]
+    member self.By10KerHeightRows() =
+        conv self.Src self.Dest kernel
+        @@ ByRect(UnLimited, Limited @@ ( * ) 10 kernel.Height)
+
+    [<Benchmark>]
+    member self.By1KerWidthColomns() =
+        conv self.Src self.Dest kernel @@ ByRect(Limited kernel.Width, UnLimited)
+
+    [<Benchmark>]
+    member self.By3KerWidthColomns() =
+        conv self.Src self.Dest kernel
+        @@ ByRect(Limited @@ ( * ) 3 kernel.Width, UnLimited)
+
+    [<Benchmark>]
+    member self.By10KerWidthColomns() =
+        conv self.Src self.Dest kernel
+        @@ ByRect(Limited @@ ( * ) 10 kernel.Width, UnLimited)
+
+
+let def_cnfg =
+    { source = ([ "/root/conv/pics" ], SearchOption.TopDirectoryOnly)
+      outdir = "./Out"
+      prefix = "Conv"
+      max_readers = Some 1
+      max_writers = None
+      max_conv_performers = Some 4
+      max_queue_size = Some 4
+      conv_mode = ByRow }
+
+
+[<MemoryDiagnoser>]
+type Pipelining() =
+
+    [<Benchmark>]
+    member self.R1C1parW1Qub() =
+        full_cycle_paral_conv
+            { def_cnfg with
+                max_readers = Some 1
+                max_writers = Some 1
+                max_conv_performers = Some 1
+                max_queue_size = None
+                conv_mode = ByRow }
+            kernel
+
+    [<Benchmark>]
+    member self.R1C1parW1Q1() =
+        full_cycle_paral_conv
+            { def_cnfg with
+                max_readers = Some 1
+                max_writers = Some 1
+                max_conv_performers = Some 1
+                max_queue_size = Some 1
+                conv_mode = ByRow }
+            kernel
+
+
+    [<Benchmark>]
+    member self.R1C4parW1Q4() =
+        full_cycle_paral_conv
+            { def_cnfg with
+                max_readers = Some 1
+                max_writers = Some 1
+                max_conv_performers = Some 4
+                max_queue_size = Some 4
+                conv_mode = ByRow }
+            kernel
+
+    [<Benchmark>]
+    member self.R1C4parW1Q8() =
+        full_cycle_paral_conv
+            { def_cnfg with
+                max_readers = Some 1
+                max_writers = Some 1
+                max_conv_performers = Some 4
+                max_queue_size = Some 8
+                conv_mode = ByRow }
+            kernel
+
+    [<Benchmark>]
+    member self.R1C4parWubQ4() =
+        full_cycle_paral_conv
+            { def_cnfg with
+                max_readers = Some 1
+                max_writers = None
+                max_conv_performers = Some 4
+                max_queue_size = Some 4
+                conv_mode = ByRow }
+            kernel
+
+    [<Benchmark>]
+    member self.R1CubseqlWubQ16() =
+        full_cycle_paral_conv
+            { def_cnfg with
+                max_readers = Some 1
+                max_writers = None
+                max_conv_performers = None
+                max_queue_size = Some 16
+                conv_mode = Seql }
+            kernel
+
+    [<Benchmark>]
+    member self.R1C2parWubQ2() =
+        full_cycle_paral_conv
+            { def_cnfg with
+                max_readers = Some 1
+                max_writers = None
+                max_conv_performers = Some 2
+                max_queue_size = Some 4
+                conv_mode = ByRow }
+            kernel
+
+    [<IterationCleanupAttribute>]
+    member self.Cleanup()  =
+        Directory.Delete (def_cnfg.outdir, recursive = true )
+
+[<EntryPoint>]
+let main _ =
+    BenchmarkRunner.Run typeof<Pipelining> |> ignore
+    0

Bench/Bench.fsproj

@@ -0,0 +1,23 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <OutputType>Exe</OutputType>
+    <TargetFramework>net6.0</TargetFramework>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <Compile Include="Bench.fs" />
+  </ItemGroup>
+
+  <ItemGroup>
+    <ProjectReference Include="../Lib/Lib.fsproj" />
+  </ItemGroup>
+
+  <ItemGroup>
+    <PackageReference Include="BenchmarkDotNet" Version="0.13.8" />
+    <PackageReference Include="fsCheck" Version="3.3.1" />
+    <PackageReference Include="OpenCvSharp4" Version="4.11.0.20250507" />
+    <PackageReference Include="OpenCvSharp4.official.runtime.linux-x64" Version="4.11.0.20250507" />
+  </ItemGroup>
+
+</Project>

LICENSE

@@ -0,0 +1,21 @@
+MIT License
+
+Copyright (c) 2025 Nikita Shchutskii
+
+Permission is hereby granted, free of charge, to any person obtaining a copy
+of this software and associated documentation files (the "Software"), to deal
+in the Software without restriction, including without limitation the rights
+to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+copies of the Software, and to permit persons to whom the Software is
+furnished to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in all
+copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+SOFTWARE.

Lib/Conv.fs

@@ -0,0 +1,99 @@
+module Conv
+
+open OpenCvSharp
+open System.Threading.Tasks
+
+let (@@) = (<|)
+
+let curry3 f a1 a2 a3 = f (a1, a2, a3)
+let (~~~) = curry3
+
+let ind (m: Mat) = m.GetGenericIndexer<byte>()
+let ind_fl (m: Mat) = m.GetGenericIndexer<float32>()
+
+type rectSideSize =
+    | UnLimited
+    | Limited of int
+
+type paral_method =
+    | Seql
+    | ByPixel
+    | ByRow
+    | ByColumn
+    | ByRect of rectSideSize * rectSideSize
+
+let conv src dest kernel paral_method =
+
+    let src_indr, dest_indr, kernel_indr = ind src, ind dest, ind_fl kernel
+
+    let calc1 x y =
+        byte
+        @@ min (float32 255)
+        @@ max (float32 0)
+        @@ Seq.fold (+) (float32 0)
+        @@ seq {
+            for ky in 0 .. kernel.Height - 1 do
+                for kx in 0 .. kernel.Width - 1 ->
+                    let m, n = (kernel.Height / 2) - ky, (kernel.Width / 2) - kx
+                    let (-) x y upper = max 0 @@ min (upper - 1) @@ (-) x y
+
+                    (float32 @@ src_indr.get_Item ((-) y m src.Height, (-) x n src.Width))
+                    * (kernel_indr.get_Item (ky, kx))
+        }
+
+    match paral_method with
+    | Seql ->
+        for y in 0 .. src.Height - 1 do
+            for x in 0 .. src.Width - 1 do
+                ~~~ dest_indr.set_Item y x @@ calc1 x y
+    | ByPixel ->
+        for y in 0 .. src.Height - 1 do
+            Parallel.For(
+                0,
+                src.Width,
+                fun x ->
+
+                    ~~~ dest_indr.set_Item y x @@ calc1 x y
+
+            )
+            |> ignore
+    | ByRow ->
+        Parallel.For(
+            0,
+            src.Height,
+            fun y ->
+                for x in 0 .. src.Width - 1 do
+                    ~~~ dest_indr.set_Item y x @@ calc1 x y
+        )
+        |> ignore
+    | ByColumn ->
+        Parallel.For(
+            0,
+            src.Width,
+            fun x ->
+                for y in 0 .. src.Height - 1 do
+                    ~~~ dest_indr.set_Item y x @@ calc1 x y
+        )
+        |> ignore
+    | ByRect(xS, yS) ->
+
+        let xS, yS =
+            (fun f -> f src.Height xS, f src.Width yS)
+            @@ fun def ->
+                function
+                | Limited n when n > 0 && n < def -> n
+                | UnLimited -> def
+                | Limited n when n > 0 -> def
+                | _ -> failwith "side size shoudn't be less then 1 pixel"
+
+        Parallel.ForEach(
+            seq {
+                for starty in 0..yS .. src.Height - 1 do
+                    for startx in 0..xS .. src.Width - 1 -> (starty, startx)
+            },
+            fun (starty, startx) ->
+                for y in starty .. min (src.Height - 1) (starty + yS) do
+                    for x in startx .. min (src.Width - 1) (startx + xS) do
+                        ~~~ dest_indr.set_Item y x @@ calc1 x y
+        )
+        |> ignore