1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
|
/* ISC license. */
#include <sys/uio.h>
#include <stdint.h>
#include <errno.h>
#include <time.h>
#include <limits.h>
#include <pthread.h>
#include <skalibs/uint32.h>
#include <skalibs/tai.h>
#include <skalibs/siovec.h>
#include <skalibs/pthread.h>
#include <skalibs/gensetdyn.h>
#include <skalibs/textclient.h>
#include <skalibs/sassclient.h>
#include "sassclient-internal.h"
int sassclient_sendv (sassclient *a, uint32_t *cid, uint32_t flags, uint32_t timeout, uint32_t opcode, struct iovec const *vv, unsigned int n, sassclient_cb_func_ref cb, void *data, tain const *deadline, tain *stamp)
{
size_t len = siovec_len(vv, n) ;
uint32_t id, ans ;
int e ;
struct iovec answer ;
sassclient_data *p ;
char pack[21] = "+" ;
struct iovec v[1 + n] ;
if (len + 17 > UINT32_MAX) return (errno = ENAMETOOLONG, 0) ;
e = pthread_mutex_tailock(&a->connection_mutex, deadline, stamp) ;
if (e) return (errno = e, 0) ;
if (!gensetdyn_new(&a->store, &id)) goto err ;
v[0].iov_base = pack ;
v[0].iov_len = 21 ;
for (unsigned int i = 0 ; i < n ; i++) v[i+1] = vv[i] ;
uint32_pack_big(pack + 1, id) ;
uint32_pack_big(pack + 5, flags) ;
uint32_pack_big(pack + 9, timeout) ;
uint32_pack_big(pack + 13, opcode) ;
uint32_pack_big(pack + 17, len) ;
if (!textclient_exchangev(&a->connection, v, 1 + n, &answer, deadline, stamp)) { e = errno ; goto err0 ; }
if (answer.iov_len != 4) { e = EPROTO ; goto err0 ; }
uint32_unpack_big((char *)answer.iov_base, &ans) ;
if (ans) { e = ans ; goto err0 ; }
p = GENSETDYN_P(sassclient_data, &a->store, id) ;
p->cb = cb ;
p->data = data ;
pthread_mutex_unlock(&a->connection_mutex) ;
*cid = id ;
return 1 ;
err0:
gensetdyn_delete(&a->store, id) ;
errno = e ;
err:
pthread_mutex_unlock(&a->connection_mutex) ;
return 0 ;
}
|
