+ return 1;
+}
+
+int ftp_pending(struct ftp *ftp)
+{
+ int maxfd = -1;
+ fd_set rdset;
+ struct timeval tv = {0, 0};
+
+ FD_ZERO(&rdset);
+ if(ftp->ctl >= 0) {
+ FD_SET(ftp->ctl, &rdset);
+ maxfd = ftp->ctl;
+ }
+ if(ftp->data >= 0) {
+ FD_SET(ftp->data, &rdset);
+ if(ftp->data > maxfd) maxfd = ftp->data;
+ }
+ if(maxfd == -1) return 0;
+
+ return select(maxfd + 1, &rdset, 0, 0, &tv) > 0 ? 1 : 0;
+}
+
+int ftp_handle(struct ftp *ftp, int s)
+{
+ if(s == ftp->ctl) {
+ return handle_control(ftp);
+ }
+ if(s == ftp->data) {
+ return handle_data(ftp, s);
+ }
+ return -1;
+}
+
+static int handle_control(struct ftp *ftp)
+{
+ int i, sz, rd;
+ char *buf, *start, *end;
+
+ while((sz = sizeof ftp->crecv - ftp->num_crecv) > 0) {
+ start = ftp->crecv + ftp->num_crecv;
+ if((rd = recv(ftp->ctl, start, sz, 0)) == -1) {
+ if(errno == EINTR) continue;
+ /* assume EWOULDBLOCK, try again next time */
+ return 0;
+ }
+ if(rd == 0) {
+ ftp_close(ftp);
+ return -1;
+ }
+
+ end = start + rd;
+ buf = ftp->crecv;
+ for(i=0; i<rd; i++) {
+ if(start[i] == '\n') {
+ start[i] = 0;
+ proc_control(ftp, buf);
+ buf = start + i + 1;
+ }
+ }
+ if(buf != ftp->crecv && buf < end) {
+ ftp->num_crecv = end - buf;
+ memmove(ftp->crecv, buf, ftp->num_crecv);
+ }
+ }
+ return 0;
+}
+
+static int handle_data(struct ftp *ftp, int s)
+{
+ return -1;
+}
+
+static void proc_control(struct ftp *ftp, const char *buf)
+{