#!/usr/bin/env python
# ============================================================
#
# Copyright (C) 2011 by Johannes Wienke <jwienke at techfak dot uni-bielefeld dot de>
# Copyright (C) 2011, 2012, 2014 Jan Moringen <jmoringe@techfak.uni-bielefeld.de>
#
# This program is free software; you can redistribute it
# and/or modify it under the terms of the GNU General
# Public License as published by the Free Software Foundation;
# either version 2, or (at your option)
# any later version.
#
# This program is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
# GNU General Public License for more details.
#
# ============================================================

import logging
import sys
import time
import rsb
import uuid


if __name__ == '__main__':
    logging.basicConfig(level=logging.DEBUG,
                        format='%(asctime)s %(name)-12s %(levelname)-8s\n%(message)s',
                        stream=sys.stderr)

    listener_pid = int(sys.argv[2])

    for size in [4, 256, 400000]:
        scope = "/size-%d/sub_1/sub_2" % size
        print("[Python Informer] Processing scope %s" % scope)
        informer = rsb.create_informer(scope, data_type=str)

        for i in range(120):
            event = rsb.Event(scope=scope,
                              data='c' * size,
                              data_type=str,
                              user_infos={
                                  "informer-lang": "Python",
                                  "index":         str(listener_pid + i)
                              },
                              user_times={
                                  "informer-start": time.time()
                              },
                              causes=set([
                                  rsb.EventId(
                                      uuid.UUID('00000000-0000-0000-0000-000000000000'), 0)
                              ]))
            informer.publish_event(event)

        informer.deactivate()

    print("[Python Informer] Done")

81edfcea735ddae01f01e96757fff4021ce03625
<mask token>

<mask token>
if __name__ == '__main__':
    logging.basicConfig(level=logging.DEBUG, format=
        """%(asctime)s %(name)-12s %(levelname)-8s
%(message)s""", stream=
        sys.stderr)
    listener_pid = int(sys.argv[2])
    for size in [4, 256, 400000]:
        scope = '/size-%d/sub_1/sub_2' % size
        print('[Python Informer] Processing scope %s' % scope)
        informer = rsb.create_informer(scope, data_type=str)
        for i in range(120):
            event = rsb.Event(scope=scope, data='c' * size, data_type=str,
                user_infos={'informer-lang': 'Python', 'index': str(
                listener_pid + i)}, user_times={'informer-start': time.time
                ()}, causes=set([rsb.EventId(uuid.UUID(
                '00000000-0000-0000-0000-000000000000'), 0)]))
            informer.publish_event(event)
        informer.deactivate()
    print('[Python Informer] Done')

import logging
import sys
import time
import rsb
import uuid
if __name__ == '__main__':
    logging.basicConfig(level=logging.DEBUG, format=
        """%(asctime)s %(name)-12s %(levelname)-8s
%(message)s""", stream=
        sys.stderr)
    listener_pid = int(sys.argv[2])
    for size in [4, 256, 400000]:
        scope = '/size-%d/sub_1/sub_2' % size
        print('[Python Informer] Processing scope %s' % scope)
        informer = rsb.create_informer(scope, data_type=str)
        for i in range(120):
            event = rsb.Event(scope=scope, data='c' * size, data_type=str,
                user_infos={'informer-lang': 'Python', 'index': str(
                listener_pid + i)}, user_times={'informer-start': time.time
                ()}, causes=set([rsb.EventId(uuid.UUID(
                '00000000-0000-0000-0000-000000000000'), 0)]))
            informer.publish_event(event)
        informer.deactivate()
    print('[Python Informer] Done')

#!/usr/bin/env python
# ============================================================
#
# Copyright (C) 2011 by Johannes Wienke <jwienke at techfak dot uni-bielefeld dot de>
# Copyright (C) 2011, 2012, 2014 Jan Moringen <jmoringe@techfak.uni-bielefeld.de>
#
# This program is free software; you can redistribute it
# and/or modify it under the terms of the GNU General
# Public License as published by the Free Software Foundation;
# either version 2, or (at your option)
# any later version.
#
# This program is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
# GNU General Public License for more details.
#
# ============================================================

import logging
import sys
import time
import rsb
import uuid


if __name__ == '__main__':
    logging.basicConfig(level=logging.DEBUG,
                        format='%(asctime)s %(name)-12s %(levelname)-8s\n%(message)s',
                        stream=sys.stderr)

    listener_pid = int(sys.argv[2])

    for size in [4, 256, 400000]:
        scope = "/size-%d/sub_1/sub_2" % size
        print("[Python Informer] Processing scope %s" % scope)
        informer = rsb.create_informer(scope, data_type=str)

        for i in range(120):
            event = rsb.Event(scope=scope,
                              data='c' * size,
                              data_type=str,
                              user_infos={
                                  "informer-lang": "Python",
                                  "index":         str(listener_pid + i)
                              },
                              user_times={
                                  "informer-start": time.time()
                              },
                              causes=set([
                                  rsb.EventId(
                                      uuid.UUID('00000000-0000-0000-0000-000000000000'), 0)
                              ]))
            informer.publish_event(event)

        informer.deactivate()

    print("[Python Informer] Done")
