~ubuntu-branches/ubuntu/vivid/postfix/vivid-proposed

« back to all changes in this revision

Viewing changes to src/global/dict_proxy.c

Committer: Package Import Robot
Author(s): LaMont Jones
Date: 2012-03-20 13:47:16 UTC
mfrom: (1.1.33)
mto: This revision was merged to the branch mainline in revision 44.
Revision ID: package-import@ubuntu.com-20120320134716-v7ab94fmor2z9pvp

Tags: upstream-2.9.1

Import upstream version 2.9.1

files added:
README_FILES/MEMCACHE_README

RELEASE_NOTES-2.8

html/MEMCACHE_README.html

html/memcache_table.5.html

man/man5/memcache_table.5

pflogsumm_quickfix.txt

proto/MEMCACHE_README.html

proto/memcache_table

src/global/dict_memcache.c

src/global/dict_memcache.h

src/global/mail_version.in

src/global/mail_version.ref

src/global/maps.in

src/global/maps.ref

src/global/memcache_proto.c

src/global/memcache_proto.h

src/global/mkmap_fail.c

src/global/resolve_local.in

src/global/resolve_local.ref

src/global/safe_ultostr.c

src/global/safe_ultostr.h

src/global/server_acl.c

src/global/server_acl.h

src/global/server_acl.in

src/global/server_acl.ref

src/global/surrogate.ref

src/global/verify_sender_addr.c

src/global/verify_sender_addr.h

src/global/verify_sender_addr.ref

src/postalias/aliases

src/postalias/fail_test.in

src/postalias/fail_test.ref

src/postconf/postconf.h

src/postconf/postconf_builtin.c

src/postconf/postconf_dbms.c

src/postconf/postconf_edit.c

src/postconf/postconf_main.c

src/postconf/postconf_master.c

src/postconf/postconf_misc.c

src/postconf/postconf_node.c

src/postconf/postconf_other.c

src/postconf/postconf_service.c

src/postconf/postconf_unused.c

src/postconf/postconf_user.c

src/postconf/test1.ref

src/postconf/test10.ref

src/postconf/test11.ref

src/postconf/test12.ref

src/postconf/test13.ref

src/postconf/test14.ref

src/postconf/test15.ref

src/postconf/test16.ref

src/postconf/test17.ref

src/postconf/test18.ref

src/postconf/test19.ref

src/postconf/test2.ref

src/postconf/test20.ref

src/postconf/test21.ref

src/postconf/test22.ref

src/postconf/test23.ref

src/postconf/test24.ref

src/postconf/test25.ref

src/postconf/test26.ref

src/postconf/test27.ref

src/postconf/test28.ref

src/postconf/test29.ref

src/postconf/test3.ref

src/postconf/test30.ref

src/postconf/test4.ref

src/postconf/test5.ref

src/postconf/test6.ref

src/postconf/test7.ref

src/postconf/test8.ref

src/postconf/test9.ref

src/postmap/aliases

src/postmap/fail_test.in

src/postmap/fail_test.ref

src/smtpd/smtpd_error.in

src/smtpd/smtpd_error.ref

src/util/base32_code.c

src/util/base32_code.h

src/util/dict_fail.c

src/util/dict_fail.h

src/util/dict_surrogate.c

src/util/dict_test.c

src/util/dict_thash.map

src/util/msg_rate_delay.c

src/util/surrogate.ref

src/util/warn_stat.c

src/util/warn_stat.h

files removed:
pflogsumm-conn-delays-dsn-patch

src/postconf/auto.awk

src/postscreen/postscreen_access.c

src/util/match_ops.h

files modified:
.indent.pro

AAAREADME

HISTORY

Makefile.in

README_FILES/AAAREADME

README_FILES/ADDRESS_VERIFICATION_README

README_FILES/BACKSCATTER_README

README_FILES/BASIC_CONFIGURATION_README

README_FILES/DATABASE_README

README_FILES/DB_README

README_FILES/INSTALL

README_FILES/MILTER_README

README_FILES/MULTI_INSTANCE_README

README_FILES/OVERVIEW

README_FILES/PACKAGE_README

README_FILES/POSTSCREEN_README

