forked from v.moiseev/distributed-computing
done
This commit is contained in:
38
tasks/mytarin_es/lab2/worker-1/Program.cs
Normal file
38
tasks/mytarin_es/lab2/worker-1/Program.cs
Normal file
@@ -0,0 +1,38 @@
|
||||
using System.Text;
|
||||
|
||||
string[] f = Directory.GetFiles("../var/data");
|
||||
|
||||
string maxPath = "";
|
||||
|
||||
long maxCapacity = 0;
|
||||
|
||||
foreach (var path in f)
|
||||
{
|
||||
FileInfo info = new FileInfo(path);
|
||||
|
||||
if (info.Length > maxCapacity)
|
||||
{
|
||||
maxCapacity = info.Length;
|
||||
|
||||
maxPath = path;
|
||||
}
|
||||
}
|
||||
using (FileStream stream_read = File.OpenRead(maxPath))
|
||||
{
|
||||
byte[] bufffer_read = new byte[stream_read.Length];
|
||||
|
||||
await stream_read.ReadAsync(bufffer_read, 0, bufffer_read.Length);
|
||||
|
||||
string text = Encoding.Default.GetString(bufffer_read);
|
||||
|
||||
using (FileStream stream_write = new FileStream("../var/result/data.txt", FileMode.OpenOrCreate))
|
||||
{
|
||||
stream_write.SetLength(0);
|
||||
|
||||
byte[] buffer_write = Encoding.Default.GetBytes(text);
|
||||
|
||||
await stream_write.WriteAsync(buffer_write, 0, buffer_write.Length);
|
||||
}
|
||||
}
|
||||
|
||||
Console.WriteLine("Программа 1 завершена");
|
||||
Reference in New Issue
Block a user