Skip to content

Commit 9258978

Browse files
bocon13PINS Working Group
bocon13
and
PINS Working Group
authored
[orchagent, cfgmgr] Add response publisher and state recording (#1992)
* Add response publisher , Add APPL STATE DB recording. Co-authored-by: PINS Working Group <[email protected]>
1 parent 3d862a7 commit 9258978

25 files changed

+815
-43
lines changed

‎cfgmgr/Makefile.am‎

Lines changed: 13 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -23,67 +23,67 @@ else
2323
DBGFLAGS = -g
2424
endif
2525

26-
vlanmgrd_SOURCES = vlanmgrd.cpp vlanmgr.cpp $(top_srcdir)/orchagent/orch.cpp $(top_srcdir)/orchagent/request_parser.cpp shellcmd.h
26+
vlanmgrd_SOURCES = vlanmgrd.cpp vlanmgr.cpp $(top_srcdir)/orchagent/orch.cpp $(top_srcdir)/orchagent/request_parser.cpp $(top_srcdir)/orchagent/response_publisher.cpp shellcmd.h
2727
vlanmgrd_CFLAGS = $(DBGFLAGS) $(AM_CFLAGS) $(CFLAGS_COMMON) $(CFLAGS_SAI)
2828
vlanmgrd_CPPFLAGS = $(DBGFLAGS) $(AM_CFLAGS) $(CFLAGS_COMMON) $(CFLAGS_SAI)
2929
vlanmgrd_LDADD = $(COMMON_LIBS) $(SAIMETA_LIBS)
3030

31-
teammgrd_SOURCES = teammgrd.cpp teammgr.cpp $(top_srcdir)/orchagent/orch.cpp $(top_srcdir)/orchagent/request_parser.cpp shellcmd.h
31+
teammgrd_SOURCES = teammgrd.cpp teammgr.cpp $(top_srcdir)/orchagent/orch.cpp $(top_srcdir)/orchagent/request_parser.cpp $(top_srcdir)/orchagent/response_publisher.cpp shellcmd.h
3232
teammgrd_CFLAGS = $(DBGFLAGS) $(AM_CFLAGS) $(CFLAGS_COMMON) $(CFLAGS_SAI)
3333
teammgrd_CPPFLAGS = $(DBGFLAGS) $(AM_CFLAGS) $(CFLAGS_COMMON) $(CFLAGS_SAI)
3434
teammgrd_LDADD = $(COMMON_LIBS) $(SAIMETA_LIBS)
3535

36-
portmgrd_SOURCES = portmgrd.cpp portmgr.cpp $(top_srcdir)/orchagent/orch.cpp $(top_srcdir)/orchagent/request_parser.cpp shellcmd.h
36+
portmgrd_SOURCES = portmgrd.cpp portmgr.cpp $(top_srcdir)/orchagent/orch.cpp $(top_srcdir)/orchagent/request_parser.cpp $(top_srcdir)/orchagent/response_publisher.cpp shellcmd.h
3737
portmgrd_CFLAGS = $(DBGFLAGS) $(AM_CFLAGS) $(CFLAGS_COMMON) $(CFLAGS_SAI)
3838
portmgrd_CPPFLAGS = $(DBGFLAGS) $(AM_CFLAGS) $(CFLAGS_COMMON) $(CFLAGS_SAI)
3939
portmgrd_LDADD = $(COMMON_LIBS) $(SAIMETA_LIBS)
4040

41-
intfmgrd_SOURCES = intfmgrd.cpp intfmgr.cpp $(top_srcdir)/orchagent/orch.cpp $(top_srcdir)/orchagent/request_parser.cpp $(top_srcdir)/lib/subintf.cpp shellcmd.h
41+
intfmgrd_SOURCES = intfmgrd.cpp intfmgr.cpp $(top_srcdir)/orchagent/orch.cpp $(top_srcdir)/orchagent/request_parser.cpp $(top_srcdir)/lib/subintf.cpp $(top_srcdir)/orchagent/response_publisher.cpp shellcmd.h
4242
intfmgrd_CFLAGS = $(DBGFLAGS) $(AM_CFLAGS) $(CFLAGS_COMMON) $(CFLAGS_SAI)
4343
intfmgrd_CPPFLAGS = $(DBGFLAGS) $(AM_CFLAGS) $(CFLAGS_COMMON) $(CFLAGS_SAI)
4444
intfmgrd_LDADD = $(COMMON_LIBS) $(SAIMETA_LIBS)
4545

46-
buffermgrd_SOURCES = buffermgrd.cpp buffermgr.cpp buffermgrdyn.cpp $(top_srcdir)/orchagent/orch.cpp $(top_srcdir)/orchagent/request_parser.cpp shellcmd.h
46+
buffermgrd_SOURCES = buffermgrd.cpp buffermgr.cpp buffermgrdyn.cpp $(top_srcdir)/orchagent/orch.cpp $(top_srcdir)/orchagent/request_parser.cpp $(top_srcdir)/orchagent/response_publisher.cpp shellcmd.h
4747
buffermgrd_CFLAGS = $(DBGFLAGS) $(AM_CFLAGS) $(CFLAGS_COMMON) $(CFLAGS_SAI)
4848
buffermgrd_CPPFLAGS = $(DBGFLAGS) $(AM_CFLAGS) $(CFLAGS_COMMON) $(CFLAGS_SAI)
4949
buffermgrd_LDADD = $(COMMON_LIBS) $(SAIMETA_LIBS)
5050

51-
vrfmgrd_SOURCES = vrfmgrd.cpp vrfmgr.cpp $(top_srcdir)/orchagent/orch.cpp $(top_srcdir)/orchagent/request_parser.cpp shellcmd.h
51+
vrfmgrd_SOURCES = vrfmgrd.cpp vrfmgr.cpp $(top_srcdir)/orchagent/orch.cpp $(top_srcdir)/orchagent/request_parser.cpp $(top_srcdir)/orchagent/response_publisher.cpp shellcmd.h
5252
vrfmgrd_CFLAGS = $(DBGFLAGS) $(AM_CFLAGS) $(CFLAGS_COMMON) $(CFLAGS_SAI)
5353
vrfmgrd_CPPFLAGS = $(DBGFLAGS) $(AM_CFLAGS) $(CFLAGS_COMMON) $(CFLAGS_SAI)
5454
vrfmgrd_LDADD = $(COMMON_LIBS) $(SAIMETA_LIBS)
5555

56-
nbrmgrd_SOURCES = nbrmgrd.cpp nbrmgr.cpp $(top_srcdir)/orchagent/orch.cpp $(top_srcdir)/orchagent/request_parser.cpp shellcmd.h
56+
nbrmgrd_SOURCES = nbrmgrd.cpp nbrmgr.cpp $(top_srcdir)/orchagent/orch.cpp $(top_srcdir)/orchagent/request_parser.cpp $(top_srcdir)/orchagent/response_publisher.cpp shellcmd.h
5757
nbrmgrd_CFLAGS = $(DBGFLAGS) $(AM_CFLAGS) $(CFLAGS_COMMON) $(CFLAGS_SAI) $(LIBNL_CFLAGS)
5858
nbrmgrd_CPPFLAGS = $(DBGFLAGS) $(AM_CFLAGS) $(CFLAGS_COMMON) $(CFLAGS_SAI) $(LIBNL_CPPFLAGS)
5959
nbrmgrd_LDADD = $(COMMON_LIBS) $(SAIMETA_LIBS) $(LIBNL_LIBS)
6060

61-
vxlanmgrd_SOURCES = vxlanmgrd.cpp vxlanmgr.cpp $(top_srcdir)/orchagent/orch.cpp $(top_srcdir)/orchagent/request_parser.cpp shellcmd.h
61+
vxlanmgrd_SOURCES = vxlanmgrd.cpp vxlanmgr.cpp $(top_srcdir)/orchagent/orch.cpp $(top_srcdir)/orchagent/request_parser.cpp $(top_srcdir)/orchagent/response_publisher.cpp shellcmd.h
6262
vxlanmgrd_CFLAGS = $(DBGFLAGS) $(AM_CFLAGS) $(CFLAGS_COMMON) $(CFLAGS_SAI)
6363
vxlanmgrd_CPPFLAGS = $(DBGFLAGS) $(AM_CFLAGS) $(CFLAGS_COMMON) $(CFLAGS_SAI)
6464
vxlanmgrd_LDADD = $(COMMON_LIBS) $(SAIMETA_LIBS)
6565

66-
sflowmgrd_SOURCES = sflowmgrd.cpp sflowmgr.cpp $(top_srcdir)/orchagent/orch.cpp $(top_srcdir)/orchagent/request_parser.cpp shellcmd.h
66+
sflowmgrd_SOURCES = sflowmgrd.cpp sflowmgr.cpp $(top_srcdir)/orchagent/orch.cpp $(top_srcdir)/orchagent/request_parser.cpp $(top_srcdir)/orchagent/response_publisher.cpp shellcmd.h
6767
sflowmgrd_CFLAGS = $(DBGFLAGS) $(AM_CFLAGS) $(CFLAGS_COMMON) $(CFLAGS_SAI)
6868
sflowmgrd_CPPFLAGS = $(DBGFLAGS) $(AM_CFLAGS) $(CFLAGS_COMMON) $(CFLAGS_SAI)
6969
sflowmgrd_LDADD = $(COMMON_LIBS) $(SAIMETA_LIBS)
7070

71-
natmgrd_SOURCES = natmgrd.cpp natmgr.cpp $(top_srcdir)/orchagent/orch.cpp $(top_srcdir)/orchagent/request_parser.cpp shellcmd.h
71+
natmgrd_SOURCES = natmgrd.cpp natmgr.cpp $(top_srcdir)/orchagent/orch.cpp $(top_srcdir)/orchagent/request_parser.cpp $(top_srcdir)/orchagent/response_publisher.cpp shellcmd.h
7272
natmgrd_CFLAGS = $(DBGFLAGS) $(AM_CFLAGS) $(CFLAGS_COMMON) $(CFLAGS_SAI)
7373
natmgrd_CPPFLAGS = $(DBGFLAGS) $(AM_CFLAGS) $(CFLAGS_COMMON) $(CFLAGS_SAI)
7474
natmgrd_LDADD = $(COMMON_LIBS) $(SAIMETA_LIBS)
7575

76-
coppmgrd_SOURCES = coppmgrd.cpp coppmgr.cpp $(top_srcdir)/orchagent/orch.cpp $(top_srcdir)/orchagent/request_parser.cpp shellcmd.h
76+
coppmgrd_SOURCES = coppmgrd.cpp coppmgr.cpp $(top_srcdir)/orchagent/orch.cpp $(top_srcdir)/orchagent/request_parser.cpp $(top_srcdir)/orchagent/response_publisher.cpp shellcmd.h
7777
coppmgrd_CFLAGS = $(DBGFLAGS) $(AM_CFLAGS) $(CFLAGS_COMMON) $(CFLAGS_SAI)
7878
coppmgrd_CPPFLAGS = $(DBGFLAGS) $(AM_CFLAGS) $(CFLAGS_COMMON) $(CFLAGS_SAI)
7979
coppmgrd_LDADD = $(COMMON_LIBS) $(SAIMETA_LIBS)
8080

81-
tunnelmgrd_SOURCES = tunnelmgrd.cpp tunnelmgr.cpp $(top_srcdir)/orchagent/orch.cpp $(top_srcdir)/orchagent/request_parser.cpp shellcmd.h
81+
tunnelmgrd_SOURCES = tunnelmgrd.cpp tunnelmgr.cpp $(top_srcdir)/orchagent/orch.cpp $(top_srcdir)/orchagent/request_parser.cpp $(top_srcdir)/orchagent/response_publisher.cpp shellcmd.h
8282
tunnelmgrd_CFLAGS = $(DBGFLAGS) $(AM_CFLAGS) $(CFLAGS_COMMON) $(CFLAGS_SAI)
8383
tunnelmgrd_CPPFLAGS = $(DBGFLAGS) $(AM_CFLAGS) $(CFLAGS_COMMON) $(CFLAGS_SAI)
8484
tunnelmgrd_LDADD = $(COMMON_LIBS) $(SAIMETA_LIBS)
8585

86-
macsecmgrd_SOURCES = macsecmgrd.cpp macsecmgr.cpp $(top_srcdir)/orchagent/orch.cpp $(top_srcdir)/orchagent/request_parser.cpp shellcmd.h
86+
macsecmgrd_SOURCES = macsecmgrd.cpp macsecmgr.cpp $(top_srcdir)/orchagent/orch.cpp $(top_srcdir)/orchagent/request_parser.cpp $(top_srcdir)/orchagent/response_publisher.cpp shellcmd.h
8787
macsecmgrd_CFLAGS = $(DBGFLAGS) $(AM_CFLAGS) $(CFLAGS_COMMON) $(CFLAGS_SAI)
8888
macsecmgrd_CPPFLAGS = $(DBGFLAGS) $(AM_CFLAGS) $(CFLAGS_COMMON) $(CFLAGS_SAI)
8989
macsecmgrd_LDADD = $(COMMON_LIBS) $(SAIMETA_LIBS)

‎cfgmgr/buffermgrd.cpp‎

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -33,6 +33,10 @@ bool gSwssRecord = false;
3333
bool gLogRotate = false;
3434
ofstream gRecordOfs;
3535
string gRecordFile;
36+
bool gResponsePublisherRecord = false;
37+
bool gResponsePublisherLogRotate = false;
38+
ofstream gResponsePublisherRecordOfs;
39+
string gResponsePublisherRecordFile;
3640
/* Global database mutex */
3741
mutex gDbMutex;
3842

‎cfgmgr/coppmgrd.cpp‎

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -29,6 +29,10 @@ bool gSwssRecord = false;
2929
bool gLogRotate = false;
3030
ofstream gRecordOfs;
3131
string gRecordFile;
32+
bool gResponsePublisherRecord = false;
33+
bool gResponsePublisherLogRotate = false;
34+
ofstream gResponsePublisherRecordOfs;
35+
string gResponsePublisherRecordFile;
3236
/* Global database mutex */
3337
mutex gDbMutex;
3438

‎cfgmgr/intfmgrd.cpp‎

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -29,6 +29,10 @@ bool gSwssRecord = false;
2929
bool gLogRotate = false;
3030
ofstream gRecordOfs;
3131
string gRecordFile;
32+
bool gResponsePublisherRecord = false;
33+
bool gResponsePublisherLogRotate = false;
34+
ofstream gResponsePublisherRecordOfs;
35+
string gResponsePublisherRecordFile;
3236
/* Global database mutex */
3337
mutex gDbMutex;
3438

‎cfgmgr/macsecmgrd.cpp‎

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -38,6 +38,10 @@ bool gSwssRecord = false;
3838
bool gLogRotate = false;
3939
ofstream gRecordOfs;
4040
string gRecordFile;
41+
bool gResponsePublisherRecord = false;
42+
bool gResponsePublisherLogRotate = false;
43+
ofstream gResponsePublisherRecordOfs;
44+
string gResponsePublisherRecordFile;
4145
/* Global database mutex */
4246
mutex gDbMutex;
4347

‎cfgmgr/natmgrd.cpp‎

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -52,6 +52,10 @@ bool gSwssRecord = false;
5252
bool gLogRotate = false;
5353
ofstream gRecordOfs;
5454
string gRecordFile;
55+
bool gResponsePublisherRecord = false;
56+
bool gResponsePublisherLogRotate = false;
57+
ofstream gResponsePublisherRecordOfs;
58+
string gResponsePublisherRecordFile;
5559
mutex gDbMutex;
5660
NatMgr *natmgr = NULL;
5761

@@ -200,4 +204,3 @@ int main(int argc, char **argv)
200204
}
201205
return -1;
202206
}
203-

‎cfgmgr/nbrmgrd.cpp‎

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -33,6 +33,10 @@ bool gSwssRecord = false;
3333
bool gLogRotate = false;
3434
ofstream gRecordOfs;
3535
string gRecordFile;
36+
bool gResponsePublisherRecord = false;
37+
bool gResponsePublisherLogRotate = false;
38+
ofstream gResponsePublisherRecordOfs;
39+
string gResponsePublisherRecordFile;
3640
/* Global database mutex */
3741
mutex gDbMutex;
3842

‎cfgmgr/portmgrd.cpp‎

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -28,6 +28,10 @@ bool gSwssRecord = false;
2828
bool gLogRotate = false;
2929
ofstream gRecordOfs;
3030
string gRecordFile;
31+
bool gResponsePublisherRecord = false;
32+
bool gResponsePublisherLogRotate = false;
33+
ofstream gResponsePublisherRecordOfs;
34+
string gResponsePublisherRecordFile;
3135
/* Global database mutex */
3236
mutex gDbMutex;
3337

‎cfgmgr/sflowmgrd.cpp‎

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -28,6 +28,10 @@ bool gSwssRecord = false;
2828
bool gLogRotate = false;
2929
ofstream gRecordOfs;
3030
string gRecordFile;
31+
bool gResponsePublisherRecord = false;
32+
bool gResponsePublisherLogRotate = false;
33+
ofstream gResponsePublisherRecordOfs;
34+
string gResponsePublisherRecordFile;
3135
/* Global database mutex */
3236
mutex gDbMutex;
3337

‎cfgmgr/teammgrd.cpp‎

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -17,6 +17,10 @@ bool gSwssRecord = false;
1717
bool gLogRotate = false;
1818
ofstream gRecordOfs;
1919
string gRecordFile;
20+
bool gResponsePublisherRecord = false;
21+
bool gResponsePublisherLogRotate = false;
22+
ofstream gResponsePublisherRecordOfs;
23+
string gResponsePublisherRecordFile;
2024

2125
bool received_sigterm = false;
2226

0 commit comments

Comments
 (0)