version 1.3.2.8, 2011/09/06 23:58:48
|
version 1.3.2.9, 2011/09/07 00:30:04
|
Line 229 rpcBLOBServerVars(rpc_func_t *call, int ic, array_t *i
|
Line 229 rpcBLOBServerVars(rpc_func_t *call, int ic, array_t *i
|
else |
else |
srv = call->func_parent; |
srv = call->func_parent; |
|
|
|
rpc_srv_getVars(call, &vals); |
|
|
|
if (srv->srv_blob.state == kill) { |
|
AIT_SET_STR(io_array(vals, 0, ait_val_t*), "BLOB Server is killed"); |
|
return 1; |
|
} |
|
if (srv->srv_blob.state == disable) { |
|
AIT_SET_STR(io_array(vals, 0, ait_val_t*), "BLOB Server is disabled"); |
|
return 1; |
|
} |
|
|
pthread_mutex_lock(&srv->srv_blob.mtx); |
pthread_mutex_lock(&srv->srv_blob.mtx); |
for (i = 0, b = srv->srv_blob.blobs; b; i++, b = b->blob_next); |
for (i = 0, b = srv->srv_blob.blobs; b; i++, b = b->blob_next); |
len = i * sizeof str; |
len = i * sizeof str; |
|
|
rpc_srv_getVars(call, &vals); |
|
|
|
if (!(val = malloc(len))) { |
if (!(val = malloc(len))) { |
LOGERR; |
LOGERR; |
pthread_mutex_unlock(&srv->srv_blob.mtx); |
pthread_mutex_unlock(&srv->srv_blob.mtx); |
Line 295 rpcBLOBServerClients(rpc_func_t *call, int ic, array_t
|
Line 304 rpcBLOBServerClients(rpc_func_t *call, int ic, array_t
|
srv = call->func_parent; |
srv = call->func_parent; |
|
|
rpc_srv_getVars(call, &vals); |
rpc_srv_getVars(call, &vals); |
|
|
|
if (srv->srv_blob.state == kill) { |
|
AIT_SET_STR(io_array(vals, 0, ait_val_t*), "BLOB Server is killed"); |
|
return 1; |
|
} |
|
if (srv->srv_blob.state == disable) { |
|
AIT_SET_STR(io_array(vals, 0, ait_val_t*), "BLOB Server is disabled"); |
|
return 1; |
|
} |
|
|
len = srv->srv_numcli * STRSIZ; |
len = srv->srv_numcli * STRSIZ; |
if (!(val = malloc(len))) { |
if (!(val = malloc(len))) { |