README_FILES/SASL_README

README_FILES/SCHEDULER_README

README_FILES/SMTPD_POLICY_README

README_FILES/TLS_README

README_FILES/TUNING_README

README_FILES/VERP_README

README_FILES/XCLIENT_README

RELEASE_NOTES

auxiliary/qshape/qshape.pl

conf/main.cf

conf/master.cf

conf/post-install

conf/postfix-files

html/ADDRESS_VERIFICATION_README.html

html/BACKSCATTER_README.html

html/BASIC_CONFIGURATION_README.html

html/DATABASE_README.html

html/DB_README.html

html/DEBUG_README.html

html/INSTALL.html

html/MILTER_README.html

html/MULTI_INSTANCE_README.html

html/Makefile.in

html/OVERVIEW.html

html/PACKAGE_README.html

html/POSTSCREEN_README.html

html/SASL_README.html

html/SCHEDULER_README.html

html/SMTPD_POLICY_README.html

html/TLS_README.html

html/TUNING_README.html

html/VERP_README.html

html/XCLIENT_README.html

html/cleanup.8.html

html/index.html

html/lmtp.8.html

html/mailq.1.html

html/master.5.html

html/master.8.html

html/mysql_table.5.html

html/newaliases.1.html

html/pgsql_table.5.html

html/postalias.1.html

html/postconf.1.html

html/postconf.5.html

html/postdrop.1.html

html/postfix-manuals.html

html/postfix.1.html

html/postkick.1.html

html/postmap.1.html

html/postqueue.1.html

html/postscreen.8.html

html/postsuper.1.html

html/proxymap.8.html

html/qmqpd.8.html

html/sendmail.1.html

html/showq.8.html

html/smtp.8.html

html/smtpd.8.html

html/tlsproxy.8.html

html/verify.8.html

makedefs

man/Makefile.in

man/man1/postalias.1

man/man1/postconf.1

man/man1/postfix.1

man/man1/postkick.1

man/man1/postmap.1

man/man1/postsuper.1

man/man1/sendmail.1

man/man5/master.5

man/man5/mysql_table.5

man/man5/pgsql_table.5

man/man5/postconf.5

man/man8/cleanup.8

man/man8/master.8

man/man8/postscreen.8

man/man8/proxymap.8

man/man8/qmqpd.8

man/man8/showq.8

man/man8/smtp.8

man/man8/smtpd.8

man/man8/tlsproxy.8

man/man8/verify.8

mantools/double

mantools/postlink

postfix-install

proto/ADDRESS_VERIFICATION_README.html

proto/BACKSCATTER_README.html

proto/BASIC_CONFIGURATION_README.html

proto/DATABASE_README.html

proto/DB_README.html

proto/DEBUG_README.html

proto/INSTALL.html

proto/MILTER_README.html

proto/MULTI_INSTANCE_README.html

proto/Makefile.in

proto/OVERVIEW.html

proto/PACKAGE_README.html

proto/POSTSCREEN_README.html

proto/SASL_README.html

proto/SCHEDULER_README.html

proto/SMTPD_POLICY_README.html

proto/TLS_README.html

proto/TUNING_README.html

proto/VERP_README.html

proto/XCLIENT_README.html

proto/master

proto/mysql_table

proto/pgsql_table

proto/postconf.proto

src/bounce/bounce_trace_service.c

src/cleanup/Makefile.in

src/cleanup/cleanup.c

src/cleanup/cleanup.h

src/cleanup/cleanup_addr.c

src/cleanup/cleanup_init.c

src/cleanup/cleanup_map11.c

src/cleanup/cleanup_map1n.c

src/cleanup/cleanup_masq.ref

src/cleanup/cleanup_masquerade.c

src/cleanup/cleanup_message.c

src/cleanup/cleanup_milter.c

src/cleanup/cleanup_milter.ref1

src/cleanup/cleanup_milter.ref12

src/cleanup/cleanup_milter.ref13a

src/cleanup/cleanup_milter.ref3

src/cleanup/cleanup_milter.ref4

src/cleanup/cleanup_region.c

src/dns/dns_rr_eq_sa.ref

