@@ -56,7 +56,7 @@ class Watermarkstat(object):
56
56
def get_queue_type (table_id ):
57
57
queue_type = self .counters_db .get (self .counters_db .COUNTERS_DB , COUNTERS_QUEUE_TYPE_MAP , table_id )
58
58
if queue_type is None :
59
- sys . stderr . write ("Queue Type is not available in table '{}'" .format (table_id ))
59
+ print ("Queue Type is not available in table '{}'" .format (table_id ), file = sys . stderr )
60
60
sys .exit (1 )
61
61
elif queue_type == SAI_QUEUE_TYPE_MULTICAST :
62
62
return QUEUE_TYPE_MC
@@ -65,29 +65,29 @@ class Watermarkstat(object):
65
65
elif queue_type == SAI_QUEUE_TYPE_ALL :
66
66
return QUEUE_TYPE_ALL
67
67
else :
68
- sys . stderr . write ("Queue Type '{} in table '{}' is invalid" .format (queue_type , table_id ))
68
+ print ("Queue Type '{} in table '{}' is invalid" .format (queue_type , table_id ), file = sys . stderr )
69
69
sys .exit (1 )
70
70
71
71
def get_queue_port (table_id ):
72
72
port_table_id = self .counters_db .get (self .counters_db .COUNTERS_DB , COUNTERS_QUEUE_PORT_MAP , table_id )
73
73
if port_table_id is None :
74
- sys . stderr . write ("Port is not available in table '{}'" .format (table_id ))
74
+ print ("Port is not available in table '{}'" .format (table_id ), file = sys . stderr )
75
75
sys .exit (1 )
76
76
77
77
return port_table_id
78
78
79
79
def get_pg_port (table_id ):
80
80
port_table_id = self .counters_db .get (self .counters_db .COUNTERS_DB , COUNTERS_PG_PORT_MAP , table_id )
81
81
if port_table_id is None :
82
- sys . stderr . write ("Port is not available in table '{}'" .format (table_id ))
82
+ print ("Port is not available in table '{}'" .format (table_id ), file = sys . stderr )
83
83
sys .exit (1 )
84
84
85
85
return port_table_id
86
86
87
87
# Get all ports
88
88
self .counter_port_name_map = self .counters_db .get_all (self .counters_db .COUNTERS_DB , COUNTERS_PORT_NAME_MAP )
89
89
if self .counter_port_name_map is None :
90
- sys . stderr . write ("COUNTERS_PORT_NAME_MAP is empty!" )
90
+ print ("COUNTERS_PORT_NAME_MAP is empty!" , file = sys . stderr )
91
91
sys .exit (1 )
92
92
93
93
self .port_uc_queues_map = {}
@@ -104,7 +104,7 @@ class Watermarkstat(object):
104
104
# Get Queues for each port
105
105
counter_queue_name_map = self .counters_db .get_all (self .counters_db .COUNTERS_DB , COUNTERS_QUEUE_NAME_MAP )
106
106
if counter_queue_name_map is None :
107
- sys . stderr . write ("COUNTERS_QUEUE_NAME_MAP is empty!" )
107
+ print ("COUNTERS_QUEUE_NAME_MAP is empty!" , file = sys . stderr )
108
108
sys .exit (1 )
109
109
110
110
for queue in counter_queue_name_map :
@@ -118,7 +118,7 @@ class Watermarkstat(object):
118
118
# Get PGs for each port
119
119
counter_pg_name_map = self .counters_db .get_all (self .counters_db .COUNTERS_DB , COUNTERS_PG_NAME_MAP )
120
120
if counter_pg_name_map is None :
121
- sys . stderr . write ("COUNTERS_PG_NAME_MAP is empty!" )
121
+ print ("COUNTERS_PG_NAME_MAP is empty!" , file = sys . stderr )
122
122
sys .exit (1 )
123
123
124
124
for pg in counter_pg_name_map :
@@ -128,7 +128,7 @@ class Watermarkstat(object):
128
128
# Get all buffer pools
129
129
self .buffer_pool_name_to_oid_map = self .counters_db .get_all (self .counters_db .COUNTERS_DB , COUNTERS_BUFFER_POOL_NAME_MAP )
130
130
if self .buffer_pool_name_to_oid_map is None :
131
- sys . stderr . write ("COUNTERS_BUFFER_POOL_NAME_MAP is empty!" )
131
+ print ("COUNTERS_BUFFER_POOL_NAME_MAP is empty!" , file = sys . stderr )
132
132
sys .exit (1 )
133
133
134
134
self .watermark_types = {
@@ -160,22 +160,22 @@ class Watermarkstat(object):
160
160
def get_queue_index (self , table_id ):
161
161
queue_index = self .counters_db .get (self .counters_db .COUNTERS_DB , COUNTERS_QUEUE_INDEX_MAP , table_id )
162
162
if queue_index is None :
163
- sys . stderr . write ("Queue index is not available in table '{}'" .format (table_id ))
163
+ print ("Queue index is not available in table '{}'" .format (table_id ), file = sys . stderr )
164
164
sys .exit (1 )
165
165
166
166
return queue_index
167
167
168
168
def get_pg_index (self , table_id ):
169
169
pg_index = self .counters_db .get (self .counters_db .COUNTERS_DB , COUNTERS_PG_INDEX_MAP , table_id )
170
170
if pg_index is None :
171
- sys . stderr . write ("Priority group index is not available in table '{}'" .format (table_id ))
171
+ print ("Priority group index is not available in table '{}'" .format (table_id ), file = sys . stderr )
172
172
sys .exit (1 )
173
173
174
174
return pg_index
175
175
176
176
def build_header (self , wm_type ):
177
177
if wm_type is None :
178
- sys . stderr . write ("Header info is not available!" )
178
+ print ("Header info is not available!" , file = sys . stderr )
179
179
sys .exit (1 )
180
180
181
181
self .header_list = ['Port' ]
0 commit comments