Lines Matching refs:req_id
293 int req_id = generateNextRequestID();
298 sendMessage(Packet.SSH_FXP_CLOSE, req_id, tw.getBytes());
300 expectStatusOKMessage(req_id);
380 int req_id = generateNextRequestID();
386 sendMessage(Packet.SSH_FXP_FSTAT, req_id, tw.getBytes());
396 if (rep_id != req_id)
419 int req_id = generateNextRequestID();
425 sendMessage(statMethod, req_id, tw.getBytes());
435 if (rep_id != req_id)
495 int req_id = generateNextRequestID();
501 sendMessage(Packet.SSH_FXP_READLINK, req_id, tw.getBytes());
511 if (rep_id != req_id)
581 int req_id = generateNextRequestID();
588 sendMessage(Packet.SSH_FXP_SETSTAT, req_id, tw.getBytes());
590 expectStatusOKMessage(req_id);
606 int req_id = generateNextRequestID();
613 sendMessage(Packet.SSH_FXP_FSETSTAT, req_id, tw.getBytes());
615 expectStatusOKMessage(req_id);
628 int req_id = generateNextRequestID();
639 sendMessage(Packet.SSH_FXP_SYMLINK, req_id, tw.getBytes());
641 expectStatusOKMessage(req_id);
655 int req_id = generateNextRequestID();
661 sendMessage(Packet.SSH_FXP_REALPATH, req_id, tw.getBytes());
671 if (rep_id != req_id)
707 int req_id = generateNextRequestID();
713 sendMessage(Packet.SSH_FXP_READDIR, req_id, tw.getBytes());
723 if (rep_id != req_id)
769 int req_id = generateNextRequestID();
775 sendMessage(Packet.SSH_FXP_OPENDIR, req_id, tw.getBytes());
785 if (rep_id != req_id)
927 int req_id = generateNextRequestID();
934 sendMessage(Packet.SSH_FXP_MKDIR, req_id, tw.getBytes());
936 expectStatusOKMessage(req_id);
947 int req_id = generateNextRequestID();
952 sendMessage(Packet.SSH_FXP_REMOVE, req_id, tw.getBytes());
954 expectStatusOKMessage(req_id);
965 int req_id = generateNextRequestID();
970 sendMessage(Packet.SSH_FXP_RMDIR, req_id, tw.getBytes());
972 expectStatusOKMessage(req_id);
984 int req_id = generateNextRequestID();
990 sendMessage(Packet.SSH_FXP_RENAME, req_id, tw.getBytes());
992 expectStatusOKMessage(req_id);
1213 int req_id = generateNextRequestID();
1221 sendMessage(Packet.SSH_FXP_OPEN, req_id, tw.getBytes());
1231 if (rep_id != req_id)
1259 int req_id;
1368 req.req_id = generateNextRequestID();
1378 sendReadRequest(req.req_id, handle, req.serverOffset, req.len);
1380 pendingReadQueue.put(req.req_id, req);
1412 log.debug("Got SSH_FXP_STATUS (" + req.req_id + ") (" + ((desc != null) ? desc[0] : "UNKNOWN") + ")");
1437 log.debug("Got SSH_FXP_DATA (" + req.req_id + ") " + req.serverOffset + "/" + readLen
1447 req.req_id = generateNextRequestID();
1452 sendReadRequest(req.req_id, handle, req.serverOffset, req.len);
1454 pendingReadQueue.put(req.req_id, req);
1473 int req_id;
1499 req.req_id = generateNextRequestID();
1507 sendMessage(Packet.SSH_FXP_WRITE, req.req_id, tw.getBytes());
1509 pendingStatusQueue.put(req.req_id, req);
1541 log.debug("Got SSH_FXP_STATUS (" + status.req_id + ") (" + ((desc != null) ? desc[0] : "UNKNOWN") + ")");
1577 log.debug("Got SSH_FXP_STATUS (" + status.req_id + ") (" + ((desc != null) ? desc[0] : "UNKNOWN") + ")");
