6245

Committed 01 Feb 2022 05:40AM UTC coverage: 57.331%. First build

Build # 6245

Build Type

push

travis-ci-com

Committed by

akhilamohanan

Commit Message

<a href="https://github.com/noironetworks/aci-containers/commit/<a class=hub.com/noironetworks/aci-containers/commit/<a class="double-link" href="https://git"><a class=hub.com/noironetworks/aci-containers/commit/9b02f03b71b78439cd9343cf19d26a9fc0851a30">9b02f03b7">&lt;a href=&quot;https://github.com/noironetworks/aci-containers/commit/</a><a class="double-link" href="https://github.com/noironetworks/aci-containers/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://git">&lt;a class=</a>hub.com/noironetworks/aci-containers/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://git">&lt;a class=</a>hub.com/noironetworks/aci-containers/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://git">&lt;a class=</a>hub.com/noironetworks/aci-containers/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://git">&lt;a class=</a>hub.com/noironetworks/aci-containers/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://git">&lt;a class=</a>hub.com/noironetworks/aci-containers/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://git">&lt;a class=</a>hub.com/noironetworks/aci-containers/commit/9b02f03b71b78439cd9343cf19d26a9fc0851a30">9b02f03b7</a><a href="https://github.com/noironetworks/aci-containers/commit/9b02f03b71b78439cd9343cf19d26a9fc0851a30">&quot;&gt;&amp;lt;a href=&amp;quot;https://github.com/noironetworks/aci-containers/commit/&lt;/a&gt;&lt;a class=&quot;double-link&quot; href=&quot;https://github.com/noironetworks/aci-containers/commit/&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://git&quot;&gt;&amp;lt;a class=&lt;/a&gt;hub.com/noironetworks/aci-containers/commit/&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://git&quot;&gt;&amp;lt;a class=&lt;/a&gt;hub.com/noironetworks/aci-containers/commit/&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://git&quot;&gt;&amp;lt;a class=&lt;/a&gt;hub.com/noironetworks/aci-containers/commit/&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://git&quot;&gt;&amp;lt;a class=&lt;/a&gt;hub.com/noironetworks/aci-containers/commit/9b02f03b71b78439cd93... (continued)

Run Details

7 of 7 new or added lines in 3 files covered. (100.0%)

11582 of 20202 relevant lines covered (57.33%)

0.64 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/pkg/hostagent/status.go

// Copyright 2017 Cisco Systems, Inc.
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
//     http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.

package hostagent

import (
        "encoding/json"
        "fmt"
        "net/http"

        "github.com/noironetworks/aci-containers/pkg/metadata"
)

type agentStatus struct {
        Endpoints int             `json:"endpoints,omitempty"`
        Services  int             `json:"services,omitempty"`
        PodIps    metadata.NetIps `json:"pod-ips,omitempty"`
        UsedIPs   int             `json:"used-ips,omitempty"`
}

type ipamStatus struct {
        PodIps  metadata.NetIps   `json:"pod-ips,omitempty"`
        UsedIPs map[string]string `json:"used-ips,omitempty"`
}

func (agent *HostAgent) RunStatus() {
        if agent.config.StatusPort <= 0 {
                return
        }

        http.HandleFunc("/endpoints", func(w http.ResponseWriter, r *http.Request) {
                w.Header().Set("Content-Type", "application/json")
                agent.indexMutex.Lock()
                eps := make([]*opflexEndpoint, 0, len(agent.opflexEps))
                for _, eps := range agent.opflexEps {
                        for _, ep := range eps {
                                eps = append(eps, ep)
                        }
                }
                json.NewEncoder(w).Encode(eps)
                agent.indexMutex.Unlock()
        })
        http.HandleFunc("/services", func(w http.ResponseWriter, r *http.Request) {
                w.Header().Set("Content-Type", "application/json")
                agent.indexMutex.Lock()
                services := make([]*opflexService, 0, len(agent.opflexServices))
                for _, service := range agent.opflexServices {
                        services = append(services, service)
                }
                json.NewEncoder(w).Encode(services)
                agent.indexMutex.Unlock()
        })
        http.HandleFunc("/config", func(w http.ResponseWriter, r *http.Request) {
                w.Header().Set("Content-Type", "application/json")
                json.NewEncoder(w).Encode(agent.config)
        })
        http.HandleFunc("/status", func(w http.ResponseWriter, r *http.Request) {
                w.Header().Set("Content-Type", "application/json")
                agent.indexMutex.Lock()
                agent.ipamMutex.Lock()
                status := &agentStatus{
                        Endpoints: len(agent.opflexEps),
                        Services:  len(agent.opflexServices),
                        PodIps: metadata.NetIps{
                                V4: agent.podIps.CombineV4(),
                                V6: agent.podIps.CombineV6(),
                        },
                        UsedIPs: len(agent.usedIPs),
                }
                json.NewEncoder(w).Encode(status)
                agent.ipamMutex.Unlock()
                agent.indexMutex.Unlock()
        })
        http.HandleFunc("/ipam", func(w http.ResponseWriter, r *http.Request) {
                w.Header().Set("Content-Type", "application/json")
                agent.indexMutex.Lock()
                agent.ipamMutex.Lock()
                is := &ipamStatus{
                        PodIps: metadata.NetIps{
                                V4: agent.podIps.CombineV4(),
                                V6: agent.podIps.CombineV6(),
                        },
                        UsedIPs: agent.usedIPs,
                }
                json.NewEncoder(w).Encode(is)
                agent.ipamMutex.Unlock()
                agent.indexMutex.Unlock()
        })
        agent.log.Info("Starting status server")
        panic(http.ListenAndServe(fmt.Sprintf(":%d", agent.config.StatusPort), nil))
}

