Lines Matching refs:dict_proxy

114     DICT_PROXY *dict_proxy = (DICT_PROXY *) dict;  in dict_proxy_sequence()  local
127 VSTRING_RESET(dict_proxy->reskey); in dict_proxy_sequence()
128 VSTRING_TERMINATE(dict_proxy->reskey); in dict_proxy_sequence()
129 VSTRING_RESET(dict_proxy->result); in dict_proxy_sequence()
130 VSTRING_TERMINATE(dict_proxy->result); in dict_proxy_sequence()
131 request_flags = dict_proxy->inst_flags in dict_proxy_sequence()
134 stream = clnt_stream_access(dict_proxy->clnt); in dict_proxy_sequence()
147 RECV_ATTR_STR(MAIL_ATTR_KEY, dict_proxy->reskey), in dict_proxy_sequence()
148 RECV_ATTR_STR(MAIL_ATTR_VALUE, dict_proxy->result), in dict_proxy_sequence()
151 msg_warn("%s: service %s: %m", myname, dict_proxy->service); in dict_proxy_sequence()
156 function, status, STR(dict_proxy->reskey), in dict_proxy_sequence()
157 STR(dict_proxy->result)); in dict_proxy_sequence()
162 dict_proxy->service, dict->name, function); in dict_proxy_sequence()
165 dict_proxy->service, dict->name); in dict_proxy_sequence()
167 *key = STR(dict_proxy->reskey); in dict_proxy_sequence()
168 *value = STR(dict_proxy->result); in dict_proxy_sequence()
182 dict_proxy->service, dict->name, function, status); in dict_proxy_sequence()
185 clnt_stream_recover(dict_proxy->clnt); in dict_proxy_sequence()
195 DICT_PROXY *dict_proxy = (DICT_PROXY *) dict; in dict_proxy_lookup() local
208 VSTRING_RESET(dict_proxy->result); in dict_proxy_lookup()
209 VSTRING_TERMINATE(dict_proxy->result); in dict_proxy_lookup()
210 request_flags = dict_proxy->inst_flags in dict_proxy_lookup()
213 stream = clnt_stream_access(dict_proxy->clnt); in dict_proxy_lookup()
226 RECV_ATTR_STR(MAIL_ATTR_VALUE, dict_proxy->result), in dict_proxy_lookup()
229 msg_warn("%s: service %s: %m", myname, dict_proxy->service); in dict_proxy_lookup()
235 status, STR(dict_proxy->result)); in dict_proxy_lookup()
240 dict_proxy->service, dict->name, key); in dict_proxy_lookup()
243 dict_proxy->service, dict->name); in dict_proxy_lookup()
245 DICT_ERR_VAL_RETURN(dict, DICT_ERR_NONE, STR(dict_proxy->result)); in dict_proxy_lookup()
255 dict_proxy->service, dict->name, key, status); in dict_proxy_lookup()
258 clnt_stream_recover(dict_proxy->clnt); in dict_proxy_lookup()
268 DICT_PROXY *dict_proxy = (DICT_PROXY *) dict; in dict_proxy_update() local
281 request_flags = dict_proxy->inst_flags in dict_proxy_update()
284 stream = clnt_stream_access(dict_proxy->clnt); in dict_proxy_update()
300 msg_warn("%s: service %s: %m", myname, dict_proxy->service); in dict_proxy_update()
310 dict_proxy->service, dict->name, key); in dict_proxy_update()
313 dict_proxy->service, dict->name); in dict_proxy_update()
325 dict_proxy->service, dict->name, key, status); in dict_proxy_update()
328 clnt_stream_recover(dict_proxy->clnt); in dict_proxy_update()
338 DICT_PROXY *dict_proxy = (DICT_PROXY *) dict; in dict_proxy_delete() local
351 request_flags = dict_proxy->inst_flags in dict_proxy_delete()
354 stream = clnt_stream_access(dict_proxy->clnt); in dict_proxy_delete()
370 msg_warn("%s: service %s: %m", myname, dict_proxy->service); in dict_proxy_delete()
380 dict_proxy->service, dict->name, key); in dict_proxy_delete()
383 dict_proxy->service, dict->name); in dict_proxy_delete()
395 dict_proxy->service, dict->name, key, status); in dict_proxy_delete()
398 clnt_stream_recover(dict_proxy->clnt); in dict_proxy_delete()
407 DICT_PROXY *dict_proxy = (DICT_PROXY *) dict; in dict_proxy_close() local
409 vstring_free(dict_proxy->reskey); in dict_proxy_close()
410 vstring_free(dict_proxy->result); in dict_proxy_close()
419 DICT_PROXY *dict_proxy; in dict_proxy_open() local
476 dict_proxy = (DICT_PROXY *) in dict_proxy_open()
477 dict_alloc(DICT_TYPE_PROXY, map, sizeof(*dict_proxy)); in dict_proxy_open()
478 dict_proxy->dict.lookup = dict_proxy_lookup; in dict_proxy_open()
479 dict_proxy->dict.update = dict_proxy_update; in dict_proxy_open()
480 dict_proxy->dict.delete = dict_proxy_delete; in dict_proxy_open()
481 dict_proxy->dict.sequence = dict_proxy_sequence; in dict_proxy_open()
482 dict_proxy->dict.close = dict_proxy_close; in dict_proxy_open()
483 dict_proxy->inst_flags = (dict_flags & DICT_FLAG_INST_MASK); in dict_proxy_open()
484 dict_proxy->reskey = vstring_alloc(10); in dict_proxy_open()
485 dict_proxy->result = vstring_alloc(10); in dict_proxy_open()
486 dict_proxy->clnt = *pstream; in dict_proxy_open()
487 dict_proxy->service = service; in dict_proxy_open()
495 stream = clnt_stream_access(dict_proxy->clnt); in dict_proxy_open()
500 SEND_ATTR_STR(MAIL_ATTR_TABLE, dict_proxy->dict.name), in dict_proxy_open()
501 SEND_ATTR_INT(MAIL_ATTR_FLAGS, dict_proxy->inst_flags), in dict_proxy_open()
509 msg_warn("%s: service %s: %m", myname, dict_proxy->service); in dict_proxy_open()
513 myname, dict_proxy->dict.name, status, in dict_proxy_open()
518 dict_proxy->service, dict_proxy->dict.name); in dict_proxy_open()
521 dict_proxy->service, dict_proxy->dict.name); in dict_proxy_open()
523 dict_proxy->dict.flags = (dict_flags & ~DICT_FLAG_IMPL_MASK) in dict_proxy_open()
525 return (DICT_DEBUG (&dict_proxy->dict)); in dict_proxy_open()
528 dict_proxy->service, dict_proxy->dict.name, status); in dict_proxy_open()
531 clnt_stream_recover(dict_proxy->clnt); in dict_proxy_open()