Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
9 changes: 5 additions & 4 deletions Net/Gearman/Client.php
Original file line number Diff line number Diff line change
Expand Up @@ -113,15 +113,15 @@ public function __construct($servers = null, $timeout = 1000)
}

/**
* Private function to handle the status communication
* function to handle the status communication
*
* @param string $handle The handle returned when the task was created
* @param string $server The server name(:port) this task was assigned to.
* If not set, all servers in the server list will be checked
* @return mixed An associative array containing information about
* the provided task handle. Returns false if the request failed.
*/
private function getStatus($handle, $server = null)
public function getStatus($handle, $server = null)
{

$params = array(
Expand All @@ -135,9 +135,10 @@ private function getStatus($handle, $server = null)
}

foreach($server_list as $s) {
Net_Gearman_Connection::send($s, 'get_status', $params);
$conn = $this->getConnection();
Net_Gearman_Connection::send($conn, 'get_status', $params);

$read = array($s);
$read = array($conn);
$write = null;
$except = null;

Expand Down
2 changes: 1 addition & 1 deletion Net/Gearman/Connection.php
Original file line number Diff line number Diff line change
Expand Up @@ -306,7 +306,7 @@ static public function read($socket)
}

throw new Net_Gearman_Exception(
$return['err_text'], $return['err_code']
$return['err_text'] . " code: " . $return['err_code']
);
}

Expand Down
8 changes: 8 additions & 0 deletions README.md
Original file line number Diff line number Diff line change
@@ -0,0 +1,8 @@
net_gearman
===========

A PHP interface for Danga's Gearman

I've traced these forks all the way back to https://github.com/lenn0x/net_gearman

I've noticed a few bugs so I'm commiting them in via this fork.