angelina/distributed-computing
1
0
Fork 0
forked from v.moiseev/distributed-computing
Code Pull Requests Activity

lr 3 #2

Merged
angelina merged 113 commits from v.moiseev/distributed-computing:main into main 2023-12-07 18:07:15 +04:00
Conversation 0 Commits 113 Files Changed 410 +4 -4
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit 38083bcc01 - Show all commits

4
tasks/kazakov-ev/lab_2/worker-1/Program.cs
View File

@ -1,6 +1,6 @@
using System.Text;
string[] files = Directory.GetFiles("../../../../var/data");
string[] files = Directory.GetFiles("/var/data");
string FilePath = "";
long maxFileLenght = 0;
foreach(var filePath in files){
@ -14,7 +14,7 @@ using (FileStream fstream = File.OpenRead(FilePath)){
byte[] buffer = new byte[fstream.Length];
await fstream.ReadAsync(buffer, 0, buffer.Length);
string text = Encoding.Default.GetString(buffer);
using(FileStream fstream1 = new FileStream("../../../../var/result/data.txt", FileMode.OpenOrCreate)){
using(FileStream fstream1 = new FileStream("/var/result/data.txt", FileMode.OpenOrCreate)){
fstream1.SetLength(0);
byte[] buffer1 = Encoding.Default.GetBytes(text);
await fstream1.WriteAsync(buffer1, 0, buffer1.Length);

4
tasks/kazakov-ev/lab_2/worker-2/Program.cs
View File

@ -1,7 +1,7 @@
using System.Text;
string[] numbers;
using (FileStream fstream = File.OpenRead("../../../../var/result/data.txt")){
using (FileStream fstream = File.OpenRead("/var/result/data.txt")){
byte[] buffer = new byte[fstream.Length];
await fstream.ReadAsync(buffer, 0, buffer.Length);
string text = Encoding.Default.GetString(buffer);
@ -16,7 +16,7 @@ foreach(var number in numbers){
n = maxNumber*maxNumber;
}
}
using(FileStream fstream = new FileStream("../../../../var/result/result.txt", FileMode.OpenOrCreate)){
using(FileStream fstream = new FileStream("/var/result/result.txt", FileMode.OpenOrCreate)){
byte[] buffer = Encoding.Default.GetBytes(n.ToString());
await fstream.WriteAsync(buffer, 0, buffer.Length);
}