linuxhelpers_p.h

Go to the documentation of this file.

#ifndef ZYPP_BASE_LINUXHELPERS_P_H_DEFINED
#define ZYPP_BASE_LINUXHELPERS_P_H_DEFINED
 
#include <string>
#include <optional>
#include <zypp-core/zyppng/core/ByteArray>
#include <zypp-core/AutoDispose.h>
#include <errno.h>
 
namespace zyppng {
 
  class SockAddr;
 
  inline std::string strerr_cxx ( const int err = -1 ) {
    ByteArray strBuf( 1024, '\0' );
    strerror_r( err == -1 ? errno : err , strBuf.data(), strBuf.size() );
    return std::string( strBuf.data() );
  }
 

  template<typename Fun, typename RestartCb, typename... Args >
  auto eintrSafeCallEx ( const Fun &function, const RestartCb &restartCb, Args&&... args ) {
    int res = 0;
    while ( true ) {
      errno = 0;
      res = std::invoke(function, args... );
      if ( res == -1 && errno == EINTR ) {
        std::invoke( restartCb );
        continue;
      }
      break;
    };
    return res;
  }
 
  template<typename Fun, typename... Args >
  auto eintrSafeCall ( Fun &&function, Args&&... args ) {
    return eintrSafeCallEx( std::forward<Fun>(function), [](){},  std::forward<Args>(args)... );
  }
 
  bool blockAllSignalsForCurrentThread ( );
 
  bool blockSignalsForCurrentThread ( const std::vector<int> &sigs );
 
  bool trySocketConnection (int &sockFD, const SockAddr &addr, uint64_t timeout );
 
  // origfd will be accessible as newfd and closed (unless they were equal)
  void renumberFd (int origfd, int newfd);

  int64_t bytesAvailableOnFD( int fd );

  struct Pipe {
    zypp::AutoFD readFd;
    zypp::AutoFD writeFd;
    static std::optional<Pipe> create ( int flags = 0 );
 
    void unrefWrite( ) {
      writeFd = -1;
    }
 
    void unrefRead( ) {
      readFd = -1;
    }
  };
}
 
#endif // LINUXHELPERS_P_H