+
+myoob()
+{
+ char mark, *cp;
+ int aflag = 0, count = 0, iacflag = 0, c;
+
+ if (!transflag) {
+ for (;;) {
+ if (ioctl(fileno(stdin), SIOCATMARK, &mark) < 0) {
+ perror("ioctl");
+ break;
+ }
+ if (mark) {
+ break;
+ }
+ read(fileno(stdin), &mark, 1);
+ c = 0377 & mark;
+ }
+ recv(fileno(stdin), &mark, 1, MSG_OOB);
+ c = 0377 & mark;
+ read(fileno(stdin), &mark, 1);
+ return;
+ }
+ for (;;) {
+ if (ioctl(fileno(stdin), SIOCATMARK, &mark) < 0) {
+ perror("ioctl");
+ break;
+ }
+ if (mark) {
+ break;
+ }
+ read(fileno(stdin), &mark, 1);
+ c = 0377 & mark;
+ if (c == IAC) {
+ aflag++;
+ }
+ else if (c == IP) {
+ aflag++;
+ }
+ }
+ recv(fileno(stdin), &mark, 1, MSG_OOB);
+ c = 0377 & mark;
+ if (c == IAC) {
+ aflag++;
+ }
+ read(fileno(stdin), &mark, 1);
+ c = 0377 & mark;
+ if (c == DM) {
+ aflag++;
+ }
+ if (aflag != 4) {
+ return;
+ }
+ cp = tmpline;
+ (void) getline(cp, 7, stdin);
+ upper(cp);
+ if (strcmp(cp, "ABOR\r\n")) {
+ return;
+ }
+ tmpline[0] = '\0';
+ reply(426,"Transfer aborted. Data connection closed.");
+ reply(226,"Abort successful");
+ longjmp(urgcatch, 1);
+}
+
+passive()
+{
+ int len;
+ struct sockaddr_in tmp;
+ register char *p, *a;
+
+ pdata = socket(AF_INET, SOCK_STREAM, 0);
+ if (pdata < 0) {
+ reply(451, "Can't open passive connection");
+ return;
+ }
+ tmp = ctrl_addr;
+ tmp.sin_port = 0;
+ seteuid(0);
+ if (bind(pdata, (char *) &tmp, sizeof(tmp), 0) < 0) {
+ seteuid(pw->pw_uid);
+ (void) close(pdata);
+ pdata = -1;
+ reply(451, "Can't open passive connection");
+ return;
+ }
+ seteuid(pw->pw_uid);
+ len = sizeof(tmp);
+ if (getsockname(pdata, (char *) &tmp, &len) < 0) {
+ (void) close(pdata);
+ pdata = -1;
+ reply(451, "Can't open passive connection");
+ return;
+ }
+ if (listen(pdata, 1) < 0) {
+ (void) close(pdata);
+ pdata = -1;
+ reply(451, "Can't open passive connection");
+ return;
+ }
+ a = (char *) &tmp.sin_addr;
+ p = (char *) &tmp.sin_port;
+
+#define UC(b) (((int) b) & 0xff)
+
+ reply(227, "Entering Passive Mode (%d,%d,%d,%d,%d,%d)", UC(a[0]),
+ UC(a[1]), UC(a[2]), UC(a[3]), UC(p[0]), UC(p[1]));
+}
+
+char *
+gunique(local)
+ char *local;
+{
+ static char new[MAXPATHLEN];
+ char *cp = rindex(local, '/');
+ int d, count=0;
+ char ext = '1';
+
+ if (cp) {
+ *cp = '\0';
+ }
+ d = access(cp ? local : ".", 2);
+ if (cp) {
+ *cp = '/';
+ }
+ if (d < 0) {
+ perror(local);
+ return((char *) 0);
+ }
+ (void) strcpy(new, local);
+ cp = new + strlen(new);
+ *cp++ = '.';
+ while (!d) {
+ if (++count == 100) {
+ reply(451, "Unique file name not cannot be created.");
+ return((char *) 0);
+ }
+ *cp++ = ext;
+ *cp = '\0';
+ if (ext == '9') {
+ ext = '0';
+ }
+ else {
+ ext++;
+ }
+ if ((d = access(new, 0)) < 0) {
+ break;
+ }
+ if (ext != '0') {
+ cp--;
+ }
+ else if (*(cp - 2) == '.') {
+ *(cp - 1) = '1';
+ }
+ else {
+ *(cp - 2) = *(cp - 2) + 1;
+ cp--;
+ }
+ }
+ return(new);
+}
projects / unix-history / commitdiff