summaryrefslogtreecommitdiffstats
path: root/transport/socket/src/socket.c
diff options
context:
space:
mode:
Diffstat (limited to 'transport/socket/src/socket.c')
-rw-r--r--transport/socket/src/socket.c8
1 files changed, 4 insertions, 4 deletions
diff --git a/transport/socket/src/socket.c b/transport/socket/src/socket.c
index 4af064f3b7b..a1e088b9444 100644
--- a/transport/socket/src/socket.c
+++ b/transport/socket/src/socket.c
@@ -416,7 +416,7 @@ socket_event_poll_err (transport_t *this)
}
pthread_mutex_unlock (&priv->lock);
- this->xl->notify (this->xl, GF_EVENT_POLLERR, this);
+ xlator_notify (this->xl, GF_EVENT_POLLERR, this);
return ret;
}
@@ -442,7 +442,7 @@ socket_event_poll_out (transport_t *this)
}
pthread_mutex_unlock (&priv->lock);
- this->xl->notify (this->xl, GF_EVENT_POLLOUT, this);
+ xlator_notify (this->xl, GF_EVENT_POLLOUT, this);
return ret;
}
@@ -710,7 +710,7 @@ socket_event_poll_in (transport_t *this)
just to keep the last_received timestamp ticking */
if (ret == 0)
- ret = this->xl->notify (this->xl, GF_EVENT_POLLIN, this);
+ ret = xlator_notify (this->xl, GF_EVENT_POLLIN, this);
return ret;
}
@@ -778,7 +778,7 @@ unlock:
pthread_mutex_unlock (&priv->lock);
if (notify_xlator)
- this->xl->notify (this->xl, event, this);
+ xlator_notify (this->xl, event, this);
return 0;
}