apps/irc/ircreader.cpp

   1 /*
   2 ** Copyright 2002, Travis Geiselbrecht. All rights reserved.
   3 ** Distributed under the terms of the NewOS License.
   4 */
   5 #include <sys/syscalls.h>
   6 #include <stdio.h>
   7 #include <unistd.h>
   8 #include <socket/socket.h>
   9
  10 #include "ircreader.h"
  11 #include "ircengine.h"
  12
  13 IRCReader::IRCReader(int socket, IRCEngine *engine)
  14         :       mSocket(socket),
  15                 mEngine(engine),
  16                 mReaderThread(-1),
  17                 mBufPos(0)
  18 {
  19 }
  20
  21 IRCReader::~IRCReader()
  22 {
  23         // forgive me father...
  24         if(mReaderThread >= 0)
  25                 _kern_thread_kill_thread(mReaderThread);
  26 }
  27
  28 int IRCReader::Start()
  29 {
  30         mReaderThread = _kern_thread_create_thread("irc reader", &ThreadEntry, (void *)this);
  31         if(mReaderThread < 0)
  32                 return mReaderThread;
  33
  34         _kern_thread_resume_thread(mReaderThread);
  35
  36         return 0;
  37 }
  38
  39 int IRCReader::Run()
  40 {
  41         for(;;) {
  42                 char buf[1024];
  43                 ssize_t bytes_received;
  44
  45                 bytes_received = read(mSocket, buf, sizeof(buf));
  46                 if(bytes_received < 0) {
  47                         mEngine->SocketError(bytes_received);
  48                         break;
  49                 }
  50
  51                 // add this data to the end of the line buffer we have
  52                 for(int i = 0; i < bytes_received; i++) {
  53                         mBuf[mBufPos++] = buf[i];
  54                         if(mBufPos == sizeof(mBuf) - 1 || buf[i] == '\n') {
  55                                 mBuf[mBufPos] = 0;
  56                                 mEngine->ReceivedSocketData(mBuf, mBufPos);
  57                                 mBufPos = 0;
  58                         }
  59                 }
  60         }
  61         return 0;
  62 }
  63
  64 int IRCReader::ThreadEntry(void *args)
  65 {
  66         IRCReader *reader = (IRCReader *)args;
  67
  68         return reader->Run();
  69 }
  70
  71