const char* SVN_ADD_FILE_TAG = SVN_NS "add-file";
const char* SVN_TXDELTA_TAG = SVN_NS "txdelta";
const char* SVN_SET_PROP_TAG = SVN_NS "set-prop";
+ const char* SVN_PROP_TAG = SVN_NS "prop";
const char* SVN_DELETE_ENTRY_TAG = SVN_NS "delete-entry";
const char* SVN_DAV_MD5_CHECKSUM = SUBVERSION_DAV_NS ":md5-checksum";
const char* DAV_HREF_TAG = DAV_NS "href";
- const char* DAV_CHECKED_IN_TAG = SVN_NS "checked-in";
+ const char* DAV_CHECKED_IN_TAG = DAV_NS "checked-in";
const int svn_txdelta_source = 0;
_ptr = p;
}
- bool apply(std::vector<char>& output, std::istream& source)
+ bool apply(std::vector<unsigned char>& output, std::istream& source)
{
unsigned char* pEnd = _ptr + instructionLength;
unsigned char* newData = pEnd;
while (_ptr < pEnd) {
int op = ((*_ptr >> 6) & 0x3);
if (op >= 3) {
- SG_LOG(SG_IO, SG_INFO, "SVNDeltaWindow: bad opcode:" << op);
+ SG_LOG(SG_IO, SG_INFO, "SVNDeltaWindow: bad opcode:" << op);
return false;
}
}
if (op == svn_txdelta_target) {
- while (length > 0) {
- output.push_back(output[offset++]);
- --length;
- }
+ // this is inefficent, but ranges can overlap.
+ while (length > 0) {
+ output.push_back(output[offset++]);
+ --length;
+ }
} else if (op == svn_txdelta_new) {
output.insert(output.end(), newData, newData + length);
+ newData += length;
} else if (op == svn_txdelta_source) {
source.seekg(offset);
char* sourceBuf = (char*) malloc(length);
source.read(sourceBuf, length);
output.insert(output.end(), sourceBuf, sourceBuf + length);
free(sourceBuf);
+ } else {
+ SG_LOG(SG_IO, SG_WARN, "bad opcode logic");
+ return false;
}
} // of instruction loop
string fileName(attrs.getValue("name"));
SGPath filePath(Dir(currentPath).file(fileName));
currentPath = filePath;
-
- DAVResource* res = currentDir->collection()->childWithName(fileName);
- if (!res || !filePath.exists()) {
- // set error condition
+
+ if (!filePath.exists()) {
+ fail(SVNRepository::SVN_ERROR_FILE_NOT_FOUND);
+ return;
}
-
+
inFile = true;
} else if (!strcmp(name, SVN_ADD_DIRECTORY_TAG)) {
string dirName(attrs.getValue("name"));
} else if (!strcmp(name, SVN_DELETE_ENTRY_TAG)) {
string entryName(attrs.getValue("name"));
deleteEntry(entryName);
- } else if (!strcmp(name, DAV_CHECKED_IN_TAG) || !strcmp(name, DAV_HREF_TAG)) {
+ } else if (!strcmp(name, DAV_CHECKED_IN_TAG) ||
+ !strcmp(name, DAV_HREF_TAG) ||
+ !strcmp(name, SVN_PROP_TAG)) {
// don't warn on these ones
} else {
- //std::cerr << "unhandled element:" << name << std::endl;
+ //SG_LOG(SG_IO, SG_WARN, "SVNReportParser: unhandled tag:" << name);
}
} // of startElement
}
bool decodeTextDelta(const SGPath& outputPath)
- {
- string decoded = strutils::decodeBase64(txDeltaData);
+ {
+ std::vector<unsigned char> output, decoded;
+ strutils::decodeBase64(txDeltaData, decoded);
size_t bytesToDecode = decoded.size();
- std::vector<char> output;
- unsigned char* p = (unsigned char*) decoded.data();
+
+ unsigned char* p = decoded.data();
if (memcmp(p, "SVN\0", DELTA_HEADER_SIZE) != 0) {
return false; // bad header
}
while (bytesToDecode > 0) {
if (!SVNDeltaWindow::isWindowComplete(p, bytesToDecode)) {
- SG_LOG(SG_IO, SG_WARN, "SVN txdelta broken window");
- return false;
- }
+ SG_LOG(SG_IO, SG_WARN, "SVN txdelta broken window");
+ return false;
+ }
SVNDeltaWindow window(p);
assert(bytesToDecode >= window.size());
std::ofstream f;
f.open(outputPath.c_str(),
std::ios::out | std::ios::trunc | std::ios::binary);
- f.write(output.data(), output.size());
+ f.write((char*) output.data(), output.size());
// compute MD5 while we have the file in memory
memset(&md5Context, 0, sizeof(SG_MD5_CTX));
SG_MD5Init(&md5Context);
SG_MD5Update(&md5Context, (unsigned char*) output.data(), output.size());
- SG_MD5Final(&md5Context);
- decodedFileMd5 = strutils::encodeHex(md5Context.digest, 16);
+ unsigned char digest[MD5_DIGEST_LENGTH];
+ SG_MD5Final(digest, &md5Context);
+ decodedFileMd5 = strutils::encodeHex(digest, MD5_DIGEST_LENGTH);
return true;
}
fail(SVNRepository::SVN_ERROR_TXDELTA);
}
} else if (!strcmp(name, SVN_ADD_FILE_TAG)) {
- finishFile(currentDir->addChildFile(currentPath.file()));
+ finishFile(currentPath);
} else if (!strcmp(name, SVN_OPEN_FILE_TAG)) {
- DAVResource* res = currentDir->collection()->childWithName(currentPath.file());
- assert(res);
- finishFile(res);
+ finishFile(currentPath);
} else if (!strcmp(name, SVN_ADD_DIRECTORY_TAG)) {
// pop directory
currentPath = currentPath.dir();
fail(SVNRepository::SVN_ERROR_CHECKSUM);
}
} else if (!strcmp(name, SVN_OPEN_DIRECTORY_TAG)) {
+ currentDir->updateReportComplete();
if (currentDir->parent()) {
// pop the collection stack
currentDir = currentDir->parent();
}
- currentDir->updateReportComplete();
currentPath = currentDir->fsPath();
} else {
// std::cout << "element:" << name;
}
}
- void finishFile(DAVResource* res)
+ void finishFile(const SGPath& path)
{
- res->setVersionName(currentVersionName);
- res->setMD5(md5Sum);
- currentPath = currentPath.dir();
+ currentPath = path.dir();
inFile = false;
}
}
if (tagStack.back() == SVN_SET_PROP_TAG) {
- setPropValue += string(s, length);
+ setPropValue.append(s, length);
} else if (tagStack.back() == SVN_TXDELTA_TAG) {
- txDeltaData += string(s, length);
+ txDeltaData.append(s, length);
} else if (tagStack.back() == SVN_DAV_MD5_CHECKSUM) {
- md5Sum += string(s, length);
+ md5Sum.append(s, length);
}
}