@@ -171,18 +171,18 @@ _forward(struct gate *g, struct connection * c, int size) {
171
171
if (g -> broker ) {
172
172
void * temp = skynet_malloc (size );
173
173
databuffer_read (& c -> buffer ,& g -> mp ,temp , size );
174
- skynet_send (ctx , 0 , g -> broker , g -> client_tag | PTYPE_TAG_DONTCOPY , 0 , temp , size );
174
+ skynet_send (ctx , 0 , g -> broker , g -> client_tag | PTYPE_TAG_DONTCOPY , 1 , temp , size );
175
175
return ;
176
176
}
177
177
if (c -> agent ) {
178
178
void * temp = skynet_malloc (size );
179
179
databuffer_read (& c -> buffer ,& g -> mp ,temp , size );
180
- skynet_send (ctx , c -> client , c -> agent , g -> client_tag | PTYPE_TAG_DONTCOPY , 0 , temp , size );
180
+ skynet_send (ctx , c -> client , c -> agent , g -> client_tag | PTYPE_TAG_DONTCOPY , 1 , temp , size );
181
181
} else if (g -> watchdog ) {
182
182
char * tmp = skynet_malloc (size + 32 );
183
183
int n = snprintf (tmp ,32 ,"%d data " ,c -> id );
184
184
databuffer_read (& c -> buffer ,& g -> mp ,tmp + n ,size );
185
- skynet_send (ctx , 0 , g -> watchdog , PTYPE_TEXT | PTYPE_TAG_DONTCOPY , 0 , tmp , size + n );
185
+ skynet_send (ctx , 0 , g -> watchdog , PTYPE_TEXT | PTYPE_TAG_DONTCOPY , 1 , tmp , size + n );
186
186
}
187
187
}
188
188
0 commit comments