datasift / storyplayer

        $log->endAction();

    }

    public function unbindFromAllPorts()

    {

        // what are we doing?

        $log = usingLog()->startAction("unbind() ZMQ socket from all ports");

        // where are we unbinding from?

        $endpoints = fromZmqSocket($this->args[0])->getEndpoints();

        foreach($endpoints['bind'] as $address) {

            usingLog()->writeToLog("unbinding from {$address}");

            $this->args[0]->unbind($address);

        }

        // all done

        $log->endAction();

    }

    public function connectToHost($hostId, $port, $sendHwm = 100, $recvHwm = 100)

    {

        $log->endAction();

    }

    public function disconnectFromAllHosts()

    {

        // what are we doing?

        $log = usingLog()->startAction("disconnect() ZMQ socket from all endpoints");

        // where are we disconnecting from?

        $endpoints = fromZmqSocket($this->args[0])->getEndpoints();

        foreach($endpoints['connect'] as $address) {

            usingLog()->writeToLog("disconnecting from {$address}");

            $this->args[0]->disconnect($address);

        }

        // all done

        $log->endAction();

    }

    public function close()

    {

        $log->endAction("session running as PID {$sessionDetails->pid}");

    }

    public function stopInScreen($sessionName)

    {

        // what are we doing?

        $log = usingLog()->startAction("stop screen session '{$sessionName}' on host '{$this->args[0]}'");

        // get the process details

        $processDetails = fromHost($this->args[0])->getScreenSessionDetails($sessionName);

        // stop the process

        usingHost($this->args[0])->stopProcess($processDetails->pid);

        // all done

        $log->endAction();

    }

    public function stopAllScreens()

    {