We will be using crypt_r()
(a reentrant/thread safe version) of the crypt()
function, as our hashing function. crypt_r()
takes three arguments: the string to hash, a salt string, a struct crypt_data
. Make sure to set the initialized
member of your struct crypt_data
before using it for the first time. For example:
This code outputs the following:
The struct crypt_data
is necessary for crypt_r()
. This is because crypt()
needs to store information between invocations, so calling crypt()
on multiple threads will cause this information to be inaccurate. crypt_r()
gets around this by storing information in a struct crypt_data
instead. You should check the man page for crypt_r,
do you need to free the string it returns?
Why is there salt in my hash?
The salt argument flavors the string so that when you hash the same password with different salts, youll get different results. For example, we can use part of a users username to salt their password before hashing. This way, two users with the same password will not have the same hash stored in the database.
For this assignment, always use "xx"
for the salt argument.
Problem Statement
You will be given a list of password hashes which you must recover. Each password is a password partial, meaning that we have these two pieces of information:
- The first few letters in their password
- The total length of the password
All the passwords only contain lowercase letters!
For example, we may say that a password begins with "hello"
and has a total of 8 letters. We know the hashed value associated with this password is "xxsczBXm6z4zA"
, so we simply have to try hashing each possible password (staring with the prefix provided) until we find one that hashes to the desired value.
Input
Your input will be a file with one line for each password to recover. Each line will contain:
- Username (1-8 characters)
- Password hash (13 characters)
- Known part of password (plus periods representing unknown characters) (1-8 characters, contains 0-8 lowercase letters followed by 0-8 periods)
- A period in the password represents an unknown letter.
These three fields are separated by a single space. Dont worry about duplicate usernames, duplicate password hashes, or duplicate prefixes. Each line is an independent task.
All input we provide is guaranteed to be in this format.
Example input:
Version 1: Thread Pool
We will not grade any output which is not the result of a call to a function in format.h
It is always a good idea to write a single threaded version of your code before trying to parallelize!
Use multiple threads to speed up the password processing. The main thread will start up a pool of worker threads, then read lines of input from standard input. Each line will be converted to a task which is added to a task queue. The task queue is provided in libprovided.a
and queue.h.
This is the same thread-safe queue that youve implemented in lab! The worker threads will pull one task from the task queue, then process the task. When a worker thread starts processing a task, it will print the username of the task (use format.h
).
When a worker thread finishes a task, it will print the cracked password (use format.h
), along with the index of the thread (starting with index 1) and the amount of CPU time spent working on the password (use getThreadCPUTime()
).
When the main thread finishes reading in lines from the input, it cant shut down immediately, since worker threads may still cracking some passwords. You need to decide how to cleanly shut all the threads down when there are no more passwords to crack. Every thread must join with the main thread!
After all the worker threads have exited, the main thread will print (this is provided):
- Number of successful and unsuccessful password cracks
- Wall clock time since the program was started (via
getTime()
inutils.h
) - CPU time used (a sum of the CPU time used in all threads).
- Proportion of CPU time to wall clock time.
By default, the provided code creates 4 worker threads. If a command line argument is supplied to the program, it will use that as the number of worker threads rather than the default.
Example:
Example output:
The times and order may vary slightly.
Remember to use appropriate synchronization, and make sure to use crypt_r
. If you create a new thread for each task (instead of keeping the threads in the thread pool running), you will loose points! (and your implementation will be very slow)
Version 2: Parallelize each task
We will not grade any output which is not the result of a call to a function in format.h
Version 1 works great when there is a long list of passwords that need cracking in parallel, but its no faster than a single threaded version when theres one really hard password that needs cracking. For version 2, youll still have a pool of threads, but rather than assigning one thread to each password task, all the threads will work in parallel on each password task.
Example input:
Example output:
Distribute the work by splitting the search space into equal-sized chunks, one for each worker thread. For example, if there are 3 unknown characters, then there are 26^3 = 17576 possible passwords that need to be tested. With 4 worker threads, you would split the work up like this:
- Thread 1: 0..4393 (aaa..gmz)
- Thread 2: 4394..8787 (gna..mzz)
- Thread 3: 8788..13181 (naa..tmz)
- Thread 4: 13182..17575 (tna..zzz)
When the number of threads doesnt divide the search space evenly, its easy to get off-by-one errors due to integer rounding. Weve provided functions getSubrange()
and setStringPosition()
to help you with this.
With all the threads working on the same task, you may want to restructure your thread synchronization a little. Rather than a queue, you may wish to use a barrier.
Like with version 1, you may not create new threads for each task. The threads you create at the beginning of the program must be the same threads that compute the last task.
When the main thread reads a task, it should print "Start <username>"
. When a thread starts processing a task, it should print its index and starting position. As usual, make sure to use format.h
. For example:
When a worker thread finds the correct password, it should tell all the other threads to stop working on the task. You can implement this with a simple flag variable that each thread checks on each iteration. Since all the threads are reading this variable and any thread may write to it, youll need to properly synchronize access to it.
When the worker threads finish a task, each thread will print the number of passwords it tried and a word describing how its run finished:
- (found) this thread found the password
- (cancelled) stopped early because another thread found the password
- (end) finished with no password found. Note: this can happen if the password was found, but this thread finished its chunk before another thread found the password.
After all worker threads finish each task, the main thread will print the password (if found), the total number of hashes, the wall clock and CPU time spent on that task, and the ratio of CPU time to wall clock time. Note that we have not provided any of the timing print statements in cracker2
.
Submission instructions
As usual, we will use subversion for your submission of this MP. Please modify only the following files: cracker1.c
cracker2.c
Concept
Latency & Throughput
By definition, latency is the delay from input into a system to desired outcome or the execution time of a single task. Throughput is the maximum rate at which something can be processed or the amount of task that could be completed in a period of time.
Lets take pizza delivery for an example, Do you want your pizza hot? Low latency = pizza arrives quicker! Or do you want your pizza to be inexpensive? High throughput = lots of pizzas per hour
For the Version 1: Thread Pool solution, because the amount of time needed for every task is different, the tasks that need less time wont be blocked by the tasks that needed longer time. On the other hand, the execution time for each task is longer than having all the thread working on the single task.
Consider the following tasks (in order), where a thread can run 100 iterations per second:
- task 1: 100 iterations
- task 2: 10000 iterations
- task 3: 100 iterations
- task 4: 100 iterations
- task 5: 100 iterations
Throughput
Suppose there are 4 threads available and the program runs for 1 seconds.
For version 1: The throughput is 2 since tasks 1, 3, and 4 will have completed, while 2 is still being worked on (and 5 is just being started).
For version 2: The throughput is 1 since only the first task will have completed and all of the threads are busy working on task 2.
Latency
The latency is determined by how quickly each password can be cracked.
Task1 | Task2 | Task3 | Task4 | Task5 | |
---|---|---|---|---|---|
Latency (version 1) | 1 | 100 | 1 | 1 | 1 |
Latency (version 2) | 0.2 | 20 | 0.2 | 0.2 | 0.2 |
Version 2 has much lower latency since each password is cracked faster by multiple threads working on the same task.
Building and Running
As usual, we have provided a Makefile which can build a release
and a debug
version of your code. Running make
will compile cracker1
and cracker2
in release mode, as well as a tool called create_examples
(more on this in the next section). Running make debug
will compile cracker1
and cracker2
in debug mode, and will also compile create_examples.
ThreadSanitizer
We have also included the target make tsan
, which compiles your code with Thread Sanitizer (run cracker1-tsan
and cracker2-tsan
)
ThreadSantizer is a race condition detection tool. See this page for more information.
We will be using ThreadSanitizer to grade your code! If the autograder detects a data race, you wont automatically get 0 points, but a few points will be deducted.
Helpful Extras
Thread status hook
Weve provided a simple tool to help you when debugging your program. See thread_status.h
and thread_status.c
. Weve install threadStatusPrint()
as a handler for SIGINT
. It will print a brief summary of what each thread is currently doing any time you hit ctrl-c. For example:
To use it:
#include "thread_status.h"
- Call threadStatusSet() to describe what the thread is currently doing. The argument to
threadStatusSet()
should be a string constant. For example:
When threadStatusPrint()
is called, it doesnt print the exact line number that each thread is at. It just prints the line number of the most recent call to threadStatusSet()
. So, for more precise reporting, add more calls to threadStatusSet()
to your code.
thread_status.h
contains macros that will redefine calls to common thread synchronization functions so that when a thread is blocking on one of them, its status will represent that (like the semaphore wait on line 219 in the example above).
Note: Since Thread Status is hooked to Ctrl-C, you might need to use Ctrl-D (EOF) or Ctrl- (SIGQUIT) to shutdown a running password cracker
Youre not required to use the thread status tool as part of the assignment, we just thought it might make your debugging easier.
create_examples
Weve also provided a small program to create example input files, to help you with your testing. To build the create_examples
program, run make create_examples
. To use the program, write its output to a file, then use the file as input to a cracker program. For example:
To see what the cracked passwords should be, use the -soln
flag when running create_examples
(see the usage documentation given when running the program with no arguments).
timing example
CPU time and so called wall clock time are not always the same thing. CPU time is defined as the amount of time your program spends running on a CPU, and wall clock time is quite literally, the amount of time that would pass on a wall clock (the kind of clock on a wall) between the time a program starts and a program finishes running. These numbers are often not the same!
If your program makes a large number of blocking system calls, it may take 10 seconds to run, but only actually consume 5 seconds of CPU time. In this case, the kernel spent time reading from a file, or writing packets to the network, while your program sat idle.
CPU time can also be much larger than wall clock time. If a program runs in multiple threads, it may use 40 seconds of CPU time, but only take 10 seconds of wall clock time (4 threads, each ran for 10 seconds).
To demonstrate these differences, weve provided a program in tools/timing.c
which shows an example of both kinds cases.
To compile this program, run make timing
, then run ./timing.
You should see output like this:
Reviews
There are no reviews yet.