[Top][All Lists]
[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[GNUnet-SVN] r5256 - in GNUnet: . src/applications/advertising src/appli
|
From: |
gnunet |
|
Subject: |
[GNUnet-SVN] r5256 - in GNUnet: . src/applications/advertising src/applications/chat src/applications/datastore src/applications/dht/module src/applications/dht/tools src/applications/dstore src/applications/fs/collection src/applications/fs/ecrs src/applications/fs/fsui src/applications/fs/module src/applications/fs/namespace src/applications/fs/tools src/applications/fs/uritrack src/applications/gap src/applications/identity src/applications/kvstore_sqlite src/applications/pingpong src/applications/rpc src/applications/session src/applications/sqstore_mysql src/applications/sqstore_mysql_embedded src/applications/sqstore_sqlite src/applications/stats src/applications/testbed src/applications/testing src/applications/topology_default src/applications/topology_f2f src/applications/tracekit src/applications/transport src/applications/vpn src/include src/server src/setup src/setup/gtk src/setup/lib src/setup/ncurses src/setup/text src/transports src/transports/upnp src/util/config_impl src/util/containers src/util/crypto src/util/disk src/util/getopt src/util/loggers src/util/network src/util/os src/util/string src/util/threads src/util/win |
|
Date: |
Fri, 6 Jul 2007 23:05:12 -0600 (MDT) |
Author: grothoff
Date: 2007-07-06 23:05:09 -0600 (Fri, 06 Jul 2007)
New Revision: 5256
Modified:
GNUnet/ChangeLog
GNUnet/README
GNUnet/src/applications/advertising/advertising.c
GNUnet/src/applications/advertising/bootstrap.c
GNUnet/src/applications/chat/gnunet-chat.c
GNUnet/src/applications/datastore/datastore.c
GNUnet/src/applications/datastore/prefetch.c
GNUnet/src/applications/dht/module/table.c
GNUnet/src/applications/dht/tools/dht-query.c
GNUnet/src/applications/dht/tools/dht_api.c
GNUnet/src/applications/dstore/dstore.c
GNUnet/src/applications/fs/collection/collection.c
GNUnet/src/applications/fs/collection/collectiontest.c
GNUnet/src/applications/fs/ecrs/download.c
GNUnet/src/applications/fs/ecrs/namespace.c
GNUnet/src/applications/fs/ecrs/search.c
GNUnet/src/applications/fs/ecrs/uri.c
GNUnet/src/applications/fs/fsui/deserialize.c
GNUnet/src/applications/fs/fsui/download.c
GNUnet/src/applications/fs/fsui/fsui.c
GNUnet/src/applications/fs/fsui/serialize.c
GNUnet/src/applications/fs/module/dht_push.c
GNUnet/src/applications/fs/module/fs.c
GNUnet/src/applications/fs/module/migration.c
GNUnet/src/applications/fs/module/querymanager.c
GNUnet/src/applications/fs/namespace/namespace_info.c
GNUnet/src/applications/fs/tools/gnunet-download.c
GNUnet/src/applications/fs/tools/gnunet-insert.c
GNUnet/src/applications/fs/uritrack/uri_info.c
GNUnet/src/applications/gap/gap.c
GNUnet/src/applications/gap/gaptest.c
GNUnet/src/applications/identity/identity.c
GNUnet/src/applications/kvstore_sqlite/kv_sqlite.c
GNUnet/src/applications/pingpong/pingpong.c
GNUnet/src/applications/rpc/rpc.c
GNUnet/src/applications/session/connect.c
GNUnet/src/applications/session/sessiontest2.c
GNUnet/src/applications/session/sessiontest_http.c
GNUnet/src/applications/sqstore_mysql/mysql.c
GNUnet/src/applications/sqstore_mysql/mysqltest2.c
GNUnet/src/applications/sqstore_mysql_embedded/mysql.c
GNUnet/src/applications/sqstore_mysql_embedded/mysqltest2.c
GNUnet/src/applications/sqstore_sqlite/sqlite.c
GNUnet/src/applications/stats/clientapi.c
GNUnet/src/applications/testbed/gnunet-testbed.c
GNUnet/src/applications/testbed/testbed.c
GNUnet/src/applications/testing/testing.c
GNUnet/src/applications/topology_default/topology.c
GNUnet/src/applications/topology_f2f/topology.c
GNUnet/src/applications/tracekit/tracekit.c
GNUnet/src/applications/transport/transport.c
GNUnet/src/applications/vpn/vpn.c
GNUnet/src/include/gnunet_transport_service.h
GNUnet/src/include/gnunet_util_error.h
GNUnet/src/include/gnunet_util_network.h
GNUnet/src/include/gnunet_util_threads.h
GNUnet/src/server/connection.c
GNUnet/src/server/gnunet-peer-info.c
GNUnet/src/server/gnunet-transport-check.c
GNUnet/src/server/gnunet-update.c
GNUnet/src/server/handler.c
GNUnet/src/server/startup.c
GNUnet/src/setup/gnunet-win-tool.c
GNUnet/src/setup/gtk/gconf.c
GNUnet/src/setup/gtk/wizard_gtk.c
GNUnet/src/setup/lib/tree.c
GNUnet/src/setup/ncurses/mconf.c
GNUnet/src/setup/ncurses/wizard_curs.c
GNUnet/src/setup/text/conf.c
GNUnet/src/transports/http.c
GNUnet/src/transports/ip.c
GNUnet/src/transports/ip.h
GNUnet/src/transports/nat.c
GNUnet/src/transports/tcp.c
GNUnet/src/transports/tcp6.c
GNUnet/src/transports/tcp_helper.c
GNUnet/src/transports/udp.c
GNUnet/src/transports/udp6.c
GNUnet/src/transports/upnp/upnp.c
GNUnet/src/transports/upnp/xmlnode.c
GNUnet/src/util/config_impl/impl.c
GNUnet/src/util/containers/bloomfilter.c
GNUnet/src/util/crypto/kblockkey.c
GNUnet/src/util/crypto/weakkeytest.c
GNUnet/src/util/disk/storage.c
GNUnet/src/util/getopt/printhelp.c
GNUnet/src/util/loggers/file.c
GNUnet/src/util/network/dns.c
GNUnet/src/util/network/io.c
GNUnet/src/util/network/select.c
GNUnet/src/util/os/installpath.c
GNUnet/src/util/string/string.c
GNUnet/src/util/threads/mutex.c
GNUnet/src/util/threads/semaphore.c
GNUnet/src/util/win/winproc.c
Log:
removing trailing whitespace
Modified: GNUnet/ChangeLog
===================================================================
--- GNUnet/ChangeLog 2007-07-07 05:03:27 UTC (rev 5255)
+++ GNUnet/ChangeLog 2007-07-07 05:05:09 UTC (rev 5256)
@@ -6,7 +6,7 @@
Fixed issue with too many TCP connections being
created. Reduced CPU overheads by increasing
requirements for grouping of messages. Improved
- various error messages.
+ various error messages.
Sat Jun 30 01:55:34 MDT 2007
Improved bloomfilter recomputation after quota change.
@@ -48,14 +48,14 @@
Tue May 29 23:15:27 MDT 2007
Fixed a major bug which resulted in peers without
traffic between them disconnecting (even if that
- session was their only connection).
+ session was their only connection).
Fixed another major bug where nodes would not
properly forward HELLOs from other peers (given
certain common/default configuration options).
Sun May 27 22:39:48 MDT 2007
Added new API gnunet_testing_lib.h to make it
- easier to write testcases that need to start
+ easier to write testcases that need to start
gnunetd. API is now used everywhere and the
ugly peer.conf files and directories are gone.
Fixed a bug with inserting empty directories.
@@ -63,9 +63,9 @@
Sat May 26 18:24:15 MDT 2007
Fixed bugs with testcases (changes in names and
- structure of options were not reflected in .conf
+ structure of options were not reflected in .conf
files for various testcases).
- Fixed issues with command-line option handling (failed to
+ Fixed issues with command-line option handling (failed to
override configuration file options).
Fixed bogus nesting in GAP routing algorithm (caused
random request drops).
@@ -85,7 +85,7 @@
Enabled abortion of gnunet-peer-info with CTRL-C.
Mon Feb 26 19:19:29 MST 2007
- Fixed handling of -d option by gnunet-download
+ Fixed handling of -d option by gnunet-download
if -f option is not given.
Sat Feb 24 15:43:14 MST 2007
@@ -113,7 +113,7 @@
Sat Jan 27 16:02:02 MST 2007
Changing $-expansion for interpretation of configuration file
(again). Also, now the base-path for gnunetd defaults to
- "/var/lib/gnunet" instead of "/var/lib/GNUnet".
+ "/var/lib/gnunet" instead of "/var/lib/GNUnet".
Tue Jan 23 19:48:37 MST 2007
Fixed problem with split-extractor keywords not being used
@@ -131,7 +131,7 @@
Mon Jan 8 21:34:02 MST 2007
Forcing -O3 for crypto library (performance critical).
- Enforcing message queue limit for daemon (somehow got lost
+ Enforcing message queue limit for daemon (somehow got lost
on the way to 0.7.1, was responsible for high CPU load).
Fixing cron job deletion in core (clean shutdown).
@@ -211,7 +211,7 @@
FSUI test suite.
Mon Nov 27 08:51:46 MST 2006
- Added conversion of ECRS error messages to FSUI
+ Added conversion of ECRS error messages to FSUI
error event messages.
Sun Nov 19 00:20:14 MST 2006
@@ -230,7 +230,7 @@
Fixed some problems with index creation in sqlite
datastore (discovered with new sqlite benchmarking
code). Performance should improve significantly
- (observed was a factor of 4-10 depending on
+ (observed was a factor of 4-10 depending on
database size and operation).
Thu Oct 19 23:44:24 MDT 2006
@@ -262,7 +262,7 @@
Major gnunet-setup GTK code cleanup (now uses libglade).
Sat May 13 19:35:49 PDT 2006
- Made headers more C++ friendly.
+ Made headers more C++ friendly.
Wed May 10 22:11:17 PDT 2006
Fixing bug that could result in hanging the UDP transport;
@@ -273,7 +273,7 @@
Fri May 5 01:33:42 PDT 2006
Fixed bug with priorities of IBlocks of uploaded content
- (priority was left at zero, making those blocks be
+ (priority was left at zero, making those blocks be
possibly discarded rather quickly once the datastore filled
up).
@@ -286,7 +286,7 @@
fixing Mantis #1058.
Sat Apr 22 13:50:39 PDT 2006
- Fixed bug in util/cron.c where stopCron() would wait for an
+ Fixed bug in util/cron.c where stopCron() would wait for an
unnecessary sleep to complete.
Sat Mar 18 12:54:11 PST 2006
@@ -380,9 +380,9 @@
Alpha-rename fest. Releasing 0.7.0pre5.
Sun Jul 17 13:49:40 CEST 2005
- Fixed problems with struct alignment on 64-bit
+ Fixed problems with struct alignment on 64-bit
AMDs. Fixed recently introduced memory leak.
- Fixed various compiler warnings.
+ Fixed various compiler warnings.
Sat Jul 16 23:55:31 CEST 2005
Fixed various minor problems with platforms
@@ -394,7 +394,7 @@
Fixed tiny memory leak in http_bootstrap.
Mon Jul 11 02:22:24 CEST 2005
- Fixed long-standing problems in statuscalls wrt
+ Fixed long-standing problems in statuscalls wrt
network load estimates, leading to too-high bandwidth
consumption on average. Fixed minor memory leaks.
Fixed far too often session-key exchange (was done
@@ -419,7 +419,7 @@
Fri Jul 1 15:08:42 CEST 2005
Added statistics for transports and other connection-
related functions. Prevented core from dropping
- messages just because transport is (temporarily)
+ messages just because transport is (temporarily)
blocked. Made transport selection in identity random
again where necessary.
@@ -453,9 +453,9 @@
passed around, wrong list of filenames updated).
Sat Apr 2 01:54:23 EST 2005
- Various bugfixes, some of them critical (segfaults,
- protocol errors (resulting in failures to connect),
- old version of configuration file would be
+ Various bugfixes, some of them critical (segfaults,
+ protocol errors (resulting in failures to connect),
+ old version of configuration file would be
generated if configuration was missing,
gnunet-insert would not properly work with multiple
keywords (-k and -K options)). Releasing 0.7.0pre2.
Modified: GNUnet/README
===================================================================
--- GNUnet/README 2007-07-07 05:03:27 UTC (rev 5255)
+++ GNUnet/README 2007-07-07 05:05:09 UTC (rev 5256)
@@ -61,7 +61,7 @@
$ make
# make install
# gnunet-setup -d
-# gnunetd
+# gnunetd
This will compile and install GNUnet to ~/bin/, ~/lib/ and ~/man/.
gnunet-setup will create the daemon configuration (-d); this step is
@@ -119,7 +119,7 @@
options can be changed at runtime this way (e.g. to change any port
number, you must fully restart gnunetd).
-After changing certain options (or updating GNUnet) you must re-run
+After changing certain options (or updating GNUnet) you must re-run
gnunet-update.
@@ -181,7 +181,7 @@
where GNUnet is installed (usually, GNUnet will use OS specific
tricks in order to try to figure out the PREFIX, but since the
testcase binaries are not installed, that trick does not work
-for them). Also, before running any testcases, you must
+for them). Also, before running any testcases, you must
complete the installation first. Quick summary:
$ ./configure --prefix=$SOMEWHERE
Modified: GNUnet/src/applications/advertising/advertising.c
===================================================================
--- GNUnet/src/applications/advertising/advertising.c 2007-07-07 05:03:27 UTC
(rev 5255)
+++ GNUnet/src/applications/advertising/advertising.c 2007-07-07 05:05:09 UTC
(rev 5256)
@@ -157,7 +157,7 @@
int res;
cron_t now;
EncName enc;
-
+
/* first verify that it is actually a valid hello */
msg = (const P2P_hello_MESSAGE* ) message;
if ( (ntohs(msg->header.size) < sizeof(P2P_hello_MESSAGE)) ||
@@ -202,7 +202,7 @@
IF_GELOG(ectx,
GE_INFO | GE_BULK | GE_USER,
hash2enc(&msg->senderIdentity.hashPubKey,
- &enc));
+ &enc));
GE_LOG(ectx,
GE_DEBUG | GE_BULK | GE_USER,
"Transport verification of HELLO message from `%s' failed (%u).\n",
@@ -556,7 +556,7 @@
identity->addHost(sd.m);
if (sd.n < 1) {
if (identity->forEachHost(0, NULL, NULL) == 0)
- GE_LOG(ectx,
+ GE_LOG(ectx,
GE_WARNING | GE_BULK | GE_USER,
_("Announcing ourselves pointless: "
"no other peers are known to us so far.\n"));
@@ -584,7 +584,7 @@
return; /* CPU load too high... */
i = transport->forEach(NULL,
NULL);
- if (i > 0)
+ if (i > 0)
transport->forEach(&broadcasthelloTransport,
&i);
}
@@ -651,7 +651,7 @@
GE_INFO | GE_REQUEST | GE_USER,
hash2enc(&peer->hashPubKey,
&enc));
- GE_LOG(ectx,
+ GE_LOG(ectx,
GE_INFO | GE_REQUEST | GE_USER,
"Removing HELLO from peer `%s' (expired %ds ago).\n",
&enc,
Modified: GNUnet/src/applications/advertising/bootstrap.c
===================================================================
--- GNUnet/src/applications/advertising/bootstrap.c 2007-07-07 05:03:27 UTC
(rev 5255)
+++ GNUnet/src/applications/advertising/bootstrap.c 2007-07-07 05:05:09 UTC
(rev 5256)
@@ -180,7 +180,7 @@
return YES;
}
/* wait a bit longer */
- return NO;
+ return NO;
}
static void * processThread(void * unused) {
Modified: GNUnet/src/applications/chat/gnunet-chat.c
===================================================================
--- GNUnet/src/applications/chat/gnunet-chat.c 2007-07-07 05:03:27 UTC (rev
5255)
+++ GNUnet/src/applications/chat/gnunet-chat.c 2007-07-07 05:05:09 UTC (rev
5256)
@@ -107,7 +107,7 @@
char timebuf[64];
time_t timetmp;
struct tm * tmptr;
-
+
time(&timetmp);
tmptr = localtime(&timetmp);
strftime(timebuf,
Modified: GNUnet/src/applications/datastore/datastore.c
===================================================================
--- GNUnet/src/applications/datastore/datastore.c 2007-07-07 05:03:27 UTC
(rev 5255)
+++ GNUnet/src/applications/datastore/datastore.c 2007-07-07 05:05:09 UTC
(rev 5256)
@@ -388,7 +388,7 @@
if (stats != NULL) {
stat_filtered = stats->create(gettext_noop("# requests filtered by bloom
filter"));
stat_filter_failed = stats->create(gettext_noop("# bloom filter false
positives"));
-
+
stats->set(stats->create(gettext_noop("# bytes allowed in datastore")),
quota);
}
@@ -506,7 +506,7 @@
(sizeof(unsigned long long) != state->read(uapi->ectx,
"FS-LAST-QUOTA",
(void**)&lq)) &&
- (ntohll(*lq) == quota) ) {
+ (ntohll(*lq) == quota) ) {
uapi->releaseService(state);
FREE(lq);
return; /* no change */
Modified: GNUnet/src/applications/datastore/prefetch.c
===================================================================
--- GNUnet/src/applications/datastore/prefetch.c 2007-07-07 05:03:27 UTC
(rev 5255)
+++ GNUnet/src/applications/datastore/prefetch.c 2007-07-07 05:05:09 UTC
(rev 5256)
@@ -142,20 +142,20 @@
gather_thread = PTHREAD_CREATE(&rcbAcquire,
NULL,
64*1024);
- if (gather_thread == NULL)
+ if (gather_thread == NULL)
GE_LOG_STRERROR(ectx,
GE_ERROR | GE_ADMIN | GE_USER | GE_IMMEDIATE,
- "pthread_create");
+ "pthread_create");
}
void donePrefetch() {
void * unused;
doneSignal = YES;
- if (gather_thread != NULL)
+ if (gather_thread != NULL)
PTHREAD_STOP_SLEEP(gather_thread);
SEMAPHORE_UP(acquireMoreSignal);
- if (gather_thread != NULL)
+ if (gather_thread != NULL)
PTHREAD_JOIN(gather_thread, &unused);
SEMAPHORE_DESTROY(acquireMoreSignal);
FREENONNULL(rvalue);
Modified: GNUnet/src/applications/dht/module/table.c
===================================================================
--- GNUnet/src/applications/dht/module/table.c 2007-07-07 05:03:27 UTC (rev
5255)
+++ GNUnet/src/applications/dht/module/table.c 2007-07-07 05:05:09 UTC (rev
5256)
@@ -562,7 +562,7 @@
P2P_hello_MESSAGE * hello;
bucket = findBucketFor(peer);
- if (bucket == NULL)
+ if (bucket == NULL)
return; /* peers[i] == self */
if (bucket->peers_size >= MAINTAIN_BUCKET_SIZE)
checkExpiration(bucket);
Modified: GNUnet/src/applications/dht/tools/dht-query.c
===================================================================
--- GNUnet/src/applications/dht/tools/dht-query.c 2007-07-07 05:03:27 UTC
(rev 5255)
+++ GNUnet/src/applications/dht/tools/dht-query.c 2007-07-07 05:05:09 UTC
(rev 5256)
@@ -144,7 +144,7 @@
"put",
key,
value);
- }
+ }
FREE(dc);
}
Modified: GNUnet/src/applications/dht/tools/dht_api.c
===================================================================
--- GNUnet/src/applications/dht/tools/dht_api.c 2007-07-07 05:03:27 UTC (rev
5255)
+++ GNUnet/src/applications/dht/tools/dht_api.c 2007-07-07 05:05:09 UTC (rev
5256)
@@ -191,7 +191,7 @@
connection_destroy(sock);
return info.total;
}
-
+
/**
* Perform a synchronous put operation. The peer does not have
* to be part of the table!
Modified: GNUnet/src/applications/dstore/dstore.c
===================================================================
--- GNUnet/src/applications/dstore/dstore.c 2007-07-07 05:03:27 UTC (rev
5255)
+++ GNUnet/src/applications/dstore/dstore.c 2007-07-07 05:05:09 UTC (rev
5256)
@@ -255,7 +255,7 @@
payload,
quota);
#endif
- sqlite3_reset(dstmt);
+ sqlite3_reset(dstmt);
}
if (err != SQLITE_DONE) {
GE_LOG(coreAPI->ectx,
Modified: GNUnet/src/applications/fs/collection/collection.c
===================================================================
--- GNUnet/src/applications/fs/collection/collection.c 2007-07-07 05:03:27 UTC
(rev 5255)
+++ GNUnet/src/applications/fs/collection/collection.c 2007-07-07 05:05:09 UTC
(rev 5256)
@@ -418,8 +418,8 @@
ectx = NULL;
cfg = NULL;
}
-
+
/**
* Start collection.
*
Modified: GNUnet/src/applications/fs/collection/collectiontest.c
===================================================================
--- GNUnet/src/applications/fs/collection/collectiontest.c 2007-07-07
05:03:27 UTC (rev 5255)
+++ GNUnet/src/applications/fs/collection/collectiontest.c 2007-07-07
05:05:09 UTC (rev 5256)
@@ -105,7 +105,7 @@
cfg,
"test-collection");
CHECK(NULL == CO_getCollection());
-
+
/* END OF TEST CODE */
FAILURE:
if (sock != NULL) {
Modified: GNUnet/src/applications/fs/ecrs/download.c
===================================================================
--- GNUnet/src/applications/fs/ecrs/download.c 2007-07-07 05:03:27 UTC (rev
5255)
+++ GNUnet/src/applications/fs/ecrs/download.c 2007-07-07 05:05:09 UTC (rev
5256)
@@ -1288,7 +1288,7 @@
issueRequest(rm, j);
delta = (rm->requestList[j]->lastTimeout - now) + TTL_DECREMENT;
pending++;
- } else {
+ } else {
delta = 0;
}
} else {
Modified: GNUnet/src/applications/fs/ecrs/namespace.c
===================================================================
--- GNUnet/src/applications/fs/ecrs/namespace.c 2007-07-07 05:03:27 UTC (rev
5255)
+++ GNUnet/src/applications/fs/ecrs/namespace.c 2007-07-07 05:05:09 UTC (rev
5256)
@@ -275,7 +275,7 @@
&knb->nblock,
size - sizeof(KBlock) - sizeof(unsigned int));
- GE_ASSERT(ectx,
+ GE_ASSERT(ectx,
OK == sign(pk,
sizeof(NBlock) + mdsize,
&knb->nblock,
@@ -448,7 +448,7 @@
dstURI = ECRS_uriToString(dstU);
mdsize = ECRS_sizeofMetaData(md,
ECRS_SERIALIZE_PART);
- size = mdsize + sizeof(SBlock) + strlen(dstURI) + 1;
+ size = mdsize + sizeof(SBlock) + strlen(dstURI) + 1;
if (size > MAX_SBLOCK_SIZE) {
size = MAX_SBLOCK_SIZE;
value = MALLOC(sizeof(Datastore_Value) +
Modified: GNUnet/src/applications/fs/ecrs/search.c
===================================================================
--- GNUnet/src/applications/fs/ecrs/search.c 2007-07-07 05:03:27 UTC (rev
5255)
+++ GNUnet/src/applications/fs/ecrs/search.c 2007-07-07 05:05:09 UTC (rev
5256)
@@ -212,7 +212,7 @@
&hc,
sqc);
freePrivateKey(pk);
- }
+ }
#if DEBUG_SEARCH
GE_LOG(ectx,
GE_DEBUG | GE_REQUEST | GE_USER,
@@ -369,7 +369,7 @@
EncName enc;
#endif
int j;
-
+
if (size < sizeof(KBlock))
return SYSERR;
kb = MALLOC(size);
@@ -429,7 +429,7 @@
}
case N_BLOCK: {
const NBlock * nb;
-
+
if (size < sizeof(NBlock))
return SYSERR;
nb = (const NBlock*) &value[1];
@@ -441,7 +441,7 @@
case KN_BLOCK: {
KNBlock * kb;
int ret;
-
+
if (size < sizeof(KNBlock))
return SYSERR;
kb = MALLOC(size);
@@ -463,7 +463,7 @@
TIME_T now;
HashCode512 updateId;
URI updateURI;
-
+
if (size < sizeof(SBlock))
return SYSERR;
sb = MALLOC(size);
Modified: GNUnet/src/applications/fs/ecrs/uri.c
===================================================================
--- GNUnet/src/applications/fs/ecrs/uri.c 2007-07-07 05:03:27 UTC (rev
5255)
+++ GNUnet/src/applications/fs/ecrs/uri.c 2007-07-07 05:05:09 UTC (rev
5256)
@@ -322,7 +322,7 @@
return SYSERR;
pos += strlen(ECRS_SUBSPACE_INFIX);
if ( (slen < pos+sizeof(EncName)+1) ||
- (! ( (uri[pos+sizeof(EncName)-1] == '/') ||
+ (! ( (uri[pos+sizeof(EncName)-1] == '/') ||
(uri[pos+sizeof(EncName)-1] == '\\') ) ) )
return SYSERR;
@@ -877,7 +877,7 @@
&uri2->data.sks.namespace) &&
equalsHashCode512(&uri1->data.sks.identifier,
&uri2->data.sks.identifier) )
-
+
return YES;
return NO;
case ksk:
@@ -906,7 +906,7 @@
sizeof(unsigned short) +
sizeof(unsigned short)) != 0)
return NO;
- return YES;
+ return YES;
default:
return NO;
}
Modified: GNUnet/src/applications/fs/fsui/deserialize.c
===================================================================
--- GNUnet/src/applications/fs/fsui/deserialize.c 2007-07-07 05:03:27 UTC
(rev 5255)
+++ GNUnet/src/applications/fs/fsui/deserialize.c 2007-07-07 05:05:09 UTC
(rev 5256)
@@ -378,7 +378,7 @@
if (big == 0)
return OK;
list
- = MALLOC(sizeof(FSUI_SearchList));
+ = MALLOC(sizeof(FSUI_SearchList));
memset(list,
0,
sizeof(FSUI_SearchList));
@@ -392,7 +392,7 @@
(OK != read_int(fd, (int*) &list->sizeUnmatchedResultsReceived)) ||
(list->sizeResultsReceived > 1024*1024) ||
(list->sizeUnmatchedResultsReceived > 1024*1024) ) {
- GE_BREAK(NULL, 0);
+ GE_BREAK(NULL, 0);
break;
}
fixState(&list->state);
@@ -474,7 +474,7 @@
goto ERR;
}
}
- }
+ }
list->ctx
= ctx;
list->next
Modified: GNUnet/src/applications/fs/fsui/download.c
===================================================================
--- GNUnet/src/applications/fs/fsui/download.c 2007-07-07 05:03:27 UTC (rev
5255)
+++ GNUnet/src/applications/fs/fsui/download.c 2007-07-07 05:05:09 UTC (rev
5256)
@@ -375,7 +375,7 @@
dl);
if (md != NULL)
ECRS_freeMetaData(md);
-
+
if (dl->is_recursive) {
/* load directory, start downloads */
md = NULL;
Modified: GNUnet/src/applications/fs/fsui/fsui.c
===================================================================
--- GNUnet/src/applications/fs/fsui/fsui.c 2007-07-07 05:03:27 UTC (rev
5255)
+++ GNUnet/src/applications/fs/fsui/fsui.c 2007-07-07 05:05:09 UTC (rev
5256)
@@ -270,7 +270,7 @@
event.data.UnindexResumed.eta = get_time();
event.data.UnindexResumed.filename = xlist->filename;
event.data.UnindexResumed.state = xlist->state;
- xlist->cctx = cb(closure, &event);
+ xlist->cctx = cb(closure, &event);
xlist = xlist->next;
}
Modified: GNUnet/src/applications/fs/fsui/serialize.c
===================================================================
--- GNUnet/src/applications/fs/fsui/serialize.c 2007-07-07 05:03:27 UTC (rev
5255)
+++ GNUnet/src/applications/fs/fsui/serialize.c 2007-07-07 05:05:09 UTC (rev
5256)
@@ -307,7 +307,7 @@
WRITEINT(fd, shared->doIndex);
WRITEINT(fd, shared->anonymityLevel);
WRITEINT(fd, shared->priority);
- WRITEINT(fd, shared->individualKeywords);
+ WRITEINT(fd, shared->individualKeywords);
WRITELONG(fd, shared->expiration);
if (shared->extractor_config != NULL)
WRITESTRING(fd,
Modified: GNUnet/src/applications/fs/module/dht_push.c
===================================================================
--- GNUnet/src/applications/fs/module/dht_push.c 2007-07-07 05:03:27 UTC
(rev 5255)
+++ GNUnet/src/applications/fs/module/dht_push.c 2007-07-07 05:05:09 UTC
(rev 5256)
@@ -33,7 +33,7 @@
/**
* Disable DHT pushing? Set to 1 to essentially disable
* the code in this file. Used to study its performance
- * impact. Useful also for users that do not want to
+ * impact. Useful also for users that do not want to
* use non-anonymous file-sharing (since it eliminates
* some of the processing cost which would otherwise go
* to waste).
Modified: GNUnet/src/applications/fs/module/fs.c
===================================================================
--- GNUnet/src/applications/fs/module/fs.c 2007-07-07 05:03:27 UTC (rev
5255)
+++ GNUnet/src/applications/fs/module/fs.c 2007-07-07 05:05:09 UTC (rev
5256)
@@ -256,7 +256,7 @@
GE_BREAK(NULL, 0);
return OK;
}
-
+
gapPut(NULL,
query,
value,
@@ -1137,7 +1137,7 @@
"FS successfully took GAP shortcut for `%s'.\n",
&enc);
#endif
- return OK;
+ return OK;
}
/* run gapGet asynchronously (since it may take a while due to lots of IO) */
Modified: GNUnet/src/applications/fs/module/migration.c
===================================================================
--- GNUnet/src/applications/fs/module/migration.c 2007-07-07 05:03:27 UTC
(rev 5255)
+++ GNUnet/src/applications/fs/module/migration.c 2007-07-07 05:05:09 UTC
(rev 5256)
@@ -101,7 +101,7 @@
static struct MigrationRecord content[MAX_RECORDS];
static struct GE_Context * ectx;
-
+
/**
* Callback method for pushing content into the network.
* The method chooses either a "recently" deleted block
@@ -175,13 +175,13 @@
discard_match = content[i].sentCount;
discard_entry = i;
}
- }
+ }
}
if (entry == -1) {
entry = discard_entry;
GE_ASSERT(NULL,
entry != -1);
- FREENONNULL(content[entry].value);
+ FREENONNULL(content[entry].value);
content[entry].value = NULL;
content[entry].sentCount = 0;
if (OK != datastore->getRandom(&receiver->hashPubKey,
@@ -197,7 +197,7 @@
"Migration: random lookup in datastore failed.\n");
#endif
return 0;
- }
+ }
if (stats != NULL)
stats->change(stat_migration_factor, 1);
}
@@ -206,7 +206,7 @@
GE_ASSERT(NULL, 0);
MUTEX_UNLOCK(lock);
return 0;
- }
+ }
size = sizeof(GapWrapper) + ntohl(value->size) - sizeof(Datastore_Value);
if (size > padding) {
MUTEX_UNLOCK(lock);
@@ -223,7 +223,7 @@
value,
&content[entry].key,
&enc) != OK) {
- FREENONNULL(value);
+ FREENONNULL(value);
content[entry].value = NULL;
MUTEX_UNLOCK(lock);
return 0;
@@ -273,8 +273,8 @@
"gap's tryMigrate returned %u\n",
ret);
#endif
- if (ret != 0)
- content[entry].receiverIndices[content[entry].sentCount++] = index;
+ if (ret != 0)
+ content[entry].receiverIndices[content[entry].sentCount++] = index;
}
MUTEX_UNLOCK(lock);
if ( (ret > 0)&&
Modified: GNUnet/src/applications/fs/module/querymanager.c
===================================================================
--- GNUnet/src/applications/fs/module/querymanager.c 2007-07-07 05:03:27 UTC
(rev 5255)
+++ GNUnet/src/applications/fs/module/querymanager.c 2007-07-07 05:05:09 UTC
(rev 5256)
@@ -232,12 +232,12 @@
void doneQueryManager() {
int i;
- for (i=trackerCount-1;i>=0;i--)
+ for (i=trackerCount-1;i>=0;i--)
FREE(trackers[i]);
-
+
GROW(trackers,
trackerSize,
- 0);
+ 0);
trackerCount = 0;
if (stats != NULL) {
stats->set(stat_queries_tracked, 0);
Modified: GNUnet/src/applications/fs/namespace/namespace_info.c
===================================================================
--- GNUnet/src/applications/fs/namespace/namespace_info.c 2007-07-07
05:03:27 UTC (rev 5255)
+++ GNUnet/src/applications/fs/namespace/namespace_info.c 2007-07-07
05:05:09 UTC (rev 5256)
@@ -229,7 +229,7 @@
if (ret != NULL) {
HashCode512 id;
char * name;
-
+
NS_setNamespaceRoot(ectx,
cfg,
ret);
Modified: GNUnet/src/applications/fs/tools/gnunet-download.c
===================================================================
--- GNUnet/src/applications/fs/tools/gnunet-download.c 2007-07-07 05:03:27 UTC
(rev 5255)
+++ GNUnet/src/applications/fs/tools/gnunet-download.c 2007-07-07 05:05:09 UTC
(rev 5256)
@@ -348,7 +348,7 @@
else
printf(_("Did not find any files in directory `%s'\n"),
argv[i]);
- }
+ }
} else {
meta = ECRS_createMetaData();
dl = FSUI_startDownload(ctx,
Modified: GNUnet/src/applications/fs/tools/gnunet-insert.c
===================================================================
--- GNUnet/src/applications/fs/tools/gnunet-insert.c 2007-07-07 05:03:27 UTC
(rev 5255)
+++ GNUnet/src/applications/fs/tools/gnunet-insert.c 2007-07-07 05:05:09 UTC
(rev 5256)
@@ -231,7 +231,7 @@
: (double) (event->data.UploadCompleted.total
/ 1024.0 * cronSECONDS / delta));
}
- fstring = ECRS_uriToString(event->data.UploadCompleted.uri);
+ fstring = ECRS_uriToString(event->data.UploadCompleted.uri);
printf(_("File `%s' has URI: %s\n"),
event->data.UploadCompleted.filename,
fstring);
@@ -376,7 +376,7 @@
char * ex;
char * dirname;
char * fname;
-
+
l = EXTRACTOR_loadDefaultLibraries();
ex = NULL;
GC_get_configuration_value_string(cfg,
Modified: GNUnet/src/applications/fs/uritrack/uri_info.c
===================================================================
--- GNUnet/src/applications/fs/uritrack/uri_info.c 2007-07-07 05:03:27 UTC
(rev 5255)
+++ GNUnet/src/applications/fs/uritrack/uri_info.c 2007-07-07 05:05:09 UTC
(rev 5256)
@@ -95,7 +95,7 @@
s = getDBName(cfg);
if (NO == disk_file_test(ectx,
s))
- return URITRACK_FRESH;
+ return URITRACK_FRESH;
size = getDBSize(cfg);
fd = disk_file_open(ectx,
s,
Modified: GNUnet/src/applications/gap/gap.c
===================================================================
--- GNUnet/src/applications/gap/gap.c 2007-07-07 05:03:27 UTC (rev 5255)
+++ GNUnet/src/applications/gap/gap.c 2007-07-07 05:05:09 UTC (rev 5256)
@@ -287,7 +287,7 @@
if (stats != NULL)
stats->change(stat_response_count, rpos->responseCount / 2);
rpos->responseCount = rpos->responseCount / 2;
- if (rpos->responseCount == 0) {
+ if (rpos->responseCount == 0) {
if (rprev == NULL)
pos->responseList = rpos->next;
else
@@ -706,7 +706,7 @@
if (rankingSum == 0)
break;
sel = weak_randomi64(rankingSum);
- pos = 0;
+ pos = 0;
for (j=0;j<8*BITMAP_SIZE;j++) {
pos += qr->rankings[j];
if (pos > sel) {
@@ -997,8 +997,8 @@
for (i=0;i<ite->hostsWaiting;i++)
if (ite->destination[i] == sender)
return SYSERR;
- if (ite->hostsWaiting >= MAX_HOSTS_WAITING)
- resetDestinations(ite);
+ if (ite->hostsWaiting >= MAX_HOSTS_WAITING)
+ resetDestinations(ite);
} else {
ite->successful_local_lookup_in_delay_loop = NO;
/* different request, flush pending queues */
@@ -1009,7 +1009,7 @@
ite->priority = priority;
}
} else { /* GROW mode */
- GE_ASSERT(ectx,
+ GE_ASSERT(ectx,
equalsHashCode512(query,
&ite->primaryKey));
/* extend lifetime */
@@ -1539,7 +1539,7 @@
GE_BREAK(NULL, 0);
FREE(cls.values[perm[i]]);
continue;
- }
+ }
if ( (i < max) &&
(sender != NULL) &&
(YES == queueReply(sender,
@@ -1565,10 +1565,10 @@
cls.valueCount,
0);
MUTEX_UNLOCK(lookup_exclusion);
- if (doForward)
+ if (doForward)
forwardQuery(query,
target,
- sender);
+ sender);
change_pid_rc(senderID, -1);
return doForward;
}
@@ -1624,7 +1624,7 @@
&enc2,
(host != NULL) ? (const char*)&enc : "myself");
#endif
-
+
ite = &ROUTING_indTable_[computeRoutingIndex(&msg->primaryKey)];
ite->successful_local_lookup_in_delay_loop = NO;
size = ntohs(msg->header.size) - sizeof(P2P_gap_reply_MESSAGE);
@@ -2084,7 +2084,7 @@
ttl = ntohl(qmsg->ttl);
if (ttl < 0)
ttl = 0;
- execQuery(sender,
+ execQuery(sender,
NULL,
prio,
policy,
Modified: GNUnet/src/applications/gap/gaptest.c
===================================================================
--- GNUnet/src/applications/gap/gaptest.c 2007-07-07 05:03:27 UTC (rev
5255)
+++ GNUnet/src/applications/gap/gaptest.c 2007-07-07 05:05:09 UTC (rev
5256)
@@ -103,7 +103,7 @@
0, /* anon */
0, /* prio */
get_time() + 10 * cronMINUTES, /* expire */
- &uprogress,
+ &uprogress,
NULL,
&testTerminate,
NULL,
Modified: GNUnet/src/applications/identity/identity.c
===================================================================
--- GNUnet/src/applications/identity/identity.c 2007-07-07 05:03:27 UTC (rev
5255)
+++ GNUnet/src/applications/identity/identity.c 2007-07-07 05:05:09 UTC (rev
5256)
@@ -476,7 +476,7 @@
entry->hellos[0] = msg;
entry->protocols[0] = ntohs(msg->protocol);
entry->strict = NO;
- entry->trust = 0;
+ entry->trust = 0;
MUTEX_UNLOCK(lock_);
}
@@ -869,7 +869,7 @@
if (strict) {
entry->delta = desperation * cronSECONDS;
} else {
- if (entry->until < now)
+ if (entry->until < now)
entry->delta
= weak_randomi(1+desperation*cronSECONDS);
else
@@ -1033,14 +1033,14 @@
#if 0
#if DEBUG_IDENTITY
EncName enc;
-
+
IF_GELOG(ectx,
GE_INFO | GE_USER | GE_BULK,
hash2enc(&entry->identity.hashPubKey,
&enc));
GE_LOG(ectx,
GE_INFO | GE_USER | GE_BULK,
- entry->strict ?
+ entry->strict ?
_("Peer `%s' is currently strictly blacklisted (for another
%llums).\n") :
_("Peer `%s' is currently blacklisted (for another %llums).\n"),
&enc,
@@ -1292,14 +1292,14 @@
hello = identity2Hello(identity,
protocol,
YES);
- if (hello == NULL)
+ if (hello == NULL)
return OK; /* ignore -- happens if HELLO just expired */
transport = coreAPI->requestService("transport");
if (transport == NULL) {
FREE(hello);
return OK;
}
-
+
len = 0;
address = NULL;
transport->helloToAddress(hello,
Modified: GNUnet/src/applications/kvstore_sqlite/kv_sqlite.c
===================================================================
--- GNUnet/src/applications/kvstore_sqlite/kv_sqlite.c 2007-07-07 05:03:27 UTC
(rev 5255)
+++ GNUnet/src/applications/kvstore_sqlite/kv_sqlite.c 2007-07-07 05:05:09 UTC
(rev 5256)
@@ -255,7 +255,7 @@
if (sqlite3_open(db->fn,
&dbh->dbh) != SQLITE_OK) {
printf("FN: %s\n", db->fn);
- LOG_SQLITE(dbh->dbh,
+ LOG_SQLITE(dbh->dbh,
GE_ERROR | GE_BULK | GE_USER,
"sqlite3_open");
sqlite3_close(dbh->dbh);
Modified: GNUnet/src/applications/pingpong/pingpong.c
===================================================================
--- GNUnet/src/applications/pingpong/pingpong.c 2007-07-07 05:03:27 UTC (rev
5255)
+++ GNUnet/src/applications/pingpong/pingpong.c 2007-07-07 05:05:09 UTC (rev
5256)
@@ -116,7 +116,7 @@
/**
* We received a PING message, send the PONG reply.
- */
+ */
static int pingReceived(const PeerIdentity * sender,
const MESSAGE_HEADER * msg) {
const P2P_pingpong_MESSAGE * pmsg;
@@ -144,7 +144,7 @@
#if DEBUG_PINGPONG
EncName enc;
- hash2enc(&sender->hashPubKey,
+ hash2enc(&sender->hashPubKey,
&enc);
GE_LOG(ectx,
GE_DEBUG | GE_REQUEST | GE_USER,
@@ -182,7 +182,7 @@
/**
* We received a PING message, send the PONG reply and notify the
* connection module that the session is still life.
- */
+ */
static int plaintextPingReceived(const PeerIdentity * sender,
const MESSAGE_HEADER * hmsg,
TSession * tsession) {
@@ -213,7 +213,7 @@
}
#if DEBUG_PINGPONG
- hash2enc(&sender->hashPubKey,
+ hash2enc(&sender->hashPubKey,
&enc);
GE_LOG(ectx,
GE_DEBUG | GE_REQUEST | GE_USER,
@@ -238,12 +238,12 @@
if (stats != NULL)
stats->change(stat_plaintextPongFailed, 1);
}
- return ret;
+ return ret;
}
/**
* Handler for a pong.
- */
+ */
static int pongReceived(const PeerIdentity * sender,
const MESSAGE_HEADER * msg) {
int i;
@@ -313,7 +313,7 @@
/**
* Handler for a pong.
- */
+ */
static int plaintextPongReceived(const PeerIdentity * sender,
const MESSAGE_HEADER * msg,
TSession * session) {
Modified: GNUnet/src/applications/rpc/rpc.c
===================================================================
--- GNUnet/src/applications/rpc/rpc.c 2007-07-07 05:03:27 UTC (rev 5255)
+++ GNUnet/src/applications/rpc/rpc.c 2007-07-07 05:05:09 UTC (rev 5256)
@@ -649,7 +649,7 @@
vectorRemoveObject(outgoingCalls, call);
} else {
vectorRemoveObject(incomingCalls, call);
- }
+ }
FREE(call->msg);
FREE(call);
} else {
@@ -689,7 +689,7 @@
call->expirationTime - now,
now - call->lastAttempt,
call->attempts);
- }
+ }
#endif
call->lastAttempt = now;
call->attempts++;
Modified: GNUnet/src/applications/session/connect.c
===================================================================
--- GNUnet/src/applications/session/connect.c 2007-07-07 05:03:27 UTC (rev
5255)
+++ GNUnet/src/applications/session/connect.c 2007-07-07 05:05:09 UTC (rev
5256)
@@ -529,7 +529,7 @@
if (stats != NULL) {
stats->change(stat_pingSent, 1);
stats->change(stat_skeySent, 1);
- /* pong, if present, is accounted for
+ /* pong, if present, is accounted for
by caller */
}
if (hello != NULL) {
Modified: GNUnet/src/applications/session/sessiontest2.c
===================================================================
--- GNUnet/src/applications/session/sessiontest2.c 2007-07-07 05:03:27 UTC
(rev 5255)
+++ GNUnet/src/applications/session/sessiontest2.c 2007-07-07 05:05:09 UTC
(rev 5256)
@@ -153,7 +153,7 @@
peer2 = os_daemon_start(NULL,
cfg,
"nat-peer.conf",
- NO);
+ NO);
if (peer2 == -1) {
os_daemon_stop(NULL, peer1);
GC_free(cfg);
Modified: GNUnet/src/applications/session/sessiontest_http.c
===================================================================
--- GNUnet/src/applications/session/sessiontest_http.c 2007-07-07 05:03:27 UTC
(rev 5255)
+++ GNUnet/src/applications/session/sessiontest_http.c 2007-07-07 05:05:09 UTC
(rev 5256)
@@ -153,7 +153,7 @@
peer2 = os_daemon_start(NULL,
cfg,
"nat-http-peer.conf",
- NO);
+ NO);
if (peer2 == -1) {
os_daemon_stop(NULL, peer1);
GC_free(cfg);
Modified: GNUnet/src/applications/sqstore_mysql/mysql.c
===================================================================
--- GNUnet/src/applications/sqstore_mysql/mysql.c 2007-07-07 05:03:27 UTC
(rev 5255)
+++ GNUnet/src/applications/sqstore_mysql/mysql.c 2007-07-07 05:05:09 UTC
(rev 5256)
@@ -312,7 +312,7 @@
MYSQL_READ_DEFAULT_GROUP,
"client");
mysql_options(dbhI->dbf,
- MYSQL_OPT_RECONNECT,
+ MYSQL_OPT_RECONNECT,
&reconnect);
mysql_options(dbhI->dbf,
MYSQL_OPT_CONNECT_TIMEOUT,
@@ -569,7 +569,7 @@
if (OK != iopen(&dbhI, NO))
return SYSERR;
- mysql_thread_init();
+ mysql_thread_init();
mysql_query(dbhI.dbf,
"SET AUTOCOMMIT = 0");
mysql_query(dbhI.dbf,
@@ -596,7 +596,7 @@
LOG_MYSQL(GE_ERROR | GE_ADMIN | GE_BULK,
"mysql_query",
&dbhI);
- mysql_thread_end();
+ mysql_thread_end();
iclose(&dbhI);
return SYSERR;
}
@@ -609,7 +609,7 @@
sql_row,
&dbhI);
if (datum == NULL) {
- mysql_thread_end();
+ mysql_thread_end();
iclose(&dbhI);
return count;
}
@@ -629,12 +629,12 @@
"mysql_query",
&dbhI);
mysql_free_result(sql_res);
- mysql_thread_end();
+ mysql_thread_end();
iclose(&dbhI);
return SYSERR;
}
mysql_free_result(sql_res);
- mysql_thread_end();
+ mysql_thread_end();
iclose(&dbhI);
return count;
}
@@ -796,9 +796,9 @@
type);
#endif
MUTEX_LOCK(lock);
- mysql_thread_init();
+ mysql_thread_init();
if (OK != CHECK_DBH) {
- mysql_thread_end();
+ mysql_thread_end();
MUTEX_UNLOCK(lock);
return SYSERR;
}
@@ -827,7 +827,7 @@
__FILE__, __LINE__,
mysql_stmt_error(stmt));
iclose(dbh);
- mysql_thread_end();
+ mysql_thread_end();
MUTEX_UNLOCK(lock);
return SYSERR;
}
@@ -835,7 +835,7 @@
(7 != mysql_num_fields(sql_res)) ) {
GE_BREAK(ectx, 0);
iclose(dbh);
- mysql_thread_end();
+ mysql_thread_end();
MUTEX_UNLOCK(lock);
return SYSERR;
}
@@ -848,7 +848,7 @@
__FILE__, __LINE__,
mysql_stmt_error(stmt));
iclose(dbh);
- mysql_thread_end();
+ mysql_thread_end();
MUTEX_UNLOCK(lock);
return SYSERR;
}
@@ -860,14 +860,14 @@
__FILE__, __LINE__,
mysql_stmt_error(stmt));
iclose(dbh);
- mysql_thread_end();
+ mysql_thread_end();
MUTEX_UNLOCK(lock);
return SYSERR;
}
if (iter == NULL) {
count = mysql_stmt_affected_rows(stmt);
mysql_stmt_reset(stmt);
- mysql_thread_end();
+ mysql_thread_end();
MUTEX_UNLOCK(lock);
return count;
}
@@ -893,7 +893,7 @@
__FILE__, __LINE__,
mysql_stmt_error(stmt));
iclose(dbh);
- mysql_thread_end();
+ mysql_thread_end();
MUTEX_UNLOCK(lock);
FREE(datum);
return SYSERR;
@@ -906,7 +906,7 @@
__FILE__, __LINE__,
mysql_stmt_error(stmt));
iclose(dbh);
- mysql_thread_end();
+ mysql_thread_end();
MUTEX_UNLOCK(lock);
FREE(datum);
return SYSERR;
@@ -929,13 +929,13 @@
sizeof(HashCode512),
sizeof(Datastore_Value));
if (0 != mysql_query(dbh->dbf, scratch))
- LOG_MYSQL(GE_ERROR | GE_ADMIN | GE_BULK,
- "mysql_query",
+ LOG_MYSQL(GE_ERROR | GE_ADMIN | GE_BULK,
+ "mysql_query",
dbh);
FREE(datum);
iclose(dbh);
- mysql_thread_end();
+ mysql_thread_end();
MUTEX_UNLOCK(lock);
return count;
}
@@ -956,7 +956,7 @@
closure) ) {
count = SYSERR;
break;
- }
+ }
datasize = MAX_DATUM_SIZE;
}
if (mysql_stmt_errno(stmt)) {
@@ -969,13 +969,13 @@
mysql_free_result(sql_res);
FREE(datum);
iclose(dbh);
- mysql_thread_end();
+ mysql_thread_end();
MUTEX_UNLOCK(lock);
return SYSERR;
}
mysql_free_result(sql_res);
FREE(datum);
- mysql_thread_end();
+ mysql_thread_end();
MUTEX_UNLOCK(lock);
#if DEBUG_MYSQL
@@ -1024,9 +1024,9 @@
return SYSERR;
}
MUTEX_LOCK(lock);
- mysql_thread_init();
+ mysql_thread_init();
if (OK != CHECK_DBH) {
- mysql_thread_end();
+ mysql_thread_end();
MUTEX_UNLOCK(lock);
return SYSERR;
}
@@ -1067,7 +1067,7 @@
__FILE__, __LINE__,
mysql_stmt_error(dbh->insert));
iclose(dbh);
- mysql_thread_end();
+ mysql_thread_end();
MUTEX_UNLOCK(lock);
return SYSERR;
}
@@ -1080,11 +1080,11 @@
__FILE__, __LINE__,
mysql_stmt_error(dbh->insert));
iclose(dbh);
- mysql_thread_end();
+ mysql_thread_end();
MUTEX_UNLOCK(lock);
return SYSERR;
}
- mysql_thread_end();
+ mysql_thread_end();
content_size += ntohl(value->size);
MUTEX_UNLOCK(lock);
return OK;
@@ -1132,7 +1132,7 @@
MUTEX_LOCK(lock);
mysql_thread_init();
if (OK != CHECK_DBH) {
- mysql_thread_end();
+ mysql_thread_end();
MUTEX_UNLOCK(lock);
return SYSERR;
}
@@ -1151,14 +1151,14 @@
__FILE__, __LINE__,
mysql_stmt_error(stmt));
iclose(dbh);
- mysql_thread_end();
+ mysql_thread_end();
MUTEX_UNLOCK(lock);
return SYSERR;
}
if (7 != mysql_num_fields(sql_res)) {
GE_BREAK(ectx, 0);
iclose(dbh);
- mysql_thread_end();
+ mysql_thread_end();
MUTEX_UNLOCK(lock);
return SYSERR;
}
@@ -1171,7 +1171,7 @@
__FILE__, __LINE__,
mysql_stmt_error(stmt));
iclose(dbh);
- mysql_thread_end();
+ mysql_thread_end();
MUTEX_UNLOCK(lock);
return SYSERR;
}
@@ -1209,7 +1209,7 @@
__FILE__, __LINE__,
mysql_stmt_error(stmt));
iclose(dbh);
- mysql_thread_end();
+ mysql_thread_end();
MUTEX_UNLOCK(lock);
FREE(svalue);
return SYSERR;
@@ -1222,7 +1222,7 @@
__FILE__, __LINE__,
mysql_stmt_error(stmt));
iclose(dbh);
- mysql_thread_end();
+ mysql_thread_end();
MUTEX_UNLOCK(lock);
FREE(svalue);
return SYSERR;
@@ -1353,7 +1353,7 @@
MUTEX_LOCK(lock);
mysql_thread_init();
if (OK != CHECK_DBH) {
- mysql_thread_end();
+ mysql_thread_end();
MUTEX_UNLOCK(lock);
return SYSERR;
}
@@ -1425,9 +1425,9 @@
*/
static void drop() {
MUTEX_LOCK(lock);
- mysql_thread_init();
+ mysql_thread_init();
if (OK != CHECK_DBH) {
- mysql_thread_end();
+ mysql_thread_end();
MUTEX_UNLOCK(lock);
return;
}
@@ -1441,7 +1441,7 @@
} else {
content_size = 0;
}
- mysql_thread_end();
+ mysql_thread_end();
MUTEX_UNLOCK(lock);
}
@@ -1457,7 +1457,7 @@
unsigned long long * sb;
MYSQL_RES *sql_res;
MYSQL_ROW sql_row;
-
+
ectx = capi->ectx;
coreAPI = capi;
stats = coreAPI->requestService("stats");
@@ -1509,7 +1509,7 @@
fclose(fp);
}
dbh = MALLOC(sizeof(mysqlHandle));
- dbh->cnffile = cnffile;
+ dbh->cnffile = cnffile;
if (OK != iopen(dbh, YES)) {
FREE(cnffile);
FREE(dbh);
Modified: GNUnet/src/applications/sqstore_mysql/mysqltest2.c
===================================================================
--- GNUnet/src/applications/sqstore_mysql/mysqltest2.c 2007-07-07 05:03:27 UTC
(rev 5255)
+++ GNUnet/src/applications/sqstore_mysql/mysqltest2.c 2007-07-07 05:05:09 UTC
(rev 5256)
@@ -108,7 +108,7 @@
#define ITERATIONS 100
/**
- * Name of the database on disk.
+ * Name of the database on disk.
* You may have to adjust this path and the access
* permission to the respective directory in order
* to obtain all of the performance information.
Modified: GNUnet/src/applications/sqstore_mysql_embedded/mysql.c
===================================================================
--- GNUnet/src/applications/sqstore_mysql_embedded/mysql.c 2007-07-07
05:03:27 UTC (rev 5255)
+++ GNUnet/src/applications/sqstore_mysql_embedded/mysql.c 2007-07-07
05:05:09 UTC (rev 5256)
@@ -544,7 +544,7 @@
return SYSERR;
MUTEX_LOCK(dbhI.DATABASE_Lock_);
- mysql_thread_init();
+ mysql_thread_init();
mysql_query(dbhI.dbf,
"SET AUTOCOMMIT = 0");
mysql_query(dbhI.dbf,
@@ -571,7 +571,7 @@
LOG_MYSQL(GE_ERROR | GE_ADMIN | GE_BULK,
"mysql_query",
&dbhI);
- mysql_thread_end();
+ mysql_thread_end();
MUTEX_UNLOCK(dbhI.DATABASE_Lock_);
iclose(&dbhI);
return SYSERR;
@@ -586,7 +586,7 @@
sql_row,
&dbhI);
if (datum == NULL) {
- mysql_thread_end();
+ mysql_thread_end();
MUTEX_UNLOCK(dbhI.DATABASE_Lock_);
iclose(&dbhI);
return count;
@@ -607,13 +607,13 @@
"mysql_query",
&dbhI);
mysql_free_result(sql_res);
- mysql_thread_end();
+ mysql_thread_end();
MUTEX_UNLOCK(dbhI.DATABASE_Lock_);
iclose(&dbhI);
return SYSERR;
}
mysql_free_result(sql_res);
- mysql_thread_end();
+ mysql_thread_end();
MUTEX_UNLOCK(dbhI.DATABASE_Lock_);
iclose(&dbhI);
return count;
@@ -776,7 +776,7 @@
type);
#endif
MUTEX_LOCK(dbh->DATABASE_Lock_);
- mysql_thread_init();
+ mysql_thread_init();
if (type != 0) {
if (iter == NULL)
stmt = dbh->selectsc;
@@ -801,13 +801,13 @@
"mysql_stmt_result_metadata",
__FILE__, __LINE__,
mysql_stmt_error(stmt));
- mysql_thread_end();
+ mysql_thread_end();
MUTEX_UNLOCK(dbh->DATABASE_Lock_);
return SYSERR;
}
if (7 != mysql_num_fields(sql_res)) {
GE_BREAK(ectx, 0);
- mysql_thread_end();
+ mysql_thread_end();
MUTEX_UNLOCK(dbh->DATABASE_Lock_);
return SYSERR;
}
@@ -819,7 +819,7 @@
"mysql_stmt_bind_param",
__FILE__, __LINE__,
mysql_stmt_error(stmt));
- mysql_thread_end();
+ mysql_thread_end();
MUTEX_UNLOCK(dbh->DATABASE_Lock_);
return SYSERR;
}
@@ -830,7 +830,7 @@
"mysql_stmt_execute",
__FILE__, __LINE__,
mysql_stmt_error(stmt));
- mysql_thread_end();
+ mysql_thread_end();
MUTEX_UNLOCK(dbh->DATABASE_Lock_);
return SYSERR;
}
@@ -856,7 +856,7 @@
"mysql_stmt_bind_result",
__FILE__, __LINE__,
mysql_stmt_error(stmt));
- mysql_thread_end();
+ mysql_thread_end();
MUTEX_UNLOCK(dbh->DATABASE_Lock_);
FREE(datum);
return SYSERR;
@@ -868,7 +868,7 @@
"mysql_stmt_store_result",
__FILE__, __LINE__,
mysql_stmt_error(stmt));
- mysql_thread_end();
+ mysql_thread_end();
MUTEX_UNLOCK(dbh->DATABASE_Lock_);
FREE(datum);
return SYSERR;
@@ -894,7 +894,7 @@
LOG_MYSQL(GE_ERROR | GE_ADMIN | GE_BULK, "mysql_query", dbh);
FREE(datum);
- mysql_thread_end();
+ mysql_thread_end();
MUTEX_UNLOCK(dbh->DATABASE_Lock_);
return count;
}
@@ -930,7 +930,7 @@
}
mysql_free_result(sql_res);
FREE(datum);
- mysql_thread_end();
+ mysql_thread_end();
MUTEX_UNLOCK(dbh->DATABASE_Lock_);
#if DEBUG_MYSQL
@@ -979,7 +979,7 @@
return SYSERR;
}
MUTEX_LOCK(dbh->DATABASE_Lock_);
- mysql_thread_init();
+ mysql_thread_init();
contentSize = ntohl(value->size)-sizeof(Datastore_Value);
hashSize = sizeof(HashCode512);
size = ntohl(value->size);
@@ -1016,7 +1016,7 @@
"mysql_stmt_bind_param",
__FILE__, __LINE__,
mysql_stmt_error(dbh->insert));
- mysql_thread_end();
+ mysql_thread_end();
MUTEX_UNLOCK(dbh->DATABASE_Lock_);
return SYSERR;
}
@@ -1028,11 +1028,11 @@
"mysql_stmt_execute",
__FILE__, __LINE__,
mysql_stmt_error(dbh->insert));
- mysql_thread_end();
+ mysql_thread_end();
MUTEX_UNLOCK(dbh->DATABASE_Lock_);
return SYSERR;
}
- mysql_thread_end();
+ mysql_thread_end();
MUTEX_UNLOCK(dbh->DATABASE_Lock_);
MUTEX_LOCK(lock);
content_size += ntohl(value->size);
@@ -1095,7 +1095,7 @@
"mysql_stmt_result_metadata",
__FILE__, __LINE__,
mysql_stmt_error(stmt));
- mysql_thread_end();
+ mysql_thread_end();
MUTEX_UNLOCK(dbh->DATABASE_Lock_);
return SYSERR;
}
@@ -1112,7 +1112,7 @@
"mysql_stmt_bind_param",
__FILE__, __LINE__,
mysql_stmt_error(stmt));
- mysql_thread_end();
+ mysql_thread_end();
MUTEX_UNLOCK(dbh->DATABASE_Lock_);
return SYSERR;
}
@@ -1148,7 +1148,7 @@
"mysql_stmt_bind_result",
__FILE__, __LINE__,
mysql_stmt_error(stmt));
- mysql_thread_end();
+ mysql_thread_end();
MUTEX_UNLOCK(dbh->DATABASE_Lock_);
FREE(svalue);
return SYSERR;
@@ -1160,7 +1160,7 @@
"mysql_stmt_store_result",
__FILE__, __LINE__,
mysql_stmt_error(stmt));
- mysql_thread_end();
+ mysql_thread_end();
MUTEX_UNLOCK(dbh->DATABASE_Lock_);
FREE(svalue);
return SYSERR;
@@ -1427,7 +1427,7 @@
fclose(fp);
}
dbh = MALLOC(sizeof(mysqlHandle));
- dbh->cnffile = cnffile;
+ dbh->cnffile = cnffile;
if (OK != iopen(dbh, YES)) {
FREE(cnffile);
FREE(dbh);
Modified: GNUnet/src/applications/sqstore_mysql_embedded/mysqltest2.c
===================================================================
--- GNUnet/src/applications/sqstore_mysql_embedded/mysqltest2.c 2007-07-07
05:03:27 UTC (rev 5255)
+++ GNUnet/src/applications/sqstore_mysql_embedded/mysqltest2.c 2007-07-07
05:05:09 UTC (rev 5256)
@@ -108,7 +108,7 @@
#define ITERATIONS 100
/**
- * Name of the database on disk.
+ * Name of the database on disk.
* You may have to adjust this path and the access
* permission to the respective directory in order
* to obtain all of the performance information.
Modified: GNUnet/src/applications/sqstore_sqlite/sqlite.c
===================================================================
--- GNUnet/src/applications/sqstore_sqlite/sqlite.c 2007-07-07 05:03:27 UTC
(rev 5255)
+++ GNUnet/src/applications/sqstore_sqlite/sqlite.c 2007-07-07 05:05:09 UTC
(rev 5256)
@@ -223,12 +223,12 @@
CHECK(SQLITE_OK ==
sqlite3_exec(ret->dbh,
"PRAGMA page_size=4092", NULL, NULL, ENULL));
-
+
CHECK(SQLITE_OK ==
sqlite3_busy_timeout(ret->dbh,
BUSY_TIMEOUT_MS));
-
+
/* We have to do it here, because otherwise precompiling SQL might fail */
CHECK(SQLITE_OK ==
sq_prepare(ret->dbh,
@@ -466,7 +466,7 @@
}
}
sqlite3_finalize(stmt);
- if (i == SQLITE_BUSY)
+ if (i == SQLITE_BUSY)
return SYSERR;
if (i != SQLITE_OK) {
LOG_SQLITE(handle,
@@ -995,7 +995,7 @@
type);
else
ret = SQLITE_OK;
-
+
if (key && (ret == SQLITE_OK)) {
ret = sqlite3_bind_blob(stmt,
bind,
@@ -1009,7 +1009,7 @@
if (iter != NULL) {
datum = assembleDatum(handle,
stmt);
-
+
if (datum == NULL)
continue;
if ( (key != NULL) &&
@@ -1030,7 +1030,7 @@
if (SYSERR == iter(&datum->key,
&datum->value,
closure) ) {
-
+
count = SYSERR;
FREE(datum);
ret = SQLITE_DONE;
@@ -1122,13 +1122,13 @@
n = sqlite3_step(stmt);
if (n != SQLITE_DONE) {
if (n == SQLITE_BUSY) {
- sqlite3_reset(stmt);
+ sqlite3_reset(stmt);
return NO;
}
LOG_SQLITE(dbh,
GE_ERROR | GE_ADMIN | GE_USER | GE_BULK,
"sqlite_query");
- sqlite3_reset(stmt);
+ sqlite3_reset(stmt);
return SYSERR;
}
sqlite3_reset(stmt);
@@ -1209,7 +1209,7 @@
value = &dvalue->value;
} else {
dvalue = NULL;
- }
+ }
contentSize = ntohl(value->size)-sizeof(Datastore_Value);
n = sq_prepare(dbh->dbh,
"DELETE FROM gn070 WHERE hash = ? and "
@@ -1321,7 +1321,7 @@
GE_DEBUG | GE_REQUEST | GE_USER,
"SQLite: block updated\n");
#endif
- if (n == SQLITE_BUSY)
+ if (n == SQLITE_BUSY)
return NO;
return n == SQLITE_OK ? OK : SYSERR;
}
Modified: GNUnet/src/applications/stats/clientapi.c
===================================================================
--- GNUnet/src/applications/stats/clientapi.c 2007-07-07 05:03:27 UTC (rev
5255)
+++ GNUnet/src/applications/stats/clientapi.c 2007-07-07 05:05:09 UTC (rev
5256)
@@ -382,7 +382,7 @@
if (SYSERR == connection_read_result(sock,
&supported))
return SYSERR;
- if (supported == YES) {
+ if (supported == YES) {
ret = processor(i,
(j == 2) ? YES : NO,
cls);
Modified: GNUnet/src/applications/testbed/gnunet-testbed.c
===================================================================
--- GNUnet/src/applications/testbed/gnunet-testbed.c 2007-07-07 05:03:27 UTC
(rev 5255)
+++ GNUnet/src/applications/testbed/gnunet-testbed.c 2007-07-07 05:05:09 UTC
(rev 5256)
@@ -440,7 +440,7 @@
while (SOCKET_ADD_ARGUMENT == readSocket(&buf, &len)) {
GROW(args, argc, argc+1);
args[argc-1] = MALLOC(len+1);
- memcpy(args[argc-1], buf, len);
+ memcpy(args[argc-1], buf, len);
args[argc-1][len] = '\0';
FREE(buf);
buf = NULL;
Modified: GNUnet/src/applications/testbed/testbed.c
===================================================================
--- GNUnet/src/applications/testbed/testbed.c 2007-07-07 05:03:27 UTC (rev
5255)
+++ GNUnet/src/applications/testbed/testbed.c 2007-07-07 05:05:09 UTC (rev
5256)
@@ -170,7 +170,7 @@
identity->changeHostTrust(&msg->otherPeer,
trust);
sendAcknowledgement(client, OK);
-}
+}
/**
* Get a trust value.
@@ -181,7 +181,7 @@
trust = identity->getHostTrust(&msg->otherPeer);
sendAcknowledgement(client, trust);
-}
+}
/**
* Change the bandwidth limitations.
@@ -704,10 +704,10 @@
pi = pt[i];
if (pi->uid != uid)
continue;
- if (sig == -1) {
+ if (sig == -1) {
if (pi->hasExited == NO) {
ret = SYSERR;
- } else {
+ } else {
ret = WEXITSTATUS(pi->exitStatus);
/* free resources... */
GROW(pi->output,
@@ -762,7 +762,7 @@
sendAcknowledgement(client, pi->outputSize);
pos = 0;
- while (pos < pi->outputSize) {
+ while (pos < pi->outputSize) {
unsigned int run = pi->outputSize - pos;
if (run > 65532 - sizeof(TESTBED_OUTPUT_REPLY_MESSAGE))
run = 65532 - sizeof(TESTBED_OUTPUT_REPLY_MESSAGE);
Modified: GNUnet/src/applications/testing/testing.c
===================================================================
--- GNUnet/src/applications/testing/testing.c 2007-07-07 05:03:27 UTC (rev
5255)
+++ GNUnet/src/applications/testing/testing.c 2007-07-07 05:05:09 UTC (rev
5256)
@@ -116,13 +116,13 @@
updatePort(cfg, "UDP6", tra_offset);
updatePort(cfg, "HTTP", tra_offset);
updatePort(cfg, "SMTP", tra_offset);
- GC_set_configuration_value_string(cfg,
+ GC_set_configuration_value_string(cfg,
NULL,
"PATHS",
"GNUNETD_HOME",
gnunetd_home);
if (transports != NULL)
- GC_set_configuration_value_string(cfg,
+ GC_set_configuration_value_string(cfg,
NULL,
"GNUNETD",
"TRANSPORTS",
Modified: GNUnet/src/applications/topology_default/topology.c
===================================================================
--- GNUnet/src/applications/topology_default/topology.c 2007-07-07 05:03:27 UTC
(rev 5255)
+++ GNUnet/src/applications/topology_default/topology.c 2007-07-07 05:05:09 UTC
(rev 5256)
@@ -169,7 +169,7 @@
static void scanForHosts(unsigned int index) {
IndexMatch indexMatch;
cron_t now;
-#if DEBUG_TOPOLOGY
+#if DEBUG_TOPOLOGY
EncName enc;
#endif
@@ -243,7 +243,7 @@
PeerIdentity * hostId = cls;
#if DEBUG_TOPOLOGY || DEBUG_LIVENESS
EncName enc;
-
+
IF_GELOG(coreAPI->ectx,
GE_DEBUG | GE_REQUEST | GE_DEVELOPER,
hash2enc(&hostId->hashPubKey,
@@ -283,7 +283,7 @@
to keep the connection open instead of hanging up */
#if DEBUG_TOPOLOGY || DEBUG_LIVENESS
EncName enc;
-
+
IF_GELOG(coreAPI->ectx,
GE_DEBUG | GE_REQUEST | GE_DEVELOPER,
hash2enc(&peer->hashPubKey,
@@ -335,7 +335,7 @@
for (i=slotCount-1;i>=0;i--) {
if (weak_randomi(LIVE_SCAN_EFFECTIVENESS) != 0)
continue;
- if (minint > coreAPI->isSlotUsed(i))
+ if (minint > coreAPI->isSlotUsed(i))
scanForHosts(i);
}
}
Modified: GNUnet/src/applications/topology_f2f/topology.c
===================================================================
--- GNUnet/src/applications/topology_f2f/topology.c 2007-07-07 05:03:27 UTC
(rev 5255)
+++ GNUnet/src/applications/topology_f2f/topology.c 2007-07-07 05:05:09 UTC
(rev 5256)
@@ -288,7 +288,7 @@
#if DEBUG_TOPOLOGY
hash2enc(&hi->hashPubKey,
&enc);
- GE_LOG(ectx,
+ GE_LOG(ectx,
GE_DEBUG | GE_REQUEST | GE_USER,
"Sending ping to `%s' to prevent connection timeout.\n",
(char*)&enc);
@@ -323,7 +323,7 @@
for (i=slotCount-1;i>=0;i--) {
if (weak_randomi(LIVE_SCAN_EFFECTIVENESS) != 0)
continue;
- if (0 == coreAPI->isSlotUsed(i))
+ if (0 == coreAPI->isSlotUsed(i))
scanForHosts(i);
}
}
Modified: GNUnet/src/applications/tracekit/tracekit.c
===================================================================
--- GNUnet/src/applications/tracekit/tracekit.c 2007-07-07 05:03:27 UTC (rev
5255)
+++ GNUnet/src/applications/tracekit/tracekit.c 2007-07-07 05:05:09 UTC (rev
5256)
@@ -109,7 +109,7 @@
idx);
continue; /* discard */
}
-
+
csReply =
MALLOC(sizeof(CS_tracekit_reply_MESSAGE)+hostCount*sizeof(PeerIdentity));
/* build msg */
csReply->header.size
Modified: GNUnet/src/applications/transport/transport.c
===================================================================
--- GNUnet/src/applications/transport/transport.c 2007-07-07 05:03:27 UTC
(rev 5255)
+++ GNUnet/src/applications/transport/transport.c 2007-07-07 05:05:09 UTC
(rev 5256)
@@ -199,8 +199,8 @@
}
tsession = NULL;
if (OK != tapis[prot]->connect(hello,
- &tsession))
- return NULL;
+ &tsession))
+ return NULL;
tsession->ttype = prot;
return tsession;
}
@@ -265,7 +265,7 @@
static int transportAssociate(TSession * tsession) {
if ( (tsession == NULL) ||
(tsession->ttype >= tapis_count) ||
- (tapis[tsession->ttype] == NULL) )
+ (tapis[tsession->ttype] == NULL) )
return SYSERR;
return tapis[tsession->ttype]->associate(tsession);
}
@@ -275,7 +275,7 @@
*/
static unsigned int transportGetCost(int ttype) {
if ( (ttype >= tapis_count) ||
- (tapis[ttype] == NULL) )
+ (tapis[ttype] == NULL) )
return SYSERR; /* -1 = INFTY */
return tapis[ttype]->cost;
}
@@ -345,7 +345,7 @@
return SYSERR; /* invalid */
prot = ntohs(hello->protocol);
if ( (prot >= tapis_count) ||
- (tapis[prot] == NULL) )
+ (tapis[prot] == NULL) )
return SYSERR; /* not supported */
return tapis[prot]->verifyHello(hello);
}
@@ -355,7 +355,7 @@
*/
static int transportGetMTU(unsigned short ttype) {
if ( (ttype >= tapis_count) ||
- (tapis[ttype] == NULL) )
+ (tapis[ttype] == NULL) )
return SYSERR;
return tapis[ttype]->mtu;
}
Modified: GNUnet/src/applications/vpn/vpn.c
===================================================================
--- GNUnet/src/applications/vpn/vpn.c 2007-07-07 05:03:27 UTC (rev 5255)
+++ GNUnet/src/applications/vpn/vpn.c 2007-07-07 05:05:09 UTC (rev 5256)
@@ -186,7 +186,7 @@
PublicKey owner;
int hops;
} transit_route;
-
+
static route_info *route_store = NULL;
static int route_entries = 0;
static int route_capacity = 0;
@@ -241,7 +241,7 @@
int i;
int ln = maxi(first->sizen, second->sizen);
int sn = mini(first->sizen, second->sizen);
-
+
/* compare common mode modulus */
if (memcmp( (first->key)+((first->sizen)-sn),
(second->key)+((second->sizen)-sn), sn) != 0)
return NO;
@@ -464,7 +464,7 @@
buf->s6_addr16[0] = htons(0xfd00 + a);
buf->s6_addr16[1] = htons(b * 256 + c);
buf->s6_addr16[2] = htons(d * 256 + e);
-
+
/* IPv6 /48 subnet number is zero */
buf->s6_addr16[3] = 0;
@@ -562,7 +562,7 @@
*/
/* Bring interface up, like system("sudo ifconfig %s up"); */
-
+
/* not needed, we already have the iface name ... strncpy(ifr.ifr_name,
name, IFNAMSIZ); */
if (ioctl(admin_fd, SIOCGIFFLAGS, &ifr) < 0) {
GE_LOG(ectx, GE_ERROR | GE_BULK | GE_USER, _("Cannot get socket flags
for gnu%d because %s\n"), id, strerror(errno));
@@ -572,7 +572,7 @@
GE_LOG(ectx, GE_ERROR | GE_BULK | GE_USER, _("Cannot set socket
flags for gnu%d because %s\n"), id, strerror(errno));
}
}
-
+
/* Seems to go better with lower mtu, aka system("sudo ifconfig %s mtu
1280") */
ifr.ifr_mtu = 1280;
if (ioctl(admin_fd, SIOCSIFMTU, &ifr) < 0) {
@@ -855,7 +855,7 @@
for (i = 0; i < entries1; i++) {
if (isEqual(sender, &((store1+i)->peer))) {
fd = ((store1+i)->fd);
-
+
(store1+i)->active = YES;
/* We are only allowed one call to write() per packet.
@@ -1335,7 +1335,7 @@
static int makeNonblocking(int handle) {
#if MINGW
u_long mode;
-
+
mode = 1;
if (ioctlsocket(handle,
FIONBIO,
@@ -1394,7 +1394,7 @@
/* system("sudo setpcaps cap_net_admin+eip `pidof gnunetd`"); */
admin_fd = socket(AF_INET6, SOCK_DGRAM, 0);
-
+
GE_LOG(ectx, GE_DEBUG | GE_DEVELOPER | GE_REQUEST, _("`%s' initialising
RFC4913 module %d and %d\n"), "template", CS_PROTO_MAX_USED,
P2P_PROTO_MAX_USED);
GE_LOG(ectx, GE_DEBUG | GE_DEVELOPER | GE_REQUEST, _("RFC4193 my First 4 hex
digits of host id are %x\n"), capi->myIdentity->hashPubKey.bits[0]);
Modified: GNUnet/src/include/gnunet_transport_service.h
===================================================================
--- GNUnet/src/include/gnunet_transport_service.h 2007-07-07 05:03:27 UTC
(rev 5255)
+++ GNUnet/src/include/gnunet_transport_service.h 2007-07-07 05:05:09 UTC
(rev 5256)
@@ -154,7 +154,7 @@
/**
* Get the network address from a HELLO.
*
- * @return OK on success, SYSERR on error
+ * @return OK on success, SYSERR on error
*/
int (*helloToAddress)(const P2P_hello_MESSAGE * hello,
void ** sa,
Modified: GNUnet/src/include/gnunet_util_error.h
===================================================================
--- GNUnet/src/include/gnunet_util_error.h 2007-07-07 05:03:27 UTC (rev
5255)
+++ GNUnet/src/include/gnunet_util_error.h 2007-07-07 05:05:09 UTC (rev
5256)
@@ -228,15 +228,15 @@
/**
* Use this for assertion violations caused by other
* peers (i.e. protocol violations). We do not want to
- * confuse end-users (say, some other peer runs an
+ * confuse end-users (say, some other peer runs an
* older, broken or incompatible GNUnet version), but
- * we still want to see these problems during
+ * we still want to see these problems during
* development and testing. "OP == other peer".
*/
#define GE_BREAK_OP(ctx, cond) do { if (! (cond)) { GE_LOG(ctx, GE_DEVELOPER
| GE_FATAL | GE_IMMEDIATE, _("Internal error: assertion failed at %s:%d in
%s.\n"), __FILE__, __LINE__, __FUNCTION__); } } while(0)
/**
- * Just like GE_BREAK just with file/line/function
+ * Just like GE_BREAK just with file/line/function
* information given as part of the call.
*/
#define GE_BREAK_FLF(ctx, cond, file, line, function) do { if (! (cond)) {
GE_LOG(ctx, GE_DEVELOPER | GE_USER | GE_FATAL | GE_IMMEDIATE, _("Internal
error: assertion failed at %s:%d in %s.\n"), file, line, function); } } while(0)
Modified: GNUnet/src/include/gnunet_util_network.h
===================================================================
--- GNUnet/src/include/gnunet_util_network.h 2007-07-07 05:03:27 UTC (rev
5255)
+++ GNUnet/src/include/gnunet_util_network.h 2007-07-07 05:05:09 UTC (rev
5256)
@@ -527,7 +527,7 @@
* human-readable IP address).
*
* @param sa should be of type "struct sockaddr*"
- */
+ */
char * network_get_ip_as_string(const void * sa,
unsigned int salen,
int do_resolve);
Modified: GNUnet/src/include/gnunet_util_threads.h
===================================================================
--- GNUnet/src/include/gnunet_util_threads.h 2007-07-07 05:03:27 UTC (rev
5255)
+++ GNUnet/src/include/gnunet_util_threads.h 2007-07-07 05:05:09 UTC (rev
5256)
@@ -59,7 +59,7 @@
/**
* How long will we accept locks to be held before
- * reporting that there maybe a problem? Set to
+ * reporting that there maybe a problem? Set to
* zero to disable reporting.
*/
#define REALTIME_LIMIT (000 * cronMILLIS)
Modified: GNUnet/src/server/connection.c
===================================================================
--- GNUnet/src/server/connection.c 2007-07-07 05:03:27 UTC (rev 5255)
+++ GNUnet/src/server/connection.c 2007-07-07 05:05:09 UTC (rev 5256)
@@ -95,7 +95,7 @@
/**
* After 2 minutes on an inactive connection, probe the other
* node with a ping if we have achieved less than 50% of our
- * connectivity goal. Also, messages that are older than
+ * connectivity goal. Also, messages that are older than
* this value are discarded as too old.
*/
#define SECONDS_PINGATTEMPT 120
@@ -882,18 +882,18 @@
unsigned int delta;
load = os_network_monitor_get_load(load_monitor, Upload); /* how much free
bandwidth do we have? */
- if (load >= 150)
- return SYSERR; /* => always drop */
+ if (load >= 150)
+ return SYSERR; /* => always drop */
if (load > 100) {
- if (priority >= EXTREME_PRIORITY)
+ if (priority >= EXTREME_PRIORITY)
return OK; /* allow administrative msgs */
- else
- return SYSERR; /* but nothing else */
+ else
+ return SYSERR; /* but nothing else */
}
if (overhead > 50)
overhead = 50; /* bound */
- if (load <= overhead)
- return OK;
+ if (load <= overhead)
+ return OK;
/* Suppose overhead = 50, then:
Now load in [51, 100]. Between 51% and 100% load:
at 51% require priority >= 1 = (load-50)^3
@@ -1517,7 +1517,7 @@
everything. Since we don't want to possibly
loop forever, give it another shot later;
so even if "ensureTransportConnected" succeded,
- abort for now! */
+ abort for now! */
}
if (YES != ret) {
/* transport's buffer full -- no point in
@@ -2587,7 +2587,7 @@
if (size < sizeof(P2P_PACKET_HEADER)) {
IF_GELOG(ectx,
GE_WARNING | GE_BULK | GE_DEVELOPER,
- hash2enc(&sender->hashPubKey,
+ hash2enc(&sender->hashPubKey,
&enc));
GE_LOG(ectx,
GE_WARNING | GE_BULK | GE_DEVELOPER,
@@ -2597,10 +2597,10 @@
}
if (stats != NULL)
stats->change(stat_received, size);
- hash2enc(&sender->hashPubKey,
+ hash2enc(&sender->hashPubKey,
&enc);
- hash(&msg->sequenceNumber,
- size - sizeof(HashCode512),
+ hash(&msg->sequenceNumber,
+ size - sizeof(HashCode512),
&hc);
if (equalsHashCode512(&hc,
&msg->hash) &&
@@ -2612,12 +2612,12 @@
MUTEX_LOCK(lock);
be = lookForHost(sender);
if ( (be == NULL) ||
- (be->status == STAT_DOWN) ||
+ (be->status == STAT_DOWN) ||
(be->status == STAT_SETKEY_SENT) ) {
#if DEBUG_CONNECTION
IF_GELOG(ectx,
GE_INFO | GE_BULK | GE_DEVELOPER,
- hash2enc(&sender->hashPubKey,
+ hash2enc(&sender->hashPubKey,
&enc));
GE_LOG(ectx,
GE_INFO | GE_BULK | GE_DEVELOPER,
@@ -2638,12 +2638,12 @@
(const INITVECTOR *) &msg->hash, /* IV */
tmp);
hash(tmp, size - sizeof(HashCode512), &hc);
- if (! ( (res != OK) &&
+ if (! ( (res != OK) &&
equalsHashCode512(&hc, &msg->hash) ) ) {
#if DEBUG_CONNECTION
IF_GELOG(ectx,
GE_INFO | GE_BULK | GE_DEVELOPER,
- hash2enc(&sender->hashPubKey,
+ hash2enc(&sender->hashPubKey,
&enc));
GE_LOG(ectx,
GE_INFO | GE_BULK | GE_DEVELOPER,
@@ -2879,7 +2879,7 @@
* @param time updated with the time
* @return SYSERR if we are not connected to the peer at the moment
*/
-int getLastActivityOf(const PeerIdentity * peer,
+int getLastActivityOf(const PeerIdentity * peer,
cron_t * time) {
int ret;
BufferEntry *be;
@@ -3513,8 +3513,8 @@
if ( (getBandwidthAssignedTo(receiver, NULL, NULL) != OK) &&
(identity->isBlacklistedStrict(receiver) == NO) )
session->tryConnect(receiver);
- if (msg == NULL)
- return;
+ if (msg == NULL)
+ return;
len = ntohs(msg->size);
if (len == 0) {
GE_LOG(ectx,
Modified: GNUnet/src/server/gnunet-peer-info.c
===================================================================
--- GNUnet/src/server/gnunet-peer-info.c 2007-07-07 05:03:27 UTC (rev
5255)
+++ GNUnet/src/server/gnunet-peer-info.c 2007-07-07 05:05:09 UTC (rev
5256)
@@ -79,7 +79,7 @@
hello = identity->identity2Hello(id,
proto,
NO);
- if (NULL == hello)
+ if (NULL == hello)
return OK;
addr = NULL;
addr_len = 0;
@@ -91,10 +91,10 @@
info = network_get_ip_as_string(addr,
addr_len,
! no_resolve);
- FREE(addr);
+ FREE(addr);
addr = NULL;
FREENONNULL(info);
- }
+ }
return OK;
}
@@ -152,7 +152,7 @@
! no_resolve);
FREE(addr);
addr = NULL;
- }
+ }
if (info == NULL) {
GE_LOG(ectx,
GE_DEBUG | GE_BULK | GE_USER,
Modified: GNUnet/src/server/gnunet-transport-check.c
===================================================================
--- GNUnet/src/server/gnunet-transport-check.c 2007-07-07 05:03:27 UTC (rev
5255)
+++ GNUnet/src/server/gnunet-transport-check.c 2007-07-07 05:05:09 UTC (rev
5256)
@@ -249,7 +249,7 @@
void * addr;
unsigned int addr_len;
int have_addr;
-
+
have_addr = transport->helloToAddress(xhello,
&addr,
&addr_len);
@@ -260,7 +260,7 @@
addr_len,
YES);
FREE(addr);
- }
+ }
fprintf(stderr,
_("\nContacting `%s'."),
str);
@@ -396,10 +396,10 @@
1, &gnunet_getopt_configure_set_option, "GNUNETD:TRANSPORTS" },
{ 'T', "timeout", "MS",
gettext_noop("specifies after how many MS to time-out"),
- 1, &gnunet_getopt_configure_set_option, "TRANSPORT-CHECK:TIMEOUT" },
+ 1, &gnunet_getopt_configure_set_option, "TRANSPORT-CHECK:TIMEOUT" },
{ 'u', "user", "LOGIN",
gettext_noop("run as user LOGIN"),
- 1, &gnunet_getopt_configure_set_option, "GNUNETD:USER" },
+ 1, &gnunet_getopt_configure_set_option, "GNUNETD:USER" },
COMMAND_LINE_OPTION_VERSION(PACKAGE_VERSION), /* -v */
COMMAND_LINE_OPTION_VERBOSE,
{ 'X', "Xrepeat", "X",
Modified: GNUnet/src/server/gnunet-update.c
===================================================================
--- GNUnet/src/server/gnunet-update.c 2007-07-07 05:03:27 UTC (rev 5255)
+++ GNUnet/src/server/gnunet-update.c 2007-07-07 05:05:09 UTC (rev 5256)
@@ -226,8 +226,8 @@
cfgFilename = DEFAULT_CLIENT_CONFIG_FILE;
return OK;
}
-
+
/**
* All gnunet-update command line options
*/
@@ -241,10 +241,10 @@
COMMAND_LINE_OPTION_LOGGING, /* -L */
{ 'u', "user", "LOGIN",
gettext_noop("run as user LOGIN"),
- 1, &gnunet_getopt_configure_set_option, "GNUNETD:USER" },
+ 1, &gnunet_getopt_configure_set_option, "GNUNETD:USER" },
{ 'U', "client", NULL,
gettext_noop("run in client mode (for getting client configuration
values)"),
- 0, &set_client_config, NULL },
+ 0, &set_client_config, NULL },
COMMAND_LINE_OPTION_VERSION(PACKAGE_VERSION), /* -v */
COMMAND_LINE_OPTION_VERBOSE,
COMMAND_LINE_OPTION_END,
Modified: GNUnet/src/server/handler.c
===================================================================
--- GNUnet/src/server/handler.c 2007-07-07 05:03:27 UTC (rev 5255)
+++ GNUnet/src/server/handler.c 2007-07-07 05:05:09 UTC (rev 5256)
@@ -543,8 +543,8 @@
ret = checkHeader(sender,
(P2P_PACKET_HEADER*) msg,
size);
- if (ret == SYSERR)
- return; /* message malformed */
+ if (ret == SYSERR)
+ return; /* message malformed */
if ( (ret == YES) &&
(tsession != NULL) &&
(sender != NULL) &&
@@ -620,7 +620,7 @@
accepted,
discarded,
blacklisted,
- 1.0 * accepted / (blacklisted + discarded + 1));
+ 1.0 * accepted / (blacklisted + discarded + 1));
if (globalLock_ != NULL)
MUTEX_UNLOCK(globalLock_);
#endif
@@ -648,7 +648,7 @@
accepted,
discarded,
blacklisted,
- 1.0 * accepted / (blacklisted + discarded + 1));
+ 1.0 * accepted / (blacklisted + discarded + 1));
MUTEX_UNLOCK(globalLock_);
#endif
FREE(mp->msg);
@@ -679,7 +679,7 @@
accepted,
discarded,
blacklisted,
- 1.0 * accepted / (blacklisted + discarded + 1));
+ 1.0 * accepted / (blacklisted + discarded + 1));
if (globalLock_ != NULL)
MUTEX_UNLOCK(globalLock_);
#endif
@@ -702,7 +702,7 @@
accepted,
discarded,
blacklisted,
- 1.0 * accepted / (blacklisted + discarded + 1));
+ 1.0 * accepted / (blacklisted + discarded + 1));
#endif
MUTEX_UNLOCK(globalLock_);
SEMAPHORE_UP(bufferQueueRead_);
@@ -784,8 +784,8 @@
SEMAPHORE_DESTROY(bufferQueueWrite_);
bufferQueueWrite_ = NULL;
for (i=0;i<QUEUE_LENGTH;i++) {
- if (bufferQueue_[i] != NULL)
- FREENONNULL(bufferQueue_[i]->msg);
+ if (bufferQueue_[i] != NULL)
+ FREENONNULL(bufferQueue_[i]->msg);
FREENONNULL(bufferQueue_[i]);
}
@@ -829,7 +829,7 @@
i,
time_by_type[i],
time_by_type[i] / count_by_type[i]);
- }
+ }
#endif
}
Modified: GNUnet/src/server/startup.c
===================================================================
--- GNUnet/src/server/startup.c 2007-07-07 05:03:27 UTC (rev 5255)
+++ GNUnet/src/server/startup.c 2007-07-07 05:05:09 UTC (rev 5256)
@@ -63,12 +63,12 @@
if (sig != SERVICE_CONTROL_STOP)
{
SERVICE_STATUS theStat;
-
+
/* Init proper shutdown through the SCM */
if (GNControlService(hService, SERVICE_CONTROL_STOP, &theStat))
{
/* Success */
-
+
/* The Service Control Manager will call
gnunetd.c::ServiceCtrlHandler(), which calls
this function again. We then stop the gnunetd. */
@@ -292,7 +292,7 @@
return OK;
}
-#define CHECK(a,b,c,d,e) if (OK != checkPermission(ectx, cfg, a, b, c, d, e))
return SYSERR;
+#define CHECK(a,b,c,d,e) if (OK != checkPermission(ectx, cfg, a, b, c, d, e))
return SYSERR;
int checkPermissions(struct GE_Context * ectx,
struct GC_Configuration * cfg) {
Modified: GNUnet/src/setup/gnunet-win-tool.c
===================================================================
--- GNUnet/src/setup/gnunet-win-tool.c 2007-07-07 05:03:27 UTC (rev 5255)
+++ GNUnet/src/setup/gnunet-win-tool.c 2007-07-07 05:05:09 UTC (rev 5256)
@@ -174,7 +174,7 @@
unsigned long lMem;
char *pMem;
int iCrc;
-
+
pFile = fopen(szFn, "r+b");
if (!pFile)
{
Modified: GNUnet/src/setup/gtk/gconf.c
===================================================================
--- GNUnet/src/setup/gtk/gconf.c 2007-07-07 05:03:27 UTC (rev 5255)
+++ GNUnet/src/setup/gtk/gconf.c 2007-07-07 05:05:09 UTC (rev 5256)
@@ -297,7 +297,7 @@
gtk_tree_store_remove(model,
&it);
return;
- }
+ }
}
typedef struct {
Modified: GNUnet/src/setup/gtk/wizard_gtk.c
===================================================================
--- GNUnet/src/setup/gtk/wizard_gtk.c 2007-07-07 05:03:27 UTC (rev 5255)
+++ GNUnet/src/setup/gtk/wizard_gtk.c 2007-07-07 05:05:09 UTC (rev 5256)
@@ -163,7 +163,7 @@
char * val;
destroyCurrentWindow();
- curwnd = get_xml("assi_step2");
+ curwnd = get_xml("assi_step2");
cls.cmbNIC = lookup_widget("cmbNIC");
GE_ASSERT(err_ctx, cls.cmbNIC != NULL);
cls.nic_item_count = 0;
@@ -225,7 +225,7 @@
entDown = lookup_widget("entDown");
radGNUnet = lookup_widget("radGNUnet");
radShare = lookup_widget("radShare");
- entCPU = lookup_widget("entCPU");
+ entCPU = lookup_widget("entCPU");
GC_get_configuration_value_string(editCfg,
"LOAD",
"MAXNETUPBPSTOTAL",
@@ -490,7 +490,7 @@
showErr(_("Unable to change startup process:"),
STRERROR(errno));
#endif
- }
+ }
if (OK != save_conf())
return;
Modified: GNUnet/src/setup/lib/tree.c
===================================================================
--- GNUnet/src/setup/lib/tree.c 2007-07-07 05:03:27 UTC (rev 5255)
+++ GNUnet/src/setup/lib/tree.c 2007-07-07 05:05:09 UTC (rev 5256)
@@ -148,7 +148,7 @@
GE_BREAK(NULL, 0);
return SCM_EOL;
}
-
+
/**
* Change the visibility of an entry in the
* tree (and notify listeners about change).
Modified: GNUnet/src/setup/ncurses/mconf.c
===================================================================
--- GNUnet/src/setup/ncurses/mconf.c 2007-07-07 05:03:27 UTC (rev 5255)
+++ GNUnet/src/setup/ncurses/mconf.c 2007-07-07 05:05:09 UTC (rev 5256)
@@ -239,7 +239,7 @@
items = MALLOC(sizeof(DIALOG_LISTITEM) * i);
i = 0;
msel = -1;
-
+
while (val->String.legalRange[i] != NULL) {
items[i].name = "";
items[i].text = val->String.legalRange[i];
@@ -307,7 +307,7 @@
tlen += strlen(val->String.legalRange[i]) + 1;
items[i].help = "";
items[i].state = 0;
-
+
tmp = val->String.val;
while (NULL != (tmp = strstr(tmp,
val->String.legalRange[i]))) {
Modified: GNUnet/src/setup/ncurses/wizard_curs.c
===================================================================
--- GNUnet/src/setup/ncurses/wizard_curs.c 2007-07-07 05:03:27 UTC (rev
5255)
+++ GNUnet/src/setup/ncurses/wizard_curs.c 2007-07-07 05:05:09 UTC (rev
5256)
@@ -58,7 +58,7 @@
static void showCursErr(const char * prefix,
const char * error) {
char * err;
-
+
err = MALLOC(strlen(prefix) + strlen(error) + 2);
sprintf(err,
"%s %s",
@@ -69,7 +69,7 @@
70,
15,
1);
- FREE(err);
+ FREE(err);
}
static void show_help(const char * helptext) {
@@ -104,7 +104,7 @@
dialog_vars.cancel_label = _("No");
dialog_vars.ok_label = _("Yes");
while (true) {
- ret = dialog_yesno(title,
+ ret = dialog_yesno(title,
question,
20,
70);
@@ -493,7 +493,7 @@
showCursErr(_("Unable to create user account for daemon."),
"");
ret = SYSERR;
- }
+ }
if ( (YES == GC_get_configuration_value_yesno(cfg,
"GNUNETD",
"AUTOSTART",
Modified: GNUnet/src/setup/text/conf.c
===================================================================
--- GNUnet/src/setup/text/conf.c 2007-07-07 05:03:27 UTC (rev 5255)
+++ GNUnet/src/setup/text/conf.c 2007-07-07 05:05:09 UTC (rev 5256)
@@ -223,7 +223,7 @@
}
continue;
}
-#endif
+#endif
if ( (buf[i] == 'd') && (i == 0) ) {
printf("%s\n",
val->String.def);
Modified: GNUnet/src/transports/http.c
===================================================================
--- GNUnet/src/transports/http.c 2007-07-07 05:03:27 UTC (rev 5255)
+++ GNUnet/src/transports/http.c 2007-07-07 05:05:09 UTC (rev 5256)
@@ -357,7 +357,7 @@
break;
}
}
- MUTEX_UNLOCK(httplock);
+ MUTEX_UNLOCK(httplock);
if (httpsession->is_client) {
curl_multi_remove_handle(curl_multi,
httpsession->cs.client.get);
@@ -373,7 +373,7 @@
FREE(pos);
pos = next;
}
-
+
} else {
MHD_destroy_response(httpsession->cs.server.get);
}
@@ -1011,7 +1011,7 @@
MUTEX_LOCK(httpSession->lock);
curl_put = create_curl_put(httpSession,
putData,
- size + sizeof(MESSAGE_HEADER));
+ size + sizeof(MESSAGE_HEADER));
if (curl_put == NULL) {
MUTEX_UNLOCK(httpSession->lock);
FREE(putData->msg);
@@ -1020,7 +1020,7 @@
}
putData->curl_put = curl_put;
putData->next = httpSession->cs.client.puts;
- httpSession->cs.client.puts = putData;
+ httpSession->cs.client.puts = putData;
MUTEX_UNLOCK(httpSession->lock);
MUTEX_LOCK(httplock);
mret = curl_multi_add_handle(curl_multi, curl_put);
@@ -1040,10 +1040,10 @@
return OK;
} else { /* httpSession->isClient == false */
MUTEX_LOCK(httpSession->lock);
- if (httpSession->wsize == 0)
+ if (httpSession->wsize == 0)
GROW(httpSession->wbuff,
httpSession->wsize,
- HTTP_BUF_SIZE);
+ HTTP_BUF_SIZE);
if (httpSession->wpos + size > httpSession->wsize) {
/* need to grow or discard */
if (! important) {
@@ -1073,7 +1073,7 @@
msg,
size);
httpSession->wpos += size;
- }
+ }
MUTEX_UNLOCK(httpSession->lock);
return OK;
}
@@ -1084,7 +1084,7 @@
* (completed PUTs, GETs that have timed out,
* etc.).
*/
-static void
+static void
cleanup_connections() {
int i;
HTTPSession * s;
@@ -1100,11 +1100,11 @@
pos = s->cs.client.puts;
while (pos != NULL) {
/* FIXME: check if CURL has timed out
- the GET operation! If so, clean up!
- (and make sure we re-establish GET
+ the GET operation! If so, clean up!
+ (and make sure we re-establish GET
as needed!) */
-
+
if (pos->done) {
if (prev == NULL)
s->cs.client.puts = pos->next;
@@ -1114,7 +1114,7 @@
curl_multi_remove_handle(curl_multi,
pos->curl_put);
curl_easy_cleanup(pos->curl_put);
- FREE(pos);
+ FREE(pos);
if (prev == NULL)
pos = s->cs.client.puts;
else
@@ -1127,14 +1127,14 @@
} else {
/* FIXME: add code to close MHD connection
from the server side (timeout!); need
- to
+ to
A) tell GET callback to return "end of transmission"
B) destroy response object
*/
}
MUTEX_UNLOCK(s->lock);
}
- MUTEX_UNLOCK(httplock);
+ MUTEX_UNLOCK(httplock);
}
static void *
@@ -1285,7 +1285,7 @@
unsigned int * sa_len) {
const HostAddress * haddr = (const HostAddress*) &hello[1];
struct sockaddr_in * serverAddr;
-
+
*sa_len = sizeof(struct sockaddr_in);
serverAddr = MALLOC(sizeof(struct sockaddr_in));
*sa = serverAddr;
Modified: GNUnet/src/transports/ip.c
===================================================================
--- GNUnet/src/transports/ip.c 2007-07-07 05:03:27 UTC (rev 5255)
+++ GNUnet/src/transports/ip.c 2007-07-07 05:05:09 UTC (rev 5256)
@@ -22,7 +22,7 @@
* @file transports/ip.c
* @brief code to determine thep IP of the local machine
* and to do DNS resolution (with caching)
- *
+ *
* @author Christian Grothoff
* @author Tzvetan Horozov
* @author Heikki Lindholm
@@ -83,11 +83,11 @@
static struct MUTEX * lock;
static void expirePICache() {
- struct PICache * pos;
- struct PICache * next;
- struct PICache * prev;
+ struct PICache * pos;
+ struct PICache * next;
+ struct PICache * prev;
cron_t now;
-
+
now = get_time();
pos = pi_head;
prev = NULL;
@@ -109,17 +109,17 @@
/**
* We only have the PeerIdentity. Do we have any
- * clue about the address based on
+ * clue about the address based on
* the "accept" of the connection? Note that the
* response is just the best guess.
- *
+ *
* @param sa set to the address
* @return OK if we found an address, SYSERR if not
*/
int getIPaddressFromPID(const PeerIdentity * peer,
void ** sa,
unsigned int * salen) {
- struct PICache * cache;
+ struct PICache * cache;
MUTEX_LOCK(lock);
expirePICache();
@@ -127,7 +127,7 @@
while (cache != NULL) {
if (0 == memcmp(peer,
&cache->peer,
- sizeof(PeerIdentity))) {
+ sizeof(PeerIdentity))) {
*salen = cache->len;
*sa = MALLOC(cache->len);
memcpy(*sa,
@@ -148,7 +148,7 @@
* a welcome message that claims that this connection
* came from a particular peer. This information is
* NOT validated (and it may well be impossible for
- * us to validate the address).
+ * us to validate the address).
*/
void setIPaddressFromPID(const PeerIdentity * peer,
const void * sa,
@@ -166,7 +166,7 @@
(0 == memcmp(sa,
next->address,
salen)) ) {
- MUTEX_UNLOCK(lock);
+ MUTEX_UNLOCK(lock);
return;
}
FREE(next->address);
@@ -175,8 +175,8 @@
memcpy(next->address,
sa,
salen);
- MUTEX_UNLOCK(lock);
- return;
+ MUTEX_UNLOCK(lock);
+ return;
}
next = next->next;
}
@@ -189,10 +189,10 @@
next->len = salen;
next->expire = get_time() + 12 * cronHOURS;
expirePICache();
- next->next = pi_head;
+ next->next = pi_head;
pi_head = next;
- MUTEX_UNLOCK(lock);
-
+ MUTEX_UNLOCK(lock);
+
}
Modified: GNUnet/src/transports/ip.h
===================================================================
--- GNUnet/src/transports/ip.h 2007-07-07 05:03:27 UTC (rev 5255)
+++ GNUnet/src/transports/ip.h 2007-07-07 05:05:09 UTC (rev 5256)
@@ -51,10 +51,10 @@
/**
* We only have the PeerIdentity. Do we have any
- * clue about the address based on
+ * clue about the address based on
* the "accept" of the connection? Note that the
* response is just the best guess.
- *
+ *
* @param sa set to the address
* @return OK if we found an address, SYSERR if not
*/
@@ -68,7 +68,7 @@
* a welcome message that claims that this connection
* came from a particular peer. This information is
* NOT validated (and it may well be impossible for
- * us to validate the address).
+ * us to validate the address).
*/
void setIPaddressFromPID(const PeerIdentity * peer,
const void * sa,
Modified: GNUnet/src/transports/nat.c
===================================================================
--- GNUnet/src/transports/nat.c 2007-07-07 05:03:27 UTC (rev 5255)
+++ GNUnet/src/transports/nat.c 2007-07-07 05:05:09 UTC (rev 5256)
@@ -61,8 +61,8 @@
static int verifyHello(const P2P_hello_MESSAGE * hello) {
if ( (ntohs(hello->senderAddressSize) != sizeof(HostAddress)) ||
(ntohs(hello->header.size) != P2P_hello_MESSAGE_size(hello)) ||
- (ntohs(hello->header.type) != p2p_PROTO_hello) )
- return SYSERR; /* obviously invalid */
+ (ntohs(hello->header.type) != p2p_PROTO_hello) )
+ return SYSERR; /* obviously invalid */
if (YES == GC_get_configuration_value_yesno(coreAPI->cfg,
"NAT",
"LIMITED",
@@ -75,7 +75,7 @@
return OK;
return SYSERR;
}
- return OK;
+ return OK;
}
/**
Modified: GNUnet/src/transports/tcp.c
===================================================================
--- GNUnet/src/transports/tcp.c 2007-07-07 05:03:27 UTC (rev 5255)
+++ GNUnet/src/transports/tcp.c 2007-07-07 05:05:09 UTC (rev 5256)
@@ -329,9 +329,9 @@
return OK;
}
MUTEX_UNLOCK(session->lock);
- }
+ }
session = session->next;
- }
+ }
MUTEX_UNLOCK(tcplock);
haddr = (HostAddress*) &hello[1];
#if DEBUG_TCP
@@ -475,7 +475,7 @@
&isRejected,
&select_close_handler,
NULL,
- 128 * 1024 /* max memory */,
+ 128 * 1024 /* max memory */,
128 /* max sockets */);
return OK;
}
@@ -493,7 +493,7 @@
if (0 != strcmp(section, "TCP"))
return 0; /* fast path */
-
+
MUTEX_LOCK(tcpblacklistlock);
FREENONNULL(filteredNetworks_);
FREENONNULL(allowedNetworks_);
@@ -532,7 +532,7 @@
unsigned int * sa_len) {
const HostAddress * haddr = (const HostAddress*) &hello[1];
struct sockaddr_in * serverAddr;
-
+
*sa_len = sizeof(struct sockaddr_in);
serverAddr = MALLOC(sizeof(struct sockaddr_in));
*sa = serverAddr;
Modified: GNUnet/src/transports/tcp6.c
===================================================================
--- GNUnet/src/transports/tcp6.c 2007-07-07 05:03:27 UTC (rev 5255)
+++ GNUnet/src/transports/tcp6.c 2007-07-07 05:05:09 UTC (rev 5256)
@@ -281,9 +281,9 @@
return OK;
}
MUTEX_UNLOCK(session->lock);
- }
+ }
session = session->next;
- }
+ }
MUTEX_UNLOCK(tcplock);
haddr = (Host6Address*) &hello[1];
memset(&hints, 0, sizeof(hints));
@@ -489,7 +489,7 @@
unsigned int * sa_len) {
const Host6Address * haddr = (const Host6Address*) &hello[1];
struct sockaddr_in6 * serverAddr;
-
+
*sa_len = sizeof(struct sockaddr_in6);
serverAddr = MALLOC(sizeof(struct sockaddr_in6));
*sa = serverAddr;
Modified: GNUnet/src/transports/tcp_helper.c
===================================================================
--- GNUnet/src/transports/tcp_helper.c 2007-07-07 05:03:27 UTC (rev 5255)
+++ GNUnet/src/transports/tcp_helper.c 2007-07-07 05:05:09 UTC (rev 5256)
@@ -121,7 +121,7 @@
static void freeTCPSession(TCPSession * tcpsession) {
TCPSession * pos;
TCPSession * prev;
-
+
MUTEX_DESTROY(tcpsession->lock);
FREENONNULL(tcpsession->accept_addr);
pos = sessions;
@@ -203,7 +203,7 @@
tcpSession->sock,
TCP_TIMEOUT);
tcpSession->users++;
-
+
MUTEX_UNLOCK(tcpSession->lock);
return OK;
}
@@ -252,7 +252,7 @@
tcpSession->expectingWelcome = NO;
tcpSession->sender = welcome->clientIdentity;
tsession->peer = welcome->clientIdentity;
- if (tcpSession->accept_addr != NULL)
+ if (tcpSession->accept_addr != NULL)
setIPaddressFromPID(&welcome->clientIdentity,
tcpSession->accept_addr,
tcpSession->addr_len);
@@ -280,7 +280,7 @@
MUTEX_UNLOCK(tcplock);
return SYSERR;
}
- if (pos->in_select)
+ if (pos->in_select)
select_disconnect(sh,
pos->sock);
pos->in_select = YES;
@@ -295,15 +295,15 @@
tcpSession->accept_addr = NULL;
tcpSession->addr_len = 0;
tcpDisconnect(tsession);
- tcpSession->in_select = NO;
+ tcpSession->in_select = NO;
freeTCPSession(tcpSession);
tcpSession = pos;
tsession = pos->tsession;
MUTEX_UNLOCK(pos->lock);
break;
- }
+ }
pos = pos->next;
- }
+ }
MUTEX_UNLOCK(tcplock);
} else {
@@ -366,7 +366,7 @@
tcpSession->lock = MUTEX_CREATE(YES);
tcpSession->users = 0;
tcpSession->in_select = YES;
-
+
tsession = MALLOC(sizeof(TSession));
tsession->ttype = TCP_PROTOCOL_NUMBER;
tsession->internal = tcpSession;
@@ -381,7 +381,7 @@
} else {
GE_BREAK(NULL, 0);
tcpSession->addr_len = 0;
- tcpSession->accept_addr = NULL;
+ tcpSession->accept_addr = NULL;
}
MUTEX_LOCK(tcplock);
tcpSession->next = sessions;
@@ -445,7 +445,7 @@
if (tcpSession->in_select == NO) {
#if DEBUG_TCP
EncName enc;
-
+
IF_GELOG(ectx,
GE_DEBUG | GE_DEVELOPER | GE_BULK,
hash2enc(&tcpSession->sender.hashPubKey,
Modified: GNUnet/src/transports/udp.c
===================================================================
--- GNUnet/src/transports/udp.c 2007-07-07 05:03:27 UTC (rev 5255)
+++ GNUnet/src/transports/udp.c 2007-07-07 05:05:09 UTC (rev 5256)
@@ -495,7 +495,7 @@
unsigned int * sa_len) {
const HostAddress * haddr = (const HostAddress*) &hello[1];
struct sockaddr_in * serverAddr;
-
+
*sa_len = sizeof(struct sockaddr_in);
serverAddr = MALLOC(sizeof(struct sockaddr_in));
*sa = serverAddr;
Modified: GNUnet/src/transports/udp6.c
===================================================================
--- GNUnet/src/transports/udp6.c 2007-07-07 05:03:27 UTC (rev 5255)
+++ GNUnet/src/transports/udp6.c 2007-07-07 05:05:09 UTC (rev 5256)
@@ -450,7 +450,7 @@
unsigned int * sa_len) {
const Host6Address * haddr = (const Host6Address*) &hello[1];
struct sockaddr_in6 * serverAddr;
-
+
*sa_len = sizeof(struct sockaddr_in6);
serverAddr = MALLOC(sizeof(struct sockaddr_in6));
*sa = serverAddr;
Modified: GNUnet/src/transports/upnp/upnp.c
===================================================================
--- GNUnet/src/transports/upnp/upnp.c 2007-07-07 05:03:27 UTC (rev 5255)
+++ GNUnet/src/transports/upnp/upnp.c 2007-07-07 05:05:09 UTC (rev 5256)
@@ -167,7 +167,7 @@
int ret;
if (deviceTypeNode == NULL)
- return FALSE;
+ return FALSE;
tmp = xmlnode_get_data(deviceTypeNode);
ret = !strcasecmp(tmp, deviceType);
FREE(tmp);
@@ -182,7 +182,7 @@
int ret;
if (service == NULL)
- return FALSE;
+ return FALSE;
serviceTypeNode = xmlnode_get_child(service, "serviceType");
if(serviceTypeNode == NULL)
return FALSE;
@@ -369,7 +369,7 @@
const char* actionParams,
GaimUtilFetchUrlCallback cb,
void * cb_data) {
- CURL * curl;
+ CURL * curl;
int ret;
char * soapHeader;
char * sizeHeader;
@@ -551,7 +551,7 @@
static int
gaim_upnp_parse_description(char * proxy,
UPnPDiscoveryData * dd) {
- CURL * curl;
+ CURL * curl;
int ret;
if (0 != curl_global_init(CURL_GLOBAL_WIN32))
@@ -751,7 +751,7 @@
int ret;
if (control_info.status != GAIM_UPNP_STATUS_DISCOVERED)
- return NO;
+ return NO;
if (do_add) {
internal_ip = gaim_upnp_get_internal_ip(cfg,
ectx);
Modified: GNUnet/src/transports/upnp/xmlnode.c
===================================================================
--- GNUnet/src/transports/upnp/xmlnode.c 2007-07-07 05:03:27 UTC (rev
5255)
+++ GNUnet/src/transports/upnp/xmlnode.c 2007-07-07 05:05:09 UTC (rev
5256)
@@ -273,7 +273,7 @@
if (child_name != NULL) {
child_name[0] = '\0';
child_name++;
- }
+ }
for(x = parent->child; x; x = x->next) {
const char *xmlns = NULL;
Modified: GNUnet/src/util/config_impl/impl.c
===================================================================
--- GNUnet/src/util/config_impl/impl.c 2007-07-07 05:03:27 UTC (rev 5255)
+++ GNUnet/src/util/config_impl/impl.c 2007-07-07 05:05:09 UTC (rev 5256)
@@ -416,7 +416,7 @@
if (0 == strcmp(section,
data->sections[i].name))
return &data->sections[i];
- return NULL;
+ return NULL;
}
/**
@@ -436,7 +436,7 @@
if (0 == strcmp(key,
sec->entries[i].key))
return &sec->entries[i];
- return NULL;
+ return NULL;
}
static int
Modified: GNUnet/src/util/containers/bloomfilter.c
===================================================================
--- GNUnet/src/util/containers/bloomfilter.c 2007-07-07 05:03:27 UTC (rev
5255)
+++ GNUnet/src/util/containers/bloomfilter.c 2007-07-07 05:05:09 UTC (rev
5256)
@@ -158,7 +158,7 @@
setBit(bitArray, bitIdx);
if (fd == -1)
return;
- /* Update the counter file on disk */
+ /* Update the counter file on disk */
fileSlot = bitIdx / 2;
targetLoc = bitIdx % 2;
@@ -210,7 +210,7 @@
unsigned int low;
unsigned int targetLoc;
- if (fd == -1)
+ if (fd == -1)
return; /* cannot decrement! */
GE_ASSERT(NULL, fd != -1);
/* Each char slot in the counter file holds two 4 bit counters */
@@ -219,10 +219,10 @@
lseek(fd, fileSlot, SEEK_SET);
value = 0;
READ(fd, &value, 1);
-
+
low = value & 0xF;
high = (value & 0xF0) >> 4;
-
+
/* decrement, but once we have reached the max, never go back! */
if (targetLoc == 0) {
if ( (low > 0) && (low < 0xF) )
@@ -440,7 +440,7 @@
if (-1 == bf->fd) {
FREE(bf);
return NULL;
- }
+ }
bf->filename = STRDUP(filename);
} else {
bf->fd = -1;
@@ -461,7 +461,7 @@
pos = 0;
while (pos < size*8) {
int res;
-
+
res = READ(bf->fd,
rbuff,
BUFFSIZE);
@@ -495,7 +495,7 @@
if (NULL == bf)
return;
MUTEX_DESTROY(bf->lock);
- if (bf->fd != -1)
+ if (bf->fd != -1)
disk_file_close(bf->ectx,
bf->filename,
bf->fd);
@@ -517,7 +517,7 @@
memset(bf->bitArray,
0,
bf->bitArraySize);
- if (bf->fd != -1)
+ if (bf->fd != -1)
makeEmptyFile(bf->fd,
bf->bitArraySize * 4);
MUTEX_UNLOCK(bf->lock);
@@ -615,7 +615,7 @@
memset(bf->bitArray,
0,
bf->bitArraySize);
- if (bf->fd != -1)
+ if (bf->fd != -1)
makeEmptyFile(bf->fd,
bf->bitArraySize * 4);
e = iterator(iterator_arg);
Modified: GNUnet/src/util/crypto/kblockkey.c
===================================================================
--- GNUnet/src/util/crypto/kblockkey.c 2007-07-07 05:03:27 UTC (rev 5255)
+++ GNUnet/src/util/crypto/kblockkey.c 2007-07-07 05:05:09 UTC (rev 5256)
@@ -305,7 +305,7 @@
}
if (x)
continue; /* Found a multiple of an already known prime. */
-
+
mpz_add_ui( ptest, prime, step );
if (! mpz_tstbit( ptest, nbits-2 ))
break;
@@ -313,7 +313,7 @@
/* Do a fast Fermat test now. */
mpz_sub_ui( pminus1, ptest, 1);
mpz_powm( result, val_2, pminus1, ptest );
- if ( ( !mpz_cmp_ui( result, 1 ) ) &&
+ if ( ( !mpz_cmp_ui( result, 1 ) ) &&
(is_prime(ptest, 5, hc) ) ) {
/* Got it. */
mpz_clear(val_2);
Modified: GNUnet/src/util/crypto/weakkeytest.c
===================================================================
--- GNUnet/src/util/crypto/weakkeytest.c 2007-07-07 05:03:27 UTC (rev
5255)
+++ GNUnet/src/util/crypto/weakkeytest.c 2007-07-07 05:05:09 UTC (rev
5256)
@@ -163,7 +163,7 @@
}
gcry_cipher_close(handle);
-
+
}
return number_of_weak_keys;
Modified: GNUnet/src/util/disk/storage.c
===================================================================
--- GNUnet/src/util/disk/storage.c 2007-07-07 05:03:27 UTC (rev 5255)
+++ GNUnet/src/util/disk/storage.c 2007-07-07 05:05:09 UTC (rev 5256)
@@ -552,7 +552,7 @@
closedir(dinfo);
return SYSERR;
}
- }
+ }
count++;
}
closedir(dinfo);
@@ -750,16 +750,16 @@
void disk_filename_canonicalize(char *fn) {
char *idx;
char c;
-
+
idx = fn;
while (*idx) {
c = *idx;
-
+
if (c == '/' || c == '\\' || c == ':' || c == '*' || c == '?' ||
c == '"' || c == '<' || c == '>' || c == '|') {
*idx = '_';
}
-
+
idx++;
}
}
Modified: GNUnet/src/util/getopt/printhelp.c
===================================================================
--- GNUnet/src/util/getopt/printhelp.c 2007-07-07 05:03:27 UTC (rev 5255)
+++ GNUnet/src/util/getopt/printhelp.c 2007-07-07 05:05:09 UTC (rev 5256)
@@ -43,7 +43,7 @@
char * scp;
const char * trans;
const struct CommandLineOption * opt;
-
+
printf("%s\n%s\n",
ctx->binaryOptions,
gettext(about));
Modified: GNUnet/src/util/loggers/file.c
===================================================================
--- GNUnet/src/util/loggers/file.c 2007-07-07 05:03:27 UTC (rev 5255)
+++ GNUnet/src/util/loggers/file.c 2007-07-07 05:05:09 UTC (rev 5256)
@@ -194,7 +194,7 @@
/* Remove special chars */
disk_filename_canonicalize(date);
-
+
size = strlen(name) + 82;
ret = MALLOC(size);
SNPRINTF(ret,
@@ -255,8 +255,8 @@
AllocConsole();
SetConsoleTitle(_("GNUnet error log"));
}
-#endif
-
+#endif
+
if (fctx->logdate) {
ret = fprintf(fctx->handle,
"%s %s: %s",
Modified: GNUnet/src/util/network/dns.c
===================================================================
--- GNUnet/src/util/network/dns.c 2007-07-07 05:03:27 UTC (rev 5255)
+++ GNUnet/src/util/network/dns.c 2007-07-07 05:05:09 UTC (rev 5256)
@@ -61,7 +61,7 @@
adns_status ret;
struct IPCache * rec;
int reti;
-
+
if (cache->posted == NO) {
ret = adns_submit_reverse(a_state,
cache->sa,
@@ -70,14 +70,14 @@
adns_qf_none,
#else
0,
-#endif
+#endif
cache,
&cache->query);
if (adns_s_ok == ret)
- cache->posted = YES;
+ cache->posted = YES;
}
adns_processany(a_state);
- answer = NULL;
+ answer = NULL;
reti = adns_check(a_state,
&cache->query,
&answer,
@@ -90,7 +90,7 @@
free(answer);
}
cache->posted = NO;
- }
+ }
#else
#if HAVE_GETNAMEINFO
char hostname[256];
@@ -105,7 +105,7 @@
#else
#if HAVE_GETHOSTBYADDR
struct hostent * ent;
-
+
switch (cache->sa->sa_family) {
case AF_INET:
ent = gethostbyaddr(&((struct sockaddr_in*) cache->sa)->sin_addr,
@@ -121,13 +121,13 @@
ent = NULL;
}
if (ent != NULL)
- cache->addr = STRDUP(ent->h_name);
+ cache->addr = STRDUP(ent->h_name);
#endif
#endif
#endif
}
-static struct IPCache *
+static struct IPCache *
resolve(const struct sockaddr * sa,
unsigned int salen) {
struct IPCache * ret;
@@ -190,19 +190,19 @@
* human-readable IP address).
*
* @param sa should be of type "struct sockaddr*"
- */
+ */
char * network_get_ip_as_string(const void * sav,
unsigned int salen,
int do_resolve) {
const struct sockaddr * sa = sav;
char * ret;
- struct IPCache * cache;
+ struct IPCache * cache;
struct IPCache * prev;
cron_t now;
if (salen < sizeof(struct sockaddr))
return NULL;
- now = get_time();
+ now = get_time();
MUTEX_LOCK(lock);
cache = head;
prev = NULL;
@@ -222,17 +222,17 @@
prev->next = cache->next;
FREENONNULL(cache->addr);
FREE(cache->sa);
- FREE(cache);
+ FREE(cache);
cache = prev->next;
} else {
head = cache->next;
FREENONNULL(cache->addr);
FREE(cache->sa);
- FREE(cache);
+ FREE(cache);
cache = head;
}
continue;
- }
+ }
prev = cache;
cache = cache->next;
}
@@ -253,7 +253,7 @@
MUTEX_UNLOCK(lock);
return no_resolve(sav, salen);
} else
- cache = resolve(sa, salen);
+ cache = resolve(sa, salen);
ret = (cache->addr == NULL) ? NULL : STRDUP(cache->addr);
if (ret == NULL)
ret = no_resolve(sa, salen);
Modified: GNUnet/src/util/network/io.c
===================================================================
--- GNUnet/src/util/network/io.c 2007-07-07 05:03:27 UTC (rev 5255)
+++ GNUnet/src/util/network/io.c 2007-07-07 05:05:09 UTC (rev 5256)
@@ -170,7 +170,7 @@
int doBlock) {
#if MINGW
u_long mode;
-
+
mode = !doBlock;
if (ioctlsocket(s->handle,
FIONBIO, &mode) == SOCKET_ERROR) {
Modified: GNUnet/src/util/network/select.c
===================================================================
--- GNUnet/src/util/network/select.c 2007-07-07 05:03:27 UTC (rev 5255)
+++ GNUnet/src/util/network/select.c 2007-07-07 05:05:09 UTC (rev 5256)
@@ -452,7 +452,7 @@
int s;
void * sctx;
SocketHandle * sock;
- Session * session;
+ Session * session;
size_t size;
int old_errno;
@@ -603,7 +603,7 @@
sh->sessionArrayLength + 4);
sh->sessions[sh->sessionCount++] = session;
}
- }
+ }
} else { /* is_udp == YES */
if ( (sh->listen_sock != NULL) &&
(FD_ISSET(sh->listen_sock->handle, &readSet)) ) {
@@ -611,7 +611,7 @@
int udp_sock;
int error;
socklen_t optlen;
-
+
udp_sock = sh->listen_sock->handle;
lenOfIncomingAddr = sh->max_addr_len;
memset(clientAddr,
@@ -685,7 +685,7 @@
} else {
/* validate msg format! */
const MESSAGE_HEADER * hdr;
-
+
/* if size < pending, set pending to size */
if (size < pending)
pending = size;
@@ -694,7 +694,7 @@
(size >= sizeof(MESSAGE_HEADER)) &&
(ntohs(hdr->size) == size) ) {
void * sctx;
-
+
MUTEX_UNLOCK(sh->lock);
sctx = sh->ah(sh->ah_cls,
sh,
@@ -794,7 +794,7 @@
int handle) {
#if MINGW
DWORD mode;
-
+
mode = PIPE_NOWAIT;
if (SetNamedPipeHandleState((HANDLE) handle, &mode, NULL, NULL))
@@ -1061,7 +1061,7 @@
struct SocketHandle * sock,
void * old_sock_ctx,
void * new_sock_ctx) {
- Session * session;
+ Session * session;
int i;
session = NULL;
@@ -1078,7 +1078,7 @@
GE_ASSERT(NULL,
session->sock_ctx == old_sock_ctx);
session->sock_ctx = new_sock_ctx;
- MUTEX_UNLOCK(sh->lock);
+ MUTEX_UNLOCK(sh->lock);
return OK;
}
@@ -1089,7 +1089,7 @@
int select_connect(struct SelectHandle * sh,
struct SocketHandle * sock,
void * sock_ctx) {
- Session * session;
+ Session * session;
#if DEBUG_SELECT
GE_LOG(sh->ectx,
@@ -1120,7 +1120,7 @@
int i;
for (i=0;i<sh->sessionCount;i++)
- if (sh->sessions[i]->sock == sock)
+ if (sh->sessions[i]->sock == sock)
return sh->sessions[i];
return NULL;
}
Modified: GNUnet/src/util/os/installpath.c
===================================================================
--- GNUnet/src/util/os/installpath.c 2007-07-07 05:03:27 UTC (rev 5255)
+++ GNUnet/src/util/os/installpath.c 2007-07-07 05:05:09 UTC (rev 5256)
@@ -132,7 +132,7 @@
len--;
path[len] = '\0';
}
- }
+ }
}
return path;
}
Modified: GNUnet/src/util/string/string.c
===================================================================
--- GNUnet/src/util/string/string.c 2007-07-07 05:03:27 UTC (rev 5255)
+++ GNUnet/src/util/string/string.c 2007-07-07 05:05:09 UTC (rev 5256)
@@ -135,8 +135,8 @@
unit = _(/* time unit */ " days");
}
}
- }
- }
+ }
+ }
ret = MALLOC(32);
SNPRINTF(ret,
32,
@@ -167,8 +167,8 @@
unit = _(/* size unit */ "TiB");
}
}
- }
- }
+ }
+ }
ret = MALLOC(32);
SNPRINTF(ret,
32,
Modified: GNUnet/src/util/threads/mutex.c
===================================================================
--- GNUnet/src/util/threads/mutex.c 2007-07-07 05:03:27 UTC (rev 5255)
+++ GNUnet/src/util/threads/mutex.c 2007-07-07 05:05:09 UTC (rev 5256)
@@ -146,7 +146,7 @@
end - start,
file,
line);
- }
+ }
if (ret != 0) {
if (ret == EINVAL)
GE_LOG(NULL,
@@ -164,7 +164,7 @@
mutex->locked_file = file;
mutex->locked_line = line;
mutex->locked_time = end;
- }
+ }
}
void MUTEX_UNLOCK(Mutex * mutex) {
Modified: GNUnet/src/util/threads/semaphore.c
===================================================================
--- GNUnet/src/util/threads/semaphore.c 2007-07-07 05:03:27 UTC (rev 5255)
+++ GNUnet/src/util/threads/semaphore.c 2007-07-07 05:05:09 UTC (rev 5256)
@@ -150,7 +150,7 @@
int ret;
cron_t start;
cron_t end;
-
+
GE_ASSERT(NULL, s != NULL);
start = get_time();
GE_ASSERT(NULL,
@@ -175,7 +175,7 @@
end - start,
file,
line);
- }
+ }
return ret;
}
Modified: GNUnet/src/util/win/winproc.c
===================================================================
--- GNUnet/src/util/win/winproc.c 2007-07-07 05:03:27 UTC (rev 5255)
+++ GNUnet/src/util/win/winproc.c 2007-07-07 05:05:09 UTC (rev 5256)
@@ -90,7 +90,7 @@
if (ectx)
pEctx = ectx;
-
+
init = plibc_initialized();
plibc_set_panic_proc(plibc_panic);
ret = plibc_init("GNU", PACKAGE);
| [Prev in Thread] |
Current Thread |
[Next in Thread] |
- [GNUnet-SVN] r5256 - in GNUnet: . src/applications/advertising src/applications/chat src/applications/datastore src/applications/dht/module src/applications/dht/tools src/applications/dstore src/applications/fs/collection src/applications/fs/ecrs src/applications/fs/fsui src/applications/fs/module src/applications/fs/namespace src/applications/fs/tools src/applications/fs/uritrack src/applications/gap src/applications/identity src/applications/kvstore_sqlite src/applications/pingpong src/applications/rpc src/applications/session src/applications/sqstore_mysql src/applications/sqstore_mysql_embedded src/applications/sqstore_sqlite src/applications/stats src/applications/testbed src/applications/testing src/applications/topology_default src/applications/topology_f2f src/applications/tracekit src/applications/transport src/applications/vpn src/include src/server src/setup src/setup/gtk src/setup/lib src/setup/ncurses src/setup/text src/transports src/transports/upnp src/util/config_impl src/util/containers src/util/crypto src/util/disk src/util/getopt src/util/loggers src/util/network src/util/os src/util/string src/util/threads src/util/win,
gnunet <=