Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Re-align priorities for current log msgs #258

Merged
merged 1 commit into from
Jun 5, 2017
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion tendrl/ceph_integration/ceph.py
Original file line number Diff line number Diff line change
Expand Up @@ -575,7 +575,7 @@ def get_cluster_object(cluster_name, sync_type):
if ret != 0:
Event(
Message(
priority="error",
priority="debug",
publisher=NS.publisher_id,
payload={"message": "Metadata not"
" available for OSD: %s" % osd_id}
Expand Down
4 changes: 2 additions & 2 deletions tendrl/ceph_integration/manager/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -49,7 +49,7 @@ def main():
except etcd.EtcdKeyNotFound:
Event(
Message(
priority="error",
priority="debug",
publisher=NS.publisher_id,
payload={"message": "Node %s is not part of any sds cluster" %
NS.node_context.node_id
Expand All @@ -64,7 +64,7 @@ def main():
if NS.tendrl_context.integration_id is None:
Event(
Message(
priority="error",
priority="debug",
publisher=NS.publisher_id,
payload={"message": "Node %s is not part of any sds cluster" %
NS.node_context.node_id
Expand Down
2 changes: 1 addition & 1 deletion tendrl/ceph_integration/manager/user_request.py
Original file line number Diff line number Diff line change
Expand Up @@ -482,7 +482,7 @@ def on_map(self, sync_type, sync_object):
if self._pool_id is None:
Event(
Message(
priority="error",
priority="debug",
publisher=NS.publisher_id,
payload={
"message": "'{0}' not found, pools are "
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -51,7 +51,7 @@ def run(self):
except RequestStateError as ex:
Event(
Message(
priority="info",
priority="error",
publisher=NS.publisher_id,
payload={
"message": "Failed to create ec-profile %s."
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -35,7 +35,7 @@ def run(self):
except RequestStateError as ex:
Event(
Message(
priority="info",
priority="error",
publisher=NS.publisher_id,
payload={
"message": "Failed to delete ec-profile %s."
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -48,7 +48,7 @@ def run(self):
except RequestStateError as ex:
Event(
Message(
priority="info",
priority="error",
publisher=NS.publisher_id,
payload={
"message": "Failed to create pool %s."
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -43,7 +43,7 @@ def run(self):
self.parameters['Pool.poolname']:
Event(
Message(
priority="info",
priority="error",
publisher=NS.publisher_id,
payload={
"message": "Pool with name %s already exists" %
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -34,7 +34,7 @@ def run(self):
except etcd.EtcdKeyNotFound:
Event(
Message(
priority="warning",
priority="error",
publisher=NS.publisher_id,
payload={
"message": "Pool with id %s doesnt exist" %
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -59,7 +59,7 @@ def run(self):
except RequestStateError as ex:
Event(
Message(
priority="info",
priority="error",
publisher=NS.publisher_id,
payload={
"message": "Failed to update pool %s."
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -42,7 +42,7 @@ def run(self):
except RequestStateError as ex:
Event(
Message(
priority="info",
priority="error",
publisher=NS.publisher_id,
payload={
"message": "Failed to delete rbd %s."
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -35,7 +35,7 @@ def run(self):
except etcd.EtcdKeyNotFound:
Event(
Message(
priority="info",
priority="warning",
publisher=NS.publisher_id,
payload={
"message": "Rbd: %s does not exist for pool %s" %
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -39,7 +39,7 @@ def run(self):
except RequestStateError as ex:
Event(
Message(
priority="info",
priority="error",
publisher=NS.publisher_id,
payload={
"message": "Failed to resize rbd %s."
Expand Down
12 changes: 6 additions & 6 deletions tendrl/ceph_integration/sds_sync/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -344,7 +344,7 @@ def on_sync_object(self, data):
else:
Event(
Message(
priority="warning",
priority="debug",
publisher=NS.publisher_id,
payload={"message": "ClusterMonitor.on_sync_object: "
"stale object received for %s"
Expand Down Expand Up @@ -499,7 +499,7 @@ def _get_utilization_data(self):
if index >= len(lines):
Event(
Message(
priority="warning",
priority="debug",
publisher=NS.publisher_id,
payload={"message": "No cluster stats to parse"
}
Expand All @@ -511,7 +511,7 @@ def _get_utilization_data(self):
if len(cluster_fields) < 4:
Event(
Message(
priority="warning",
priority="debug",
publisher=NS.publisher_id,
payload={"message": "Missing fields in cluster"
" stat"
Expand All @@ -537,7 +537,7 @@ def _get_utilization_data(self):
if index >= len(lines):
Event(
Message(
priority="warning",
priority="debug",
publisher=NS.publisher_id,
payload={"message": "No pool stats to parse"}
)
Expand All @@ -560,7 +560,7 @@ def _get_utilization_data(self):
pool_max_avail_idx == -1:
Event(
Message(
priority="warning",
priority="debug",
publisher=NS.publisher_id,
payload={"message": "Missing fields in pool "
"stat"
Expand All @@ -575,7 +575,7 @@ def _get_utilization_data(self):
if len(pool_fields) < 5:
Event(
Message(
priority="warning",
priority="debug",
publisher=NS.publisher_id,
payload={"message": "Missing fields in pool"
" stat"
Expand Down
4 changes: 2 additions & 2 deletions tendrl/ceph_integration/sds_sync/sync_objects.py
Original file line number Diff line number Diff line change
Expand Up @@ -111,7 +111,7 @@ def on_version(self, sync_type, new_version):
else:
Event(
Message(
priority="warning",
priority="debug",
publisher=NS.publisher_id,
payload={"message": "Abandoning fetch for %s "
"started at %s"
Expand Down Expand Up @@ -173,7 +173,7 @@ def on_fetch_complete(self, sync_type, version, data):
if sync_type.cmp(version, self.get_version(sync_type)) <= 0:
Event(
Message(
priority="warning",
priority="debug",
publisher=NS.publisher_id,
payload={"message": "Ignoring outdated update %s/%s" %
(sync_type.str, version)
Expand Down
4 changes: 2 additions & 2 deletions tendrl/ceph_integration/types.py
Original file line number Diff line number Diff line change
Expand Up @@ -253,7 +253,7 @@ def osds_by_pool(self):
# Just report all OSDs instead of failing horribly.
Event(
Message(
priority="error",
priority="debug",
publisher=NS.publisher_id,
payload={"message": "Cannot determine OSDS for pool %s"
% pool_id
Expand All @@ -280,7 +280,7 @@ def osd_pools(self):
except KeyError:
Event(
Message(
priority="warning",
priority="info",
publisher=NS.publisher_id,
payload={"message": "OSD {0} is present in CRUSH "
"map, but not in OSD map"
Expand Down