summaryrefslogtreecommitdiff
path: root/lgc
diff options
context:
space:
mode:
authorWill Hawkins <[email protected]>2022-06-04 21:24:19 -0400
committerWill Hawkins <[email protected]>2022-06-04 21:24:19 -0400
commit9be87fa5ec89c9e393c9c93b3cb36668c71593d6 (patch)
tree7c5a5df400370660c670935dc36e2e4b0493ab86 /lgc
parentde7a7bf994a020049eca89098aab9d13ff81f361 (diff)
[Feature] Add conditional compilation support for GetTCPInfo
Now there is functionality for conditionally supporting GetTCPInfo depending on the platform. If the platform supports it, then the client can call utilities.GetTCPInfo. In the case that the platform does not support the GetTCPInfo function call, the result is an error of the type `NotImplemented`.
Diffstat (limited to 'lgc')
-rw-r--r--lgc/lgc.go31
1 files changed, 16 insertions, 15 deletions
diff --git a/lgc/lgc.go b/lgc/lgc.go
index 5b35fd1..fb51ec1 100644
--- a/lgc/lgc.go
+++ b/lgc/lgc.go
@@ -281,40 +281,40 @@ func (lgd *LoadGeneratingConnectionDownload) Start(
go lgd.doDownload(ctx)
return true
}
-func (lbd *LoadGeneratingConnectionDownload) IsValid() bool {
- return lbd.valid
+func (lgd *LoadGeneratingConnectionDownload) IsValid() bool {
+ return lgd.valid
}
-func (lbd *LoadGeneratingConnectionDownload) Stats() *stats.TraceStats {
- return &lbd.stats
+func (lgd *LoadGeneratingConnectionDownload) Stats() *stats.TraceStats {
+ return &lgd.stats
}
-func (lbd *LoadGeneratingConnectionDownload) doDownload(ctx context.Context) {
+func (lgd *LoadGeneratingConnectionDownload) doDownload(ctx context.Context) {
var request *http.Request = nil
var get *http.Response = nil
var err error = nil
if request, err = http.NewRequestWithContext(
- httptrace.WithClientTrace(ctx, lbd.tracer),
+ httptrace.WithClientTrace(ctx, lgd.tracer),
"GET",
- lbd.Path,
+ lgd.Path,
nil,
); err != nil {
- lbd.valid = false
+ lgd.valid = false
return
}
- lbd.downloadStartTime = time.Now()
- lbd.lastIntervalEnd = 0
+ lgd.downloadStartTime = time.Now()
+ lgd.lastIntervalEnd = 0
- if get, err = lbd.client.Do(request); err != nil {
- lbd.valid = false
+ if get, err = lgd.client.Do(request); err != nil {
+ lgd.valid = false
return
}
- cr := &countingReader{n: &lbd.downloaded, ctx: ctx, readable: get.Body}
+ cr := &countingReader{n: &lgd.downloaded, ctx: ctx, readable: get.Body}
_, _ = io.Copy(ioutil.Discard, cr)
get.Body.Close()
- if debug.IsDebug(lbd.debug) {
+ if debug.IsDebug(lgd.debug) {
fmt.Printf("Ending a load-generating download.\n")
}
}
@@ -426,6 +426,7 @@ func (lgu *LoadGeneratingConnectionUpload) Start(
return true
}
-func (lbd *LoadGeneratingConnectionUpload) Stats() *stats.TraceStats {
+func (lgu *LoadGeneratingConnectionUpload) Stats() *stats.TraceStats {
+ // Get all your stats from the download side of the LGC.
return nil
}