lihao/skynet
1
0
Fork 0
mirror of https://github.com/cloudwu/skynet.git synced 2026-07-22 02:53:09 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix type

Browse Source
This commit is contained in:
Cloud Wu
2021-02-03 16:04:01 +08:00
parent 4534fb5269
commit e23ad8fc6b
2 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
service-src/databuffer.h
View File

@@ -62,7 +62,7 @@ _return_message(struct databuffer *db, struct messagepool *mp) {
} }
static void static void
databuffer_read(struct databuffer *db, struct messagepool *mp, void * buffer, int sz) { databuffer_read(struct databuffer *db, struct messagepool *mp, char * buffer, int sz) {
assert(db->size >= sz); assert(db->size >= sz);
db->size -= sz; db->size -= sz;
for (;;) { for (;;) {

4
service-src/service_gate.c
View File

@@ -175,13 +175,13 @@ _forward(struct gate *g, struct connection * c, int size) {
} }
if (g->broker) { if (g->broker) {
void * temp = skynet_malloc(size); void * temp = skynet_malloc(size);
databuffer_read(&c->buffer,&g->mp,temp, size); databuffer_read(&c->buffer,&g->mp,(char *)temp, size);
skynet_send(ctx, 0, g->broker, g->client_tag | PTYPE_TAG_DONTCOPY, fd, temp, size); skynet_send(ctx, 0, g->broker, g->client_tag | PTYPE_TAG_DONTCOPY, fd, temp, size);
return; return;
} }
if (c->agent) { if (c->agent) {
void * temp = skynet_malloc(size); void * temp = skynet_malloc(size);
databuffer_read(&c->buffer,&g->mp,temp, size); databuffer_read(&c->buffer,&g->mp,(char *)temp, size);
skynet_send(ctx, c->client, c->agent, g->client_tag | PTYPE_TAG_DONTCOPY, fd , temp, size); skynet_send(ctx, c->client, c->agent, g->client_tag | PTYPE_TAG_DONTCOPY, fd , temp, size);
} else if (g->watchdog) { } else if (g->watchdog) {
char * tmp = skynet_malloc(size + 32); char * tmp = skynet_malloc(size + 32);