From 5925ae711a934611ed1f7686b3eddf7a62eb8566 Mon Sep 17 00:00:00 2001 From: Reece Williams Date: Wed, 16 Oct 2024 13:11:19 -0500 Subject: [PATCH] increase buffer size --- .../interchain/handlers/container_log_stream.go | 16 +--------------- 1 file changed, 1 insertion(+), 15 deletions(-) diff --git a/local-interchain/interchain/handlers/container_log_stream.go b/local-interchain/interchain/handlers/container_log_stream.go index 1204bbe98..31cadac73 100644 --- a/local-interchain/interchain/handlers/container_log_stream.go +++ b/local-interchain/interchain/handlers/container_log_stream.go @@ -54,20 +54,6 @@ func (cs *ContainerStream) StreamContainer(w http.ResponseWriter, r *http.Reques containerID := r.URL.Query().Get("id") if containerID == "" { - // TODO: use this for other sidecar containers that are made? (need to test) - // returns containers only for this testnet. other containers are not shown on this endpoint - // c, err := cs.cli.ContainerList(cs.ctx, dockertypes.ContainerListOptions{ - // Filters: filters.NewArgs(filters.Arg("label", dockerutil.CleanupLabel+"="+cs.testName)), - // }) - // if err != nil { - // http.Error(w, "Unable to get container list", http.StatusInternalServerError) - // return - // } - // availableContainers := []string{} - // for _, container := range c { - // availableContainers = append(availableContainers, container.ID) - // } - output := "No container ID provided. Available containers:\n" for name, id := range cs.nameToID { output += fmt.Sprintf("- %s: %s\n", name, id) @@ -116,7 +102,7 @@ func (cs *ContainerStream) StreamContainer(w http.ResponseWriter, r *http.Reques } for { - buf := make([]byte, 1024) + buf := make([]byte, 8*1024) n, err := rr.Read(buf) if err != nil { break