src/DiskIO/DiskThreads/CommIO.h

   1 /*
   2  * Copyright (C) 1996-2014 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 #ifndef SQUID_SRC_DISKIO_DISKTHREADS_COMMIO_H
  10 #define SQUID_SRC_DISKIO_DISKTHREADS_COMMIO_H
  11
  12 #include "fde.h"
  13 #include "globals.h"
  14
  15 class CommIO
  16 {
  17
  18 public:
  19     static inline void NotifyIOCompleted();
  20     static void ResetNotifications();
  21     static void Initialize();
  22     static void NotifyIOClose();
  23
  24 private:
  25     static void NULLFDHandler(int, void *);
  26     static void FlushPipe();
  27     static bool Initialized;
  28     static bool DoneSignalled;
  29     static int DoneFD;
  30     static int DoneReadFD;
  31 };
  32
  33 /* Inline code. TODO: make structured approach to inlining */
  34 void
  35 CommIO::NotifyIOCompleted()
  36 {
  37     if (!Initialized) {
  38         fatalf("Disk Threads I/O pipes not initialized before first use.");
  39     }
  40
  41     if (!DoneSignalled) {
  42         DoneSignalled = true;
  43         FD_WRITE_METHOD(DoneFD, "!", 1);
  44     }
  45 };
  46
  47 #endif /* SQUID_SRC_DISKIO_DISKTHREADS_COMMIO_H */