#include "include/types.h"
#include "include/buffer.h"
-#include "common/Throttler.h"
+#include "common/Throttle.h"
#include "msg_types.h"
#include "common/debug.h"
uint64_t message_size = header.front_len + header.middle_len
+ header.data_len;
messenger->message_throttler.get(message_size);
- if (policy->throttler) throttler->get(message_size);
+ if (policy.throttler) policy.throttler->get(message_size);
// read front
bufferlist front;
bool server;
Throttle *throttler;
- Policy(bool l=false, bool s=false) :
- lossy(l), server(s), throttler(NULL) {}
-
Policy(bool l=false, bool s=false, Throttle *t=NULL) :
lossy(l), server(s), throttler(t) {}