diff --git a/cert.pem b/cert.pem deleted file mode 100644 index f9a2028..0000000 --- a/cert.pem +++ /dev/null @@ -1,18 +0,0 @@ ------BEGIN CERTIFICATE----- -MIIC9DCCAdygAwIBAgIQXOymZW4XLjqscy843BeeBzANBgkqhkiG9w0BAQsFADAS -MRAwDgYDVQQKEwdBY21lIENvMB4XDTI0MTAyMDIxMjc1NloXDTI1MTAyMDIxMjc1 -NlowEjEQMA4GA1UEChMHQWNtZSBDbzCCASIwDQYJKoZIhvcNAQEBBQADggEPADCC -AQoCggEBAMFErOjO5LYkiMev4Xma6DX7rmjcyQRau84IyOflajE7LFyUnEDxZJkE -JU57mm06uOLr6XUytkFOFrgeCsWAbraiGhKDH5srBvvNAgah/8RgkIFXASDslEy5 -bI9RZZLe8jJP0cVGvgnZi6aZsDYZm9wlYSgY+9f9QddCb1NQ+/0mu9cluq6v/n3G -q5PhXHt9CnHoYs8hJ+fbJATAogugvfh3zYbkrBUPY73hQ2/dwHy7mdfAieo6i3GR -NP2/YQTHBwBqm6teOlBZ8VfQOyzU8czz1mhbD8GVh5CF/ZWE6tHxxjWG+B53VW/e -yH0LlQQFttNn2bB58W9Bgfov5CBj/30CAwEAAaNGMEQwDgYDVR0PAQH/BAQDAgWg -MBMGA1UdJQQMMAoGCCsGAQUFBwMBMAwGA1UdEwEB/wQCMAAwDwYDVR0RBAgwBocE -TWH5GDANBgkqhkiG9w0BAQsFAAOCAQEAEs4zLQt9n1BLibCmoKwzYDSUK/KQQdcA -8LREoTH6bD+TryzWSQ1zF+WZHbru9pGNO9gkEbmcYwziTVoPmFwblvoc/YoXFp2B -fQiIAZ5+TMtEfdj6agW8+fz00eMKvo1HkbO3RhDj+KYxlED7DL4Tn/ESx7wKtPsX -lSUBK4Chqmj3hB8OCIeDUoMwnCaA1plLfBgcFixtWyYEGv8gXgwrpVqXLfdnGCOI -biFWeLMSXiqZOykJl6fJbOGjkmTsLSDHcyhV2x1+FHviDJYF4WckrkhSmBw+Pspz -OT41o6uP/MFimbFAhCfcPRwHj1vMzfunKvb7UGPJPCWE5oWA7sWsQw== ------END CERTIFICATE----- diff --git a/key.pem b/key.pem deleted file mode 100644 index 170c493..0000000 --- a/key.pem +++ /dev/null @@ -1,28 +0,0 @@ ------BEGIN PRIVATE KEY----- -MIIEvAIBADANBgkqhkiG9w0BAQEFAASCBKYwggSiAgEAAoIBAQDBRKzozuS2JIjH -r+F5mug1+65o3MkEWrvOCMjn5WoxOyxclJxA8WSZBCVOe5ptOrji6+l1MrZBTha4 -HgrFgG62ohoSgx+bKwb7zQIGof/EYJCBVwEg7JRMuWyPUWWS3vIyT9HFRr4J2Yum -mbA2GZvcJWEoGPvX/UHXQm9TUPv9JrvXJbqur/59xquT4Vx7fQpx6GLPISfn2yQE -wKILoL34d82G5KwVD2O94UNv3cB8u5nXwInqOotxkTT9v2EExwcAapurXjpQWfFX -0Dss1PHM89ZoWw/BlYeQhf2VhOrR8cY1hvged1Vv3sh9C5UEBbbTZ9mwefFvQYH6 -L+QgY/99AgMBAAECggEAag7BxFAk+j86QDqoRQ9Y9qbSowDl3tnbzcjMV1Vx3OpY -AcYbqRfO2JmJz3PM3rwm0YAccRAPK+8qUIdL6e3804RJQndqVMBb6LorrnAf5ygG -pLOWDvdEuoXWqR9F2j82MZ3Tw6p6hvU2yYn1RPrwqPJqSpLLQU/dXb87UEFUxyoQ -7bNBNzsulZNd70JJtvmieXU1tf88EdiIxv/Ua9ZRepkkLDJlt3BwsGK+JdVhOhN2 -zUjhlQ4HrErdY6C0rEX7gKznSaThaZb6RYZOLqBfe5nG/uQjw+OfltLEz4nR5xn2 -2F07T0a5hP4WvCgNQRBzsXGYNumJEuSkcadEw8hEkQKBgQD2RAnUlnQ99xqvz3QK -STptQcJOF07DQmEs6A8E7BHue/Z4+gYNtbyQ7NefDYBuGWOzUOXOJs6k//CCgcDe -ZzmtRPs3Sro8AfK0FS09r/OpXL+LPJjhSJ+YEjoVzERSDCvVNshuIO92zlDPITg8 -J9ZsPzXrm+Yh1f5gvSgvmgJodwKBgQDI6FsH7mdjW3bp1tGnF/SzqOBMutyZp7/9 -b7dtJhZNwdi4765JVtLAXDei5kht7NzVlH7GJGcrIen5emKBRS6JjDlhFcFw669V -biOiBrL/3Gu9irjLh2abSBE5r7GClelDLgmJ/JrpkRJRcBtfoPLsYIHtViNXz2CE -w2yf3D+IqwKBgDV7l0r1Fe+zL7eI7WGif67kvicphrB/RQ10pHZkMozBnUiuvAvU -MUykMzvWudKvbuitpAr+gJhzAS/GsDVc47jOp2RdtU58+dHEW5vvD5LzkqHRmj4r -AIYNR1Iel6PeAtL+X88TFg6ORhyF0Wm3GSlPHQ27QOKOT/2Ady7HWsiHAoGAAZ2U -tdCd9jeTEjhPAUf5CMTP4O4TvgySR6hxUihfP4rSglIzFZXkJfXX4LB3XqLr96+1 -AUTjq34fUolAZ4e14xdEktpI7u6GP2qeULw7DkGogCKwb7qMAa2nrc4S4FjyQj8J -hpmIaV5oRk1fevphWbNA+DacHCWnwgmMQxDTVfcCgYAxbQQFyRJ1B+WJtvE66cqA -T/DvgzevwqE4na+NNc6hApZt+kNoLODLUi6ikYimNzdtGnr4AIitvGR3J9qzFC+I -+d2F1ioSV4fpVD7idYDVkncME+pXzzGweg91k8ucHqcdU1k70lYTokGgm3DyClcP -76O6IS1URnFFXco9DGuDcA== ------END PRIVATE KEY----- diff --git a/p2p/testingMetrics.go b/p2p/testingMetrics.go deleted file mode 100644 index 7ab6d7e..0000000 --- a/p2p/testingMetrics.go +++ /dev/null @@ -1,179 +0,0 @@ -package p2p - -import ( - "bytes" - "errors" - "github.com/Akilan1999/p2p-rendering-computation/config" - "io" - "io/ioutil" - "log" - "mime/multipart" - "net/http" - "os" - "time" -) - -// var dlSizes = [...]int{350, 500, 750, 1000, 1500, 2000, 2500, 3000, 3500, 4000} -// var ulSizes = [...]int{100, 300, 500, 800, 1000, 1500, 2500, 3000, 3500, 4000} //kB -var httpclient = http.Client{} - -// DownloadTest executes the test to measure download speed -//func (s *IpAddress) DownloadTest(savingMode bool) error { -// dlURL := "http://" + s.Ipv4 + ":8088/server_info" -// eg := errgroup.Group{} -// -// // Warming up -// sTime := time.Now() -// for i := 0; i < 2; i++ { -// eg.Go(func() error { -// return dlWarmUp("http://" + s.Ipv4 + ":8088/server_info") -// }) -// } -// if err := eg.Wait(); err != nil { -// return err -// } -// fTime := time.Now() -// // 1.125MB for each request (750 * 750 * 2) -// wuSpeed := 1.125 * 8 * 2 / fTime.Sub(sTime.Add(s.Latency)).Seconds() -// -// // Decide workload by warm up speed -// workload := 0 -// weight := 0 -// skip := false -// if savingMode { -// workload = 6 -// weight = 3 -// } else if 10.0 < wuSpeed { -// workload = 16 -// weight = 4 -// } else if 4.0 < wuSpeed { -// workload = 8 -// weight = 4 -// } else if 2.5 < wuSpeed { -// workload = 4 -// weight = 4 -// } else { -// skip = true -// } -// -// // Main speedtest -// dlSpeed := wuSpeed -// if skip == false { -// sTime = time.Now() -// for i := 0; i < workload; i++ { -// eg.Go(func() error { -// return downloadRequest(dlURL, weight) -// }) -// } -// if err := eg.Wait(); err != nil { -// return err -// } -// fTime = time.Now() -// -// reqMB := dlSizes[weight] * dlSizes[weight] * 2 / 1000 / 1000 -// dlSpeed = float64(reqMB) * 8 * float64(workload) / fTime.Sub(sTime).Seconds() -// } -// -// s.Download = dlSpeed -// return nil -//} - -// Download Speed -func (s *IpAddress) DownloadSpeed() error { - start := time.Now() - resp, err := httpclient.Get("http://" + s.Ipv4 + ":8088/50") - if err != nil { - return err - } - defer resp.Body.Close() - ioutil.ReadAll(resp.Body) - t := time.Since(start) - //fmt.Println(s.Seconds()) - // size * time (seconds) - s.Download = (50 / t.Seconds()) * 8 - return nil -} - -func (s *IpAddress) UploadSpeed() error { - start := time.Now() - - // Get upload file path from config file - // Get Path from config - config, err := config.ConfigInit(nil, nil) - if err != nil { - return err - } - - b, w := createMultipartFormData("file", config.SpeedTestFile) - - req, err := http.NewRequest("GET", "http://"+s.Ipv4+":"+s.ServerPort+"/upload", &b) - if err != nil { - return err - } - // Don't forget to set the content type, this will contain the boundary. - req.Header.Set("Content-Type", w.FormDataContentType()) - defer req.Body.Close() - ioutil.ReadAll(req.Body) - t := time.Since(start) - //fmt.Println(s.Seconds()) - // size * time (seconds) - s.Upload = (50 / t.Seconds()) * 8 - return nil -} - -// Upload helper function for uploading -// (https://stackoverflow.com/questions/20205796/post-data-using-the-content-type-multipart-form-data -func createMultipartFormData(fieldName, fileName string) (bytes.Buffer, *multipart.Writer) { - var b bytes.Buffer - var err error - w := multipart.NewWriter(&b) - var fw io.Writer - file := mustOpen(fileName) - if fw, err = w.CreateFormFile(fieldName, file.Name()); err != nil { - log.Fatalf("Error creating writer: %v", err) - } - if _, err = io.Copy(fw, file); err != nil { - log.Fatalf("Error with io.Copy: %v", err) - //t.Errorf("Error with io.Copy: %v", err) - } - w.Close() - return b, w -} - -func mustOpen(f string) *os.File { - r, err := os.Open(f) - if err != nil { - log.Fatalf("Error with mustOpen: %v", err) - } - return r -} - -// PingTest executes test to measure latency -func (s *IpAddress) PingTest() error { - //pingURL := strings.Split(s.URL, "/upload")[0] + "/latency.txt" - var pingURL string - if s.Ipv6 != "" { - pingURL = "http://[" + s.Ipv6 + "]:" + s.ServerPort + "/server_info" - s.Ipv4 = "" - } else { - pingURL = "http://" + s.Ipv4 + ":" + s.ServerPort + "/server_info" - } - - l := time.Duration(100000000000) // 10sec - for i := 0; i < 3; i++ { - sTime := time.Now() - resp, err := http.Get(pingURL) - fTime := time.Now() - if err != nil || resp.StatusCode != 200 { - return errors.New("Node not found") - } - if fTime.Sub(sTime) < l { - l = fTime.Sub(sTime) - } - resp.Body.Close() - } - - s.Latency = time.Duration(int64(l.Nanoseconds() / 2)) - - return nil -} diff --git a/plugin/TestAnsible/description.txt b/plugin/TestAnsible/description.txt deleted file mode 100644 index b0a0a8f..0000000 --- a/plugin/TestAnsible/description.txt +++ /dev/null @@ -1 +0,0 @@ -Test if it's detected \ No newline at end of file diff --git a/plugin/TestAnsible/hosts b/plugin/TestAnsible/hosts deleted file mode 100644 index 07e4869..0000000 --- a/plugin/TestAnsible/hosts +++ /dev/null @@ -1,12 +0,0 @@ ---- -all: - vars: - ansible_python_interpreter: /usr/bin/python3 -main: - hosts: - host1: - ansible_host: 0.0.0.0 # Replace with your remote IP - ansible_port: 44003 # Replace with your remote SSH port - ansible_user: master # Replace wtih your username - ansible_ssh_pass: password - ansible_sudo_pass: password \ No newline at end of file diff --git a/plugin/TestAnsible/site.yml b/plugin/TestAnsible/site.yml deleted file mode 100644 index f263373..0000000 --- a/plugin/TestAnsible/site.yml +++ /dev/null @@ -1,8 +0,0 @@ ---- - -- hosts: all - - tasks: - - name: simple-ansibleplaybook - debug: - msg: Your are running 'simple-ansibleplaybook' example