src/ipc/Port.cc

   1 /*
   2  * Copyright (C) 1996-2015 The Squid Software Foundation and contributors
   3  *
   4  * Squid software is distributed under GPLv2+ license and includes
   5  * contributions from numerous individuals and organizations.
   6  * Please see the COPYING and CONTRIBUTORS files for details.
   7  */
   8
   9 /* DEBUG: section 54    Interprocess Communication */
  10
  11 #include "squid.h"
  12 #include "comm.h"
  13 #include "comm/Connection.h"
  14 #include "comm/Read.h"
  15 #include "CommCalls.h"
  16 #include "ipc/Port.h"
  17 #include "tools.h"
  18 #include "util.h"
  19
  20 static const char channelPathPfx[] = DEFAULT_STATEDIR "/";
  21 static const char coordinatorAddrLabel[] = "-coordinator";
  22 const char Ipc::strandAddrLabel[] =  "-kid";
  23
  24 Ipc::Port::Port(const String& aListenAddr):
  25     UdsOp(aListenAddr)
  26 {
  27     setOptions(COMM_NONBLOCKING | COMM_DOBIND);
  28 }
  29
  30 void Ipc::Port::start()
  31 {
  32     UdsOp::start();
  33     doListen();
  34 }
  35
  36 void Ipc::Port::doListen()
  37 {
  38     debugs(54, 6, HERE);
  39     buf.prepForReading();
  40     typedef CommCbMemFunT<Port, CommIoCbParams> Dialer;
  41     AsyncCall::Pointer readHandler = JobCallback(54, 6,
  42                                      Dialer, this, Port::noteRead);
  43     comm_read(conn(), buf.raw(), buf.size(), readHandler);
  44 }
  45
  46 bool Ipc::Port::doneAll() const
  47 {
  48     return false; // listen forever
  49 }
  50
  51 String Ipc::Port::MakeAddr(const char* processLabel, int id)
  52 {
  53     assert(id >= 0);
  54     String addr = channelPathPfx;
  55     addr.append(service_name.c_str());
  56     addr.append(processLabel);
  57     addr.append('-');
  58     addr.append(xitoa(id));
  59     addr.append(".ipc");
  60     return addr;
  61 }
  62
  63 String
  64 Ipc::Port::CoordinatorAddr()
  65 {
  66     static String coordinatorAddr;
  67     if (!coordinatorAddr.size()) {
  68         coordinatorAddr= channelPathPfx;
  69         coordinatorAddr.append(service_name.c_str());
  70         coordinatorAddr.append(coordinatorAddrLabel);
  71         coordinatorAddr.append(".ipc");
  72     }
  73     return coordinatorAddr;
  74 }
  75
  76 void Ipc::Port::noteRead(const CommIoCbParams& params)
  77 {
  78     debugs(54, 6, HERE << params.conn << " flag " << params.flag <<
  79            " [" << this << ']');
  80     if (params.flag == Comm::OK) {
  81         assert(params.buf == buf.raw());
  82         receive(buf);
  83     }
  84     // TODO: if there was a fatal error on our socket, close the socket before
  85     // trying to listen again and print a level-1 error message.
  86
  87     doListen();
  88 }
  89