diff options
author | Bart Polot <bart@net.in.tum.de> | 2014-07-21 00:15:22 +0000 |
---|---|---|
committer | Bart Polot <bart@net.in.tum.de> | 2014-07-21 00:15:22 +0000 |
commit | 2c0aed48a0c9507ea50b1683b7dc1cced822713d (patch) | |
tree | 9b17d1568c50724746f731cbdb45dd9584f41f5e /src/cadet/gnunet-service-cadet_peer.h | |
parent | cd806ab8dc55774a64ed25b453757f2d9569535f (diff) | |
download | gnunet-2c0aed48a0c9507ea50b1683b7dc1cced822713d.tar.gz gnunet-2c0aed48a0c9507ea50b1683b7dc1cced822713d.zip |
- notify about deleted messages when popping messages from a connection, allowing to keep a count and make sure the connection is destroyed
Diffstat (limited to 'src/cadet/gnunet-service-cadet_peer.h')
-rw-r--r-- | src/cadet/gnunet-service-cadet_peer.h | 11 |
1 files changed, 7 insertions, 4 deletions
diff --git a/src/cadet/gnunet-service-cadet_peer.h b/src/cadet/gnunet-service-cadet_peer.h index b7297d101..e581685fa 100644 --- a/src/cadet/gnunet-service-cadet_peer.h +++ b/src/cadet/gnunet-service-cadet_peer.h | |||
@@ -169,17 +169,20 @@ GCP_queue_cancel (struct CadetPeer *peer, struct CadetConnection *c); | |||
169 | /** | 169 | /** |
170 | * Get the first message for a connection and unqueue it. | 170 | * Get the first message for a connection and unqueue it. |
171 | * | 171 | * |
172 | * If the message was the last in the connection and the destruction flag | 172 | * Only tunnel (or higher) level messages are unqueued. Connection specific |
173 | * was set, the connection will be freed by the continuation called by this | 173 | * messages are destroyed and the count given to the caller. |
174 | * function, and @c c will be INVALID after the call. | ||
175 | * | 174 | * |
176 | * @param peer Neighboring peer. | 175 | * @param peer Neighboring peer. |
177 | * @param c Connection. | 176 | * @param c Connection. |
177 | * @param del[out] How many messages have been deleted without returning. | ||
178 | * Can be NULL. | ||
178 | * | 179 | * |
179 | * @return First message for this connection. | 180 | * @return First message for this connection. |
180 | */ | 181 | */ |
181 | struct GNUNET_MessageHeader * | 182 | struct GNUNET_MessageHeader * |
182 | GCP_connection_pop (struct CadetPeer *peer, struct CadetConnection *c); | 183 | GCP_connection_pop (struct CadetPeer *peer, |
184 | struct CadetConnection *c, | ||
185 | unsigned int *del); | ||
183 | 186 | ||
184 | /** | 187 | /** |
185 | * Unlock a possibly locked queue for a connection. | 188 | * Unlock a possibly locked queue for a connection. |