Annotation of src/usr.bin/cvs/client.c, Revision 1.129
1.129 ! naddy 1: /* $OpenBSD: client.c,v 1.128 2018/07/14 21:28:02 joris Exp $ */
1.1 jfb 2: /*
1.9 joris 3: * Copyright (c) 2006 Joris Vink <joris@openbsd.org>
1.1 jfb 4: *
1.9 joris 5: * Permission to use, copy, modify, and distribute this software for any
6: * purpose with or without fee is hereby granted, provided that the above
7: * copyright notice and this permission notice appear in all copies.
8: *
9: * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
10: * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
11: * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
12: * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
13: * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
14: * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
15: * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
1.1 jfb 16: */
17:
1.124 deraadt 18: #include <sys/types.h>
1.59 otto 19: #include <sys/dirent.h>
20: #include <sys/stat.h>
1.97 tobias 21: #include <sys/time.h>
1.59 otto 22:
23: #include <errno.h>
24: #include <fcntl.h>
25: #include <libgen.h>
26: #include <limits.h>
27: #include <pwd.h>
28: #include <stdlib.h>
29: #include <string.h>
1.115 tobias 30: #include <time.h>
1.59 otto 31: #include <unistd.h>
1.1 jfb 32:
33: #include "cvs.h"
1.9 joris 34: #include "remote.h"
1.1 jfb 35:
1.9 joris 36: struct cvs_req cvs_requests[] = {
37: /* this is what our client will use, the server should support it */
38: { "Root", 1, cvs_server_root, REQ_NEEDED },
39: { "Valid-responses", 1, cvs_server_validresp, REQ_NEEDED },
40: { "valid-requests", 1, cvs_server_validreq, REQ_NEEDED },
41: { "Directory", 0, cvs_server_directory, REQ_NEEDED },
1.66 joris 42: { "Static-directory", 0, cvs_server_static_directory,
43: REQ_NEEDED | REQ_NEEDDIR },
44: { "Sticky", 0, cvs_server_sticky,
45: REQ_NEEDED | REQ_NEEDDIR },
46: { "Entry", 0, cvs_server_entry,
47: REQ_NEEDED | REQ_NEEDDIR },
48: { "Modified", 0, cvs_server_modified,
49: REQ_NEEDED | REQ_NEEDDIR },
1.9 joris 50: { "UseUnchanged", 0, cvs_server_useunchanged, REQ_NEEDED },
1.66 joris 51: { "Unchanged", 0, cvs_server_unchanged,
52: REQ_NEEDED | REQ_NEEDDIR },
1.9 joris 53: { "Questionable", 0, cvs_server_questionable, REQ_NEEDED },
54: { "Argument", 0, cvs_server_argument, REQ_NEEDED },
1.24 xsa 55: { "Argumentx", 0, cvs_server_argumentx, REQ_NEEDED },
56: { "Global_option", 0, cvs_server_globalopt, REQ_NEEDED },
1.26 xsa 57: { "Set", 0, cvs_server_set, REQ_NEEDED },
1.121 joris 58: { "expand-modules", 0, cvs_server_exp_modules, 0 },
1.1 jfb 59:
1.9 joris 60: /*
61: * used to tell the server what is going on in our
62: * working copy, unsupported until we are told otherwise
63: */
64: { "Max-dotdot", 0, NULL, 0 },
65: { "Checkin-prog", 0, NULL, 0 },
66: { "Update-prog", 0, NULL, 0 },
67: { "Kopt", 0, NULL, 0 },
68: { "Checkin-time", 0, NULL, 0 },
69: { "Is-modified", 0, NULL, 0 },
70: { "Notify", 0, NULL, 0 },
71: { "Case", 0, NULL, 0 },
72: { "Gzip-stream", 0, NULL, 0 },
1.25 xsa 73: { "wrapper-sendme-rcsOptions", 0, NULL, 0 },
1.9 joris 74: { "Kerberos-encrypt", 0, NULL, 0 },
75: { "Gssapi-encrypt", 0, NULL, 0 },
76: { "Gssapi-authenticate", 0, NULL, 0 },
77:
78: /* commands that might be supported */
1.95 xsa 79: { "ci", 0, cvs_server_commit, REQ_NEEDDIR },
80: { "co", 0, cvs_server_checkout, REQ_NEEDDIR },
81: { "update", 0, cvs_server_update, REQ_NEEDDIR },
82: { "diff", 0, cvs_server_diff, REQ_NEEDDIR },
83: { "log", 0, cvs_server_log, REQ_NEEDDIR },
84: { "rlog", 0, cvs_server_rlog, 0 },
85: { "add", 0, cvs_server_add, REQ_NEEDDIR },
86: { "remove", 0, cvs_server_remove, REQ_NEEDDIR },
87: { "update-patches", 0, cvs_server_update_patches, 0 },
88: { "gzip-file-contents", 0, NULL, 0 },
89: { "status", 0, cvs_server_status, REQ_NEEDDIR },
1.99 tobias 90: { "rdiff", 0, cvs_server_rdiff, 0 },
1.95 xsa 91: { "tag", 0, cvs_server_tag, REQ_NEEDDIR },
92: { "rtag", 0, cvs_server_rtag, 0 },
93: { "import", 0, cvs_server_import, REQ_NEEDDIR },
94: { "admin", 0, cvs_server_admin, REQ_NEEDDIR },
95: { "export", 0, cvs_server_export, REQ_NEEDDIR },
96: { "history", 0, NULL, 0 },
97: { "release", 0, cvs_server_release, REQ_NEEDDIR },
98: { "watch-on", 0, NULL, 0 },
99: { "watch-off", 0, NULL, 0 },
100: { "watch-add", 0, NULL, 0 },
101: { "watch-remove", 0, NULL, 0 },
102: { "watchers", 0, NULL, 0 },
103: { "editors", 0, NULL, 0 },
104: { "init", 0, cvs_server_init, 0 },
105: { "annotate", 0, cvs_server_annotate, REQ_NEEDDIR },
106: { "rannotate", 0, cvs_server_rannotate, 0 },
107: { "noop", 0, NULL, 0 },
108: { "version", 0, cvs_server_version, 0 },
109: { "", -1, NULL, 0 }
1.9 joris 110: };
111:
1.98 joris 112: static void client_check_directory(char *, char *);
1.16 xsa 113: static char *client_get_supported_responses(void);
114: static char *lastdir = NULL;
115: static int end_of_response = 0;
116:
117: static void cvs_client_initlog(void);
118:
119: /*
120: * File descriptors for protocol logging when the CVS_CLIENT_LOG environment
121: * variable is set.
122: */
123: static int cvs_client_logon = 0;
1.42 joris 124: int cvs_client_inlog_fd = -1;
125: int cvs_client_outlog_fd = -1;
1.16 xsa 126:
1.9 joris 127:
1.37 joris 128: int server_response = SERVER_OK;
129:
1.9 joris 130: static char *
131: client_get_supported_responses(void)
132: {
133: BUF *bp;
134: char *d;
135: int i, first;
136:
137: first = 0;
1.122 ray 138: bp = buf_alloc(512);
1.9 joris 139: for (i = 0; cvs_responses[i].supported != -1; i++) {
140: if (cvs_responses[i].hdlr == NULL)
141: continue;
142:
143: if (first != 0)
1.122 ray 144: buf_putc(bp, ' ');
1.9 joris 145: else
146: first++;
1.122 ray 147: buf_puts(bp, cvs_responses[i].name);
1.9 joris 148: }
149:
1.122 ray 150: buf_putc(bp, '\0');
151: d = buf_release(bp);
1.9 joris 152: return (d);
153: }
1.1 jfb 154:
1.10 joris 155: static void
1.98 joris 156: client_check_directory(char *data, char *repository)
1.10 joris 157: {
158: CVSENTRIES *entlist;
1.102 xsa 159: char *entry, *parent, *base, *p;
1.129 ! naddy 160: char basebuf[PATH_MAX], parentbuf[PATH_MAX];
1.10 joris 161:
162: STRIP_SLASH(data);
163:
1.98 joris 164: /* first directory we get is our module root */
1.101 joris 165: if (module_repo_root == NULL && checkout_target_dir != NULL) {
1.98 joris 166: p = repository + strlen(current_cvsroot->cr_dir) + 1;
167: module_repo_root = xstrdup(p);
168: p = strrchr(module_repo_root, '/');
169: if (p != NULL)
170: *p = '\0';
171: }
172:
1.69 joris 173: cvs_mkpath(data, NULL);
1.10 joris 174:
1.90 tobias 175: if (cvs_cmdop == CVS_OP_EXPORT)
176: return;
177:
1.129 ! naddy 178: if (strlcpy(basebuf, data, sizeof(basebuf)) >= sizeof(basebuf))
! 179: fatal("client_check_directory: truncation");
! 180: if ((base = basename(basebuf)) == NULL)
1.10 joris 181: fatal("client_check_directory: overflow");
182:
1.129 ! naddy 183: if (strlcpy(parentbuf, data, sizeof(parentbuf)) >= sizeof(parentbuf))
! 184: fatal("client_check_directory: truncation");
! 185: if ((parent = dirname(parentbuf)) == NULL)
1.10 joris 186: fatal("client_check_directory: overflow");
1.11 joris 187:
188: if (!strcmp(parent, "."))
189: return;
1.10 joris 190:
1.102 xsa 191: entry = xmalloc(CVS_ENT_MAXLINELEN);
192: cvs_ent_line_str(base, NULL, NULL, NULL, NULL, 1, 0, entry,
193: CVS_ENT_MAXLINELEN);
1.10 joris 194:
195: entlist = cvs_ent_open(parent);
196: cvs_ent_add(entlist, entry);
1.102 xsa 197:
1.125 nicm 198: free(entry);
1.10 joris 199: }
200:
1.9 joris 201: void
202: cvs_client_connect_to_server(void)
203: {
1.26 xsa 204: struct cvs_var *vp;
1.127 millert 205: char *cmd, *argv[10], *resp;
1.9 joris 206: int ifd[2], ofd[2], argc;
1.45 joris 207:
208: if (cvs_server_active == 1)
209: fatal("cvs_client_connect: I was already connected to server");
1.1 jfb 210:
1.9 joris 211: switch (current_cvsroot->cr_method) {
212: case CVS_METHOD_PSERVER:
213: case CVS_METHOD_KSERVER:
214: case CVS_METHOD_GSERVER:
215: case CVS_METHOD_FORK:
1.14 joris 216: fatal("the specified connection method is not supported");
1.9 joris 217: default:
218: break;
219: }
220:
221: if (pipe(ifd) == -1)
222: fatal("cvs_client_connect: %s", strerror(errno));
223: if (pipe(ofd) == -1)
224: fatal("cvs_client_connect: %s", strerror(errno));
225:
226: switch (fork()) {
227: case -1:
228: fatal("cvs_client_connect: fork failed: %s", strerror(errno));
229: case 0:
230: if (dup2(ifd[0], STDIN_FILENO) == -1)
231: fatal("cvs_client_connect: %s", strerror(errno));
232: if (dup2(ofd[1], STDOUT_FILENO) == -1)
233: fatal("cvs_client_connect: %s", strerror(errno));
1.1 jfb 234:
1.9 joris 235: close(ifd[1]);
236: close(ofd[0]);
1.1 jfb 237:
1.9 joris 238: if ((cmd = getenv("CVS_SERVER")) == NULL)
239: cmd = CVS_SERVER_DEFAULT;
1.1 jfb 240:
241: argc = 0;
242: argv[argc++] = cvs_rsh;
243:
1.9 joris 244: if (current_cvsroot->cr_user != NULL) {
1.1 jfb 245: argv[argc++] = "-l";
1.9 joris 246: argv[argc++] = current_cvsroot->cr_user;
1.1 jfb 247: }
248:
1.127 millert 249: argv[argc++] = "--";
1.9 joris 250: argv[argc++] = current_cvsroot->cr_host;
251: argv[argc++] = cmd;
1.1 jfb 252: argv[argc++] = "server";
253: argv[argc] = NULL;
254:
1.9 joris 255: cvs_log(LP_TRACE, "connecting to server %s",
256: current_cvsroot->cr_host);
257:
1.1 jfb 258: execvp(argv[0], argv);
1.9 joris 259: fatal("cvs_client_connect: failed to execute cvs server");
260: default:
261: break;
1.1 jfb 262: }
263:
1.9 joris 264: close(ifd[0]);
265: close(ofd[1]);
266:
267: if ((current_cvsroot->cr_srvin = fdopen(ifd[1], "w")) == NULL)
268: fatal("cvs_client_connect: %s", strerror(errno));
269: if ((current_cvsroot->cr_srvout = fdopen(ofd[0], "r")) == NULL)
270: fatal("cvs_client_connect: %s", strerror(errno));
1.1 jfb 271:
1.9 joris 272: setvbuf(current_cvsroot->cr_srvin, NULL,_IOLBF, 0);
273: setvbuf(current_cvsroot->cr_srvout, NULL, _IOLBF, 0);
1.1 jfb 274:
1.16 xsa 275: cvs_client_initlog();
276:
1.18 xsa 277: if (cvs_cmdop != CVS_OP_INIT)
278: cvs_client_send_request("Root %s", current_cvsroot->cr_dir);
1.1 jfb 279:
1.9 joris 280: resp = client_get_supported_responses();
281: cvs_client_send_request("Valid-responses %s", resp);
1.125 nicm 282: free(resp);
1.1 jfb 283:
1.9 joris 284: cvs_client_send_request("valid-requests");
285: cvs_client_get_responses();
1.1 jfb 286:
1.28 xsa 287: cvs_client_send_request("UseUnchanged");
288:
1.20 xsa 289: if (cvs_nolog == 1)
290: cvs_client_send_request("Global_option -l");
291:
1.19 xsa 292: if (cvs_noexec == 1)
293: cvs_client_send_request("Global_option -n");
294:
1.76 tobias 295: switch (verbosity) {
296: case 0:
1.19 xsa 297: cvs_client_send_request("Global_option -Q");
1.76 tobias 298: break;
299: case 1:
300: /* Be quiet. This is the default in OpenCVS. */
301: cvs_client_send_request("Global_option -q");
302: break;
303: default:
304: break;
305: }
1.19 xsa 306:
307: if (cvs_readonly == 1)
308: cvs_client_send_request("Global_option -r");
309:
310: if (cvs_trace == 1)
1.9 joris 311: cvs_client_send_request("Global_option -t");
1.26 xsa 312:
313: /* XXX: If 'Set' is supported? */
314: TAILQ_FOREACH(vp, &cvs_variables, cv_link)
315: cvs_client_send_request("Set %s=%s", vp->cv_name, vp->cv_val);
1.1 jfb 316: }
317:
1.9 joris 318: void
319: cvs_client_send_request(char *fmt, ...)
320: {
1.112 tobias 321: int i;
1.9 joris 322: va_list ap;
323: char *data, *s;
324: struct cvs_req *req;
325:
326: va_start(ap, fmt);
1.112 tobias 327: i = vasprintf(&data, fmt, ap);
1.9 joris 328: va_end(ap);
1.112 tobias 329: if (i == -1)
1.113 tobias 330: fatal("cvs_client_send_request: could not allocate memory");
1.1 jfb 331:
1.9 joris 332: if ((s = strchr(data, ' ')) != NULL)
333: *s = '\0';
1.1 jfb 334:
1.9 joris 335: req = cvs_remote_get_request_info(data);
336: if (req == NULL)
337: fatal("'%s' is an unknown request", data);
1.1 jfb 338:
1.9 joris 339: if (req->supported != 1)
340: fatal("remote cvs server does not support '%s'", data);
1.1 jfb 341:
1.9 joris 342: if (s != NULL)
343: *s = ' ';
1.1 jfb 344:
1.12 joris 345: cvs_log(LP_TRACE, "%s", data);
1.16 xsa 346:
1.9 joris 347: cvs_remote_output(data);
1.125 nicm 348: free(data);
1.9 joris 349: }
1.1 jfb 350:
1.9 joris 351: void
352: cvs_client_read_response(void)
1.1 jfb 353: {
1.9 joris 354: char *cmd, *data;
355: struct cvs_resp *resp;
1.1 jfb 356:
1.9 joris 357: cmd = cvs_remote_input();
358: if ((data = strchr(cmd, ' ')) != NULL)
359: (*data++) = '\0';
1.1 jfb 360:
1.9 joris 361: resp = cvs_remote_get_response_info(cmd);
362: if (resp == NULL)
363: fatal("response '%s' is not supported by our client", cmd);
1.1 jfb 364:
1.9 joris 365: if (resp->hdlr == NULL)
366: fatal("opencvs client does not support '%s'", cmd);
1.16 xsa 367:
1.9 joris 368: (*resp->hdlr)(data);
1.16 xsa 369:
1.125 nicm 370: free(cmd);
1.1 jfb 371: }
372:
1.9 joris 373: void
374: cvs_client_get_responses(void)
375: {
376: while (end_of_response != 1)
377: cvs_client_read_response();
1.1 jfb 378:
1.9 joris 379: end_of_response = 0;
1.72 joris 380: }
381:
382: void
383: cvs_client_send_logmsg(char *msg)
384: {
385: char *buf, *p, *q;
386:
387: (void)xasprintf(&buf, "%s\n", msg);
388:
389: cvs_client_send_request("Argument -m");
390: if ((p = strchr(buf, '\n')) != NULL)
391: *p++ = '\0';
392: cvs_client_send_request("Argument %s", buf);
393: for (q = p; p != NULL; q = p) {
394: if ((p = strchr(q, '\n')) != NULL) {
395: *p++ = '\0';
396: cvs_client_send_request("Argumentx %s", q);
397: }
398: }
399:
1.125 nicm 400: free(buf);
1.9 joris 401: }
1.1 jfb 402:
1.9 joris 403: void
404: cvs_client_senddir(const char *dir)
1.1 jfb 405: {
1.34 xsa 406: struct stat st;
1.29 xsa 407: int nb;
1.124 deraadt 408: char *d, *date, fpath[PATH_MAX], repo[PATH_MAX], *tag;
1.29 xsa 409:
410: d = NULL;
1.9 joris 411:
412: if (lastdir != NULL && !strcmp(dir, lastdir))
413: return;
1.1 jfb 414:
1.124 deraadt 415: cvs_get_repository_path(dir, repo, PATH_MAX);
1.31 xsa 416:
1.81 tobias 417: if (cvs_cmdop != CVS_OP_RLOG)
1.70 xsa 418: cvs_client_send_request("Directory %s\n%s", dir, repo);
1.31 xsa 419:
1.124 deraadt 420: (void)xsnprintf(fpath, PATH_MAX, "%s/%s",
1.58 xsa 421: dir, CVS_PATH_STATICENTRIES);
1.34 xsa 422:
423: if (stat(fpath, &st) == 0 && (st.st_mode & (S_IRUSR|S_IRGRP|S_IROTH)))
424: cvs_client_send_request("Static-directory");
425:
1.29 xsa 426: d = xstrdup(dir);
427: cvs_parse_tagfile(d, &tag, &date, &nb);
428:
429: if (tag != NULL || date != NULL) {
430: char buf[128];
431:
1.82 chl 432: if (tag != NULL && nb != 0) {
1.29 xsa 433: if (strlcpy(buf, "N", sizeof(buf)) >= sizeof(buf))
434: fatal("cvs_client_senddir: truncation");
435: } else if (tag != NULL) {
436: if (strlcpy(buf, "T", sizeof(buf)) >= sizeof(buf))
437: fatal("cvs_client_senddir: truncation");
438: } else {
439: if (strlcpy(buf, "D", sizeof(buf)) >= sizeof(buf))
440: fatal("cvs_client_senddir: truncation");
441: }
442:
443: if (strlcat(buf, tag ? tag : date, sizeof(buf)) >= sizeof(buf))
444: fatal("cvs_client_senddir: truncation");
445:
446: cvs_client_send_request("Sticky %s", buf);
447:
1.125 nicm 448: free(tag);
449: free(date);
1.29 xsa 450: }
1.125 nicm 451: free(d);
452: free(lastdir);
1.9 joris 453: lastdir = xstrdup(dir);
454: }
1.1 jfb 455:
1.9 joris 456: void
457: cvs_client_sendfile(struct cvs_file *cf)
1.1 jfb 458: {
1.9 joris 459: size_t len;
1.115 tobias 460: struct tm datetm;
1.92 xsa 461: char rev[CVS_REV_BUFSZ], timebuf[CVS_TIME_BUFSZ], sticky[CVS_REV_BUFSZ];
1.1 jfb 462:
1.9 joris 463: cvs_client_senddir(cf->file_wd);
464: cvs_remote_classify_file(cf);
465:
1.128 joris 466: if (cf->file_type == CVS_DIR)
1.10 joris 467: return;
468:
1.85 tobias 469: if (cf->file_ent != NULL && cvs_cmdop != CVS_OP_IMPORT) {
1.9 joris 470: if (cf->file_status == FILE_ADDED) {
471: len = strlcpy(rev, "0", sizeof(rev));
472: if (len >= sizeof(rev))
473: fatal("cvs_client_sendfile: truncation");
474:
475: len = strlcpy(timebuf, "Initial ", sizeof(timebuf));
476: if (len >= sizeof(timebuf))
477: fatal("cvs_client_sendfile: truncation");
478:
479: len = strlcat(timebuf, cf->file_name, sizeof(timebuf));
480: if (len >= sizeof(timebuf))
481: fatal("cvs_client_sendfile: truncation");
482: } else {
483: rcsnum_tostr(cf->file_ent->ce_rev, rev, sizeof(rev));
484: ctime_r(&cf->file_ent->ce_mtime, timebuf);
485: }
1.1 jfb 486:
1.9 joris 487: if (cf->file_ent->ce_conflict == NULL) {
1.88 tobias 488: timebuf[strcspn(timebuf, "\n")] = '\0';
1.9 joris 489: } else {
490: len = strlcpy(timebuf, cf->file_ent->ce_conflict,
491: sizeof(timebuf));
492: if (len >= sizeof(timebuf))
493: fatal("cvs_client_sendfile: truncation");
1.120 joris 494: len = strlcat(timebuf, "+=", sizeof(timebuf));
1.56 joris 495: if (len >= sizeof(timebuf))
496: fatal("cvs_client_sendfile: truncation");
1.9 joris 497: }
1.1 jfb 498:
1.9 joris 499: sticky[0] = '\0';
500: if (cf->file_ent->ce_tag != NULL) {
1.57 xsa 501: (void)xsnprintf(sticky, sizeof(sticky), "T%s",
1.9 joris 502: cf->file_ent->ce_tag);
1.103 joris 503: } else if (cf->file_ent->ce_date != -1) {
1.115 tobias 504: gmtime_r(&(cf->file_ent->ce_date), &datetm);
1.104 xsa 505: (void)strftime(sticky, sizeof(sticky),
1.115 tobias 506: "D"CVS_DATE_FMT, &datetm);
1.1 jfb 507: }
508:
1.55 otto 509: cvs_client_send_request("Entry /%s/%s%s/%s/%s/%s",
1.9 joris 510: cf->file_name, (cf->file_status == FILE_REMOVED) ? "-" : "",
1.53 xsa 511: rev, timebuf, cf->file_ent->ce_opts ?
512: cf->file_ent->ce_opts : "", sticky);
1.9 joris 513: }
514:
1.84 tobias 515: if (cvs_cmdop == CVS_OP_ADD)
516: cf->file_status = FILE_MODIFIED;
517:
1.9 joris 518: switch (cf->file_status) {
519: case FILE_UNKNOWN:
1.118 joris 520: if (cf->file_flags & FILE_ON_DISK)
1.9 joris 521: cvs_client_send_request("Questionable %s",
522: cf->file_name);
523: break;
524: case FILE_ADDED:
1.123 nicm 525: if (backup_local_changes) /* for update -C */
526: cvs_backup_file(cf);
527:
528: cvs_client_send_request("Modified %s", cf->file_name);
529: cvs_remote_send_file(cf->file_path, cf->fd);
530: break;
1.9 joris 531: case FILE_MODIFIED:
1.123 nicm 532: if (backup_local_changes) { /* for update -C */
533: cvs_backup_file(cf);
534: cvs_client_send_request("Entry /%s/%s%s/%s/%s/%s",
535: cf->file_name, "", rev, timebuf,
536: cf->file_ent->ce_opts ? cf->file_ent->ce_opts : "",
537: sticky);
538: break;
539: }
540:
1.9 joris 541: cvs_client_send_request("Modified %s", cf->file_name);
1.106 joris 542: cvs_remote_send_file(cf->file_path, cf->fd);
1.9 joris 543: break;
544: case FILE_UPTODATE:
545: cvs_client_send_request("Unchanged %s", cf->file_name);
546: break;
1.1 jfb 547: }
1.9 joris 548: }
1.1 jfb 549:
1.9 joris 550: void
551: cvs_client_send_files(char **argv, int argc)
552: {
553: int i;
1.1 jfb 554:
1.9 joris 555: for (i = 0; i < argc; i++)
556: cvs_client_send_request("Argument %s", argv[i]);
557: }
1.1 jfb 558:
1.9 joris 559: void
560: cvs_client_ok(char *data)
561: {
562: end_of_response = 1;
1.37 joris 563: server_response = SERVER_OK;
1.1 jfb 564: }
565:
1.9 joris 566: void
567: cvs_client_error(char *data)
568: {
569: end_of_response = 1;
1.37 joris 570: server_response = SERVER_ERROR;
1.9 joris 571: }
1.1 jfb 572:
1.9 joris 573: void
574: cvs_client_validreq(char *data)
1.1 jfb 575: {
1.9 joris 576: int i;
577: char *sp, *ep;
578: struct cvs_req *req;
579:
1.62 ray 580: if ((sp = data) == NULL)
581: fatal("Missing argument for Valid-requests");
582:
1.9 joris 583: do {
584: if ((ep = strchr(sp, ' ')) != NULL)
585: *ep = '\0';
586:
587: req = cvs_remote_get_request_info(sp);
588: if (req != NULL)
589: req->supported = 1;
590:
591: if (ep != NULL)
592: sp = ep + 1;
593: } while (ep != NULL);
594:
595: for (i = 0; cvs_requests[i].supported != -1; i++) {
596: req = &cvs_requests[i];
597: if ((req->flags & REQ_NEEDED) &&
598: req->supported != 1) {
599: fatal("server does not support required '%s'",
600: req->name);
601: }
1.1 jfb 602: }
1.9 joris 603: }
1.1 jfb 604:
1.9 joris 605: void
606: cvs_client_e(char *data)
607: {
1.62 ray 608: if (data == NULL)
609: fatal("Missing argument for E");
610:
1.80 tobias 611: fprintf(stderr, "%s\n", data);
1.9 joris 612: }
1.1 jfb 613:
1.9 joris 614: void
615: cvs_client_m(char *data)
616: {
1.62 ray 617: if (data == NULL)
618: fatal("Missing argument for M");
619:
1.80 tobias 620: puts(data);
1.9 joris 621: }
1.1 jfb 622:
1.9 joris 623: void
624: cvs_client_checkedin(char *data)
625: {
626: CVSENTRIES *entlist;
627: struct cvs_ent *ent, *newent;
1.84 tobias 628: size_t len;
1.115 tobias 629: struct tm datetm;
1.102 xsa 630: char *dir, *e, *entry, rev[CVS_REV_BUFSZ];
1.67 xsa 631: char sticky[CVS_ENT_MAXLINELEN], timebuf[CVS_TIME_BUFSZ];
1.1 jfb 632:
1.62 ray 633: if (data == NULL)
634: fatal("Missing argument for Checked-in");
635:
1.9 joris 636: dir = cvs_remote_input();
1.54 otto 637: e = cvs_remote_input();
1.125 nicm 638: free(dir);
1.1 jfb 639:
1.9 joris 640: entlist = cvs_ent_open(data);
1.54 otto 641: newent = cvs_ent_parse(e);
1.9 joris 642: ent = cvs_ent_get(entlist, newent->ce_name);
1.125 nicm 643: free(e);
1.1 jfb 644:
1.9 joris 645: rcsnum_tostr(newent->ce_rev, rev, sizeof(rev));
1.1 jfb 646:
1.9 joris 647: sticky[0] = '\0';
1.84 tobias 648: if (ent == NULL) {
649: len = strlcpy(rev, "0", sizeof(rev));
650: if (len >= sizeof(rev))
651: fatal("cvs_client_sendfile: truncation");
652:
653: len = strlcpy(timebuf, "Initial ", sizeof(timebuf));
654: if (len >= sizeof(timebuf))
655: fatal("cvs_client_sendfile: truncation");
656:
657: len = strlcat(timebuf, newent->ce_name, sizeof(timebuf));
658: if (len >= sizeof(timebuf))
659: fatal("cvs_client_sendfile: truncation");
660: } else {
1.119 tobias 661: gmtime_r(&ent->ce_mtime, &datetm);
662: asctime_r(&datetm, timebuf);
1.84 tobias 663: timebuf[strcspn(timebuf, "\n")] = '\0';
664:
1.103 joris 665: if (newent->ce_tag != NULL) {
1.84 tobias 666: (void)xsnprintf(sticky, sizeof(sticky), "T%s",
1.100 tobias 667: newent->ce_tag);
1.103 joris 668: } else if (newent->ce_date != -1) {
1.115 tobias 669: gmtime_r(&(newent->ce_date), &datetm);
1.104 xsa 670: (void)strftime(sticky, sizeof(sticky),
1.115 tobias 671: "D"CVS_DATE_FMT, &datetm);
1.103 joris 672: }
1.84 tobias 673:
674: cvs_ent_free(ent);
675: }
1.1 jfb 676:
1.102 xsa 677: entry = xmalloc(CVS_ENT_MAXLINELEN);
678: cvs_ent_line_str(newent->ce_name, rev, timebuf,
679: newent->ce_opts ? newent->ce_opts : "", sticky, 0,
680: newent->ce_status == CVS_ENT_REMOVED ? 1 : 0,
681: entry, CVS_ENT_MAXLINELEN);
1.9 joris 682:
683: cvs_ent_free(newent);
684: cvs_ent_add(entlist, entry);
1.102 xsa 685:
1.125 nicm 686: free(entry);
1.1 jfb 687: }
688:
1.9 joris 689: void
690: cvs_client_updated(char *data)
691: {
1.57 xsa 692: int fd;
1.9 joris 693: time_t now;
1.109 tobias 694: mode_t fmode;
1.9 joris 695: size_t flen;
696: CVSENTRIES *ent;
697: struct cvs_ent *e;
698: const char *errstr;
1.115 tobias 699: struct tm datetm;
1.9 joris 700: struct timeval tv[2];
1.124 deraadt 701: char repo[PATH_MAX], *entry;
1.67 xsa 702: char timebuf[CVS_TIME_BUFSZ], revbuf[CVS_REV_BUFSZ];
1.117 joris 703: char *en, *mode, *len, *rpath, *p;
1.124 deraadt 704: char sticky[CVS_ENT_MAXLINELEN], fpath[PATH_MAX];
1.9 joris 705:
1.62 ray 706: if (data == NULL)
707: fatal("Missing argument for Updated");
708:
1.9 joris 709: rpath = cvs_remote_input();
1.54 otto 710: en = cvs_remote_input();
1.9 joris 711: mode = cvs_remote_input();
712: len = cvs_remote_input();
713:
1.98 joris 714: client_check_directory(data, rpath);
1.124 deraadt 715: cvs_get_repository_path(".", repo, PATH_MAX);
1.48 joris 716:
717: STRIP_SLASH(repo);
1.9 joris 718:
719: if (strlen(repo) + 1 > strlen(rpath))
720: fatal("received a repository path that is too short");
721:
1.117 joris 722: p = strrchr(rpath, '/');
723: if (p == NULL)
724: fatal("malicious repository path from server");
725:
726: (void)xsnprintf(fpath, sizeof(fpath), "%s/%s", data, p);
1.9 joris 727:
728: flen = strtonum(len, 0, INT_MAX, &errstr);
729: if (errstr != NULL)
730: fatal("cvs_client_updated: %s: %s", len, errstr);
1.125 nicm 731: free(len);
1.9 joris 732:
733: cvs_strtomode(mode, &fmode);
1.125 nicm 734: free(mode);
1.109 tobias 735: fmode &= ~cvs_umask;
1.9 joris 736:
737: time(&now);
1.115 tobias 738: gmtime_r(&now, &datetm);
739: asctime_r(&datetm, timebuf);
1.88 tobias 740: timebuf[strcspn(timebuf, "\n")] = '\0';
1.9 joris 741:
1.54 otto 742: e = cvs_ent_parse(en);
1.125 nicm 743: free(en);
1.69 joris 744:
745: sticky[0] = '\0';
1.103 joris 746: if (e->ce_tag != NULL) {
1.69 joris 747: (void)xsnprintf(sticky, sizeof(sticky), "T%s", e->ce_tag);
1.103 joris 748: } else if (e->ce_date != -1) {
1.115 tobias 749: gmtime_r(&(e->ce_date), &datetm);
1.104 xsa 750: (void)strftime(sticky, sizeof(sticky),
1.115 tobias 751: "D"CVS_DATE_FMT, &datetm);
1.103 joris 752: }
1.69 joris 753:
1.9 joris 754: rcsnum_tostr(e->ce_rev, revbuf, sizeof(revbuf));
1.102 xsa 755:
756: entry = xmalloc(CVS_ENT_MAXLINELEN);
757: cvs_ent_line_str(e->ce_name, revbuf, timebuf,
758: e->ce_opts ? e->ce_opts : "", sticky, 0, 0,
759: entry, CVS_ENT_MAXLINELEN);
1.9 joris 760:
761: cvs_ent_free(e);
1.90 tobias 762:
763: if (cvs_cmdop != CVS_OP_EXPORT) {
1.98 joris 764: ent = cvs_ent_open(data);
1.90 tobias 765: cvs_ent_add(ent, entry);
766: }
1.102 xsa 767:
1.125 nicm 768: free(entry);
1.9 joris 769:
1.108 joris 770: (void)unlink(fpath);
1.9 joris 771: if ((fd = open(fpath, O_CREAT | O_WRONLY | O_TRUNC)) == -1)
772: fatal("cvs_client_updated: open: %s: %s",
773: fpath, strerror(errno));
1.1 jfb 774:
1.46 joris 775: cvs_remote_receive_file(fd, flen);
1.1 jfb 776:
1.9 joris 777: tv[0].tv_sec = now;
778: tv[0].tv_usec = 0;
779: tv[1] = tv[0];
1.1 jfb 780:
1.9 joris 781: if (futimes(fd, tv) == -1)
782: fatal("cvs_client_updated: futimes: %s", strerror(errno));
1.1 jfb 783:
1.9 joris 784: if (fchmod(fd, fmode) == -1)
785: fatal("cvs_client_updated: fchmod: %s", strerror(errno));
1.1 jfb 786:
1.9 joris 787: (void)close(fd);
1.1 jfb 788:
1.125 nicm 789: free(rpath);
1.1 jfb 790: }
791:
1.9 joris 792: void
793: cvs_client_merged(char *data)
794: {
1.56 joris 795: int fd;
796: time_t now;
1.109 tobias 797: mode_t fmode;
1.56 joris 798: size_t flen;
799: CVSENTRIES *ent;
800: const char *errstr;
801: struct timeval tv[2];
1.115 tobias 802: struct tm datetm;
1.67 xsa 803: char timebuf[CVS_TIME_BUFSZ], *repo, *rpath, *entry, *mode;
1.129 ! naddy 804: char *len, *fpath, *wdir, wdirbuf[PATH_MAX];
1.56 joris 805:
1.62 ray 806: if (data == NULL)
807: fatal("Missing argument for Merged");
808:
1.56 joris 809: rpath = cvs_remote_input();
810: entry = cvs_remote_input();
811: mode = cvs_remote_input();
812: len = cvs_remote_input();
813:
1.98 joris 814: client_check_directory(data, rpath);
815:
1.124 deraadt 816: repo = xmalloc(PATH_MAX);
817: cvs_get_repository_path(".", repo, PATH_MAX);
1.56 joris 818:
819: STRIP_SLASH(repo);
820:
821: if (strlen(repo) + 1 > strlen(rpath))
822: fatal("received a repository path that is too short");
823:
824: fpath = rpath + strlen(repo) + 1;
1.129 ! naddy 825: if (strlcpy(wdirbuf, fpath, sizeof(wdirbuf)) >= sizeof(wdirbuf))
! 826: fatal("cvs_client_merged: truncation");
! 827: if ((wdir = dirname(wdirbuf)) == NULL)
1.56 joris 828: fatal("cvs_client_merged: dirname: %s", strerror(errno));
1.125 nicm 829: free(repo);
1.56 joris 830:
831: flen = strtonum(len, 0, INT_MAX, &errstr);
832: if (errstr != NULL)
833: fatal("cvs_client_merged: %s: %s", len, errstr);
1.125 nicm 834: free(len);
1.56 joris 835:
836: cvs_strtomode(mode, &fmode);
1.125 nicm 837: free(mode);
1.109 tobias 838: fmode &= ~cvs_umask;
1.56 joris 839:
840: time(&now);
1.115 tobias 841: gmtime_r(&now, &datetm);
842: asctime_r(&datetm, timebuf);
1.88 tobias 843: timebuf[strcspn(timebuf, "\n")] = '\0';
1.56 joris 844:
845: ent = cvs_ent_open(wdir);
846: cvs_ent_add(ent, entry);
1.125 nicm 847: free(entry);
1.56 joris 848:
1.108 joris 849: (void)unlink(fpath);
1.56 joris 850: if ((fd = open(fpath, O_CREAT | O_WRONLY | O_TRUNC)) == -1)
851: fatal("cvs_client_merged: open: %s: %s",
852: fpath, strerror(errno));
853:
854: cvs_remote_receive_file(fd, flen);
855:
856: tv[0].tv_sec = now;
857: tv[0].tv_usec = 0;
858: tv[1] = tv[0];
859:
860: if (futimes(fd, tv) == -1)
861: fatal("cvs_client_merged: futimes: %s", strerror(errno));
862:
863: if (fchmod(fd, fmode) == -1)
864: fatal("cvs_client_merged: fchmod: %s", strerror(errno));
865:
866: (void)close(fd);
867:
1.125 nicm 868: free(rpath);
1.9 joris 869: }
1.1 jfb 870:
1.9 joris 871: void
872: cvs_client_removed(char *data)
873: {
1.65 joris 874: CVSENTRIES *entlist;
1.124 deraadt 875: char *rpath, *filename, fpath[PATH_MAX];
1.91 tobias 876:
877: if (data == NULL)
878: fatal("Missing argument for Removed");
1.65 joris 879:
880: rpath = cvs_remote_input();
881: if ((filename = strrchr(rpath, '/')) == NULL)
882: fatal("bad rpath in cvs_client_removed: %s", rpath);
883: filename++;
884:
885: entlist = cvs_ent_open(data);
886: cvs_ent_remove(entlist, filename);
887:
1.124 deraadt 888: (void)xsnprintf(fpath, PATH_MAX, "%s/%s", data, filename);
1.65 joris 889: (void)unlink(fpath);
1.13 joris 890:
1.125 nicm 891: free(rpath);
1.9 joris 892: }
1.1 jfb 893:
1.9 joris 894: void
895: cvs_client_remove_entry(char *data)
1.1 jfb 896: {
1.38 xsa 897: CVSENTRIES *entlist;
1.44 joris 898: char *filename, *rpath;
1.41 joris 899:
1.62 ray 900: if (data == NULL)
901: fatal("Missing argument for Remove-entry");
902:
1.41 joris 903: rpath = cvs_remote_input();
904: if ((filename = strrchr(rpath, '/')) == NULL)
905: fatal("bad rpath in cvs_client_remove_entry: %s", rpath);
1.61 ray 906: filename++;
1.1 jfb 907:
1.38 xsa 908: entlist = cvs_ent_open(data);
1.44 joris 909: cvs_ent_remove(entlist, filename);
1.38 xsa 910:
1.125 nicm 911: free(rpath);
1.36 xsa 912: }
913:
914: void
915: cvs_client_set_static_directory(char *data)
916: {
917: FILE *fp;
1.124 deraadt 918: char *dir, fpath[PATH_MAX];
1.36 xsa 919:
1.62 ray 920: if (data == NULL)
921: fatal("Missing argument for Set-static-directory");
922:
1.36 xsa 923: STRIP_SLASH(data);
924:
925: dir = cvs_remote_input();
1.125 nicm 926: free(dir);
1.36 xsa 927:
1.90 tobias 928: if (cvs_cmdop == CVS_OP_EXPORT)
929: return;
930:
1.124 deraadt 931: (void)xsnprintf(fpath, PATH_MAX, "%s/%s",
1.58 xsa 932: data, CVS_PATH_STATICENTRIES);
1.36 xsa 933:
934: if ((fp = fopen(fpath, "w+")) == NULL) {
935: cvs_log(LP_ERRNO, "%s", fpath);
1.50 otto 936: return;
1.36 xsa 937: }
938: (void)fclose(fp);
1.16 xsa 939: }
1.35 xsa 940:
941: void
942: cvs_client_clear_static_directory(char *data)
943: {
1.124 deraadt 944: char *dir, fpath[PATH_MAX];
1.35 xsa 945:
1.62 ray 946: if (data == NULL)
947: fatal("Missing argument for Clear-static-directory");
948:
1.35 xsa 949: STRIP_SLASH(data);
950:
951: dir = cvs_remote_input();
1.125 nicm 952: free(dir);
1.35 xsa 953:
1.90 tobias 954: if (cvs_cmdop == CVS_OP_EXPORT)
955: return;
956:
1.124 deraadt 957: (void)xsnprintf(fpath, PATH_MAX, "%s/%s",
1.58 xsa 958: data, CVS_PATH_STATICENTRIES);
1.35 xsa 959:
960: (void)cvs_unlink(fpath);
961: }
962:
963: void
964: cvs_client_set_sticky(char *data)
965: {
966: FILE *fp;
1.124 deraadt 967: char *dir, *tag, tagpath[PATH_MAX];
1.35 xsa 968:
1.62 ray 969: if (data == NULL)
970: fatal("Missing argument for Set-sticky");
971:
1.35 xsa 972: STRIP_SLASH(data);
973:
974: dir = cvs_remote_input();
975: tag = cvs_remote_input();
976:
1.90 tobias 977: if (cvs_cmdop == CVS_OP_EXPORT)
978: goto out;
979:
1.98 joris 980: client_check_directory(data, dir);
1.69 joris 981:
1.124 deraadt 982: (void)xsnprintf(tagpath, PATH_MAX, "%s/%s", data, CVS_PATH_TAG);
1.35 xsa 983:
984: if ((fp = fopen(tagpath, "w+")) == NULL) {
985: cvs_log(LP_ERRNO, "%s", tagpath);
986: goto out;
987: }
988:
989: (void)fprintf(fp, "%s\n", tag);
990: (void)fclose(fp);
991: out:
1.125 nicm 992: free(tag);
993: free(dir);
1.35 xsa 994: }
995:
996: void
997: cvs_client_clear_sticky(char *data)
998: {
1.124 deraadt 999: char *dir, tagpath[PATH_MAX];
1.47 xsa 1000:
1.62 ray 1001: if (data == NULL)
1002: fatal("Missing argument for Clear-sticky");
1.35 xsa 1003:
1004: STRIP_SLASH(data);
1005:
1006: dir = cvs_remote_input();
1.90 tobias 1007:
1.98 joris 1008: if (cvs_cmdop == CVS_OP_EXPORT) {
1.125 nicm 1009: free(dir);
1.90 tobias 1010: return;
1.98 joris 1011: }
1.35 xsa 1012:
1.98 joris 1013: client_check_directory(data, dir);
1.69 joris 1014:
1.124 deraadt 1015: (void)xsnprintf(tagpath, PATH_MAX, "%s/%s", data, CVS_PATH_TAG);
1.69 joris 1016: (void)unlink(tagpath);
1.98 joris 1017:
1.125 nicm 1018: free(dir);
1.35 xsa 1019: }
1020:
1021:
1.16 xsa 1022: /*
1023: * cvs_client_initlog()
1024: *
1025: * Initialize protocol logging if the CVS_CLIENT_LOG environment variable is
1026: * set. In this case, the variable's value is used as a path to which the
1027: * appropriate suffix is added (".in" for client input and ".out" for server
1028: * output).
1029: */
1030: static void
1031: cvs_client_initlog(void)
1032: {
1033: u_int i;
1.124 deraadt 1034: char *env, *envdup, buf[PATH_MAX], fpath[PATH_MAX];
1035: char rpath[PATH_MAX], timebuf[CVS_TIME_BUFSZ], *s;
1.16 xsa 1036: struct stat st;
1037: time_t now;
1038: struct passwd *pwd;
1039:
1040: /* avoid doing it more than once */
1041: if (cvs_client_logon)
1042: return;
1043:
1044: if ((env = getenv("CVS_CLIENT_LOG")) == NULL)
1045: return;
1046:
1047: envdup = xstrdup(env);
1048: if ((s = strchr(envdup, '%')) != NULL)
1049: *s = '\0';
1050:
1051: if (strlcpy(buf, env, sizeof(buf)) >= sizeof(buf))
1052: fatal("cvs_client_initlog: truncation");
1053:
1054: if (strlcpy(rpath, envdup, sizeof(rpath)) >= sizeof(rpath))
1055: fatal("cvs_client_initlog: truncation");
1056:
1.125 nicm 1057: free(envdup);
1.16 xsa 1058:
1059: s = buf;
1060: while ((s = strchr(s, '%')) != NULL) {
1061: s++;
1062: switch (*s) {
1063: case 'c':
1.87 tobias 1064: if (strlcpy(fpath, cmdp->cmd_name, sizeof(fpath)) >=
1.16 xsa 1065: sizeof(fpath))
1066: fatal("cvs_client_initlog: truncation");
1067: break;
1068: case 'd':
1069: time(&now);
1.115 tobias 1070: ctime_r(&now, timebuf);
1071: timebuf[strcspn(timebuf, "\n")] = '\0';
1072: if (strlcpy(fpath, timebuf, sizeof(fpath)) >=
1.16 xsa 1073: sizeof(fpath))
1074: fatal("cvs_client_initlog: truncation");
1075: break;
1076: case 'p':
1.57 xsa 1077: (void)xsnprintf(fpath, sizeof(fpath), "%d", getpid());
1.16 xsa 1078: break;
1079: case 'u':
1080: if ((pwd = getpwuid(getuid())) != NULL) {
1081: if (strlcpy(fpath, pwd->pw_name,
1082: sizeof(fpath)) >= sizeof(fpath))
1083: fatal("cvs_client_initlog: truncation");
1084: } else {
1085: fpath[0] = '\0';
1086: }
1087: endpwent();
1088: break;
1089: default:
1090: fpath[0] = '\0';
1091: break;
1092: }
1093:
1094: if (fpath[0] != '\0') {
1095: if (strlcat(rpath, "-", sizeof(rpath)) >= sizeof(rpath))
1096: fatal("cvs_client_initlog: truncation");
1097:
1098: if (strlcat(rpath, fpath, sizeof(rpath))
1099: >= sizeof(rpath))
1100: fatal("cvs_client_initlog: truncation");
1101: }
1102: }
1103:
1104: for (i = 0; i < UINT_MAX; i++) {
1.57 xsa 1105: (void)xsnprintf(fpath, sizeof(fpath), "%s-%d.in", rpath, i);
1.16 xsa 1106:
1107: if (stat(fpath, &st) != -1)
1108: continue;
1109:
1110: if (errno != ENOENT)
1111: fatal("cvs_client_initlog() stat failed '%s'",
1112: strerror(errno));
1113:
1114: break;
1115: }
1116:
1117: if ((cvs_client_inlog_fd = open(fpath,
1.60 xsa 1118: O_RDWR | O_CREAT | O_TRUNC, 0644)) == -1) {
1.16 xsa 1119: fatal("cvs_client_initlog: open `%s': %s",
1120: fpath, strerror(errno));
1121: }
1122:
1123: for (i = 0; i < UINT_MAX; i++) {
1.57 xsa 1124: (void)xsnprintf(fpath, sizeof(fpath), "%s-%d.out", rpath, i);
1.16 xsa 1125:
1126: if (stat(fpath, &st) != -1)
1127: continue;
1128:
1129: if (errno != ENOENT)
1130: fatal("cvs_client_initlog() stat failed '%s'",
1131: strerror(errno));
1132:
1133: break;
1134: }
1135:
1.93 xsa 1136: if ((cvs_client_outlog_fd = open(fpath,
1.60 xsa 1137: O_RDWR | O_CREAT | O_TRUNC, 0644)) == -1) {
1.16 xsa 1138: fatal("cvs_client_initlog: open `%s': %s",
1139: fpath, strerror(errno));
1140: }
1141:
1142: cvs_client_logon = 1;
1.1 jfb 1143: }