No commit message

hhblaze · Sep 4, 2017 · fab6cc2 · fab6cc2
1 parent 3deb660
commit fab6cc2
Show file tree

Hide file tree

Showing 27 changed files with 226 additions and 36 deletions.
diff --git a/Process1/Process1/Form1.cs b/Process1/Process1/Form1.cs
@@ -100,17 +100,17 @@ async void t001_TestIntensiveParallel()
             //});
 
 
-            sw = new System.Diagnostics.Stopwatch();
-            sw.Start();
-            for (int j = 0; j < 1000; j++)
-            {
-                var tor = await sm.RemoteRequestAsync(new byte[50000], null);
+            //sw = new System.Diagnostics.Stopwatch();
+            //sw.Start();
+            //for (int j = 0; j < 1000; j++)
+            //{
+            //    var tor = await sm.RemoteRequestAsync(new byte[50000], null);
 
-            }
-            sw.Stop();
-            Console.WriteLine("ELAPS: " + sw.ElapsedMilliseconds);
-            //MessageBox.Show("ELAPS: " + sw.ElapsedMilliseconds);
-            return;
+            //}
+            //sw.Stop();
+            //Console.WriteLine("ELAPS: " + sw.ElapsedMilliseconds);
+            ////MessageBox.Show("ELAPS: " + sw.ElapsedMilliseconds);
+            //return;
 
 
             //sw = new System.Diagnostics.Stopwatch();
@@ -134,7 +134,7 @@ async void t001_TestIntensiveParallel()
             sw.Start();
             for (int j = 0; j < 1000; j++)
             {
-                var tor = sm.RemoteRequest(new byte[50000], null);
+                var tor = sm.RemoteRequest(new byte[512], null);
 
             }
             sw.Stop();
@@ -167,8 +167,9 @@ async void t001_TestIntensiveParallel()
             {
                 for (int j = 0; j < 1000; j++)
                 {
-                    //var tor = sm.RemoteRequest(new byte[50]);
-                    var tor = sm.RemoteRequest(new byte[50],null);
+                    var tor = sm.RemoteRequest(new byte[512]);
+                    //var tor = sm.RemoteRequest(new byte[50],(par) => {
+                    //});
                     //Console.WriteLine(DateTime.UtcNow.ToString("HH:mm:ss.ms") + "> masterRes " +tor.Item1 + " " + tor.Item2.Length);
                 }
             };
@@ -182,7 +183,7 @@ async void t001_TestIntensiveParallel()
 
             sw = new System.Diagnostics.Stopwatch();
             sw.Start();
-            Task.WaitAll(tasks.ToArray());
+            await Task.WhenAll(tasks.ToArray());
             sw.Stop();
             Console.WriteLine("ELAPS: " + sw.ElapsedMilliseconds);
         }

diff --git a/Process1/Process1/bin/Debug/Process1.exe b/Process1/Process1/bin/Debug/Process1.exe
diff --git a/Process1/Process1/bin/Debug/Process1.pdb b/Process1/Process1/bin/Debug/Process1.pdb
diff --git a/Process1/Process1/bin/Debug/SharmIpc.dll b/Process1/Process1/bin/Debug/SharmIpc.dll
diff --git a/Process1/Process1/bin/Debug/SharmIpc.pdb b/Process1/Process1/bin/Debug/SharmIpc.pdb
diff --git a/Process1/Process1/bin/Release/Process1.exe b/Process1/Process1/bin/Release/Process1.exe
diff --git a/Process1/Process1/bin/Release/Process1.pdb b/Process1/Process1/bin/Release/Process1.pdb
diff --git a/Process1/Process1/bin/Release/SharmIpc.dll b/Process1/Process1/bin/Release/SharmIpc.dll
diff --git a/Process1/Process1/bin/Release/SharmIpc.pdb b/Process1/Process1/bin/Release/SharmIpc.pdb
diff --git a/Process1/SharmIpc/ReaderWriterHandler.cs b/Process1/SharmIpc/ReaderWriterHandler.cs
@@ -360,8 +360,8 @@ unsafe void StartSendProcedure()
 
             }
 