src/dns/dns_rr_to_pa.ref

src/dns/dns_rr_to_sa.ref

src/dns/dns_sa_to_rr.ref

src/flush/Makefile.in

src/flush/flush.c

src/global/Makefile.in

src/global/abounce.c

src/global/addr_match_list.c

src/global/addr_match_list.h

src/global/cfg_parser.c

src/global/cfg_parser.h

src/global/data_redirect.c

src/global/db_common.c

src/global/db_common.h

src/global/debug_peer.c

src/global/dict_ldap.c

src/global/dict_mysql.c

src/global/dict_pgsql.c

src/global/dict_proxy.c

src/global/dict_proxy.h

src/global/dict_sqlite.c

src/global/domain_list.c

src/global/domain_list.h

src/global/dot_lockfile.c

src/global/file_id.c

src/global/file_id.h

src/global/flush_clnt.c

src/global/header_body_checks.c

src/global/header_body_checks.h

src/global/mail_addr_find.c

src/global/mail_addr_map.c

src/global/mail_conf.c

src/global/mail_copy.c

src/global/mail_dict.c

src/global/mail_error.c

src/global/mail_error.h

src/global/mail_open_ok.c

src/global/mail_params.c

src/global/mail_params.h

src/global/mail_proto.h

src/global/mail_queue.c

src/global/mail_queue.h

src/global/mail_stream.c

src/global/mail_trigger.c

src/global/mail_version.c

src/global/mail_version.h

src/global/maps.c

src/global/maps.h

src/global/match_parent_style.h

src/global/match_service.c

src/global/match_service.h

src/global/mbox_open.c

src/global/mkmap.h

src/global/mkmap_db.c

src/global/mkmap_open.c

src/global/mynetworks.c

src/global/mypwd.c

src/global/mypwd.h

src/global/namadr_list.c

src/global/namadr_list.h

src/global/namadr_list.in

src/global/namadr_list.ref

src/global/own_inet_addr.c

src/global/remove.c

src/global/resolve_local.c

src/global/resolve_local.h

src/global/smtp_reply_footer.c

src/global/smtp_stream.c

src/global/smtp_stream.h

src/global/string_list.c

src/global/string_list.h

src/global/user_acl.c

src/local/Makefile.in

src/local/alias.c

src/local/bounce_workaround.c

src/local/dotforward.c

src/local/include.c

src/local/local.c

src/local/mailbox.c

src/local/maildir.c

src/local/recipient.c

src/local/unknown.c

src/master/Makefile.in

src/master/event_server.c

src/master/mail_flow.c

src/master/mail_server.h

src/master/master.c

src/master/master.h

src/master/master_avail.c

src/master/master_conf.c

src/master/master_ent.c

src/master/master_service.c

src/master/master_spawn.c

src/master/master_vars.c

src/master/multi_server.c

src/master/single_server.c

src/master/trigger_server.c

src/milter/milter.c

src/oqmgr/Makefile.in

src/oqmgr/qmgr_active.c

src/postalias/Makefile.in

src/postalias/postalias.c

src/postcat/Makefile.in

src/postcat/postcat.c

src/postconf/Makefile.in

src/postconf/extract.awk

src/postconf/install_table.h

src/postconf/install_vars.h

src/postconf/postconf.c

src/postdrop/Makefile.in

src/postdrop/postdrop.c

src/postfix/Makefile.in

src/postfix/postfix.c

src/postkick/Makefile.in

src/postkick/postkick.c

src/postlock/Makefile.in

src/postlock/postlock.c

src/postlog/Makefile.in

src/postlog/postlog.c

src/postmap/Makefile.in

src/postmap/postmap.c

src/postmulti/Makefile.in

src/postmulti/postmulti.c

src/postqueue/Makefile.in

src/postqueue/postqueue.c

src/postscreen/Makefile.in

src/postscreen/postscreen.c

src/postscreen/postscreen.h

src/postscreen/postscreen_dnsbl.c

src/postscreen/postscreen_send.c

src/postscreen/postscreen_smtpd.c

src/postscreen/postscreen_starttls.c

src/postscreen/postscreen_state.c

src/postscreen/postscreen_tests.c

