noffle: src/fetch.c annotate

annotate src/fetch.c @ 288:c02c4eb95f95 noffle

[svn] * src/configfile.h,src/configfile.c,docs/noffle.conf.5: Add noffle-user and noffle-group configs. * src/configfile.c,src/fetch.c,src/fetchlist.c,src/protocol.c, src/server.c: Replace strcpy() with Utl_cpyStr() where appropriate. See Debian bug 168128. * src/control.c,src/configfile.c,src/noffle.c: Replace [s]scanf("%s") with [s]scanf(MAXCHAR_FMT). * src/noffle.c: Log warning if noffle.conf is world readable. * src/noffle.c: Restrict most options to news admins; i.e. those who are root or news on running Noffle. * Makefile.in,acconfig.h,aclocal.m4,config.h.in,configure,configure.in, docs/Makefile.in,docs/noffle.conf.5,packages/Makefile.in, packages/redhat/Makefile.in,src/Makefile.am,src/Makefile.in, src/authenticate.c,src/authenticate.h,src/noffle.c,src/server.c: Add basic authentication using either Noffle-specific user file or authenticating via PAM (service 'noffle'). PAM authentication needs to run as root, so a Noffle server that needs PAM must be started by root. Helpful (?) error messages will be logged if not. Noffle will switch ruid and euid to 'news' (or whatever is configured) ASAP. * src/noffle.c: Add uid checking.

author	bears
date	Fri, 10 Jan 2003 23:25:45 +0000
parents	39d9c19ffba4
children	d9035d08fe51

