컴공 일기278
게시글 주소: https://orbi.kr/00073281944
가산점을 주는 네트워크 과제입니다.
4장 이내 11pt 설계보고서, 소스코드 원본을 제출해야 하며
연구실에서 1:1 인터뷰를 통해 데모 실행 및 설명을 해야 합니다.
TCP/IP 통신기반의 공유 문서 작성 및 읽기 프로그램입니다.
소켓 프로그래밍과 시스템 프로그래밍에서 자주 사용되는 기법을 적절히 조화시켜야 하는데 가장 핵심적인 기능 중 하나는, write 명령이 클라이언트로부터 왔을 때, 서버는 한줄씩 데이터를 받아들이는 겁니다. 이걸 구현하는 것이 이 과제의 핵심 중 하나가 아닌가 생각하네요.
소켓의 본질을 알고 있어야, 이 기능을 구현할 수 있거든요.
소켓의 본질은 파일입니다. 파일은 데이터 단위가 Stream인데,
이 스트림은 시작은 확실히 정해져 있지만, 끝이 어딘지 확실하지 않다는 특징을 갖고 있습니다. 그렇기 때문에 ‘줄 입력‘이 여기서 종료되었다는 판단을 아무런 정보가 없다면 서버는 할 수 없죠.
따라서 적절한 시그널을 주고받는 프로토콜 절차가 있어야 합니다.
인터뷰에서 시그널을 주고받음으로써 줄의 끝이 어디까지인지 서버가 알도록 한다는 말씀을 드렸을 때, 인터뷰 평가 사항에 무엇인가를 막 적고 계시더라구요. 그때 조금 확실히 알게된 것 같습니다.
과제의 의도가 결국 ‘소켓’이 무엇인지 정확히 알고 있느냐라는 걸요.. 사실 이 얘기는 네트워크 이론과 운영체제론을 알고 있어야 이해할 수 있을 겁니다. 조금 더 다듬어서 비동기 입출력까지 지원하는 서버를 한번 만들어 보려구요. 설계 구조를 완전히 바꿔야 겠지만, 오랜만에 아주 재미있는 프로젝트를 하게 되어서 이 내용물은 깃허브에 올려 볼 것 같습니다.
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <pthread.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#define MAX_DOCS 100
#define MAX_SECTIONS 10
#define MAX_TITLE 64
#define MAX_LINE 256
#define MAX_LINES 10
#define BUF_SIZE 1024
typedef struct {
char title[MAX_TITLE];
char section_titles[MAX_SECTIONS][MAX_TITLE];
char section_contents[MAX_SECTIONS][MAX_LINES][MAX_LINE];
int section_line_count[MAX_SECTIONS];
int section_count;
} Document;
typedef struct WriteRequest {
int client_sock;
int estimated_lines;
struct WriteRequest *next;
} WriteRequest;
Document docs[MAX_DOCS];
int doc_count = 0;
pthread_mutex_t docs_mutex = PTHREAD_MUTEX_INITIALIZER;
pthread_mutex_t section_mutex[MAX_DOCS][MAX_SECTIONS];
pthread_cond_t section_cond[MAX_DOCS][MAX_SECTIONS];
int section_writing[MAX_DOCS][MAX_SECTIONS] = {{0}};
WriteRequest *section_queue[MAX_DOCS][MAX_SECTIONS] = {{{0}}};
pthread_mutex_t section_queue_mutex[MAX_DOCS][MAX_SECTIONS];
pthread_cond_t section_queue_cond[MAX_DOCS][MAX_SECTIONS];
void send_all(int sock, const char *msg) {
send(sock, msg, strlen(msg), 0);
}
Document* find_doc(const char* title) {
for (int i = 0; i < doc_count; ++i) {
if (strcmp(docs[i].title, title) == 0)
return &docs[i];
}
return NULL;
}
ssize_t read_line(int sock, char *buf, size_t max_len) {
size_t i = 0;
char ch;
while (i < max_len - 1) {
ssize_t n = recv(sock, &ch, 1, 0);
if (n <= 0) break;
if (ch == '\n') break;
buf[i++] = ch;
}
buf[i] = '\0';
return i;
}
void parse_command(const char* input, char* args[], int* argc) {
*argc = 0;
const char* p = input;
while (*p) {
while (*p == ' ' || *p == '\t') p++;
if (*p == '"') {
p++;
const char* start = p;
while (*p && *p != '"') p++;
int len = p - start;
args[*argc] = malloc(len + 1);
strncpy(args[*argc], start, len);
args[*argc][len] = '\0';
(*argc)++;
if (*p == '"') p++;
} else {
const char* start = p;
while (*p && *p != ' ' && *p != '\t' && *p != '\n') p++;
int len = p - start;
args[*argc] = malloc(len + 1);
strncpy(args[*argc], start, len);
args[*argc][len] = '\0';
(*argc)++;
}
}
}
void* client_handler(void* arg);
int main(int argc, char* argv[]) {
if (argc != 3) {
fprintf(stderr, "Usage: %s <IP> <Port>\n", argv[0]);
exit(1);
}
for (int i = 0; i < MAX_DOCS; ++i)
for (int j = 0; j < MAX_SECTIONS; ++j) {
pthread_mutex_init(§ion_mutex[i][j], NULL);
pthread_cond_init(§ion_cond[i][j], NULL);
pthread_mutex_init(§ion_queue_mutex[i][j], NULL);
pthread_cond_init(§ion_queue_cond[i][j], NULL);
}
int server_sock = socket(AF_INET, SOCK_STREAM, 0);
struct sockaddr_in server_addr, client_addr;
socklen_t addrlen = sizeof(client_addr);
server_addr.sin_family = AF_INET;
server_addr.sin_port = htons(atoi(argv[2]));
inet_pton(AF_INET, argv[1], &server_addr.sin_addr);
bind(server_sock, (struct sockaddr*)&server_addr, sizeof(server_addr));
listen(server_sock, 10);
printf("[Server] Listening on %s:%s\n", argv[1], argv[2]);
while (1) {
int *client_sock = malloc(sizeof(int));
*client_sock = accept(server_sock, (struct sockaddr*)&client_addr, &addrlen);
pthread_t tid;
pthread_create(&tid, NULL, client_handler, client_sock);
pthread_detach(tid);
}
close(server_sock);
return 0;
}
void* client_handler(void* arg) {
int client_sock = *(int*)arg;
free(arg);
char buf[BUF_SIZE];
char* args[64];
int argc;
while (1) {
memset(buf, 0, sizeof(buf));
if (read_line(client_sock, buf, sizeof(buf)) <= 0) break;
parse_command(buf, args, &argc);
if (argc == 0) continue;
if (strcmp(args[0], "create") == 0) {
pthread_mutex_lock(&docs_mutex);
if (argc < 3 || doc_count >= MAX_DOCS) {
pthread_mutex_unlock(&docs_mutex);
send_all(client_sock, "[Error] Invalid create command.\n");
continue;
}
if (find_doc(args[1])) {
pthread_mutex_unlock(&docs_mutex);
send_all(client_sock, "[Error] Document already exists.\n");
continue;
}
int section_count = atoi(args[2]);
if (section_count <= 0 || section_count > MAX_SECTIONS || argc != 3 + section_count) {
pthread_mutex_unlock(&docs_mutex);
send_all(client_sock, "[Error] Invalid section count or titles.\n");
continue;
}
strcpy(docs[doc_count].title, args[1]);
docs[doc_count].section_count = section_count;
for (int i = 0; i < section_count; ++i) {
strcpy(docs[doc_count].section_titles[i], args[3 + i]);
docs[doc_count].section_line_count[i] = 0;
}
++doc_count;
pthread_mutex_unlock(&docs_mutex);
send_all(client_sock, "[OK] Document created.\n");
}
else if (strcmp(args[0], "write") == 0) {
if (argc < 3) {
send_all(client_sock, "[Error] Invalid write command.\n");
continue;
}
pthread_mutex_lock(&docs_mutex);
Document* doc = find_doc(args[1]);
if (!doc) {
pthread_mutex_unlock(&docs_mutex);
send_all(client_sock, "[Error] Document not found.\n");
continue;
}
int section_idx = -1;
for (int i = 0; i < doc->section_count; ++i)
if (strcmp(doc->section_titles[i], args[2]) == 0) {
section_idx = i;
break;
}
if (section_idx == -1) {
pthread_mutex_unlock(&docs_mutex);
send_all(client_sock, "[Error] Section not found.\n");
continue;
}
int doc_idx = doc - docs;
pthread_mutex_unlock(&docs_mutex);
send_all(client_sock, "[OK] You can start writing. Send <END> to finish.\n>> ");
int line_count = 0;
char line[MAX_LINE];
char temp_lines[MAX_LINES][MAX_LINE];
while (1) {
if (read_line(client_sock, line, sizeof(line)) <= 0) break;
if (strcmp(line, "<END>") == 0) break;
if (line_count < MAX_LINES)
strncpy(temp_lines[line_count++], line, MAX_LINE - 1);
send_all(client_sock, ">> ");
}
WriteRequest *req = malloc(sizeof(WriteRequest));
req->client_sock = client_sock;
req->estimated_lines = line_count;
req->next = NULL;
pthread_mutex_lock(§ion_queue_mutex[doc_idx][section_idx]);
if (!section_queue[doc_idx][section_idx] || line_count < section_queue[doc_idx][section_idx]->estimated_lines) {
req->next = section_queue[doc_idx][section_idx];
section_queue[doc_idx][section_idx] = req;
} else {
WriteRequest *cur = section_queue[doc_idx][section_idx];
while (cur->next && cur->next->estimated_lines <= line_count)
cur = cur->next;
req->next = cur->next;
cur->next = req;
}
pthread_cond_signal(§ion_queue_cond[doc_idx][section_idx]);
pthread_mutex_unlock(§ion_queue_mutex[doc_idx][section_idx]);
pthread_mutex_lock(§ion_mutex[doc_idx][section_idx]);
while (section_queue[doc_idx][section_idx]->client_sock != client_sock)
pthread_cond_wait(§ion_queue_cond[doc_idx][section_idx], §ion_mutex[doc_idx][section_idx]);
pthread_mutex_lock(&docs_mutex);
doc->section_line_count[section_idx] = 0;
for (int i = 0; i < line_count && i < MAX_LINES; ++i)
strncpy(doc->section_contents[section_idx][i], temp_lines[i], MAX_LINE - 1);
doc->section_line_count[section_idx] = line_count;
pthread_mutex_unlock(&docs_mutex);
section_queue[doc_idx][section_idx] = section_queue[doc_idx][section_idx]->next;
pthread_cond_broadcast(§ion_queue_cond[doc_idx][section_idx]);
pthread_mutex_unlock(§ion_mutex[doc_idx][section_idx]);
send_all(client_sock, "[Write_Completed]\n");
}
else if (strcmp(args[0], "read") == 0) {
pthread_mutex_lock(&docs_mutex);
if (argc == 1) {
for (int i = 0; i < doc_count; ++i) {
char line[BUF_SIZE];
snprintf(line, sizeof(line), "%s\n", docs[i].title);
send_all(client_sock, line);
for (int j = 0; j < docs[i].section_count; ++j) {
snprintf(line, sizeof(line), " %d. %s\n", j + 1, docs[i].section_titles[j]);
send_all(client_sock, line);
}
}
} else if (argc >= 3) {
Document* doc = find_doc(args[1]);
if (!doc) {
pthread_mutex_unlock(&docs_mutex);
send_all(client_sock, "[Error] Document not found.\n");
continue;
}
int found = 0;
for (int i = 0; i < doc->section_count; ++i)
if (strcmp(doc->section_titles[i], args[2]) == 0) {
found = 1;
char header[BUF_SIZE];
snprintf(header, sizeof(header), "%s\n %d. %s\n", doc->title, i + 1, doc->section_titles[i]);
send_all(client_sock, header);
for (int j = 0; j < doc->section_line_count[i]; ++j) {
char line[BUF_SIZE];
snprintf(line, sizeof(line), " %s\n", doc->section_contents[i][j]);
send_all(client_sock, line);
}
break;
}
if (!found)
send_all(client_sock, "[Error] Section not found.\n");
}
send_all(client_sock, "__END__\n");
pthread_mutex_unlock(&docs_mutex);
}
else if (strcmp(args[0], "bye") == 0) {
send_all(client_sock, "[Disconnected]\n");
break;
} else {
send_all(client_sock, "[Error] Unknown command.\n");
}
for (int i = 0; i < argc; ++i) free(args[i]);
}
close(client_sock);
return NULL;
}
0 XDK (+0)
유익한 글을 읽었다면 작성자에게 XDK를 선물하세요.
-
#07년생#08년생#독학생 오르비의 주인이 될 기회 37 39
-
지스퍼거뭐냐 ㅅㅂ 3 0
벽느껴짐 올해 지리비슷한거 한다는데 본인 수도 대한민국 서울 일본 도쿄 중국 베이징...
-
적어보세요
-
성심당오르비꺼라 1 0
넵
-
결국 훼스탈 하나 먹음.. 2 0
후..
-
설캠이랑 더 가까워서 무조건 설캠인줄알텐데 개쪽팔리네; 학교에 있다가 약속잡혀서 바로 가는중임
-
ㅋㅋㅋㅋ 얜 절대 안 나오겠네
-
삼수기준 3 0
5합+5는 할만한데 각각 1개씩 올리는건 너무 어려운듯 그냥 하지마라는건가 싶기도 하고
-
깨달았다 1 0
나는 설통계에 가야겠음 통계학을 공부해 로또당첨확률이 가장 높은 번호를 알아내겠다
-
자꾸 부모님하고 내가 싸우게 되는데 3모 수학은 미적분에서 전범위가 안 나오고...
-
운전병을 지원해서 가려고 하고 있고 학점은행제를 수료해야 할 일이 있어서요. 뭐...
-
대학방학은 꽤나 길구나 3 1
거의 2달 반이네
-
무슨학과가지 9 1
고민된당..
-
확통런 했는데 조언좀 주세용 0 0
공통은 21틀이라 대학다니면서 확통 공부 할것 같은데 김기현 아이디어+기출은 지금...
-
08 유망주 누구있음 23 1
-
Team 05 살아있나요? 4 0
-
내가 보는 웹툰 11 3
이거 있는거만 봄 이 표시 있는게 좋더라구요
-
살빼느라 0 0
매일 운동하는데 생각보다 즐겁다 근력운동이 유산소보다 재밌는듯
-
코인 줍줍 1 0
-
문과 정시 카드 질문 4 0
언매 확통 사문 생윤으로 시험 봤을 때 이번년도 계약학과 지원할때 제한 없었나요?...
-
전쟁이 일어나버렸네 1 0
헐랭
-
발상노트 이렇게 쓰는 거 맞나요? (고수님들 헬프) 3 0
검은 색으로 조건이나 상황 쓰고, 빨간색으로 사고과정이나 이유 또는 근거 쓰고,...
-
머리뒤쪽이아프다 4 0
한달된생각이다
-
오느레저녁 11 0
-
문학을 수능장에서 다 맞을걸 상정하고 공부하는건 오만이라고 생각해요 10 0
수능날 문학이 평가원 모고처럼 부드럽게 읽힐 것 같아요? 저는 그래서 전략적으로...
-
입시로 인한 우울감은 0 0
입시가 끝나고 시간 지나면 자연스럽게 사라진다는 걸 이미 알면서도 또다시 입시를...
-
문학 고트 누군가여 1 0
국어 만년 4등급인데 누구 들을가여
-
내신때 암기 이렇게 할걸 0 1
공부할때 전체적인 구조도를 그리고 오늘 공주한거를 거기에 덧붙인다는 생각으로...
-
연대 비교내신 몇수부터임? 1 0
5?
-
레전드음알못이네 ㅉㅉ 그런 너에게 디스코뮤성인을 들려주겠다
-
초등학교 6년내내 친구가 얘밖에 없으면 됨
-
군면제인데 16 0
진지하게 사수 어떻게 생각하시나요??현역 때 32122였고 시립대나 건동홍 목표로...
-
나만큼 글 빨리지우는사람 못봄 8 0
사실 다른사람이 글쓰는거 본적없는데 내가 더 빠를거임
-
확통사탐 언매화작 7 0
삼반수 예정인데 확통사탐 조합으로 한약수 가기 유리하거나 갈 수 있는 곳 있나요?!...
-
한 무당의 양심고백 2 0
한 명이 아니라 양이 좀 많으니까 양무당인가? ㅋㅋ
-
서울대 목표면 3 0
원원/원투/투투 +저 서울대 수교과까지도 생각하고 있는데 이거 자전으로 갈 수 있나요?
-
시간이 참 안가네요 1 1
전역만 하면 행복할텐데 12월 31일이 올런지..
-
나도 그 쪽으로 나름 자부심 갖고 살았는데 좃고수들은 다르드라
-
오르비 처음 써보는 사람들 주목 11 5
여기에 개별 과목 풀이에 관한 질문을 할 생각이었다면 뒤로가기를 누르시고 다른 곳을...
-
ㅅㅂ 이거하세요!! 저기요!! 이쪽으로 와서 하는거에요!! 이런생각하면 안되지만...
-
이건진짜 볼때마다 웃기네 ㅋㅋ 3 0
-
두각 잘 아는사람 0 0
현강 2주만 더듣고 안듣고 싶은데 이번에 한달 결재 해야 하는데 2주 듣고...
-
와 금요일에 주식 다팔았는데ㅋㅋ 11 0
와
-
다음 나라의 공통점은? 1 0
일본 우주베키스탄 러시아 힌트1 수능끝나고 여행가고 싶음
-
재종 윈터 끝나니까 2 0
좋을줄 알았는데 기분이 너무 우울함.... 열심히 한다고 했는데 별차이 없는느낌임
-
오후 공부 완 2 0
.
-
삼성전자 현직 질문받아봐용 29 2
진로 취업 회사생활 학교생활 연애 결혼 등 다 괜찮습니당
-
이제 뉴런 시작하는데 3 0
이해원n제 4규 드릴 다있음 ㅋㅋ
-
딴건 모르겠는데 0 1
서울에 외국인 되게 많네 나도 나름 외국인 많은 도시에서 9년을 살았는데 ㅋㅋ...
-
똥이하얀색임 2 0
평가원 고정1이상인 분들 문제풀때 법칙들 공유해주삼 나는 크게 써야할 능력을...
-
고닉들도 공부 잘하긴 하는데 5 2
저렙노프사들 중에 은둔 개고수들이 많구나
반가워요