-            Task.Run(() =>
-            {
+            //Task.Run(() =>
+            //{
                 //here we got smth toSend
                 while (true)
                 {
@@ -400,7 +400,7 @@ unsafe void StartSendProcedure()
                     }
                 }//eo while
 
-            });
+            //});
 
         }//eof
 
@@ -421,8 +421,8 @@ unsafe void StartSendProcedure_v2()
 
             }
 
-            Task.Run(() =>
-            {
+            //Task.Run(() =>
+            //{
                 uint p = 0;
                 int ptr = 0;
 
@@ -502,7 +502,7 @@ unsafe void StartSendProcedure_v2()
                     }
                 }//eo while
 
-            });
+            //});
 
         }//eof
 

diff --git a/Process1/SharmIpc/bin/Debug/SharmIpc.dll b/Process1/SharmIpc/bin/Debug/SharmIpc.dll
diff --git a/Process1/SharmIpc/bin/Debug/SharmIpc.pdb b/Process1/SharmIpc/bin/Debug/SharmIpc.pdb
diff --git a/Process1/SharmIpc/bin/Release/SharmIpc.dll b/Process1/SharmIpc/bin/Release/SharmIpc.dll
diff --git a/Process1/SharmIpc/bin/Release/SharmIpc.pdb b/Process1/SharmIpc/bin/Release/SharmIpc.pdb
diff --git a/Process1/SharmIpc462/bin/Release/SharmIpc.dll b/Process1/SharmIpc462/bin/Release/SharmIpc.dll
diff --git a/Process1/SharmIpc462/bin/Release/SharmIpc.pdb b/Process1/SharmIpc462/bin/Release/SharmIpc.pdb
diff --git a/Process1/SharmIpcUWP/bin/Release/SharmIpc.dll b/Process1/SharmIpcUWP/bin/Release/SharmIpc.dll
diff --git a/Process1/SharmIpcUWP/bin/Release/SharmIpc.pdb b/Process1/SharmIpcUWP/bin/Release/SharmIpc.pdb
diff --git a/Process1/SharmIpcUWP/project.lock.json b/Process1/SharmIpcUWP/project.lock.json
diff --git a/Process2/.vs/Process2/v15/.suo b/Process2/.vs/Process2/v15/.suo
diff --git a/Process2/.vs/Process2/v15/sqlite3/storage.ide b/Process2/.vs/Process2/v15/sqlite3/storage.ide
diff --git a/Process2/Form1.cs b/Process2/Form1.cs
@@ -31,7 +31,9 @@ Tuple<bool, byte[]> RemoteCall(byte[] data)
 
         void AsyncRemoteCallHandler(ulong msgId, byte[] data)
         {
-            sm.AsyncAnswerOnRemoteCall(msgId, new Tuple<bool, byte[]>(true, new byte[] { 9 }));
+            //sm.AsyncAnswerOnRemoteCall(msgId, new Tuple<bool, byte[]>(true, new byte[] { 9 }));
+
+            sm.AsyncAnswerOnRemoteCall(msgId, new Tuple<bool, byte[]>(true, new byte[512]));
 
             //Task.Run(() =>
             //{

diff --git a/Process2/bin/Debug/Process2.exe b/Process2/bin/Debug/Process2.exe
diff --git a/Process2/bin/Debug/Process2.pdb b/Process2/bin/Debug/Process2.pdb
diff --git a/Process2/bin/Debug/SharmIpc.dll b/Process2/bin/Debug/SharmIpc.dll
diff --git a/Process2/bin/Debug/SharmIpc.pdb b/Process2/bin/Debug/SharmIpc.pdb
diff --git a/SharmIPC.1.11.0.nupkg b/SharmIPC.1.11.0.nupkg