github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-23 11:50:44 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #84045 from bclau/tests/agnhost-netexec-changes

Browse Source 
tests: Extends agnhost netexec udp buffers
This commit is contained in:
Kubernetes Prow Robot 2019-10-30 18:23:36 -07:00 committed by GitHub
commit da5b90a8c3
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
4 changed files with 11 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
test/images/agnhost/README.md
View File

@ -40,7 +40,7 @@ For example, let's consider the following `pod.yaml` file:
containers: containers:
- args: - args:
- dns-suffix - dns-suffix
image: gcr.io/kubernetes-e2e-test-images/agnhost:2.2 image: gcr.io/kubernetes-e2e-test-images/agnhost:2.7
name: agnhost name: agnhost
dnsConfig: dnsConfig:
nameservers: nameservers:
@ -258,14 +258,14 @@ Examples:
```console ```console
docker run -i \ docker run -i \
gcr.io/kubernetes-e2e-test-images/agnhost:2.2 \ gcr.io/kubernetes-e2e-test-images/agnhost:2.7 \
logs-generator --log-lines-total 10 --run-duration 1s logs-generator --log-lines-total 10 --run-duration 1s
``` ```
```console ```console
kubectl run logs-generator \ kubectl run logs-generator \
--generator=run-pod/v1 \ --generator=run-pod/v1 \
--image=gcr.io/kubernetes-e2e-test-images/agnhost:2.2 \ --image=gcr.io/kubernetes-e2e-test-images/agnhost:2.7 \
--restart=Never \ --restart=Never \
-- logs-generator -t 10 -d 1s -- logs-generator -t 10 -d 1s
``` ```
@ -392,7 +392,7 @@ Usage:
```console ```console
kubectl run test-agnhost \ kubectl run test-agnhost \
--generator=run-pod/v1 \ --generator=run-pod/v1 \
--image=gcr.io/kubernetes-e2e-test-images/agnhost:2.2 \ --image=gcr.io/kubernetes-e2e-test-images/agnhost:2.7 \
--restart=Never \ --restart=Never \
--env "POD_IP=<POD_IP>" \ --env "POD_IP=<POD_IP>" \
--env "NODE_IP=<NODE_IP>" \ --env "NODE_IP=<NODE_IP>" \
@ -447,7 +447,7 @@ Usage:
```console ```console
kubectl run test-agnhost \ kubectl run test-agnhost \
--generator=run-pod/v1 \ --generator=run-pod/v1 \
--image=gcr.io/kubernetes-e2e-test-images/agnhost:2.1 \ --image=gcr.io/kubernetes-e2e-test-images/agnhost:2.7 \
--restart=Never \ --restart=Never \
--env "BIND_ADDRESS=localhost" \ --env "BIND_ADDRESS=localhost" \
--env "BIND_PORT=8080" \ --env "BIND_PORT=8080" \
@ -534,6 +534,6 @@ The image contains `iperf`.
## Image ## Image
The image can be found at `gcr.io/kubernetes-e2e-test-images/agnhost:2.2` for Linux The image can be found at `gcr.io/kubernetes-e2e-test-images/agnhost:2.7` for Linux
containers, and `e2eteam/agnhost:2.2` for Windows containers. In the future, the same containers, and `e2eteam/agnhost:2.7` for Windows containers. In the future, the same
repository can be used for both OSes. repository can be used for both OSes.

2
test/images/agnhost/VERSION
View File

@ -1 +1 @@
2.6 2.7

2
test/images/agnhost/agnhost.go
View File

@ -44,7 +44,7 @@ import (
) )
func main() { func main() {
rootCmd := &cobra.Command{Use: "app", Version: "2.6"} rootCmd := &cobra.Command{Use: "app", Version: "2.7"}
rootCmd.AddCommand(auditproxy.CmdAuditProxy) rootCmd.AddCommand(auditproxy.CmdAuditProxy)
rootCmd.AddCommand(connect.CmdConnect) rootCmd.AddCommand(connect.CmdConnect)

4
test/images/agnhost/netexec/netexec.go
View File

@ -288,7 +288,7 @@ func dialUDP(request string, remoteAddress *net.UDPAddr) (string, error) {
if err != nil { if err != nil {
return "", fmt.Errorf("udp connection write failed. err:%v", err) return "", fmt.Errorf("udp connection write failed. err:%v", err)
} }
udpResponse := make([]byte, 1024) udpResponse := make([]byte, 2048)
Conn.SetReadDeadline(time.Now().Add(5 * time.Second)) Conn.SetReadDeadline(time.Now().Add(5 * time.Second))
count, err := Conn.Read(udpResponse) count, err := Conn.Read(udpResponse)
if err != nil || count == 0 { if err != nil || count == 0 {
@ -393,7 +393,7 @@ func startUDPServer(udpPort int) {
serverConn, err := net.ListenUDP("udp", serverAddress) serverConn, err := net.ListenUDP("udp", serverAddress)
assertNoError(err) assertNoError(err)
defer serverConn.Close() defer serverConn.Close()
buf := make([]byte, 1024) buf := make([]byte, 2048)
log.Printf("Started UDP server") log.Printf("Started UDP server")
// Start responding to readiness probes. // Start responding to readiness probes.