Skip to content

Commit

Permalink
Fix Membership thread name
Browse files Browse the repository at this point in the history
  • Loading branch information
KeiichiFujino committed Nov 11, 2020
1 parent 20edb41 commit 13721f9
Showing 1 changed file with 4 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -373,7 +373,7 @@ private void memberDataReceived(byte[] data) {
public void run() {
String name = Thread.currentThread().getName();
try {
Thread.currentThread().setName("Membership-MemberDisappeared.");
Thread.currentThread().setName("Membership-MemberDisappeared");
service.memberDisappeared(m);
}finally {
Thread.currentThread().setName(name);
Expand All @@ -387,7 +387,7 @@ public void run() {
public void run() {
String name = Thread.currentThread().getName();
try {
Thread.currentThread().setName("Membership-MemberAdded.");
Thread.currentThread().setName("Membership-MemberAdded");
service.memberAdded(m);
}finally {
Thread.currentThread().setName(name);
Expand Down Expand Up @@ -418,7 +418,7 @@ private void memberBroadcastsReceived(final byte[] b) {
public void run() {
String name = Thread.currentThread().getName();
try {
Thread.currentThread().setName("Membership-MemberAdded.");
Thread.currentThread().setName("Membership-MemberAdded");
for (ChannelData datum : data) {
try {
if (datum != null && !member.equals(datum.getAddress())) {
Expand Down Expand Up @@ -456,7 +456,7 @@ protected void checkExpired() {
public void run() {
String name = Thread.currentThread().getName();
try {
Thread.currentThread().setName("Membership-MemberExpired.");
Thread.currentThread().setName("Membership-MemberExpired");
service.memberDisappeared(member);
} finally {
Thread.currentThread().setName(name);
Expand Down

0 comments on commit 13721f9

Please sign in to comment.