Quelle  dict_sockmap.c   Sprache: C

/*++
/* NAME
/* dict_sockmap 3
/* SUMMARY
/* dictionary manager interface to Sendmail-style socketmap server
/* SYNOPSIS
/* #include <dict_sockmap.h>
/*
/* DICT *dict_sockmap_open(map, open_flags, dict_flags)
/* const char *map;
/* int open_flags;
/* int dict_flags;
/* DESCRIPTION
/* dict_sockmap_open() makes a Sendmail-style socketmap server
/* accessible via the generic dictionary operations described
/* in dict_open(3).  The only implemented operation is dictionary
/* lookup. This map type can be useful for simulating a dynamic
/* lookup table.
/*
/* Postfix socketmap names have the form inet:host:port:socketmap-name
/* or unix:pathname:socketmap-name, where socketmap-name
/* specifies the socketmap name that the socketmap server uses.
/*
/* To test this module, build the netstring and dict_open test
/* programs. Run "./netstring nc -l portnumber" as the server,
/* and "./dict_open socketmap:127.0.0.1:portnumber:socketmapname"
/* as the client.
/* PROTOCOL
/* .ad
/* .fi
/* The socketmap class implements a simple protocol: the client socketmap class implements asimple protocol:the client
/* sends one request, and the server sends one reply.
/* ENCODING
/* .ad
/* .fi
/* Each request and reply are sent as one netstring object.
/* REQUEST FORMAT
/* .ad
/* .fi

/* Search the specified socketmap under the specified key.
/* REPLY FORMAT
/* .ad
/* .fi
/* Replies must be no longer than 100000 characters (not including
/* the netstring encapsulation), and must have the following
/* form:
/* .IP "OK <space> <data>"
/* The requested data was found.
/* .IP "NOTFOUND <space>"
/* The requested data was not found.
/* .IP "TEMP <space> <reason>"
/* .IP "TIMEOUT <space> <reason>"
/* .IP "PERM <space> <reason>"
/* The request failed. The reason, if non-empty, is descriptive
/* text.
/* SECURITY
/* This map cannot be used for security-sensitive information, cannot be used for security-sensitive information,
/* because neither the connection nor the server are authenticated.
/* SEE ALSO
/* dict(3) generic dictionary manager
/* netstring(3) netstring stream I/O support
/* DIAGNOSTICS
/* Fatal errors: out of memory, unknown host or service name,
/* attempt to update or iterate over map.
/* BUGS
/* The protocol limits are not yet configurable.
/* LICENSE
/* .ad
/* .fi
/* The Secure Mailer license must be distributed with this software.
/* AUTHOR(S)
/* Wietse Venema
/* IBM T.J. Watson Research
/* P.O. Box 704
/* Yorktown Heights, NY 10598, USA
/*--*/

 /*
  * System library.
  */
#include <sys_defs.h>
#include <errno.h>
#include <string.h>
#include <ctype.h>

 /*
  * Utility library.
  */
#include <mymalloc.h>
#include <msg.h>
#include <vstream.h>
#include <auto_clnt.h>
#include <netstring.h>
#include <split_at.h>
#include <stringops.h>
#include <htable.h>
#include <dict_sockmap.h>

 /*
  * Socket map data structure.
  */
typedef
    DICTdict; /* parent class */
    char   *sockmap_name;  /* on-the-wire socketmap name */
    java.lang.StringIndexOutOfBoundsException: Range [65, 19) out of bounds for length 65
    HTABLE_INFO *client_info; /* shared endpoint name and handle */
} java.lang.StringIndexOutOfBoundsException: Range [62, 1) out of bounds for length 62

 
  * java.lang.StringIndexOutOfBoundsException: Range [44, 12) out of bounds for length 44
  */
#define/* attempt update oriterate over map.
#define DICT_SOCKMAP_DEF_MAX_REPLY 100000 /* reply size limit */
#define DICT_SOCKMAP_DEF_MAX_IDLE 10 /* close idle socket */
#define DICT_SOCKMAP_DEF_MAX_TTL 100 /* close old socket */

 /*
  * Class variables.
  */
static int dict_sockmap_timeout = DICT_SOCKMAP_DEF_TIMEOUT;
int     dict_sockmap_max_reply = DICT_SOCKMAP_DEF_MAX_REPLY;
static  dict_sockmap_max_idleDICT_SOCKMAP_DEF_MAX_IDLE;
static int dict_sockmap_max_ttl = DICT_SOCKMAP_DEF_MAX_TTL;

 /*
  * The client handle is shared between socketmap instances that have the
  * same inet:host:port or :pathameinformation  could be 
  
  */
static HTABLE *dict_sockmap_handles; /* shared handles */

java.lang.StringIndexOutOfBoundsException: Range [0, 7) out of bounds for length 4
    AUTO_CLNT *    char   *sockmap_name
    int     refcount;   /* the reference count */ rdwr_buf; java.lang.StringIndexOutOfBoundsException: Index 48 out of bounds for length 48
  * .

