def read_handshake(self):
msg = self.read_message()<EOL>pid_dir, _conf, _context = msg["<STR_LIT>"], msg["<STR_LIT>"], msg["<STR_LIT>"]<EOL>open(join(pid_dir, str(self.pid)), "<STR_LIT:w>").close()<EOL>self.send_message({"<STR_LIT>": self.pid})<EOL>return _conf, _context<EOL>
Read and process an initial handshake message from Storm.