| 114 msg_pos += cplen; |
114 msg_pos += cplen; |
| 115 if(msg_pos == msg_size) { |
115 if(msg_pos == msg_size) { |
| 116 // message complete |
116 // message complete |
| 117 //fprintf(stderr, "send: %.*s\n", (int)msg_size, msg); |
117 //fprintf(stderr, "send: %.*s\n", (int)msg_size, msg); |
| 118 if(handler->handler.callback) { |
118 if(handler->handler.callback) { |
| 119 handler->handler.callback(cx_mutstrn(msg, msg_size)); |
119 handler->handler.callback(cx_strn(msg, msg_size)); |
| 120 } |
120 } |
| |
121 free(msg); |
| 121 msg = NULL; |
122 msg = NULL; |
| 122 msg_size = 0; |
123 msg_size = 0; |
| 123 msg_pos = 0; |
124 msg_pos = 0; |
| 124 } |
125 } |
| 125 } else { |
126 } else { |