UNIX: разработка сетевых приложений
UNIX: разработка сетевых приложений читать книгу онлайн
Новое издание книги, посвященной созданию веб-серверов, клиент-серверных приложений или любого другого сетевого программного обеспечения в операционной системе UNIX, — классическое руководство по сетевым программным интерфейсам, в частности сокетам. Оно основано на трудах Уильяма Стивенса и полностью переработано и обновлено двумя ведущими экспертами по сетевому программированию. В книгу включено описание ключевых современных стандартов, реализаций и методов, она содержит большое количество иллюстрирующих примеров и может использоваться как учебник по программированию в сетях, так и в качестве справочника для опытных программистов.
Внимание! Книга может содержать контент только для совершеннолетних. Для несовершеннолетних чтение данного контента СТРОГО ЗАПРЕЩЕНО! Если в книге присутствует наличие пропаганды ЛГБТ и другого, запрещенного контента - просьба написать на почту [email protected] для удаления материала
Листинг 26.5. Первая часть функции readline, безопасной в многопоточной среде
//threads/readline.c 1 #include "unpthread.h" 2 static pthread_key_t rl_key; 3 static pthread_once_t rl_once = PTHREAD_ONCE_INIT; 4 static void 5 readline_destructor(void *ptr) 6 { 7 free(ptr); 8 }9 static void10 readline_once(void)11 {12 Pthread_key_create(&rl_key, readline_destructor);13 }14 typedef struct {15 int rl_cnt; /* инициализируется нулем */16 char *rl_bufptr; /* инициализируется значением rl_buf */17 char rl_buf[MAXLINE];18 } Rline;4-89-13pthread_oncereadline14-18RlinestaticВ листинге 26.6 показана сама функция
readlinemy_readЛистинг 26.6. Вторая часть функции readline, безопасной в многопоточной среде
//threads/readline.c19 static ssize_t20 my_read(Rline *tsd, int fd, char *ptr)21 {22 if (tsd->rl_cnt <= 0) {23 again:24 if ((tsd->rl_cnt = read(fd, tsd->rl_buf, MAXLINE)) < 0) {25 if (errno == EINTR)26 goto again;27 return (-1);28 } else if (tsd->rl_cnt == 0)29 return (0);30 tsd->rl_bufptr = tsd->rl_buf;31 }32 tsd->rl_cnt--;33 *ptr = *tsd->rl_bufptr++;34 return (1);35 }36 ssize_t37 readline(int fd, void *vptr, size_t maxlen)38 {39 int n, rc;40 char c, *ptr;41 Rline *tsd;42 Pthread_once(&rl_once, readline_once);43 if ((tsd = pthread_getspecific(rl_key)) == NULL) {44 tsd = Calloc(1, sizeof(Rline)); /* инициализируется нулем */45 Pthread_setspecifiс(rl_key, tsd);46 }47 ptr = vptr;48 for (n = 1; n < maxlen; n++) {49 if ((rc = my_read(tsd, fd, &c)) == 1) {50 *ptr++ = c;51 if (c == 'n')52 break;53 } else if (rc == 0) {54 *ptr = 0;55 return (n-1); /* EOF, данные не были считаны */56 } else57 return (-1); /* ошибка, errno устанавливается функцией read() */58 }59 *ptr = 0;60 return (n);61 }19-35Rline42pthread_oncereadlinereadline_once43-46pthread_getspecificRlinereadlineRlinerl_cntcallocpthread_setspecificreadlinepthread_getspecific
