bq_hashmap.py
def put_data(self, Qi, data):
        """Enqueues data into the queue with key Qi"""
        try:
            self.hashmap[Qi].enqueue(data)
        except KeyError:
            print("Error: queue with key " +str(Qi)+" does not exist or has \
been popped, please create it before accessing")
            raise

        if self.hashmap[Qi].is_queue_full():
            #the queue will only be popped when it has reached its buffer size
            self.send_zipped_pickle(self.hashmap[Qi].dequeue())
            self.hashmap.pop(Qi)
Enqueues data into the queue with key Qi
Enqueues data into the queue with key Qi
Enqueues data into the queue with key Qi
def put_data(self, Qi, data):
        try:
            self.hashmap[Qi].enqueue(data)
        except KeyError:
            print("Error: queue with key " +str(Qi)+" does not exist or has \
been popped, please create it before accessing")
            raise
        if self.hashmap[Qi].is_queue_full():
            self.send_zipped_pickle(self.hashmap[Qi].dequeue())
            self.hashmap.pop(Qi)
def put_data ( self , Qi , data ) : try : self . hashmap [ Qi ] . enqueue ( data ) except KeyError : print ( "Error: queue with key " + str ( Qi ) + " does not exist or has \
been popped, please create it before accessing" ) raise if self . hashmap [ Qi ] . is_queue_full ( ) : self . send_zipped_pickle ( self . hashmap [ Qi ] . dequeue ( ) ) self . hashmap . pop ( Qi )
Enqueues data into the queue with key Qi
Enqueues data into the queue with key Qi
"""Enqueues data into the queue with key Qi""" #the queue will only be popped when it has reached its buffer size
self
Qi
data