aboutsummaryrefslogtreecommitdiffstats
path: root/P3
diff options
context:
space:
mode:
Diffstat (limited to '')
-rw-r--r--P3/server.c29
1 files changed, 18 insertions, 11 deletions
diff --git a/P3/server.c b/P3/server.c
index cc8be2c..90fed7a 100644
--- a/P3/server.c
+++ b/P3/server.c
@@ -22,7 +22,7 @@
int port, workers, dispatchers, dynFlag, qLen, cSiz = 0;
char* path;
-pthread_mutex_t Qlock;
+pthread_mutex_t Qlock, logLock;
/*
THE CODE STRUCTURE GIVEN BELOW IS JUST A SUGGESTION. FEEL FREE TO MODIFY AS NEEDED
@@ -108,7 +108,7 @@ char* Type(char * mybuf) {
// Function to open and read the file from the disk into the memory
// Add necessary arguments as needed
-int readFromDisk(/*necessary arguments*/) {
+int readFromDisk() {
// Open and read the contents of file given the request
}
@@ -128,19 +128,17 @@ void * dispatch(void *arg) {
// Add the request into the queue
for(int i = 0; i < qLen; i++) {
if (traverse == NULL) {
- //Add things to queue. Lock & unlock to prevent a race condition
+ //Add things to queue. Lock & unlock to prevent a deadlock
pthread_mutex_lock(&Qlock);
request_t * tempNode = (request_t*) calloc(1, sizeof(request_t *)); // Yes, he spelled it like that on purpose
- char* tempBuf = malloc(BUFF_SIZE); // Buffer to store the requested filename
+ char* tempBuf = (char *) malloc(BUFF_SIZE); // Buffer to store the requested filename
pthread_mutex_unlock(&Qlock);
- if (get_request(newReq, tempBuf) != 0) {
+ if (get_request(newReq, tempBuf) != 0)
continue; // If get_request fails, try again
- }
- //Hopefully this works. Please work
+ //Hopefully this works. Please work. Please.
tempNode->fd = newReq;
- tempNode->request= tempBuf;
- free(tempBuf);
+ tempNode->request = tempBuf;
break;
} else {
traverse = traverse -> next;
@@ -155,20 +153,26 @@ void * dispatch(void *arg) {
// Function to retrieve the request from the queue, process it and then return a result to the client
void * worker(void *arg) {
-
+ long numbytes;
+ unsigned long long numReqs = 0;
while (1) {
request_t *head = Q;
if (head == NULL)
continue;
// Get the request from the queue
pthread_mutex_lock(&Qlock);
- return_result(head->fd, getContentType(head->request), );
+ char *tempBuf = (char *) calloc(BUFF_SIZE, sizeof(char));
pthread_mutex_unlock(&Qlock);
// Get the data from the disk or the cache (extra credit B)
// Log the request into the file and terminal
+ pthread_mutex_lock(&logLock);
+ FILE* log = fopen("../webserver_log", "a");
+ fprintf(log, "[%d][%lld][%d][%s][%s][%s]", +numReqs, pthread_self());
+ numb
// return the result
+ return_result(head->fd, getContentType(head->request), tempBuf, );
}
return NULL;
}
@@ -243,6 +247,7 @@ int main(int argc, char **argv) {
}
// Open log file
FILE* logfile = fopen("webserver_log", "a");
+ fclose("webserver_log");
// Change the current working directory to server root directory
if (chdir(path) == -1) {
@@ -271,7 +276,9 @@ int main(int argc, char **argv) {
}
//Create workers (make detachable?????)
pthread_t wThreads[workers];
+ int* Wargs = malloc(sizeof(int)*workers);
for (int i = 0; i < workers; i++) {
+ Wargs[i]=i;
pthread_create(&wThreads[i], &attr, worker, NULL); //TODO: Worker arguments
}
// Create dynamic pool manager thread (extra credit A)