current development rebased on gearman org branch

.travis.yml

@@ -0,0 +1,44 @@
+language: perl
+perl:
+  - "5.24"
+  - "5.22"
+  - "5.20"
+  - "5.18"
+  - "5.16"
+  - "5.14"
+  - "5.12"
+  - "5.10"
+
+sudo: true
+
+matrix:
+  include:
+    - perl: 5.18
+      env: COVERAGE=1
+
+before_install:
+  - sudo apt-get update -qq
+  - sudo apt-get install -y gearman-job-server
+  - git clone git://github.com/travis-perl/helpers ~/travis-perl-helpers
+  - source ~/travis-perl-helpers/init
+  - build-perl
+  - perl -V
+  - build-dist
+  - cd $BUILD_DIR
+
+install:
+  - cpanm --quiet --notest Devel::Cover::Report::Coveralls
+  - cpanm --quiet --notest --installdeps .
+
+script:
+  - perl Makefile.PL
+  - make
+  - PERL5OPT=-MDevel::Cover=-coverage,statement,branch,condition,path,subroutine prove -b -r -s t
+  - cover
+
+after_success:
+  - cover -report coveralls
+
+branches:
+  only:
+    - master

CHANGES

@@ -1,3 +1,78 @@
+2.001.001 2016-10-13 10:45:00 Europe/Berlin (TRIAL RELEASE)
+     -- support for SSL connection to gearmand
+     -- support IPv6
+     -- tests refactoring
+
+1.130.004 (2016-08-06)
+     -- add Gearman::ResponseParser pod
+     -- add Gearman::ResposeParser::Taskset pod
+     -- rename Gearman::Taskset->_process_packet to process_packet
+     -- issue 116744 Utility pod
+
+1.130.003 (2016-08-05)
+     -- check OS in Test::Gearman and don't use "which" on Windows
+     -- replace 'use Errno qw(EAGAIN)' by 'POSIX qw(:errno_h)'
+        see: http://www.cpantesters.org/cpan/report/d801a704-5975-11e6-9451-9b92aab8e0c0
+
+1.130.002 (2016-08-03)
+     -- skip worker _get_js_sock test without gearmand
+
+1.130.001 (2016-08-02)
+     -- refactoring of Gearman::Util::read_res_packet: no goto/redo
+     -- test suite refactoring
+     -- solved issue 85191 Programming error prevents Gearman::Worker::work() from connecting to servers
+     -- solved issue 59185 document Gearman::Client::get_status
+     -- solved issue 56508 using $task->fail("reason goes here") in Gearman::Taskset
+
+1.12.009 (2016-06-04)
+     -- run t/30-maxqueue.t and t/40-prefix.t only with AUTHOR_TESTING
+     -- s/::Object/::Objects/
+
+1.12.008 (2016-06-03)
+     -- rename Gearman::Base back to Geamrman::Object because Gearman-Client-Async depends on it
+
+1.12.007 (2016-05-20)
+     -- more tests only with AUTHOR_TESTING
+
+1.12.006 (2016-05-19)
+     -- tests refactoring
+     -- execute some tests only if AUTHOR_TESTING env is defined
+
+1.12.005 (2016-05-06)
+     -- rm META.*
+
+1.12.004 (2016-05-06)
+
+     -- solved issue 5324ce04-0bae-11e6-a317-839d20bbf307
+        there was a bug in test script
+
+1.12.003 (2016-05-01)
+
+     -- tested with perl5-22-1 to improve cpan tester resport
+        5324ce04-0bae-11e6-a317-839d20bbf307
+
+     -- fields moved from Gearman::Objects to proper modules
+
+     -- rm obsolete Gearman::Objects
+
+     -- use warnings (except redefine)
+
+     -- perltidy applied to all modules
+
+1.12.002 (2014-12-19)
+
+     -- attempt to fix bugs: 89037, 100594, 101012
+
+     -- cpan tester report 586f5968-8489-11e4-adb9-802de0bfc7aa is - ugly - fixed too
+
+     -- refactoring: Client/Worker base class added
+
+     -- dynamic tests by using environment variable GEARMAN_SERVERS
+
+1.12 (2014-12-14)
+
+     -- Repoint HACKING file.
+
      -- Make a jobserver connection use the command timeout during exception negotiation.
 
      -- Make $taskset->add_task use the command timeout to not hang during job submission.
@@ -132,3 +207,4 @@
      -- finally package it up and call it 1.00 now that we've been using
         it in (LiveJournal) production for quite a while, finding/fixing
         the bugs that happen when you put something into production.
+

MANIFEST

@@ -1,6 +1,6 @@
 CHANGES
-HACKING
 lib/Gearman/Client.pm
+lib/Gearman/Job.pm
 lib/Gearman/JobStatus.pm
 lib/Gearman/Objects.pm
 lib/Gearman/ResponseParser.pm
@@ -12,17 +12,29 @@ lib/Gearman/Worker.pm
 Makefile.PL
 MANIFEST			This list of files
 MANIFEST.SKIP			This list of files
-META.yml
 t/00-use.t
