|
|
|
#include "Iguana/Framework/interface/IgNet.h"#include "Iguana/Framework/interface/IgNetError.h"#include "classlib/sysapi/InetSocket.h"#include "classlib/iobase/Filename.h"#include "classlib/utils/TimeInfo.h"#include "classlib/utils/StringList.h"#include "classlib/utils/StringFormat.h"#include "classlib/utils/StringOps.h"#include "classlib/utils/SystemError.h"#include "classlib/utils/Regexp.h"#include <unistd.h>#include <fcntl.h>#include <sys/wait.h>#include <stdio.h>#include <stdint.h>#include <iostream>#include <cassert>Go to the source code of this file.
Defines | |
| #define | MESSAGE_SIZE_LIMIT (2*1024*1024) |
| #define | SOCKET_BUF_SIZE (8*1024*1024) |
| #define | SOCKET_READ_GROWTH (SOCKET_BUF_SIZE) |
| #define | SOCKET_READ_SIZE (SOCKET_BUF_SIZE/8) |
Functions | |
| static void * | communicate (void *obj) |
| A thread to communicate with the distributed memory cache peers. | |
A thread to communicate with the distributed memory cache peers.
All this does is run the loop to respond to new connections. Much of the actual work is done when a new connection is received, and in pumping data around in response to actual requests.
Definition at line 920 of file IgNet.cc.
References sigfillset.
00921 { 00922 sigset_t sigs; 00923 sigfillset(&sigs); 00924 pthread_sigmask(SIG_BLOCK, &sigs, 0); 00925 ((IgNet *)obj)->run(); 00926 return 0; 00927 }
1.5.4