rev	line source
43 2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	1 /*
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	2 fetch.c
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	3
283 39d9c19ffba4 [svn] * src/fetch.c: Add Reply-To to the front of the list of headers searched bears parents: 274 diff changeset	4 $Id: fetch.c 415 2003-01-10 22:40:18Z bears $
43 2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	5 */
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	6
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	7 #if HAVE_CONFIG_H
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	8 #include <config.h>
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	9 #endif
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	10
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	11 #include <stdio.h>
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	12 #include <errno.h>
54 125d79c9e586 [svn] * src/client.c, src/configfile.c, src/content.c, src/control.c, uh1763 parents: 43 diff changeset	13
125d79c9e586 [svn] * src/client.c, src/configfile.c, src/content.c, src/control.c, uh1763 parents: 43 diff changeset	14 #if TIME_WITH_SYS_TIME
125d79c9e586 [svn] * src/client.c, src/configfile.c, src/content.c, src/control.c, uh1763 parents: 43 diff changeset	15 #include <sys/time.h>
43 2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	16 #include <time.h>
54 125d79c9e586 [svn] * src/client.c, src/configfile.c, src/content.c, src/control.c, uh1763 parents: 43 diff changeset	17 #else
125d79c9e586 [svn] * src/client.c, src/configfile.c, src/content.c, src/control.c, uh1763 parents: 43 diff changeset	18 #if HAVE_SYS_TIME_H
125d79c9e586 [svn] * src/client.c, src/configfile.c, src/content.c, src/control.c, uh1763 parents: 43 diff changeset	19 #include <sys/time.h>
125d79c9e586 [svn] * src/client.c, src/configfile.c, src/content.c, src/control.c, uh1763 parents: 43 diff changeset	20 #else
125d79c9e586 [svn] * src/client.c, src/configfile.c, src/content.c, src/control.c, uh1763 parents: 43 diff changeset	21 #include <time.h>
125d79c9e586 [svn] * src/client.c, src/configfile.c, src/content.c, src/control.c, uh1763 parents: 43 diff changeset	22 #endif
125d79c9e586 [svn] * src/client.c, src/configfile.c, src/content.c, src/control.c, uh1763 parents: 43 diff changeset	23 #endif
125d79c9e586 [svn] * src/client.c, src/configfile.c, src/content.c, src/control.c, uh1763 parents: 43 diff changeset	24
43 2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	25 #include <signal.h>
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	26 #include "client.h"
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	27 #include "configfile.h"
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	28 #include "content.h"
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	29 #include "dynamicstring.h"
197 24d4cd032da5 [svn] * AUTHORS,INSTALL,NEWS,README,TODO,docs/NOTES,src/client.c,src/protocol.c, bears parents: 193 diff changeset	30 #include "fetch.h"
43 2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	31 #include "fetchlist.h"
249 0340b9c17edc [svn] * empty log message * mirkol parents: 223 diff changeset	32 #include "filter.h"
43 2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	33 #include "request.h"
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	34 #include "group.h"
127 3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	35 #include "lock.h"
43 2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	36 #include "log.h"
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	37 #include "outgoing.h"
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	38 #include "protocol.h"
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	39 #include "pseudo.h"
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	40 #include "util.h"
54 125d79c9e586 [svn] * src/client.c, src/configfile.c, src/content.c, src/control.c, uh1763 parents: 43 diff changeset	41 #include "portable.h"
43 2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	42
127 3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	43 #define MAX_ARTICLE_CMDS_QUEUED 20
3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	44
274 755e03bc7dcf [svn] * src/fetch.c,src/log.c: Make 'fetch' and 'log' variables static; they're bears parents: 271 diff changeset	45 static struct Fetch
43 2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	46 {
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	47 Bool ready;
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	48 Str serv;
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	49 } fetch = { FALSE, "" };
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	50
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	51 static Bool
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	52 connectToServ( const char *name )
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	53 {
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	54 Log_inf( "Fetch from '%s'", name );
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	55 if ( ! Client_connect( name ) )
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	56 {
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	57 Log_err( "Could not connect to %s", name );
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	58 return FALSE;
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	59 }
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	60 return TRUE;
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	61 }
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	62
180 09ca6eb5c7ff [svn] * TODO,src/client.c,src/client.h,src/fetch.c,src/fetch.h,src/noffle.c: bears parents: 155 diff changeset	63 Bool
43 2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	64 Fetch_getNewGrps( void )
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	65 {
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	66 time_t t;
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	67 Str file;
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	68
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	69 ASSERT( fetch.ready );
127 3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	70 snprintf( file, MAXCHAR, "%s/lastupdate.%s",
3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	71 Cfg_spoolDir(), fetch.serv );
43 2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	72 if ( ! Utl_getStamp( &t, file ) )
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	73 {
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	74 Log_err( "Cannot read %s. Please run noffle --query groups", file );
180 09ca6eb5c7ff [svn] * TODO,src/client.c,src/client.h,src/fetch.c,src/fetch.h,src/noffle.c: bears parents: 155 diff changeset	75 return FALSE;
43 2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	76 }
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	77 Log_inf( "Updating groupinfo" );
188 f1bacee93ca6 [svn] * src/client.c,src/client.h,src/fetch.c,src/noffle.c,src/server.c: bears parents: 185 diff changeset	78
f1bacee93ca6 [svn] * src/client.c,src/client.h,src/fetch.c,src/noffle.c,src/server.c: bears parents: 185 diff changeset	79 /*
f1bacee93ca6 [svn] * src/client.c,src/client.h,src/fetch.c,src/noffle.c,src/server.c: bears parents: 185 diff changeset	80 * If NEWGROUPS fails, it isn't necessarily fatal. You can do
f1bacee93ca6 [svn] * src/client.c,src/client.h,src/fetch.c,src/noffle.c,src/server.c: bears parents: 185 diff changeset	81 * a periodic noffle --query groups to refresh your group list.
f1bacee93ca6 [svn] * src/client.c,src/client.h,src/fetch.c,src/noffle.c,src/server.c: bears parents: 185 diff changeset	82 * So only return failure here if the status indicates the link
f1bacee93ca6 [svn] * src/client.c,src/client.h,src/fetch.c,src/noffle.c,src/server.c: bears parents: 185 diff changeset	83 * itself failed.
f1bacee93ca6 [svn] * src/client.c,src/client.h,src/fetch.c,src/noffle.c,src/server.c: bears parents: 185 diff changeset	84 *
f1bacee93ca6 [svn] * src/client.c,src/client.h,src/fetch.c,src/noffle.c,src/server.c: bears parents: 185 diff changeset	85 * In particular, older versions of NNTPcache have a Y2K bug that
f1bacee93ca6 [svn] * src/client.c,src/client.h,src/fetch.c,src/noffle.c,src/server.c: bears parents: 185 diff changeset	86 * stops NEWGROUPS working.
f1bacee93ca6 [svn] * src/client.c,src/client.h,src/fetch.c,src/noffle.c,src/server.c: bears parents: 185 diff changeset	87 */
f1bacee93ca6 [svn] * src/client.c,src/client.h,src/fetch.c,src/noffle.c,src/server.c: bears parents: 185 diff changeset	88 return ( ! IS_FATAL( Client_getNewgrps( &t ) ) );
43 2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	89 }
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	90
127 3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	91 /* Databases open on entry, closed on exit. */
188 f1bacee93ca6 [svn] * src/client.c,src/client.h,src/fetch.c,src/noffle.c,src/server.c: bears parents: 185 diff changeset	92 static int
127 3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	93 fetchNewArts( const char *name, FetchMode mode )
43 2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	94 {
188 f1bacee93ca6 [svn] * src/client.c,src/client.h,src/fetch.c,src/noffle.c,src/server.c: bears parents: 185 diff changeset	95 int next, first, last, refetch, stat;
43 2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	96
188 f1bacee93ca6 [svn] * src/client.c,src/client.h,src/fetch.c,src/noffle.c,src/server.c: bears parents: 185 diff changeset	97 stat = Client_changeToGrp( name );
f1bacee93ca6 [svn] * src/client.c,src/client.h,src/fetch.c,src/noffle.c,src/server.c: bears parents: 185 diff changeset	98 if ( stat != STAT_OK )
43 2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	99 {
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	100 Log_err( "Could not change to group %s", name );
129 6b2b93288caa [svn] Fix potential lock bug bears parents: 127 diff changeset	101 if ( Lock_gotLock() )
6b2b93288caa [svn] Fix potential lock bug bears parents: 127 diff changeset	102 Lock_closeDatabases();
188 f1bacee93ca6 [svn] * src/client.c,src/client.h,src/fetch.c,src/noffle.c,src/server.c: bears parents: 185 diff changeset	103 return stat;
43 2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	104 }
127 3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	105 Client_rmtFirstLast( &first, &last );
43 2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	106 Cont_read( name );
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	107 next = Grp_rmtNext( name );
102 38b0a1532a37 [svn] Only track remote message no when subscribed bears parents: 79 diff changeset	108 if ( next == GRP_RMT_NEXT_NOT_SUBSCRIBED )
38b0a1532a37 [svn] Only track remote message no when subscribed bears parents: 79 diff changeset	109 next = first;
43 2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	110 if ( next == last + 1 )
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	111 {
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	112 Log_inf( "No new articles in %s", name );
223 ffb1848a39db [svn] * src/util.c: Improve (correct) error detection when updating bears parents: 197 diff changeset	113 if ( Cont_write() )
ffb1848a39db [svn] * src/util.c: Improve (correct) error detection when updating bears parents: 197 diff changeset	114 Grp_setFirstLast( name, Cont_first(), Cont_last() );
127 3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	115 Lock_closeDatabases();
188 f1bacee93ca6 [svn] * src/client.c,src/client.h,src/fetch.c,src/noffle.c,src/server.c: bears parents: 185 diff changeset	116 return STAT_OK;
43 2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	117 }
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	118 if ( first == 0 && last == 0 )
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	119 {
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	120 Log_inf( "No articles in %s", name );
223 ffb1848a39db [svn] * src/util.c: Improve (correct) error detection when updating bears parents: 197 diff changeset	121 if ( Cont_write() )
ffb1848a39db [svn] * src/util.c: Improve (correct) error detection when updating bears parents: 197 diff changeset	122 Grp_setFirstLast( name, Cont_first(), Cont_last() );
127 3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	123 Lock_closeDatabases();
188 f1bacee93ca6 [svn] * src/client.c,src/client.h,src/fetch.c,src/noffle.c,src/server.c: bears parents: 185 diff changeset	124 return STAT_OK;
43 2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	125 }
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	126 if ( next > last + 1 )
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	127 {
155 22b81617d427 [svn] applied patch from Matija Nalis: better handling of inconsistent counters enz parents: 154 diff changeset	128 refetch = last - Cfg_maxFetch() + 1;
22b81617d427 [svn] applied patch from Matija Nalis: better handling of inconsistent counters enz parents: 154 diff changeset	129 if ( refetch < 0 ) refetch = 1;
188 f1bacee93ca6 [svn] * src/client.c,src/client.h,src/fetch.c,src/noffle.c,src/server.c: bears parents: 185 diff changeset	130 Log_err( "Article number inconsistent (%s rmt=%lu-%lu, next=%lu). "
f1bacee93ca6 [svn] * src/client.c,src/client.h,src/fetch.c,src/noffle.c,src/server.c: bears parents: 185 diff changeset	131 "Refetching from %lu",
155 22b81617d427 [svn] applied patch from Matija Nalis: better handling of inconsistent counters enz parents: 154 diff changeset	132 name, first, last, next, refetch );
22b81617d427 [svn] applied patch from Matija Nalis: better handling of inconsistent counters enz parents: 154 diff changeset	133 Pseudo_cntInconsistent( name, first, last, next, refetch );
22b81617d427 [svn] applied patch from Matija Nalis: better handling of inconsistent counters enz parents: 154 diff changeset	134 first = refetch;
43 2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	135 }
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	136 else if ( next < first )
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	137 {
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	138 Log_inf( "Missing articles (%s first=%lu next=%lu)",
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	139 name, first, next );
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	140 Pseudo_missArts( name, first, next );
188 f1bacee93ca6 [svn] * src/client.c,src/client.h,src/fetch.c,src/noffle.c,src/server.c: bears parents: 185 diff changeset	141
f1bacee93ca6 [svn] * src/client.c,src/client.h,src/fetch.c,src/noffle.c,src/server.c: bears parents: 185 diff changeset	142 /*
f1bacee93ca6 [svn] * src/client.c,src/client.h,src/fetch.c,src/noffle.c,src/server.c: bears parents: 185 diff changeset	143 * If we are missing articles but there are none to fetch,
f1bacee93ca6 [svn] * src/client.c,src/client.h,src/fetch.c,src/noffle.c,src/server.c: bears parents: 185 diff changeset	144 * we must ensure we don't repeatedly generate missing
f1bacee93ca6 [svn] * src/client.c,src/client.h,src/fetch.c,src/noffle.c,src/server.c: bears parents: 185 diff changeset	145 * article warning on every fetch until there is something
f1bacee93ca6 [svn] * src/client.c,src/client.h,src/fetch.c,src/noffle.c,src/server.c: bears parents: 185 diff changeset	146 * to fetch. To guard against this, update the group remote
f1bacee93ca6 [svn] * src/client.c,src/client.h,src/fetch.c,src/noffle.c,src/server.c: bears parents: 185 diff changeset	147 * next now.
f1bacee93ca6 [svn] * src/client.c,src/client.h,src/fetch.c,src/noffle.c,src/server.c: bears parents: 185 diff changeset	148 */
f1bacee93ca6 [svn] * src/client.c,src/client.h,src/fetch.c,src/noffle.c,src/server.c: bears parents: 185 diff changeset	149 Grp_setRmtNext( name, first );
f1bacee93ca6 [svn] * src/client.c,src/client.h,src/fetch.c,src/noffle.c,src/server.c: bears parents: 185 diff changeset	150 next = first;
43 2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	151 }
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	152 else
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	153 first = next;
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	154 if ( last - first > Cfg_maxFetch() )
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	155 {
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	156 Log_ntc( "Cutting number of overviews to %lu", Cfg_maxFetch() );
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	157 first = last - Cfg_maxFetch() + 1;
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	158 }
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	159 Log_inf( "Getting remote overviews %lu-%lu for group %s",
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	160 first, last, name );
127 3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	161 Lock_closeDatabases();
180 09ca6eb5c7ff [svn] * TODO,src/client.c,src/client.h,src/fetch.c,src/fetch.h,src/noffle.c: bears parents: 155 diff changeset	162 return Client_getOver( name, first, last, mode );
127 3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	163 }
3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	164
180 09ca6eb5c7ff [svn] * TODO,src/client.c,src/client.h,src/fetch.c,src/fetch.h,src/noffle.c: bears parents: 155 diff changeset	165 Bool
127 3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	166 Fetch_getNewArts( const char *name, FetchMode mode )
3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	167 {
3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	168 if ( ! Lock_openDatabases() )
3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	169 {
3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	170 Log_err( "Could not open message base" );
180 09ca6eb5c7ff [svn] * TODO,src/client.c,src/client.h,src/fetch.c,src/fetch.h,src/noffle.c: bears parents: 155 diff changeset	171 return FALSE;
127 3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	172 }
249 0340b9c17edc [svn] * empty log message * mirkol parents: 223 diff changeset	173 Flt_init( fetch.serv ); /* Get filter data. Sorry, can't do it in Client_getOver().
0340b9c17edc [svn] * empty log message * mirkol parents: 223 diff changeset	174 * This is the lowest procedure not in the
0340b9c17edc [svn] * empty log message * mirkol parents: 223 diff changeset	175 * noffle.c:doFetch() tree. */
0340b9c17edc [svn] * empty log message * mirkol parents: 223 diff changeset	176
180 09ca6eb5c7ff [svn] * TODO,src/client.c,src/client.h,src/fetch.c,src/fetch.h,src/noffle.c: bears parents: 155 diff changeset	177 return fetchNewArts( name, mode );
43 2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	178 }
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	179
180 09ca6eb5c7ff [svn] * TODO,src/client.c,src/client.h,src/fetch.c,src/fetch.h,src/noffle.c: bears parents: 155 diff changeset	180 Bool
43 2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	181 Fetch_updateGrps( void )
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	182 {
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	183 FetchMode mode;
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	184 int i, size;
127 3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	185 const char *name;
43 2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	186
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	187 ASSERT( fetch.ready );
127 3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	188 if ( ! Lock_openDatabases() )
3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	189 {
3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	190 Log_err( "Could not open message base" );
180 09ca6eb5c7ff [svn] * TODO,src/client.c,src/client.h,src/fetch.c,src/fetch.h,src/noffle.c: bears parents: 155 diff changeset	191 return FALSE;
127 3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	192 }
43 2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	193 Fetchlist_read();
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	194 size = Fetchlist_size();
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	195 for ( i = 0; i < size; ++i )
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	196 {
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	197 Fetchlist_element( &name, &mode, i );
61 adf0af5152f7 [svn] Renamed some variables and function names, because they caused compiler enz parents: 54 diff changeset	198 if ( strcmp( Grp_server( name ), fetch.serv ) == 0 )
127 3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	199 {
188 f1bacee93ca6 [svn] * src/client.c,src/client.h,src/fetch.c,src/noffle.c,src/server.c: bears parents: 185 diff changeset	200 if ( IS_FATAL( fetchNewArts( name, mode ) ) )
180 09ca6eb5c7ff [svn] * TODO,src/client.c,src/client.h,src/fetch.c,src/fetch.h,src/noffle.c: bears parents: 155 diff changeset	201 return FALSE;
127 3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	202 if ( ! Lock_openDatabases() )
3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	203 {
3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	204 Log_err( "Could not open message base" );
180 09ca6eb5c7ff [svn] * TODO,src/client.c,src/client.h,src/fetch.c,src/fetch.h,src/noffle.c: bears parents: 155 diff changeset	205 return FALSE;
127 3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	206 }
3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	207 }
43 2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	208 }
127 3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	209 Lock_closeDatabases();
180 09ca6eb5c7ff [svn] * TODO,src/client.c,src/client.h,src/fetch.c,src/fetch.h,src/noffle.c: bears parents: 155 diff changeset	210 return TRUE;
127 3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	211 }
3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	212
188 f1bacee93ca6 [svn] * src/client.c,src/client.h,src/fetch.c,src/noffle.c,src/server.c: bears parents: 185 diff changeset	213 static int
127 3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	214 fetchMessageList( const char list, int artcnt, int artmax )
3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	215 {
3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	216 const char *p;
3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	217 Str msgId;
188 f1bacee93ca6 [svn] * src/client.c,src/client.h,src/fetch.c,src/noffle.c,src/server.c: bears parents: 185 diff changeset	218 int stat;
127 3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	219
3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	220 ASSERT( Lock_gotLock() );
188 f1bacee93ca6 [svn] * src/client.c,src/client.h,src/fetch.c,src/noffle.c,src/server.c: bears parents: 185 diff changeset	221 stat = Client_retrieveArtList( list, artcnt, artmax );
193 021d145e34e9 [svn] * src/fetch.c: Only leave articles in the requested list if the error bears parents: 188 diff changeset	222 if ( IS_FATAL( stat ) )
188 f1bacee93ca6 [svn] * src/client.c,src/client.h,src/fetch.c,src/noffle.c,src/server.c: bears parents: 185 diff changeset	223 return stat;
127 3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	224 p = list;
3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	225 while ( ( p = Utl_getLn( msgId, p ) ) )
3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	226 Req_remove( fetch.serv, msgId );
188 f1bacee93ca6 [svn] * src/client.c,src/client.h,src/fetch.c,src/noffle.c,src/server.c: bears parents: 185 diff changeset	227 return STAT_OK;
43 2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	228 }
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	229
180 09ca6eb5c7ff [svn] * TODO,src/client.c,src/client.h,src/fetch.c,src/fetch.h,src/noffle.c: bears parents: 155 diff changeset	230 Bool
43 2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	231 Fetch_getReq_( void )
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	232 {
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	233 Str msgId;
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	234 DynStr *list;
127 3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	235 DynStr *fetchList;
43 2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	236 const char *p;
120 05f50c1761d9 [svn] Applied patch from Matija Nalis: enz parents: 102 diff changeset	237 int count = 0, artcnt = 0, artmax = 0;
180 09ca6eb5c7ff [svn] * TODO,src/client.c,src/client.h,src/fetch.c,src/fetch.h,src/noffle.c: bears parents: 155 diff changeset	238 Bool res;
188 f1bacee93ca6 [svn] * src/client.c,src/client.h,src/fetch.c,src/noffle.c,src/server.c: bears parents: 185 diff changeset	239 int stat;
43 2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	240
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	241 ASSERT( fetch.ready );
185 fed1334d766b [svn] * src/client.c: Change variable only used on constant to 'const'. bears parents: 184 diff changeset	242 Log_dbg( LOG_DBG_FETCH, "Retrieving articles marked for download" );
43 2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	243 list = new_DynStr( 10000 );
127 3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	244 fetchList = new_DynStr( 1000 );
3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	245 if ( list == NULL \|\| fetchList == NULL )
3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	246 {
3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	247 if ( list != NULL )
3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	248 del_DynStr( list );
3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	249 Log_err( "Out of memory in Fetch_get_Req_");
180 09ca6eb5c7ff [svn] * TODO,src/client.c,src/client.h,src/fetch.c,src/fetch.h,src/noffle.c: bears parents: 155 diff changeset	250 return FALSE;
127 3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	251 }
3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	252
3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	253 /*
3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	254 * Get all waiting message IDs for this server. We copy into a master
3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	255 * list as the requests file will be closed and re-opened during the
3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	256 * fetch and the position therein will be lost.
3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	257 */
3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	258 if ( ! Lock_openDatabases() )
3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	259 {
3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	260 Log_err( "Could not open message base" );
180 09ca6eb5c7ff [svn] * TODO,src/client.c,src/client.h,src/fetch.c,src/fetch.h,src/noffle.c: bears parents: 155 diff changeset	261 return FALSE;
127 3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	262 }
3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	263
43 2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	264 if ( Req_first( fetch.serv, msgId ) )
127 3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	265 {
43 2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	266 do
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	267 {
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	268 DynStr_appLn( list, msgId );
127 3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	269 artmax++;
43 2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	270 }
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	271 while ( Req_next( msgId ) );
127 3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	272 Log_inf( "%d TOTAL messages to download", artmax);
3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	273 }
3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	274
3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	275 /* Retrieve in groups of up to size MAX_ARTICLE_CMDS_QUEUED. */
43 2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	276 p = DynStr_str( list );
180 09ca6eb5c7ff [svn] * TODO,src/client.c,src/client.h,src/fetch.c,src/fetch.h,src/noffle.c: bears parents: 155 diff changeset	277 res = TRUE;
09ca6eb5c7ff [svn] * TODO,src/client.c,src/client.h,src/fetch.c,src/fetch.h,src/noffle.c: bears parents: 155 diff changeset	278 while ( res && ( p = Utl_getLn( msgId, p ) ) != NULL )
127 3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	279 {
3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	280 DynStr_appLn( fetchList, msgId );
3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	281 if ( ++count % MAX_ARTICLE_CMDS_QUEUED == 0 )
3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	282 {
188 f1bacee93ca6 [svn] * src/client.c,src/client.h,src/fetch.c,src/noffle.c,src/server.c: bears parents: 185 diff changeset	283 stat = fetchMessageList( DynStr_str( fetchList ), &artcnt,
f1bacee93ca6 [svn] * src/client.c,src/client.h,src/fetch.c,src/noffle.c,src/server.c: bears parents: 185 diff changeset	284 artmax );
f1bacee93ca6 [svn] * src/client.c,src/client.h,src/fetch.c,src/noffle.c,src/server.c: bears parents: 185 diff changeset	285 res = ! IS_FATAL( stat );
127 3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	286 DynStr_clear( fetchList );
3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	287 }
3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	288 }
188 f1bacee93ca6 [svn] * src/client.c,src/client.h,src/fetch.c,src/noffle.c,src/server.c: bears parents: 185 diff changeset	289 stat = fetchMessageList( DynStr_str( fetchList ), &artcnt, artmax );
f1bacee93ca6 [svn] * src/client.c,src/client.h,src/fetch.c,src/noffle.c,src/server.c: bears parents: 185 diff changeset	290 res = res && ! IS_FATAL( stat );
127 3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	291
3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	292 del_DynStr( fetchList );
43 2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	293 del_DynStr( list );
127 3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	294 Lock_closeDatabases();
180 09ca6eb5c7ff [svn] * TODO,src/client.c,src/client.h,src/fetch.c,src/fetch.h,src/noffle.c: bears parents: 155 diff changeset	295 return res;
43 2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	296 }
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	297
79 28aeb0b93509 [svn] Extracted function in Fetch_postArts for returning failed postings to sender enz parents: 61 diff changeset	298 static void
28aeb0b93509 [svn] Extracted function in Fetch_postArts for returning failed postings to sender enz parents: 61 diff changeset	299 returnArticleToSender( const char sender, const char reason,
28aeb0b93509 [svn] Extracted function in Fetch_postArts for returning failed postings to sender enz parents: 61 diff changeset	300 const char *article )
28aeb0b93509 [svn] Extracted function in Fetch_postArts for returning failed postings to sender enz parents: 61 diff changeset	301 {
28aeb0b93509 [svn] Extracted function in Fetch_postArts for returning failed postings to sender enz parents: 61 diff changeset	302 int ret;
28aeb0b93509 [svn] Extracted function in Fetch_postArts for returning failed postings to sender enz parents: 61 diff changeset	303 Str cmd;
28aeb0b93509 [svn] Extracted function in Fetch_postArts for returning failed postings to sender enz parents: 61 diff changeset	304 FILE *f;
271 3477050e8d10 [svn] * src/client.c,src/fetch.c,src/lock.c.src/protocol.c,src/util.h,src/util.c: bears parents: 249 diff changeset	305 SignalHandler lastHandler;
79 28aeb0b93509 [svn] Extracted function in Fetch_postArts for returning failed postings to sender enz parents: 61 diff changeset	306
28aeb0b93509 [svn] Extracted function in Fetch_postArts for returning failed postings to sender enz parents: 61 diff changeset	307 Log_err( "Return article to '%s' by mail", sender );
154 b2a4f839affd [svn] Use sendmail instead of mail enz parents: 139 diff changeset	308 snprintf( cmd, MAXCHAR, "%s -t -oi", SENDMAILPROG);
79 28aeb0b93509 [svn] Extracted function in Fetch_postArts for returning failed postings to sender enz parents: 61 diff changeset	309 lastHandler = signal( SIGPIPE, SIG_IGN );
28aeb0b93509 [svn] Extracted function in Fetch_postArts for returning failed postings to sender enz parents: 61 diff changeset	310 f = popen( cmd, "w" );
28aeb0b93509 [svn] Extracted function in Fetch_postArts for returning failed postings to sender enz parents: 61 diff changeset	311 if ( f == NULL )
28aeb0b93509 [svn] Extracted function in Fetch_postArts for returning failed postings to sender enz parents: 61 diff changeset	312 Log_err( "Invocation of '%s' failed (%s)", cmd, strerror( errno ) );
28aeb0b93509 [svn] Extracted function in Fetch_postArts for returning failed postings to sender enz parents: 61 diff changeset	313 else
28aeb0b93509 [svn] Extracted function in Fetch_postArts for returning failed postings to sender enz parents: 61 diff changeset	314 {
28aeb0b93509 [svn] Extracted function in Fetch_postArts for returning failed postings to sender enz parents: 61 diff changeset	315 fprintf( f,
154 b2a4f839affd [svn] Use sendmail instead of mail enz parents: 139 diff changeset	316 "To: %s\n"
b2a4f839affd [svn] Use sendmail instead of mail enz parents: 139 diff changeset	317 "Subject: [ NOFFLE: Posting failed ]\n"
b2a4f839affd [svn] Use sendmail instead of mail enz parents: 139 diff changeset	318 "\n"
79 28aeb0b93509 [svn] Extracted function in Fetch_postArts for returning failed postings to sender enz parents: 61 diff changeset	319 "\t[ NOFFLE: POSTING OF ARTICLE FAILED ]\n"
28aeb0b93509 [svn] Extracted function in Fetch_postArts for returning failed postings to sender enz parents: 61 diff changeset	320 "\n"
28aeb0b93509 [svn] Extracted function in Fetch_postArts for returning failed postings to sender enz parents: 61 diff changeset	321 "\t[ The posting of your article failed. ]\n"
28aeb0b93509 [svn] Extracted function in Fetch_postArts for returning failed postings to sender enz parents: 61 diff changeset	322 "\t[ Reason of failure at remote server: ]\n"
28aeb0b93509 [svn] Extracted function in Fetch_postArts for returning failed postings to sender enz parents: 61 diff changeset	323 "\n"
28aeb0b93509 [svn] Extracted function in Fetch_postArts for returning failed postings to sender enz parents: 61 diff changeset	324 "\t[ %s ]\n"
28aeb0b93509 [svn] Extracted function in Fetch_postArts for returning failed postings to sender enz parents: 61 diff changeset	325 "\n"
28aeb0b93509 [svn] Extracted function in Fetch_postArts for returning failed postings to sender enz parents: 61 diff changeset	326 "\t[ Full article text has been appended. ]\n"
28aeb0b93509 [svn] Extracted function in Fetch_postArts for returning failed postings to sender enz parents: 61 diff changeset	327 "\n"
28aeb0b93509 [svn] Extracted function in Fetch_postArts for returning failed postings to sender enz parents: 61 diff changeset	328 "%s"
28aeb0b93509 [svn] Extracted function in Fetch_postArts for returning failed postings to sender enz parents: 61 diff changeset	329 ".\n",
154 b2a4f839affd [svn] Use sendmail instead of mail enz parents: 139 diff changeset	330 sender,
79 28aeb0b93509 [svn] Extracted function in Fetch_postArts for returning failed postings to sender enz parents: 61 diff changeset	331 reason, article );
28aeb0b93509 [svn] Extracted function in Fetch_postArts for returning failed postings to sender enz parents: 61 diff changeset	332 ret = pclose( f );
28aeb0b93509 [svn] Extracted function in Fetch_postArts for returning failed postings to sender enz parents: 61 diff changeset	333 if ( ret != EXIT_SUCCESS )
28aeb0b93509 [svn] Extracted function in Fetch_postArts for returning failed postings to sender enz parents: 61 diff changeset	334 Log_err( "'%s' exit value %d", cmd, ret );
28aeb0b93509 [svn] Extracted function in Fetch_postArts for returning failed postings to sender enz parents: 61 diff changeset	335 signal( SIGPIPE, lastHandler );
28aeb0b93509 [svn] Extracted function in Fetch_postArts for returning failed postings to sender enz parents: 61 diff changeset	336 }
28aeb0b93509 [svn] Extracted function in Fetch_postArts for returning failed postings to sender enz parents: 61 diff changeset	337 }
28aeb0b93509 [svn] Extracted function in Fetch_postArts for returning failed postings to sender enz parents: 61 diff changeset	338
180 09ca6eb5c7ff [svn] * TODO,src/client.c,src/client.h,src/fetch.c,src/fetch.h,src/noffle.c: bears parents: 155 diff changeset	339 Bool
43 2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	340 Fetch_postArts( void )
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	341 {
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	342 DynStr *s;
79 28aeb0b93509 [svn] Extracted function in Fetch_postArts for returning failed postings to sender enz parents: 61 diff changeset	343 Str msgId, errStr, sender;
43 2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	344 const char *txt;
180 09ca6eb5c7ff [svn] * TODO,src/client.c,src/client.h,src/fetch.c,src/fetch.h,src/noffle.c: bears parents: 155 diff changeset	345 Bool res;
43 2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	346
180 09ca6eb5c7ff [svn] * TODO,src/client.c,src/client.h,src/fetch.c,src/fetch.h,src/noffle.c: bears parents: 155 diff changeset	347 res = TRUE;
43 2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	348 s = new_DynStr( 10000 );
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	349 if ( Out_first( fetch.serv, msgId, s ) )
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	350 {
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	351 Log_inf( "Posting articles" );
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	352 do
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	353 {
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	354 txt = DynStr_str( s );
188 f1bacee93ca6 [svn] * src/client.c,src/client.h,src/fetch.c,src/noffle.c,src/server.c: bears parents: 185 diff changeset	355 if ( Client_postArt( msgId, txt, errStr ) != STAT_OK )
180 09ca6eb5c7ff [svn] * TODO,src/client.c,src/client.h,src/fetch.c,src/fetch.h,src/noffle.c: bears parents: 155 diff changeset	356 {
09ca6eb5c7ff [svn] * TODO,src/client.c,src/client.h,src/fetch.c,src/fetch.h,src/noffle.c: bears parents: 155 diff changeset	357 res = FALSE;
09ca6eb5c7ff [svn] * TODO,src/client.c,src/client.h,src/fetch.c,src/fetch.h,src/noffle.c: bears parents: 155 diff changeset	358 break;
09ca6eb5c7ff [svn] * TODO,src/client.c,src/client.h,src/fetch.c,src/fetch.h,src/noffle.c: bears parents: 155 diff changeset	359 }
09ca6eb5c7ff [svn] * TODO,src/client.c,src/client.h,src/fetch.c,src/fetch.h,src/noffle.c: bears parents: 155 diff changeset	360
09ca6eb5c7ff [svn] * TODO,src/client.c,src/client.h,src/fetch.c,src/fetch.h,src/noffle.c: bears parents: 155 diff changeset	361 /*
09ca6eb5c7ff [svn] * TODO,src/client.c,src/client.h,src/fetch.c,src/fetch.h,src/noffle.c: bears parents: 155 diff changeset	362 * OK, no server communication SNAFU during post. Now, do we
09ca6eb5c7ff [svn] * TODO,src/client.c,src/client.h,src/fetch.c,src/fetch.h,src/noffle.c: bears parents: 155 diff changeset	363 * get an error response? If so, try to return article to sender.
09ca6eb5c7ff [svn] * TODO,src/client.c,src/client.h,src/fetch.c,src/fetch.h,src/noffle.c: bears parents: 155 diff changeset	364 */
09ca6eb5c7ff [svn] * TODO,src/client.c,src/client.h,src/fetch.c,src/fetch.h,src/noffle.c: bears parents: 155 diff changeset	365 Out_remove( fetch.serv, msgId );
09ca6eb5c7ff [svn] * TODO,src/client.c,src/client.h,src/fetch.c,src/fetch.h,src/noffle.c: bears parents: 155 diff changeset	366 if ( errStr[0] != '\0' )
09ca6eb5c7ff [svn] * TODO,src/client.c,src/client.h,src/fetch.c,src/fetch.h,src/noffle.c: bears parents: 155 diff changeset	367 {
09ca6eb5c7ff [svn] * TODO,src/client.c,src/client.h,src/fetch.c,src/fetch.h,src/noffle.c: bears parents: 155 diff changeset	368 Utl_cpyStr( sender, Cfg_mailTo() );
09ca6eb5c7ff [svn] * TODO,src/client.c,src/client.h,src/fetch.c,src/fetch.h,src/noffle.c: bears parents: 155 diff changeset	369 if ( strcmp( sender, "" ) == 0
283 39d9c19ffba4 [svn] * src/fetch.c: Add Reply-To to the front of the list of headers searched bears parents: 274 diff changeset	370 && ! Prt_searchHeader( txt, "REPLY-TO", sender )
180 09ca6eb5c7ff [svn] * TODO,src/client.c,src/client.h,src/fetch.c,src/fetch.h,src/noffle.c: bears parents: 155 diff changeset	371 && ! Prt_searchHeader( txt, "SENDER", sender )
09ca6eb5c7ff [svn] * TODO,src/client.c,src/client.h,src/fetch.c,src/fetch.h,src/noffle.c: bears parents: 155 diff changeset	372 && ! Prt_searchHeader( txt, "X-NOFFLE-X-SENDER",
09ca6eb5c7ff [svn] * TODO,src/client.c,src/client.h,src/fetch.c,src/fetch.h,src/noffle.c: bears parents: 155 diff changeset	373 sender ) /* see server.c */
09ca6eb5c7ff [svn] * TODO,src/client.c,src/client.h,src/fetch.c,src/fetch.h,src/noffle.c: bears parents: 155 diff changeset	374 && ! Prt_searchHeader( txt, "FROM", sender ) )
09ca6eb5c7ff [svn] * TODO,src/client.c,src/client.h,src/fetch.c,src/fetch.h,src/noffle.c: bears parents: 155 diff changeset	375 Log_err( "Article %s has no From/Sender/X-Sender field",
09ca6eb5c7ff [svn] * TODO,src/client.c,src/client.h,src/fetch.c,src/fetch.h,src/noffle.c: bears parents: 155 diff changeset	376 msgId );
09ca6eb5c7ff [svn] * TODO,src/client.c,src/client.h,src/fetch.c,src/fetch.h,src/noffle.c: bears parents: 155 diff changeset	377 else
09ca6eb5c7ff [svn] * TODO,src/client.c,src/client.h,src/fetch.c,src/fetch.h,src/noffle.c: bears parents: 155 diff changeset	378 returnArticleToSender( sender, errStr, txt );
09ca6eb5c7ff [svn] * TODO,src/client.c,src/client.h,src/fetch.c,src/fetch.h,src/noffle.c: bears parents: 155 diff changeset	379 }
43 2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	380 }
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	381 while ( Out_next( msgId, s ) );
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	382 }
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	383 del_DynStr( s );
180 09ca6eb5c7ff [svn] * TODO,src/client.c,src/client.h,src/fetch.c,src/fetch.h,src/noffle.c: bears parents: 155 diff changeset	384 return res;
43 2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	385 }
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	386
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	387 Bool
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	388 Fetch_init( const char *serv )
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	389 {
127 3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	390 Lock_closeDatabases();
43 2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	391 if ( ! connectToServ( serv ) )
139 8e350d558c98 [svn] Fixed a bug in Fetch_init, that triggered enz parents: 129 diff changeset	392 {
8e350d558c98 [svn] Fixed a bug in Fetch_init, that triggered enz parents: 129 diff changeset	393 Lock_openDatabases();
43 2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	394 return FALSE;
139 8e350d558c98 [svn] Fixed a bug in Fetch_init, that triggered enz parents: 129 diff changeset	395 }
43 2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	396 Utl_cpyStr( fetch.serv, serv );
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	397 fetch.ready = TRUE;
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	398 return TRUE;
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	399 }
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	400
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	401 void
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	402 Fetch_close()
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	403 {
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	404 Client_disconnect();
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	405 fetch.ready = FALSE;
2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	406 Log_inf( "Fetch from '%s' finished", fetch.serv );
127 3c71e28c8eef [svn] Release-1-0 mergedocs/NOTES bears parents: 120 diff changeset	407 Lock_openDatabases();
43 2842f50feb55 [svn] * client.c, client.h, common.h, config.c, config.h, content.c, content.h, uh1763 parents: diff changeset	408 }

Mercurial > noffle

annotate src/fetch.c @ 288:c02c4eb95f95 noffle