-t/10-all.t
-t/20-leaktest.t
-t/30-maxqueue.t
+t/01-object.t
+t/02-client.t
+t/03-worker.t
+t/04-task.t
+t/05-taskset.t
+t/06-response-parser.t
+t/07-response-parser-taskset.t
+t/08-jobstatus.t
+t/09-connect.t
+t/10-job.t
+t/11-unit.t
+t/12-sum.t
+t/13-fail.t
+t/14-sleep.t
+t/15-priority.t
+t/16-background.t
+t/17-status.t
+t/18-ssl.t
 t/40-prefix.t
 t/50-wait_timeout.t
-t/51-large_args.t
-t/60-stop-if.t
-t/lib/GearTestLib.pm
-t/TestGearman.pm
-t/worker.pl
 t/65-responseparser.t
+t/Server.pm
+t/Worker.pm
+README
 TODO

Makefile.PL

@@ -1,16 +1,54 @@
 use 5.008;
+use strict;
+use warnings;
+
 use ExtUtils::MakeMaker;
+
 # See lib/ExtUtils/MakeMaker.pm for details of how to influence
 # the contents of the Makefile that is written.
 WriteMakefile(
-              'NAME'=> 'Gearman',
-              'VERSION_FROM' => 'lib/Gearman/Client.pm',
-              'PREREQ_PM' => {
-                String::CRC32 => 0,
-		Time::HiRes   => 0, # Usually core now
-              }, # e.g., Module::Name => 1.1
-              AUTHOR     => 'Brad Fitzpatrick <brad@danga.com>',
-              ABSTRACT   => "Client and worker libraries for gearman job dispatch dispatch.  Server is in separate package.",
-              );
+    NAME   => "Gearman",
+    AUTHOR => 'Brad Fitzpatrick <brad@danga.com>',
+    ABSTRACT =>
+        "Client and worker libraries for gearman job dispatch dispatch. Server is in separate package.",
+    VERSION_FROM   => "lib/Gearman/Client.pm",
+    BUILD_REQUIRES => {
+        "version"          => 0,
+        "File::Which"      => 0,
+        "IO::Socket::IP" => 0,
+        "IO::Socket::SSL"  => 0,
+        "Perl::OSType"     => 0,
+        "Proc::Guard"      => "0.07",
+        "Storable"         => 0,
+        "Test::Exception"  => 0,
+        "Test::More"       => 0,
+        "Test::TCP"        => "2.17",
+        "Test::Timer"      => 0,
+    },
+    PREREQ_PM => {
+        "version"          => 0,
+        "Carp"             => 0,
+        "POSIX"            => 0,
+        "IO::Handle"       => 0,
+        "IO::Socket::IP" => 0,
+        "IO::Socket::SSL"  => 0,
+        "Scalar::Util"     => 0,
+        "Socket"           => 0,
+        "Storable"         => 1,
+        "String::CRC32"    => 0,
+        "Time::HiRes"      => 0,    # Usually core now
+        "fields"           => 0,
+    },
+    META_MERGE => {
+        'meta-spec' => { version => 2 },
+        resources   => {
+            repository => {
+                type => 'git',
+                url  => 'https://github.com/p-alik/perl-Gearman.git',
+                web  => 'https://github.com/p-alik/perl-Gearman',
+            },
+        },
+    },
+);
 
 1;

README

@@ -0,0 +1,33 @@
+Gearman client, task and worker implementation for perl
+
+Gearman::Client - Client for gearman distributed job system
+Gearman::Task - a task in Gearman, from the point of view of a client
+Gearman::Worker - Worker for gearman distributed job system
+
+INSTALLATION
+
+To install this module, run the following commands:
+
+	perl Makefile.PL
+	make
+	make test
+	make install
+
+SUPPORT AND DOCUMENTATION
+
+After installing, you can find documentation for this module with the
+perldoc command.
+
+    perldoc Log::Log4perl::Appender::Elasticsearch
+    perldoc Log::Log4perl::Appender::Elasticsearch::Bulk
+
+    perldoc Gearman::Client
+    perldoc Gearman::Task
+    perldoc Gearman::Worker
+
+LICENSE AND COPYRIGHT
+
+Copyright 2006-2007 Six Apart, Ltd.
+
+This library is free software; you can redistribute it and/or modify
+it under the same terms as Perl itself.

README.md

@@ -0,0 +1,15 @@
+Gearman
+===================
+
+[![CPAN version](https://badge.fury.io/pl/Gearman.png)](https://badge.fury.io/pl/Gearman)
+[![Build Status](https://travis-ci.org/p-alik/perl-Gearman.png)](https://travis-ci.org/p-alik/perl-Gearman)
+[![Coverage Status](https://coveralls.io/repos/github/p-alik/perl-Gearman/badge.png)](https://coveralls.io/github/p-alik/perl-Gearman)
+
+This repository contains perl [Gearman](http://gearman.org) Client/Worker implementation
+
+perl Modules
+------------
+* [Gearman::Client](https://metacpan.org/pod/Gearman::Client) - Client for gearman distributed job system
+* [Gearman::Task](https://metacpan.org/pod/Gearman::Task)     - a task in Gearman, from the point of view of a client
+* [Gearman::Worker](https://metacpan.org/pod/Gearman::Worker) - Worker for gearman distributed job system
+