/*
- * DEBUG: section 17 Request Forwarding
+ * Copyright (C) 1996-2015 The Squid Software Foundation and contributors
*
+ * Squid software is distributed under GPLv2+ license and includes
+ * contributions from numerous individuals and organizations.
+ * Please see the COPYING and CONTRIBUTORS files for details.
*/
+/* DEBUG: section 17 Request Forwarding */
+
#include "squid.h"
#include "CollapsedForwarding.h"
#include "globals.h"
Ipc::TypedMsgHdr msg;
msg.setType(Ipc::mtCollapsedForwardingNotification);
msg.putInt(KidIdentifier);
- const String addr = Ipc::Port::MakeAddr(Ipc::strandAddrPfx, workerId);
+ const String addr = Ipc::Port::MakeAddr(Ipc::strandAddrLabel, workerId);
Ipc::SendMessage(addr, msg);
}
virtual ~CollapsedForwardingRr();
protected:
- virtual void create(const RunnerRegistry &);
- virtual void open(const RunnerRegistry &);
+ virtual void create();
+ virtual void open();
private:
Ipc::MultiQueue::Owner *owner;
};
-RunnerRegistrationEntry(rrAfterConfig, CollapsedForwardingRr);
+RunnerRegistrationEntry(CollapsedForwardingRr);
-void CollapsedForwardingRr::create(const RunnerRegistry &)
+void CollapsedForwardingRr::create()
{
Must(!owner);
owner = Ipc::MultiQueue::Init(ShmLabel, Config.workers, 1,
QueueCapacity);
}
-void CollapsedForwardingRr::open(const RunnerRegistry &)
+void CollapsedForwardingRr::open()
{
CollapsedForwarding::Init();
}
{
delete owner;
}
+