diff options
| author | Matthew Sackman <matthew@lshift.net> | 2009-09-01 23:30:44 +0100 |
|---|---|---|
| committer | Matthew Sackman <matthew@lshift.net> | 2009-09-01 23:30:44 +0100 |
| commit | 387533145bbd4e95b46f6bb7e50cde4855bfdeab (patch) | |
| tree | e8fb5379794ef5672ba7195b2ce93a983da201e5 | |
| parent | c97b00e17c066e41256569486d0b7902c766dce5 (diff) | |
| download | rabbitmq-server-git-387533145bbd4e95b46f6bb7e50cde4855bfdeab.tar.gz | |
specs for msg_file
| -rw-r--r-- | src/rabbit_msg_file.erl | 16 |
1 files changed, 16 insertions, 0 deletions
diff --git a/src/rabbit_msg_file.erl b/src/rabbit_msg_file.erl index 70b04c0900..6124b989c6 100644 --- a/src/rabbit_msg_file.erl +++ b/src/rabbit_msg_file.erl @@ -35,6 +35,8 @@ %%---------------------------------------------------------------------------- +-include("rabbit.hrl"). + -define(INTEGER_SIZE_BYTES, 8). -define(INTEGER_SIZE_BITS, (8 * ?INTEGER_SIZE_BYTES)). -define(WRITE_OK_SIZE_BITS, 8). @@ -44,6 +46,20 @@ %%---------------------------------------------------------------------------- +-ifdef(use_specs). + +-spec(append/4 :: (any(), msg_id(), binary(), boolean()) -> + ({'ok', non_neg_integer()} | any())). +-spec(read/2 :: (any(), non_neg_integer()) -> + ({'ok', {msg_id(), binary(), boolean(), non_neg_integer()}} | + any())). +-spec(scan/1 :: (any()) -> {'ok', [{msg_id(), boolean(), non_neg_integer(), + non_neg_integer()}]}). + +-endif. + +%%---------------------------------------------------------------------------- + append(FileHdl, MsgId, MsgBody, IsPersistent) when is_binary(MsgBody) -> BodySize = size(MsgBody), MsgIdBin = term_to_binary(MsgId), |