jcsp

"""
Copyright 2017 Red Hat, Inc
Author: John Spray <john.spray@redhat.com>
License: LGPLv2
Middle name: Danger
"""

import rados
import cephfs

jcsp

# License: LGPL2.1 or later

from glob import glob
import os
import re
import socket
import subprocess
import struct
import json

jcsp

import zmq 
import sys 

def send(payload):
    """ 
    This emulates the salt SREQ class's __init__() and send()
    methods, which are called together repeatedly if using
    Minion._fire_master to send monitoring data.  Hopefully
    we're going to reproduce the ZMQ crash that sometimes happens
    in that case.

jcsp

from gevent import getcurrent
from functools import wraps
from contextlib import contextmanager


class ForbiddenYield(Exception):
    pass


@contextmanager