src/postsuper/Makefile.in

src/postsuper/postsuper.c

src/proxymap/proxymap.c

src/qmgr/Makefile.in

src/qmgr/qmgr_active.c

src/qmqpd/Makefile.in

src/qmqpd/qmqpd.c

src/qmqpd/qmqpd_peer.c

src/sendmail/Makefile.in

src/sendmail/sendmail.c

src/showq/showq.c

src/smtp/Makefile.in

src/smtp/lmtp_params.c

src/smtp/smtp.c

src/smtp/smtp_chat.c

src/smtp/smtp_connect.c

src/smtp/smtp_map11.c

src/smtp/smtp_params.c

src/smtp/smtp_proto.c

src/smtp/smtp_sasl_auth_cache.c

src/smtp/smtp_sasl_glue.c

src/smtp/smtp_session.c

src/smtp/smtp_trouble.c

src/smtpd/Makefile.in

src/smtpd/smtpd.c

src/smtpd/smtpd.h

src/smtpd/smtpd_chat.c

src/smtpd/smtpd_check.c

src/smtpd/smtpd_check.h

src/smtpd/smtpd_check.ref

src/smtpd/smtpd_dnswl.in

src/smtpd/smtpd_dnswl.ref

src/smtpd/smtpd_exp.ref

src/smtpd/smtpd_peer.c

src/smtpd/smtpd_proxy.c

src/smtpd/smtpd_sasl_glue.c

src/smtpd/smtpd_sasl_glue.h

src/smtpd/smtpd_sasl_proto.c

src/smtpd/smtpd_sasl_proto.h

src/smtpd/smtpd_state.c

src/smtpstone/smtp-sink.c

src/smtpstone/smtp-source.c

src/tls/tls.h

src/tls/tls_bio_ops.c

src/tls/tls_client.c

src/tls/tls_misc.c

src/tls/tls_proxy_print.c

src/tls/tls_proxy_scan.c

src/tls/tls_server.c

src/tls/tls_stream.c

src/tls/tls_verify.c

src/tlsmgr/Makefile.in

src/tlsmgr/tlsmgr.c

src/tlsproxy/tlsproxy.c

src/tlsproxy/tlsproxy.h

src/tlsproxy/tlsproxy_state.c

src/trivial-rewrite/Makefile.in

src/trivial-rewrite/resolve.c

src/trivial-rewrite/transport.c

src/trivial-rewrite/transport.h

src/util/Makefile.in

src/util/argv.c

src/util/argv.h

src/util/dict.c

src/util/dict.h

src/util/dict_alloc.c

src/util/dict_cache.c

src/util/dict_cache.h

src/util/dict_cdb.c

src/util/dict_cidr.c

src/util/dict_db.c

src/util/dict_dbm.c

src/util/dict_debug.c

src/util/dict_env.c

src/util/dict_ht.c

src/util/dict_ni.c

src/util/dict_nis.c

src/util/dict_nisplus.c

src/util/dict_open.c

src/util/dict_pcre.c

src/util/dict_regexp.c

src/util/dict_regexp.ref

src/util/dict_sdbm.c

src/util/dict_static.c

src/util/dict_tcp.c

src/util/dict_thash.c

src/util/dict_unix.c

src/util/edit_file.c

src/util/fifo_listen.c

src/util/host_port.in

src/util/host_port.ref

src/util/inet_proto.c

src/util/load_file.c

src/util/lstat_as.c

src/util/mac_expand.c

src/util/mac_expand.h

src/util/make_dirs.c

src/util/match_list.c

src/util/match_list.h

src/util/match_ops.c

src/util/msg.c

src/util/msg.h

src/util/myaddrinfo.ref

src/util/mymalloc.c

src/util/name_mask.c

src/util/safe_open.c

src/util/sane_link.c

src/util/sane_rename.c

src/util/stat_as.c

src/util/sys_defs.h

src/util/vbuf.c

src/util/vbuf.h

src/util/vstream.c

src/util/vstream.h

src/util/vstream_tweak.c

src/verify/Makefile.in

src/verify/verify.c

src/virtual/Makefile.in

src/virtual/mailbox.c

