MRP_UNUSED(ml);
MRP_UNUSED(user_data);
- mrp_log_info("process_queue");
-
mrp_disable_deferred(d);
mrp_list_foreach(&msg_queue, p, n) {
msg = mrp_list_entry(p, typeof(*msg), hook);
- mrp_log_info("processing msg %p", msg);
-
if (!msg) {
mrp_log_error("no message!");
goto end;
/* Look next from the general connections table. */
endpoint = mrp_htbl_lookup(connections, msg->addr->data);
- mrp_log_info("sending message to connection '%s'",
- msg->addr->data);
- }
- else {
- mrp_log_info("sending message to server '%s'",
- msg->addr->data);
}
}
else {
MRP_UNUSED(size);
- mrp_log_info("> internal_resolve");
-
if (!str)
return 0;
memcpy(addr->data, str+9, len-9+1);
- mrp_log_info("resolved %s from %s", addr->data, str);
-
return len-9;
}
{
internal_t *u = (internal_t *)mu;
- mrp_log_info("> internal_open");
-
if (internal_initialize_table(u) < 0)
return FALSE;
{
internal_t *u = (internal_t *)mu;
- mrp_log_info("> internal_bind");
-
if (internal_initialize_table(u) < 0)
return FALSE;
if (!u->bound)
return FALSE;
- mrp_log_info("> internal_listen");
-
u->listening = TRUE;
return TRUE;
internal_t *lt = (internal_t *) mlt;
internal_t *client = lt->endpoint;
- mrp_log_info("> internal_accept");
-
t->endpoint = client;
client->endpoint = t;
{
internal_t *u = (internal_t *)mu;
- mrp_log_info("> internal_close");
-
/* Is this client or server? If server, go remove the connection from
* servers table. */
MRP_UNUSED(addrlen);
- mrp_log_info("> internal_connect");
-
/* client connecting */
if (!servers) {
{
internal_t *u = (internal_t *)mu;
- mrp_log_info("> internal_disconnect");
-
if (u->connected) {
internal_t *endpoint = u->endpoint;
size_t size;
internal_message_t *msg;
-
- mrp_log_info("> internal_sendto");
-
size = mrp_msg_default_encode(data, &buf);
if (size == 0 || buf == NULL) {
static int internal_send(mrp_transport_t *mu, mrp_msg_t *msg)
{
- mrp_log_info("> internal_send");
-
if (!mu->connected) {
return FALSE;
}
internal_t *u = (internal_t *)mu;
internal_message_t *msg;
- mrp_log_info("> internal_sendrawto");
-
msg = mrp_allocz(sizeof(internal_message_t));
msg->addr = addr;
static int internal_sendraw(mrp_transport_t *mu, void *data, size_t size)
{
- mrp_log_info("> internal_sendraw");
-
if (!mu->connected) {
return FALSE;
}
size_t size;
internal_message_t *msg;
- mrp_log_info("> internal_senddatato");
-
if (type == NULL)
return FALSE;
static int internal_senddata(mrp_transport_t *mu, void *data, uint16_t tag)
{
- mrp_log_info("> internal_senddata");
-
if (!mu->connected) {
return FALSE;
}