if (r < 0)
return r;
- assert(wr);
- if (wr->readed > msg->length) {
- wr->readed -= msg->length;
- memmove(wr->buffer, wr->buffer + msg->length, wr->readed);
- } else
- wr->readed = 0;
-
return 0;
}
log_storage_clear(wr->buf_ptr->log_storage);
- if (wr->readed > msg->length) {
- wr->readed -= msg->length;
- memmove(wr->buffer, wr->buffer + msg->length, wr->readed);
- } else
- wr->readed = 0;
-
return 0;
}
*/
static int service_writer_handle_req_ctrl(struct logger *server, struct writer *wr, struct dlog_control_msg *msg)
{
+ assert(server);
+ assert(wr);
assert(msg);
+ int ret;
switch (msg->request) {
- case DLOG_REQ_CLEAR:
- return service_writer_handle_req_clear(server, wr, msg);
- case DLOG_REQ_HANDLE_LOGUTIL:
- return service_writer_handle_req_util(server, wr, msg);
- case DLOG_REQ_GET_CAPACITY:
- return service_writer_handle_req_get_capacity(server, wr, msg);
- case DLOG_REQ_GET_USAGE:
- return service_writer_handle_req_get_usage(server, wr, msg);
- default:
- return -EINVAL;
+ case DLOG_REQ_CLEAR: ret = service_writer_handle_req_clear (server, wr, msg); break;
+ case DLOG_REQ_HANDLE_LOGUTIL: ret = service_writer_handle_req_util (server, wr, msg); break;
+ case DLOG_REQ_GET_CAPACITY: ret = service_writer_handle_req_get_capacity(server, wr, msg); break;
+ case DLOG_REQ_GET_USAGE: ret = service_writer_handle_req_get_usage (server, wr, msg); break;
+
+ default: ret = -EINVAL;
}
+
+ if (wr->readed > msg->length) {
+ wr->readed -= msg->length;
+ memmove(wr->buffer, wr->buffer + msg->length, wr->readed);
+ } else
+ wr->readed = 0;
+
+ return ret;
}
/**