blob: 786050c7da9cbfd2477a7969fb43a5f3166c3b3f (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
|
using System;
using System.Text;
using System.Linq;
using System.Drawing;
using System.Diagnostics;
using System.Windows.Forms;
using System.Threading;
using System.Threading.Tasks;
using System.Collections.Generic;
using Tango.PMR.IO;
using Tango.Stubs;
using Google.Protobuf;
using System.IO;
public void OnExecute(StubManager stubManager)
{
GetStorageInfoRequest getStorageInfoRequest = new GetStorageInfoRequest();
var response = stubManager.Run<GetStorageInfoResponse>(getStorageInfoRequest);
CreateRequest createRequest = new CreateRequest();
createRequest.Attribute = Tango.PMR.IO.FileAttribute.Directory;
createRequest.Path = "0://Shlomo";
var response1 = stubManager.Run<CreateResponse>(createRequest);
DeleteRequest deleteRequest = new DeleteRequest();
deleteRequest.Path = "0://Shlomo//Shlomo1.txt";
var response5 = stubManager.Run<DeleteResponse>(deleteRequest);
deleteRequest.Path = "0://Shlomo//Shlomo2.txt";
response5 = stubManager.Run<DeleteResponse>(deleteRequest);
createRequest.Attribute = 0;
createRequest.Path = "0://Shlomo//Shlomo1.txt";
response1 = stubManager.Run<CreateResponse>(createRequest);
createRequest.Attribute = 0;
createRequest.Path = "0://Shlomo//Shlomo2.txt";
response1 = stubManager.Run<CreateResponse>(createRequest);
byte[] fileBytes = File.ReadAllBytes("C:\\FileSystemTests\\test.txt");
FileUploadRequest fileUploadRequest = new FileUploadRequest();
fileUploadRequest.FileName = "0://Shlomo//Shlomo1.txt";
fileUploadRequest.Length = (int)fileBytes.Length;
FileUploadResponse response2 = stubManager.Run<FileUploadResponse>(fileUploadRequest);
long chunk_size = response2.MaxChunkLength;
FileStream fs = new FileStream("C:\\FileSystemTests\\test.txt",FileMode.Open);
while (fs.Position < fs.Length)
{
stubManager.Write("Position "+ fs.Position+ " Length "+ fs.Length +"\n\n");
FileChunkUploadRequest fileChunkUploadRequest = new FileChunkUploadRequest();
fileChunkUploadRequest.UploadID = response2.UploadID;
byte[] chunk = new byte[Math.Min(chunk_size,fs.Length - fs.Position)];
fs.Read(chunk,0,chunk.Length);
fileChunkUploadRequest.Buffer = ByteString.CopyFrom(chunk);
var response3 = stubManager.Run<FileChunkUploadResponse>(fileChunkUploadRequest);
Thread.Sleep(2000);
}
GetFilesRequest getFilesRequest = new GetFilesRequest();
getFilesRequest.Path = "0://Shlomo";
var response4 = stubManager.Run<GetFilesResponse>(getFilesRequest);
}
|