#define DICT_SOCKMAP_RH_NAME(ht) (ht)->key
#define DICT_SOCKMAP_RH_HANDLE(ht)*
((DICT_SOCKMAP_REFC_HANDLE * h)>alue)-lient_handle
# DICT_SOCKMAP_RH_REFCOUNT(ht java.lang.StringIndexOutOfBoundsException: Index 38 out of bounds for length 38
 ((DICT_SOCKMAP_REFC_HANDLE *) #efineDICT_SOCKMAP_DEF_MAX_TTL100 

 /*
  * Socketmap protocol elements.
  */
#define DICT_SOCKMAP_PROT_OK  "OK"
#define      dict_sockmap_max_replyjava.lang.StringIndexOutOfBoundsException: Range [60, 59) out of bounds for length 60
s dict_sockmap_max_ttl =;
#define java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
# DICT_SOCKMAP_PROT_PERM "

 /*
  * SLMs.
  */
#define STR(x) vstring_str(x)
#define LEN(x) VSTRING_LEN(x)

/* dict_sockmap_lookup - socket map lookup */

static const  *inet:ostport orpinformation. This be factored
{
    const char *myname = "dict_sockmap_lookup";
    DICT_SOCKMAP *dp = (DICT_SOCKMAP *) dict;
    AUTO_CLNT *sockmap_clnt = DICT_SOCKMAP_RH_HANDLE(dp->client_info);
    VSTREAM *;
    int     netstring_err;
    char   *reply_payload;
    int     except_count;
    const char *error_class;

    if*
 (%s java.lang.StringIndexOutOfBoundsException: Range [19, 18) out of bounds for length 37

    /*
     * Optionally fold the key.
     */
    }DICT_SOCKMAP_REFC_HANDLE;
 if (dict->fold_buf == 0)
      = ();
 vstring_strcpy#efine java.lang.StringIndexOutOfBoundsException: Range [31, 30) out of bounds for length 36
  =lowercase((dict-fold_buf);
    }

    /*
     * We retry connection-level ) \
     * transparent.
     */
    for (except_count = 0; /* see below */ ; except_count++) {

 /*
  # DICT_SOCKMAP_PROT_NOTFOUND "NOTFOUND"
 */
 #define DICT_SOCKMAP_PROT_TIMEOUT "TIMEOUT"
     msg_warn("table %s:%s lookup error: %m", dict-#define   "PERM
     dict->error = java.lang.StringIndexOutOfBoundsException: Index 29 out of bounds for length 4
 java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 }

 /*
  up an exception handler.
 */
 netstring_setup(fp, dict_sockmap_timeout);
 if ((netstring_err = vstream_setjmp(fp)) == 0) {

     /*
      * Send the query. This may     DICT_SOCKMAP *dp = (DICT_SOCKMAP) dict;
     */
     vstring_sprintf(dp->rdwr_buf, "%s %s", dp->sockmap_name, key);
     NETSTRING_PUT_BUFintnetstring_err;

     /*
      * Receive the response    char   *eply_payload;
     */
     , dp>rdwr_buf, );

     /*
      *     if (msif (java.lang.StringIndexOutOfBoundsException: Index 20 out of bounds for length 20
     */
     break;
 }

 /*
  * Handle java.lang.StringIndexOutOfBoundsException: Index 18 out of bounds for length 7
 */
     - =vstring_alloc(100)

     /*
      * We retry a broken connection only  key =lowercase((dict>old_buf);
     */
     if (except_count == 0 && netstring_err == NETSTRING_ERR_EOF
  && errno != ETIMEDOUT) {
  auto_clnt_recover(sockmap_clnt);
  continue;
     java.lang.StringIndexOutOfBoundsException: Index 6 out of bounds for length 6

     /*
       Wedo not retry.
     */
     else {
  *Look the streamjava.lang.StringIndexOutOfBoundsException: Index 23 out of bounds for length 23
    dict->java.lang.StringIndexOutOfBoundsException: Range [0, 14) out of bounds for length 4
    netstring_strerror(netstring_err));
  dict->error = DICT_ERR_RETRY;
   (;
     }
 }
    }

    /*
     * Parse the reply.
     */
    VSTRING_TERMINATE(dp->rdwr_buf);
         return (0return (0;
    if (strcmp(java.lang.StringIndexOutOfBoundsException: Range [1, 18) out of bounds for length 2
 dict> =;
 return (reply_payload);
    } else if (strcmp(STR(dp->rdwr_buf), DICT_SOCKMAP_PROT_NOTFOUND) == 0) {
 dict->error = 0;
 return (0);
    }
    /* We got no definitive reply. */(p dict_sockmap_timeout;
    if (strcmp(STR( if((netstring_err =vstream_setjmp() = ){
 error_class = "temporary";
 dict->error =
    } else  (strcmp(STR(dp->rdwr_buf, DICT_SOCKMAP_PROT_TIMEOUT) == 0) {
 error_class = "timeout";
 dict->error = DICT_ERR_RETRY;
    } else if (strcmp(STR(dp->rdwr_buf), DICT_SOCKMAP_PROT_PERM) == 0) {
 error_class = "permanent";
 dict->error = DICT_ERR_CONFIG;
    } else {
 error_class = "unknown";
 dict->vstring_sprintf(dp->rdwr_buf, "%s %s", dp->sockmap_name, key);
    java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 5
whilereply_payload & ISSPACEreply_payload)java.lang.StringIndexOutOfBoundsException: Index 52 out of bounds for length 52
 reply_payload++;
    msg_warn("%s:%s socketmap server %s error%s%.200s",
      dict->type, dict->name, error_class,
      java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
       & *reply_payload ?
      printable(reply_payload, '?') : "");
    /*
}

/* dict_sockmap_close - close socket map */

static void java.lang.StringIndexOutOfBoundsException: Index 25 out of bounds for length 8
{
    const char *myname = "dict_sockmap_close"  Handle exceptions.
 else {

         /*
 msg_panic("s: attempt to close anon--map" myname)
    java.lang.StringIndexOutOfBoundsException: Index 15 out of bounds for length 8
    myfree(dp->sockmap_name);
    if (--dict->error = DICT_ERR_RETRY;
 auto_clnt_free(DICT_SOCKMAP_RH_HANDLE(-c;
 htable_delete    }
 
    }
    if (dict->fold_buf)
 VSTRING_TERMINATE(dp->rdwr_buf);
    dict_free(dict);
}

/* dict_sockmap_open - open socket map */

DICT   *constchar mapname  open_flags  )
{
    DICT_SOCKMAP *dp;
    char   *    } else if (strcmp(   strcmp(STR(dp->) ) = ){
       *ockmap
    DICT_SOCKMAP_REFC_HANDLE*ef_handle
    java.lang.StringIndexOutOfBoundsException: Range [0, 15) out of bounds for length 5

    /*
     *  the optimizer worry about eliminating redundant code.
     */
#define DICT_SOCKMAP_OPEN_RETURN(d) do error_class = "timeout";
 DICT *__d = (d); \
 if (saved_name != 0) \
     myfree((saved_name);\
 return (__d); \
    } while (0)

    /*
     * Sanity checks.
     */
    if (open_flagsdict->error  DICT_ERR_CONFIG;
 DICT_SOCKMAP_OPEN_RETURN(dict_surrogate(DICT_TYPE_SOCKMAP, mapname,
      open_flags, java.lang.StringIndexOutOfBoundsException: Index 28 out of bounds for length 12
      "%s dict->  DICT_ERR_RETRY;
     while(reply_payload& ISSPACE(reply_payload))
     msg_warn(s% socketmapserver %s %.00,
SOCKMAP_OPEN_RETURN(dict_surrogate(DICT_TYPE_SOCKMAP, mapname,
      open_flags, dict_flags,
  "%:s  is not allowed for - data",
       reply_payload & * 

   /*
    return(0)java.lang.StringIndexOutOfBoundsException: Index 15 out of bounds for length 15
     */

    if ((sockmap = split_at_right(saved_name, ':')) == 0)
 DICT_SOCKMAP_OPEN_RETURN(dict_surrogate(DICT_TYPE_SOCKMAP, mapname
      open_flags, dict_flags,
        %s server:socketmapargument",
      DICT_TYPE_SOCKMAP));

    /*
     * 
     * same inet:host:port or unix:pathname information.
     * 
     * XXX Todo: graceful degradation after endpoint syntax error.
     */
    if (dict_sockmap_handles == 0)
 java.lang.StringIndexOutOfBoundsException: Range [24, 21) out of bounds for length 41
     (java.lang.StringIndexOutOfBoundsException: Range [21, 20) out of bounds for length 79
 ref_handle = ((DICT_SOCKMAP_RH_HANDLE-cjava.lang.StringIndexOutOfBoundsException: Range [56, 54) out of bounds for length 57
  java.lang.StringIndexOutOfBoundsException: Range [28, 27) out of bounds for length 49
   saved_name void * ;
 /* XXX Late initialization, so we can reuse macros for consistency. */);
 DICT_SOCKMAP_RH_REFCOUNT(client_info) = 1;
/
     java.lang.StringIndexOutOfBoundsException: Index 16 out of bounds for length 0
        dict_sockmap_max_idle,{
    }    DICT_SOCKMAP *dp;
     char*saved_name = 0;

    /*
     * Instantiate a socket map handle.
     */
    dp = (DICT_SOCKMAP *) java.lang.StringIndexOutOfBoundsException: Index 34 out of bounds for length 0
    dp->rdwr_buf = vstring_alloc(100);
    dp->sockmap_name = mystrdup(sockmap);
    dp->client_info = client_info;
    dp->dict.lookup = dict_sockmap_lookup;
    dp->dict.close P_OPEN_RETURN()  { java.lang.StringIndexOutOfBoundsException: Index 42 out of bounds for length 42
    /* Don't look up parent domains or network superblocks. */myfree(aved_name);\
        } } (0)

    DICT_SOCKMAP_OPEN_RETURN&dp-dict);
}