wdgzyjx/myxce
1
0
Fork 0
forked from lei.chen/myxce
Code Pull requests Activity

improve join protocol

Browse source
This commit is contained in:
Rongsong Shen 2025-12-11 14:49:05 +08:00
parent 123b656dcf
commit 79124c6e5c
1 changed files with 5 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

9
src/controller/join.c
View file

@ -82,6 +82,7 @@ static int handle_scheduler_join(cluster_t* c, endpoint_t* ep,
{ {
xce_reply_t reply; xce_reply_t reply;
ep_private_t* priv = (ep_private_t*)ep->data; ep_private_t* priv = (ep_private_t*)ep->data;
int rc = 0;
TRACE("%s scheduler join, ep %p", __func__, ep); TRACE("%s scheduler join, ep %p", __func__, ep);
@ -90,13 +91,13 @@ static int handle_scheduler_join(cluster_t* c, endpoint_t* ep,
c->sched.ep = ep; c->sched.ep = ep;
priv->u.idx = 0; priv->u.idx = 0;
reply.status = 0; rc = on_scheduler_join(c);
reply.status = rc;
reply.data_which = RequestReply_data_nodata; reply.data_which = RequestReply_data_nodata;
xce_reply(ep, c->myhost, &reply); xce_reply(ep, c->myhost, &reply);
on_scheduler_join(c); return rc;
return 0;
} }
static int handle_controller_join(cluster_t* c, endpoint_t* ep, static int handle_controller_join(cluster_t* c, endpoint_t* ep,