Fix CloudWatch issue and Spacing in Output

aws · Nov 15, 2017 · f7f9dd0 · f7f9dd0
1 parent 518833a
commit f7f9dd0
Show file tree

Hide file tree

Showing 4 changed files with 8 additions and 8 deletions.
diff --git a/agent/framework/processor/executer/iohandler/iomodule/commandoutput.go b/agent/framework/processor/executer/iohandler/iomodule/commandoutput.go
@@ -15,7 +15,6 @@ package iomodule
 
 import (
 	"bufio"
-	"bytes"
 	"fmt"
 	"io"
 
@@ -38,17 +37,15 @@ func (c CommandOutput) Read(log log.T, reader *io.PipeReader) {
 	scanner.Split(bufio.ScanBytes)
 
 	outputLimit := 0
-	var buffer bytes.Buffer
 	for scanner.Scan() {
 		// Check if size of output is greater than the output limit
 		outputLimit++
 		if outputLimit > c.OutputLimit {
 			break
 		}
-		buffer.WriteString(scanner.Text())
+		*c.OutputString = fmt.Sprintf("%v%v", *c.OutputString, scanner.Text())
 	}
 	log.Debugf("Number of bytes written to console output: %v", outputLimit)
-	*c.OutputString = fmt.Sprintf("%v%v", *c.OutputString, buffer.String())
 
 	if err := scanner.Err(); err != nil {
 		log.Error("Error with the scanner while reading the stream")

diff --git a/agent/framework/runpluginutil/runpluginutil.go b/agent/framework/runpluginutil/runpluginutil.go
@@ -249,7 +249,6 @@ func runPlugin(
 	default:
 		executePlugin(context, p, pluginName, config, cancelFlag, output)
 	}
-
 	pluginConfig := iohandler.DefaultOutputConfig()
 
 	res.Code = output.GetExitCode()
@@ -271,7 +270,11 @@ func executePlugin(context context.T,
 	var propID string
 	var err error
 	if config.PluginName == config.PluginID {
-		propID, err = GetPropertyName(config.Properties) //V10 Schema
+		if pluginName == appconfig.PluginNameCloudWatch {
+			propID = appconfig.PluginNameCloudWatch
+		} else {
+			propID, err = GetPropertyName(config.Properties) //V10 Schema
+		}
 	} else {
 		propID = config.PluginID //V20 Schema
 	}

diff --git a/agent/longrunning/manager/invoke.go b/agent/longrunning/manager/invoke.go
@@ -67,7 +67,7 @@ func Invoke(log logger.T, pluginID string, res *contracts.PluginResult, orchestr
 		}
 
 	default:
-		log.Errorf("Allowed Values of StartType: Enabled | Disabled")
+		log.Errorf("Allowed Values of StartType: Enabled | Disabled but provided value is: %s", startType)
 		CreateResult("Allowed Values of StartType: Enabled | Disabled",
 			contracts.ResultStatusFailed, res)
 	}

diff --git a/agent/plugins/lrpminvoker/invoker.go b/agent/plugins/lrpminvoker/invoker.go
@@ -90,7 +90,7 @@ func (p *Plugin) Execute(context context.T, config contracts.Configuration, canc
 	} else {
 		property := p.prepareForStart(log, config, cancelFlag, output)
 		output.SetOutput(property)
-		output.SetStdout(setting.StartType)
+		output.AppendInfo(setting.StartType)
 	}
 
 	return