FD_EVENT fde;
int fd;
- //TODO HOT PATCH FOR 2048.
- char char_2048;
- int check_2048;
-
LIST_NODE* pkt_list;
TRANSPORT *transport;
log_parse(sdb_debug);
}
- char* trace_packet;
- trace_packet = getenv(TRACE_PACKET);
- if(!strcmp(trace_packet, "true")) {
+ char* trace_packet_char;
+ trace_packet_char = getenv(TRACE_PACKET);
+ if(!strcmp(trace_packet_char, "true")) {
trace_packet = 2;
}
else if ((loglevel_mask & (1 << SDBLOG_INFO)) != 0) {
} else {
p->len = MAX_PAYLOAD - avail;
- //TODO HOT PATCH FOR 2048.
-
if(peer_enqueue(s, p) < 0) {
//local socket is already closed by peer or should not close the socket.
return;
s->node = NULL;
s->pkt_list = NULL;
s->fd = fd;
- s->check_2048 = 0;
s->local_id = local_socket_next_id++;
s->node = prepend(&local_socket_list, s);
sock->remote_id = remote_id;
sock->transport = t;
}
- //TODO HOT PATCH FOR 2048.
- if(sock->check_2048 == 1) {
- sock->check_2048 = 0;
- PACKET *__p = get_apacket();
- __p->msg.command = A_WRTE;
- __p->msg.arg0 = sock->local_id;
- __p->msg.arg1 = sock->remote_id;
- __p->data[0] = sock->char_2048;
- __p->msg.data_length = 1;
- send_packet(__p, sock->transport);
- }
- else {
- local_socket_ready(sock);
- }
+ local_socket_ready(sock);
}
}
if(cmd == A_CLSE) {