src/virtual/maildir.c

src/virtual/virtual.c

src/xsasl/xsasl_dovecot_server.c

Show diffs side-by-side

added added

removed removed

src/global/dict_proxy.c

/* int open_flags;

/* int dict_flags;

/* DESCRIPTION

/* dict_proxy_open() relays read-only operations through

/* the Postfix proxymap server.

/* dict_proxy_open() relays read-only or read-write operations

/* through the Postfix proxymap server.

/* The \fIopen_flags\fR argument must specify O_RDONLY

/* or O_RDWR|O_CREAT. Depending on this, the client

/* or O_RDWR. Depending on this, the client

/* connects to the proxymap multiserver or to the

/* proxywrite single updater.

DICT dict; /* generic members */

CLNT_STREAM *clnt; /* client handle (shared) */

const char *service; /* service name */

int in_flags; /* caller-specified flags */

int inst_flags; /* saved dict flags */

VSTRING *reskey; /* result key storage */

VSTRING *result; /* storage */

} DICT_PROXY;

static CLNT_STREAM *proxymap_stream; /* read-only maps */

static CLNT_STREAM *proxywrite_stream; /* read-write maps */

/* dict_proxy_sequence - find first/next entry */

static int dict_proxy_sequence(DICT *dict, int function,

const char **key, const char **value)

{

const char *myname = "dict_proxy_sequence";

DICT_PROXY *dict_proxy = (DICT_PROXY *) dict;

VSTREAM *stream;

100

int status;

101

int count = 0;

102

int request_flags;

103

104

105

* The client and server live in separate processes that may start and

106

* terminate independently. We cannot rely on a persistent connection,

107

* let alone on persistent state (such as a specific open table) that is

108

* associated with a specific connection. Each lookup needs to specify

109

* the table and the flags that were specified to dict_proxy_open().

110

111

VSTRING_RESET(dict_proxy->reskey);

112

VSTRING_TERMINATE(dict_proxy->reskey);

113

VSTRING_RESET(dict_proxy->result);

114

VSTRING_TERMINATE(dict_proxy->result);

115

request_flags = dict_proxy->inst_flags

116

| (dict->flags & DICT_FLAG_RQST_MASK);

117

for (;;) {

118

stream = clnt_stream_access(dict_proxy->clnt);

119

errno = 0;

120

count += 1;

121

if (attr_print(stream, ATTR_FLAG_NONE,

122

ATTR_TYPE_STR, MAIL_ATTR_REQ, PROXY_REQ_SEQUENCE,

123

ATTR_TYPE_STR, MAIL_ATTR_TABLE, dict->name,

124

ATTR_TYPE_INT, MAIL_ATTR_FLAGS, request_flags,

125

ATTR_TYPE_INT, MAIL_ATTR_FUNC, function,

126

ATTR_TYPE_END) != 0

127

|| vstream_fflush(stream)

128

|| attr_scan(stream, ATTR_FLAG_STRICT,

129

ATTR_TYPE_INT, MAIL_ATTR_STATUS, &status,

130

ATTR_TYPE_STR, MAIL_ATTR_KEY, dict_proxy->reskey,

131

ATTR_TYPE_STR, MAIL_ATTR_VALUE, dict_proxy->result,

132

ATTR_TYPE_END) != 3) {

133

if (msg_verbose || count > 1 || (errno && errno != EPIPE && errno != ENOENT))

134

msg_warn("%s: service %s: %m", myname, VSTREAM_PATH(stream));

135

} else {

136

if (msg_verbose)

137

msg_info("%s: table=%s flags=%s func=%d -> status=%d key=%s val=%s",

138

myname, dict->name, dict_flags_str(request_flags),

139

function, status, STR(dict_proxy->reskey),

140

STR(dict_proxy->result));

141

switch (status) {

142

case PROXY_STAT_BAD:

143

msg_fatal("%s sequence failed for table \"%s\" function %d: "

144

"invalid request",

145

dict_proxy->service, dict->name, function);

146

case PROXY_STAT_DENY:

147

msg_fatal("%s service is not configured for table \"%s\"",

148

dict_proxy->service, dict->name);

149

case PROXY_STAT_OK:

150

*key = STR(dict_proxy->reskey);

151

*value = STR(dict_proxy->result);

152

DICT_ERR_VAL_RETURN(dict, DICT_ERR_NONE, DICT_STAT_SUCCESS);

153

case PROXY_STAT_NOKEY:

154

*key = *value = 0;

155

DICT_ERR_VAL_RETURN(dict, DICT_ERR_NONE, DICT_STAT_FAIL);

156

case PROXY_STAT_RETRY:

157

*key = *value = 0;

158

DICT_ERR_VAL_RETURN(dict, DICT_ERR_RETRY, DICT_STAT_ERROR);

159

default:

160

msg_warn("%s sequence failed for table \"%s\" function %d: "

161

"unexpected reply status %d",

162

dict_proxy->service, dict->name, function, status);

163

}

164

}

165

clnt_stream_recover(dict_proxy->clnt);

166

sleep(1); /* XXX make configurable */

167

}

168

}

