version 1.8.2.9, 2012/05/16 08:10:39
|
version 1.8.2.10, 2012/05/16 09:02:47
|
Line 213 typedef struct {
|
Line 213 typedef struct {
|
TAILQ_HEAD(, tagRPCFunc) srv_funcs; /* RPC functions list */ |
TAILQ_HEAD(, tagRPCFunc) srv_funcs; /* RPC functions list */ |
|
|
struct { |
struct { |
cmd_type_t state; /* BLOB server state: ==0 disable | !=0 enable */ | sched_root_task_t *root; /* BLOB server scheduler */ |
| intptr_t kill; /* BLOB server state: ==0 disable | !=0 enable */ |
| |
ait_val_t dir; /* BLOB states directory */ |
ait_val_t dir; /* BLOB states directory */ |
|
|
rpc_cli_t server; /* BLOB server socket */ |
rpc_cli_t server; /* BLOB server socket */ |
Line 308 void rpc_srv_endServer(rpc_srv_t ** __restrict psrv);
|
Line 310 void rpc_srv_endServer(rpc_srv_t ** __restrict psrv);
|
*/ |
*/ |
int rpc_srv_loopServer(rpc_srv_t * __restrict srv); |
int rpc_srv_loopServer(rpc_srv_t * __restrict srv); |
#define rpc_srv_execServer(_srv, _sync) do { assert((_srv)); pthread_t __tid; \ |
#define rpc_srv_execServer(_srv, _sync) do { assert((_srv)); pthread_t __tid; \ |
pthread_create(&__tid, NULL, (void*(*)(void*)) \ | if (!(_srv)->srv_kill) { \ |
rpc_srv_loopServer, (_srv)); \ | pthread_create(&__tid, NULL, (void*(*)(void*)) \ |
if ((_sync)) \ | rpc_srv_loopServer, (_srv)); \ |
pthread_join(__tid, (void**) (_sync)); \ | if ((_sync)) \ |
else \ | pthread_join(__tid, (void**) (_sync)); \ |
pthread_detach(__tid); \ | else \ |
} while (0) | pthread_detach(__tid); \ |
| } } while (0) |
|
|
/* |
/* |
* rpc_srv_initBLOBServer() - Init & create BLOB Server |
* rpc_srv_initBLOBServer() - Init & create BLOB Server |
Line 338 void rpc_srv_endBLOBServer(rpc_srv_t * __restrict srv)
|
Line 341 void rpc_srv_endBLOBServer(rpc_srv_t * __restrict srv)
|
* @srv = RPC Server instance |
* @srv = RPC Server instance |
* return: -1 error or 0 ok, infinite loop ... |
* return: -1 error or 0 ok, infinite loop ... |
*/ |
*/ |
int rpc_srv_loopBLOB(rpc_srv_t * __restrict srv); | int rpc_srv_loopBLOBServer(rpc_srv_t * __restrict srv); |
#define rpc_srv_execBLOBServer(_srv) do { assert((_srv)); pthread_t __tid; \ |
#define rpc_srv_execBLOBServer(_srv) do { assert((_srv)); pthread_t __tid; \ |
if ((_srv)->srv_blob.state == enable) { \ | if (!(_srv)->srv_kill && !(_srv)->srv_blob.kill) { \ |
pthread_create(&__tid, NULL, (void*(*)(void*)) \ |
pthread_create(&__tid, NULL, (void*(*)(void*)) \ |
rpc_srv_loopBLOB, (_srv)); \ | rpc_srv_loopBLOBServer, (_srv)); \ |
pthread_detach(__tid); \ |
pthread_detach(__tid); \ |
(_srv)->srv_blob.state = running; \ |
|
} \ |
} \ |
} while (0) |
} while (0) |
|
|