← Back to branch summary

~elambert/gearmanij/gearman_java_library

« back to all changes in this revision

Viewing changes to src/org/gearman/worker/GearmanWorkerImpl.java

  • Committer: Eric Lambert
  • Date: 2009-07-08 17:44:39 UTC
  • Revision ID: eric.d.lambert@gmail.com-20090708174439-sg3xb0edz5q65ilx
removed session.sendRequestToServer

Show diffs side-by-side

added added

removed removed

Lines of Context:
src/org/gearman/worker/GearmanWorkerImpl.java
256
256
                        GearmanServerRequest gsr = new GearmanServerRequest(
257
257
                                new Packet(PacketMagic.REQ,
258
258
                                PacketType.WORK_FAIL, handle));
259
 
                        sess.sendRequestToServer(gsr);
 
259
                        sess.submitRequest(gsr);
260
260
                    }
261
261
                    GearmanFunction function = def.getFactory().getFunction();
262
262
                    function.setData(data);
335
335
 
336
336
        GearmanPacket p = new Packet(PacketMagic.REQ, PacketType.SET_CLIENT_ID,
337
337
                ByteUtils.toUTF8Bytes(id));
338
 
        session.sendRequestToServer(new GearmanServerRequest(p));
 
338
        session.submitRequest(new GearmanServerRequest(p));
339
339
 
340
340
        for (FunctionDefinition def : functionMap.values()) {
341
341
            p = generateCanDoPacket(def);
342
 
            session.sendRequestToServer(new GearmanServerRequest(p));
 
342
            session.submitRequest(new GearmanServerRequest(p));
343
343
        }
344
344
 
345
345
        if (isRunning()) {
346
346
            p = new Packet(PacketMagic.REQ, PacketType.GRAB_JOB, new byte[0]);
347
347
            GearmanServerRequest gsr = new GearmanServerRequest(
348
348
                    new GrabJobEventHandler(session), p);
349
 
            session.sendRequestToServer(gsr);
 
349
            session.submitRequest(gsr);
350
350
        }
351
351
        LOG.log(Level.FINE, "Added server " + conn + " to worker " + this);
352
352
    }
481
481
            gsr = new GearmanServerRequest(handler, p);
482
482
        }
483
483
        for (GearmanWorkerJobServerSession sess : sessionList) {
484
 
            sess.sendRequestToServer(gsr);
 
484
            sess.submitRequest(gsr);
485
485
        }
486
486
 
487
487
    }