import _testcapi
import _interpchannels as _channels
from concurrent.interpreters import _crossinterp

REPLACE = _crossinterp._UNBOUND_CONSTANT_TO_FLAG[_crossinterp.UNBOUND]

# Case 1: _channels.create()
for n in range(1, 20):
    _testcapi.set_nomemory(n, n + 1)
    try:
        cid = _channels.create(REPLACE)
    except MemoryError:
        pass
    except SystemError as exc:
        print(f"[create] n={n}: {type(exc).__name__}: {exc}")
    else:
        _channels.destroy(cid)
    finally:
        _testcapi.remove_mem_hooks()

# Case 2: _channels.close(send=True) on a non-empty channel
for n in range(1, 30):
    cid = _channels.create(REPLACE)
    _channels.send(cid, b"spam", blocking=False)
    _testcapi.set_nomemory(n, n + 1)
    try:
        _channels.close(cid, send=True)
    except MemoryError:
        pass
    except SystemError as exc:
        print(f"[close] n={n}: {type(exc).__name__}: {exc}")
    finally:
        _testcapi.remove_mem_hooks()
        try:
            _channels.close(cid, force=True)
        except Exception:
            pass
        try:
            _channels.destroy(cid)
        except Exception:
            pass