1	// Copyright 2017 Cisco Systems, Inc.
2	//
3	// Licensed under the Apache License, Version 2.0 (the "License");
4	// you may not use this file except in compliance with the License.
5	// You may obtain a copy of the License at
6	//
7	// http://www.apache.org/licenses/LICENSE-2.0
8	//
9	// Unless required by applicable law or agreed to in writing, software
10	// distributed under the License is distributed on an "AS IS" BASIS,
11	// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12	// See the License for the specific language governing permissions and
13	// limitations under the License.
14
15	package hostagent
16
17	import (
18	"encoding/json"
19	"fmt"
20	"net/http"
21
22	"github.com/noironetworks/aci-containers/pkg/metadata"
23	)
24
25	type agentStatus struct {
26	Endpoints int `json:"endpoints,omitempty"`
27	Services int `json:"services,omitempty"`
28	PodIps metadata.NetIps `json:"pod-ips,omitempty"`
29	UsedIPs int `json:"used-ips,omitempty"`
30	}
31
32	type ipamStatus struct {
33	PodIps metadata.NetIps `json:"pod-ips,omitempty"`
34	UsedIPs map[string]string `json:"used-ips,omitempty"`
35	}
36
37	func (agent *HostAgent) RunStatus() {	×
38	if agent.config.StatusPort <= 0 {	×
39	return	×
40	}	×
41
42	http.HandleFunc("/endpoints", func(w http.ResponseWriter, r *http.Request) {	×
43	w.Header().Set("Content-Type", "application/json")	×
44	agent.indexMutex.Lock()	×
45	eps := make([]*opflexEndpoint, 0, len(agent.opflexEps))	×
46	for _, eps := range agent.opflexEps {	×
47	for _, ep := range eps {	×
48	eps = append(eps, ep)	×
49	}	×
50	}
51	json.NewEncoder(w).Encode(eps)	×
52	agent.indexMutex.Unlock()	×
53	})
54	http.HandleFunc("/services", func(w http.ResponseWriter, r *http.Request) {	×
55	w.Header().Set("Content-Type", "application/json")	×
56	agent.indexMutex.Lock()	×
57	services := make([]*opflexService, 0, len(agent.opflexServices))	×
58	for _, service := range agent.opflexServices {	×
59	services = append(services, service)	×
60	}	×
61	json.NewEncoder(w).Encode(services)	×
62	agent.indexMutex.Unlock()	×
63	})
64	http.HandleFunc("/config", func(w http.ResponseWriter, r *http.Request) {	×
65	w.Header().Set("Content-Type", "application/json")	×
66	json.NewEncoder(w).Encode(agent.config)	×
67	})	×
68	http.HandleFunc("/status", func(w http.ResponseWriter, r *http.Request) {	×
69	w.Header().Set("Content-Type", "application/json")	×
70	agent.indexMutex.Lock()	×
71	agent.ipamMutex.Lock()	×
72	status := &agentStatus{	×
73	Endpoints: len(agent.opflexEps),	×
74	Services: len(agent.opflexServices),	×
75	PodIps: metadata.NetIps{	×
76	V4: agent.podIps.CombineV4(),	×
77	V6: agent.podIps.CombineV6(),	×
78	},	×
79	UsedIPs: len(agent.usedIPs),	×
80	}	×
81	json.NewEncoder(w).Encode(status)	×
82	agent.ipamMutex.Unlock()	×
83	agent.indexMutex.Unlock()	×
84	})	×
85	http.HandleFunc("/ipam", func(w http.ResponseWriter, r *http.Request) {	×
86	w.Header().Set("Content-Type", "application/json")	×
87	agent.indexMutex.Lock()	×
88	agent.ipamMutex.Lock()	×
89	is := &ipamStatus{	×
90	PodIps: metadata.NetIps{	×
91	V4: agent.podIps.CombineV4(),	×
92	V6: agent.podIps.CombineV6(),	×
93	},	×
94	UsedIPs: agent.usedIPs,	×
95	}	×
96	json.NewEncoder(w).Encode(is)	×
97	agent.ipamMutex.Unlock()	×
98	agent.indexMutex.Unlock()	×
99	})	×
100	agent.log.Info("Starting status server")	×
101	panic(http.ListenAndServe(fmt.Sprintf(":%d", agent.config.StatusPort), nil))	×
102	}

noironetworks / aci-containers / 6245

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous