@@ -1541,7 +1541,7 @@ _channels_add(_channels *channels, _PyChannelState *chan)
1541
1541
}
1542
1542
1543
1543
/* forward */
1544
- static int _channel_set_closing (struct _channelref * , PyThread_type_lock );
1544
+ static int _channel_set_closing (_channelref * , PyThread_type_lock );
1545
1545
1546
1546
static int
1547
1547
_channels_close (_channels * channels , int64_t cid , _PyChannelState * * pchan ,
@@ -1736,12 +1736,12 @@ _channels_clear_interpreter(_channels *channels, int64_t interpid)
1736
1736
/* support for closing non-empty channels */
1737
1737
1738
1738
struct _channel_closing {
1739
- struct _channelref * ref ;
1739
+ _channelref * ref ;
1740
1740
};
1741
1741
1742
1742
static int
1743
- _channel_set_closing (struct _channelref * ref , PyThread_type_lock mutex ) {
1744
- struct _channel * chan = ref -> chan ;
1743
+ _channel_set_closing (_channelref * ref , PyThread_type_lock mutex ) {
1744
+ _PyChannelState * chan = ref -> chan ;
1745
1745
if (chan == NULL ) {
1746
1746
// already closed
1747
1747
return 0 ;
@@ -1765,7 +1765,7 @@ _channel_set_closing(struct _channelref *ref, PyThread_type_lock mutex) {
1765
1765
}
1766
1766
1767
1767
static void
1768
- _channel_clear_closing (struct _channel * chan ) {
1768
+ _channel_clear_closing (_PyChannelState * chan ) {
1769
1769
PyThread_acquire_lock (chan -> mutex , WAIT_LOCK );
1770
1770
if (chan -> closing != NULL ) {
1771
1771
GLOBAL_FREE (chan -> closing );
@@ -1775,7 +1775,7 @@ _channel_clear_closing(struct _channel *chan) {
1775
1775
}
1776
1776
1777
1777
static void
1778
- _channel_finish_closing (struct _channel * chan ) {
1778
+ _channel_finish_closing (_PyChannelState * chan ) {
1779
1779
struct _channel_closing * closing = chan -> closing ;
1780
1780
if (closing == NULL ) {
1781
1781
return ;
0 commit comments