169

170

/* dict_proxy_lookup - find table entry */

171

172

static const char *dict_proxy_lookup(DICT *dict, const char *key)

108

187

109

188

VSTRING_RESET(dict_proxy->result);

110

189

VSTRING_TERMINATE(dict_proxy->result);

111

request_flags = (dict_proxy->in_flags & DICT_FLAG_RQST_MASK)

190

request_flags = dict_proxy->inst_flags

112

191

| (dict->flags & DICT_FLAG_RQST_MASK);

113

192

for (;;) {

114

193

stream = clnt_stream_access(dict_proxy->clnt);

142

221

msg_fatal("%s service is not configured for table \"%s\"",

143

222

dict_proxy->service, dict->name);

144

223

case PROXY_STAT_OK:

145

return (STR(dict_proxy->result));

224

DICT_ERR_VAL_RETURN(dict, DICT_ERR_NONE, STR(dict_proxy->result));

146

225

case PROXY_STAT_NOKEY:

147

dict_errno = 0;

148

return (0);

226

DICT_ERR_VAL_RETURN(dict, DICT_ERR_NONE, (char *) 0);

149

227

case PROXY_STAT_RETRY:

150

dict_errno = DICT_ERR_RETRY;

151

return (0);

228

DICT_ERR_VAL_RETURN(dict, DICT_ERR_RETRY, (char *) 0);

152

229

default:

153

230

msg_warn("%s lookup failed for table \"%s\" key \"%s\": "

154

231

"unexpected reply status %d",

162

239

163

240

/* dict_proxy_update - update table entry */

164

241

165

static void dict_proxy_update(DICT *dict, const char *key, const char *value)

242

static int dict_proxy_update(DICT *dict, const char *key, const char *value)

166

243

{

167

244

const char *myname = "dict_proxy_update";

168

245

DICT_PROXY *dict_proxy = (DICT_PROXY *) dict;

178

255

* associated with a specific connection. Each lookup needs to specify

179

256

* the table and the flags that were specified to dict_proxy_open().

180

257

181

request_flags = (dict_proxy->in_flags & DICT_FLAG_RQST_MASK)

258

request_flags = dict_proxy->inst_flags

182

259

| (dict->flags & DICT_FLAG_RQST_MASK);

183

260

for (;;) {

184

261

stream = clnt_stream_access(dict_proxy->clnt);

211

288

msg_fatal("%s update access is not configured for table \"%s\"",

212

289

dict_proxy->service, dict->name);

213

290

case PROXY_STAT_OK:

214

return;

291

DICT_ERR_VAL_RETURN(dict, DICT_ERR_NONE, DICT_STAT_SUCCESS);

292

case PROXY_STAT_NOKEY:

293

DICT_ERR_VAL_RETURN(dict, DICT_ERR_NONE, DICT_STAT_FAIL);

294

case PROXY_STAT_RETRY:

295

DICT_ERR_VAL_RETURN(dict, DICT_ERR_RETRY, DICT_STAT_ERROR);

215

296

default:

216

297

msg_warn("%s update failed for table \"%s\" key \"%s\": "

217

298

"unexpected reply status %d",

241

322

* associated with a specific connection. Each lookup needs to specify

242

323

* the table and the flags that were specified to dict_proxy_open().

243

324

244

request_flags = (dict_proxy->in_flags & DICT_FLAG_RQST_MASK)

325

request_flags = dict_proxy->inst_flags

245

326

| (dict->flags & DICT_FLAG_RQST_MASK);

246

327

for (;;) {

247

328

stream = clnt_stream_access(dict_proxy->clnt);

274

355

msg_fatal("%s update access is not configured for table \"%s\"",

275

356

dict_proxy->service, dict->name);

276

357

case PROXY_STAT_OK:

277

return 0;

358

DICT_ERR_VAL_RETURN(dict, DICT_ERR_NONE, DICT_STAT_SUCCESS);

278

359

case PROXY_STAT_NOKEY:

279

return 1;

360

DICT_ERR_VAL_RETURN(dict, DICT_ERR_NONE, DICT_STAT_FAIL);

361

case PROXY_STAT_RETRY:

362

DICT_ERR_VAL_RETURN(dict, DICT_ERR_RETRY, DICT_STAT_ERROR);

280

363

default:

281

364

msg_warn("%s delete failed for table \"%s\" key \"%s\": "

282

365

"unexpected reply status %d",

294

377

{

295

378

DICT_PROXY *dict_proxy = (DICT_PROXY *) dict;

296

379

380

vstring_free(dict_proxy->reskey);

297

381

vstring_free(dict_proxy->result);

298

382

dict_free(dict);

299

383

}

334

418

if (open_flags == O_RDONLY) {

335

419

pstream = &proxymap_stream;

336

420

service = var_proxymap_service;

337

} else if (open_flags == (O_RDWR | O_CREAT)) {

421

} else if ((open_flags & O_RDWR) == O_RDWR) {

338

422

pstream = &proxywrite_stream;

339

423

service = var_proxywrite_service;

340

424

} else

341

msg_fatal("%s: %s map open requires O_RDONLY or O_RDWR|O_CREAT mode",

425

msg_fatal("%s: %s map open requires O_RDONLY or O_RDWR mode",

342

426

map, DICT_TYPE_PROXY);

343

427

344

428

if (*pstream == 0) {

364

448

dict_proxy->dict.lookup = dict_proxy_lookup;

365

449

dict_proxy->dict.update = dict_proxy_update;

366

450

dict_proxy->dict.delete = dict_proxy_delete;

451

dict_proxy->dict.sequence = dict_proxy_sequence;

367

452

dict_proxy->dict.close = dict_proxy_close;

368

dict_proxy->in_flags = dict_flags;

453

dict_proxy->inst_flags = (dict_flags & DICT_FLAG_INST_MASK);

454

dict_proxy->reskey = vstring_alloc(10);

369

455

dict_proxy->result = vstring_alloc(10);

370

456

dict_proxy->clnt = *pstream;

371

457

dict_proxy->service = service;

381

467

if (attr_print(stream, ATTR_FLAG_NONE,

382

468

ATTR_TYPE_STR, MAIL_ATTR_REQ, PROXY_REQ_OPEN,

383

469

ATTR_TYPE_STR, MAIL_ATTR_TABLE, dict_proxy->dict.name,

384

ATTR_TYPE_INT, MAIL_ATTR_FLAGS, dict_proxy->in_flags,

470

ATTR_TYPE_INT, MAIL_ATTR_FLAGS, dict_proxy->inst_flags,

385

471

ATTR_TYPE_END) != 0

386

472

|| vstream_fflush(stream)

387

473

|| attr_scan(stream, ATTR_FLAG_STRICT,

403

489

msg_fatal("%s service is not configured for table \"%s\"",

404

490

dict_proxy->service, dict_proxy->dict.name);

405

491

case PROXY_STAT_OK:

406

dict_proxy->dict.flags = dict_proxy->in_flags

492

dict_proxy->dict.flags = (dict_flags & ~DICT_FLAG_IMPL_MASK)

407

493

| (server_flags & DICT_FLAG_IMPL_MASK);

408

494

return (DICT_DEBUG (&dict_proxy->dict));

409

495

default:

Older »