Worker does not get jobs if job payload in size ~65480-65510 bytes veny#55

martynas19942 · martynas19942 · commit bc6ec807186b · 2017-03-01T17:40:28.000+02:00
diff --git a/lib/gearmanode/job-server.js b/lib/gearmanode/job-server.js
@@ -300,12 +300,12 @@ JobServer.prototype._processData = function (chunk) {
         return;
     }
 
-    if (chunk.length < protocol.CONSTANTS.HEADER_LEN) { // it's only header fragment, the rest should come in next packet
+    if (chunk.length < protocol.CONSTANTS.HEADER_LEN && chunk[0] == '00') { // it's only header fragment, the rest should come in next packet
         this.headerfrag = chunk;
         return;
     }
 
-    if (chunk.readUInt32BE(0) !== protocol.CONSTANTS.HEADER_RESP) {
+    if (chunk[0] != '00' || chunk.readUInt32BE(0) !== protocol.CONSTANTS.HEADER_RESP) {
         if (this.hasOwnProperty('segmentedPacket')) {
             chunk = Buffer.concat([this.segmentedPacket, chunk]);
         } else if (this.hasOwnProperty('headerfrag')) {

Original file line number	Diff line number	Diff line change
`@@ -300,12 +300,12 @@ JobServer.prototype._processData = function (chunk) {`
`300`	`300`	`return;`
`301`	`301`	`}`
`302`	`302`
`303`		`- if (chunk.length < protocol.CONSTANTS.HEADER_LEN) { // it's only header fragment, the rest should come in next packet`
	`303`	`+ if (chunk.length < protocol.CONSTANTS.HEADER_LEN && chunk[0] == '00') { // it's only header fragment, the rest should come in next packet`
`304`	`304`	`this.headerfrag = chunk;`
`305`	`305`	`return;`
`306`	`306`	`}`
`307`	`307`
`308`		`- if (chunk.readUInt32BE(0) !== protocol.CONSTANTS.HEADER_RESP) {`
	`308`	`+ if (chunk[0] != '00' \|\| chunk.readUInt32BE(0) !== protocol.CONSTANTS.HEADER_RESP) {`
`309`	`309`	`if (this.hasOwnProperty('segmentedPacket')) {`
`310`	`310`	`chunk = Buffer.concat([this.segmentedPacket, chunk]);`
`311`	`311`	`} else if (this.hasOwnProperty('headerfrag')) {`