/dports/databases/postgresql11-client/postgresql-11.14/src/backend/storage/ipc/ |
H A D | shm_mq.c | 288 mqh->mqh_queue = mq; in shm_mq_attach() 292 mqh->mqh_buflen = 0; in shm_mq_attach() 303 return mqh; in shm_mq_attach() 375 res = shm_mq_send_bytes(mqh, sizeof(Size) - mqh->mqh_partial_bytes, in shm_mq_sendv() 612 res = shm_mq_receive_bytes(mqh, sizeof(Size) - mqh->mqh_partial_bytes, in shm_mq_receive() 657 mqh->mqh_buffer = MemoryContextAlloc(mqh->mqh_context, in shm_mq_receive() 668 memcpy(&mqh->mqh_buffer[mqh->mqh_partial_bytes], rawdata, in shm_mq_receive() 678 mqh->mqh_expected_bytes = *(Size *) mqh->mqh_buffer; in shm_mq_receive() 739 mqh->mqh_buffer = MemoryContextAlloc(mqh->mqh_context, newbuflen); in shm_mq_receive() 751 memcpy(&mqh->mqh_buffer[mqh->mqh_partial_bytes], rawdata, rb); in shm_mq_receive() [all …]
|
/dports/databases/postgresql11-docs/postgresql-11.14/src/backend/storage/ipc/ |
H A D | shm_mq.c | 288 mqh->mqh_queue = mq; in shm_mq_attach() 292 mqh->mqh_buflen = 0; in shm_mq_attach() 303 return mqh; in shm_mq_attach() 375 res = shm_mq_send_bytes(mqh, sizeof(Size) - mqh->mqh_partial_bytes, in shm_mq_sendv() 612 res = shm_mq_receive_bytes(mqh, sizeof(Size) - mqh->mqh_partial_bytes, in shm_mq_receive() 657 mqh->mqh_buffer = MemoryContextAlloc(mqh->mqh_context, in shm_mq_receive() 668 memcpy(&mqh->mqh_buffer[mqh->mqh_partial_bytes], rawdata, in shm_mq_receive() 678 mqh->mqh_expected_bytes = *(Size *) mqh->mqh_buffer; in shm_mq_receive() 739 mqh->mqh_buffer = MemoryContextAlloc(mqh->mqh_context, newbuflen); in shm_mq_receive() 751 memcpy(&mqh->mqh_buffer[mqh->mqh_partial_bytes], rawdata, rb); in shm_mq_receive() [all …]
|
/dports/databases/postgresql11-plpython/postgresql-11.14/src/backend/storage/ipc/ |
H A D | shm_mq.c | 288 mqh->mqh_queue = mq; 292 mqh->mqh_buflen = 0; 303 return mqh; 375 res = shm_mq_send_bytes(mqh, sizeof(Size) - mqh->mqh_partial_bytes, 612 res = shm_mq_receive_bytes(mqh, sizeof(Size) - mqh->mqh_partial_bytes, 657 mqh->mqh_buffer = MemoryContextAlloc(mqh->mqh_context, 668 memcpy(&mqh->mqh_buffer[mqh->mqh_partial_bytes], rawdata, 678 mqh->mqh_expected_bytes = *(Size *) mqh->mqh_buffer; 739 mqh->mqh_buffer = MemoryContextAlloc(mqh->mqh_context, newbuflen); 751 memcpy(&mqh->mqh_buffer[mqh->mqh_partial_bytes], rawdata, rb); [all …]
|
/dports/databases/postgresql11-contrib/postgresql-11.14/src/backend/storage/ipc/ |
H A D | shm_mq.c | 288 mqh->mqh_queue = mq; in shm_mq_attach() 292 mqh->mqh_buflen = 0; in shm_mq_attach() 303 return mqh; in shm_mq_attach() 375 res = shm_mq_send_bytes(mqh, sizeof(Size) - mqh->mqh_partial_bytes, in shm_mq_sendv() 612 res = shm_mq_receive_bytes(mqh, sizeof(Size) - mqh->mqh_partial_bytes, in shm_mq_receive() 657 mqh->mqh_buffer = MemoryContextAlloc(mqh->mqh_context, in shm_mq_receive() 668 memcpy(&mqh->mqh_buffer[mqh->mqh_partial_bytes], rawdata, in shm_mq_receive() 678 mqh->mqh_expected_bytes = *(Size *) mqh->mqh_buffer; in shm_mq_receive() 739 mqh->mqh_buffer = MemoryContextAlloc(mqh->mqh_context, newbuflen); in shm_mq_receive() 751 memcpy(&mqh->mqh_buffer[mqh->mqh_partial_bytes], rawdata, rb); in shm_mq_receive() [all …]
|
/dports/databases/postgresql11-plperl/postgresql-11.14/src/backend/storage/ipc/ |
H A D | shm_mq.c | 288 mqh->mqh_queue = mq; in shm_mq_attach() 292 mqh->mqh_buflen = 0; in shm_mq_attach() 303 return mqh; in shm_mq_attach() 375 res = shm_mq_send_bytes(mqh, sizeof(Size) - mqh->mqh_partial_bytes, in shm_mq_sendv() 612 res = shm_mq_receive_bytes(mqh, sizeof(Size) - mqh->mqh_partial_bytes, in shm_mq_receive() 657 mqh->mqh_buffer = MemoryContextAlloc(mqh->mqh_context, in shm_mq_receive() 668 memcpy(&mqh->mqh_buffer[mqh->mqh_partial_bytes], rawdata, in shm_mq_receive() 678 mqh->mqh_expected_bytes = *(Size *) mqh->mqh_buffer; in shm_mq_receive() 739 mqh->mqh_buffer = MemoryContextAlloc(mqh->mqh_context, newbuflen); in shm_mq_receive() 751 memcpy(&mqh->mqh_buffer[mqh->mqh_partial_bytes], rawdata, rb); in shm_mq_receive() [all …]
|
/dports/databases/postgresql11-server/postgresql-11.14/src/backend/storage/ipc/ |
H A D | shm_mq.c | 288 mqh->mqh_queue = mq; in shm_mq_attach() 292 mqh->mqh_buflen = 0; in shm_mq_attach() 303 return mqh; in shm_mq_attach() 375 res = shm_mq_send_bytes(mqh, sizeof(Size) - mqh->mqh_partial_bytes, in shm_mq_sendv() 612 res = shm_mq_receive_bytes(mqh, sizeof(Size) - mqh->mqh_partial_bytes, in shm_mq_receive() 657 mqh->mqh_buffer = MemoryContextAlloc(mqh->mqh_context, in shm_mq_receive() 668 memcpy(&mqh->mqh_buffer[mqh->mqh_partial_bytes], rawdata, in shm_mq_receive() 678 mqh->mqh_expected_bytes = *(Size *) mqh->mqh_buffer; in shm_mq_receive() 739 mqh->mqh_buffer = MemoryContextAlloc(mqh->mqh_context, newbuflen); in shm_mq_receive() 751 memcpy(&mqh->mqh_buffer[mqh->mqh_partial_bytes], rawdata, rb); in shm_mq_receive() [all …]
|
/dports/databases/postgresql11-pltcl/postgresql-11.14/src/backend/storage/ipc/ |
H A D | shm_mq.c | 288 mqh->mqh_queue = mq; in shm_mq_attach() 292 mqh->mqh_buflen = 0; in shm_mq_attach() 303 return mqh; in shm_mq_attach() 375 res = shm_mq_send_bytes(mqh, sizeof(Size) - mqh->mqh_partial_bytes, in shm_mq_sendv() 612 res = shm_mq_receive_bytes(mqh, sizeof(Size) - mqh->mqh_partial_bytes, in shm_mq_receive() 657 mqh->mqh_buffer = MemoryContextAlloc(mqh->mqh_context, in shm_mq_receive() 668 memcpy(&mqh->mqh_buffer[mqh->mqh_partial_bytes], rawdata, in shm_mq_receive() 678 mqh->mqh_expected_bytes = *(Size *) mqh->mqh_buffer; in shm_mq_receive() 739 mqh->mqh_buffer = MemoryContextAlloc(mqh->mqh_context, newbuflen); in shm_mq_receive() 751 memcpy(&mqh->mqh_buffer[mqh->mqh_partial_bytes], rawdata, rb); in shm_mq_receive() [all …]
|
/dports/databases/postgresql14-pltcl/postgresql-14.1/src/backend/storage/ipc/ |
H A D | shm_mq.c | 288 mqh->mqh_queue = mq; in shm_mq_attach() 292 mqh->mqh_buflen = 0; in shm_mq_attach() 303 return mqh; in shm_mq_attach() 375 res = shm_mq_send_bytes(mqh, sizeof(Size) - mqh->mqh_partial_bytes, in shm_mq_sendv() 612 res = shm_mq_receive_bytes(mqh, sizeof(Size) - mqh->mqh_partial_bytes, in shm_mq_receive() 657 mqh->mqh_buffer = MemoryContextAlloc(mqh->mqh_context, in shm_mq_receive() 668 memcpy(&mqh->mqh_buffer[mqh->mqh_partial_bytes], rawdata, in shm_mq_receive() 678 mqh->mqh_expected_bytes = *(Size *) mqh->mqh_buffer; in shm_mq_receive() 739 mqh->mqh_buffer = MemoryContextAlloc(mqh->mqh_context, newbuflen); in shm_mq_receive() 751 memcpy(&mqh->mqh_buffer[mqh->mqh_partial_bytes], rawdata, rb); in shm_mq_receive() [all …]
|
/dports/databases/postgresql14-server/postgresql-14.1/src/backend/storage/ipc/ |
H A D | shm_mq.c | 288 mqh->mqh_queue = mq; in shm_mq_attach() 292 mqh->mqh_buflen = 0; in shm_mq_attach() 303 return mqh; in shm_mq_attach() 375 res = shm_mq_send_bytes(mqh, sizeof(Size) - mqh->mqh_partial_bytes, in shm_mq_sendv() 612 res = shm_mq_receive_bytes(mqh, sizeof(Size) - mqh->mqh_partial_bytes, in shm_mq_receive() 657 mqh->mqh_buffer = MemoryContextAlloc(mqh->mqh_context, in shm_mq_receive() 668 memcpy(&mqh->mqh_buffer[mqh->mqh_partial_bytes], rawdata, in shm_mq_receive() 678 mqh->mqh_expected_bytes = *(Size *) mqh->mqh_buffer; in shm_mq_receive() 739 mqh->mqh_buffer = MemoryContextAlloc(mqh->mqh_context, newbuflen); in shm_mq_receive() 751 memcpy(&mqh->mqh_buffer[mqh->mqh_partial_bytes], rawdata, rb); in shm_mq_receive() [all …]
|
/dports/databases/postgresql14-contrib/postgresql-14.1/src/backend/storage/ipc/ |
H A D | shm_mq.c | 288 mqh->mqh_queue = mq; 292 mqh->mqh_buflen = 0; 303 return mqh; 375 res = shm_mq_send_bytes(mqh, sizeof(Size) - mqh->mqh_partial_bytes, 612 res = shm_mq_receive_bytes(mqh, sizeof(Size) - mqh->mqh_partial_bytes, in SetTypeDiff() 657 mqh->mqh_buffer = MemoryContextAlloc(mqh->mqh_context, in SetTypeDiff() 668 memcpy(&mqh->mqh_buffer[mqh->mqh_partial_bytes], rawdata, in SetTypeDiff() 678 mqh->mqh_expected_bytes = *(Size *) mqh->mqh_buffer; in SetTypeDiff() 739 mqh->mqh_buffer = MemoryContextAlloc(mqh->mqh_context, newbuflen); in SetKind() 751 memcpy(&mqh->mqh_buffer[mqh->mqh_partial_bytes], rawdata, rb); in StartTraverse() [all …]
|
/dports/databases/postgresql14-plpython/postgresql-14.1/src/backend/storage/ipc/ |
H A D | shm_mq.c | 288 mqh->mqh_queue = mq; in shm_mq_attach() 292 mqh->mqh_buflen = 0; in shm_mq_attach() 303 return mqh; in shm_mq_attach() 375 res = shm_mq_send_bytes(mqh, sizeof(Size) - mqh->mqh_partial_bytes, in shm_mq_sendv() 612 res = shm_mq_receive_bytes(mqh, sizeof(Size) - mqh->mqh_partial_bytes, in shm_mq_receive() 657 mqh->mqh_buffer = MemoryContextAlloc(mqh->mqh_context, in shm_mq_receive() 668 memcpy(&mqh->mqh_buffer[mqh->mqh_partial_bytes], rawdata, in shm_mq_receive() 678 mqh->mqh_expected_bytes = *(Size *) mqh->mqh_buffer; in shm_mq_receive() 739 mqh->mqh_buffer = MemoryContextAlloc(mqh->mqh_context, newbuflen); in shm_mq_receive() 751 memcpy(&mqh->mqh_buffer[mqh->mqh_partial_bytes], rawdata, rb); in shm_mq_receive() [all …]
|
/dports/databases/postgresql14-plperl/postgresql-14.1/src/backend/storage/ipc/ |
H A D | shm_mq.c | 288 mqh->mqh_queue = mq; in shm_mq_attach() 292 mqh->mqh_buflen = 0; in shm_mq_attach() 303 return mqh; in shm_mq_attach() 375 res = shm_mq_send_bytes(mqh, sizeof(Size) - mqh->mqh_partial_bytes, in shm_mq_sendv() 612 res = shm_mq_receive_bytes(mqh, sizeof(Size) - mqh->mqh_partial_bytes, in shm_mq_receive() 657 mqh->mqh_buffer = MemoryContextAlloc(mqh->mqh_context, in shm_mq_receive() 668 memcpy(&mqh->mqh_buffer[mqh->mqh_partial_bytes], rawdata, in shm_mq_receive() 678 mqh->mqh_expected_bytes = *(Size *) mqh->mqh_buffer; in shm_mq_receive() 739 mqh->mqh_buffer = MemoryContextAlloc(mqh->mqh_context, newbuflen); in shm_mq_receive() 751 memcpy(&mqh->mqh_buffer[mqh->mqh_partial_bytes], rawdata, rb); in shm_mq_receive() [all …]
|
/dports/databases/postgresql14-docs/postgresql-14.1/src/backend/storage/ipc/ |
H A D | shm_mq.c | 288 mqh->mqh_queue = mq; in shm_mq_attach() 292 mqh->mqh_buflen = 0; in shm_mq_attach() 303 return mqh; in shm_mq_attach() 375 res = shm_mq_send_bytes(mqh, sizeof(Size) - mqh->mqh_partial_bytes, in shm_mq_sendv() 612 res = shm_mq_receive_bytes(mqh, sizeof(Size) - mqh->mqh_partial_bytes, in shm_mq_receive() 657 mqh->mqh_buffer = MemoryContextAlloc(mqh->mqh_context, in shm_mq_receive() 668 memcpy(&mqh->mqh_buffer[mqh->mqh_partial_bytes], rawdata, in shm_mq_receive() 678 mqh->mqh_expected_bytes = *(Size *) mqh->mqh_buffer; in shm_mq_receive() 739 mqh->mqh_buffer = MemoryContextAlloc(mqh->mqh_context, newbuflen); in shm_mq_receive() 751 memcpy(&mqh->mqh_buffer[mqh->mqh_partial_bytes], rawdata, rb); in shm_mq_receive() [all …]
|
/dports/databases/postgresql13-server/postgresql-13.5/src/backend/storage/ipc/ |
H A D | shm_mq.c | 288 mqh->mqh_queue = mq; in shm_mq_attach() 292 mqh->mqh_buflen = 0; in shm_mq_attach() 303 return mqh; in shm_mq_attach() 375 res = shm_mq_send_bytes(mqh, sizeof(Size) - mqh->mqh_partial_bytes, in shm_mq_sendv() 612 res = shm_mq_receive_bytes(mqh, sizeof(Size) - mqh->mqh_partial_bytes, in shm_mq_receive() 657 mqh->mqh_buffer = MemoryContextAlloc(mqh->mqh_context, in shm_mq_receive() 668 memcpy(&mqh->mqh_buffer[mqh->mqh_partial_bytes], rawdata, in shm_mq_receive() 678 mqh->mqh_expected_bytes = *(Size *) mqh->mqh_buffer; in shm_mq_receive() 739 mqh->mqh_buffer = MemoryContextAlloc(mqh->mqh_context, newbuflen); in shm_mq_receive() 751 memcpy(&mqh->mqh_buffer[mqh->mqh_partial_bytes], rawdata, rb); in shm_mq_receive() [all …]
|
/dports/databases/postgresql14-client/postgresql-14.1/src/backend/storage/ipc/ |
H A D | shm_mq.c | 288 mqh->mqh_queue = mq; in shm_mq_attach() 292 mqh->mqh_buflen = 0; in shm_mq_attach() 303 return mqh; in shm_mq_attach() 375 res = shm_mq_send_bytes(mqh, sizeof(Size) - mqh->mqh_partial_bytes, in shm_mq_sendv() 612 res = shm_mq_receive_bytes(mqh, sizeof(Size) - mqh->mqh_partial_bytes, in shm_mq_receive() 657 mqh->mqh_buffer = MemoryContextAlloc(mqh->mqh_context, in shm_mq_receive() 668 memcpy(&mqh->mqh_buffer[mqh->mqh_partial_bytes], rawdata, in shm_mq_receive() 678 mqh->mqh_expected_bytes = *(Size *) mqh->mqh_buffer; in shm_mq_receive() 739 mqh->mqh_buffer = MemoryContextAlloc(mqh->mqh_context, newbuflen); in shm_mq_receive() 751 memcpy(&mqh->mqh_buffer[mqh->mqh_partial_bytes], rawdata, rb); in shm_mq_receive() [all …]
|
/dports/databases/postgresql13-pltcl/postgresql-13.5/src/backend/storage/ipc/ |
H A D | shm_mq.c | 288 mqh->mqh_queue = mq; in shm_mq_attach() 292 mqh->mqh_buflen = 0; in shm_mq_attach() 303 return mqh; in shm_mq_attach() 375 res = shm_mq_send_bytes(mqh, sizeof(Size) - mqh->mqh_partial_bytes, in shm_mq_sendv() 612 res = shm_mq_receive_bytes(mqh, sizeof(Size) - mqh->mqh_partial_bytes, in shm_mq_receive() 657 mqh->mqh_buffer = MemoryContextAlloc(mqh->mqh_context, in shm_mq_receive() 668 memcpy(&mqh->mqh_buffer[mqh->mqh_partial_bytes], rawdata, in shm_mq_receive() 678 mqh->mqh_expected_bytes = *(Size *) mqh->mqh_buffer; in shm_mq_receive() 739 mqh->mqh_buffer = MemoryContextAlloc(mqh->mqh_context, newbuflen); in shm_mq_receive() 751 memcpy(&mqh->mqh_buffer[mqh->mqh_partial_bytes], rawdata, rb); in shm_mq_receive() [all …]
|
/dports/databases/postgresql12-pltcl/postgresql-12.9/src/backend/storage/ipc/ |
H A D | shm_mq.c | 288 mqh->mqh_queue = mq; in shm_mq_attach() 292 mqh->mqh_buflen = 0; in shm_mq_attach() 303 return mqh; in shm_mq_attach() 375 res = shm_mq_send_bytes(mqh, sizeof(Size) - mqh->mqh_partial_bytes, in shm_mq_sendv() 612 res = shm_mq_receive_bytes(mqh, sizeof(Size) - mqh->mqh_partial_bytes, in shm_mq_receive() 657 mqh->mqh_buffer = MemoryContextAlloc(mqh->mqh_context, in shm_mq_receive() 668 memcpy(&mqh->mqh_buffer[mqh->mqh_partial_bytes], rawdata, in shm_mq_receive() 678 mqh->mqh_expected_bytes = *(Size *) mqh->mqh_buffer; in shm_mq_receive() 739 mqh->mqh_buffer = MemoryContextAlloc(mqh->mqh_context, newbuflen); in shm_mq_receive() 751 memcpy(&mqh->mqh_buffer[mqh->mqh_partial_bytes], rawdata, rb); in shm_mq_receive() [all …]
|
/dports/databases/postgresql12-server/postgresql-12.9/src/backend/storage/ipc/ |
H A D | shm_mq.c | 288 mqh->mqh_queue = mq; in ProcArrayAdd() 292 mqh->mqh_buflen = 0; in ProcArrayAdd() 303 return mqh; in ProcArrayAdd() 375 res = shm_mq_send_bytes(mqh, sizeof(Size) - mqh->mqh_partial_bytes, in ProcArrayRemove() 612 res = shm_mq_receive_bytes(mqh, sizeof(Size) - mqh->mqh_partial_bytes, 657 mqh->mqh_buffer = MemoryContextAlloc(mqh->mqh_context, 668 memcpy(&mqh->mqh_buffer[mqh->mqh_partial_bytes], rawdata, 678 mqh->mqh_expected_bytes = *(Size *) mqh->mqh_buffer; 739 mqh->mqh_buffer = MemoryContextAlloc(mqh->mqh_context, newbuflen); 751 memcpy(&mqh->mqh_buffer[mqh->mqh_partial_bytes], rawdata, rb); [all …]
|
/dports/databases/postgresql13-docs/postgresql-13.5/src/backend/storage/ipc/ |
H A D | shm_mq.c | 288 mqh->mqh_queue = mq; 292 mqh->mqh_buflen = 0; 303 return mqh; 375 res = shm_mq_send_bytes(mqh, sizeof(Size) - mqh->mqh_partial_bytes, 612 res = shm_mq_receive_bytes(mqh, sizeof(Size) - mqh->mqh_partial_bytes, 657 mqh->mqh_buffer = MemoryContextAlloc(mqh->mqh_context, 668 memcpy(&mqh->mqh_buffer[mqh->mqh_partial_bytes], rawdata, 678 mqh->mqh_expected_bytes = *(Size *) mqh->mqh_buffer; 739 mqh->mqh_buffer = MemoryContextAlloc(mqh->mqh_context, newbuflen); 751 memcpy(&mqh->mqh_buffer[mqh->mqh_partial_bytes], rawdata, rb); [all …]
|
/dports/databases/postgresql13-contrib/postgresql-13.5/src/backend/storage/ipc/ |
H A D | shm_mq.c | 288 mqh->mqh_queue = mq; in shm_mq_attach() 292 mqh->mqh_buflen = 0; in shm_mq_attach() 303 return mqh; in shm_mq_attach() 375 res = shm_mq_send_bytes(mqh, sizeof(Size) - mqh->mqh_partial_bytes, in shm_mq_sendv() 612 res = shm_mq_receive_bytes(mqh, sizeof(Size) - mqh->mqh_partial_bytes, in shm_mq_receive() 657 mqh->mqh_buffer = MemoryContextAlloc(mqh->mqh_context, in shm_mq_receive() 668 memcpy(&mqh->mqh_buffer[mqh->mqh_partial_bytes], rawdata, in shm_mq_receive() 678 mqh->mqh_expected_bytes = *(Size *) mqh->mqh_buffer; in shm_mq_receive() 739 mqh->mqh_buffer = MemoryContextAlloc(mqh->mqh_context, newbuflen); in shm_mq_receive() 751 memcpy(&mqh->mqh_buffer[mqh->mqh_partial_bytes], rawdata, rb); in shm_mq_receive() [all …]
|
/dports/databases/postgresql12-docs/postgresql-12.9/src/backend/storage/ipc/ |
H A D | shm_mq.c | 288 mqh->mqh_queue = mq; in shm_mq_attach() 292 mqh->mqh_buflen = 0; in shm_mq_attach() 303 return mqh; in shm_mq_attach() 375 res = shm_mq_send_bytes(mqh, sizeof(Size) - mqh->mqh_partial_bytes, in shm_mq_sendv() 612 res = shm_mq_receive_bytes(mqh, sizeof(Size) - mqh->mqh_partial_bytes, in shm_mq_receive() 657 mqh->mqh_buffer = MemoryContextAlloc(mqh->mqh_context, in shm_mq_receive() 668 memcpy(&mqh->mqh_buffer[mqh->mqh_partial_bytes], rawdata, in shm_mq_receive() 678 mqh->mqh_expected_bytes = *(Size *) mqh->mqh_buffer; in shm_mq_receive() 739 mqh->mqh_buffer = MemoryContextAlloc(mqh->mqh_context, newbuflen); in shm_mq_receive() 751 memcpy(&mqh->mqh_buffer[mqh->mqh_partial_bytes], rawdata, rb); in shm_mq_receive() [all …]
|
/dports/databases/postgresql12-contrib/postgresql-12.9/src/backend/storage/ipc/ |
H A D | shm_mq.c | 288 mqh->mqh_queue = mq; in shm_mq_attach() 292 mqh->mqh_buflen = 0; in shm_mq_attach() 303 return mqh; in shm_mq_attach() 375 res = shm_mq_send_bytes(mqh, sizeof(Size) - mqh->mqh_partial_bytes, in shm_mq_sendv() 612 res = shm_mq_receive_bytes(mqh, sizeof(Size) - mqh->mqh_partial_bytes, in shm_mq_receive() 657 mqh->mqh_buffer = MemoryContextAlloc(mqh->mqh_context, in shm_mq_receive() 668 memcpy(&mqh->mqh_buffer[mqh->mqh_partial_bytes], rawdata, in shm_mq_receive() 678 mqh->mqh_expected_bytes = *(Size *) mqh->mqh_buffer; in shm_mq_receive() 739 mqh->mqh_buffer = MemoryContextAlloc(mqh->mqh_context, newbuflen); in shm_mq_receive() 751 memcpy(&mqh->mqh_buffer[mqh->mqh_partial_bytes], rawdata, rb); in shm_mq_receive() [all …]
|
/dports/databases/postgresql12-plperl/postgresql-12.9/src/backend/storage/ipc/ |
H A D | shm_mq.c | 288 mqh->mqh_queue = mq; in shm_mq_attach() 292 mqh->mqh_buflen = 0; in shm_mq_attach() 303 return mqh; in shm_mq_attach() 375 res = shm_mq_send_bytes(mqh, sizeof(Size) - mqh->mqh_partial_bytes, in shm_mq_sendv() 612 res = shm_mq_receive_bytes(mqh, sizeof(Size) - mqh->mqh_partial_bytes, in shm_mq_receive() 657 mqh->mqh_buffer = MemoryContextAlloc(mqh->mqh_context, in shm_mq_receive() 668 memcpy(&mqh->mqh_buffer[mqh->mqh_partial_bytes], rawdata, in shm_mq_receive() 678 mqh->mqh_expected_bytes = *(Size *) mqh->mqh_buffer; in shm_mq_receive() 739 mqh->mqh_buffer = MemoryContextAlloc(mqh->mqh_context, newbuflen); in shm_mq_receive() 751 memcpy(&mqh->mqh_buffer[mqh->mqh_partial_bytes], rawdata, rb); in shm_mq_receive() [all …]
|
/dports/databases/postgresql12-client/postgresql-12.9/src/backend/storage/ipc/ |
H A D | shm_mq.c | 288 mqh->mqh_queue = mq; in shm_mq_attach() 292 mqh->mqh_buflen = 0; in shm_mq_attach() 303 return mqh; in shm_mq_attach() 375 res = shm_mq_send_bytes(mqh, sizeof(Size) - mqh->mqh_partial_bytes, in shm_mq_sendv() 612 res = shm_mq_receive_bytes(mqh, sizeof(Size) - mqh->mqh_partial_bytes, in shm_mq_receive() 657 mqh->mqh_buffer = MemoryContextAlloc(mqh->mqh_context, in shm_mq_receive() 668 memcpy(&mqh->mqh_buffer[mqh->mqh_partial_bytes], rawdata, in shm_mq_receive() 678 mqh->mqh_expected_bytes = *(Size *) mqh->mqh_buffer; in shm_mq_receive() 739 mqh->mqh_buffer = MemoryContextAlloc(mqh->mqh_context, newbuflen); in shm_mq_receive() 751 memcpy(&mqh->mqh_buffer[mqh->mqh_partial_bytes], rawdata, rb); in shm_mq_receive() [all …]
|
/dports/databases/postgresql12-plpython/postgresql-12.9/src/backend/storage/ipc/ |
H A D | shm_mq.c | 288 mqh->mqh_queue = mq; in shm_mq_attach() 292 mqh->mqh_buflen = 0; in shm_mq_attach() 303 return mqh; in shm_mq_attach() 375 res = shm_mq_send_bytes(mqh, sizeof(Size) - mqh->mqh_partial_bytes, in shm_mq_sendv() 612 res = shm_mq_receive_bytes(mqh, sizeof(Size) - mqh->mqh_partial_bytes, in shm_mq_receive() 657 mqh->mqh_buffer = MemoryContextAlloc(mqh->mqh_context, in shm_mq_receive() 668 memcpy(&mqh->mqh_buffer[mqh->mqh_partial_bytes], rawdata, in shm_mq_receive() 678 mqh->mqh_expected_bytes = *(Size *) mqh->mqh_buffer; in shm_mq_receive() 739 mqh->mqh_buffer = MemoryContextAlloc(mqh->mqh_context, newbuflen); in shm_mq_receive() 751 memcpy(&mqh->mqh_buffer[mqh->mqh_partial_bytes], rawdata, rb); in shm_mq_receive() [all …]
|