lihao/skynet
1
0
Fork 0
mirror of https://github.com/cloudwu/skynet.git synced 2026-07-24 20:23:06 +00:00
Code Issues Packages Projects Releases Wiki Activity

master close socket on harbor error

Browse Source
This commit is contained in:
云风
2014-01-06 18:10:33 +08:00
parent 6e3ef7fe09
commit 7c218a4e85
1 changed files with 10 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
service-src/service_master.c
View File

@@ -182,13 +182,18 @@ _update_name(struct master *m, uint32_t handle, const char * buffer, size_t sz)
}
static void
_update_address(struct master *m, int harbor_id, const char * buffer, size_t sz) {
close_harbor(struct master *m, int harbor_id) {
struct skynet_context * context = m->ctx;
if (m->remote_fd[harbor_id] >= 0) {
skynet_socket_close(context, m->remote_fd[harbor_id]);
m->remote_fd[harbor_id] = -1;
m->connected[harbor_id] = false;
}
static void
_update_address(struct master *m, int harbor_id, const char * buffer, size_t sz) {
if (m->remote_fd[harbor_id] >= 0) {
close_harbor(m, harbor_id);
}
free(m->remote_addr[harbor_id]);
char * addr = malloc(sz+1);
memcpy(addr, buffer, sz);
@@ -233,6 +238,7 @@ dispatch_socket(struct master *m, const struct skynet_socket_message *msg, int s
break;
case SKYNET_SOCKET_TYPE_CLOSE:
case SKYNET_SOCKET_TYPE_ERROR:
close_harbor(m, id);
skynet_error(m->ctx, "socket error on harbor %d", id);
break;
default: