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