Newer
Older
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
// CS 225 util.h
// Created Spring 2011 by Jack Toole
#include <ctype.h>
#include <dirent.h>
#include <errno.h>
#include <fcntl.h>
#include <signal.h>
#include <stdlib.h>
#include <sys/stat.h>
#include <sys/time.h>
#include <sys/types.h>
#include <sys/wait.h>
#include <unistd.h>
#include <iostream>
#include "util.h"
extern char ** environ; // man 7 environ
namespace util
{
namespace internal
{
const char * error_prefix = "";
template<typename StrType>
void exit_if_error_output(const char * file, int32_t line, StrType message)
{
if (util::internal::error_prefix != NULL)
cerr << util::internal::error_prefix;
cerr << file << ":" << line << ": " << message;
if (errno != 0)
cerr << ": " << strerror(errno);
cerr << endl;
exit(-1);
}
}
void SET_ERROR_MESSAGE(const char * message)
{
internal::error_prefix = message;
}
char * allocateCstr(const string & str)
{
char * cstr = new char[str.size() + 1];
str.copy(cstr, str.size());
cstr[str.size()] = '\0';
return cstr;
}
// TODO (toole1) this is a total hack, should use execvp like exec() below
int8_t exec(int redirect_fd, const string & command, const vector<string> & args)
{
// For debugging:
#if 0
cerr << "exec(" << '\"' << command << '\"';
for (size_t i = 0; i < args.size(); i++)
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
cerr << ")" << endl;
#endif
// avoid self destruction errors from closing then trying to duplicate output
// you can't redirect to what's already there
if (redirect_fd == STDOUT_FILENO || redirect_fd == STDERR_FILENO)
redirect_fd = STDOUT_FILENO;
// Save timer values :)
// These are preserved across the parent, but not inherited by the child
// let's change that
struct itimerval remaining_real;
struct itimerval remaining_virtual;
struct itimerval remaining_prof;
bool supports_virtual = true;
bool supports_prof = true;
EXIT_IF_ERROR(getitimer(ITIMER_REAL, &remaining_real));
if (getitimer(ITIMER_VIRTUAL, &remaining_virtual) != 0)
{
if (errno == EINVAL)
{
supports_virtual = false;
errno = 0;
}
else
internal::exit_if_error_output(__FILE__, __LINE__, "getitimer(ITIMER_VIRTUAL) failed");
}
if (getitimer(ITIMER_PROF, &remaining_prof) != 0)
{
if (errno == EINVAL)
{
supports_prof = false;
errno = 0;
}
else
internal::exit_if_error_output(__FILE__, __LINE__, "getitimer(ITIMER_PROF) failed");
}
pid_t pid = fork();
if (pid == 0) /* child */
{
// Restore timers
EXIT_IF_ERROR(setitimer(ITIMER_REAL, &remaining_real, NULL));
if (supports_virtual) EXIT_IF_ERROR(setitimer(ITIMER_VIRTUAL, &remaining_virtual, NULL));
if (supports_prof) EXIT_IF_ERROR(setitimer(ITIMER_PROF, &remaining_prof, NULL));
if (redirect_fd == -1)
{
int devnull_fd = open("/dev/null", O_WRONLY | O_NONBLOCK);
close(STDOUT_FILENO);
close(STDERR_FILENO);
dup2(devnull_fd, STDOUT_FILENO);
dup2(devnull_fd, STDERR_FILENO);
close(devnull_fd);
}
else if (redirect_fd != STDOUT_FILENO)
{
close(STDOUT_FILENO);
close(STDERR_FILENO);
dup2(redirect_fd, STDOUT_FILENO);
dup2(redirect_fd, STDERR_FILENO);
}
// Sanitize the environment
#if 1 //!! hack!
char path[] = "PATH=/bin/:/usr/bin:/usr/local/bin";
// Turn off glibc errors default write-to-terminal behaviour, because
// it does not get caught by stderr. This instead results in an abort.
char redirect_glibc[] = "LIBC_FATAL_STDERR_=1";
char * newenv[] = { path, redirect_glibc, NULL };
//char * newenv[] = { path, NULL };
environ = newenv;
#endif
// TODO (toole1): check this doesn't cause a memleak
char ** args_cstr = new char*[args.size() + 2];
args_cstr[0] = allocateCstr(command);
for (size_t i = 0; i < args.size(); i++)
args_cstr[i + 1] = allocateCstr(args[i]);
args_cstr[args.size() + 1] = NULL;
// Swap out child process image with the command, searching
// in the specified path
execvp(command.c_str(), args_cstr);
// An error occured
cerr << "exec(" << '\"' << command << '\"';
for (size_t i = 0; i < args.size(); i++)
cerr << ", \"" << args[i] << "\"";
cerr << ") failed: " << strerror(errno) << endl;
exit(-1);
}
else if (pid < 0)
{
/* error - couldn't start process - you decide how to handle */
return -1;
}
else
{
int childExitStatus;
/* parent - wait for child - this has all error handling, you
* could just call wait() as long as you are only expecting to
* have one child process at a time.
*/
pid_t ws = waitpid( pid, &childExitStatus, 0);
if (ws == -1)
{ /* error - handle as you wish */
//cout << "exec error: " << __LINE__ << endl;
return -1;
}
if (WIFEXITED(childExitStatus)) /* exit code in childExitStatus */
{
int8_t status = WEXITSTATUS(childExitStatus); /* zero is normal exit */
/* handle non-zero as you wish */
return status;
}
else if (WIFSIGNALED(childExitStatus)) /* killed */
{
kill(getpid(), WTERMSIG(childExitStatus));
return -1;
}
else if (WIFSTOPPED(childExitStatus)) /* stopped */
{
//cout << "exec error: " << __LINE__ << endl;
return -1;
}
else
return -1;
}
}
// originally from stackoverflow.com user plinth
// http://stackoverflow.com/questions/2180079/how-can-i-copy-a-file-on-unix-using-c
// Modified by Jack Toole
int8_t exec(int redirect_fd, const char * command,
const char * arg1,
const char * arg2,
const char * arg3,
const char * arg4,
const char * arg5,
const char * arg6)
{
int childExitStatus;
pid_t pid;
const char * args[] = {arg1, arg2, arg3, arg4, arg5, arg6};
const size_t args_count = (sizeof args) / (sizeof args[0]);
// shift all nulls to end
size_t first_null = 0;
for (size_t i = 0; i < args_count; i++)
if (args[i] != NULL)
swap(args[i], args[first_null++]);
cerr << "exec(" << '\"' << command << '\"';
for (size_t i = 0; i < args_count; i++)
if (args[i] != NULL) cerr << ", \"" << args[i] << "\"";
cerr << ")" << endl;
#endif
// avoid self destruction errors from closing then trying to duplicate output
// you can't redirect to what's already there
if (redirect_fd == STDOUT_FILENO || redirect_fd == STDERR_FILENO)
redirect_fd = STDOUT_FILENO;
// Save timer values :)
// These are preserved across the parent, but not inherited by the child
// let's change that
struct itimerval remaining_real;
struct itimerval remaining_virtual;
struct itimerval remaining_prof;
EXIT_IF_ERROR(getitimer(ITIMER_REAL, &remaining_real));
if (getitimer(ITIMER_VIRTUAL, &remaining_virtual) != 0)
{
if (errno == EINVAL)
{
supports_virtual = false;
errno = 0;
}
else
internal::exit_if_error_output(__FILE__, __LINE__, "getitimer(ITIMER_VIRTUAL) failed");
}
if (getitimer(ITIMER_PROF, &remaining_prof) != 0)
{
if (errno == EINVAL)
{
supports_prof = false;
errno = 0;
}
else
internal::exit_if_error_output(__FILE__, __LINE__, "getitimer(ITIMER_PROF) failed");
}
pid = fork();
if (pid == 0) /* child */
{
// Restore timers
EXIT_IF_ERROR(setitimer(ITIMER_REAL, &remaining_real, NULL));
if (supports_virtual) EXIT_IF_ERROR(setitimer(ITIMER_VIRTUAL, &remaining_virtual, NULL));
if (supports_prof) EXIT_IF_ERROR(setitimer(ITIMER_PROF, &remaining_prof, NULL));
if (redirect_fd == -1)
{
int devnull_fd = open("/dev/null", O_WRONLY | O_NONBLOCK);
close(STDOUT_FILENO);
close(STDERR_FILENO);
dup2(devnull_fd, STDOUT_FILENO);
dup2(devnull_fd, STDERR_FILENO);
close(devnull_fd);
}
else if (redirect_fd != STDOUT_FILENO)
{
close(STDOUT_FILENO);
close(STDERR_FILENO);
dup2(redirect_fd, STDOUT_FILENO);
dup2(redirect_fd, STDERR_FILENO);
}
// Sanitize the environment
char path[] = "PATH=/bin/:/usr/bin:/usr/local/bin";
// Turn off glibc errors default write-to-terminal behaviour, because
// it does not get caught by stderr. This instead results in an abort.
char redirect_glibc[] = "LIBC_FATAL_STDERR_=1";
char * newenv[] = { path, redirect_glibc, NULL };
//char * newenv[] = { path, NULL };
// Swap out child process image with the command, searching
// in the specified path
execlp(command, command, args[0], args[1], args[2], args[3], args[4], args[5], NULL);
for (size_t i = 0; i < args_count; i++)
if (args[i] != NULL) cerr << ", \"" << args[i] << "\"";
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
cerr << ") failed: " << strerror(errno) << endl;
exit(-1);
}
else if (pid < 0)
{
/* error - couldn't start process - you decide how to handle */
return -1;
}
else
{
/* parent - wait for child - this has all error handling, you
* could just call wait() as long as you are only expecting to
* have one child process at a time.
*/
pid_t ws = waitpid( pid, &childExitStatus, 0);
if (ws == -1)
{ /* error - handle as you wish */
//cout << "exec error: " << __LINE__ << endl;
return -1;
}
if (WIFEXITED(childExitStatus)) /* exit code in childExitStatus */
{
int8_t status = WEXITSTATUS(childExitStatus); /* zero is normal exit */
/* handle non-zero as you wish */
return status;
}
else if (WIFSIGNALED(childExitStatus)) /* killed */
{
kill(getpid(), WTERMSIG(childExitStatus));
return -1;
}
else if (WIFSTOPPED(childExitStatus)) /* stopped */
{
//cout << "exec error: " << __LINE__ << endl;
return -1;
}
else
return -1;
}
}
const char * Signal::what() const
{
const char * desc = strsignal(signum);
return (desc == NULL) ? "Unknown Signal" : desc;
}
int chdir(const string & dir)
{
return ::chdir(dir.c_str());
}
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
472
473
474
475
476
477
478
479
480
481
482
483
484
void assertExists(const string & path, int exit_code /* = -1 */)
{
if (!exists(path))
{
cerr << "Error: " << path << " does not exist." << endl;
exit(exit_code);
}
}
bool exists(const string & path)
{
// Try stat-ing it
struct stat st;
if (stat(path.c_str(), &st) != 0) return false;
// Check for read permission
if ((st.st_mode & S_IRUSR) == 0) return false;
// Check for correct file/directory nature
if (path[path.length()-1] != '/') return S_ISREG(st.st_mode);
// Otherwise we want a directory
if ((st.st_mode & S_IXUSR) == 0) return false;
return S_ISDIR(st.st_mode);
}
mode_t permissions(const string & path)
{
// Try stat-ing it
struct stat st;
if (stat(path.c_str(), &st) != 0) return -1;
// Check for read permission
if ((st.st_mode & S_IRUSR) == 0) return -1;
return (st.st_mode & (S_IRWXU | S_IRWXG | S_IRWXO));
}
void forceRemoveDir(string dir)
{
size_t len = dir.length();
if (dir[len-1] == '/') dir[len-1] = '\0';
EXIT_IF_ERROR(exec("rm","-rf",dir.c_str()) != 0);
if (dir[len-1] == '\0') dir[len-1] = '/';
}
string getcwdstr()
{
int len = 256;
char * buffer = new char[len];
char * ret = getcwd(&buffer[0], len - 1);
while (ret == NULL && errno == ERANGE)
{
len *= 2;
delete buffer;
buffer = new char[len];
ret = getcwd(&buffer[0], len - 1);
}
EXIT_IF_ERROR(ret == NULL);
string cwdstr(buffer);
delete buffer;
return cwdstr;
}
void copyFile(const string & source, const string & dest)
{
assertExists(source);
vector<string> folders = tokenize(dest, '/');
string currdir = "";
for (size_t i = 0; i < folders.size() - 1; i++)
{
currdir += folders[i] + '/';
if (!exists(currdir))
exec("mkdir", currdir.c_str());
}
exec("cp", source.c_str(), dest.c_str());
}
void copyFiles(const string & sourceFolder, const string & destFolder, const vector<string> & files)
{
assertExists(destFolder);
for (size_t i = 0; i < files.size(); i++)
{
string sourceFile = sourceFolder + files[i];
assertExists(sourceFile);
copyFile(sourceFile, destFolder);
}
}
void protectFiles(const string & folder, const vector<string> & files)
{
#if 0 // (debug)
for (size_t i = 0; i < files.size(); i++)
{
string file = folder + files[i];
assertExists(file);
if (chmod(file.c_str(), S_IRUSR) != 0)
{
perror("chmod failed");
exit(-1);
}
}
#endif
}
void protectDir(const string & dir)
{
// (debug) EXIT_IF_ERROR(exec("/bin/chmod", "-R", "ugoa-w", dir.c_str()) != 0);
}
// Originally from Simon Biber
// http://bytes.com/topic/c/answers/545614-list-files-current-directory
vector<string> get_files_in_dir(const string & dir, bool concatdir /* = true */)
EXIT_IF_ERROR(dir == "" || dir[dir.length()-1] != '/', "Directory name must end in a '/'");
vector<string> files;
DIR * dirp = opendir(dir.c_str());
if (dirp == NULL) return files;
struct dirent * ent = readdir(dirp);
while (ent != NULL)
{
ent = readdir(dirp);
}
closedir(dirp);
return files;
}
bool is_symlink(const string & file)
{
// Try lstat-ing it
struct stat st;
if (lstat(file.c_str(), &st) != 0) return -1;
// Check for read permission
if ((st.st_mode & S_IRUSR) == 0) return false;
// & with symlink bit
return (S_ISLNK(st.st_mode)) != 0;
}
string get_symlink_target(const string & symlink)
{
const size_t buf_size = 4096;
char buf[buf_size+1]; // TODO (toole1): hack-y value
ssize_t len = readlink(symlink.c_str(), buf, buf_size);
EXIT_IF_ERROR(len < 0 || static_cast<size_t>(len) == buf_size, "Error getting target of symlink " + symlink);
buf[len] = '\0';
return string(buf);
}
528
529
530
531
532
533
534
535
536
537
538
539
540
541
542
543
544
545
546
547
548
549
550
551
552
553
554
555
556
557
558
559
560
561
562
563
564
565
566
567
568
569
570
571
572
573
574
575
576
577
578
579
580
581
582
583
584
585
586
587
588
589
590
591
592
593
594
595
596
597
598
599
600
601
602
603
604
605
606
607
608
609
610
611
612
613
614
615
616
617
618
619
620
621
622
623
624
625
626
627
628
629
630
631
632
633
634
635
636
637
638
639
640
641
642
643
644
645
646
647
648
649
650
651
652
653
654
655
656
657
658
659
660
661
662
663
664
665
666
667
668
669
670
671
672
673
674
675
676
677
678
679
680
681
682
683
684
685
686
687
688
689
690
691
692
693
694
695
696
697
698
699
700
701
702
703
704
705
706
707
708
709
710
711
712
713
714
715
716
717
718
719
720
721
722
723
724
725
726
727
728
729
730
731
732
733
734
735
736
737
738
739
740
741
742
743
744
745
746
747
748
749
750
751
752
753
754
void linkDirs(const string & sourceFolder, const string & destFolder, const vector<string> & dirs)
{
assertExists(destFolder);
for (size_t i = 0; i < dirs.size(); i++)
{
string source = sourceFolder + dirs[i];
string target = destFolder + dirs[i];
// Check for redundant monad/ directory
// This allows the monad/ dir to be safely renamed
if (replaceFirst(source, "/../monad/","/"))
replaceFirst(target, "/monad/","/");
assertExists(destFolder + source + '/');
if (symlink(source.c_str(), target.c_str()) != 0)
{
cerr << "symlink failed: " << target << ": ";
perror(NULL);
exit(-1);
}
}
}
bool replaceFirst(string & str, const string & toreplace, const string & with)
{
size_t i = str.find(toreplace);
if (i != string::npos)
{
str.replace(i,toreplace.length(),with);
return true;
}
return false;
}
size_t replaceAll(string & str, const string & toreplace, const string & with)
{
size_t i = str.find(toreplace);
size_t count = 0;
while (i != string::npos)
{
str.replace(i,toreplace.length(),with);
i = str.find(toreplace, i + with.length());
count++;
}
return count;
}
size_t replaceAllInternal(string & str, const string & toreplace, const string & with)
{
size_t i = str.find(toreplace);
size_t count = 0;
while ((i != string::npos) && (i != str.length() - toreplace.length()))
{
str.replace(i,toreplace.length(),with);
i = str.find(toreplace, i + with.length());
count++;
}
return count;
}
size_t findNthLast(const string & str, char c, size_t n)
{
if (str.length() == 0) return string::npos;
size_t i = str.length() - 1;
do
{
if (str[i] == c) n--;
if (n == 0) return i;
} while (i-- != 0);
return string::npos;
}
string read_string_from_FILE(FILE * file, size_t max_length /* = -1 */)
{
vector<char> v;
v.reserve(256);
while (true)
{
int nextchar = fgetc(file);
if (nextchar == '\0' || nextchar == EOF)
break;
if (v.size() < max_length)
v.push_back(nextchar);
}
if (v.size() == max_length)
{
v.push_back('.');
v.push_back('.');
v.push_back('.');
}
v.push_back('\0');
return string(&v[0]);
}
void write_string_to_FILE(FILE * file, const char * str)
{
fflush(file);
size_t i = 0;
do
{
// cout << (int)str[i] << ' ';
fputc(str[i], file);
// We use a do-while because we want the \0 to be written to the stream
// for sending multiple strings
} while (str[i++] != 0);
// cout << endl;
fflush(file);
}
/**
*
*
**/
string readFile(const string & filename)
{
ifstream file;
file.open(filename.c_str());
if (!file.good())
return "";
stringbuf linebuf;
file.get(linebuf, '\0');
linebuf.pubsync();
return linebuf.str();
}
void readConfig(const string & testsFolder, FileMap & map, const string & discriminator /* = "" */)
{
string file;
if (testsFolder == "" || testsFolder[testsFolder.length()-1] == '/')
file = testsFolder + "config.ini";
else
file = testsFolder;
readFileGeneric(file, &map, NULL, discriminator);
}
void readFile(const string & file, vector<string> & lines)
{
readFileGeneric(file, NULL, &lines);
}
void readFileGeneric(const string & filename, FileMap * map, vector<string> * lines, const string & discriminator /* = "" */)
{
ifstream infile;
istream * fileptr;
if (filename == "/dev/stdin")
fileptr = &cin;
else
{
fileptr = &infile;
infile.open(filename.c_str(), fstream::in);
}
istream & file = *fileptr;
vector<string> * section = NULL;
if (map != NULL) section = &(*map)[""];
else section = lines;
while ((file.good() && file.peek() == '\n') || file.peek() == '\r')
file.get(); // get '\n'
while (file.good())
{
// Read a line - A lot of code, I know, right?
stringbuf linebuf;
file.get(linebuf);
while ((file.good() && file.peek() == '\n') || file.peek() == '\r')
file.get(); // get '\n'
if (linebuf.in_avail() == 0) continue;
linebuf.pubsync();
string line = linebuf.str();
int len = line.length();
if (line[len-1] == '\r')
line.replace(--len,1,"");
if (len == 0 || line[0] == ';') continue; // skip comments
if (map != NULL)
{
// Update the section
if (line[0] == '[' && line[len-1] == ']')
{
section = &(*map)[line.substr(1, len - 2)];
continue;
}
else if (line[0] == '[' || line[len-1] == ']')
{
cout << "config.ini: Format error: " << line << endl;
exit(-1);
}
}
// Or add the line/file to the section
size_t delim_pos = line.find_first_of("?:");
if (delim_pos == string::npos || map == NULL)
section->push_back(line);
else if ((line[delim_pos] == ':' && (delim_pos == 0 || discriminator == "")) ||
line.compare(0, delim_pos, discriminator) == 0)
section->push_back(line.substr(delim_pos+1, line.size()-delim_pos-1));
}
if (filename != "/dev/stdin")
infile.close();
}
OptionsParser::OptionsParser()
{
valueMap[""] = true;
valueMap["yes"] = true;
valueMap["no"] = false;
valueMap["on"] = true;
valueMap["off"] = false;
valueMap["true"] = true;
valueMap["false"] = false;
valueMap["1"] = true;
valueMap["0"] = false;
}
vector<string> OptionsParser::parse(int argc, const char * const * argv)
{
vector<string> unprocessedArgs;
size_t out_arg_i = 0;
for (int arg_i = 1; arg_i < argc; arg_i++)
{
string originalCaseArg = argv[arg_i];
string currarg = toLower(originalCaseArg);
781
782
783
784
785
786
787
788
789
790
791
792
793
794
795
796
797
798
799
800
801
802
803
804
805
806
807
808
809
810
811
812
813
814
815
816
817
818
819
820
821
822
823
824
if (currarg.compare(0, 2, "--") == 0) //long option
{
bool invert = (currarg.compare(2, 2, "no") == 0);
size_t name_i = (invert ? 4 : 2);
size_t equalspos = currarg.find_first_of("=-", name_i);
string name = currarg.substr(name_i, equalspos - name_i);
string value = (equalspos >= currarg.length()) ? "" : currarg.substr(equalspos);
optsMap_t::iterator option = optsMap.find(name);
if (option == optsMap.end())
{
cerr << "Unknown option: " << currarg << endl;
exit(-1);
}
valueMap_t::iterator valueIt = valueMap.find(value);
if (valueIt == valueMap.end())
{
cerr << "Unknown value: " << currarg << endl;
exit(-1);
}
*option->second = valueIt->second ^ invert;
} // "--"
else if (currarg[0] == '-') //string of single char options
{
for (size_t c = 1; currarg[c] != '\0'; c++)
{
optsMap_t::iterator option = optsMap.find(string(1,currarg[c]));
if (option == optsMap.end())
{
cerr << "Unknown option: -" << currarg[c] << endl;
exit(-1);
}
*option->second = true;
}
}
else //positional argument
{
if (out_arg_i < args.size())
out_arg_i++;
}
}
return unprocessedArgs;
}
835
836
837
838
839
840
841
842
843
844
845
846
847
848
849
850
851
852
853
854
855
856
857
858
859
860
861
862
863
864
865
866
867
868
869
870
871
872
873
874
875
876
877
878
879
880
881
882
883
884
885
886
887
888
889
890
891
892
893
894
895
896
897
898
899
900
901
902
903
904
905
906
907
908
909
910
911
912
913
914
915
916
917
918
919
920
921
922
923
924
925
926
927
928
929
930
931
932
933
934
935
936
937
938
939
940
941
942
943
944
945
946
947
948
949
950
951
952
953
954
955
956
957
958
959
960
961
962
963
964
965
966
967
968
969
970
971
972
973
974
975
976
977
978
979
980
981
982
983
984
985
986
987
988
989
990
991
992
993
994
995
996
997
998
999
1000
char * processOptions(int argc, char ** argv, OptionsMap & opts, vector<string> & args)
{
for (int arg_i = 1; arg_i < argc; arg_i++)
{
char * currarg = argv[arg_i];
if (strncmp(currarg, "--", 2) == 0) //long option
{
bool value, invert;
size_t string_i;
if (strncasecmp(currarg+2, "no", 2) == 0)
{
invert = true;
string_i = 4;
}
else
{
invert = false;
string_i = 2;
}
size_t equals_i = string_i;
while (currarg[equals_i] != '\0' && currarg[equals_i] != '=')
equals_i++;
if (currarg[equals_i] == '=')
currarg[equals_i++] = '\0';
OptionsMap::iterator option = opts.find(currarg+string_i);
if (option == opts.end())
{
cerr << "Unknown option: " << currarg << endl;
return currarg;
}
char valuechar = tolower(currarg[equals_i]);
if (valuechar == 'o') valuechar = tolower(currarg[equals_i+1]) + 1;
switch (valuechar)
{
case '\0' : value = true; break;
case 'f'+1 : value = false; break; //off: see 'o' above
case 'n' : value = false; break;
case 'n'+1 : value = true; break; //on: contrast 'n': see 'o' above
case 't' : value = true; break;
case 'y' : value = true; break;
default:
cerr << "Unknown option value: " << currarg << endl;
return currarg;
}
(*option).second = value ^ invert;
} // "--"
else if (currarg[0] == '-') //string of single char options
{
for (size_t c = 1; currarg[c] != '\0'; c++)
{
OptionsMap::iterator option = opts.find(string(1,currarg[c]));
if (option == opts.end())
{
cerr << "Unknown option: -" << currarg[c] << endl;
currarg[1] = currarg[c];
currarg[2] = '\0';
return currarg;
}
(*option).second = true;
}
}
else //positional argument
args.push_back(currarg);
}
return NULL;
}
void makeLower(string & str)
{
for (size_t i = 0; i < str.length(); i++)
{
str[i] = tolower(str[i]);
}
}
string toLower(const string & str)
{
string s(str);
makeLower(s);
return s;
}
/**
* A wrapper function which writes a buffer to a file.
**/
ssize_t writeBytesToFile(signed int fileDescriptor, const char * buffer, unsigned int bufferLength) {
return writen(fileDescriptor, buffer, bufferLength);
}
// From Steven's Unix Net Programming
// http://www.kohala.com/start/
/* Write "n" bytes to a descriptor. */
ssize_t writen(int fd, const void *vptr, size_t n)
{
size_t nleft;
ssize_t nwritten;
const int8_t * ptr;
ptr = static_cast<const int8_t*>(vptr);
nleft = n;
while (nleft > 0) {
if ( (nwritten = ::write(fd, ptr, nleft)) <= 0) {
if (errno == EINTR)
nwritten = 0; /* and call write() again */
else
return -1; /* error */
}
nleft -= nwritten;
ptr += nwritten;
}
return n;
}
// From Steven's Unix Net Programming
// http://www.kohala.com/start/
/* Read "n" bytes from a descriptor. */
ssize_t readn(int fd, void *vptr, size_t n)
{
size_t nleft;
ssize_t nread;
int8_t * ptr;
ptr = static_cast<int8_t*>(vptr);
nleft = n;
while (nleft > 0) {
if ( (nread = ::read(fd, ptr, nleft)) < 0) {
if (errno == EINTR)
nread = 0; /* and call read() again */
else
return -1;
}
else if (nread == 0)
break; /* EOF */
nleft -= nread;
ptr += nread;
}
return n - nleft; /* return >= 0 */
}
void rename_main(const string & file, const string & newname)
{
if (newname[0] != '_')
{
cerr << "INTERNAL ERROR: " __FILE__ << ":" << __LINE__
<< "newname argument to rename_main must begin with an underscore to ensure replacement safety" << endl;