|
|
Imports Microsoft.VisualBasic.CommandLine.Reflection
|
|
|
Imports Microsoft.VisualBasic.ComputingServices.FileSystem
|
|
|
Imports Microsoft.VisualBasic.ComputingServices.FileSystem.Protocols
|
|
|
Imports Microsoft.VisualBasic.ComputingServices.TaskHost
|
|
|
Imports Microsoft.VisualBasic.LINQ.Extensions
|
|
|
Imports Microsoft.VisualBasic.Net
|
|
|
|
|
|
''' <summary>
|
|
|
''' 我想要构建的是一个去中心化的网格计算框架
|
|
|
''' </summary>
|
|
|
Module ServicesProgram
|
|
|
|
|
|
Public Function Main() As Integer
|
|
|
|
|
|
Dim filertwer As New FileURI("Z:\日漫\[160127] TVアニメ 「だがしかし」 (Dagashi Kashi) OPテーマ 「Checkmate!？」／M\01. Checkmate!.flac", New IPEndPoint("192.168.2.2", 55))
|
|
|
|
|
|
Dim off As New FileURI(filertwer.ToString)
|
|
|
|
|
|
off = New FileURI("Z:\日漫\[160127] TVアニメ 「だがしかし」 (Dagashi Kashi) OPテーマ 「Checkmate!？」／M\01. Checkmate!.flac")
|
|
|
|
|
|
Dim DIR As New FileSystemHost(1526)
|
|
|
Dim fs As New FileSystem(DIR.Portal)
|
|
|
|
|
|
Dim file As New IO.FileStream("Z:\1ST.MP3", System.IO.FileMode.Open, fs)
|
|
|
|
|
|
Dim buf As Byte() = New Byte(5 * 1024 * 100) {}
|
|
|
Call file.Read(buf, Scan0, buf.Length)
|
|
|
Call buf.FlushStream("x:\1....sdfgsdf.mp3")
|
|
|
|
|
|
Dim writeFile As New IO.FileStream("x:\2....dfgdfghf.mp3", System.IO.FileMode.OpenOrCreate, fs)
|
|
|
Call writeFile.Write(buf, Scan0, buf.Length)
|
|
|
|
|
|
Return GetType(ServicesProgram).RunCLI(App.CommandLine, AddressOf TestLocal)
|
|
|
End Function
|
|
|
|
|
|
Private Sub __testLinq()
|
|
|
Dim array = 20.Sequence
|
|
|
Dim source As New LinqProvider(array, GetType(Integer))
|
|
|
Call Threading.Thread.Sleep(100)
|
|
|
Dim reader As New ILinq(Of Integer)(source.Portal)
|
|
|
|
|
|
Dim xr = (From x In reader Where x > 10 Select x).ToArray
|
|
|
End Sub
|
|
|
|
|
|
''' <summary>
|
|
|
''' Example of running on local machine
|
|
|
''' </summary>
|
|
|
''' <returns></returns>
|
|
|
Public Function TestLocal() As Integer
|
|
|
Call __testLinq()
|
|
|
|
|
|
Dim exe As String = App.ExecutablePath
|
|
|
Dim port As Integer = Microsoft.VisualBasic.Net.GetFirstAvailablePort
|
|
|
|
|
|
' Call Process.Start(exe, $"/remote /port {port}").Start() ' example test
|
|
|
' Call Threading.Thread.Sleep(1500)
|
|
|
Dim invoke As New TaskInvoke(port)
|
|
|
Dim remote As New TaskHost("127.0.0.1", port)
|
|
|
Dim msg As String = "Code execute on the remotes!"
|
|
|
Dim remoteFunc As Func(Of String, Integer) = AddressOf TestExample1 ' Gets the function pointer on the remote machine
|
|
|
|
|
|
Call remote.Invoke(Of Integer)(remoteFunc, msg).__DEBUG_ECHO ' gets the value that returns from the remote machine
|
|
|
|
|
|
End Function
|
|
|
|
|
|
Public Function TestExample1(msg As String) As Integer
|
|
|
Call MsgBox(msg, MsgBoxStyle.Information, App.Command) ' remotes have the commandline but the local is empty
|
|
|
Return 100000 * RandomDouble()
|
|
|
End Function
|
|
|
|
|
|
''' <summary>
|
|
|
''' Example of running on a remote machine.
|
|
|
''' </summary>
|
|
|
''' <returns></returns>
|
|
|
'''
|
|
|
<ExportAPI("/remote", Usage:="/remote [/port <port, default:=1234>]")>
|
|
|
Public Function TestRemote(args As CommandLine.CommandLine) As Integer
|
|
|
Dim port As Integer = args.GetValue("/port", 1234)
|
|
|
Dim invoke As New TaskInvoke(port)
|
|
|
|
|
|
Call Pause()
|
|
|
|
|
|
Return 0
|
|
|
End Function
|
|
|
End Module
|
