Merge pull request #366 from lobsterjerusalem/add-sleeps-for-atomics

Adds sleeps

Author: j-baines

c2/cli/basic.go

@@ -49,6 +49,7 @@ func backgroundResponse(ch *channel.Channel, wg *sync.WaitGroup, conn net.Conn,
 			// below. I that that's tolerable for now.
 			responseCh <- string(responseBuffer[:bytesRead])
 		}
+		time.Sleep(10 * time.Millisecond)
 	}
 }
 
@@ -83,6 +84,7 @@ func Basic(conn net.Conn, ch *channel.Channel) {
 				output.PrintShell(response)
 			default:
 			}
+			time.Sleep(10 * time.Millisecond)
 		}
 	}(ch)
 
@@ -109,6 +111,7 @@ func Basic(conn net.Conn, ch *channel.Channel) {
 
 				break
 			}
+			time.Sleep(10 * time.Millisecond)
 		}
 	}(ch)
 

c2/httpservefile/httpservefile.go

@@ -265,6 +265,7 @@ func (httpServer *Server) Run(timeout int) {
 
 						break
 					}
+					time.Sleep(10 * time.Millisecond)
 				}
 			}()
 			// Handle timeouts
@@ -292,6 +293,7 @@ func (httpServer *Server) Run(timeout int) {
 
 						break
 					}
+					time.Sleep(10 * time.Millisecond)
 				}
 			}()
 			// Handle timeouts

c2/httpserveshell/httpserveshell.go

@@ -33,6 +33,7 @@ package httpserveshell
 import (
 	"flag"
 	"sync"
+	"time"
 	"sync/atomic"
 	"time"
 
@@ -207,6 +208,7 @@ func (serveShell *Server) Run(timeout int) {
 
 				break
 			}
+			time.Sleep(10 * time.Millisecond)
 		}
 	}()
 	go func() {
@@ -227,6 +229,7 @@ func (serveShell *Server) Run(timeout int) {
 
 						break
 					}
+					time.Sleep(10 * time.Millisecond)
 				}
 			}()
 		} else {
@@ -240,6 +243,7 @@ func (serveShell *Server) Run(timeout int) {
 
 						break
 					}
+					time.Sleep(10 * time.Millisecond)
 				}
 			}()
 		}

c2/httpshellserver/httpshellserver.go

@@ -244,6 +244,7 @@ func (httpServer *Server) Run(timeout int) {
 
 						break
 					}
+					time.Sleep(10 * time.Millisecond)
 				}
 			}()
 			// Handle timeouts
@@ -271,6 +272,7 @@ func (httpServer *Server) Run(timeout int) {
 
 						break
 					}
+					time.Sleep(10 * time.Millisecond)
 				}
 			}()
 			// Handle timeouts

c2/shelltunnel/shelltunnel.go

@@ -191,6 +191,7 @@ func (shellTunnel *Server) Run(timeout int) {
 
 				break
 			}
+			time.Sleep(10 * time.Millisecond)
 		}
 	}()
 
@@ -214,6 +215,7 @@ func (shellTunnel *Server) Run(timeout int) {
 		// but may not be immediately clear.
 		shellTunnel.Channel().AddSession(&client, client.RemoteAddr().String())
 		go handleTunnelConn(client, shellTunnel.ConnectBackHost, shellTunnel.ConnectBackPort, shellTunnel.ConnectBackSSL, shellTunnel.channel)
+		time.Sleep(10 * time.Millisecond)
 	}
 }
 

c2/simpleshell/simpleshellclient.go

@@ -84,6 +84,7 @@ func (shellClient *Client) Run(timeout int) {
 
 				break
 			}
+			time.Sleep(10 * time.Millisecond)
 		}
 	}()
 

c2/simpleshell/simpleshellserver.go

@@ -107,6 +107,7 @@ func (shellServer *Server) Run(timeout int) {
 
 				break
 			}
+			time.Sleep(10 * time.Millisecond)
 		}
 	}()
 	// Accept arbitrary connections. In the future we need something for the

c2/sslshell/sslshellserver.go

@@ -154,6 +154,7 @@ func (shellServer *Server) Run(timeout int) {
 
 				break
 			}
+			time.Sleep(10 * time.Millisecond)
 		}
 	}()
 	// Accept arbitrary connections. In the future we need something for the