Socket-Pair

Installation

First, install socket_pair package by pip.

pip install --upgrade git+https://github.com/asrafulashiq/socket_pair

Or, clone and install from the directory

git clone https://github.com/asrafulashiq/socket_pair.git
cd socket_pair
pip install .

Instruction

Initialization

• Import library:

  from socket_pair.socket_pair import SockPairs

• All teams should initialize sockObj first. For example, for RPI, it should be:

  sockObj = SockPairs(name_self='RPI', 
                      name_other=['NU', 'MU', 'Wrapper'])

  And for MU:

  sockObj = SockPairs(name_self='MU', 
                      name_other=['NU', 'RPI', 'Wrapper'])

  And for NU:

  sockObj = SockPairs(name_self='NU', 
                      name_other=['MU', 'RPI', 'Wrapper'])

  And for Pooja,

  sockObj = SockPairs(name_self='Wrapper', 
                      name_other=['NU', 'RPI', 'MU'])

Synchronization

For synchronization between groups, there are two functions: sync_all and sync_with.

sync_all

Each team should call sync_all three times:

1. At the beginning of batch, so that everyone starts from the same line
2. When Pooja copies the frames for processing
3. When everyone finishes the batch processing

Hence, Pooja's code should look like:

sockObj.sync_all()  # batch start

# Pooja copies the current batch in a folder for the group to process
# and then call
sockObj.sync_all()

# ...

# End of batch, sync here 
sockObj.sync_all()

Codes for other groups should look like:

# start batch
sockObj.sync_all()

# wait to sync here so that next batch from Pooja is ready
sockObj.sync_all()

# Read the frames after sync_all

# ... 

# End of batch, sync here 
sockObj.sync_all()

sync_with

sync_with is called when two groups want to be in sync with each other. In our setting, this happens in the following cases:

• When MU finishes person processing, MU should let NU know that the person processing is done and they should be in sync. The code block for MU should be:

    # ... 
    # finished person processing
    # and then call:
    sockObj.sync_with('NU')
    # ...

  And NU's code should look like:

    # ...
    # finish pre-processing for action detection
    sockObj.sync_with('MU')
  
    # Read MU's PAX results
    # ...

• When RPI finishes bin processing, RPI and NU should be in sync. RPI's code:

    # ...
    # finished bin processing
    sockObj.sync_with('MU')
  
    # ...

  And NU's code should look like:

    # ...
    # finished pre-processing for action detection
    # and then call:
    sockObj.sync_with('RPI')
  
    # read bin results from RPI
  
    # ...