1 files changed, 134 insertions, 0 deletions
diff --git a/split/join.c b/split/join.c
new file mode 100644
index 000000000..9e99f643b
--- /dev/null
+++ b/split/join.c
@@ -0,0 +1,134 @@
+/*
+ * dpkg-split - splitting and joining of multipart *.deb archives
+ * join.c - joining
+ *
+ * Copyright (C) 1995 Ian Jackson <iwj10@cus.cam.ac.uk>
+ *
+ * This is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as
+ * published by the Free Software Foundation; either version 2,
+ * or (at your option) any later version.
+ *
+ * This is distributed in the hope that it will be useful, but
+ * WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public
+ * License along with dpkg; if not, write to the Free Software
+ * Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
+ */
+
+#include <stdio.h>
+#include <stdlib.h>
+#include <limits.h>
+#include <assert.h>
+#include <string.h>
+
+#include "config.h"
+#include "dpkg.h"
+#include "dpkg-db.h"
+#include "dpkg-split.h"
+
+void reassemble(struct partinfo **partlist, const char *outputfile) {
+  FILE *output, *input;
+  void *buffer;
+  struct partinfo *pi;
+  int i,nr;
+  long buffersize;
+
+  printf("Putting package %s together from %d parts: ",
+         partlist[0]->package,partlist[0]->maxpartn);
+  
+  buffersize= partlist[0]->maxpartlen;
+  for (i=0; i<partlist[0]->maxpartn; i++)
+    if (partlist[0]->headerlen > buffersize) buffersize= partlist[0]->headerlen;
+  buffer= m_malloc(partlist[0]->maxpartlen);
+  output= fopen(outputfile,"w");
+  if (!output) ohshite("unable to open output file `%.250s'",outputfile);
+  for (i=0; i<partlist[0]->maxpartn; i++) {
+    pi= partlist[i];
+    input= fopen(pi->filename,"r");
+    if (!input) ohshite("unable to (re)open input part file `%.250s'",pi->filename);
+    assert(pi->headerlen <= buffersize);
+    nr= fread(buffer,1,pi->headerlen,input);
+    if (nr != pi->headerlen) rerreof(input,pi->filename);
+    assert(pi->thispartlen <= buffersize);
+    printf("%d ",i+1);
+    nr= fread(buffer,1,pi->thispartlen,input);
+    if (nr != pi->thispartlen) rerreof(input,pi->filename);
+    if (pi->thispartlen & 1)
+      if (getc(input) == EOF) rerreof(input,pi->filename);
+    if (ferror(input)) rerr(pi->filename);
+    fclose(input);
+    nr= fwrite(buffer,1,pi->thispartlen,output);
+    if (nr != pi->thispartlen) werr(outputfile);
+  }
+  if (fclose(output)) werr(outputfile);
+  printf("done\n");
+}
+
+
+void addtopartlist(struct partinfo **partlist,
+                   struct partinfo *pi, struct partinfo *refi) {
+  int i;
+  
+  if (strcmp(pi->package,refi->package) ||
+      strcmp(pi->version,refi->version) ||
+      strcmp(pi->md5sum,refi->md5sum) ||
+      pi->orglength != refi->orglength ||
+      pi->maxpartn != refi->maxpartn ||
+      pi->maxpartlen != refi->maxpartlen) {
+    print_info(pi);
+    print_info(refi);
+    ohshit("files `%.250s' and `%.250s' are not parts of the same file",
+           pi->filename,refi->filename);
+  }
+  i= pi->thispartn-1;
+  if (partlist[i])
+    ohshit("there are several versions of part %d - at least `%.250s' and `%.250s'",
+           pi->thispartn, pi->filename, partlist[i]->filename);
+  partlist[i]= pi;
+}
+
+void do_join(const char *const *argv) {
+  char *p;
+  const char *thisarg;
+  struct partqueue *pq;
+  struct partinfo *refi, *pi, **partlist;
+  int i;
+  
+  assert(!queue);
+  if (!*argv) badusage("--join requires one or more part file arguments");
+  while ((thisarg= *argv++)) {
+    pq= nfmalloc(sizeof(struct partqueue));
+
+    mustgetpartinfo(thisarg,&pq->info);
+    
+    
+    pq->nextinqueue= queue;
+    queue= pq;
+  }
+  refi= 0;
+  for (pq= queue; pq; pq= pq->nextinqueue)
+    if (!refi || pq->info.thispartn < refi->thispartn) refi= &pq->info;
+  assert(refi);
+  partlist= nfmalloc(sizeof(struct partinfo*)*refi->maxpartn);
+  for (i=0; i<refi->maxpartn; i++) partlist[i]= 0;
+  for (pq= queue; pq; pq= pq->nextinqueue) {
+    pi= &pq->info;
+    addtopartlist(partlist,pi,refi);
+  }
+  for (i=0; i<refi->maxpartn; i++) {
+    if (!partlist[i]) ohshit("part %d is missing",i+1);
+  }
+  if (!outputfile) {
+    p= nfmalloc(strlen(refi->package)+1+strlen(refi->version)+sizeof(DEBEXT));
+    strcpy(p,refi->package);
+    strcat(p,"-");
+    strcat(p,refi->version);
+    strcat(p,DEBEXT);
+    outputfile= p;
+  }
+  reassemble(partlist,outputfile);
+}