ControlWebSocketHandler.h

Go to the documentation of this file.

// Copyright 2019-2020 CERN and copyright holders of ALICE O2.
// See https://alice-o2.web.cern.ch/copyright for details of the copyright holders.
// All rights not expressly granted are reserved.
//
// This software is distributed under the terms of the GNU General Public
// License v3 (GPL Version 3), copied verbatim in the file "COPYING".
//
// In applying this license CERN does not waive the privileges and immunities
// granted to it by virtue of its status as an Intergovernmental Organization
// or submit itself to any jurisdiction.
#ifndef O2_FRAMEWORK_CONTROLWEBSOCKETHANDLER_H_
#define O2_FRAMEWORK_CONTROLWEBSOCKETHANDLER_H_
#include "HTTPParser.h"
#include "ControlServiceHelpers.h"
#include <map>
#include <string>
 
namespace o2::framework
{
struct DriverServerContext;
 
struct ControlWebSocketHandler : public WebSocketHandler {
  ControlWebSocketHandler(DriverServerContext& context);
  ~ControlWebSocketHandler() override = default;
 
  void headers(std::map<std::string, std::string> const& headers) override;
 
  void beginFragmentation() override {}
 
  void frame(char const* frame, size_t s) override;
 
  void endFragmentation() override{};
  void control(char const* frame, size_t s) override{};
 
  void beginChunk() override
  {
    didProcessMetric = false;
    didHaveNewMetric = false;
  }
 
  void endChunk() override;
 
  DriverServerContext& mContext;
  pid_t mPid = 0;
  size_t mIndex = (size_t)-1;
  bool didProcessMetric = false;
  bool didHaveNewMetric = false;
};
 
} // namespace o2::framework
#endif // O2_FRAMEWORK_CONTROLWEBSOCKETHANDLER_H_