sem/Proftaak-RH-B4
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix

Browse Source
This commit is contained in:
shinichi
2020-10-07 11:54:47 +02:00
parent 5d14d53df5
commit 7c943f4f73
2 changed files with 21 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
Server/Client.cs
View File

@@ -154,7 +154,7 @@ namespace Server
temp++; temp++;
if (temp > 50) if (temp > 50)
{ {
Console.WriteLine(BitConverter.ToString(this.saveData?.getBPMgraphData(100, 1))); Console.WriteLine(BitConverter.ToString(this.saveData?.getBPMgraphData(10, 2)));
temp = 0; temp = 0;
} }
} }

28
Server/SaveData.cs
View File

@@ -63,12 +63,20 @@ namespace Server
{ {
// do nothing // do nothing
} }
using (BinaryWriter sw = new BinaryWriter(File.Open(fileLocation, FileMode.Create))) using (var fileStream = new FileStream(fileLocation, FileMode.Append, FileAccess.Write, FileShare.None))
using (var bw = new BinaryWriter(fileStream))
{ {
sw.Seek(length, SeekOrigin.End); //sw.BaseStream.Seek(length, SeekOrigin.Begin);
sw.Write(data); bw.Write(data);
sw.Flush(); bw.Flush();
//Console.WriteLine("wrote at " + bw.BaseStream.Position);
} }
//using (BinaryReader binaryReader = new BinaryReader(File.Open(fileLocation, FileMode.Open)))
//{
// byte[] totalArray = new byte[binaryReader.BaseStream.Length];
// binaryReader.BaseStream.Read(totalArray, 0, (int)binaryReader.BaseStream.Length);
// Console.WriteLine("all data is " + BitConverter.ToString(totalArray));
//}
} }
/// <summary> /// <summary>
@@ -86,7 +94,7 @@ namespace Server
{ {
FileInfo fi = new FileInfo(this.path + rawBPMFilename); FileInfo fi = new FileInfo(this.path + rawBPMFilename);
int length = (int)fi.Length; int length = (int)fi.Length;
Console.WriteLine("length " + length); //Console.WriteLine("length " + length);
byte[] output = new byte[outputSize]; byte[] output = new byte[outputSize];
@@ -94,16 +102,20 @@ namespace Server
int readSize = messageSize * averageOver; int readSize = messageSize * averageOver;
byte[] readBuffer = new byte[readSize]; byte[] readBuffer = new byte[readSize];
using (FileStream fileStream = new FileStream(this.path + rawBPMFilename, FileMode.Open, FileAccess.Read)) using (BinaryReader binaryReader = new BinaryReader(File.Open(this.path + rawBPMFilename, FileMode.Open)))
{ {
//byte[] totalArray = new byte[binaryReader.BaseStream.Length];
//binaryReader.BaseStream.Read(totalArray, 0, (int)binaryReader.BaseStream.Length);
//Console.WriteLine("all data is " + BitConverter.ToString(totalArray));
for (int i = 1; i <= outputSize; i++) for (int i = 1; i <= outputSize; i++)
{ {
if (length - (i * readSize) < 0) if (length - (i * readSize) < 0)
{ {
break; break;
} }
Console.WriteLine("reading " + (length - (i * readSize) - 1) + " and size " + readSize); binaryReader.BaseStream.Seek(length - (i * readSize), SeekOrigin.Begin);
fileStream.Read(readBuffer, length - (i * readSize) - 1, readSize); binaryReader.BaseStream.Read(readBuffer, 0, readSize);
//Console.WriteLine("read " + binaryReader.BaseStream.Position + " and size " + readSize + " with value " + BitConverter.ToString(readBuffer));
//handling data //handling data
int total = 0; int total = 0;